feat: management test (WIP)

Author: ssut

apps/server/src/index.ts

@@ -2,6 +2,7 @@ import { OpenAPIHono } from "@hono/zod-openapi";
 import { Hono } from "hono";
 import { prettyJSON } from "hono/pretty-json";
 import { secureHeaders } from "hono/secure-headers";
+import { authMiddleware } from "./middleware/auth";
 import { corsMiddleware } from "./middleware/cors";
 import { logging } from "./middleware/logging";
 import { acquisitionRouter } from "./routes/acquisition";

apps/server/src/routes/management.ts

@@ -1,6 +1,7 @@
 import { OpenAPIHono, createRoute } from "@hono/zod-openapi";
 import { HTTPException } from "hono/http-exception";
 import { z } from "zod";
+import { authMiddleware } from "../middleware/auth";
 import { getStorageProvider } from "../storage/factory";
 import type { Env } from "../types/env";
 import {
@@ -26,6 +27,8 @@ import {
 
 const router = new OpenAPIHono<Env>();
 
+router.use("/*", authMiddleware());
+
 const DEFAULT_ACCESS_KEY_EXPIRY = 1000 * 60 * 60 * 24 * 60; // 60 days
 const ACCESS_KEY_MASKING_STRING = "(hidden)";
 

apps/server/src/utils/errors.ts

@@ -1,6 +1,6 @@
 import type { Context } from "hono";
 import { HTTPException } from "hono/http-exception";
-import { ErrorCode, type StorageError } from "../types/storage";
+import { isStorageError } from "../types/error";
 
 export class AppError extends Error {
   constructor(
@@ -71,7 +71,6 @@ export function handleError(error: unknown, c: Context): Response {
   }
 
   if (isStorageError(error)) {
-    // const statusCode = storageErrorToStatusCode(error.code);
     return c.json({
       error: "STORAGE_ERROR",
       error_description: error.message,
@@ -86,31 +85,3 @@ export function handleError(error: unknown, c: Context): Response {
     500,
   );
 }
-
-function isStorageError(error: unknown): error is StorageError {
-  return (
-    typeof error === "object" &&
-    error !== null &&
-    "code" in error &&
-    "source" in error &&
-    error.source === "storage"
-  );
-}
-function storageErrorToStatusCode(code: ErrorCode): number {
-  switch (code) {
-    case ErrorCode.NotFound:
-      return 404;
-    case ErrorCode.AlreadyExists:
-      return 409;
-    case ErrorCode.Invalid:
-      return 400;
-    case ErrorCode.Expired:
-      return 401;
-    case ErrorCode.TooLarge:
-      return 413;
-    case ErrorCode.ConnectionFailed:
-      return 503;
-    default:
-      return 500;
-  }
-}

apps/server/src/utils/middleware.ts

@@ -172,7 +172,7 @@ class PackageDifferImpl implements PackageDiffer {
 
     // Get deployment info to update history
     const deployment = await storage.getDeploymentInfo(
-      latestPackage.deploymentId, // Changed from deploymentKey to deploymentId
+      latestPackage.originalDeployment,
     );
 
     await storage.updatePackageHistory(

apps/server/src/utils/package-differ.ts

@@ -1,8 +1,18 @@
 declare module "cloudflare:test" {
   // Controls the type of `import("cloudflare:test").env`
   interface ProvidedEnv extends Env {
+    TEST_MIGRATIONS: D1Migration[];
     DB: D1Database;
     STORAGE_BUCKET: R2Bucket;
-    TEST_MIGRATIONS: D1Migration[];
+    GITHUB_CLIENT_ID: string;
+    GITHUB_CLIENT_SECRET: string;
+    SERVER_URL: string;
+    JWT_SECRET: string;
+    ENABLE_ACCOUNT_REGISTRATION: string;
+    CORS_ORIGINS: string;
+    ACCOUNT_ID: string;
+    R2_BUCKET_NAME: string;
+    R2_ACCESS_KEY_ID: string;
+    R2_SECRET_ACCESS_KEY: string;
   }
 }