Class APIStack

bin/stacks/api-stack.ts:39–647

import { ParamDashboardStack } from './param-dashboard-stack';

/**
 * APIStack
 *    Sets up the API Gateway and Lambda functions for the parameterization service.
 *    The API Gateway is responsible for creating REST endpoints, each of which is integrated with a Lambda function.
 */
export class APIStack extends cdk.Stack {
  public readonly url: CfnOutput;

  constructor(
    parent: Construct,
    name: string,
    props: cdk.StackProps & {
      provisionedConcurrency: number;
      internalApiKey?: string;
      throttlingOverride?: string;
      chatbotSNSArn?: string;
      stage: string;
      envVars: Record<string, string>;
      hardQuoteCosignerBackendAccounts?: readonly string[];
      // Backend accounts that may reach the market-maker egress proxy. Absent (local stack)
      // means no proxy is created.
      egressProxyBackendAccounts?: readonly string[];
      // Backend accounts that may write analytics records cross-account. Absent (local stack)
      // means no direct-write streams or writer role are created.
      analyticsWriterBackendAccounts?: readonly string[];
      // Backend accounts that may read the circuit-breaker bench state and roster, and record posted
      // orders and filler addresses, during the ramp. Absent (local stack) means no role is created.
      rampAccessBackendAccounts?: readonly string[];
      // Share (0-100) of the quote Lambdas' market-maker webhook calls sent through the egress
      // proxy. Needs the proxy. Absent leaves the Lambdas untouched.
      egressProxyWebhookSharePercent?: number;
    }
  ) {
    super(parent, name, props);
    const region = cdk.Stack.of(this).region;
    const { provisionedConcurrency, internalApiKey, stage, chatbotSNSArn } = props;

    // The quote analytics streams exist only where the analytics writer does (AnalyticsStack). Their
    // names are fixed per stage, so the Lambdas get names and a grant without referencing the
    // nested stack.
    const directStreams = props.analyticsWriterBackendAccounts?.length
      ? quoteAnalyticsDirectStreamNames(stage)
      : undefined;
    const softQuoteAnalyticsEnv = directStreams && {
      [QUOTE_ANALYTICS_STREAM_ENV.QuoteRequest]: directStreams.rfqRequest,
      [QUOTE_ANALYTICS_STREAM_ENV.QuoteResponse]: directStreams.rfqResponse,
    };
    const hardQuoteAnalyticsEnv = directStreams && {
      [QUOTE_ANALYTICS_STREAM_ENV.HardRequest]: directStreams.hardRequest,
      [QUOTE_ANALYTICS_STREAM_ENV.HardResponse]: directStreams.hardResponse,
    };

    /*
     *  API Gateway Initialization
     */
    const accessLogGroup = new aws_logs.LogGroup(this, `${SERVICE_NAME}APIGAccessLogs`);

    const api = new aws_apigateway.RestApi(this, `${SERVICE_NAME}`, {