Ako používať Slack prichádzajúce a odchádzajúce Webhooks pre agentov AI v reálnom čase

Teraz naše je a pripravený na nasadenie, rozšírime jeho možnosti integrovaním nového vstupného zdroja. aplikácie Kontajnerizácia aplikácie Kontajnerizácia Integrácia Slack pre komunikáciu v reálnom čase Predstavte si scenár, v ktorom chceme dostávať oznámenia v reálnom čase o nových správach v konkrétnych kanáloch Slack. (LLMs) generovať zhrnutia alebo návrhy odpovedí. Táto nová funkcia bude pracovať v tandeme s našimi existujúcimi , ktorý pokračuje v prieskume poštových schránok. Veľké jazykové modely Ako agent Veľké jazykové modely Ako agent Táto integrácia bude kľúčovým kameňom nášho systému Proactive Agent. Súbežným monitorovaním Slack a e-mailu sa naša aplikácia stáva centralizovaným hubom pre komunikáciu, čím sa zabezpečí, že žiadna správa nebude vynechaná a každá otázka bude okamžite spracovaná.Tento prístup s dvojitým zdrojom demonštruje silu a flexibilitu dobre navrhnutého systému, ktorý kombinuje tradičné aj moderné komunikačné platformy pre komplexné riešenie. Ak chcete získať oznámenia o nových správach Slack, môžeme použiť odchádzajúce Webhook je používateľom definovaný HTTP callback, ktorý je spustený udalosťou v zdrojovom systéme.Keď k udalosti dôjde, zdrojový systém urobí HTTP/HTTPS požiadavku na adresu URL nakonfigurovanú v . Webhooks Webhook Ako funguje Slack Webhooks V kontexte Slack je pre konkrétny kanál alebo pracovný priestor nakonfigurovaný odchádzajúci Webhook.Keď je zverejnená správa alebo sa dosiahne udalosť, ktorá spĺňa určité kritériá (napr. konkrétne kľúčové slovo, vzor), Slack odošle požiadavku HTTP POST na určenú adresu URL. , ktorý potom spracováva prichádzajúce údaje. aplikácie aplikácie Táto metóda je veľmi efektívna, pretože Namiesto toho, aby naša aplikácia neustále vyhľadávala Slack pre nové správy (čo je zdrojovo náročné a neefektívne), Slack nám proaktívne „potlačí“ informácie hneď, ako sa stane udalosť. udalosť poháňaná udalosť poháňaná Prečo si vybrať Webhooks? Získajte správy tak, ako sa vyskytujú, čo umožňuje okamžitú akciu. Real-time updates: Naša aplikácia nepotrebuje prieskum Slack, šetrí API hovory a serverové zdroje. Reduced resource usage: Webhooks sú štandardným a jednoduchým spôsobom pripojenia rôznych služieb. Simple integration: Tento prístup je nevyhnutný pre vytvorenie ktorý okamžite reaguje na nové komunikácie, či už pochádzajú zo Slack alebo z iných zdrojov, ako je e-mail. Proactive Agent Prichádzajúce a odchádzajúce webhooks Áno, Slack má prichádzajúce aj odchádzajúce webhooks. Toto sú dva odlišné mechanizmy, ktoré slúžia rôznym účelom v komunikačnom pracovnom postupe. Príchod Webhooks Čo sú: Toto je najbežnejší typ webhooku v Slack. Umožňujú externým aplikáciám posielať (push) správy do kanála Slack. Vaša aplikácia urobí HTTP POST požiadavku na túto URL, odosielanie JSON záťaž s textom správy a formátovanie. Prichádzajúce Webhooks sa používajú na oznámenia, upozornenia a automatizované správy. Napríklad na odosielanie oznámení o nových záväzkoch GitHub, stave nasadenia alebo správach z nášho servera. Späť na Slack. Proactive Ako agent Ako agent Ako agent Odporúčané webhooks Ide o tradičný mechanizmus, ktorý umožňuje spoločnosti Slack posielať (push) dáta do vonkajšej aplikácie, keď sa v kanáli vyskytne špecifická udalosť. Konfigurujete odchádzajúci webhook tak, že zadáte adresu URL vašej aplikácie a spustíte slová alebo udalosti.Keď používateľ v kanáli Slack zverejní správu obsahujúcu jedno z týchto slov, Slack vytvorí požiadavku HTTP POST na adresu URL vašej aplikácie. Outgoing Webhooks používané na vytváranie a automatizácie, ktoré reagujú na konkrétne príkazy alebo kľúčové slová. Interaktívne boty Interaktívne boty V našom scenári nastavujeme odchádzajúci webhook s spúšťačom ako súhrn, aby náš agent mohol prijímať a spracovávať správu na generovanie súhrnu. Kľúčový rozdiel Incoming Webhooks sa používajú na odosielanie správ do aplikácie Slack (z externého zdroja). Výstupné webové háčiky sa používajú na prijímanie správ zo služby Slack (do externého zdroja), ale iba na základe konkrétneho spúšťača. V kontexte nášho článku o Používame vychádzajúci webhook na prijímanie správ od spoločnosti Slack na spracovanie a prichádzajúci webhook na odoslanie odpovedí späť do spoločnosti Slack. “Proactive Agent” Krok za krokom sprievodca vytvorením aplikácie Slack Aby nám Slack mohol posielať webhook udalosti, musíme najprv vytvoriť aplikáciu v vývojárskom portáli a nainštalovať ju do pracovného priestoru Slack alebo konkrétneho kanála, z ktorého chceme dostávať oznámenia. Prístup na webovú stránku Slack API: Navigácia na . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps Kliknite na položku „Vytvoriť aplikáciu“ a vyberte možnosť „Vytvoriť ju od začiatku“. Dajte svojej aplikácii popisný názov a vyberte pracovný priestor Slack, v ktorom ju budete vyvíjať a testovať. Povoliť predplatné udalostí: V nastaveniach aplikácie prejdite do sekcie „Predplatné udalostí“ a zapnite „Povoliť udalosti“. Poskytnutie adresy URL žiadosti: Pre vašu aplikáciu musíte poskytnúť verejne prístupnú adresu URL. Toto je koncový bod, kde spoločnosť Slack odošle výnosy udalostí. Spoločnosť Slack vykoná jednorazovú kontrolu overenia adresy URL, kde vaša aplikácia musí reagovať s hodnotou výzvy z požiadavky spoločnosti Slack. Tento koncový bod vytvoríme v našej aplikácii Symfony. Prihláste sa k udalostiam botov: Prejdite nadol do sekcie „Prihlásiť sa k udalostiam botov“. Kliknite na „Pridať udalosť používateľa botov“ a vyberte udalosť message.channels.Toto hovorí spoločnosti Slack, aby vašej aplikácii poslala záťaž pre každú správu zverejnenú vo verejnom kanáli. Rozsah požiadaviek: Ak chcete tieto udalosti prijímať, váš robot bude potrebovať príslušné povolenia. V sekcii „OAuth & Permissions“ pridajte rozsah channels:history do tokenu vášho robota. Opätovná inštalácia aplikácie: Po pridaní nových rozsahov musíte aplikáciu znova nainštalovať do pracovného priestoru, aby zmeny nadobudli účinnosť. Po týchto krokoch, naše dostane plné JSON užitočné zaťaženie pre každú novú správu v predplatiteľských kanáloch, čo poskytuje viac kontextu a flexibility ako metóda dedičných spúšťačov slov. Tento moderný prístup je základom pre budovanie pokročilých, . proactive agent AI-powered aplikácie AI-powered aplikácie AI-powered aplikácie Webhook Validácia Je čas vytvoriť koncový bod na spracovanie odpovede na našu žiadosť o overenie koncového bodu. Máme dve možnosti na prácu s webhooks na strane Symfony: môžeme ho spracovať na úrovni ovládača alebo použiť V tomto článku sa zameriame na prácu na úrovni ovládača.V budúcom príspevku vám ukážem, ako to urobiť pomocou . symfony/webhook Symfony Webhook Component Keď nakonfigurujete svoju koncovú adresu URL v aplikácii Slack Event Subscriptions, spoločnosť Slack odošle počiatočnú žiadosť o overenie, aby potvrdila, že adresa URL je platná a patrí do vašej aplikácie. Náš koncový bod musí odpovedať s presnou hodnotou výzvy od žiadosti. challenge Aby sme správne spracovali žiadosť o webhook, musíme nielen prijať užitočné zaťaženie, ale aj overiť jeho správnosť. (DTO) a nainštalujte dve kľúčové komponenty Symfony: a . dátový prenos objektov symfony/validator symfony/serializer-pack dátový prenos objektov dátový prenos objektov Prečo sú tieto komponenty dôležité Namiesto manuálneho písania vyhlásení if-else na kontrolu každého poľa môžeme definovať obmedzenia overenia (napr. NotBlank, Typ, Dĺžka) priamo na našich vlastnostiach DTO. symfony/validator: Tento balík komponentov poskytuje všetko, čo potrebujeme na serializáciu (previesť objekty na súpravy/JSON) a deserializáciu (previesť JSON/arrays na objekty) dát. Použijeme deserializátor na automatickú konverziu prichádzajúceho úžitkového zaťaženia JSON zo Slack na validovaný objekt DTO. Tento proces automatizuje únavnú úlohu mapovania dátových polí, čím zabezpečíme, že štruktúra úžitkového zaťaženia zodpovedá našim očakávaniam. symfony/serializer-pack: A teraz sme pripravení používať pokročilejšie kolekcie, ktoré Doctrine ponúka. komponent zatiaľ; namiesto toho nainštalujeme iba balík na prácu s . Doctrine collections Zatiaľ čo rozsahy PHP sú všestranné, chýbajú im niektoré pokročilé funkcie, ako je tipovanie typu, nemennosť a špecializované metódy na filtrovanie alebo mapovanie. poskytujú výkonný, objektovo orientovaný obal okolo radov, čo nám poskytuje robustnejší a predvídateľnejší spôsob správy údajov. systém, kde sa budeme zaoberať zoznamami správ, používateľmi alebo inými dátovými záťažami. Doctrine Collections Proactive Agent Tieto malé, ale vplyvné zmeny výrazne zlepší spôsob, akým spravujeme dáta v rámci robí logiku nášho agenta robustnejšou a ľahšie sa udržiava. Naša aplikácia Naša aplikácia Ak chcete nainštalovať potrebné komponenty, jednoducho spustite nasledujúci príkaz vo vašom termináli: composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack Pracovný postup na overenie Webhook Payload Prijímať požiadavku: Náš ovládač Symfony prijíma požiadavku HTTP POST od spoločnosti Slack. Deserializácia na DTO: Používame serializátor na transformáciu úžitkového zaťaženia JSON na náš preddefinovaný objekt DTO. Validácia DTO: Validátorová zložka kontroluje vlastnosti DTO proti definovaným obmedzeniam. Riešenie chýb: Ak overenie zlyhá, vrátime odpoveď na chybu (napr. 400 Bad Request) do aplikácie Slack. Procesné platné údaje: Ak je overenie úspešné, naša aplikácia môže bezpečne pokračovať v spracovaní údajov webhook, s vedomím, že sú v správnom formáte. Tento štruktúrovaný prístup zaisťuje, že naša aplikácia je odolná a spracováva iba údaje, ktoré sú v súlade s naším očakávaným formátom, čo je kritický krok pri budovaní spoľahlivého a bezpečného systému. Riešenie viacerých platobných zaťažení v rámci jedného ovládača Mali by sme tiež zvážiť, že náš prevádzkovateľ a jediná trasa musia správne zvládnuť , od overenia adresy URL až po payloads pracovných udalostí, na ktoré sme sa prihlásili. different types of payloads Jednotná trasa musí byť dostatočne inteligentná na to, aby rozlišovala medzi jednorazovou žiadosťou o overenie adresy URL a oznámením o živej udalosti. Ako už bolo uvedené vyššie, počiatočné zaťaženie overovania URL od spoločnosti Slack obsahuje jedinečný Všetky následné náklady na udalosti obsahujú kľúč udalosti, ktorý obsahuje skutočné údaje o správe. challenge Typická žiadosť o overenie Slack URL V poriadku, vytvorme DTO na overenie žiadosti o overenie adresy URL od spoločnosti Slack. Po prvé, tu je to, ako vyzerá typická žiadosť o overenie adresy URL od spoločnosti Slack. Keď zapnete Predplatné udalostí, Slack odošle do vášho koncového bodu žiadosť POST s úžitkovým zaťažením JSON, ktoré obsahuje tri kľúčové polia: token, výzva a typ. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } Jedinečný token pre vašu aplikáciu. Toto môžete použiť na overenie žiadosti je z vašej aplikácie. token: Musíte vrátiť tento presný reťazec vo vašej odpovedi JSON, aby ste dokázali, že vlastníte adresu URL. challenge: Pre overenie, to bude vždy url_verification. type: Vytvorenie DTO Teraz vytvoríme DTO, ktoré odráža túto štruktúru a obsahuje obmedzenia overenia pomocou komponentu validátora 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; } } Toto DTO zjednodušuje validáciu: Zabezpečuje, aby token, výzva a typové polia boli prítomné v žiadosti. Assert\NotBlank: Potvrdzuje, že hodnota každého poľa je reťazec, čo zabraňuje neočakávaným typom údajov. Assert\Type(“string”): Špecificky overuje, že pole typu zodpovedá požadovanému reťazcu, takže vieme, že spracovávame žiadosť o overenie adresy URL a nie iný typ udalosti. Assert\EqualTo(“url_verification”): Pomocou tohto DTO môžeme deserializovať prichádzajúce úžitkové zaťaženie JSON a automaticky overiť jeho štruktúru s minimálnym kódom v našom ovládači. Vytvorenie ovládača pre Slack Webhook Validation Perfektné, vytvorme ovládač, ktorý používa Tento ovládač skontroluje, či prichádzajúca žiadosť je žiadosťou o overenie URL a správne ju spracováva vrátením kódu výzvy. SlackUrlValidationRequest Injekciu budeme podávať na deserializáciu úžitkového zaťaženia JSON do našej DTO a Tento prístup robí kód čistý, spoľahlivý a v súlade so štandardmi 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); } } Tento ovládač teraz spoľahlivo a bezpečne spracováva žiadosti o overenie, čo je základom pre naše “ .” Proaktívny agent Proaktívny agent Proaktívny agent Teraz môžeme otestovať fungovanie nášho ovládača odoslaním správy o overení adresy URL zo servera, ktorá simuluje správanie spoločnosti Slack.Táto kontrola zabezpečí, že náš koncový bod je správne nakonfigurovaný a pripravený na prijímanie údajov o skutočných udalostiach. Vytvorenie DTO pre správy o udalostiach Slack Teraz vytvorme DTO na spracovanie a overenie správ, ktoré nám Slack pošle, keď sa vyskytnú udalosti.Na rozdiel od jednoduchej žiadosti o overenie adresy URL, úžitkové zaťaženie udalostí obsahuje oveľa viac údajov, takže vytvoríme niekoľko DTO pre efektívnejšie a modulárnejšie overenie. Typická štruktúra žiadosti o udalosť Žiadosť o udalosť bude obsahovať token, team_id, api_app_id polia a čo je najdôležitejšie, objekt udalosti.Vnútri objektu udalosti nájdete informácie o type udalosti (správa, app_mention atď.), text správy, údaje o používateľovi a informácie o kanáli. { "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": [ ... ] } Vytvorenie DTO pre spracovanie udalostí Vytvoríme hierarchiu objektov DTO, aby sme oddelili validáciu celkovej štruktúry požiadavky od špecifikácií samotnej udalosti. (Obal DTO pre celú žiadosť) Táto DTO bude obsahovať všeobecné polia pre všetky udalosti. 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 pre objekt udalosti) Táto DTO bude obsahovať údaje špecifické pre samotnú udalosť. 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 pre zber povolení) Táto DTO bude obsahovať údaje špecifické pre zber povolení. 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; } } Na oddelenie validácie používame tri DTO. vyhodnocuje celkovú štruktúru žiadosti, zatiaľ čo potvrdzuje obsah nestedovaného objektu udalosti a Validácia povolenia na zber. SlackEvent SlackEventData SlackEventAuthorization Ak v budúcnosti chceme spracovať iný typ udalosti (napr. app_mention alebo reaction_added), jednoducho vytvoríme nový DTO pre tento typ udalosti a použijeme ho na overenie. S týmito DTO bude náš kontrolér schopný spoľahlivo prijímať a validovať správy od spoločnosti Slack, čo je kľúčovým krokom pri budovaní našej spoločnosti. “ .” Proaktívny agent Proaktívny agent Proaktívny agent Vytvorenie vlastného denormalizátora Vo svojej predvolenej konfigurácii nemôže Symfony Serializer automaticky deserializovať zložité, nestretnuté objekty, ako sú Na správne mapovanie rozsahu autorizačných objektov z úžitkového zaťaženia Slack do nášho DTO potrebujeme vlastný denormalizér. SlackEventAuthorization Denormalizér je komponent, ktorý konvertuje štruktúrované dáta (napríklad mriežku alebo objekt JSON) do PHP objektu. Predvolený serializér sa môže zaoberať jednoduchými vlastnosťami, ale nevie, ako zaobchádzať so zložitými štruktúrami, ako je množina vlastných DTO vložených do iného DTO. Vytvorením vlastného denormalizéra explicitne hovoríme serializérovi, ako mapovať prichádzajúce dáta do nášho konkrétneho objektu. 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]; } } Aktualizovaný ovládač pre viaceré typy udalostí Teraz sme pripravení zmeniť náš webhook controller tak, aby zvládol dva typy udalostí: url_verification a upozornenia na udalosti. Aktualizujeme ovládač tak, aby používal výslovnosť prepínača na nasmerovanie požiadaviek na základe typu poľa v užitočnom zaťažení, čím sa náš jediný koncový bod stáva flexibilným a robustným. Aktualizovaný ovládač skontroluje typ prichádzajúceho úžitkového zaťaženia JSON. Ak ide o žiadosť o overenie url_verification, vykoná overenie, ktoré sme už nastavili. Ak ide o event_callback, začne proces spracovania skutočnej udalosti Slack. namespace App\DTO; class SlackMessage extends MailMessage implements DataCollectionItemInterface { } namespace App\Controller; use App\DTO\DataCollection; use App\DTO\Slack\SlackEvent; use App\DTO\Slack\SlackUrlValidationRequest; use App\DTO\SlackMessage; use App\Message\Command\AIAgentSummarizeMessage; use Symfony\Component\HttpFoundation\JsonResponse; use Symfony\Component\HttpFoundation\Request; use Symfony\Component\HttpFoundation\Response; use Symfony\Component\HttpKernel\Exception\BadRequestHttpException; use Symfony\Component\Messenger\Envelope; use Symfony\Component\Messenger\MessageBusInterface; use Symfony\Component\Routing\Attribute\Route; use Symfony\Component\Serializer\SerializerInterface; use Symfony\Component\Validator\Validator\ValidatorInterface; class WebhookController { #[Route('/webhook/slack', name: 'webhookSlack')] public function __invoke(Request $request, ValidatorInterface $validator, SerializerInterface $serializer, MessageBusInterface $messageBus ): JsonResponse { $data = json_decode($request->getContent(), true); if ($data === null) { throw new BadRequestHttpException('Invalid JSON.'); } $dtoClass = SlackUrlValidationRequest::class; if (array_key_exists('type', $data) && $data['type'] === 'event_callback') { $dtoClass = SlackEvent::class; } $dto = $serializer->denormalize($data, $dtoClass); $errors = $validator->validate($dto); if (count($errors) > 0) { $errorMessages = []; foreach ($errors as $error) { $errorMessages[] = $error->getPropertyPath() . ': ' . $error->getMessage(); } return new JsonResponse(['errors' => $errorMessages], Response::HTTP_BAD_REQUEST); } switch (get_class($dto)) { case SlackUrlValidationRequest::class: return new JsonResponse($dto->getChallenge()); case SlackEvent::class : $emailCollection = new DataCollection( new SlackMessage( 'New Slack message', $dto->getEvent()->getUser(), $dto->getEvent()->getTeam(), $dto->getEvent()->getText(), $dto->getEvent()->getTs(), $dto->getEvent()->getClientMsgId() ) ); $messageBus->dispatch( new Envelope( new AIAgentSummarizeMessage( $emailCollection, 'I have slack message. Please summarize it into a concise overview (100-150 words) focusing on key decisions, action items, and deadlines. Here’s the slack message content:' ) ) ); break; } return new JsonResponse(['status' => 'ok'], Response::HTTP_OK); } } Využitie dedičstva pre jednotný pracovný postup Vytvorili sme novú Trieda, ktorá zdedila Toto je významné návrhové rozhodnutie, ktoré nám umožňuje posielať Slack správy do nášho správneho autobusu pre štandardné asynchrónne spracovanie našimi službami. Použitie existujúceho pracovného postupu. SlackMessage Poštové správy Ako agent Poštové správy Poštové správy Ako agent Ako agent Rozšírením , trieda SlackMessage automaticky vyhovuje rovnakej zmluve o správach požadovanej naším autobusom správ a To znamená, že nepotrebujeme vytvoriť nový, samostatný spracovateľský kanál pre Slack. Namiesto toho môžeme jednoducho odovzdať inštanciu SlackMessage do autobusu a systém ju bude spracovávať rovnako ako bežný e-mail. Poštové správy Ako agent Poštové správy Ako agent Teraz, keď je náš kód kompletný, sme pripravení nasadiť a spustiť našu aplikáciu. Využijeme kontajnerizovaný prístup s , čo zjednodušuje proces spravovania našej aplikácie Symfony a jej závislostí, ako je napríklad databáza alebo sprostredkovateľ správ. Proaktívny agent Docker Compose Proaktívny agent Docker skladá záver na trieda obsahuje údaje špecifické pre Slack, ale zdedí základné vlastnosti potrebné pre nášho agenta, ako je napríklad obsah správy. SlackMessage Objekt SlackMessage môžeme teraz odoslať do Symfony Message Bus na štandardnej asynchrónnej preprave. Agent AI, ktorý je už nakonfigurovaný na konzumáciu správ z autobusu a procesu objektov, môže bezproblémovo manipulovať s objektmi SlackMessage bez akýchkoľvek zmien v jeho základnej logike. Môžete potom použiť obsah správy na vykonanie svojich úloh, ako je zhrnutie alebo generovanie odpovede. Poštové správy Agentka Poštové správy Agentka Tento prístup je veľmi efektívny, pretože zabraňuje duplicite kódu a udržuje architektúru nášho systému čistú a škálovateľnú. Môžete ľahko integrovať nové komunikačné kanály, čím zabezpečíte, že všetky správy – či už z e-mailu alebo Slack – budú spracované prostredníctvom jedného inteligentného pracovného postupu. Proaktívny agent Proaktívny agent V nasledujúcich článkoch budeme skúmať, ako zjednodušiť náš kód pomocou Tento výkonný nástroj poskytuje vyššiu úroveň abstrakcie pre spracovanie požiadaviek na webhook, čím sa eliminuje potreba niektorých manuálnych ovládačov a validácie logiky, ktorú sme doteraz vybudovali. symfony/webhook Potom sa ponoríme do vytvárania samostatného, vyhradeného pracovného postupu na generovanie automatických odpovedí na správy Slack. To bude zahŕňať: Na základe našej existujúcej architektúry navrhneme systém, ktorý dokáže identifikovať správy, ktoré si vyžadujú odpoveď. Advanced Message Processing: Ukážeme vám, ako používať formulovať inteligentné, kontextovo vedomé odpovede. Integrating an LLM: Veľký jazykový model Veľký jazykový model Nakoniec použijeme klienta Slack API na odoslanie generovanej odpovede späť používateľovi, uzavretie komunikačného cyklu a dokončenie našej ** • Systém. Sending a Reply: Proactive Agent Proaktívny agent Zostaňte v pohode, keď budujeme túto výkonnú komunikačnú platformu v reálnom čase.