lambda.js

import serverlessExpress from "@codegenie/serverless-express";
import { Environment } from "./dist/shared/helpers/Environment.js";
import { createApp } from "./dist/app.js";
import { handleSocket } from "./dist/lambda/socket-handler.js";
import { handle30MinTimer, handleMidnightTimer, handleScheduledTasks, handleWebhookTimer } from "./dist/lambda/timer-handler.js";

const initializeEnvironment = async () => {
  if (!Environment.currentEnvironment) {
    const stage = process.env.STAGE || process.env.ENVIRONMENT || "dev";
    console.log("Initializing environment with stage:", stage);
    console.log("Environment variables:", {
      STAGE: process.env.STAGE,
      ENVIRONMENT: process.env.ENVIRONMENT,
      APP_ENV: process.env.APP_ENV
    });
    await Environment.init(stage);
    console.log("Environment initialized, connection strings loaded");

    // Pools now auto-initialize on first use
  }
};

let cachedHandler;

export const web = async function (event, context) {
  try {
    console.log("Web handler invoked");
    console.log("Event httpMethod:", event.httpMethod);
    console.log("Event path:", event.path);

    if (event.path === "/test") {
      return {
        statusCode: 200,
        headers: {
          "Content-Type": "application/json",
          "Access-Control-Allow-Origin": "*"
        },
        body: JSON.stringify({
          message: "Lambda is working",
          path: event.path,
          method: event.httpMethod,
          stage: process.env.STAGE,
          time: new Date().toISOString()
        })
      };
    }

    if (event.path === "/test-post" && event.httpMethod === "POST") {
      return {
        statusCode: 200,
        headers: {
          "Content-Type": "application/json",
          "Access-Control-Allow-Origin": "*"
        },
        body: JSON.stringify({
          message: "POST request received",
          body: event.body,
          headers: event.headers,
          method: event.httpMethod,
          time: new Date().toISOString()
        })
      };
    }

    if (event.path === "/api/test") {
      return {
        statusCode: 200,
        headers: {
          "Content-Type": "application/json",
          "Access-Control-Allow-Origin": "*"
        },
        body: JSON.stringify({
          message: "API routing working",
          path: event.path,
          method: event.httpMethod,
          modules: ["membership", "attendance", "content", "giving", "messaging", "doing"],
          time: new Date().toISOString()
        })
      };
    }

    await initializeEnvironment();

    if (!cachedHandler) {
      console.log("Creating Express app with fully initialized environment...");
      const app = await createApp();
      console.log("Express app created");

      cachedHandler = serverlessExpress({
        app,
        binarySettings: {
          contentTypes: ["application/octet-stream", "font/*", "image/*", "application/pdf"]
        }
      });
      console.log("Serverless Express handler created");
    }

    const result = await cachedHandler(event, context);
    return result;
  } catch (error) {
    console.error("Error in web handler:", error);
    console.error("Error stack:", error.stack);
    return {
      statusCode: 500,
      headers: {
        "Access-Control-Allow-Origin": "*",
        "Access-Control-Allow-Headers": "Content-Type,Authorization",
        "Access-Control-Allow-Methods": "GET,POST,PUT,DELETE,OPTIONS,PATCH"
      },
      body: JSON.stringify({
        error: "Internal server error",
        message: error.message,
        stack: process.env.STAGE === "demo" ? error.stack : undefined,
        timestamp: new Date().toISOString()
      })
    };
  }
};

export const socket = async function (event, context) {
  try {
    await initializeEnvironment();
    return await handleSocket(event, context);
  } catch (error) {
    console.error("Error in socket handler:", error);
    return {
      statusCode: 500,
      body: JSON.stringify({ error: "Socket handler error" })
    };
  }
};

// Timer handlers. Export name "timer15Min" is legacy — kept as-is so it matches
// the serverless.yml function key/handler string (renaming would recreate the
// EventBridge rule); it actually runs every 30 minutes.
export const timer15Min = async function (event, context) {
  try {
    await initializeEnvironment();
    await handle30MinTimer(event, context);
    return { statusCode: 200, body: "Timer executed successfully" };
  } catch (error) {
    console.error("Error in 30-minute timer:", error);
    throw error;
  }
};

export const timerMidnight = async function (event, context) {
  try {
    await initializeEnvironment();
    await handleMidnightTimer(event, context);
    return { statusCode: 200, body: "Timer executed successfully" };
  } catch (error) {
    console.error("Error in midnight timer:", error);
    throw error;
  }
};

export const timerScheduledTasks = async function (event, context) {
  try {
    await initializeEnvironment();
    await handleScheduledTasks(event, context);
    return { statusCode: 200, body: "Scheduled tasks executed successfully" };
  } catch (error) {
    console.error("Error in scheduled tasks timer:", error);
    throw error;
  }
};

export const timerWebhooks = async function (event, context) {
  try {
    await initializeEnvironment();
    await handleWebhookTimer(event, context);
    return { statusCode: 200, body: "Webhook deliveries processed successfully" };
  } catch (error) {
    console.error("Error in webhook timer:", error);
    throw error;
  }
};