Како да ги користите Slack Incoming и Outgoing Webhooks за агенти за АИ во реално време

Сега нашата е и подготвени за имплементација, ајде да ги прошириме неговите можности со интегрирање на нов извор на влез. апликација containerized апликација Контејнерирање Интегрирање на Slack за комуникации во реално време Замислете сценарио во кое сакаме да добиваме известувања во реално време за нови пораки во одредени канали на Slack. (LLMs) за да се генерираат резимеа или нацрт одговори. Оваа нова функционалност ќе работи во тандем со нашите постоечки Кој и понатаму ги испитува поштенските кутии. Големи јазични модели Како агент Големи јазични модели Како агент Со истовремено следење на Slack и е-пошта, нашата апликација станува централизиран центар за комуникации, обезбедувајќи дека нема пропуштени пораки и секое барање се обработува навремено. Овој пристап со двојни извори ја демонстрира моќта и флексибилноста на добро дизајниран систем, комбинирајќи ги традиционалните и модерните комуникациски платформи за сеопфатно решение. За да добиете известувања за нови Slack пораки, можеме да користиме Webhook е кориснички дефиниран HTTP повик кој е предизвикан од настан во изворниот систем.Кога настанот се случува, изворниот систем прави HTTP/HTTPS барање до URL-то конфигурирано во . Webhooks Webhook Како работи Slack Webhooks Во контекст на Slack, Webhook е конфигуриран за одреден канал или работен простор. Кога е објавена порака или е постигнат настан кој ги исполнува одредени критериуми (на пример, одреден клучен збор, модел), Slack испраќа HTTP POST барање до одредена URL. , кој потоа ги обработува влезните податоци. апликација апликација Овој механизам е исклучително ефикасен, бидејќи Наместо нашата апликација постојано да ја истражува Slack за нови пораки (што е ресурсно интензивно и неефикасно), Slack проактивно ги "пушта" информациите до нас веднаш штом се случи настанот. настани водени настани водени Зошто да изберете Webhooks? Добијте пораки како што се случуваат, овозможувајќи итна акција. Real-time updates: Нашата апликација не треба да истражува Slack, заштедувајќи API повици и ресурси на серверот. Reduced resource usage: Webhooks е стандарден и едноставен начин за поврзување на различни услуги. Simple integration: Овој пристап е од суштинско значење за изградба на што веднаш одговара на новите комуникации, без разлика дали потекнуваат од Slack или други извори како е-пошта. Proactive Agent Влегувачки и излегувачки Webhooks Да, Slack има и влезни и излезни webhooks.Овие се два различни механизми кои служат за различни цели во комуникацискиот работен тек. Влегување Webhooks Што се тие: Ова е најчестиот тип на webhook во Slack. Тие им овозможуваат на надворешните апликации да испраќаат (потиснете) пораки во Slack канал. Вашата апликација прави HTTP POST барање на овој URL, испраќајќи JSON корисничко оптоварување со текстот на пораката и форматирање. Влезни Webhooks се користат за известувања, предупредувања и автоматски пораки. На пример, за да испраќате известувања за нови GitHub ангажмани, состојби на распоредување или пораки од нашата компанија. Враќање во слајд. Proactive Како агент Како агент Како агент Излегување Webhooks Ова е наследен механизам кој му овозможува на Slack да испраќа (потисне) податоци до надворешна апликација кога се случува специфичен настан во канал. Можете да конфигурирате излезен веб-кук со тоа што ќе го наведете URL-то на вашата апликација и ќе ги активирате зборовите или настаните.Кога корисникот во Slack канал поставува порака која содржи еден од овие зборови, Slack прави HTTP POST барање за URL-то на вашата апликација. Излезни Webhooks се користат за создавање и автоматизација кои реагираат на одредени команди или клучни зборови. Интерактивни ботови Интерактивни ботови Во нашиот сценарио, поставивме излезен веб-кук со триггер како резиме, така што нашиот агент може да ја прима и обработува пораката за да генерира резиме. Клучна разлика Влезни Webhooks се користат за испраќање пораки до Slack (од надворешен извор). Излезни Webhooks се користат за примање пораки од Slack (на надворешен извор), но само врз основа на специфичен триггер. Во контекст на нашата статија за , ние користиме излезен веб-кук за да примаме пораки од Slack за обработка и влезен веб-кук за да испратиме одговори назад до Slack. “Proactive Agent” Чекор по чекор водич за креирање на Slack апликација За да му овозможиме на Slack да ни испраќа веб-шокови, прво мора да креираме апликација во порталот на програмерите и да ја инсталираме во работниот простор на Slack или во одреден канал од кој сакаме да примаме известувања. Пристап до веб-страницата на Slack API: Навигација до . https://api.slack.com/apps https://api.slack.com/apps https://api.slack.com/apps Кликнете на "Креирај апликација" и изберете да ја изградите "Од нула". Дајте му на апликацијата описно име и изберете работен простор на Slack каде што ќе го развивате и тестирате. Овозможи претплата на настани: Во подесувањата на вашата апликација, преместете се во делот „Пријавување на настани“ и вклучете „Овозможи настани“. Обезбедете URL за барање: Мора да обезбедите јавно достапен URL за вашата апликација. Ова е крајната точка каде што Slack ќе испраќа настан payloads. Slack ќе изврши еднократна проверка за верификација на URL, каде што вашата апликација мора да одговори со вредноста на предизвикот од барањето на Slack. Ние ќе ја креираме оваа крајна точка во нашата Symfony апликација. Пријавете се на Bot Events: Превртете се надолу до делот „Пријавете се на Bot Events“. Кликнете на „Додај Bot User Event“ и одберете го настанот message.channels. Ова му кажува на Slack да ја испрати вашата апликација корисничко оптоварување за секоја порака објавена во јавен канал. За да ги добиете овие настани, на вашиот бот ќе ви бидат потребни соодветни овластувања. Во делот „Oauth & Permissions“ додадете опсег на канали:историја на вашиот бот токен. Ова ви дава можност да ги прегледувате пораките во јавните канали. Повторно инсталирајте ја вашата апликација: Откако ќе додадете нови опсези, треба повторно да ја инсталирате вашата апликација во работниот простор за промените да стапат на сила. По овие чекори, нашите ќе добие целосно JSON корисно оптоварување за секоја нова порака во претплатените канали, обезбедувајќи повеќе контекст и флексибилност од методот на наследен тригери. . proactive agent AI-помоќни апликации AI-помоќни апликации AI-помоќни апликации Управување со Webhook валидација Време е да се создаде крајна точка за да се справи со одговорот за нашето барање за валидација на крајната точка.Имаме две опции за работа со webhooks на страната на Symfony: можеме да се справиме со тоа на ниво на контролер или да го користиме Во оваа статија, ние ќе се фокусираме на работа на ниво на контролер. Во иднина пост, јас ќе ви покажеме како да го направите ова со користење на . symfony/webhook Symfony Webhook Component Кога ќе го конфигурирате URL-то на крајната точка во претплатите на настани на Slack, Slack испраќа првобитно барање за верификација за да потврди дека URL-то е валидно и припаѓа на вашата апликација. Нашата крајна точка мора да одговори со точната вредност на предизвикот од телото на барањето. challenge За правилно да се справи со барањето за webhook, мораме не само да го добиеме корисничкото оптоварување, туку и да ја потврдиме неговата точност. (DTOs) и инсталирајте две клучни компоненти на Symfony: и . Објекти за пренос на податоци symfony/validator symfony/serializer-pack Објекти за пренос на податоци Објекти за пренос на податоци Зошто овие компоненти се важни Оваа компонента обезбедува цврста рамка за валидирање на податоците според сет правила. Наместо рачно да пишуваме if-else изјави за да ги провериме секое поле, можеме да ги дефинираме ограничувањата за валидирање (на пример, NotBlank, Type, Length) директно на нашите DTO својства. symfony/validator: Овој пакет компоненти обезбедува сè што ни е потребно за серијализација (претворање на објекти во арени / JSON) и десеријализација (претворање на JSON /arrays во објекти) на податоци. Ние ќе го користиме десеријализаторот за автоматски да го конвертираме влезниот JSON корисен товар од Slack во валидиран DTO објект. symfony/serializer-pack: И сега сме подготвени да ги користиме повеќе напредните колекции што ги нуди Доктрината. компонента се уште; наместо тоа, ние ќе го инсталираме само пакетот за работа со . Doctrine collections Додека масивите на PHP се разноврсни, им недостасуваат некои напредни карактеристики како што се тип-индикации, непроменливост и специјализирани методи за филтрирање или мапирање. обезбеди моќна, објектно-ориентирана обвивка околу масивите, што ни дава посилен и предвидлив начин за управување со податоците. систем, каде што ќе се занимаваме со списоци на пораки, корисници или други полн товар на податоци. Doctrine Collections Proactive Agent Овие мали, но влијателни промени значително ќе го подобрат начинот на кој управуваме со податоците во Тоа ја прави логиката на нашиот агент посилна и полесна за одржување. our application Нашата апликација За да ги инсталирате потребните компоненти, едноставно извршете ја следната команда во вашиот терминал: composer require doctrine/collections composer require symfony/validator composer require symfony/serializer-pack Работен тек за валидирање на Webhook Payload Примање на барањето: нашиот контролер на Symfony ја прима HTTP POST барањето од Slack. Deserialize до DTO: Ние го користиме сериализаторот за да го трансформираме JSON корисничкото оптоварување во нашиот претходно дефиниран DTO објект. Валидирање на DTO: компонентата на валидаторот ги проверува својствата на DTO против дефинираните ограничувања. Справување со грешки: Ако верификацијата не успее, ние враќаме одговор на грешка (на пример, 400 лоша барање) на Slack. Процес валидни податоци: Ако валидацијата успее, нашата апликација може безбедно да продолжи со обработка на податоците за веб-кук, знаејќи дека е во вистинскиот формат. Овој структуриран пристап гарантира дека нашата апликација е отпорна и обработува само податоци кои се во согласност со нашиот очекуваниот формат, што е критичен чекор во изградбата на сигурен и сигурен систем. Ракување со различни плаќања во рамките на еден контролер Исто така, треба да разгледаме дека нашиот контролор и еден пат мора правилно да се справат , од верификација на URL до работните налози на настани на кои сме се претплатиле. different types of payloads Ова е клучен услов за цврста веб-кук крајна точка. Еден пат мора да биде доволно паметен за да се направи разлика помеѓу еднократно барање за верификација на URL и известување за настани во живо. Како што беше дискутирано порано, почетната корисна тежина за верификација на URL од Slack содржи единствена Сите последователни тегови на настани содржат клуч за настани кој ги содржи податоците за вистинската порака.Нашиот контролор мора да го провери присуството на овие клучеви за да ја утврди природата на барањето. challenge Типичен Slack URL барање за валидација Добро, ајде да креираме DTO за да го потврдиме барањето за верификација на URL од Slack. Прво, еве како изгледа типичниот товар на барањето за верификација на URL од Slack. Кога ќе ги овозможите претплатите на настани, Slack испраќа POST барање до вашата крајна точка со JSON корисничко оптоварување кое содржи три клучни полиња: токен, предизвик и тип. { "token": "Jhj5...z412", "challenge": "3eZbr...", "type": "url_verification" } Уникатен токен за вашата апликација. Можете да го користите за да го проверите барањето е од вашата апликација. token: Треба да го вратите овој точен ред во вашиот JSON одговор за да докажете дека го поседувате URL-то. challenge: За валидација, ова секогаш ќе биде url_verification. type: Создавање на ДТО Сега, ќе создадеме DTO кој ја одразува оваа структура и вклучува ограничувања за валидација користејќи ја компонентата за валидација на Symfony. namespace App\DTO\Slack; use Symfony\Component\Validator\Constraints as Assert; class SlackUrlValidationRequest { #[Assert\NotBlank] #[Assert\Type('string')] public string $token; #[Assert\NotBlank] #[Assert\Type('string')] public string $challenge; #[Assert\NotBlank] #[Assert\Type('string')] #[Assert\EqualTo("url_verification")] public string $type; public function getToken(): string { return $this->token; } public function getChallenge(): string { return $this->challenge; } public function getType(): string { return $this->type; } } Овој DTO ја поедноставува валидацијата: Обезбедува дека полето за токен, предизвик и тип се присутни во барањето. Assert\NotBlank: Потврдува дека вредноста на секое поле е низа, спречувајќи неочекувани типови на податоци. Assert\Type(“string”): Специфично потврдува дека полето со тип одговара на потребниот ред, така што знаеме дека се занимаваме со барање за верификација на URL, а не со друг тип на настан. Assert\EqualTo(“url_verification”): Со користење на овој DTO, можеме да дезериализираме влезниот JSON корисен товар и автоматски да ја потврдиме неговата структура со минимален код во нашиот контролер. Создавање на контролер за валидација на Slack Webhook Совршено, ајде да создадеме контролер кој користи Овој контролер ќе провери дали дојдовното барање е барање за верификација на URL и ќе го обработи правилно со враќање на кодот за предизвик. SlackUrlValidationRequest Ќе го инјектираме за да се дезериализира JSON корисничкото оптоварување во нашата DTO и Овој пристап го прави кодот чист, сигурен и во согласност со стандардите на 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); } } Овој контролер сега веродостојно и безбедно ги обработува барањата за верификација, што е основа за нашата “ .” Проактивен агент Проактивен агент Проактивен агент Сега можеме да тестираме како функционира нашиот контролер со испраќање порака за верификација на URL од сервер, симулирајќи го однесувањето на Slack. Креирање на DTO за пораки за Slack настани Сега, ајде да креираме DTO за обработка и валидирање на пораките што Slack ќе ни ги испрати кога ќе се случат настани. За разлика од едноставното барање за валидирање на URL-то, корисничкото оптоварување на настаните содржи многу повеќе податоци, па ќе создадеме неколку DTO-и за поефикасна и модуларна валидација. Типична структура на барање за настани Барањето за настани ќе ги содржи полето токен, team_id, api_app_id и, што е најважно, објектот на настанот.Во објектот на настанот, ќе најдете информации за типот на настанот (послание, app_mention, итн.), текстот на пораката, корисничките податоци и информациите за каналот. { "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": [ ... ] } Креирање на DTOs за ракување со настани Ќе создадеме хиерархија на DTO објекти за да ја одвоиме валидацијата на целокупната структура на барањето од спецификите на самиот настан. (Облеката DTO за целото барање) Овој DTO ќе ги содржи општите полиња за сите настани. 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 за објектот на настанот) Оваа ДТО ќе ги содржи податоците специфични за самиот настан. 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); } } (ДТО за собирање на овластувања) Оваа ДТО ќе ги содржи податоците специфични за собирањето на овластувањата. 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; } } Ние користиме три DTOs за да ја одвоиме валидацијата. ја потврдува целокупната структура на барањето, додека потврдува содржината на објектот за вграден настан и Валидирање на овластувањето за собирање. SlackEvent SlackEventData SlackEventAuthorization Ако во иднина сакаме да управуваме со друг тип на настан (на пример, app_mention или reaction_added), едноставно создаваме нов DTO за тој тип на настан и го користиме за валидација. Со овие DTOs, нашиот контролер ќе може сигурно да прима и да ги потврдува пораките од Slack, што е критичен чекор во изградбата на нашата компанија. “ .” Proactive Agent Проактивен агент Проактивен агент Креирање на Custom Denormalizer Во својата конфигурација по дефолт, Symfony Serializer не може автоматски да десеријализира комплексни, вградени објекти како што се За правилно мапирање на низа на објекти за овластување од корисничкото оптоварување на Slack во нашата DTO, ни е потребен сопствен denormalizer. SlackEventAuthorization Денормализатор е компонента која конвертира структурирани податоци (како матрица или JSON објект) во PHP објект. Подрачливото серијализатор може да се справи со едноставни својства, но не знае како да се справи со комплексни структури како низа на сопствени DTOs вметнати во друг DTO. 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]; } } Ажуриран контролер за повеќе типови на настани Сега сме подготвени да го модифицираме нашиот контролер за веб-кук за да се справуваме со два типа на настани: url_verification и известувања за настани. Ние ќе го ажурираме контролерот за да користиме изјава за префрлување за да ги насочиме барањата врз основа на полето со тип во корисничкото оптоварување, правејќи ја нашата единствена крајна точка флексибилна и цврста. Ажурираниот контролер ќе го провери типот на влезниот JSON корисен товар. Ако тоа е барање за url_verification, ќе ја изврши верификацијата што веќе ја поставивме. 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); } } Користење на наследноста за единствен работен тек Ние создадовме нова Класата која ја наследува Ова е значајна одлука за дизајн која ни овозможува да испраќаме Slack пораки до нашиот автобус за пораки за стандардна асинхронска обработка од страна на нашата компанија. Користете го постоечкиот работен тек. SlackMessage Поштенски Како агент Поштенски Поштенски Како агент Како агент По проширувањето , класата SlackMessage автоматски се усогласува со истиот договор за пораки што го бара нашиот автобус за пораки и Ова значи дека не треба да изградиме нов, посебен процесор за Slack. Наместо тоа, можеме едноставно да пренесеме инстанца на SlackMessage на автобусот, а системот ќе се справи со тоа исто како и со редовна е-пошта. Поштенски Како агент Поштенски Како агент Сега кога нашиот код е комплетен, ние сме подготвени да ги распоредиме и да ја извршиме нашата апликација. систем, ќе користиме контејнерски пристап со , што го поедноставува процесот на управување со нашата апликација Symfony и нејзините зависности, како што е база на податоци или брокер за пораки. Проактивен агент Docker Compose Проактивен агент Докер се состои Заклучок на Класата содржи Slack-специфични податоци, но ги наследува основните својства потребни за нашиот агент, како што е содржината на пораката. SlackMessage Сега можеме да испратиме SlackMessage објект до Symfony Message Bus на стандарден асинхрон транспорт. Агентот на АИ, кој веќе е конфигуриран да ги консумира пораките од автобусот и процесот објекти, може беспрекорно да се справи со SlackMessage објекти без никакви промени во неговата основна логика. Потоа можете да ја користите содржината на пораката за да ги извршите своите задачи, како што се сумирање или генерирање одговор. Поштенски Агент Поштенски Агент Овој пристап е многу ефикасен, бидејќи го избегнува дуплирањето на кодот и ја одржува архитектурата на нашиот систем чиста и скалабилна. лесно може да се интегрираат нови канали за комуникација, обезбедувајќи дека сите пораки – било од е-пошта или од Slack – се обработуваат преку еден интелигентен работен тек. Проактивен агент Проактивен агент Во нашите следни статии, ќе истражуваме како да го поедноставиме нашиот код со користење на Оваа моќна алатка обезбедува апстракција на повисоко ниво за обработка на веб-барања, елиминирајќи ја потребата за некои од рачните контролери и логиката за валидација што ја изградивме досега. symfony/webhook Потоа ќе се нурнеме во создавање на посебен, посветен работен тек за генерирање на автоматски одговори на Slack пораки. Ова ќе вклучува: Врз основа на нашата постоечка архитектура, ќе дизајнираме систем кој може да ги идентификува пораките кои бараат одговор. Advanced Message Processing: Ќе покажеме како да се користи Да се формулираат интелигентни, контекстуално свесни одговори. Integrating an LLM: Голем јазичен модел Голем јазичен модел Конечно, ќе користиме Slack API клиент за да го испратиме генерираниот одговор назад до корисникот, затворање на комуникацискиот круг и завршување на нашиот ** • Системот Sending a Reply: Проактивен агент Проактивен агент Останете подготвени додека продолжуваме да ја градиме оваа моќна платформа за комуникација во реално време.