feat: send notification

Author: tanhongit

src/Http/Actions/IndexAction.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace CSlant\LaravelTelegramGitNotifier\Http\Actions;
+
+use CSlant\TelegramGitNotifier\Bot;
+use CSlant\TelegramGitNotifier\Exceptions\ConfigFileException;
+use CSlant\TelegramGitNotifier\Exceptions\InvalidViewTemplateException;
+use CSlant\TelegramGitNotifier\Exceptions\MessageIsEmptyException;
+use CSlant\TelegramGitNotifier\Exceptions\SendNotificationException;
+use CSlant\TelegramGitNotifier\Notifier;
+use CSlant\LaravelTelegramGitNotifier\Services\NotificationService;
+use GuzzleHttp\Client;
+use Symfony\Component\HttpFoundation\Request;
+use Telegram;
+
+class IndexAction
+{
+    protected Client $client;
+
+    protected Bot $bot;
+
+    protected Notifier $notifier;
+
+    protected Request $request;
+
+    /**
+     * @throws ConfigFileException
+     */
+    public function __construct()
+    {
+        $this->client = new Client();
+
+        $telegram = new Telegram(config('telegram-git-notifier.bot.token'));
+        $this->bot = new Bot($telegram);
+        $this->notifier = new Notifier();
+    }
+
+    /**
+     * Handle telegram git notifier app
+     *
+     * @return void
+     * @throws InvalidViewTemplateException
+     * @throws MessageIsEmptyException
+     * @throws SendNotificationException
+     */
+    public function __invoke(): void
+    {
+        $sendNotification = new NotificationService($this->notifier,
+            $this->bot->setting);
+        $sendNotification->handle();
+    }
+}

src/Services/NotificationService.php

@@ -0,0 +1,108 @@
+<?php
+
+namespace CSlant\LaravelTelegramGitNotifier\Services;
+
+use CSlant\TelegramGitNotifier\Exceptions\InvalidViewTemplateException;
+use CSlant\TelegramGitNotifier\Exceptions\MessageIsEmptyException;
+use CSlant\TelegramGitNotifier\Exceptions\SendNotificationException;
+use CSlant\TelegramGitNotifier\Models\Setting;
+use CSlant\TelegramGitNotifier\Notifier;
+use CSlant\TelegramGitNotifier\Objects\Validator;
+use Symfony\Component\HttpFoundation\Request;
+
+class NotificationService
+{
+    protected Request $request;
+
+    protected array $chatIds = [];
+
+    protected Notifier $notifier;
+
+    protected Setting $setting;
+
+    public function __construct(
+        Notifier $notifier,
+        Setting $setting,
+    ) {
+        $this->request = Request::createFromGlobals();
+        $this->notifier = $notifier;
+        $this->chatIds = $this->notifier->parseNotifyChatIds();
+
+        $this->setting = $setting;
+    }
+
+    /**
+     * Handle to send notification from webhook event to telegram
+     *
+     * @return void
+     * @throws InvalidViewTemplateException
+     * @throws SendNotificationException
+     * @throws MessageIsEmptyException
+     */
+    public function handle(): void
+    {
+        $eventName = $this->notifier->handleEventFromRequest($this->request);
+        if (!empty($eventName)) {
+            $this->sendNotification($eventName);
+        }
+    }
+
+    /**
+     * @param  string  $event
+     *
+     * @return void
+     * @throws InvalidViewTemplateException
+     * @throws SendNotificationException
+     * @throws MessageIsEmptyException
+     */
+    private function sendNotification(string $event): void
+    {
+        if (!$this->validateAccessEvent($event)) {
+            return;
+        }
+
+        foreach ($this->chatIds as $chatId => $thread) {
+            if (empty($chatId)) {
+                continue;
+            }
+
+            if (empty($thread)) {
+                $this->notifier->sendNotify(null, ['chat_id' => $chatId]);
+
+                continue;
+            }
+
+            foreach ($thread as $threadId) {
+                $this->notifier->sendNotify(null, [
+                    'chat_id' => $chatId, 'message_thread_id' => $threadId,
+                ]);
+            }
+        }
+    }
+
+    /**
+     * Validate access event
+     *
+     * @param  string  $event
+     *
+     * @return bool
+     * @throws InvalidViewTemplateException|MessageIsEmptyException
+     */
+    private function validateAccessEvent(string $event): bool
+    {
+        $payload = $this->notifier->setPayload($this->request, $event);
+        $validator = new Validator($this->setting, $this->notifier->event);
+
+        if (empty($payload)
+            || !$validator->isAccessEvent(
+                $this->notifier->event->platform,
+                $event,
+                $payload
+            )
+        ) {
+            return false;
+        }
+
+        return true;
+    }
+}