feat(core): 实现文章的发布/取消发布功能 (#2443)

* feat(migration): add isPublished field to posts and notes collections

* feat(note, post): add publish status management for notes and posts

* build(tsup): 添加 import.meta.url 支持

- 在 tsup 配置中添加 platform: 'node' 设置
- 注入 import.meta.url 兼容层，以支持不同模块格式

* build(core): 修改 mx-server 启动脚本路径

* feat(migration): 添加 v8.4.0 版本迁移脚本至history

* feat(core): 修复未认证用户可查看未发布内容的安全问题

- 在 Note 和 Post 模块中添加了对未认证用户的访问限制

* fix(core): 回滚 mx-server 启动脚本路径

* feat(migration): 添加 v8.4.0 数据库脚本以更新 notes 集合字段

* feat(migration): 更新 v8.4.0 修复脚本以重命名 hide 字段并互换其值

* feat(note): 替换 hide 字段为 isPublished，更新相关查询和条件

* feat(note): 将 hide 字段替换为 isPublished，更新相关数据模型

* feat(migration): 添加 v8.4.0 fix2修复脚本以更新 posts 集合中的 isPublished 字段为true

Author: sysfox

apps/core/ecosystem.config.js

@@ -9,7 +9,7 @@ module.exports = {
   apps: [
     {
       name: 'mx-server',
-      script: 'index.js',
+      script: './index.js',
       autorestart: true,
       exec_mode: 'cluster',
       watch: false,

apps/core/src/migration/history.ts

@@ -9,6 +9,9 @@ import v5_0_0__1 from './version/v5.0.0-1'
 import v5_1_1 from './version/v5.1.1'
 import v5_6_0 from './version/v5.6.0'
 import v7_2_1 from './version/v7.2.1'
+import v8_4_0 from './version/v8.4.0'
+import v8_4_0__1 from './version/v8.4.0.fix1'
+import v8_4_0__2 from './version/v8.4.0.fix2'
 
 export default [
   v200Alpha1,
@@ -22,4 +25,7 @@ export default [
   v5_1_1,
   v5_6_0,
   v7_2_1,
+  v8_4_0,
+  v8_4_0__1,
+  v8_4_0__2,
 ]

apps/core/src/migration/version/v8.4.0.fix1.ts

@@ -0,0 +1,39 @@
+//patch for version 8.4.0 v1
+//移除Note中的isPublished字段，并将hide字段重命名为isPublished
+import type { Db } from 'mongodb'
+
+export default (async function v0840Fix1(db: Db) {
+  try {
+    const notesCollection = db.collection('notes')
+
+    // 移除 isPublished 字段
+    await notesCollection.updateMany(
+      {},
+      { $unset: { isPublished: '' } },
+      { upsert: false },
+    )
+
+    // 将 hide 字段重命名为 isPublished, 同时将true与false互换
+    await notesCollection.updateMany(
+      {},
+      [
+        {
+          $set: {
+            isPublished: {
+              $cond: {
+                if: { $eq: ['$hide', true] },
+                then: false,
+                else: true,
+              },
+            },
+          },
+        },
+        { $unset: 'hide' },
+      ],
+      { upsert: false },
+    )
+  } catch (error) {
+    console.error('Migration v8.4.0 Fix1 failed:', error)
+    throw error
+  }
+})

apps/core/src/migration/version/v8.4.0.fix2.ts

@@ -0,0 +1,19 @@
+// patch for version 8.4.0 v2
+// 将Posts中的isPublished字段全部设置为true
+import type { Db } from 'mongodb'
+
+export default (async function v0840Fix2(db: Db) {
+  try {
+    const postsCollection = db.collection('posts')
+
+    // 将 isPublished 字段全部设置为 true
+    await postsCollection.updateMany(
+      {},
+      { $set: { isPublished: true } },
+      { upsert: false },
+    )
+  } catch (error) {
+    console.error('Migration v8.4.0 Fix2 failed:', error)
+    throw error
+  }
+})

apps/core/src/migration/version/v8.4.0.ts

@@ -0,0 +1,26 @@
+// patch for version lower than v8.4.0
+// 本次migration会向posts和notes表中添加一个isPublished字段，默认值为true
+import type { Db } from 'mongodb'
+
+export default (async function v0840(db: Db) {
+  try {
+    const postsCollection = db.collection('posts')
+    const notesCollection = db.collection('notes')
+
+    // 添加 isPublished 字段到 posts 集合
+    await postsCollection.updateMany(
+      {},
+      { $set: { isPublished: true } },
+      { upsert: false },
+    )
+
+    // 添加 isPublished 字段到 notes 集合
+    await notesCollection.updateMany(
+      {},
+      { $set: { isPublished: true } },
+      { upsert: false },
+    )
+  } catch (error) {
+    console.error('Migration to v8.4.0 failed:', error)
+  }
+})

apps/core/src/modules/activity/activity.service.ts

@@ -670,7 +670,7 @@ export class ActivityService implements OnModuleInit, OnModuleDestroy {
       this.databaseService.db
         .collection(NOTE_COLLECTION_NAME)
         .find({
-          hide: false,
+          isPublished: true,
         })
         .sort({
           created: -1,
@@ -722,19 +722,19 @@ export class ActivityService implements OnModuleInit, OnModuleDestroy {
             mood: 1,
             bookmark: 1,
             password: 1,
-            hide: 1,
+            isPublished: 1,
           },
         )
         .lean(),
     ])
     return {
       posts,
       notes: notes.map((note) => {
-        if (note.password || note.hide) {
+        if (note.password || !note.isPublished) {
           note.title = '未公开的日记'
         }
 
-        return omit(note, 'password', 'hide')
+        return omit(note, 'password', 'isPublished')
       }),
     }
   }

apps/core/src/modules/aggregate/aggregate.service.ts

@@ -102,7 +102,7 @@ export class AggregateService {
         this.noteService.model,
         !isAuthenticated
           ? {
-              hide: false,
+              isPublished: true,
               password: undefined,
             }
           : {},
@@ -111,7 +111,7 @@ export class AggregateService {
 
       this.findTop(
         this.postService.model,
-        !isAuthenticated ? { hide: false } : {},
+        !isAuthenticated ? { isPublished: true } : {},
         size,
       )
         .populate('categoryId')
@@ -162,7 +162,7 @@ export class AggregateService {
       this.noteService.model
         .find(
           {
-            hide: false,
+            isPublished: true,
             ...addYearCondition(year),
           },
           '_id nid title weather mood created modified bookmark',
@@ -209,7 +209,7 @@ export class AggregateService {
 
       this.noteService.model
         .find({
-          hide: false,
+          isPublished: true,
 
           $or: [
             {
@@ -258,7 +258,7 @@ export class AggregateService {
     ])
 
     return combineTasks
-      .flat(1)
+      .flat()
       .sort((a, b) => -(a.published_at.getTime() - b.published_at.getTime()))
   }
 
@@ -291,7 +291,7 @@ export class AggregateService {
 
       this.noteService.model
         .find({
-          hide: false,
+          isPublished: true,
           $and: [
             {
               $or: [

apps/core/src/modules/category/category.controller.ts

@@ -46,7 +46,7 @@ export class CategoryController {
   async getCategories(@Query() query: MultiCategoriesQueryDto) {
     const { ids, joint, type = CategoryType.Category } = query // categories is category's mongo id
     if (ids) {
-      const ignoreKeys = '-text -summary -hide -images -commentsIndex'
+      const ignoreKeys = '-text -summary -isPublished -images -commentsIndex'
       if (joint) {
         const map = new Object()
 

apps/core/src/modules/mcp/mcp.service.ts

@@ -94,13 +94,15 @@ export class McpService {
    */
   async getNotes(page = 1, size = 10) {
     const query = this.noteService.model
-      .find({ hide: false })
+      .find({ isPublished: true })
       .sort({ created: -1 })
       .skip((page - 1) * size)
       .limit(size)
 
     const notes = await query.exec()
-    const total = await this.noteService.model.countDocuments({ hide: false })
+    const total = await this.noteService.model.countDocuments({
+      isPublished: true,
+    })
 
     return {
       data: notes,

apps/core/src/modules/note/note.controller.ts

@@ -29,6 +29,7 @@ import {
   NidType,
   NotePasswordQueryDto,
   NoteQueryDto,
+  SetNotePublishStatusDto,
 } from './note.dto'
 import { NoteModel, PartialNoteModel } from './note.model'
 import { NoteService } from './note.service'
@@ -68,8 +69,10 @@ export class NoteController {
   }
 
   @Get(':id')
-  @Auth()
-  async getOneNote(@Param() params: MongoIdDto) {
+  async getOneNote(
+    @Param() params: MongoIdDto,
+    @IsAuthenticated() isAuthenticated: boolean,
+  ) {
     const { id } = params
 
     const current = await this.noteService.model
@@ -82,6 +85,11 @@ export class NoteController {
       throw new CannotFindException()
     }
 
+    // 非认证用户只能查看已发布的手记
+    if (!isAuthenticated && !current.isPublished) {
+      throw new CannotFindException()
+    }
+
     return current
   }
 
@@ -95,9 +103,9 @@ export class NoteController {
     const half = size >> 1
     const { id } = params
     const select = isAuthenticated
-      ? 'nid _id title created hide'
+      ? 'nid _id title created isPublished'
       : 'nid _id title created'
-    const condition = isAuthenticated ? {} : { hide: false }
+    const condition = isAuthenticated ? {} : { isPublished: true }
 
     // 当前文档直接找，不用加条件，反正里面的东西是看不到的
     const currentDocument = await this.noteService.model
@@ -197,7 +205,7 @@ export class NoteController {
   ) {
     const { nid } = params
     const { password, single: isSingle } = query
-    const condition = isAuthenticated ? {} : { hide: false }
+    const condition = isAuthenticated ? {} : { isPublished: true }
     const current: NoteModel | null = await this.noteService.model
       .findOne({
         nid,
@@ -278,8 +286,8 @@ export class NoteController {
       sortOrder,
     } = query
     const condition: FilterQuery<NoteModel> = isAuthenticated
-      ? { $or: [{ hide: false }, { hide: true }] }
-      : { hide: false }
+      ? { $or: [{ isPublished: false }, { isPublished: true }] }
+      : { isPublished: true }
 
     return await this.noteService.getNotePaginationByTopicId(
       id,
@@ -292,4 +300,16 @@ export class NoteController {
       { ...condition },
     )
   }
+
+  @Patch('/:id/publish')
+  @Auth()
+  async setPublishStatus(
+    @Param() params: MongoIdDto,
+    @Body() body: SetNotePublishStatusDto,
+  ) {
+    await this.noteService.updateById(params.id, {
+      isPublished: body.isPublished,
+    })
+    return { success: true }
+  }
 }