Cómo usar Slack Incoming y Outgoing Webhooks para agentes de IA en tiempo real

Ahora nuestro es y listo para la implementación, ampliemos sus capacidades mediante la integración de una nueva fuente de entrada. Slack es una excelente opción para esto. Aplicación Contenedores Aplicación Contenedores Slack para comunicaciones en tiempo real Imaginemos un escenario en el que queremos recibir notificaciones en tiempo real de nuevos mensajes en canales específicos de Slack. (LLMs) para generar resúmenes o respuestas.Esta nueva funcionalidad funcionará en conjunto con nuestra que continúa en las cajas de correos. Modelos de idiomas grandes El agente Modelos de idiomas grandes El agente Esta integración será una piedra angular de nuestro sistema de agentes proactivos.Al monitorear simultáneamente Slack y correo electrónico, nuestra aplicación se convierte en un hub centralizado para las comunicaciones, asegurando que ningún mensaje se pierda y que cada consulta se trate de forma rápida.Este enfoque de doble fuente demuestra el poder y la flexibilidad de un sistema bien diseñado, combinando plataformas de comunicación tradicionales y modernas para una solución integral. Para recibir notificaciones sobre nuevos mensajes de Slack, podemos usar Un Webhook es un llamado HTTP definido por el usuario que es desencadenado por un evento en un sistema de origen.Cuando ocurre el evento, el sistema de origen hace una solicitud HTTP/HTTPS a la URL configurada en el . Webhooks Webhook Cómo funciona Slack Webhooks En el contexto de Slack, se configura un Webhook de salida para un canal o espacio de trabajo específico.Cuando se publica un mensaje o se logra un evento que cumpla ciertos criterios (por ejemplo, una palabra clave específica, patrón), Slack envía una solicitud HTTP POST a una URL designada. , que luego procesa los datos entrantes. Aplicación Aplicación Este método es muy eficaz porque es En lugar de que nuestra aplicación encuentre constantemente Slack para nuevos mensajes (que es intensivo en recursos e ineficiente), Slack "empujará" proactivamente la información a nosotros tan pronto como ocurra un evento. Eventos guiados Eventos guiados ¿Por qué elegir Webhooks? Obtenga mensajes como ocurren, permitiendo la acción inmediata. Real-time updates: Nuestra aplicación no necesita realizar encuestas en Slack, ahorrando llamadas de API y recursos de servidor. Reduced resource usage: Los Webhooks son una forma estándar y sencilla de conectar diferentes servicios. Simple integration: Este proceso es fundamental para la construcción de una que responde de inmediato a las nuevas comunicaciones, ya sean originarias de Slack u otras fuentes como el correo electrónico. Proactive Agent Webhooks entrantes y salientes Sí, Slack tiene webhooks entrantes y salientes. Estos son dos mecanismos distintos que sirven a diferentes fines en un flujo de trabajo de comunicación. Envíos Webhooks Qué son: Este es el tipo más común de webhook en Slack. Permiten a las aplicaciones externas enviar (push) mensajes en un canal Slack. Su aplicación hace una solicitud HTTP POST a esta URL, enviando una carga útil JSON con el texto del mensaje y la formatación. Webhooks de entrada utilizados para notificaciones, alertas y mensajes automatizados. por ejemplo, para enviar notificaciones sobre nuevos compromisos de GitHub, estados de implementación o mensajes de nuestro sitio web. Volver a Slack. Proactive El agente El agente El agente Siguiente Webhooks Este es un mecanismo legado que permite a Slack enviar (push) datos a una aplicación externa cuando un evento específico ocurre en un canal. Configure un webhook de salida especificando la URL de su aplicación y desencadenando palabras o eventos.Cuando un usuario en un canal de Slack publica un mensaje que contiene una de estas palabras, Slack hace una solicitud HTTP POST a la URL de su aplicación. Webhooks usados para crear y automatizaciones que reaccionan a comandos o palabras clave específicas. Los bots interactivos Los bots interactivos En nuestro escenario, configuramos un webhook de salida con un desencadenante como resumen para que nuestro agente pueda recibir y procesar el mensaje para generar un resumen. Diferencias clave Los Webhooks de entrada se utilizan para enviar mensajes a Slack (de una fuente externa). Los Webhooks de salida se utilizan para recibir mensajes de Slack (a una fuente externa), pero solo basándose en un desencadenante específico. En el contexto de nuestro artículo sobre el , usamos un webhook de salida para recibir mensajes de Slack para procesamiento y un webhook de entrada para enviar respuestas de vuelta a Slack. “Proactive Agent” Guía paso a paso para crear una aplicación Slack Para permitir que Slack nos envíe eventos de webhook, primero debemos crear una aplicación en el portal de desarrolladores e instalarla en el espacio de trabajo de Slack o en un canal específico desde el que queremos recibir notificaciones. Acceso al sitio web de la API de Slack: Navegación a . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps Haga clic en “Crear una App” y elija construirla “Desde cero”.Dale a su aplicación un nombre descriptivo y seleccione el espacio de trabajo Slack donde lo va a desarrollar y probar. Activar suscripciones de eventos: En la configuración de su aplicación, vaya a la sección “Subscripciones de eventos” y active “Activar eventos”. Proporcionar una URL de solicitud: debe proporcionar una URL accesible al público para su aplicación. Este es el punto final donde Slack enviará cargas de pago de eventos. Slack realizará una verificación de verificación de URL una vez, donde su aplicación debe responder con el valor de desafío de la solicitud de Slack. Crearemos este punto final en nuestra aplicación Symfony. Suscríbete a eventos de bot: Desplácese hacia abajo hasta la sección "Subscribe to bot events".Haga clic en "Add Bot User Event" y seleccione el evento message.channels. Esto le dice a Slack que envíe una carga útil a su aplicación para cada mensaje publicado en un canal público. Objetivos de solicitud: Para recibir estos eventos, tu bot necesitará los permisos adecuados. En la sección “OAuth & Permissions”, agrega el alcance canals:history a tu token de bot. Esto otorga a tu app la capacidad de ver mensajes en canales públicos. Reinstalar su aplicación: Después de agregar nuevos ámbitos, debe reinstalar su aplicación en el espacio de trabajo para que los cambios se produzcan. Siguiendo estos pasos, nuestro recibirá una carga útil completa de JSON para cada nuevo mensaje en los canales suscritos, proporcionando más contexto y flexibilidad que el método legado de palabras activadoras. . proactive agent Aplicaciones impulsadas por AI Aplicaciones impulsadas por AI Aplicaciones impulsadas por AI Validación de Webhook Es hora de crear un punto final para manejar la respuesta a nuestra solicitud de validación de puntos finales.Tenemos dos opciones para trabajar con webhooks en el lado de Symfony: podemos manejarlo en el nivel del controlador o usar el componente. En este artículo, nos centraremos en trabajar en el nivel del controlador. En un futuro post, te mostraré cómo hacer esto utilizando el . symfony/webhook Symfony Webhook Component Cuando configure su URL de punto final en suscripciones de eventos de Slack, Slack envía una solicitud de verificación inicial para confirmar que la URL es válida y pertenece a su aplicación. Nuestro punto final debe responder con el valor de desafío exacto del cuerpo de la solicitud. challenge Para gestionar correctamente la solicitud de webhook, no solo tenemos que recibir la carga útil, sino también validar su corrección. (DTOs) e instalar dos componentes clave de Symfony: y . Objetos de transferencia de datos symfony/validator symfony/serializer-pack Objetos de transferencia de datos Objetos de transferencia de datos Por qué estos componentes son esenciales Este componente proporciona un marco robusto para la validación de datos contra un conjunto de reglas. En lugar de escribir manualmente declaraciones if-else para comprobar cada campo, podemos definir restricciones de validación (por ejemplo, NoBlank, Tipo, Longitud) directamente en nuestras propiedades DTO. Esto hace que nuestro código sea más limpio, más legible y menos propenso a errores. symfony/validator: Este paquete de componentes proporciona todo lo que necesitamos para serializar (convertir objetos en matrizes/JSON) y deserializar (convertir JSON/arrays en objetos) los datos. Utilizaremos el deserializador para convertir automáticamente la carga útil de JSON entrante de Slack en un objeto DTO validado. Este proceso automatiza la tarea aburrida de mapear campos de datos, asegurando que la estructura de carga útil coincida con nuestras expectativas. symfony/serializer-pack: Y ahora estamos listos para usar las colecciones más avanzadas que Doctrine ofrece. componente todavía; en lugar de eso, solo instalaremos el paquete para trabajar con . Doctrine collections Mientras que los arreglos de PHP son versátiles, carecen de algunas características avanzadas como la tipografía, la immutabilidad y los métodos especializados para filtrar o mapear. proporcionar un envoltorio potente y orientado a objetos alrededor de las matrizes, dándonos una forma más robusta y predecible de gestionar los datos. sistema, donde trataremos con listas de mensajes, usuarios u otras cargas de datos. Doctrine Collections Proactive Agent Estos cambios pequeños pero impactantes mejorarán significativamente la forma en que gestionamos los datos dentro del , haciendo que la lógica de nuestro agente sea más robusta y más fácil de mantener. Nuestra aplicación Nuestra aplicación Para instalar los componentes necesarios, simplemente ejecute el siguiente comando en su terminal: composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack El flujo de trabajo para validar una carga de pago de Webhook Recibir la solicitud: Nuestro controlador de Symfony recibe la solicitud HTTP POST de Slack. Deserialize a DTO: Utilizamos el serializador para transformar la carga útil de JSON en nuestro objeto DTO predefinido. Validar el DTO: El componente validador comprueba las propiedades del DTO contra las restricciones definidas. Gestionar errores: Si la validación falla, devolveremos una respuesta de error (por ejemplo, una solicitud 400 Bad) a Slack. Datos válidos de procesamiento: Si la validación es exitosa, nuestra aplicación puede proceder de forma segura al procesamiento de los datos de webhook, sabiendo que están en el formato correcto. Este enfoque estructurado garantiza que nuestra aplicación sea resiliente y solo procesa datos que se ajusten a nuestro formato esperado, lo que es un paso crítico en la construcción de un sistema confiable y seguro. Gestionar varias cargas de pago dentro de un único controlador También debemos tener en cuenta que nuestro controlador y una única ruta deben manejar correctamente , desde la validación de URL hasta las cargas de pago de eventos de trabajo a las que hemos suscrito. different types of payloads Este es un requisito clave para un punto final de webhook robusto. Una única ruta debe ser lo suficientemente inteligente como para diferenciar entre una solicitud de verificación de URL una vez y una notificación de evento en vivo. Nuestro controlador debe poder procesar cada tipo de solicitud en consecuencia. Como se discutió anteriormente, la carga útil de verificación de URL inicial de Slack contiene un Todas las cargas de pago de eventos posteriores contienen una clave de evento que contiene los datos de mensajes reales.Nuestro controlador debe verificar la presencia de estas claves para determinar la naturaleza de la solicitud. challenge Solicitud de validación de URL Slack Bueno, vamos a crear un DTO para validar la solicitud de verificación de URL de Slack. Primero, aquí está lo que parece una carga útil típica de la solicitud de validación de URL de Slack. Cuando activas las suscripciones de eventos, Slack envía una solicitud de POST a tu punto final con una carga útil de JSON que contiene tres campos clave: token, desafío y tipo. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } Un token único para su aplicación. Puede usar esto para verificar que la solicitud es de su aplicación. token: Debe devolver esta cadena exacta en su respuesta JSON para demostrar que posee la URL. challenge: Para la validación, esto siempre será url_verification. type: Creación del DTO Ahora, crearemos un DTO que refleje esta estructura e incluya restricciones de validación utilizando el componente validador 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 la validación: Asegura que los campos token, desafío y tipo estén presentes en la solicitud. Assert\NotBlank: Confirma que el valor de cada campo es una cadena, evitando tipos de datos inesperados. Assert\Type(“string”): Especificamente valida que el campo tipo coincide con la cadena requerida, por lo que sabemos que estamos tratando una solicitud de verificación de URL y no otro tipo de evento. Assert\EqualTo(“url_verification”): Al usar este DTO, podemos deserializar la carga útil de JSON entrante y validar automáticamente su estructura con un código mínimo en nuestro controlador. Creación de un controlador para la validación de Slack Webhook perfecto, vamos a crear un controlador que utilice un DTO para validar la solicitud de Slack. Este controlador comprobará si la solicitud de entrada es una solicitud de verificación de URL y la manejará correctamente devolviendo el código de desafío. SlackUrlValidationRequest Vamos a inyectar el para deserializar la carga útil de JSON en nuestro DTO y el Este enfoque hace que el código sea limpio, fiable y conforme a los 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 ahora maneja de forma confiable y segura las solicitudes de verificación, que es la base para nuestra “ .” Agente Proactivo Agente Proactivo Agente Proactivo Ahora podemos probar cómo funciona nuestro controlador enviando un mensaje de validación de URL desde un servidor, simulando el comportamiento de Slack. Crear un DTO para mensajes de eventos Slack Ahora, creemos un DTO para procesar y validar los mensajes que Slack nos enviará cuando ocurran los eventos.A diferencia de la simple solicitud de validación de URL, la carga útil del evento contiene mucho más datos, por lo que crearemos varios DTO para una validación más efectiva y modular. Estructura típica de solicitud de evento Una solicitud de evento contendrá los campos token, team_id, api_app_id y, lo más importante, un objeto de evento.Dentro del objeto de evento, encontrará información sobre el tipo de evento (mensaje, app_mention, etc.), el texto del mensaje, los datos del usuario y la información del canal. { "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 el manejo de eventos Crearemos una jerarquía de objetos DTO para separar la validación de la estructura general de la solicitud de las especificidades del evento mismo. (El engranaje DTO para toda la solicitud) Este DTO contendrá los campos generales para todos los 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; } } (El DTO para el objeto del evento) Este DTO contendrá los datos específicos del evento mismo. 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 para la recogida de autorizaciones) Este DTO contendrá los datos específicos para la recopilación de autorizaciones. 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 la validación. validar la estructura general de la solicitud, mientras que Valida el contenido del objeto de evento niñado y Validación de la autorización de recogida. SlackEvent SlackEventData SlackEventAuthorization Si en el futuro queremos manejar otro tipo de evento (por ejemplo, app_mention o reaction_added), simplemente creamos un nuevo DTO para ese tipo de evento y lo usamos para la validación. Con estos DTOs, nuestro controlador será capaz de recibir y validar de forma confiable los mensajes de Slack, que es un paso crítico en la construcción de nuestra red. “ .” Agente Proactivo Agente Proactivo Agente Proactivo Creación de un Custom Denormalizer En su configuración predeterminada, el Symfony Serializer no puede deserializar automáticamente objetos complejos, Para mapear correctamente el conjunto de objetos de autorización de la carga útil de Slack en nuestro DTO, necesitamos un desnormalizador personalizado. SlackEventAuthorization Un denormalizador es un componente que convierte datos estructurados (como un array o un objeto JSON) en un objeto PHP. El serializador predeterminado puede manejar propiedades simples, pero no sabe cómo manejar estructuras complejas como un conjunto de DTOs personalizados anclados dentro de otro DTO. Al crear un denormalizador personalizado, le decimos explícitamente al serializador cómo mapear los datos entrantes a nuestro objeto 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 Ahora estamos listos para modificar nuestro controlador webhook para manejar dos tipos de eventos: url_verification y notificaciones de eventos. Actualizaremos el controlador para usar una declaración de interruptor para orientar las solicitudes en función del campo de tipo en la carga útil, haciendo que nuestro punto final único sea flexible y robusto. El controlador actualizado comprobará el tipo de carga útil de JSON entrante. Si se trata de una solicitud de verificación url_verification, realizará la validación que ya hemos configurado. Si se trata de un evento_callback, comenzará el proceso de manipulación del evento Slack real. 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); } } Aprovechando la herencia para un flujo de trabajo unificado Hemos creado una nueva Los que heredan de Esta es una decisión de diseño significativa que nos permite enviar mensajes Slack a nuestro bus de mensajes para el procesamiento asíncrono estándar por nuestro Utilización del flujo de trabajo existente. SlackMessage Mensaje El agente Mensaje Mensaje El agente El agente Por extensión , la clase SlackMessage se ajusta automáticamente al mismo contrato de mensajes requerido por nuestro bus de mensajes y Esto significa que no necesitamos construir una nueva tubería de procesamiento separada para Slack. En su lugar, podemos simplemente pasar una instancia de SlackMessage al bus, y el sistema la manejará como un correo electrónico normal. Mensaje El agente Mensaje El agente Ahora que nuestro código está completo, estamos listos para desplegar y ejecutar nuestra aplicación. en el sistema, utilizaremos un enfoque containerizado con , que simplifica el proceso de gestión tanto de nuestra aplicación Symfony como de sus dependencias, como una base de datos o un corredor de mensajes. Agente Proactivo Docker Compose Agente Proactivo Docker Composición Conclusión El La clase contiene datos específicos de Slack, pero hereda las propiedades básicas necesarias para nuestro agente, como el contenido de los mensajes. SlackMessage Ahora podemos enviar un objeto de SlackMessage al Bus de mensajes de Symfony en un transporte asínctico estándar. El agente de IA, que ya está configurado para consumir mensajes del bus y el proceso objetos, puede manejar sin problemas los objetos de SlackMessage sin ningún cambio en su lógica Puede utilizar el contenido del mensaje para realizar sus tareas, como resumir o generar una respuesta. Mensaje agent Mensaje Agente Este enfoque es altamente eficiente porque evita la duplicación de código y mantiene limpia y escalable la arquitectura de nuestro sistema. Puede integrar fácilmente nuevos canales de comunicación, asegurando que todos los mensajes, ya sean de correo electrónico o Slack, se procesen a través de un único flujo de trabajo inteligente. Agente Proactivo Agente Proactivo En nuestros próximos artículos, exploraremos cómo simplificar nuestro código utilizando el Esta poderosa herramienta proporciona una abstracción de nivel superior para el manejo de solicitudes de webhook, eliminando la necesidad de algunos de los controladores manuales y la lógica de validación que hemos construido hasta ahora. symfony/webhook Luego nos sumergeremos en la creación de un flujo de trabajo separado y dedicado para generar respuestas automáticas a los mensajes de Slack. Esto implicará: Sobre la base de nuestra arquitectura existente, diseñaremos un sistema que pueda identificar los mensajes que requieren una respuesta. Advanced Message Processing: Mostraremos cómo utilizar un formular respuestas inteligentes y contextuales. Integrating an LLM: Modelo de Lenguaje Gran Modelo de Lenguaje Gran Finalmente, usaremos un cliente de API Slack para enviar la respuesta generada de vuelta al usuario, cerrando el ciclo de comunicación y completando nuestro ** • El sistema. Sending a Reply: Agente Proactivo Agente Proactivo Manténgase atento mientras continuamos construyendo esta poderosa plataforma de comunicación en tiempo real.