Function execute

worker/src/components/notification/slack.ts:171–257

({ inputs, params }, context)

    return { inputs: inputs(inputShape) };
  },
  async execute({ inputs, params }, context) {
    const { text, blocks, channel, thread_ts, slackToken, webhookUrl } = inputs as Record<
      string,
      unknown
    >;
    const { authType } = params;
    const contextData = { ...params, ...inputs };

    // 1. Interpolate text
    const finalText = interpolate(text as string, contextData);

    // 2. Interpolate and parse blocks if it's a template string
    let finalBlocks = blocks;
    if (typeof blocks === 'string') {
      try {
        const interpolated = interpolate(blocks, contextData);
        finalBlocks = JSON.parse(interpolated);
      } catch (_e) {
        context.logger.warn(
          '[Slack] Failed to parse blocks JSON after interpolation, sending as raw string',
        );
        finalBlocks = undefined;
      }
    } else if (Array.isArray(blocks)) {
      // If it's already an object, we'd need a deep interpolation,
      // but typically users will pass a JSON string template for simplicity.
      // For now, let's stringify and interpolate to support variables in objects too!
      const str = JSON.stringify(blocks);
      const interpolated = interpolate(str, contextData);
      finalBlocks = JSON.parse(interpolated);
    }

    context.logger.info(`[Slack] Sending message to ${authType}...`);

    const body: any = {
      text: finalText,
      blocks: finalBlocks,
    };

    if (authType === 'webhook') {
      if (!webhookUrl) {
        throw new ConfigurationError('Slack Webhook URL is required.', {
          configKey: 'webhookUrl',
        });
      }
      const url = typeof webhookUrl === 'string' ? webhookUrl : String(webhookUrl);
      const response = await context.http.fetch(url, {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify(body),
      });
      if (!response.ok) {
        const responseBody = await response.text();
        throw fromHttpResponse(response, responseBody);
      }
      return outputSchema.parse({ ok: true });
    } else {
      if (!slackToken) {