Function execute

worker/src/components/security/notify.ts:350–446

({ inputs, params }, context)

    ],
  },
  async execute({ inputs, params }, context) {
    // Validate that providerConfig is provided
    if (!inputs.providerConfig || inputs.providerConfig.trim() === '') {
      throw new ConfigurationError(
        'Provider configuration is required. Please provide it via the Provider Config input.',
        { configKey: 'providerConfig' },
      );
    }

    const { messages, recipientIds, providerConfig, notifyConfig } = inputs;
    const parsedParams = parameterSchema.parse(params);
    const { providerIds } = parsedParams;

    context.logger.info(
      `[Notify] Sending ${messages.length} message(s) via ${providerIds && providerIds.length > 0 ? providerIds.join(', ') : 'all configured providers'}`,
    );
    context.emitProgress(
      `Sending ${messages.length} notification${messages.length > 1 ? 's' : ''}`,
    );

    const tenantId = (context as any).tenantId ?? 'default-tenant';
    const volume = new IsolatedContainerVolume(tenantId, context.runId);
    const baseRunner = definition.runner;

    if (baseRunner.kind !== 'docker') {
      throw new ContainerError('Notify runner is expected to be docker-based.', {
        details: { expectedKind: 'docker', actualKind: baseRunner.kind },
      });
    }

    let rawOutput: string;
    try {
      // Prepare input files for the volume
      const inputFiles: Record<string, string> = {
        [MESSAGES_FILE_NAME]: messages.join('\n'),
        [PROVIDER_CONFIG_FILE_NAME]: providerConfig,
      };

      // Add notify config file if provided
      if (notifyConfig && notifyConfig.trim().length > 0) {
        inputFiles[NOTIFY_CONFIG_FILE_NAME] = notifyConfig;
      }

      const volumeName = await volume.initialize(inputFiles);
      context.logger.info(`[Notify] Created isolated volume: ${volumeName}`);

      // Build notify CLI arguments in TypeScript
      const notifyArgs = buildNotifyArgs({
        messagesFile: `${CONTAINER_INPUT_DIR}/${MESSAGES_FILE_NAME}`,
        providerConfigFile: `${CONTAINER_INPUT_DIR}/${PROVIDER_CONFIG_FILE_NAME}`,
        notifyConfigFile:
          notifyConfig && notifyConfig.trim().length > 0
            ? `${CONTAINER_INPUT_DIR}/${NOTIFY_CONFIG_FILE_NAME}`
            : undefined,
        providerIds,
        recipientIds,
        messageFormat: parsedParams.messageFormat,
        bulk: parsedParams.bulk ?? true,