Làm thế nào để sử dụng Slack Incoming và Outgoing Webhooks cho các đại lý AI thời gian thực

Bây giờ chúng ta là và sẵn sàng để triển khai, hãy mở rộng khả năng của nó bằng cách tích hợp một nguồn đầu vào mới. Slack là một lựa chọn tuyệt vời cho điều này. Ứng dụng container hóa Ứng dụng container hóa Tích hợp Slack cho truyền thông thời gian thực Hãy tưởng tượng một kịch bản mà chúng ta muốn nhận được thông báo thời gian thực cho tin nhắn mới trong các kênh Slack cụ thể. (LLMs) để tạo các tóm tắt hoặc dự thảo câu trả lời. chức năng mới này sẽ làm việc song song với , mà tiếp tục khảo sát hộp thư. Các mô hình ngôn ngữ lớn Người đại diện Các mô hình ngôn ngữ lớn Người đại diện Sự tích hợp này sẽ là nền tảng của hệ thống Proactive Agent của chúng tôi.Bằng cách đồng thời giám sát Slack và email, ứng dụng của chúng tôi trở thành một trung tâm tập trung cho truyền thông, đảm bảo không có tin nhắn bị bỏ lỡ và mỗi truy vấn được xử lý kịp thời. cách tiếp cận hai nguồn này chứng minh sức mạnh và tính linh hoạt của một hệ thống được thiết kế tốt, kết hợp cả hai nền tảng truyền thống và hiện đại truyền thông cho một giải pháp toàn diện. Để nhận thông báo về các tin nhắn Slack mới, chúng tôi có thể sử dụng Một Webhook là một cuộc gọi HTTP được định nghĩa bởi người dùng được kích hoạt bởi một sự kiện trong một hệ thống nguồn. Khi sự kiện xảy ra, hệ thống nguồn thực hiện một yêu cầu HTTP / HTTPS đến URL được cấu hình trong . Webhooks Webhook Làm thế nào Slack Webhooks hoạt động Trong bối cảnh của Slack, một Webhook xuất phát được cấu hình cho một kênh hoặc không gian làm việc cụ thể. Khi một thông điệp được đăng hoặc sự kiện đạt được đáp ứng một tiêu chí nhất định (ví dụ, một từ khóa cụ thể, mô hình), Slack gửi một yêu cầu HTTP POST đến một URL được chỉ định. , sau đó xử lý dữ liệu vào. Ứng dụng Ứng dụng Hệ thống này rất hiệu quả bởi vì Thay vì ứng dụng của chúng tôi liên tục khảo sát Slack cho các thông điệp mới (đó là nguồn lực và không hiệu quả), Slack chủ động "đẩy" thông tin cho chúng tôi ngay khi một sự kiện xảy ra. Sự kiện-Driven Sự kiện-Driven Tại sao chọn Webhooks? Nhận tin nhắn khi chúng xảy ra, cho phép hành động ngay lập tức. Real-time updates: Ứng dụng của chúng tôi không cần khảo sát Slack, tiết kiệm các cuộc gọi API và tài nguyên máy chủ. Reduced resource usage: Webhooks là một cách tiêu chuẩn và đơn giản để kết nối các dịch vụ khác nhau. Simple integration: Cách tiếp cận này rất quan trọng để xây dựng một đáp ứng ngay lập tức với các thông tin liên lạc mới, cho dù chúng xuất phát từ Slack hay các nguồn khác như email. Proactive Agent Incoming và Outgoing Webhooks Có, Slack có cả webhooks đến và ra. Đây là hai cơ chế riêng biệt phục vụ các mục đích khác nhau trong một dòng công việc truyền thông. Trang chủ Webhooks Chúng là gì: Đây là loại webhook phổ biến nhất trong Slack. Chúng cho phép các ứng dụng bên ngoài gửi (đẩy) tin nhắn vào kênh Slack. Ứng dụng của bạn thực hiện một yêu cầu HTTP POST đến URL này, gửi một tải trọng JSON với văn bản tin nhắn và định dạng. Incoming Webhooks được sử dụng cho thông báo, cảnh báo và tin nhắn tự động. Ví dụ, để gửi thông báo về cam kết GitHub mới, trạng thái triển khai, hoặc tin nhắn từ chúng tôi Trở lại Slack Proactive Người đại diện Người đại diện Người đại diện Lời bài hát Outgoing Webhooks Đây là một cơ chế cổ xưa cho phép Slack gửi (đẩy) dữ liệu đến một ứng dụng bên ngoài khi một sự kiện cụ thể xảy ra trong một kênh. Bạn cấu hình một webhook xuất bằng cách chỉ định URL của ứng dụng của bạn và kích hoạt các từ hoặc sự kiện.Khi một người dùng trong kênh Slack đăng một thông điệp có chứa một trong những từ này, Slack thực hiện một yêu cầu HTTP POST cho URL của ứng dụng của bạn. Outgoing Webhooks được sử dụng để tạo và tự động hóa phản ứng với các lệnh hoặc từ khóa cụ thể. Robot tương tác Robot tương tác Trong kịch bản của chúng tôi, chúng tôi thiết lập một webhook xuất phát với một trình kích hoạt như tóm tắt để đại lý của chúng tôi có thể nhận và xử lý thông điệp để tạo ra tóm tắt. Sự khác biệt chính Incoming Webhooks được sử dụng để gửi tin nhắn đến Slack (từ một nguồn bên ngoài). Outgoing Webhooks được sử dụng để nhận tin nhắn từ Slack (cho một nguồn bên ngoài), nhưng chỉ dựa trên một kích hoạt cụ thể. Trong bối cảnh của bài viết của chúng tôi về , chúng tôi sử dụng một webhook đi ra để nhận tin nhắn từ Slack để xử lý và một webhook đến để gửi phản hồi trở lại Slack. “Proactive Agent” Hướng dẫn từng bước để tạo một ứng dụng Slack Để cho phép Slack gửi cho chúng tôi các sự kiện webhook, trước tiên chúng tôi phải tạo một ứng dụng trong cổng thông tin nhà phát triển và cài đặt nó vào không gian làm việc Slack hoặc một kênh cụ thể mà từ đó chúng tôi muốn nhận thông báo. Truy cập trang web Slack API: Navigate to . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps Nhấp vào "Tạo một ứng dụng" và chọn để xây dựng nó "Từ đầu". Cung cấp cho ứng dụng của bạn một tên mô tả và chọn không gian làm việc Slack nơi bạn sẽ phát triển và thử nghiệm nó. Kích hoạt đăng ký sự kiện: Trong cài đặt ứng dụng của bạn, hãy điều hướng đến phần “Đăng ký sự kiện” và bật “Kích hoạt sự kiện”. Cung cấp URL yêu cầu: Bạn phải cung cấp một URL có thể truy cập công khai cho ứng dụng của mình.Đây là điểm cuối mà Slack sẽ gửi tải trọng lợi nhuận sự kiện.Slack sẽ thực hiện kiểm tra xác minh URL một lần, nơi ứng dụng của bạn phải trả lời với giá trị thách thức từ yêu cầu của Slack.Chúng tôi sẽ tạo điểm cuối này trong ứng dụng Symfony của chúng tôi. Subscribe to Bot Events: Cuộn xuống phần “Subscribe to bot events” (Đăng ký các sự kiện bot). Nhấp vào “Add Bot User Event” (Thêm sự kiện người dùng bot) và chọn sự kiện message.channels. Mục đích yêu cầu: Để nhận các sự kiện này, bot của bạn sẽ cần các quyền thích hợp. Trong phần “OAuth & Permissions”, thêm phạm vi kênh:lịch sử vào token bot của bạn. Điều này cho phép ứng dụng của bạn khả năng xem tin nhắn trong các kênh công cộng. Cài đặt lại ứng dụng của bạn: Sau khi thêm phạm vi mới, bạn phải cài đặt lại ứng dụng của mình vào không gian làm việc để các thay đổi có hiệu lực. Bằng cách thực hiện các bước này, chúng tôi sẽ nhận được một tải trọng JSON đầy đủ cho mỗi tin nhắn mới trong các kênh đăng ký, cung cấp nhiều bối cảnh và tính linh hoạt hơn so với phương pháp trigger-word cổ xưa. . proactive agent AI-powered ứng dụng AI-powered ứng dụng AI-powered ứng dụng Quản lý Webhook Validation Đã đến lúc tạo một điểm cuối để xử lý câu trả lời cho yêu cầu xác thực điểm cuối của chúng tôi.Chúng tôi có hai lựa chọn để làm việc với webhooks ở phía Symfony: chúng tôi có thể xử lý nó ở cấp độ bộ điều khiển hoặc sử dụng Trong bài viết này, chúng tôi sẽ tập trung vào việc làm việc ở cấp độ bộ điều khiển. Trong một bài viết trong tương lai, tôi sẽ chỉ cho bạn cách làm điều này bằng cách sử dụng . symfony/webhook Symfony Webhook Component Khi bạn cấu hình URL điểm cuối trong Slack's Event Subscriptions, Slack sẽ gửi yêu cầu xác minh ban đầu để xác nhận rằng URL là hợp lệ và thuộc về ứng dụng của bạn. Điểm cuối của chúng tôi phải trả lời với giá trị thách thức chính xác từ cơ thể yêu cầu. challenge Để xử lý yêu cầu webhook một cách chính xác, chúng tôi phải không chỉ nhận được tải trọng mà còn xác nhận tính chính xác của nó. (DTOs) và cài đặt hai thành phần Symfony chính: và . Chuyển dữ liệu đối tượng symfony/validator symfony/serializer-pack Chuyển dữ liệu đối tượng Chuyển dữ liệu đối tượng Tại sao các thành phần này rất cần thiết Thành phần này cung cấp một khuôn khổ mạnh mẽ để xác thực dữ liệu chống lại một tập hợp các quy tắc. Thay vì viết một cách thủ công các tuyên bố if-else để kiểm tra từng trường, chúng tôi có thể xác định các hạn chế xác nhận (ví dụ: NotBlank, Type, Length) trực tiếp trên các thuộc tính DTO của chúng tôi. symfony/validator: Gói thành phần này cung cấp mọi thứ chúng ta cần để serialize (chuyển đổi đối tượng thành mảng / JSON) và deserialize (chuyển đổi JSON / mảng thành đối tượng) dữ liệu. chúng tôi sẽ sử dụng deserializer để tự động chuyển đổi tải trọng JSON đến từ Slack thành một đối tượng DTO được xác nhận. quy trình này tự động hóa nhiệm vụ nhàm chán của bản đồ các trường dữ liệu, đảm bảo cấu trúc tải trọng phù hợp với kỳ vọng của chúng tôi. symfony/serializer-pack: Và bây giờ chúng tôi đã sẵn sàng để sử dụng các bộ sưu tập tiên tiến hơn mà Doctrine cung cấp. component chưa; thay vào đó, chúng tôi sẽ chỉ cài đặt gói để làm việc với . Doctrine collections Trong khi các mảng PHP linh hoạt, chúng thiếu một số tính năng tiên tiến như gợi ý kiểu, bất biến và các phương pháp chuyên môn để lọc hoặc lập bản đồ. cung cấp một vòng tròn mạnh mẽ, hướng đối tượng xung quanh các mảng, cho chúng tôi một cách mạnh mẽ và có thể dự đoán hơn để quản lý dữ liệu. hệ thống, nơi chúng tôi sẽ xử lý danh sách tin nhắn, người dùng hoặc tải trọng dữ liệu khác. Doctrine Collections Proactive Agent Những thay đổi nhỏ nhưng có tác động này sẽ cải thiện đáng kể cách chúng tôi quản lý dữ liệu trong , làm cho logic của đại lý của chúng tôi mạnh mẽ hơn và dễ duy trì hơn. our application Ứng dụng của chúng tôi Để cài đặt các thành phần cần thiết, chỉ cần chạy lệnh sau trong thiết bị đầu cuối của bạn: composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack Các dòng công việc để xác nhận một Webhook Payload Nhận yêu cầu: Bộ điều khiển Symfony của chúng tôi nhận được yêu cầu HTTP POST từ Slack. Deserialize to DTO: Chúng tôi sử dụng serializer để chuyển đổi tải trọng JSON thành đối tượng DTO được xác định sẵn của chúng tôi. Xác nhận DTO: Thành phần xác nhận kiểm tra các thuộc tính của DTO chống lại các hạn chế được xác định. Xử lý lỗi: Nếu xác thực thất bại, chúng tôi trả về một câu trả lời lỗi (ví dụ, 400 Bad Request) cho Slack. Xử lý dữ liệu hợp lệ: Nếu xác nhận thành công, ứng dụng của chúng tôi có thể an toàn tiến hành xử lý dữ liệu webhook, biết rằng nó ở định dạng chính xác. Cách tiếp cận có cấu trúc này đảm bảo rằng ứng dụng của chúng tôi có khả năng phục hồi và chỉ xử lý dữ liệu phù hợp với định dạng mong đợi của chúng tôi, đó là một bước quan trọng trong việc xây dựng một hệ thống đáng tin cậy và an toàn. Xử lý nhiều payloads trong một controller duy nhất Chúng ta cũng nên xem xét rằng bộ điều khiển của chúng ta và một tuyến đường duy nhất phải xử lý đúng cách , từ xác nhận URL đến các payloads sự kiện làm việc mà chúng tôi đã đăng ký. different types of payloads Đây là một yêu cầu quan trọng cho một điểm cuối webhook mạnh mẽ. Một tuyến đường duy nhất phải đủ thông minh để phân biệt giữa một yêu cầu xác minh URL một lần và một thông báo sự kiện trực tiếp. bộ điều khiển của chúng tôi nên có thể xử lý từng loại yêu cầu tương ứng. Như đã thảo luận trước đó, tải trọng hiệu quả xác minh URL ban đầu từ Slack chứa một Tất cả các khoản phí sự kiện tiếp theo chứa một khóa sự kiện chứa dữ liệu tin nhắn thực tế. bộ điều khiển của chúng tôi phải kiểm tra sự hiện diện của các khóa này để xác định bản chất của yêu cầu. challenge Yêu cầu xác thực URL Slack Okay, chúng ta hãy tạo một DTO để xác minh yêu cầu xác minh URL từ Slack. Thứ nhất, đây là những gì một yêu cầu xác thực URL Slack thông thường có vẻ như thế nào. Khi bạn bật đăng ký sự kiện, Slack sẽ gửi yêu cầu POST đến điểm cuối của bạn với tải trọng JSON có chứa ba trường chính: token, thách thức và nhập. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } Một token duy nhất cho ứng dụng của bạn. Bạn có thể sử dụng điều này để xác minh yêu cầu là từ ứng dụng của bạn. token: Bạn phải trả về chuỗi chính xác này trong câu trả lời JSON của bạn để chứng minh bạn sở hữu URL. challenge: Đối với xác nhận, đây sẽ luôn luôn là url_verification. type: Tạo ra DTO Bây giờ, chúng tôi sẽ tạo ra một DTO phản ánh cấu trúc này và bao gồm các hạn chế xác nhận bằng cách sử dụng thành phần xác nhận của Symfony. 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 này đơn giản hóa xác nhận: Đảm bảo rằng các trường token, thách thức và kiểu hiện diện trong yêu cầu. Assert\NotBlank: Xác nhận rằng giá trị của mỗi trường là một chuỗi, ngăn ngừa các kiểu dữ liệu bất ngờ. Assert\Type(“string”): Cụ thể xác nhận rằng trường kiểu khớp với chuỗi yêu cầu, vì vậy chúng tôi biết rằng chúng tôi đang xử lý một yêu cầu xác minh URL và không phải là một loại sự kiện khác. Assert\EqualTo(“url_verification”): Bằng cách sử dụng DTO này, chúng tôi có thể deserialize tải trọng JSON đến và tự động xác nhận cấu trúc của nó với mã tối thiểu trong bộ điều khiển của chúng tôi. Tạo Controller cho Slack Webhook Validation Hoàn hảo, hãy tạo một bộ điều khiển sử dụng một DTO để xác minh yêu cầu từ Slack. bộ điều khiển này sẽ kiểm tra xem yêu cầu đến có phải là yêu cầu xác minh URL hay không và xử lý nó đúng cách bằng cách trả về mã thách thức. SlackUrlValidationRequest Chúng tôi sẽ tiêm để deserialize payload JSON vào DTO của chúng tôi và Cách tiếp cận này làm cho mã sạch sẽ, đáng tin cậy và tuân thủ các tiêu chuẩn 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); } } Bộ điều khiển này bây giờ xử lý các yêu cầu xác minh một cách đáng tin cậy và an toàn, đó là nền tảng cho chúng tôi “ .” Nhân viên Proactive Nhân viên Proactive Nhân viên Proactive Bây giờ chúng tôi có thể kiểm tra cách điều khiển của chúng tôi hoạt động bằng cách gửi một thông điệp xác thực URL từ một máy chủ, mô phỏng hành vi của Slack. Tạo DTO cho Slack Event Messages Bây giờ, hãy tạo một DTO để xử lý và xác nhận các thông điệp mà Slack sẽ gửi cho chúng tôi khi sự kiện xảy ra.Không giống như yêu cầu xác nhận URL đơn giản, tải trọng hiệu quả sự kiện chứa nhiều dữ liệu hơn, vì vậy chúng tôi sẽ tạo ra một số DTO để xác nhận hiệu quả hơn và mô-đun hơn. Cơ cấu yêu cầu sự kiện điển hình Một yêu cầu sự kiện sẽ chứa các trường token, team_id, api_app_id, và quan trọng nhất, một đối tượng sự kiện. bên trong đối tượng sự kiện, bạn sẽ tìm thấy thông tin về loại sự kiện (thông điệp, app_mention, v.v.), văn bản tin nhắn, dữ liệu người dùng và thông tin kênh. { "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": [ ... ] } Tạo DTOs cho Event Handling Chúng tôi sẽ tạo một hệ thống phân cấp các đối tượng DTO để tách xác nhận cấu trúc yêu cầu tổng thể khỏi các đặc điểm của sự kiện. (Đóng gói DTO cho toàn bộ yêu cầu) DTO này sẽ chứa các trường chung cho tất cả các sự kiện. 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 cho đối tượng sự kiện) DTO này sẽ chứa dữ liệu cụ thể cho chính sự kiện. 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 cho việc thu thập giấy phép) DTO này sẽ chứa dữ liệu cụ thể cho việc thu thập giấy phép. 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; } } Chúng tôi sử dụng ba DTO để tách xác nhận. xác nhận cấu trúc tổng thể của yêu cầu, trong khi xác nhận nội dung của đối tượng sự kiện được niêm phong và Xác nhận giấy phép thu thập. SlackEvent SlackEventData SlackEventAuthorization Nếu trong tương lai chúng tôi muốn xử lý một loại sự kiện khác (ví dụ, app_mention hoặc reaction_added), chúng tôi chỉ đơn giản là tạo một DTO mới cho loại sự kiện đó và sử dụng nó để xác nhận. Với những DTO này, bộ điều khiển của chúng tôi sẽ có thể nhận và xác nhận tin nhắn đáng tin cậy từ Slack, đó là một bước quan trọng trong việc xây dựng hệ thống của chúng tôi. “ .” Nhân viên Proactive Nhân viên Proactive Nhân viên Proactive Tạo một Custom Denormalizer Trong cấu hình mặc định của nó, Symfony Serializer không thể tự động deserialize phức tạp, niêm phong đối tượng như Để bản đồ chính xác phạm vi các đối tượng ủy quyền từ tải trọng sử dụng Slack vào DTO của chúng tôi, chúng tôi cần một denormalizer tùy chỉnh. SlackEventAuthorization Một denormalizer là một thành phần chuyển đổi dữ liệu có cấu trúc (như một mảng hoặc một đối tượng JSON) thành một đối tượng PHP. serializer mặc định có thể xử lý các thuộc tính đơn giản, nhưng nó không biết làm thế nào để xử lý các cấu trúc phức tạp như một loạt các DTO tùy chỉnh được niêm phong trong một DTO khác. 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]; } } Cập nhật bộ điều khiển cho nhiều loại sự kiện Bây giờ chúng tôi đã sẵn sàng để sửa đổi bộ điều khiển webhook của chúng tôi để xử lý hai loại sự kiện: url_verification và thông báo sự kiện. chúng tôi sẽ cập nhật bộ điều khiển để sử dụng một câu lệnh chuyển đổi để định tuyến các yêu cầu dựa trên trường loại trong tải trọng sử dụng, làm cho điểm cuối duy nhất của chúng tôi linh hoạt và mạnh mẽ. Bộ điều khiển được cập nhật sẽ kiểm tra loại tải trọng JSON đến.Nếu đó là một yêu cầu url_verification, nó sẽ thực hiện xác nhận chúng tôi đã thiết lập.Nếu đó là một sự kiện_callback, nó sẽ bắt đầu quá trình xử lý sự kiện Slack thực tế. 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); } } Tận dụng thừa kế cho một dòng công việc thống nhất Chúng tôi đã tạo ra một Những người thừa kế từ Đây là một quyết định thiết kế quan trọng cho phép chúng tôi gửi tin nhắn Slack đến bus tin nhắn của chúng tôi để xử lý không đồng bộ tiêu chuẩn của chúng tôi. Sử dụng dòng công việc hiện có. SlackMessage Thông điệp Người đại diện Thông điệp Thông điệp Người đại diện Người đại diện Bằng cách mở rộng , lớp SlackMessage tự động tuân thủ cùng hợp đồng tin nhắn được yêu cầu bởi bus tin nhắn của chúng tôi và Điều này có nghĩa là chúng tôi không cần phải xây dựng một đường ống xử lý mới, riêng biệt cho Slack. Thay vào đó, chúng tôi có thể chỉ đơn giản chuyển một trường hợp của SlackMessage đến bus, và hệ thống sẽ xử lý nó giống như một email thông thường. Thông điệp Người đại diện Thông điệp Người đại diện Bây giờ mã của chúng tôi đã hoàn tất, chúng tôi đã sẵn sàng để triển khai và chạy ứng dụng của chúng tôi. hệ thống, chúng tôi sẽ sử dụng một cách tiếp cận containerized với , đơn giản hóa quá trình quản lý cả ứng dụng Symfony và các phụ thuộc của nó, chẳng hạn như cơ sở dữ liệu hoặc nhà môi giới tin nhắn. Proactive Agent Docker thành phần Nhân viên Proactive Docker thành phần Kết luận Các lớp chứa dữ liệu cụ thể cho Slack nhưng thừa hưởng các thuộc tính cốt lõi cần thiết cho đại lý của chúng tôi, chẳng hạn như nội dung tin nhắn. SlackMessage Bây giờ chúng ta có thể gửi một đối tượng SlackMessage đến Symfony Message Bus trên một phương tiện vận chuyển không đồng bộ tiêu chuẩn. Đại lý AI, đã được cấu hình để tiêu thụ tin nhắn từ bus và quá trình đối tượng, có thể xử lý liền mạch các đối tượng SlackMessage mà không có bất kỳ thay đổi nào đối với logic cốt lõi của nó. Sau đó có thể sử dụng nội dung của thông điệp để thực hiện các nhiệm vụ của nó, chẳng hạn như tóm tắt hoặc tạo câu trả lời. Thông điệp đại lý Thông điệp đại lý Cách tiếp cận này rất hiệu quả vì nó tránh sự trùng lặp mã và giữ cho kiến trúc hệ thống của chúng tôi sạch sẽ và có thể mở rộng. Có thể dễ dàng tích hợp các kênh truyền thông mới, đảm bảo tất cả các tin nhắn - từ email hoặc Slack - được xử lý thông qua một dòng công việc thông minh duy nhất. Nhân viên Proactive Nhân viên Proactive Trong các bài viết tiếp theo của chúng tôi, chúng tôi sẽ khám phá cách đơn giản hóa mã của chúng tôi bằng cách sử dụng Công cụ mạnh mẽ này cung cấp một mức độ trừu tượng cao hơn để xử lý các yêu cầu webhook, loại bỏ sự cần thiết cho một số bộ điều khiển thủ công và logic xác thực mà chúng tôi đã xây dựng cho đến nay. symfony/webhook Sau đó, chúng tôi sẽ đi sâu vào việc tạo ra một dòng công việc riêng biệt, dành riêng để tạo ra các câu trả lời tự động cho các tin nhắn Slack. Điều này sẽ liên quan: Dựa trên kiến trúc hiện tại của chúng tôi, chúng tôi sẽ thiết kế một hệ thống có thể xác định các thông điệp đòi hỏi phản hồi. Advanced Message Processing: Chúng tôi sẽ chỉ ra cách sử dụng một Tạo ra những câu trả lời thông minh, hiểu bối cảnh. Integrating an LLM: Mô hình ngôn ngữ lớn Mô hình ngôn ngữ lớn Cuối cùng, chúng tôi sẽ sử dụng một máy khách Slack API để gửi phản hồi được tạo lại cho người dùng, đóng vòng lặp truyền thông và hoàn thành ** của chúng tôi. * Hệ thống Sending a Reply: Nhân viên Proactive Nhân viên Proactive Hãy yên tâm khi chúng tôi tiếp tục xây dựng nền tảng truyền thông thời gian thực mạnh mẽ này.