Function registerFilesRoutes

packages/server/src/routes/files.ts:73–238

(
  app: FilesRouteHost,
  ix: IInstantiationService,
)

}

export function registerFilesRoutes(
  app: FilesRouteHost,
  ix: IInstantiationService,
): void {

  app.register(multipart, {
    limits: {
      fileSize: DEFAULT_MAX_UPLOAD_BYTES,
      files: 1,
    },
  });

  const uploadRoute = defineRoute(
    {
      method: 'POST',
      path: '/files',
      success: { data: uploadFileResponseSchema },
      consumes: ['multipart/form-data'],
      description: 'Upload a file',
      tags: ['files'],
    },
    async (req, reply) => {
      try {
        const fastifyReq = req as unknown as FastifyRequestLike;
        if (!fastifyReq.file) {
          reply.send(
            errEnvelope(
              ErrorCode.VALIDATION_FAILED,
              'multipart not initialized',
              req.id,
            ),
          );
          return;
        }
        const part = await fastifyReq.file();
        if (!part) {
          reply.send(
            errEnvelope(
              ErrorCode.VALIDATION_FAILED,
              'missing `file` field',
              req.id,
            ),
          );
          return;
        }

        const nameOverride = readFieldString(part.fields['name']);
        const expiresInSec = readFieldNumber(part.fields['expires_in_sec']);

        const store = ix.invokeFunction((a) => a.get(IFileStore));

        const partFile = part.file as NodeJS.ReadableStream & { truncated?: boolean };
        let busboyTruncated = false;
        partFile.on('limit', () => {
          busboyTruncated = true;
        });
        try {
          const meta = await store.save(