Cum să utilizați Slack Incoming și Outgoing Webhooks pentru agenții AI în timp real

Acum a noastră este și gata de implementare, să extindem capacitățile sale prin integrarea unei noi surse de intrare. Aplicaţie containerizată Aplicaţie containerizată Slack pentru comunicarea in timp real Imaginați-vă un scenariu în care vrem să primim notificări în timp real pentru mesaje noi în anumite canale Slack. (LLM) pentru a genera rezumate sau proiecte de răspunsuri. Această nouă funcționalitate va funcționa în tandem cu Ceea ce se întâmplă în continuare cu mailbox-urile. Modele lingvistice mari Un agent Modele lingvistice mari Un agent Această integrare va fi piatra de temelie a sistemului nostru Proactive Agent. Prin monitorizarea simultană a Slack și a e-mailului, aplicația noastră devine un hub centralizat pentru comunicații, asigurând că niciun mesaj nu este ratat și fiecare interogare este tratată prompt. Această abordare cu sursă dublă demonstrează puterea și flexibilitatea unui sistem bine proiectat, combinând atât platformele tradiționale, cât și cele moderne de comunicare pentru o soluție cuprinzătoare. Pentru a primi notificări despre noile mesaje Slack, putem folosi Un Webhook este un apel HTTP definit de utilizator care este declanșat de un eveniment într-un sistem sursă. Când evenimentul are loc, sistemul sursă face o cerere HTTP/HTTPS la adresa URL configurată în . Webhooks Webhook Cum funcționează Slack Webhooks În contextul Slack, un Webhook de ieșire este configurat pentru un anumit canal sau spațiu de lucru. Când este postat un mesaj sau un eveniment care îndeplinește anumite criterii (de exemplu, un anumit cuvânt cheie, model), Slack trimite o solicitare HTTP POST la o adresă URL desemnată. , care apoi procesează datele care intră. Aplicaţie Aplicaţie Acest mecanism este foarte eficient, deoarece În loc ca aplicația noastră să sondeze în mod constant Slack pentru noi mesaje (care este bogată în resurse și ineficientă), Slack ne „ împinge” în mod proactiv informațiile de îndată ce se întâmplă un eveniment. Evenimentul condus Evenimentul condus De ce să alegeți Webhooks? Obțineți mesaje așa cum se întâmplă, permițând acțiune imediată. Real-time updates: Aplicația noastră nu are nevoie de sondaje Slack, economisind apeluri API și resurse de server. Reduced resource usage: Webhooks sunt o modalitate standard și simplă de a conecta diferite servicii. Simple integration: Această abordare este esenţială pentru construirea unei care răspunde instantaneu la noile comunicări, indiferent dacă acestea provin din Slack sau din alte surse, cum ar fi e-mailul. Proactive Agent Webhooks de intrare și ieșire Da, Slack are atât webhooks de intrare, cât și de ieșire. Acestea sunt două mecanisme distincte care servesc scopuri diferite într-un flux de lucru de comunicare. Următor Webhooks Ce sunt acestea: Acesta este cel mai frecvent tip de webhook din Slack. Acestea permit aplicațiilor externe să trimită (push) mesaje într-un canal Slack. Aplicația dvs. face o solicitare HTTP POST la această adresă URL, trimițând o sarcină utilă JSON cu textul mesajului și formatarea. Webhooks de intrare utilizate pentru notificări, alerte și mesaje automate. De exemplu, pentru a trimite notificări despre noi angajamente GitHub, stări de implementare sau mesaje din partea noastră Înapoi la Slack. Proactive Un agent Un agent Un agent Webhooks de ieșire Acesta este un mecanism moștenit care permite Slack să trimită date către o aplicație externă atunci când un eveniment specific are loc într-un canal. Configurați un webhook ieșitor specificând adresa URL a aplicației și declanșând cuvinte sau evenimente.Când un utilizator dintr-un canal Slack postează un mesaj care conține unul dintre aceste cuvinte, Slack face o solicitare HTTP POST la adresa URL a aplicației. Webhooks de ieșire utilizate pentru a crea și automatizări care reacționează la comenzi sau cuvinte cheie specifice. Botoșani interactivi Botoșani interactivi În scenariul nostru, am setat un webhook de ieșire cu un declanșator ca rezumatul, astfel încât agentul nostru să poată primi și procesa mesajul pentru a genera un rezumat. Diferența cheie Incoming Webhooks sunt folosite pentru a trimite mesaje către Slack (de la o sursă externă). Webhooks de ieșire sunt folosite pentru a primi mesaje de la Slack (la o sursă externă), dar numai pe baza unui declanșator specific. În contextul articolului nostru despre , folosim un webhook de ieșire pentru a primi mesaje de la Slack pentru procesare și un webhook de intrare pentru a trimite răspunsuri înapoi la Slack. “Proactive Agent” Ghid pas cu pas pentru crearea unei aplicații Slack Pentru a permite Slack să ne trimită evenimente webhook, trebuie mai întâi să creăm o aplicație în portalul dezvoltatorului și să o instalăm în spațiul de lucru Slack sau într-un canal specific de la care vrem să primim notificări. Accesați site-ul Slack API: Navigați la . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps Faceți clic pe „Creați o aplicație” și alegeți să o construiți „De la zero”. Dați aplicației dvs. un nume descriptiv și selectați spațiul de lucru Slack în care îl veți dezvolta și testa. Activarea abonamentelor la evenimente: În setările aplicației, navigați la secțiunea „Abonații la evenimente” și activați „Activați evenimente”. Furnizați o adresă URL de solicitare: trebuie să furnizați o adresă URL accesibilă public pentru aplicația dvs. Acesta este punctul final în care Slack va trimite sarcini utile pentru evenimente. Slack va efectua o verificare de verificare a URL-urilor o singură dată, unde aplicația dvs. trebuie să răspundă cu valoarea provocării din cererea Slack. Vom crea acest punct final în aplicația noastră Symfony. Abonați-vă la evenimentele bot: Rulați în jos la secțiunea „Abonați-vă la evenimentele bot”. Faceți clic pe „Add Bot User Event” și selectați evenimentul message.channels. Acest lucru spune lui Slack să trimită aplicației dvs. o sarcină utilă pentru fiecare mesaj postat într-un canal public. Scopuri de solicitare: Pentru a primi aceste evenimente, botul dvs. va avea nevoie de permisiunile corespunzătoare. În secțiunea „OAuth & Permissions”, adăugați canals:history scope la token-ul botului. Reinstalarea aplicației: După adăugarea de noi domenii, trebuie să reinstalați aplicația în spațiul de lucru pentru ca modificările să intre în vigoare. Urmând aceste etape, noi va primi o sarcină de utilizare completă JSON pentru fiecare mesaj nou din canalele abonate, oferind mai mult context și flexibilitate decât metoda legacy trigger-word. . proactive agent Aplicații AI-powered Aplicații AI-powered Aplicații AI-powered Validarea Webhook Este timpul să creați un punct final pentru a gestiona răspunsul la cererea noastră de validare a punctului final. Avem două opțiuni pentru a lucra cu webhooks pe partea Symfony: îl putem gestiona la nivel de controler sau putem utiliza În acest articol, ne vom concentra pe lucrul la nivel de controler.Într-un viitor post, vă voi arăta cum să faceți acest lucru folosind . symfony/webhook Symfony Webhook Component Atunci când configurați adresa URL a punctului final în Slack Event Subscriptions, Slack trimite o cerere de verificare inițială pentru a confirma că adresa URL este valabilă și aparține aplicației dvs. Această cerere este o simplă cerere HTTP POST cu un corp JSON care include un Parametru. punctul nostru final trebuie să răspundă cu valoarea exactă a provocării din corpul solicitării. challenge Pentru a gestiona în mod corespunzător solicitarea webhook, trebuie nu numai să primim sarcina utilă, ci și să validăm corectitudinea acesteia. (DTO) și instalați două componente cheie ale Symfony: şi . Obiectele de transfer de date symfony/validator symfony/serializer-pack Obiectele de transfer de date Obiectele de transfer de date De ce sunt esențiale aceste componente Această componentă oferă un cadru robust pentru validarea datelor împotriva unui set de reguli. În loc să scriem manual declarații if-else pentru a verifica fiecare câmp, putem defini constrângerile de validare (de exemplu, NotBlank, Tip, Lungime) direct pe proprietățile DTO. symfony/validator: Acest pachet de componente oferă tot ce avem nevoie pentru serializarea (convertirea obiectelor în matrice/JSON) și deserializarea (convertirea JSON/arrays în obiecte) a datelor. Vom folosi deserializatorul pentru a converti automat sarcina utilă JSON primită de la Slack într-un obiect DTO validat. Acest proces automatizează sarcina obositoare de a cartografia câmpurile de date, asigurând că structura sarcinii utilă se potrivește așteptărilor noastre. symfony/serializer-pack: Și acum suntem gata să folosim colecțiile mai avansate pe care le oferă Doctrina. componentă încă; în schimb, vom instala doar pachetul pentru a lucra cu . Doctrine collections În timp ce array-urile PHP sunt versatile, le lipsesc unele caracteristici avansate, cum ar fi tipul de sugestie, imutabilitatea și metodele specializate pentru filtrare sau cartografiere. furnizează un ambalaj puternic, orientat spre obiect în jurul ariei, oferindu-ne o modalitate mai robustă și mai previzibilă de a gestiona datele. sistem, unde vom avea de-a face cu liste de mesaje, utilizatori sau alte sarcini utile de date. Doctrine Collections Proactive Agent Aceste modificări mici, dar cu impact, vor îmbunătăți în mod semnificativ modul în care gestionăm datele în cadrul companiei. , făcând logica agentului nostru mai robustă și mai ușor de întreținut. Aplicația noastră Aplicația noastră Pentru a instala componentele necesare, pur și simplu rulați următoarea comandă în terminalul dvs.: composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack Fluxul de lucru pentru validarea unei încărcături Webhook Primirea solicitării: Controlerul nostru Symfony primește solicitarea HTTP POST de la Slack. Deserializarea la DTO: Folosim serializatorul pentru a transforma sarcina utilă JSON în obiectul DTO predefinit. Validarea DTO: Componenta validator verifică proprietățile DTO împotriva constrângerilor definite. Gestionarea erorilor: În cazul în care validarea nu reușește, vom returna un răspuns de eroare (de exemplu, o cerere proastă 400) la Slack. Date valide de procesare: Dacă validarea are succes, aplicația noastră poate proceda în siguranță la prelucrarea datelor webhook, știind că acestea sunt în formatul corect. Această abordare structurată asigură că aplicația noastră este rezilientă și procesează numai date care corespund formatului așteptat, ceea ce este un pas critic în construirea unui sistem fiabil și securizat. Gestionarea mai multor plăți într-un singur controler De asemenea, ar trebui să luăm în considerare faptul că controlorul nostru și o singură rută trebuie să se ocupe în mod corespunzător , de la validarea URL la sarcinile de lucru ale evenimentelor de lucru la care ne-am abonat. different types of payloads Aceasta este o cerință esențială pentru un punct final de webhook robust. O singură rută trebuie să fie suficient de inteligentă pentru a face diferența între o solicitare de verificare URL de o dată și o notificare de eveniment live. Așa cum am discutat mai devreme, sarcina inițială de verificare URL de la Slack conține un Toate sarcinile succesive ale evenimentelor conțin o cheie de eveniment care deține datele mesajului real. Controlorul nostru trebuie să verifice prezența acestor chei pentru a determina natura solicitării. challenge Cerere tipică de validare URL Slack Bine, să creăm un DTO pentru a valida solicitarea de verificare a URL-urilor de la Slack. În primul rând, iată cum arată o sarcină de utilizare a unei solicitări tipice de validare a URL-urilor Slack. Atunci când activați Abonamente la evenimente, Slack trimite o solicitare POST la punctul dvs. final cu o sarcină utilă JSON care conține trei câmpuri cheie: token, provocare și tip. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } Un token unic pentru aplicația dvs. Puteți utiliza acest lucru pentru a verifica cererea este de la aplicația dvs. token: Trebuie să returnați acest șir exact în răspunsul dvs. JSON pentru a dovedi că dețineți adresa URL. challenge: Pentru validare, acesta va fi întotdeauna url_verification. type: Crearea unui DTO Acum, vom crea un DTO care reflectă această structură și include constrângeri de validare utilizând componenta validator 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; } } Acest DTO simplifică validarea: Asigură faptul că câmpurile token, provocare și tip sunt prezente în cerere. Assert\NotBlank: Confirmă că valoarea fiecărui câmp este un șir, împiedicând tipurile de date neașteptate. Assert\Type(“string”): Validează în mod specific faptul că câmpul de tip se potrivește cu șirul necesar, deci știm că tratăm o solicitare de verificare URL și nu un alt tip de eveniment. Assert\EqualTo(“url_verification”): Folosind acest DTO, putem deserialize sarcina utilă JSON de intrare și validarea automată a structurii sale cu cod minim în controlerul nostru. Crearea unui controler pentru validarea Slack Webhook Perfect, să creăm un controler care utilizează o DTO pentru a valida cererea de la Slack. Acest controler va verifica dacă cererea de intrare este o cerere de verificare URL și o va gestiona corect prin returnarea codului de provocare. SlackUrlValidationRequest Vom injecta în să deserializeze sarcina utilă JSON în DTO-ul nostru și în Această abordare face ca codul să fie curat, fiabil și compatibil cu standardele 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); } } Acest controler prelucrează acum solicitările de verificare în mod fiabil și în siguranță, ceea ce constituie baza pentru “ .” Agent proactiv Agent proactiv Agent proactiv Acum putem testa modul în care funcționează controlerul nostru trimițând un mesaj de validare URL de la un server, simulând comportamentul Slack. Această verificare va asigura că punctul nostru final este configurat corect și gata să primească date despre evenimente reale. Crearea unui DTO pentru mesajele de eveniment Slack Acum, să creăm un DTO pentru a procesa și valida mesajele pe care Slack ni le va trimite atunci când evenimentele apar. Spre deosebire de cererea simplă de validare URL, sarcina de utilizare a evenimentelor conține mult mai multe date, așa că vom crea mai multe DTO-uri pentru o validare mai eficientă și modulară. Structura tipică a cererii de eveniment O cerere de eveniment va conține câmpurile token, team_id, api_app_id și, cel mai important, un obiect de eveniment. În interiorul obiectului de eveniment, veți găsi informații despre tipul de eveniment (mesaj, app_mention etc.), textul mesajului, datele utilizatorului și informațiile despre 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": [ ... ] } Crearea DTO-urilor pentru gestionarea evenimentelor Vom crea o ierarhie de obiecte DTO pentru a separa validarea structurii generale a cererii de specificul evenimentului în sine. (Pentru întreaga cerere se aplică DTO) Acest DTO va conține câmpurile generale pentru toate evenimentele. 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 pentru obiectul evenimentului) Acest DTO va conține datele specifice evenimentului în sine. 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 pentru colectarea autorizațiilor) Această DTO va conține datele specifice colectării autorizațiilor. 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; } } Folosim trei DTO-uri pentru a separa validarea. validarea structurii generale a cererii, în timp ce validează conținutul obiectului evenimentului încorporat și validarea autorizației de colectare. SlackEvent SlackEventData SlackEventAuthorization Dacă în viitor vrem să gestionăm un alt tip de eveniment (de exemplu, app_mention sau reaction_added), creăm pur și simplu un nou DTO pentru acel tip de eveniment și îl folosim pentru validare. Cu aceste DTO-uri, controlerul nostru va fi capabil să primească și să valideze în mod fiabil mesajele de la Slack, ceea ce este un pas critic în construirea companiei noastre. “ .” Agent proactiv Agent proactiv Agent proactiv Crearea unui denormalizator personalizat În configurația sa implicită, Symfony Serializer nu poate deserialize automat obiecte complexe, cuibate, cum ar fi Pentru a cartografia corect gama de obiecte de autorizare din sarcina de utilizare Slack în DTO-ul nostru, avem nevoie de un denormalizator personalizat. SlackEventAuthorization Un denormalizator este o componentă care convertește date structurate (cum ar fi un array sau un obiect JSON) într-un obiect PHP. Serializatorul implicit poate gestiona proprietăți simple, dar nu știe cum să se ocupe de structuri complexe, cum ar fi un set de DTO-uri personalizate încorporate în interiorul unui alt DTO. Prin crearea unui denormalizator personalizat, îi spunem explicit serializatorului cum să cartografiem datele care intră în obiectul nostru specific. 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]; } } Controler actualizat pentru mai multe tipuri de evenimente Acum suntem gata să modificăm controlerul nostru webhook pentru a gestiona două tipuri de evenimente: url_verification și notificări de evenimente. Vom actualiza controlerul pentru a utiliza o declarație de comutare pentru a direcționa solicitările în funcție de tipul câmpului din sarcina utilă, făcând punctul nostru unic flexibil și robust. Controlerul actualizat va verifica tipul de sarcină utilă JSON de intrare. Dacă este o cerere de verificare url_verification, va efectua validarea pe care am configurat-o deja. 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); } } Utilizarea moștenirii pentru un flux de lucru unificat Am creat o nouă Clasa care moștenește din Aceasta este o decizie de proiectare semnificativă, care ne permite să trimitem mesaje Slack la autobuzul nostru de mesaje pentru procesarea asincronă standard de către compania noastră. utilizarea fluxului de lucru existent. SlackMessage Mesaj Un agent Mesaj Mesaj Un agent Un agent Prin extinderea , clasa SlackMessage se conformează automat aceluiași contract de mesagerie cerut de autobuzul nostru de mesagerie și Acest lucru înseamnă că nu avem nevoie să construim o nouă conductă de procesare separată pentru Slack. În schimb, putem pur și simplu să transmitem o instanță a SlackMessage în autobuz, iar sistemul o va gestiona la fel ca un e-mail obișnuit. Mesaj Un agent Mesaj Un agent Acum că codul nostru este complet, suntem gata să implementăm și să executăm aplicația noastră. În acest sens, vom folosi o abordare containerizată. , care simplifică procesul de gestionare atât a aplicației noastre Symfony, cât și a dependențelor sale, cum ar fi o bază de date sau un broker de mesaje. Agent proactiv Docker Compoziție Agent proactiv Docker Compoziție Concluzie pe clasa conține date specifice Slack, dar moștenește proprietățile de bază necesare agentului nostru, cum ar fi conținutul mesajului. SlackMessage Acum putem trimite un obiect SlackMessage la Symfony Message Bus pe un transport async standard. Agentul AI, care este deja configurat pentru a consuma mesaje din autobuz și proces obiectelor, poate manipula fără probleme obiectele SlackMessage fără a schimba logica sa de bază. Apoi, puteți utiliza conținutul mesajului pentru a-și îndeplini sarcinile, cum ar fi rezumarea sau generarea unui răspuns. Mesaj Agentul Mesaj Agentul Această abordare este foarte eficientă deoarece evită duplicarea codului și menține arhitectura sistemului nostru curată și scalabilă. pot integra cu ușurință noi canale de comunicare, asigurându-se că toate mesajele – fie din e-mail, fie din Slack – sunt procesate printr-un singur flux de lucru inteligent. Proactive Agent Agent proactiv În următoarele articole, vom explora modul de simplificare a codului nostru prin utilizarea Acest instrument puternic oferă o abstracție de nivel superior pentru gestionarea solicitărilor de webhook, eliminând nevoia pentru unele dintre controlerele manuale și logica de validare pe care le-am construit până acum. symfony/webhook Apoi ne vom scufunda în crearea unui flux de lucru separat, dedicat pentru a genera răspunsuri automate la mesajele Slack. Aceasta va implica: Pe baza arhitecturii noastre existente, vom proiecta un sistem care poate identifica mesajele care necesită un răspuns. Advanced Message Processing: Vom arăta cum să folosim o să formuleze răspunsuri inteligente, conștiente de context. Integrating an LLM: Modelul lingvistic mare Modelul lingvistic mare În cele din urmă, vom folosi un client Slack API pentru a trimite răspunsul generat înapoi utilizatorului, închizând cercul de comunicare și completând ** • Sistemul Sending a Reply: Agent proactiv Agent proactiv Rămâneți atenți pe măsură ce continuăm să construim această platformă puternică de comunicare în timp real.