Add a mediaController for s3 uploads

src/controllers/api/accounts.ts

@@ -2,7 +2,7 @@ import { type AppController } from '@/app.ts';
 import { type Filter, findReplyTag, z } from '@/deps.ts';
 import * as mixer from '@/mixer.ts';
 import { getAuthor, getFollowedPubkeys, getFollows, syncUser } from '@/queries.ts';
-import { booleanParamSchema } from '@/schema.ts';
+import { booleanParamSchema, fileSchema } from '@/schema.ts';
 import { jsonMetaContentSchema } from '@/schemas/nostr.ts';
 import { toAccount, toRelationship, toStatus } from '@/transformers/nostr-to-mastoapi.ts';
 import { isFollowing, lookupAccount, Time } from '@/utils.ts';
@@ -113,8 +113,6 @@ const accountStatusesController: AppController = async (c) => {
   return paginated(c, events, statuses);
 };
 
-const fileSchema = z.custom<File>((value) => value instanceof File);
-
 const updateCredentialsSchema = z.object({
   display_name: z.string().optional(),
   note: z.string().optional(),

src/controllers/api/media.ts

@@ -0,0 +1,35 @@
+import { AppController } from '@/app.ts';
+import { Conf } from '@/config.ts';
+import { S3Client, z } from '@/deps.ts';
+import { fileSchema } from '@/schema.ts';
+import { parseBody } from '@/utils/web.ts';
+
+const s3 = new S3Client({ ...Conf.s3 });
+
+const mediaBodySchema = z.object({
+  file: fileSchema.refine((file) => !!file.type),
+  thumbnail: fileSchema.optional(),
+  description: z.string().optional(),
+  focus: z.string().optional(),
+});
+
+const mediaController: AppController = async (c) => {
+  const result = mediaBodySchema.safeParse(await parseBody(c.req.raw));
+
+  if (!result.success) {
+    return c.json({ error: 'Bad request.', schema: result.error }, 422);
+  }
+
+  const { file } = result.data;
+
+  try {
+    await s3.putObject('test', file.stream());
+  } catch (e) {
+    console.error(e);
+    return c.json({ error: 'Failed to upload file.' }, 500);
+  }
+
+  return c.json({});
+};
+
+export { mediaController };