실시간 AI 에이전트를위한 Slack Incoming and Outgoing Webhooks를 사용하는 방법

이제 우리의 이 그리고 배포할 준비가 되었으니, 새로운 입력 소스를 통합함으로써 기능을 확장해 보자.Slack은 이것을 위한 훌륭한 선택입니다. 응용 컨테이너 응용 컨테이너 실시간 커뮤니케이션을 위한 Slack 통합 특정 Slack 채널에서 새로운 메시지에 대한 실시간 알림을 받기를 원하는 시나리오를 상상해보십시오. (LLMs) 요약 또는 초안 응답을 생성합니다.이 새로운 기능은 우리의 기존 기능과 함께 작동합니다. 여전히 메일 박스를 탐색하고 있습니다. 큰 언어 모델 에이전트는 큰 언어 모델 에이전트는 이 통합은 우리의 Proactive Agent 시스템의 기초가 될 것입니다.Slack과 이메일을 동시에 모니터링함으로써, 우리의 응용 프로그램은 통신을위한 중앙 집중화 된 허브가되며, 메시지가 놓치지 않고 모든 쿼리가 신속하게 처리됩니다.이 이중 소스 접근 방식은 전통적이고 현대적인 통신 플랫폼을 결합하여 포괄적 인 솔루션을 제공하는 잘 설계된 시스템의 힘과 유연성을 보여줍니다. 새로운 Slack 메시지에 대한 알림을 받으려면 출력 메시지를 사용할 수 있습니다. Webhook는 소스 시스템의 이벤트에 의해 유발되는 사용자 정의된 HTTP 콜백백입니다.When the event occurs, the source system makes a HTTP/HTTPS request to the URL configured in the source system. . Webhooks Webhook Slack Webhooks가 작동하는 방법 Slack의 맥락에서는 특정 채널 또는 작업 영역에 대한 출력 Webhook가 구성됩니다. 특정 기준 (예: 특정 키워드, 패턴)을 충족하는 메시지 또는 이벤트가 게시되면 Slack은 지정된 URL로 HTTP POST 요청을 보냅니다. 그런 다음 들어오는 데이터를 처리합니다. 응용 응용 이 메커니즘은 매우 효율적이기 때문에 우리의 애플리케이션이 지속적으로 새로운 메시지에 대해 Slack을 조사하는 대신 (이것은 리소스 집중적이고 비효율적입니다), Slack은 이벤트가 일어날 때 즉시 우리에게 정보를 적극적으로 "추적합니다."이것은 반응적이고 지능형 시스템을 구축하는 기초입니다. 이벤트 주도 이벤트 주도 왜 Webhooks를 선택합니까? 그들이 일어날 때 메시지를 받으십시오, 즉각적인 행동을 허용합니다. Real-time updates: 우리의 응용 프로그램은 Slack 설문 조사를 할 필요가 없으며 API 호출 및 서버 리소스를 절약합니다. Reduced resource usage: Webhooks는 다양한 서비스를 연결하는 표준적이고 간단한 방법입니다. Simple integration: 이 접근법은 A를 구축하는 데 중요하다. Slack 또는 이메일과 같은 다른 소스에서 오는 새로운 커뮤니케이션에 즉시 응답합니다. Proactive Agent Incoming and Outgoing Webhooks에 대한 리뷰 보기 예, Slack에는 들어오는 웹 호크와 나오는 웹 호크가 있습니다.These are two distinct mechanisms that serve different purposes in a communication workflow. Webhooks 오픈 그들은 무엇입니까: 이것은 Slack에서 가장 일반적인 유형의 webhook입니다.They allow external applications to send (push) messages into a Slack channel. Slack은 고유한 URL을 제공합니다.Your application makes a HTTP POST request to this URL, sending a JSON payload with the message text and formatting. Incoming Webhooks는 알림, 알림 및 자동 메시지에 사용되며, 예를 들어 새로운 GitHub 의무, 배포 상태 또는 우리의 메시지에 대한 알림을 보낼 수 있습니다. Slack으로 돌아갑니다. Proactive 에이전트는 에이전트는 에이전트는 출발 Webhooks 이것은 Slack이 채널에서 특정 이벤트가 발생할 때 외부 애플리케이션에 데이터를 보낼 수 있는 전통 메커니즘입니다.This is a legacy mechanism that allows Slack to send (push) data to an external application when a specific event occurs in a channel. 응용 프로그램의 URL을 지정하고 트리거 단어 또는 이벤트를 설정하여 출력 웹 호크를 구성합니다.When a user in a Slack channel posts a message containing one of these words, Slack makes a HTTP POST request to your application's URL. 생성하기 위해 사용되는 Outgoing Webhooks 특정 명령이나 키워드에 반응하는 자동화 인터랙티브 로봇 인터랙티브 로봇 우리의 시나리오에서, 우리는 우리의 에이전트가 요약을 생성하기 위해 메시지를 수신하고 처리 할 수 있도록 요약 같은 트리거와 출력 웹 호크를 설정합니다.In our scenario, we set up a outgoing webhook with a trigger like summary so our agent can receive and process the message to generate a summary. 주요 차이점 Incoming Webhooks는 Slack(외부 소스에서)로 메시지를 보내는 데 사용됩니다.Incoming Webhooks are used to send messages to Slack (from an external source). Outgoing Webhooks는 Slack (외부 소스)에서 메시지를 수신하는 데 사용되지만 특정 트리거를 기반으로 만 사용됩니다. 우리에 관한 우리의 기사에서 , 우리는 처리하기 위해 Slack에서 메시지를 받기 위해 출력 웹 호크와 Slack로 응답을 보내기 위해 들어오는 웹 호크를 사용합니다. “Proactive Agent” Slack 앱 만들기 단계별 가이드 Step-by-Step Guide to Creating a Slack App Slack이 우리에게 webhook 이벤트를 보낼 수 있도록 하려면 먼저 개발자 포털에서 응용 프로그램을 만들고 Slack 워크 스페이스 또는 우리가 알림을 받기를 원하는 특정 채널에 설치해야 합니다. Slack API 웹사이트에 액세스하십시오: Navigate to . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps "App 만들기"를 클릭하고 "아래부터"를 구축하도록 선택합니다. 앱 이름을 설명하고 Slack 작업 영역을 선택하여 개발 및 테스트를 할 것입니다.이 곳에서 앱을 설치하여 웹 호크 URL을 얻을 수 있습니다. 이벤트 구독 활성화: 앱 설정에서 "Event Subscriptions" 섹션으로 이동하고 "Events 활성화"를 켜십시오. 요청 URL 제공: 귀하의 응용 프로그램에 대해 공개적으로 액세스할 수 있는 URL을 제공해야 합니다. 이것은 Slack이 이벤트 비용로드를 보내는 엔드포인트입니다. Slack은 단일 URL 확인 검사를 수행하여 귀하의 응용 프로그램이 Slack 요청의 도전 값으로 응답해야 합니다. 봇 이벤트에 가입: “봇 이벤트에 가입” 섹션으로 스크롤합니다. “봇 사용자 이벤트 추가”를 클릭하고 message.channels 이벤트를 선택합니다. 이것은 Slack에게 공개 채널에 게시된 모든 메시지에 대해 앱에 페이로드를 보낼 것을 알려줍니다. 요청 범위: 이러한 이벤트를 수신하려면 봇에 적절한 권한이 필요합니다. “OAuth & Permissions” 섹션에서 봇 토큰에 channels:history 범위를 추가합니다.This grants your app the ability to view messages in public channels. 앱 재설치: 새로운 범위를 추가한 후에는 변경 사항이 적용되기 위해 작업 영역에 앱을 재설치해야 합니다. 이러한 단계들에 따라, 우리의 가입 채널의 모든 새로운 메시지에 대해 완전한 JSON 유용량을 받게 되며, 기존 트리거워드 방법보다 더 많은 컨텍스트와 유연성을 제공합니다.This modern approach is the foundation for building advanced, . proactive agent AI-powered 애플리케이션 AI-powered 애플리케이션 AI-powered 애플리케이션 Webhook Validation 관리 우리는 Symfony 측면에서 webhooks와 함께 작업 할 수있는 두 가지 옵션이 있습니다 : 우리는 컨트롤러 수준에서 그것을 처리하거나 컨트롤러를 사용할 수 있습니다. 이 문서에서는 컨트롤러 수준에서 작업에 초점을 맞출 것입니다.다음 포스트에서는 컨트롤러 수준을 사용하여이 작업을 수행하는 방법을 보여 드리겠습니다. . symfony/webhook Symfony Webhook Component Slack의 이벤트 구독에서 엔드포인트 URL을 구성하면 Slack은 URL이 유효하고 응용 프로그램에 속하는지 확인하기 위해 초기 확인 요청을 보냅니다.This request is a simple HTTP POST request with a JSON body that includes a 우리의 엔드포인트는 요청체의 정확한 도전 값으로 응답해야 합니다.Our endpoint must respond with the exact challenge value from the request body. challenge 웹 호크 요청을 적절하게 처리하려면 사용량을받을뿐만 아니라 정확성을 확인해야합니다. (DTOs) 및 두 가지 핵심 Symfony 구성 요소를 설치: 그리고 . 데이터 전송 객체 symfony/validator symfony/serializer-pack 데이터 전송 객체 데이터 전송 객체 왜 이러한 구성 요소가 중요합니까? 이 구성 요소는 규칙 집합에 따라 데이터를 검증하는 강력한 프레임 워크를 제공합니다. if-else 문서를 수동으로 작성하여 각 필드를 검사하는 대신 DTO 속성에 직접 검증 제한(예: NotBlank, Type, Length)을 정의할 수 있습니다. symfony/validator: 이 구성 요소 팩은 serialization (objects into array/JSON) 및 deserialization (JSON/arrays into objects) 데이터에 필요한 모든 것을 제공합니다.We will use the deserializer to automatically convert the incoming JSON payload from Slack into a validated DTO object.This process automates the boring task of mapping data fields, ensuring the payload structure matches our expectations. symfony/serializer-pack: 그리고 이제 우리는 Doctrine이 제공하는 더 고급 컬렉션을 사용할 준비가되었습니다. component just yet; instead, we will install only the package for working with . Doctrine collections PHP 배열은 다재다능하지만, 타입 힌트, 불변성 및 필터링 또는 매핑을위한 전문적인 방법과 같은 일부 고급 기능이 부족합니다. 배열 주위에 강력하고 객체 지향적 인 포장기를 제공하여 데이터를 관리하는 더 강력하고 예측 가능한 방법을 제공합니다.This is useful for our data. 우리가 메시지 목록, 사용자 또는 기타 데이터 유용 부하를 다루는 시스템입니다. Doctrine Collections Proactive Agent 이 작지만 영향력있는 변화는 우리가 데이터를 관리하는 방식을 크게 향상시킬 것입니다. 우리의 에이전트의 논리를 더 강력하고 유지하기 쉽습니다. 우리의 응용 우리의 응용 필요한 구성 요소를 설치하려면 단순히 다음 명령을 터미널에서 실행하십시오. composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack The Workflow for Validating a Webhook Payload에 대한 정보 요청 받기: 우리의 Symfony 컨트롤러는 Slack에서 HTTP POST 요청을 받습니다. Deserialize to DTO: 우리는 serializer를 사용하여 JSON 유용 부하를 미리 정의된 DTO 개체로 변환합니다. DTO 검증: 검증 구성 요소는 정의된 제약에 대하여 DTO의 속성을 검사합니다. 오류 처리: 인증이 실패하면 Slack에 오류 응답 (예: 400 Bad Request)을 반환합니다. 프로세스 유효한 데이터: 검증이 성공하면, 우리의 응용 프로그램은 올바른 형식에 있는지 알면서 안전하게 웹 호크 데이터를 처리할 수 있습니다. 이 구조화 된 접근 방식은 우리의 응용 프로그램이 탄력적이며, 신뢰할 수 있고 안전한 시스템을 구축하는 중요한 단계인 예상된 형식에 맞는 데이터만을 처리한다는 것을 보장합니다. 단일 컨트롤러 내에서 여러 Payloads를 처리 우리는 또한 우리의 컨트롤러와 단일 경로가 제대로 처리되어야한다는 것을 고려해야합니다. , URL 검증에서 우리가 구독한 작업 이벤트 payloads에 이르기까지. different types of payloads 이것은 강력한 웹 호크 엔드포인트의 핵심 요구 사항입니다. 단일 경로가 한 번의 URL 검증 요청과 라이브 이벤트 알림을 구별하기에 충분히 똑똑해야 합니다.Our controller should be able to process each request type accordingly. 앞서 언급했듯이, Slack의 초기 URL 검증 유용량에는 고유 한 기능이 포함되어 있습니다. 모든 후속 이벤트 페이로드에는 실제 메시지 데이터를 보유하는 이벤트 키가 포함되어 있습니다.Our controller must check for the presence of these keys to determine the nature of the request. challenge 일반적인 Slack URL 검증 요청 괜찮아요, Slack에서 URL 검증 요청을 검증하기 위해 DTO를 만들자.첫째, 일반적인 Slack URL 검증 요청 페이로드가 어떻게 생겼는지 알아보자. 이벤트 구독을 활성화하면 Slack은 토큰, 도전 및 입력 세 가지 핵심 필드를 포함하는 JSON 유용 부하를 사용하는 엔드포인트에 POST 요청을 보냅니다.When you enable Event Subscriptions, Slack sends a POST request to your endpoint with a JSON payload that contains three key fields: token, challenge, and type. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } 귀하의 응용 프로그램에 대한 고유 토큰.이를 사용하여 요청이 귀하의 응용 프로그램에서 오는지 확인할 수 있습니다. token: JSON 응답에서 이 정확한 문자열을 반환하여 URL을 소유하고 있음을 증명해야 합니다.You must return this exact string in your JSON response to prove you own the URL. challenge: 이벤트 유형 확인을 위해, 이것은 항상 url_verification이 될 것입니다. type: DTO 만들기 이제 Symfony의 검증 구성 요소를 사용하여 이 구조를 반영하고 검증 제약을 포함하는 DTO를 만들 것입니다.We will use attributes to define the validation rules directly on the DTO properties. 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는 검증을 단순화합니다: 토큰, 도전 및 타입 필드가 요청에 존재하는지 확인합니다.Serves that the token, challenge, and type fields are present in the request. Assert\NotBlank: 각 필드의 값이 문자열임을 확인하여 예기치 않은 데이터 형식을 방지합니다.Confirms that each field's value is a string, preventing unexpected data types. Assert\Type(“string”): 타입 필드가 필요한 문자열과 일치한다는 것을 구체적으로 검증하므로 다른 이벤트 유형이 아닌 URL 검증 요청을 처리하고 있음을 알 수 있습니다.Specifically validates that the type field matches the required string, so we know we are handling an URL verification request and not another event type. Assert\EqualTo(“url_verification”): 이 DTO를 사용함으로써, 우리는 들어오는 JSON 유용 부하를 deserialize하고 최소한의 코드로 자동으로 구조를 검증할 수 있습니다.This makes our endpoint more secure and reliable. Slack Webhook Validation에 대한 컨트롤러 만들기 완벽하게, 사용하는 컨트롤러를 만들자 이 컨트롤러는 들어오는 요청이 URL 확인 요청인지 확인하고 도전 코드를 반환하여 올바르게 처리합니다.This controller will check if the incoming request is an URL verification request and handle it correctly by returning the challenge code. SlackUrlValidationRequest 우리는 그것을 주입할 것이다 JSON 페이로드를 우리의 DTO 및 이 방법은 코드를 깨끗하고 신뢰할 수 있으며 Symfony 표준을 준수합니다.This approach makes the code clean, reliable and compliant with Symfony standards. 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); } } 이 컨트롤러는 이제 신뢰할 수 있고 안전하게 검증 요청을 처리하며, 이는 우리의 기초입니다. “ .” 적극적인 에이전트 적극적인 에이전트 적극적인 에이전트 이제 우리는 Slack의 행동을 시뮬레이션하여 서버에서 URL 검증 메시지를 보내서 컨트롤러가 어떻게 작동하는지 테스트할 수 있습니다.This check will ensure our endpoint is configured correctly and ready to receive real event data. Slack 이벤트 메시지에 대한 DTO 만들기 이제 이벤트가 발생할 때 Slack이 보내는 메시지를 처리하고 검증하는 DTO를 만들자.단순한 URL 검증 요청과는 달리 이벤트 유용량에는 훨씬 더 많은 데이터가 포함되어 있으므로 더 효과적이고 모듈형 검증을 위해 여러 DTO를 만들 것입니다. 일반 이벤트 요청 구조(Typical Event Request Structure) 이벤트 요청에는 토큰, team_id, api_app_id 필드, 그리고 가장 중요한 것은 이벤트 개체가 포함됩니다.In the event object, you will find information about the event type (message, app_mention, etc.), the message text, user data, and the channel information. { "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": [ ... ] } Event Handling를 위한 DTOs 만들기 전체 요청 구조의 검증을 이벤트 자체의 특성과 분리하기 위해 DTO 객체의 계층을 만들 것입니다.We will create a hierarchy of DTO objects to separate the validation of the overall request structure from the specifics of the event itself. (모든 요청에 대한 Wrapper DTO) 이 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; } } (Event Object에 대한 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; } } 우리는 검증을 분리하기 위해 세 가지 DTO를 사용합니다. 전체 요청 구조를 검증하는 동안, 삽입된 이벤트 개체의 내용을 검증하고, 권한 수집을 승인합니다.Validate authorization collection. SlackEvent SlackEventData SlackEventAuthorization 미래에 우리가 다른 이벤트 유형 (예: app_mention 또는 reaction_added)을 처리하고자 한다면, 우리는 단순히 그 이벤트 유형에 대한 새로운 DTO를 만들고 검증을 위해 사용합니다. 이러한 DTO를 사용하면 컨트롤러가 Slack의 메시지를 신뢰성있게 수신하고 검증할 수 있으며, 이는 우리의 컨트롤러를 구축하는 중요한 단계입니다. “ .” 적극적인 에이전트 적극적인 에이전트 적극적인 에이전트 Custom Denormalizer 만들기 기본 구성에서 Symfony Serializer는 자동으로 복잡하고 둥지 된 개체를 deserialize할 수 없습니다. Slack 유용량에서 우리의 DTO로 권한 개체의 배열을 올바르게 매핑하려면, 우리는 사용자 지정 denormalizer가 필요합니다. SlackEventAuthorization Denormalizer는 구조화된 데이터 (예: 배열 또는 JSON 개체)를 PHP 개체로 변환하는 구성 요소입니다.The default serializer can handle simple properties, but it does not know how to handle complex structures like an array of custom DTOs nested within another 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]; } } 여러 이벤트 유형을 위한 업데이트된 컨트롤러 우리는 이제 두 가지 유형의 이벤트를 처리하기 위해 웹 호크 컨트롤러를 수정할 준비가 되었습니다: url_verification 및 이벤트 알림.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. 업데이트된 컨트롤러는 들어오는 JSON 유용량의 유형을 확인합니다. url_verification 요청이라면 이미 설정한 인증을 수행합니다. event_callback이라면 실제 Slack 이벤트를 처리하는 과정을 시작합니다. 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 Compose에 대한 정보 적극적인 에이전트 Docker Compose에 대한 정보 결론 이 클래스는 Slack-specific 데이터를 포함하지만 메시지 내용과 같은 에이전트에 필요한 핵심 속성을 상속합니다.And we will transform it to Interfaces approach. 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 객체를 핵심 논리에 아무런 변화없이 순조롭게 처리할 수 있습니다. 메시지의 내용을 사용하여 요약 또는 응답 생성과 같은 작업을 수행할 수 있습니다. can then use the message's content to perform its tasks, such as summarization or generating a response. 메일 메시지 에이전트 메일 메시지 에이전트 이 접근법은 코드 복제를 피하고 시스템 아키텍처를 깨끗하고 확장 가능하게 유지하기 때문에 매우 효율적입니다. 새로운 커뮤니케이션 채널을 쉽게 통합하여 이메일이나 Slack에서 온 모든 메시지를 하나의 지능형 워크플로우를 통해 처리할 수 있습니다. 적극적인 에이전트 적극적인 에이전트 다음 기사에서는 코드를 사용하여 코드를 단순화하는 방법을 탐구할 것입니다. 이 강력한 도구는 웹 호크 요청을 처리하기위한 더 높은 수준의 추상화를 제공하여 지금까지 우리가 구축한 수동 컨트롤러 및 검증 논리의 일부가 필요하지 않습니다. symfony/webhook 그런 다음 Slack 메시지에 대한 자동 응답을 생성하기위한 별도의 전용 워크플로우를 만듭니다. 이것은 포함될 것입니다 : 기존 아키텍처를 바탕으로 우리는 응답이 필요한 메시지를 식별할 수 있는 시스템을 설계할 것입니다. Advanced Message Processing: 우리는 어떻게 사용하는지 보여줄 것입니다 a 똑똑하고 컨텍스트에 의식적인 답을 제시합니다. Integrating an LLM: 넓은 언어 모델 넓은 언어 모델 마지막으로, 우리는 Slack API 클라이언트를 사용하여 생성 된 응답을 사용자에게 돌려 보내서 통신 루프를 닫고 우리의 **를 완료합니다. • 시스템 Sending a Reply: 적극적인 에이전트 적극적인 에이전트 이 강력한 실시간 커뮤니케이션 플랫폼을 계속 개발할 때 조심하십시오.