feat(SW-160): update profile

server/trpc.ts

@@ -1,4 +1,6 @@
 import { initTRPC } from "@trpc/server"
+import { experimental_nextAppDirCaller } from "@trpc/server/adapters/next-app-dir"
+import { ZodError } from "zod"
 
 import { env } from "@/env/server"
 
@@ -9,15 +11,30 @@ import {
   unauthorizedError,
 } from "./errors/trpc"
 import { fetchServiceToken } from "./tokenManager"
+import { type Context, createContext } from "./context"
 import { transformer } from "./transformer"
 import { langInput } from "./utils"
 
 import type { Session } from "next-auth"
 
 import type { Meta } from "@/types/trpc/meta"
-import type { Context } from "./context"
 
-const t = initTRPC.context<Context>().meta<Meta>().create({ transformer })
+const t = initTRPC
+  .context<Context>()
+  .meta<Meta>()
+  .create({
+    transformer,
+    errorFormatter({ shape, error }) {
+      return {
+        ...shape,
+        data: {
+          ...shape.data,
+          zodError:
+            error.cause instanceof ZodError ? error.cause.flatten() : null,
+        },
+      }
+    },
+  })
 
 export const { createCallerFactory, mergeRouters, router } = t
 export const publicProcedure = t.procedure
@@ -113,3 +130,30 @@ export const serviceProcedure = t.procedure.use(async (opts) => {
     },
   })
 })
+
+export const serverActionProcedure = t.procedure.experimental_caller(
+  experimental_nextAppDirCaller({
+    createContext,
+    normalizeFormData: true,
+  })
+)
+
+export const protectedServerActionProcedure = serverActionProcedure.use(
+  async (opts) => {
+    const session = await opts.ctx.auth()
+    if (!session) {
+      throw unauthorizedError()
+    }
+
+    if (session && session.error === "RefreshAccessTokenError") {
+      throw sessionExpiredError()
+    }
+
+    return opts.next({
+      ctx: {
+        ...opts.ctx,
+        session,
+      },
+    })
+  }
+)