1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21

// src/db/schema.ts

export const cmsEntryVersionTable = sqliteTable("cms_entry_versions", {
  id: text("id").primaryKey(),
  entryId: text("entry_id")
    .notNull()
    .references(() => cmsEntryTable.id),
  versionNumber: integer("version_number").notNull(),
  title: text("title").notNull(),
  content: text("content").notNull(), // JSON 格式的 Tiptap 内容
  slug: text("slug"),
  excerpt: text("excerpt"),
  seoTitle: text("seo_title"),
  seoDescription: text("seo_description"),
  status: text("status", { enum: ["draft", "published"] }).notNull(),
  createdBy: text("created_by").notNull(),
  changeDescription: text("change_description"),
  createdAt: integer("created_at", { mode: "timestamp" })
    .notNull()
    .$defaultFn(() => new Date()),
});

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

// src/lib/cms/cms-repository.ts

export async function updateCmsEntry(
  entryId: string,
  data: UpdateCmsEntryInput,
  userId: string
) {
  const db = getDB();

  // 获取当前版本以确定新版本号
  const currentEntry = await db.query.cmsEntryTable.findFirst({
    where: eq(cmsEntryTable.id, entryId),
  });

  const newVersionNumber = (currentEntry?.version || 0) + 1;

  // 创建版本快照
  await db.insert(cmsEntryVersionTable).values({
    entryId,
    versionNumber: newVersionNumber,
    title: data.title ?? currentEntry?.title ?? "",
    content: data.content ?? currentEntry?.content ?? "",
    slug: data.slug ?? currentEntry?.slug,
    excerpt: data.excerpt ?? currentEntry?.excerpt,
    seoTitle: data.seoTitle ?? currentEntry?.seoTitle,
    seoDescription: data.seoDescription ?? currentEntry?.seoDescription,
    status: data.status ?? currentEntry?.status ?? "draft",
    createdBy: userId,
    changeDescription: data.changeDescription,
  });

  // 更新 Entry
  await db
    .update(cmsEntryTable)
    .set({
      ...data,
      version: newVersionNumber,
      updatedAt: new Date(),
    })
    .where(eq(cmsEntryTable.id, entryId));
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

// src/app/(admin)/admin/cms/[collection]/_components/version-history.tsx

import { diffLines } from "diff/lib/diff/line.js";

function createContentDiff({
  currentContent,
  selectedContent,
}: {
  currentContent: JSONContent;
  selectedContent: JSONContent;
}) {
  return createUnifiedDiff({
    currentValue: contentToMarkdown(currentContent),
    selectedValue: contentToMarkdown(selectedContent),
  });
}

function createUnifiedDiff({
  currentValue,
  selectedValue,
}: {
  currentValue: string;
  selectedValue: string;
}): LocalDiff {
  const changes = diffLines(currentValue, selectedValue);

  const lines: DiffLine[] = changes.map((change) => {
    if (change.added) {
      return { id: createId(), segments: [{ type: "changed", value: change.value }], type: "added" };
    } else if (change.removed) {
      return { id: createId(), segments: [{ type: "changed", value: change.value }], type: "removed" };
    } else {
      return { id: createId(), segments: [{ type: "unchanged", value: change.value }], type: "context" };
    }
  });

  return {
    hasChanges: changes.some((c) => c.added || c.removed),
    lines,
  };
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

// src/app/(admin)/admin/cms/_actions/version-actions.ts

export const revertCmsEntryVersionAction = actionClient
  .inputSchema(v.object({
    entryId: v.string(),
    versionId: v.string(),
  }))
  .action(async ({ parsedInput: input }) => {
    await requireAdmin();

    const updatedEntry = await revertCmsEntryToVersion({
      entryId: input.entryId,
      versionId: input.versionId,
    });

    return updatedEntry;
  });