Slack Incoming and Outgoing Webhooks for Real-Time AI Agentsを使用する方法

今の私たちの は デプロイに備え、新しい入力ソースを統合することによってその機能を拡張しましょう。 応用 コンテナ 応用 コンテナ Slack をリアルタイム通信に統合 特定の Slack チャンネルにおける新しいメッセージに関するリアルタイムの通知を受け取りたいというシナリオを想像してください。 (LLMs) to generate summaries or draft answers. This new functionality will work in tandem with our existing メールボックスを検索し続ける。 大きな言語モデル エージェント 大きな言語モデル エージェント この統合は、当社のプロアクティブエージェントシステムの基盤となるでしょう。Slackと電子メールを同時に監視することで、当社のアプリケーションは通信の中心的なハブとなり、メッセージが逃れられず、すべてのクエリが迅速に処理されることを保証します。このダブルソースアプローチは、よく設計されたシステムの強さと柔軟性を示し、伝統的かつ現代的なコミュニケーションプラットフォームを組み合わせて包括的なソリューションを提供します。 新しい Slack メッセージの通知を受信するには、出力メッセージを使用できます。 . Webhook は、ソースシステム内のイベントによって引き起こされるユーザー定義の HTTP コールバックです. When the event occurs, the source system makes a HTTP/HTTPS request to the URL configured in the . Webhooks Webhook Slack Webhooksの機能 Slack では、特定のチャンネルまたはワークスペースに Webhook が設定されます. 特定の基準(例えば、特定のキーワード、パターン)を満たすメッセージまたはイベントが投稿された場合、Slack は指定された URL に HTTP POST リクエストを送信します. この URL は当社のエンドポイントです。 その後、入力するデータを処理する。 応用 応用 このシステムは非常に効率的で、なぜなら 私たちのアプリケーションが常に新しいメッセージ(資源密集性と効率が低い)をSlackに投票する代わりに、Slackはイベントが起こるとすぐに情報を積極的に私たちに「押し寄せ」します。 イベントドライブ イベントドライブ なぜWebhooksを選ぶのか? メッセージが起こるようにメッセージを受け取って、即時アクションを可能にします。 Real-time updates: 当社のアプリケーションは、Slackをアンケートする必要はありません、API呼び出しとサーバーリソースを節約します。 Reduced resource usage: Webhooksは、さまざまなサービスを接続する標準的でシンプルな方法です。 Simple integration: このアプローチは、Aを構築するために不可欠です。 新しいコミュニケーションに対して、Slackや電子メールなどの他のソースから来たものに関わらず、即座に反応します。 Proactive Agent Incoming and Outgoing Webhooks(入力および出力 Webhooks) Yes, Slack has both incoming and outgoing webhooks. これらは、コミュニケーションワークフローで異なる目的を果たす2つの異なるメカニズムです。 来るWebhooks これはSlackで最も一般的なタイプのWebhookで、外部アプリケーションがSlackチャンネルにメッセージを送信することを可能にします。 Slack はユニークな URL を提供します。あなたのアプリケーションは、この URL に HTTP POST リクエストを行い、メッセージのテキストとフォーマットを含む JSON パイロードを送信します。 Incoming Webhooks は、通知、警告、自動メッセージに使用されます. For example, to send notifications about new GitHub commits, deployment status, or messages from our site. たとえば、新しい GitHub コミットメント、展開状態、または私たちのメッセージについての通知を送信するために使用されます。 Slack に戻る Proactive エージェント エージェント エージェント Outgoing Webhooksについて これは、Slack がチャンネル内で特定のイベントが発生したときに、外部アプリケーションにデータを送信することを可能にする古いメカニズムです。 Slack チャンネル内のユーザーがこれらの単語のいずれかを含むメッセージを投稿すると、Slack はアプリケーションの URL に HTTP POST リクエストを作成します。 作成に使用される Webhooks 特定のコマンドやキーワードに反応する自動化。 インタラクティブボット インタラクティブボット 私たちのシナリオでは、エージェントがメッセージを受け取り、処理し、概要を生成できるように、概要のようなトリガーを持った出力ウェブハックを設定します。 主な違い Incoming Webhooks は、Slack (外部のソースから) にメッセージを送信するために使用されます。 Outgoing Webhooksは、Slack(外部ソース)からのメッセージを受信するために使用されますが、特定のトリガーに基づいてのみです。 私たちの記事の文脈では、 , we use an outgoing webhook to receive messages from Slack for processing and an incoming webhook to send responses back to Slack. Slack からメッセージを受け取るために出発する webhook を使用します。 “Proactive Agent” Slack App を作成するためのステップ-by-ステップガイド Slack が Webhook イベントを送信することを可能にするには、まず開発者ポータルでアプリケーションを作成し、Slack ワークスペースまたは通知を受信したい特定のチャンネルにインストールする必要があります。 Slack API ウェブサイトへのアクセス: Navigate to . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps “Create an App” をクリックし、それを “From scratch” から構築するように選択してください。 アプリケーションに記述的な名前を付けて、それを開発し、テストする Slack ワークスペースを選択してください。 イベントサブスクリプションを有効にする: アプリの設定で、「イベントサブスクリプション」セクションに移動し、「イベントを有効にする」を有効にします。 リクエスト URL を提供する: アプリケーションに公開アクセス可能な URL を提供する必要があります。これは、Slack がイベントのパイロードを送信するエンドポイントです。Slack は、アプリケーションが Slack のリクエストからの挑戦値で応答しなければならない一回の URL 検証を実行します。 ボットイベントへのサブスクリプション:「ボットイベントへのサブスクリプション」セクションにスロップして、「ボットユーザーイベントを追加」をクリックし、 message.channels イベントを選択します。 リクエストの範囲:これらのイベントを受信するには、あなたのボットは適切な許可が必要になります。「OAuth & Permissions」セクションでは、チャンネル:ストーリーの範囲をボットのトークンに追加します。 アプリの再インストール:新しい範囲を追加した後、変更が効力を生ずるために、アプリをワークスペースに再インストールする必要があります。 これらのステップを踏まえ、私たちの サブスクリプトチャンネルにおけるすべての新しいメッセージに対して、完全な JSON パイロットを受信し、伝統的なトリガー ワード メソッドよりもより多くの文脈と柔軟性を提供します。 . proactive agent AI-Powered アプリケーション AI-Powered アプリケーション AI-Powered アプリケーション Webhook Validationについて エンドポイント検証リクエストの応答を処理するエンドポイントを作成する時が来ました. We have two options for working with webhooks on the Symfony side: we can handle it at the controller level or use the この記事では、コントローラーレベルでの作業に焦点を当てます。将来の投稿では、コントローラーレベルでこれを行う方法を示します。 . symfony/webhook Symfony Webhook Component Slack のイベントサブスクリプションでエンドポイント URL を設定すると、Slack は、URL が有効でアプリケーションに属していることを確認するための初期の検証リクエストを送信します。 私たちのエンドポイントは、要求体からの正確な挑戦値で応答しなければなりません。 challenge Webhook リクエストを適切に処理するには、パイロードを受け取るだけでなく、その正確性を検証する必要があります。 (DTOs) と 2 つの主要な Symfony コンポーネントをインストールします。 そして . データ転送対象 symfony/validator symfony/serializer-pack データ転送対象 データ転送対象 なぜこれらの成分が重要なのか このコンポーネントは、一連のルールに基づいてデータを検証するための強力な枠組みを提供します。 if-else 文を手動で書く代わりに、各フィールドをチェックするには、検証制限(例えば、 NotBlank、 Type、 Length)を直接 DTO 属性に定義できます。 symfony/validator: このコンポーネントバンドルは、データを序列化(オブジェクトをアーレイ / JSON に変える)および deserialize (JSON /arrays をオブジェクトに変える)するために必要なすべてを提供します。私たちは、deserializer を使用して、Slack から入力する JSON パイロードを自動的に検証された DTO オブジェクトに変換します。 symfony/serializer-pack: そして今、私たちはDoctrineが提供するより高度なコレクションを使用する準備ができています。 コンポーネントはまだ、代わりに、私たちは作業のためのパッケージだけをインストールします。 . Doctrine collections PHPのアーレイは多様であるが、タイプヒント、不変性、およびフィルタリングまたはマッピングのための専門的な方法などのいくつかの高度な機能が欠けている。 アーレイの周りに強力でオブジェクト指向の包装を提供し、データを管理するより強力で予測可能な方法を提供します。 メッセージのリスト、ユーザー、またはその他のデータのパイロードを扱うシステムです。 Doctrine Collections Proactive Agent この小さくても影響力のある変更は、私たちがデータを管理する方法を大幅に改善します。 エージェントの論理をより強力にし、維持しやすくなります。 私たちのアプリケーション 私たちのアプリケーション 必要なコンポーネントをインストールするには、ターミナルで次のコマンドを実行するだけです。 composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack Webhook Payload を検証するためのワークフロー リクエストを受信: Symfony コントローラは Slack から HTTP POST リクエストを受信します。 Deserialize to DTO: 私たちは、Serializer を使用して JSON パイロードを私たちの事前定義された DTO オブジェクトに変換します。 Validate the DTO: Validator component checks the DTO's properties against the defined constraints. 検証コンポーネントは、DTOの特性を定義された制約に対して検証します。 エラーの処理: 検証が失敗した場合、エラー応答(例えば400 Bad Request)をSlackに返します。 プロセス有効データ: 検証が成功した場合、当社のアプリケーションは、Webhookデータを正しいフォーマットにあることを知って安全に処理することができます。 この構造化されたアプローチは、当社のアプリケーションが耐久性があり、期待されるフォーマットに合ったデータのみを処理することを保証し、信頼性とセキュリティの高いシステムを構築するための重要なステップです。 単一コントローラ内で複数のペイロードを処理する 私たちはまた、私たちのコントローラと単一ルートが適切に扱わなければならないことを考慮すべきです。 , from URL validation to the working event payloads we have subscribed to. (URLの検証から、私たちがサブスクリプトしたワークイベントのパイロードまで) different types of payloads これは強力な Webhook エンドポイントのための重要な要件です. 単一のルートは、一度の URL 検証リクエストとライブイベントの通知の区別に十分にスマートでなければなりません. Our controller should be able to process each request type accordingly. 前述したように、Slackの最初のURL検証パイロードには、ユニークなパイロードが含まれています。 All subsequent event payloads contain an event key that holds the actual message data. リクエストの性質を決定するために、当社のコントローラはこれらのキーの存在をチェックする必要があります。 challenge Slack URL 認証リクエスト さて、Slack からの URL 検証リクエストを検証するための DTO を作成しましょう. First, here is what a typical Slack URL validation request payload looks like. イベントサブスクリプションを有効にすると、Slack はトークン、チャレンジ、タイプの 3 つのキーフィールドを含む JSON パイロードでエンドポイントに POST リクエストを送信します。 { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } あなたのアプリケーションのためのユニークなトークン. You can use this to verify the request is from your app. このトークンを使用して、リクエストがあなたのアプリケーションから来ていることを確認できます。 token: ランダムに生成された文字列. You must return this exact string in your JSON response to prove you own the URL. この文字列を正確に返す必要があります。 challenge: イベントの種類 検証のために、これは常に url_verification となります。 type: DTOの作成 現在、この構造を反映し、Symfony の検証コンポーネントを使用して検証制限を含む DTO を作成します。 namespace App\DTO\Slack; use Symfony\Component\Validator\Constraints as Assert; class SlackUrlValidationRequest { #[Assert\NotBlank] #[Assert\Type('string')] public string $token; #[Assert\NotBlank] #[Assert\Type('string')] public string $challenge; #[Assert\NotBlank] #[Assert\Type('string')] #[Assert\EqualTo("url_verification")] public string $type; public function getToken(): string { return $this->token; } public function getChallenge(): string { return $this->challenge; } public function getType(): string { return $this->type; } } この DTO は、検証を簡素化します: トークン、チャレンジ、タイプフィールドがリクエストに存在することを確認します。 Assert\NotBlank: 各フィールドの値が文字列であることを確認し、予期せぬデータ型を防止します。 Assert\Type(“string”): 具体的には、タイプフィールドが要求された文字列と一致していることを検証しますので、別のイベントタイプではなく、URL検証リクエストを処理していることを知っています。 Assert\EqualTo(“url_verification”): この DTO を使用することで、入力する JSON パイロードを deserialize し、コントローラ内の最小限のコードでその構造を自動的に検証できます。 Slack Webhook Validation のコントローラの作成 Perfect, let's create a controller that uses a DTO は Slack からのリクエストを検証します. このコントローラは、入力されたリクエストが URL 検証リクエストであるかどうかを確認し、リクエストコードを返すことで正しく処理します。 SlackUrlValidationRequest We will inject the JSONのパイロードを私たちのDTOや このアプローチにより、コードはクリーンで信頼性が高く、Symfony規格に準拠します。 SerializerInterface ValidatorInterface namespace App\Controller; use App\DTO\Slack\SlackUrlValidationRequest; use Symfony\Component\HttpFoundation\JsonResponse; use Symfony\Component\HttpFoundation\Request; use Symfony\Component\HttpFoundation\Response; use Symfony\Component\HttpKernel\Exception\BadRequestHttpException; use Symfony\Component\Messenger\Envelope; use Symfony\Component\Messenger\MessageBusInterface; use Symfony\Component\Routing\Attribute\Route; use Symfony\Component\Serializer\SerializerInterface; use Symfony\Component\Validator\Validator\ValidatorInterface; class WebhookController { #[Route('/webhook/slack', name: 'webhookSlack')] public function __invoke(Request $request, ValidatorInterface $validator, SerializerInterface $serializer ): JsonResponse { $data = json_decode($request->getContent(), true); if ($data === null) { throw new BadRequestHttpException('Invalid JSON.'); } $dtoClass = SlackUrlValidationRequest::class; $dto = $serializer->denormalize($data, $dtoClass); $errors = $validator->validate($dto); if (count($errors) > 0) { $errorMessages = []; foreach ($errors as $error) { $errorMessages[] = $error->getPropertyPath() . ': ' . $error->getMessage(); } return new JsonResponse(['errors' => $errorMessages], Response::HTTP_BAD_REQUEST); } switch (get_class($dto)) { case SlackUrlValidationRequest::class: return new JsonResponse($dto->getChallenge()); } return new JsonResponse(['status' => 'ok'], Response::HTTP_OK); } } このコントローラは現在、信頼性と安全性で検証要求を処理し、これが私たちの基礎です。 “ .” プロアクティブエージェント プロアクティブエージェント プロアクティブエージェント 現在、サーバーからURL認証メッセージを送信して、Slackの行動をシミュレートすることで、コントローラの機能をテストできます。 Slack イベント メッセージのための DTO 作成 イベントが発生したときにSlackが送信するメッセージを処理し検証するためのDTOを作成します。簡単なURL検証リクエストとは異なり、イベントパイロードにはより多くのデータが含まれていますので、より効果的でモジュール化された検証のためにいくつかのDTOを作成します。 典型的なイベントリクエスト構造 イベントリクエストには、トークン、team_id、api_app_id フィールド、そして最も重要なイベントオブジェクトが含まれます。 { "token": "Jhj5...z412", "team_id": "T061...R6", "api_app_id": "A0PN...2", "event": { "client_msg_id": "92f...d56", "type": "message", "text": "Hey bot, summarize this article for me.", "user": "U214...97", "ts": "167...97", "team": "T061...R6", "channel": "C0PN...L", "event_ts": "167...97", "channel_type": "channel" }, "type": "event_callback", "event_id": "Ev08...6", "event_time": 167...97, "authorizations": [ ... ] } DTOs for Event Handlingの作成 全体的なリクエスト構造の検証をイベントそのものの特性から分離するために、DTOオブジェクトの階層を作成します。 (Wrapper DTO for the entire request) この DTO には、すべてのイベントの一般的なフィールドが含まれます。 SlackEvent.php namespace App\DTO\Slack; use Doctrine\Common\Collections\ArrayCollection; use Symfony\Component\Validator\Constraints as Assert; class SlackEvent { #[Assert\NotBlank] #[Assert\Type('string')] public string $token; #[Assert\NotBlank] #[Assert\Type('string')] public string $team_id; #[Assert\Type('string')] #[Assert\Nullable] public ?string $context_team_id; #[Assert\Type('string')] #[Assert\Nullable] public ?string $context_enterprise_id; #[Assert\NotBlank] #[Assert\Type('string')] public string $api_app_id; #[Assert\NotBlank] public SlackEventData $event; #[Assert\NotBlank] #[Assert\Type('string')] public string $type; #[Assert\NotBlank] #[Assert\Type('string')] public string $event_id; #[Assert\NotBlank] #[Assert\Type('integer')] public int $event_time; public ArrayCollection $authorizations; #[Assert\Type('bool')] public bool $is_ext_shared_channel; #[Assert\NotBlank] #[Assert\Type('string')] public string $event_context; public function __construct(){ $this->authorizations = new ArrayCollection(); } public function getToken(): string { return $this->token; } public function getTeamId(): string { return $this->team_id; } public function getContextTeamId(): ?string { return $this->context_team_id; } public function getContextEnterpriseId(): ?string { return $this->context_enterprise_id; } public function getApiAppId(): string { return $this->api_app_id; } public function getEvent(): SlackEventData { return $this->event; } public function getType(): string { return $this->type; } public function getEventId(): string { return $this->event_id; } public function getEventTime(): int { return $this->event_time; } public function getAuthorizations(): ArrayCollection { return $this->authorizations; } public function isIsExtSharedChannel(): bool { return $this->is_ext_shared_channel; } public function getEventContext(): string { return $this->event_context; } } (イベントオブジェクトのためのDTO) この DTO には、イベントそのものに特有のデータが含まれます。 SlackEventData.php namespace App\DTO\Slack; use Symfony\Component\Validator\Constraints as Assert; class SlackEventData { #[Assert\NotBlank] #[Assert\Type("string")] public string $user; #[Assert\NotBlank] #[Assert\Type("string")] public string $type; #[Assert\NotBlank] #[Assert\Type("string")] public string $ts; #[Assert\NotBlank] #[Assert\Type("string")] public string $client_msg_id; #[Assert\NotBlank] #[Assert\Type("string")] public string $text; #[Assert\NotBlank] #[Assert\Type("string")] public string $team; #[Assert\NotBlank] #[Assert\Type("array")] #[Assert\All([ new Assert\Type("array"), new Assert\Collection([ 'fields' => [ 'type' => [ 'constraints' => [ new Assert\NotBlank(), new Assert\Type("string") ], ], 'block_id' => [ 'constraints' => [ new Assert\NotBlank(), new Assert\Type("string") ], ], 'elements' => [ 'constraints' => [ new Assert\Type("array") ], ], ], ]), ])] public array $blocks; #[Assert\NotBlank] #[Assert\Type("string")] public string $channel; #[Assert\NotBlank] #[Assert\Type("string")] public string $event_ts; #[Assert\NotBlank] #[Assert\Type("string")] public string $channel_type; public function getUser(): string { return $this->user; } public function getType(): string { return $this->type; } public function getTs(): string { return $this->ts; } public function getClientMsgId(): string { return $this->client_msg_id; } public function getText(): string { return $this->text; } public function getTeam(): string { return $this->team; } public function getBlocks(): array { return $this->blocks; } public function getChannel(): string { return $this->channel; } public function getEventTs(): string { return $this->event_ts; } public function getChannelType(): string { return $this->channel_type; } public function getTsDateTime(): \DateTimeImmutable{ // Separate seconds and microseconds list($seconds, $microseconds) = explode('.', $this->getTs()); // Convert to DateTime with microseconds $dateTime = (new \DateTime())->setTimestamp($seconds); $dateTime->modify("+$microseconds microseconds"); return \DateTimeImmutable::createFromMutable($dateTime); } } (許可収集のためのDTO) この DTO には、許可の収集に特有のデータが含まれます。 SlackEventAuthorization.php namespace App\DTO\Slack; use Symfony\Component\Validator\Constraints as Assert; class SlackEventAuthorization { #[Assert\Type('string')] #[Assert\Nullable] public ?string $enterprise_id; #[Assert\NotBlank] #[Assert\Type('string')] public string $team_id; #[Assert\NotBlank] #[Assert\Type('string')] public string $user_id; #[Assert\NotBlank] #[Assert\Type('bool')] public bool $is_bot; #[Assert\NotBlank] #[Assert\Type('bool')] public bool $is_enterprise_install; public function getEnterpriseId(): ?string { return $this->enterprise_id; } public function getTeamId(): string { return $this->team_id; } public function getUserId(): string { return $this->user_id; } public function isIsBot(): bool { return $this->is_bot; } public function isIsEnterpriseInstall(): bool { return $this->is_enterprise_install; } } 検証を分離するために3つの DTO を使用します。 総合要求の構造を確認し、 ネストされたイベントオブジェクトのコンテンツを検証し、および 収集許可証を取得します。 SlackEvent SlackEventData SlackEventAuthorization このアプローチは私たちに柔軟性を提供します。将来、別のイベントタイプ(たとえば app_mention または reaction_added)を処理したい場合は、そのイベントタイプのための新しい DTO を作成し、検証に使用します。 これらの DTO により、当社のコントローラは、Slack からのメッセージを信頼できるように受信し、検証することができ、これは当社の構築における重要なステップです。 “ .” プロアクティブエージェント プロアクティブエージェント プロアクティブエージェント Custom Denormalizerの作成 デフォルト設定では、Symfony Serializer は、複雑で組み込まれたオブジェクトを自動的に deserialize することはできません。 Slack パイロードから当社の DTO に許可オブジェクトの範囲を正しくマッピングするには、カスタムのデノルマライザーが必要です。 SlackEventAuthorization Denormalizer は、構造化されたデータ(マレーまたは JSON オブジェクトなど)を PHP オブジェクトに変換するコンポーネントです. デフォルトの serializer は、単純な属性を扱うことができますが、別の DTO 内に埋め込まれたカスタム DTO のような複雑な構造を処理する方法を知りません. By creating a custom denormalizer, we explicitly tell the serializer how to map the incoming data to our specific object. namespace App\Serializer\Denormalizer; use App\DTO\Slack\SlackEvent; use App\DTO\Slack\SlackEventAuthorization; use Symfony\Component\Serializer\Normalizer\DenormalizerInterface; use Symfony\Component\Serializer\Normalizer\ObjectNormalizer; class SlackEventDenormalizer implements DenormalizerInterface { private ObjectNormalizer $normalizer; public function __construct(ObjectNormalizer $normalizer) { $this->normalizer = $normalizer; } public function denormalize($data, string $type, string $format = null, array $context = []): mixed { $entity = $this->normalizer->denormalize($data, SlackEvent::class, $format, $context); if (isset($data['authorizations']) && is_array($data['authorizations'])) { foreach ($data['authorizations'] as $authorizationData) { $authorization = $this->normalizer->denormalize($authorizationData, SlackEventAuthorization::class, $format, $context); $entity->getAuthorizations()->add($authorization); } } return $entity; } public function supportsDenormalization($data, string $type, string $format = null, array $context = []): bool { return $type === SlackEvent::class; } public function getSupportedTypes(?string $format): array { return [SlackEvent::class => true]; } } 複数のイベントタイプのための更新されたコントローラ We are now ready to modify our webhook controller to handle two types of events: url_verification and event notifications. We will update the controller to use a switch statement to route the requests based on the type field in the payload, making our single endpoint flexible and robust. 私たちは現在、ウェブホックコントローラを変更して2種類のイベントを処理する準備ができています。 更新されたコントローラは、入力する JSON パイロードの種類をチェックします。 url_verification リクエストの場合は、すでに設定した検証を実行します。 namespace App\DTO; class SlackMessage extends MailMessage implements DataCollectionItemInterface { } namespace App\Controller; use App\DTO\DataCollection; use App\DTO\Slack\SlackEvent; use App\DTO\Slack\SlackUrlValidationRequest; use App\DTO\SlackMessage; use App\Message\Command\AIAgentSummarizeMessage; use Symfony\Component\HttpFoundation\JsonResponse; use Symfony\Component\HttpFoundation\Request; use Symfony\Component\HttpFoundation\Response; use Symfony\Component\HttpKernel\Exception\BadRequestHttpException; use Symfony\Component\Messenger\Envelope; use Symfony\Component\Messenger\MessageBusInterface; use Symfony\Component\Routing\Attribute\Route; use Symfony\Component\Serializer\SerializerInterface; use Symfony\Component\Validator\Validator\ValidatorInterface; class WebhookController { #[Route('/webhook/slack', name: 'webhookSlack')] public function __invoke(Request $request, ValidatorInterface $validator, SerializerInterface $serializer, MessageBusInterface $messageBus ): JsonResponse { $data = json_decode($request->getContent(), true); if ($data === null) { throw new BadRequestHttpException('Invalid JSON.'); } $dtoClass = SlackUrlValidationRequest::class; if (array_key_exists('type', $data) && $data['type'] === 'event_callback') { $dtoClass = SlackEvent::class; } $dto = $serializer->denormalize($data, $dtoClass); $errors = $validator->validate($dto); if (count($errors) > 0) { $errorMessages = []; foreach ($errors as $error) { $errorMessages[] = $error->getPropertyPath() . ': ' . $error->getMessage(); } return new JsonResponse(['errors' => $errorMessages], Response::HTTP_BAD_REQUEST); } switch (get_class($dto)) { case SlackUrlValidationRequest::class: return new JsonResponse($dto->getChallenge()); case SlackEvent::class : $emailCollection = new DataCollection( new SlackMessage( 'New Slack message', $dto->getEvent()->getUser(), $dto->getEvent()->getTeam(), $dto->getEvent()->getText(), $dto->getEvent()->getTs(), $dto->getEvent()->getClientMsgId() ) ); $messageBus->dispatch( new Envelope( new AIAgentSummarizeMessage( $emailCollection, 'I have slack message. Please summarize it into a concise overview (100-150 words) focusing on key decisions, action items, and deadlines. Here’s the slack message content:' ) ) ); break; } return new JsonResponse(['status' => 'ok'], Response::HTTP_OK); } } 統一されたワークフローのための継承の活用 わたしたちは新しいものを創造した。 相続するクラス これは、Slack メッセージを私たちのメッセージバスに送信することを可能にする重要な設計決定です。 既存のワークフローを使用します。 SlackMessage メッセージ エージェント メッセージ メッセージ エージェント エージェント 拡大することにより SlackMessage クラスは、私たちのメッセージバスが要求する同じメッセージ契約に自動的に準拠します。 これは、Slackのための新しい、別々の処理パイプラインを構築する必要がないことを意味します。代わりに、SlackMessageのインスタンスをバスに送信し、システムは通常の電子メールのように処理します。 メッセージ エージェント メッセージ エージェント 私たちのコードが完了した今、私たちは私たちのアプリケーションを展開し、実行する準備ができています。 システムでは、コンテナ化されたアプローチを使用します。 Symfonyアプリケーションとデータベースやメッセージブローカーなどの依存関係の両方を管理するプロセスを簡素化します。 プロアクティブエージェント Docker コンポーネント プロアクティブエージェント Docker コンポーネント 結論 THE クラスには Slack 特有のデータが含まれていますが、エージェントに必要なコア属性、たとえばメッセージのコンテンツを継承します。 SlackMessage SlackMessage オブジェクトを標準のアシンク トランスポートで Symfony Message Bus に送信できます. The bus does not need to know the specific type; it just recognizes it as a valid message. AIエージェントは、すでにバスやプロセスからのメッセージを消費するように構成されています。 SlackMessage オブジェクトは、そのコアの論理に変更なしにシームレスに処理できます。 その後、メッセージのコンテンツを使用して、概要や返信を生成するなど、そのタスクを実行できます。 メッセージ エージェント メッセージ エージェント このアプローチは、コードの重複を回避し、システムのアーキテクチャをクリーンでスケーラブルに保つため、非常に効率的です。 新しいコミュニケーションチャネルを簡単に統合し、電子メールやSlackからのすべてのメッセージが単一のインテリジェントなワークフローを通じて処理されるようにします。 プロアクティブエージェント プロアクティブエージェント 次の記事では、コードを使用してコードを簡素化する方法について説明します。 この強力なツールは、Webhook リクエストを処理するためのより高いレベルの抽象化を提供し、これまでに構築したマニュアルコントローラと検証論理のいくつかを必要としないようにします。 symfony/webhook 次に、Slack メッセージへの自動応答を生成するための別々の専用ワークフローを作成します。 これは関連する: 既存のアーキテクチャに基づいて、対応が必要なメッセージを識別できるシステムを設計します。 Advanced Message Processing: どのように使用するかを示します。 インテリジェントでコンテキストに詳しい答えを出す。 Integrating an LLM: 大きな言語モデル 大きな言語モデル 最後に、Slack API クライアントを使用して、生成された応答をユーザーに送信し、コミュニケーションループを閉じ、私たちの ** を完了します。 ●システム Sending a Reply: Proactive Agent プロアクティブエージェント 私たちがこの強力なリアルタイムコミュニケーションプラットフォームを構築し続けるにつれて、気をつけてください。