Feature/ Add series to link related articles

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),

app/(app)/create/[[...paramsArr]]/_client.tsx

@@ -160,6 +160,13 @@ const Create = () => {
  isSuccess,
  } = api.post.create.useMutation();
 
+ const { mutate: seriesUpdate, status: seriesStatus } = api.series.update.useMutation({
+ onError(error) {
+ toast.error("Error updating series");
+ Sentry.captureException(error);
+ }
+ });
+
  // TODO get rid of this for standard get post
  // Should be allowed get draft post through regular mechanism if you own it
  const {
@@ -215,6 +222,7 @@ const Create = () => {
  tags,
  canonicalUrl: data.canonicalUrl || undefined,
  excerpt: data.excerpt || removeMarkdown(data.body, {}).substring(0, 155),
+ seriesName: data.seriesName || undefined
  };
  return formData;
  };
@@ -226,8 +234,30 @@ const Create = () => {
  if (!formData.id) {
  await create({ ...formData });
  } else {
- await save({ ...formData, id: postId });
- toast.success("Saved");
+ let saveSuccess = false;
+ try {
+ await save({ ...formData, id: postId });
+ saveSuccess = true;
+ } catch (error) {
+ toast.error("Error saving post.");
+ Sentry.captureException(error);
+ }
+
+ let seriesUpdateSuccess = false;
+ try {
+ if(formData?.seriesName){
+ await seriesUpdate({ postId, seriesName: formData.seriesName });
+ }
+ seriesUpdateSuccess = true;
+ } catch (error) {
+ toast.error("Error updating series.");
+ Sentry.captureException(error);
+ }
+
+ if(saveSuccess && seriesUpdateSuccess){
+ toast.success("Saved");
+ }
+
  setSavedTime(
  new Date().toLocaleString(undefined, {
  dateStyle: "medium",
@@ -539,10 +569,24 @@ const Create = () => {
  {copied ? "Copied" : "Copy Link"}
  </div>
  </button>
- <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ <p className="mt-2 mb-2 text-sm text-neutral-600 dark:text-neutral-400">
  Share this link with others to preview your
  draft. Anyone with the link can view your draft.
  </p>
+
+ <label htmlFor="seriesName">
+ Series Name
+ </label>
+ <input
+ id="seriesName"
+ type="text"
+ placeholder="The name of my series"
+ defaultValue={data?.series?.title || ""}
+ {...register("seriesName")}
+ />
+ <p className="mt-2 text-sm text-neutral-600 dark:text-neutral-400">
+ This text is case-sensitive so make sure you type it exactly as you did in previous articles to ensure they are connected
+ </p>
  </DisclosurePanel>
  </>
  )}

drizzle/0011_add_series_update_post.sql

@@ -0,0 +1,16 @@
+-- Create Series table
+CREATE TABLE IF NOT EXISTS "Series" (
+ "id" SERIAL PRIMARY KEY,
+ "title" TEXT NOT NULL,
+ "description" TEXT,
+ "userId" TEXT NOT NULL,
+ "createdAt" TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL
+);
+-- Update Post table to add seriesId column
+ALTER TABLE "Post"
+ADD COLUMN "seriesId" INTEGER
+ADD CONSTRAINT fk_post_series
+ FOREIGN KEY ("seriesId")
+ REFERENCES "Series" ("id")
+ ON DELETE SET NULL;

schema/post.ts

@@ -25,6 +25,7 @@ export const SavePostSchema = z.object({
  canonicalUrl: z.optional(z.string().trim().url()),
  tags: z.string().array().max(5).optional(),
  published: z.string().datetime().optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const PublishPostSchema = z.object({
@@ -50,6 +51,7 @@ export const ConfirmPostSchema = z.object({
  .optional(),
  canonicalUrl: z.string().trim().url().optional(),
  tags: z.string().array().max(5).optional(),
+ seriesName: z.string().trim().optional()
 });
 
 export const DeletePostSchema = z.object({

schema/series.ts

@@ -0,0 +1,6 @@
+import z from "zod";
+
+export const UpdateSeriesSchema = z.object({
+ postId: z.string(),
+ seriesName: z.string().trim().optional()
+});

server/api/router/index.ts

@@ -8,6 +8,8 @@ import { adminRouter } from "./admin";
 import { reportRouter } from "./report";
 import { tagRouter } from "./tag";
 
+import { seriesRouter } from "./series";
+
 export const appRouter = createTRPCRouter({
  post: postRouter,
  profile: profileRouter,
@@ -16,6 +18,7 @@ export const appRouter = createTRPCRouter({
  admin: adminRouter,
  report: reportRouter,
  tag: tagRouter,
+ series: seriesRouter
 });
 
 // export type definition of API

server/api/router/post.ts

@@ -14,7 +14,7 @@ import {
  GetLimitSidePosts,
 } from "../../../schema/post";
 import { removeMarkdown } from "../../../utils/removeMarkdown";
-import { bookmark, like, post, post_tag, tag, user } from "@/server/db/schema";
+import { bookmark, like, post, post_tag, tag, user, series } from "@/server/db/schema";
 import {
  and,
  eq,
@@ -187,12 +187,29 @@ export const postRouter = createTRPCRouter({
  });
  }
 
- const [deletedPost] = await ctx.db
- .delete(post)
- .where(eq(post.id, id))
- .returning();
+ const deletedPost = await ctx.db.transaction(async (tx) => {
+ const [deletedPost] = await tx
+ .delete(post)
+ .where(eq(post.id, id))
+ .returning();
+
+ if(deletedPost.seriesId){
+ // check is there is any other post with the current seriesId
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq }) => 
+ eq(post.seriesId, deletedPost.seriesId!)
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, deletedPost.seriesId));
+ }
+ }
+
+ return deletedPost;
+ });
 
-return deletedPost;
+ return deletedPost;
  }),
  like: protectedProcedure
  .input(LikePostSchema)
@@ -428,6 +445,7 @@ export const postRouter = createTRPCRouter({
  where: (posts, { eq }) => eq(posts.id, id),
  with: {
  tags: { with: { tag: true } },
+ series: true
  },
  });
 

server/api/router/series.ts

@@ -0,0 +1,129 @@
+import { TRPCError } from "@trpc/server";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+import { series, post } from "@/server/db/schema";
+import { UpdateSeriesSchema } from "@/schema/series";
+import {eq} from "drizzle-orm";
+export const seriesRouter = createTRPCRouter({
+ update: protectedProcedure
+ .input(UpdateSeriesSchema)
+ .mutation(async ({input, ctx}) => {
+ const {postId, seriesName} = input;
+
+ if (seriesName && seriesName.trim() === "") {
+ throw new TRPCError({ code: 'BAD_REQUEST', message: 'Series name cannot be empty' });
+ }
+
+ const currentPost = await ctx.db.query.post.findFirst({
+ columns: {
+ id: true,
+ seriesId: true,
+ userId: true
+ },
+ with: {
+ series: {
+ columns: {
+ id: true,
+ title: true
+ },
+ },
+ },
+ where: (post, { eq }) => eq(post.id, postId),
+ });
+
+ if (!currentPost) {
+ throw new TRPCError({ code: 'NOT_FOUND' });
+ }
+ if (currentPost?.userId !== ctx.session.user.id) {
+ throw new TRPCError({
+ code: "FORBIDDEN",
+ });
+ }
+ const createNewSeries = async (seriesTitle: string) => {
+ // check if a series with that name already exists
+ // or else create a new one
+ return await ctx.db.transaction(async (tx) => {
+ let seriesId : number;
+ const currSeries = await tx.query.series.findFirst({
+ columns: {
+ id: true
+ },
+ where: (series, { eq }) => eq(series.title, seriesTitle),
+ })
+
+ if(!currSeries){
+ const [newSeries] = await tx.insert(series).values({
+ title: seriesTitle, 
+ userId: ctx.session.user.id,
+ updatedAt: new Date() 
+ }).returning();
+
+ seriesId = newSeries.id;
+ }
+ else{
+ seriesId = currSeries.id;
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: seriesId
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+
+ }
+
+ const unlinkSeries = async (seriesId: number) => {
+ // Check if the user has added a another post with the same series id previously
+ return await ctx.db.transaction(async (tx) =>{
+ const anotherPostInThisSeries = await tx.query.post.findFirst({
+ where: (post, { eq, and, ne }) => 
+ and (
+ ne(post.id, currentPost.id),
+ eq(post.seriesId, currentPost.seriesId!)
+ )
+ })
+ // if another post with the same seriesId is present, then do nothing
+ // else remove the series from the series table
+ if(!anotherPostInThisSeries){
+ await tx.delete(series).where(eq(series.id, seriesId));
+ }
+ // update that series id in the current post
+ await tx
+ .update(post)
+ .set({
+ seriesId: null
+ })
+ .where(eq(post.id, currentPost.id));
+ })
+ }
+
+ if(seriesName){
+ // check if the current post is already linked to a series
+ if(currentPost?.seriesId){
+ // check if the series title is same as the current series name
+ // then we do nothing
+ if(currentPost?.series?.title !== seriesName){
+ // then the user has updated the series name in this particular edit
+ // Check if there is another post with the same title, else delete the series
+ // and create a new post with the new series name
+ // and update that new series id in the post
+ await unlinkSeries(currentPost.seriesId);
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // the current post is not yet linked to a seriesId
+ // so create a new series and put that Id in the post
+ await createNewSeries(seriesName);
+ }
+ }
+ else{
+ // either the user has not added the series Name (We do nothing)
+ // or while editing the post, the user has removed the series name
+ if(currentPost.seriesId !== null){
+ await unlinkSeries(currentPost.seriesId);
+ }
+ } 
+ })
+})

server/db/schema.ts

@@ -35,6 +35,26 @@ export const sessionRelations = relations(session, ({ one }) => ({
  }),
 }));
 
+export const series = pgTable("Series", {
+ id: serial("id").primaryKey(),
+ title: text("title").notNull(),
+ description: text("description"),
+ userId: text("userId").notNull().references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
+ createdAt: timestamp("createdAt", {
+ precision: 3,
+ mode: "string",
+ withTimezone: true,
+ })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updatedAt", {
+ precision: 3,
+ withTimezone: true
+ }).notNull()
+ .$onUpdate(() => new Date())
+ .default(sql`CURRENT_TIMESTAMP`),
+})
+
 export const account = pgTable(
  "account",
  {
@@ -149,6 +169,7 @@ export const post = pgTable(
  .references(() => user.id, { onDelete: "cascade", onUpdate: "cascade" }),
  showComments: boolean("showComments").default(true).notNull(),
  likes: integer("likes").default(0).notNull(),
+ seriesId: integer("seriesId").references(() => series.id, { onDelete: "set null", onUpdate: "cascade" }),
  },
  (table) => {
  return {
@@ -168,6 +189,7 @@ export const postRelations = relations(post, ({ one, many }) => ({
  notifications: many(notification),
  user: one(user, { fields: [post.userId], references: [user.id] }),
  tags: many(post_tag),
+ series: one(series,{ fields: [post.seriesId], references: [series.id] }),
 }));
 
 export const user = pgTable(
@@ -273,6 +295,14 @@ export const bookmark = pgTable(
  },
 );
 
+export const seriesRelations = relations(series, ({ one, many }) => ({
+ posts: many(post),
+ user: one(user, {
+ fields: [series.userId],
+ references: [user.id],
+ }),
+}));
+
 export const bookmarkRelations = relations(bookmark, ({ one, many }) => ({
  post: one(post, { fields: [bookmark.postId], references: [post.id] }),
  user: one(user, { fields: [bookmark.userId], references: [user.id] }),