AnalyticsEventProcessor.java

public AnalyticsEventProcessor(final Construct scope, final String id, final AnalyticsEventProcessorProps props) {
  super(scope, id);
 
  platformName = props.getPlatformName();
  stream = props.getStream();
  lambdaExecutionRole = props.getLambdaExecutionRole();
  routingLambda = props.getRoutingLambda();
  reprocessingLambda = props.getReprocessingLambda();
 
  if (Objects.equals(System.getenv("CDK_ENVIRONMENT"), "production")) {
    environmentVars.put("TEST_WRITE_KEY_ALIAS", String.format("%s_dev", platformName));
    environmentVars.put("WRITE_KEY_ALIAS", String.format("%s_prod", platformName));
  } else {
    environmentVars.put("TEST_WRITE_KEY_ALIAS", String.format("%s_testing", platformName));
    environmentVars.put("WRITE_KEY_ALIAS", String.format("%s_testing", platformName));
  }
 
  dlq = createDlq();
  sourceQueue = createSourceQueue();
  dlqTopic = createDlqTopic();
  routingFunction = createRudderstackRoutingLambda();
  reprocessingFunction = createRudderstackReprocessingLambda();
}