/* eslint-disable max-len */
/* eslint-disable no-console */
import https from "https";
import url from "url";
import { log } from "./util.js";

export const CREATE_FAILED_PHYSICAL_ID_MARKER =
  "AWSCDK::CustomResourceProviderFramework::CREATE_FAILED";
export const MISSING_PHYSICAL_ID_MARKER =
  "AWSCDK::CustomResourceProviderFramework::MISSING_PHYSICAL_ID";

/*
export interface CloudFormationResponseOptions {
  readonly reason?: string;
  readonly noEcho?: boolean;
}

export interface CloudFormationEventContext {
  StackId: string;
  RequestId: string;
  PhysicalResourceId?: string;
  LogicalResourceId: string;
  ResponseURL: string;
  Data?: any;
}
*/

export async function submitResponse(
  status: "SUCCESS" | "FAILED",
  event: any,
  options: any = {}
) {
  const json /*: AWSLambda.CloudFormationCustomResourceResponse*/ = {
    Status: status,
    Reason: options.reason || status,
    StackId: event.StackId,
    RequestId: event.RequestId,
    PhysicalResourceId: event.PhysicalResourceId || MISSING_PHYSICAL_ID_MARKER,
    LogicalResourceId: event.LogicalResourceId,
    NoEcho: options.noEcho,
    Data: event.Data,
  };

  log("submit response to cloudformation", json);

  const responseBody = JSON.stringify(json);

  const parsedUrl = url.parse(event.ResponseURL);
  await httpRequest(
    {
      hostname: parsedUrl.hostname,
      path: parsedUrl.path,
      method: "PUT",
      headers: {
        "content-type": "",
        "content-length": responseBody.length,
      },
    },
    responseBody
  );
}

export const includeStackTraces = true; // for unit tests

export function safeHandler(block: (event: any) => Promise<void>) {
  return async (event: any) => {
    // Comment out the code below b/c we want to remove the metadata even if
    // CREATE failed. CREATE might fail after the metadata is written.

    //// ignore DELETE event when the physical resource ID is the marker that
    //// indicates that this DELETE is a subsequent DELETE to a failed CREATE
    //// operation.
    //if (
    //  event.RequestType === "Delete" &&
    //  event.PhysicalResourceId === CREATE_FAILED_PHYSICAL_ID_MARKER
    //) {
    //  log("ignoring DELETE event caused by a failed CREATE event");
    //  await submitResponse("SUCCESS", event);
    //  return;
    //}

    try {
      await block(event);
    } catch (e: any) {
      log(e);

      // tell waiter state machine to retry
      if (e instanceof Retry) {
        log("retry requested by handler");
        throw e;
      }

      if (!event.PhysicalResourceId) {
        // special case: if CREATE fails, which usually implies, we usually don't
        // have a physical resource id. in this case, the subsequent DELETE
        // operation does not have any meaning, and will likely fail as well. to
        // address this, we use a marker so the provider framework can simply
        // ignore the subsequent DELETE.
        if (event.RequestType === "Create") {
          log(
            "CREATE failed, responding with a marker physical resource id so that the subsequent DELETE will be ignored"
          );
          event.PhysicalResourceId = CREATE_FAILED_PHYSICAL_ID_MARKER;
        } else {
          // otherwise, if PhysicalResourceId is not specified, something is
          // terribly wrong because all other events should have an ID.
          log(
            `ERROR: Malformed event. "PhysicalResourceId" is required: ${JSON.stringify(
              event
            )}`
          );
        }
      }

      // this is an actual error, fail the activity altogether and exist.
      // append a reference to the log group.
      const reason = [
        e.message,
        `Logs: https://${
          process.env.AWS_REGION
        }.console.aws.amazon.com/cloudwatch/home?region=${
          process.env.AWS_REGION
        }#logsV2:log-groups/log-group/${encodeURIComponent(
          process.env.AWS_LAMBDA_LOG_GROUP_NAME!
        )}/log-events/${encodeURIComponent(
          process.env.AWS_LAMBDA_LOG_STREAM_NAME!
        )}`,
      ].join("\n");

      await submitResponse("FAILED", event, { reason });
    }
  };
}

export class Retry extends Error {}

async function httpRequest(
  options: https.RequestOptions,
  responseBody: string
) {
  return new Promise((resolve, reject) => {
    try {
      const request = https.request(options, resolve);
      request.on("error", reject);
      request.write(responseBody);
      request.end();
    } catch (e) {
      reject(e);
    }
  });
}