Como usar Slack Incoming e Outgoing Webhooks para axentes de IA en tempo real

Agora a nosa é e listo para a implantación, ampliemos as súas capacidades mediante a integración dunha nova fonte de entrada. Aplicacións Contenedores Aplicacións Contenedores Integración de Slack para comunicacións en tempo real Imaxina un escenario no que queremos recibir notificacións en tempo real de novas mensaxes en canais específicos de Slack. (LLMs) para xerar resumos ou propostas de respostas.Esta nova funcionalidade funcionará en conxunto coa nosa O que segue a ser unha caixa de correos. Grandes modelos de linguaxe O axente Grandes modelos de linguaxe O axente Esta integración será unha pedra angular do noso sistema de axente proactivo. Ao monitorear simultaneamente Slack e correo electrónico, a nosa aplicación convértese nun centro centralizado para as comunicacións, garantindo que non se perda ningunha mensaxe e que cada consulta se xestione axiña. Para recibir notificacións sobre novas mensaxes de Slack, podemos usar o Un Webhook é unha chamada HTTP definida polo usuario que é desencadeada por un evento nun sistema fonte. Cando o evento ocorre, o sistema fonte fai unha solicitude HTTP/HTTPS á URL configurada no sistema fonte. . Webhooks Webhook Como funciona Slack Webhooks No contexto de Slack, configúrase un Webhook de saída para un canle ou espazo de traballo específico. Cando se publica unha mensaxe ou se logra un evento que cumpre certos criterios (por exemplo, unha palabra clave específica, un patrón), Slack envía unha solicitude HTTP POST a unha URL designada. , que entón procesa os datos entrantes. Aplicacións Aplicacións Este método é moi eficaz porque En lugar de que a nosa aplicación constantemente sondee Slack para novas mensaxes (que é intensiva en recursos e ineficiente), Slack "empurre" proactivamente a información para nós tan pronto como ocorre un evento. Eventos dirixidos Eventos dirixidos Por que elixir Webhooks? Obteña mensaxes como ocorren, permitindo unha acción inmediata. Real-time updates: A nosa aplicación non necesita facer enquisas en Slack, aforrando chamadas de API e recursos de servidor. Reduced resource usage: Webhooks son unha forma estándar e sinxela de conectar diferentes servizos. Simple integration: Este proceso é fundamental para a construción dunha que responde inmediatamente a novas comunicacións, xa sexan procedentes de Slack ou doutras fontes como o correo electrónico. Proactive Agent Webhooks entrantes e saíntes Si, Slack ten tanto webhooks de entrada como de saída. Estes son dous mecanismos distintos que serven a diferentes fins nun fluxo de traballo de comunicación. Envío de Webhooks O que son: Este é o tipo máis común de webhook en Slack. Permiten que aplicacións externas envíen (push) mensaxes a un canal Slack. A súa aplicación fai unha solicitude HTTP POST a esta URL, enviando unha carga útil de JSON co texto da mensaxe e formatación. Webhooks de entrada usados para notificacións, alertas e mensaxes automatizadas. por exemplo, para enviar notificacións sobre novos compromisos de GitHub, estados de implementación ou mensaxes da nosa Volver a Slack. Proactive O axente O axente O axente Páxinas Webhooks Este é un mecanismo herdado que permite a Slack enviar (push) datos a unha aplicación externa cando un evento específico ocorre nunha canle. Configure unha webhook saínte especificando a URL da súa aplicación e desencadeando palabras ou eventos.Cando un usuario nunha canle de Slack publica unha mensaxe que contén unha destas palabras, Slack realiza unha solicitude HTTP POST á URL da súa aplicación. Outgoing Webhooks usados para crear e automatizacións que reaccionan a comandos ou palabras clave específicas. Bots interactivos Bots interactivos No noso escenario, configuramos un webhook de saída cun desencadeador como resumo para que o noso axente poida recibir e procesar a mensaxe para xerar un resumo. Diferenzas clave Os Webhooks de entrada utilízanse para enviar mensaxes a Slack (a partir dunha fonte externa). Outgoing Webhooks utilízanse para recibir mensaxes de Slack (a unha fonte externa), pero só en base a un desencadeador específico. No noso artigo sobre o , usamos un webhook de saída para recibir mensaxes de Slack para procesamento e un webhook de entrada para enviar respostas de volta a Slack. “Proactive Agent” Guía paso a paso para crear unha aplicación Slack Para permitir que Slack nos envíe eventos de webhook, primeiro debemos crear unha aplicación no portal do desenvolvedor e instalala no espazo de traballo de Slack ou nunha canle específica desde a que queremos recibir notificacións. Acceso ao sitio web da API de Slack: Navegación a . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps Fai clic en "Crear unha aplicación" e elixe construíla "Desde cero".Dá un nome descriptivo á súa aplicación e selecciona o espazo de traballo Slack onde o vai desenvolver e probar. Activar as subscricións de eventos: Nas configuracións da aplicación, navega pola sección “Subscricións de eventos” e activa “Activar eventos”. Proporcionar unha URL de solicitude: Debe proporcionar unha URL accesible ao público para a súa aplicación. Este é o punto final onde Slack enviará cargas de rendemento de eventos. Slack realizará unha verificación de verificación de URL unha vez, onde a súa aplicación debe responder co valor de desafío da solicitude de Slack. Crearemos este punto final na nosa aplicación Symfony. Subscribe to Bot Events: Desprácese ata a sección "Subscribe to bot events".Clique en "Add Bot User Event" e seleccione o evento message.channels. Isto di a Slack para enviar a súa aplicación unha carga útil para cada mensaxe publicada nunha canle pública. Obxectivos de solicitude: Para recibir estes eventos, o bot necesitará os permisos axeitados. Na sección "OAuth & Permissions" engade o alcance de canles:history ao token do bot. Isto outorga á súa aplicación a capacidade de ver mensaxes en canles públicas. Reinstalar a túa aplicación: Despois de engadir novos ámbitos, tes que reinstalar a túa aplicación no espazo de traballo para que os cambios entren en vigor. Seguindo estes pasos, a nosa recibirá unha carga de traballo completa de JSON para cada nova mensaxe nos canles subscritos, proporcionando máis contexto e flexibilidade que o método de palabras orixinais. . proactive agent Aplicacións AI-powered Aplicacións AI-powered Aplicacións AI-powered Validación Webhook É hora de crear un punto final para xestionar a resposta á nosa solicitude de validación de puntos finais.Temos dúas opcións para traballar con webhooks no lado de Symfony: podemos xestionalo a nivel de controlador ou usar o Neste artigo, imos centrarnos en traballar no nivel do controlador. nun futuro post, vou amosar-lle como facer isto usando o . symfony/webhook Symfony Webhook Component Cando configure a URL do seu punto final en Slack's Event Subscriptions, Slack envía unha solicitude de verificación inicial para confirmar que a URL é válida e pertence á súa aplicación. O noso punto final debe responder co valor de desafío exacto do corpo de solicitude. challenge Para xestionar correctamente a solicitude de webhook, non só temos que recibir a carga útil, senón tamén validar a súa corrección. (DTOs) e instalar dous compoñentes clave de Symfony: e . Transferencia de datos obxectos symfony/validator symfony/serializer-pack Transferencia de datos obxectos Transferencia de datos obxectos Por que son importantes estes compoñentes Este compoñente proporciona un marco robusto para validar os datos contra un conxunto de regras. En lugar de escribir as declaracións if-else manualmente para comprobar cada campo, podemos definir as restricións de validación (por exemplo, NotBlank, Type, Length) directamente nas nosas propiedades DTO. Isto fai que o noso código sexa máis limpo, máis lexible e menos propenso a erros. symfony/validator: Este paquete de compoñentes proporciona todo o que necesitamos para serializar (converter obxectos en matrizes/JSON) e deserializar (converter JSON/arrays en obxectos) os datos. usaremos o deserializador para converter automaticamente a carga útil de JSON de Slack a un obxecto DTO validado. Este proceso automatiza a tediosa tarefa de mapear campos de datos, asegurando que a estrutura de carga útil coincida coas nosas expectativas. symfony/serializer-pack: E agora estamos listos para usar as coleccións máis avanzadas que Doctrine ofrece. compoñente aínda; en vez diso, instalaremos só o paquete para traballar con . Doctrine collections Mentres que os arreglos de PHP son versátiles, carecen dalgunhas características avanzadas como tipoloxía, inmutabilidade e métodos especializados para filtrar ou mapear. proporcionar un poderoso envoltorio orientado a obxectos ao redor de arreglos, dándonos unha forma máis robusta e previsible de xestionar os datos. sistema, onde trataremos de listas de mensaxes, usuarios ou outras cargas de datos. Doctrine Collections Proactive Agent Estes pequenos cambios, pero impactantes, mellorarán significativamente a forma en que xestionamos os datos dentro , facendo a lóxica do noso axente máis robusta e máis fácil de manter. A nosa aplicación A nosa aplicación Para instalar os compoñentes necesarios, simplemente execute o seguinte comando no seu terminal: composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack O fluxo de traballo para validar unha carga de traballo de Webhook Recibir a solicitude: O noso controlador Symfony recibe a solicitude HTTP POST de Slack. Deserialize a DTO: Usamos o serializador para transformar a carga útil de JSON no noso obxecto DTO predefinido. Validar o DTO: O compoñente validador comproba as propiedades do DTO contra as restricións definidas. Xestionar erros: Se a validación falla, devolveremos unha resposta de erro (por exemplo, unha 400 Bad Request) a Slack. Datos válidos de procesamento: Se a validación é exitosa, a nosa aplicación pode proceder con seguridade ao procesamento dos datos do webhook, sabendo que está no formato correcto. Este enfoque estruturado asegura que a nosa aplicación é resiliente e só procesa datos que se axusten ao noso formato esperado, o que é un paso crítico na construción dun sistema fiable e seguro. Xestionar varias cargas de pagamento dentro dun único controlador Tamén debemos considerar que o noso controlador e unha única ruta deben manexar correctamente , desde a validación de URL ata as cargas de traballo de eventos que subscribimos. different types of payloads Este é un requisito clave para un punto final de webhook robusto.Unha única ruta debe ser suficientemente intelixente como para diferenciar entre unha solicitude de verificación de URL única e unha notificación de evento en directo.O noso controlador debe poder procesar cada tipo de solicitude de acordo. Como se discutiu anteriormente, a carga de traballo inicial de verificación de URL de Slack contén un Todas as cargas de pagamento de eventos posteriores conteñen unha clave de evento que contén os datos da mensaxe real. O noso controlador debe comprobar a presenza destas claves para determinar a natureza da solicitude. challenge Solicitude típica de validación de URLs Slack Ok, imos crear un DTO para validar a solicitude de verificación de URL de Slack. Primeiro, aquí está o que parece unha carga útil típica de solicitude de validación de URL de Slack. Cando activas as subscricións de eventos, Slack envía unha solicitude POST ao teu punto final cunha carga útil de JSON que contén tres campos clave: token, reto e tipo. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } Un token único para a súa aplicación. Pode usar isto para verificar que a solicitude é da súa aplicación. token: Debe devolver esta cadea exacta na súa resposta JSON para probar que posúe a URL. challenge: Para a validación, este será sempre url_verification. type: Creación da DTO Agora, crearemos unha DTO que reflicta esta estrutura e inclúa restricións de validación usando o compoñente de validación de 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; } } Este DTO simplifica a validación: Asegura que os campos token, desafío e tipo estean presentes na solicitude. Assert\NotBlank: Confirme que o valor de cada campo é unha cadea, evitando tipos de datos inesperados. Assert\Type(“string”): Valida especificamente que o campo de tipo coincide coa cadea requirida, polo que sabemos que estamos a xestionar unha solicitude de verificación de URL e non outro tipo de evento. Assert\EqualTo(“url_verification”): Usando este DTO, podemos deserializar a carga útil de JSON de entrada e validar automaticamente a súa estrutura con código mínimo no noso controlador. Creación dun controlador para a validación de Slack Webhook perfecto, imos crear un controlador que utilice unha DTO para validar a solicitude de Slack. Este controlador comprobará se a solicitude de entrada é unha solicitude de verificación de URL e tratarao correctamente devolvendo o código de desafío. SlackUrlValidationRequest Imos inxectar o para deserializar a carga útil de JSON na nosa DTO e o Este enfoque fai que o código sexa limpo, fiable e conforme aos estándares de 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); } } Este controlador agora xestiona de forma fiable e segura as solicitudes de verificación, que é a base para a nosa “ .” Axente Proactivo Axente Proactivo Axente Proactivo Agora podemos probar como funciona o noso controlador enviando unha mensaxe de validación de URL desde un servidor, simulando o comportamento de Slack. Crear unha DTO para mensaxes de eventos Slack Agora, imos crear un DTO para procesar e validar as mensaxes que Slack nos enviará cando se produzan eventos. a diferenza da simple solicitude de validación de URL, a carga útil do evento contén moito máis datos, polo que crearemos varios DTO para unha validación máis efectiva e modular. Estrutura típica de solicitude de eventos Unha solicitude de evento contén os campos token, team_id, api_app_id e, o máis importante, un obxecto de evento. Dentro do obxecto de evento, atoparás información sobre o tipo de evento (mensaxe, app_mention, etc.), o texto da mensaxe, os datos do usuario e a información da canle. { "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": [ ... ] } Creación de DTOs para o manexo de eventos Crearemos unha xerarquía de obxectos DTO para separar a validación da estrutura global da solicitude das especificidades do propio evento. (O engrenaxe DTO para toda a solicitude) Este DTO conterá os campos xerais para todos os eventos. 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; } } (O DTO para o obxecto do evento) Este DTO conterá os datos específicos do propio evento. 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); } } (O DTO para a recollida de autorizacións) Este DTO conterá os datos específicos para a recollida de autorizacións. 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; } } Utilizamos tres DTOs para separar a validación. validar a estrutura global da solicitude, mentres Valida o contido do obxecto de evento e Validación da autorización de recollida. SlackEvent SlackEventData SlackEventAuthorization Se no futuro queremos manexar outro tipo de evento (por exemplo, app_mention ou reaction_added), simplemente creamos un novo DTO para ese tipo de evento e usámolo para a validación. Con estes DTOs, o noso controlador será capaz de recibir e validar mensaxes de forma fiable de Slack, o que é un paso crítico na construción da nosa empresa. “ .” Axente Proactivo Axente Proactivo Axente Proactivo Creación dun Custom Denormalizer Na súa configuración por defecto, o Symfony Serializer non pode deserializar automaticamente obxectos complexos e anexos como Para mapear correctamente a gama de obxectos de autorización da carga útil de Slack ao noso DTO, necesitamos un desnormalizador personalizado. SlackEventAuthorization Un denormalizador é un compoñente que converte datos estruturados (como un array ou un obxecto JSON) nun obxecto PHP. O serializador predeterminado pode manexar propiedades simples, pero non sabe como manexar estruturas complexas como unha matriz de DTOs personalizados anexados dentro doutro DTO. Ao crear un denormalizador personalizado, explicamos explicitamente ao serializador como mapear os datos entrantes ao noso obxecto específico. 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]; } } Controlador actualizado para varios tipos de eventos Agora estamos preparados para modificar o noso controlador webhook para manexar dous tipos de eventos: url_verification e notificacións de eventos. Actualizaremos o controlador para usar unha declaración de switch para dirixir as solicitudes baseadas no campo de tipo na carga útil, facendo que o noso único punto final sexa flexible e robusto. O controlador actualizado comprobará o tipo da carga útil de JSON de entrada. Se é unha solicitude de verificación url_verification, realizará a validación que xa configuramos. 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); } } Aproveitar a herdanza para un fluxo de traballo unificado Creamos unha nova Unha herdanza que herdamos Esta é unha importante decisión de deseño que nos permite enviar mensaxes Slack ao noso bus de mensaxes para o procesamento asíncrono estándar polo noso Utilización do fluxo de traballo existente. SlackMessage mensaxeiro O axente mensaxeiro mensaxeiro O axente O axente Por extensión , a clase SlackMessage cumpre automaticamente co mesmo contrato de mensaxes requirido polo noso bus de mensaxes e Isto significa que non necesitamos construír unha nova canle de procesamento separada para Slack. En lugar diso, podemos simplemente pasar unha instancia de SlackMessage ao bus, e o sistema tratarao como un correo electrónico regular. mensaxeiro O axente mensaxeiro O axente Agora que o noso código está completo, estamos listos para implantar e executar a nosa aplicación. sistema, imos usar un enfoque containerizado con , que simplifica o proceso de xestionar tanto a nosa aplicación Symfony como as súas dependencias, como unha base de datos ou un corretor de mensaxes. Axente Proactivo Docker compoñentes Axente Proactivo Docker compoñentes Conclusión A súa A clase contén datos específicos de Slack pero herda as propiedades fundamentais necesarias para o noso axente, como o contido da mensaxe. SlackMessage Agora podemos enviar un obxecto de SlackMessage ao Bus de mensaxes de Symfony nun transporte asínctico estándar. O axente de IA, que xa está configurado para consumir mensaxes do bus e do proceso Obxectos, pode manexar sen problemas obxectos de SlackMessage sen cambios na súa lóxica central. Pode usar o contido da mensaxe para realizar as súas tarefas, como resumir ou xerar unha resposta. mensaxeiro axente mensaxeiro axente Este enfoque é altamente eficiente porque evita a duplicación de código e mantén a arquitectura do noso sistema limpa e escalable. Pode integrar facilmente novos canles de comunicación, asegurando que todas as mensaxes, xa sexan de correo electrónico ou Slack, se procesen a través dun único fluxo de traballo intelixente. Axente Proactivo Axente Proactivo Nos nosos próximos artigos, exploraremos como simplificar o noso código usando o Esta poderosa ferramenta proporciona unha abstracción de nivel superior para o manexo de solicitudes de webhook, eliminando a necesidade de algúns dos controladores manuais e a lóxica de validación que construímos ata agora. symfony/webhook A continuación, imos mergullarnos na creación dun fluxo de traballo separado e dedicado para xerar respostas automáticas ás mensaxes de Slack. Isto implicará: Construíndo a nosa arquitectura existente, deseñaremos un sistema que poida identificar as mensaxes que requiren unha resposta. Advanced Message Processing: Imos amosar como usar unha formular respostas intelixentes e contextualmente conscientes. Integrating an LLM: Modelo de linguaxe grande Modelo de linguaxe grande Finalmente, usaremos un cliente Slack API para enviar a resposta xerada de volta ao usuario, pechando o ciclo de comunicación e completando a nosa ** • O sistema. Sending a Reply: Axente Proactivo Axente Proactivo Mantéñase atento mentres seguimos construíndo esta poderosa plataforma de comunicación en tempo real.