// @ts-ignore
import PrerenderManifest from "./prerender-manifest.json";
// @ts-ignore
import Manifest from "./manifest.json";
// @ts-ignore
import RoutesManifestJson from "./routes-manifest.json";
// @ts-ignore
import LambdaManifestJson from "./lambda-manifest.json";
import {
  defaultHandler,
  PreRenderedManifest as PrerenderManifestType,
  RegenerationEvent,
  RegenerationEventRequest,
  regenerationHandler,
  RoutesManifest
} from "@sls-next/core";
import { AwsPlatformClient } from "@sls-next/aws-common";
import { BuildManifest, LambdaManifest } from "src/types";
import { httpCompat } from "src/compat/apigw";
import {
  APIGatewayProxyEventV2,
  SQSEvent,
  APIGatewayProxyStructuredResultV2
} from "aws-lambda";
import Stream from "stream";
import http from "http";

/**
 * Lambda handler that wraps the platform-agnostic default handler.
 * @param event
 */
export const handleRequest = async (
  event: APIGatewayProxyEventV2
): Promise<APIGatewayProxyStructuredResultV2> => {
  const manifest: BuildManifest = Manifest;
  const prerenderManifest: PrerenderManifestType = PrerenderManifest;
  const routesManifest: RoutesManifest = RoutesManifestJson;
  const lambdaManifest: LambdaManifest = LambdaManifestJson;

  // Compatibility layer required to convert from Node.js req/res <-> API Gateway
  const { req, res, responsePromise } = httpCompat(event);

  // Initialize AWS platform specific client
  const bucketName = lambdaManifest.bucketName;
  const bucketRegion = lambdaManifest.bucketRegion;
  const regenerationQueueRegion = lambdaManifest.queueRegion;
  const regenerationQueueName = lambdaManifest.queueName;
  const awsPlatformClient = new AwsPlatformClient(
    bucketName,
    bucketRegion,
    regenerationQueueName,
    regenerationQueueRegion
  );

  // Handle request with platform-agnostic handler
  await defaultHandler({
    req,
    res,
    responsePromise,
    manifest,
    prerenderManifest,
    routesManifest,
    options: {
      logExecutionTimes: lambdaManifest.logExecutionTimes ?? false
    },
    platformClient: awsPlatformClient
  });

  // Convert to API Gateway compatible response
  return await responsePromise;
};

/**
 * Lambda handler that wraps the platform-agnostic regeneration handler.
 * @param event
 */
export const handleRegeneration = async (event: SQSEvent): Promise<void> => {
  await Promise.all(
    event.Records.map(async (record) => {
      const regenerationEvent: RegenerationEvent = JSON.parse(record.body);
      const manifest: BuildManifest = Manifest;
      const lambdaManifest: LambdaManifest = LambdaManifestJson;

      // This is needed to build the original req/res Node.js objects to be passed into pages.
      const originalRequest: RegenerationEventRequest =
        regenerationEvent.request;
      const req = Object.assign(
        new Stream.Readable(),
        http.IncomingMessage.prototype
      );
      req.url = originalRequest.url; // this already includes query parameters
      req.headers = originalRequest.headers;
      const res = Object.assign(
        new Stream.Readable(),
        http.ServerResponse.prototype
      );

      const awsPlatformClient = new AwsPlatformClient(
        lambdaManifest.bucketName,
        lambdaManifest.bucketRegion,
        lambdaManifest.queueName, // we don't need to call the SQS queue as of now, but passing this for future uses
        lambdaManifest.queueRegion
      );

      await regenerationHandler({
        req,
        res,
        regenerationEvent,
        manifest,
        platformClient: awsPlatformClient
      });
    })
  );
};

/**
 * Entry point for Lambda handling - either a request event or SQS event (for regeneration).
 * @param event
 */
export const handler = async (
  event: SQSEvent | APIGatewayProxyEventV2
): Promise<void | APIGatewayProxyStructuredResultV2> => {
  if ((event as SQSEvent).Records) {
    await handleRegeneration(event as SQSEvent);
  } else {
    return await handleRequest(event as APIGatewayProxyEventV2);
  }
};