Boltを使ってSlackワークフローからDynamoDBにデータを挿入する

display_information:
  name: SlackTestApp
  description: フォームからDynamoDBにデータを送信するBot
  background_color: "#2c2d30"
features:
  bot_user:
    display_name: SlackTestApp
    always_online: true
  slash_commands:
    - command: /submit
      url: https://example.com
      description: 申請フォームを開く
      usage_hint: /submit
      should_escape: false
oauth_config:
  scopes:
    bot:
      - commands
      - chat:write
      - users:read
      - users:read.email
  pkce_enabled: false
settings:
  interactivity:
    is_enabled: true
    request_url: https://example.com
  org_deploy_enabled: false
  socket_mode_enabled: false
  token_rotation_enabled: false
  is_mcp_enabled: false

import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import * as dynamodb from 'aws-cdk-lib/aws-dynamodb';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import * as lambdaNode from 'aws-cdk-lib/aws-lambda-nodejs';
import * as apigateway from 'aws-cdk-lib/aws-apigateway';
import * as iam from 'aws-cdk-lib/aws-iam';
import * as path from 'path';

export class SlackAppStack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    // ── DynamoDB ──────────────────────────────────────────────────────────────
    const table = new dynamodb.Table(this, 'SlackAppTest', {
      tableName: 'SlackAppTest',
      partitionKey: {
        name: 'id',
        type: dynamodb.AttributeType.STRING,
      },
      billingMode: dynamodb.BillingMode.PAY_PER_REQUEST,
      removalPolicy: cdk.RemovalPolicy.DESTROY,
    });

    // ── Lambda ────────────────────────────────────────────────────────────────
    const handler = new lambdaNode.NodejsFunction(this, 'SlackHandler', {
      functionName: 'slackapp-handler',
      entry: path.join(__dirname, '../../src/index.ts'),
      handler: 'handler',
      runtime: lambda.Runtime.NODEJS_22_X,
      timeout: cdk.Duration.seconds(10),
      memorySize: 128,
      environment: {
        TABLE_NAME: table.tableName,
        SLACK_SIGNING_SECRET_PARAM: '/slackapp/signing-secret',
        SLACK_BOT_TOKEN_PARAM: '/slackapp/bot-token',
      },
    });

    // ── IAM: DynamoDB 書き込み権限 ─────────────────────────────────────────────
    table.grantWriteData(handler);
    // ── IAM: SSM SecureString 読み取り権限 ────────────────────────────────────
    handler.addToRolePolicy(
      new iam.PolicyStatement({
        actions: ['ssm:GetParameter'],
        resources: [
          `arn:aws:ssm:${this.region}:${this.account}:parameter/slackapp/*`,
        ],
      }),
    );

    // ── API Gateway ───────────────────────────────────────────────────────────
    const api = new apigateway.RestApi(this, 'SlackApi', {
      restApiName: 'slackapp-api',
      deployOptions: { stageName: 'dev' },
    });
    const integration = new apigateway.LambdaIntegration(handler, {
      proxy: true,
    });
    const slackResource = api.root.addResource('slack');
    slackResource.addMethod('POST', integration);

    // ── Outputs ───────────────────────────────────────────────────────────────
    new cdk.CfnOutput(this, 'SlackEndpointUrl', {
      value: `${api.url}slack`,
      description: 'Slack のスラッシュコマンド URL・Interactivity Request URL の両方に設定してください',
    });
  }
}

const app = new cdk.App();
new SlackAppStack(app, 'SlackAppStack');

await client.views.open({
  view: {
    //ここに入れる
  }
})

import { App, AwsLambdaReceiver } from '@slack/bolt';
import { DynamoDBClient } from '@aws-sdk/client-dynamodb';
import { DynamoDBDocumentClient, PutCommand } from '@aws-sdk/lib-dynamodb';
import { SSMClient, GetParameterCommand } from '@aws-sdk/client-ssm';
import { v4 as uuidv4 } from 'uuid';

// ── AWS クライアント ───────────────────────────────────────────────────────────
const dynamo = DynamoDBDocumentClient.from(new DynamoDBClient({}));
const ssmClient = new SSMClient({});
const TABLE_NAME = process.env.TABLE_NAME!;

async function getParameter(name: string): Promise<string> {
  const result = await ssmClient.send(
    new GetParameterCommand({ Name: name, WithDecryption: true }),
  );
  return result.Parameter!.Value!;
}

// ── Bolt 初期化 ────────────────────
let lambdaHandler: ((...args: any[]) => Promise<unknown>) | undefined;

async function initApp(): Promise<NonNullable<typeof lambdaHandler>> {
  if (lambdaHandler) return lambdaHandler;

  const [signingSecret, botToken] = await Promise.all([
    getParameter(process.env.SLACK_SIGNING_SECRET_PARAM!),
    getParameter(process.env.SLACK_BOT_TOKEN_PARAM!),
  ]);

  const receiver = new AwsLambdaReceiver({ signingSecret });
  const app = new App({ token: botToken, receiver });

  // ── /submit スラッシュコマンド：モーダルを開く ────────────────────────────
  app.command('/submit', async ({ ack, command, client, logger }) => {
    await ack();
    try {
      await client.views.open({
        trigger_id: command.trigger_id,
        view: {
          "callback_id": "submit_modal",
          "type": "modal",
          "title": {
            "type": "plain_text",
            "text": "申請ワークフロー",
            "emoji": true
          },
          "submit": {
            "type": "plain_text",
            "text": "送信",
            "emoji": true
          },
          "close": {
            "type": "plain_text",
            "text": "キャンセル",
            "emoji": true
          },
          "blocks": [
            {
              "type": "input",
              "block_id": "text_block",
              "label": {
                "type": "plain_text",
                "text": "申請内容"
              },
              "element": {
                "type": "plain_text_input",
                "action_id": "text_input",
                "placeholder": {
                  "type": "plain_text",
                  "text": "申請内容を入力してください"
                }
              }
            }
          ]
        }
      });
    } catch (error) {
      logger.error('views.open に失敗しました:', error);
    }
  });

  // ── モーダル送信：DynamoDB に保存 ─────────────────────────────────────────
  app.view('submit_modal', async ({ ack, body, logger }) => {
    await ack();

    const userId = body.user.id;
    const text = body.view.state.values['text_block']['text_input'].value ?? '';

    try {
      await dynamo.send(
        new PutCommand({
          TableName: TABLE_NAME,
          Item: {
            id: uuidv4(),
            userId,
            text,
            submittedAt: new Date().toISOString(),
          },
        }),
      );
      logger.info(`申請を保存しました: userId=${userId}`);
    } catch (error) {
      logger.error('DynamoDB への保存に失敗しました:', error);
    }
  });

  lambdaHandler = await receiver.start();
  return lambdaHandler;
}

// ── Lambda エントリーポイント ──────────────────────────────────────────────────
export const handler = async (...args: any[]) => {
  const fn = await initApp();
  return fn(...args);
};

pnpm exec cdk deploy --profile work

 slash_commands:
    - command: /submit
      url: 👉ここにエンドポイントURLをペースト
      description: 申請フォームを開く

settings:
  interactivity:
    is_enabled: true
    request_url: 👉ここにエンドポイントURLをペースト
  org_deploy_enabled: false