uses valibot to check body schema

Author: fatfingers23

app/composables/useAtproto.ts

@@ -1,7 +1,6 @@
 import { ERROR_NEED_REAUTH } from '#imports'
 import type { FetchError } from 'ofetch'
 import type { UserSession } from '#shared/schemas/userSession'
-import type { PackageLikes } from '#server/utils/atproto/utils/likes'
 
 export async function authRedirect(identifier: string, create: boolean = false) {
   let query = { handle: identifier } as {}

server/api/auth/social/like.delete.ts

@@ -1,5 +1,7 @@
+import * as v from 'valibot'
 import { Client } from '@atproto/lex'
 import * as dev from '#shared/types/lexicons/dev'
+import { PackageLikeBodySchema } from '#shared/schemas/social'
 import { throwOnMissingOAuthScope } from '#server/utils/atproto/oauth'
 
 export default eventHandlerWithOAuthSession(async (event, oAuthSession) => {
@@ -12,14 +14,7 @@ export default eventHandlerWithOAuthSession(async (event, oAuthSession) => {
   //Checks if the user has a scope to like packages
   await throwOnMissingOAuthScope(oAuthSession, LIKES_SCOPE)
 
-  const body = await readBody<{ packageName: string }>(event)
-
-  if (!body.packageName) {
-    throw createError({
-      status: 400,
-      message: 'packageName is required',
-    })
-  }
+  const body = v.parse(PackageLikeBodySchema, await readBody(event))
 
   const likesUtil = new PackageLikesUtils()
 

server/api/auth/social/like.post.ts

@@ -1,7 +1,9 @@
+import * as v from 'valibot'
 import { Client } from '@atproto/lex'
 import * as dev from '#shared/types/lexicons/dev'
 import type { UriString } from '@atproto/lex'
 import { LIKES_SCOPE } from '#shared/utils/constants'
+import { PackageLikeBodySchema } from '#shared/schemas/social'
 import { throwOnMissingOAuthScope } from '~~/server/utils/atproto/oauth'
 
 export default eventHandlerWithOAuthSession(async (event, oAuthSession) => {
@@ -14,14 +16,7 @@ export default eventHandlerWithOAuthSession(async (event, oAuthSession) => {
   //Checks if the user has a scope to like packages
   await throwOnMissingOAuthScope(oAuthSession, LIKES_SCOPE)
 
-  const body = await readBody<{ packageName: string }>(event)
-
-  if (!body.packageName) {
-    throw createError({
-      status: 400,
-      message: 'packageName is required',
-    })
-  }
+  const body = v.parse(PackageLikeBodySchema, await readBody(event))
 
   const likesUtil = new PackageLikesUtils()
 

shared/schemas/social.ts

@@ -0,0 +1,11 @@
+import * as v from 'valibot'
+import { PackageNameSchema } from './package'
+
+/**
+ * Schema for liking/unliking a package
+ */
+export const PackageLikeBodySchema = v.object({
+  packageName: PackageNameSchema,
+})
+
+export type PackageLikeBody = v.InferOutput<typeof PackageLikeBodySchema>