Send telegram notification when new article submitted (#762)

* send telegram notification when new article submitted

* apply StyleCI fixes

* apply StyleCI fixes

* apply StyleCI fixes

* move telegram credentials to services.php

* ArticleWasCreated event

* pass AnonymousNotifiable in construct

* apply StyleCI fixes

* remove check env before event fire

* Bump laravel-notification-channels/telegram to 0.9.0

* Send notification when article submitted

* Update formatting

* rename listener

* apply StyleCI fixes

Co-authored-by: Joe Dixon <hello@joedixon.co.uk>

Author: faissaloux

.env.example

@@ -33,3 +33,6 @@ TWITTER_ACCESS_SECRET=
 
 FLARE_KEY=
 MIX_FLARE_KEY="${FLARE_KEY}"
+
+TELEGRAM_BOT_TOKEN=
+TELEGRAM_CHANNEL=

app/Events/ArticleWasSubmittedForApproval.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Events;
+
+use App\Models\Article;
+use Illuminate\Queue\SerializesModels;
+
+class ArticleWasSubmittedForApproval
+{
+    use SerializesModels;
+
+    public $article;
+
+    public function __construct(Article $article)
+    {
+        $this->article = $article;
+    }
+}

app/Jobs/CreateArticle.php

@@ -2,6 +2,7 @@
 
 namespace App\Jobs;
 
+use App\Events\ArticleWasSubmittedForApproval;
 use App\Http\Requests\ArticleRequest;
 use App\Models\Article;
 use App\Models\User;
@@ -56,6 +57,10 @@ public function handle(): Article
         $article->authoredBy($this->author);
         $article->syncTags($this->tags);
 
+        if ($article->isAwaitingApproval()) {
+            event(new ArticleWasSubmittedForApproval($article));
+        }
+
         return $article;
     }
 }

app/Jobs/UpdateArticle.php

@@ -2,6 +2,7 @@
 
 namespace App\Jobs;
 
+use App\Events\ArticleWasSubmittedForApproval;
 use App\Http\Requests\ArticleRequest;
 use App\Models\Article;
 
@@ -50,9 +51,15 @@ public function handle(): Article
             'body' => $this->body,
             'original_url' => $this->originalUrl,
             'slug' => $this->title,
-            'submitted_at' => $this->shouldUpdateSubmittedAt() ? now() : $this->article->submittedAt(),
         ]);
 
+        if ($this->shouldUpdateSubmittedAt()) {
+            $this->article->submitted_at = now();
+            $this->article->save();
+
+            event(new ArticleWasSubmittedForApproval($this->article));
+        }
+
         $this->article->syncTags($this->tags);
 
         return $this->article;

app/Listeners/SendNewArticleNotification.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\ArticleWasSubmittedForApproval;
+use App\Notifications\ArticleSubmitted;
+use Illuminate\Notifications\AnonymousNotifiable;
+
+final class SendNewArticleNotification
+{
+    public function __construct(
+        private AnonymousNotifiable $notifiable
+    ) {
+    }
+
+    public function handle(ArticleWasSubmittedForApproval $event): void
+    {
+        $this->notifiable->notify(new ArticleSubmitted($event->article));
+    }
+}

app/Notifications/ArticleSubmitted.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Notifications;
+
+use App\Models\Article;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Notification;
+use NotificationChannels\Telegram\TelegramMessage;
+
+class ArticleSubmitted extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    private Article $article;
+
+    public function __construct(Article $article)
+    {
+        $this->article = $article;
+    }
+
+    public function via($notifiable)
+    {
+        return ['telegram'];
+    }
+
+    public function toTelegram($notifiable)
+    {
+        $url = route('articles.show', $this->article->slug());
+
+        return TelegramMessage::create()
+            ->to(config('services.telegram-bot-api.channel'))
+            ->content($this->content())
+            ->button('View Article', $url);
+    }
+
+    private function content(): string
+    {
+        $content = "*New Article Submitted!*\n\n";
+        $content .= 'Title: '.$this->article->title()."\n";
+        $content .= 'By: [@'.$this->article->author()->username().']('.route('profile', $this->article->author()->username()).')';
+
+        return $content;
+    }
+}

app/Providers/EventServiceProvider.php

@@ -3,9 +3,11 @@
 namespace App\Providers;
 
 use App\Events\ArticleWasApproved;
+use App\Events\ArticleWasSubmittedForApproval;
 use App\Events\ReplyWasCreated;
 use App\Listeners\MarkLastActivity;
 use App\Listeners\SendArticleApprovedNotification;
+use App\Listeners\SendNewArticleNotification;
 use App\Listeners\SendNewReplyNotification;
 use App\Listeners\StoreTweetIdentifier;
 use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
@@ -23,6 +25,9 @@ class EventServiceProvider extends ServiceProvider
             MarkLastActivity::class,
             SendNewReplyNotification::class,
         ],
+        ArticleWasSubmittedForApproval::class => [
+            SendNewArticleNotification::class,
+        ],
         ArticleWasApproved::class => [
             SendArticleApprovedNotification::class,
         ],

composer.json

@@ -17,6 +17,7 @@
         "guzzlehttp/guzzle": "^7.0.1",
         "intervention/image": "^2.5",
         "intervention/imagecache": "^2.5",
+        "laravel-notification-channels/telegram": "^0.9.0",
         "laravel-notification-channels/twitter": "^5.0",
         "laravel/framework": "8.66.0",
         "laravel/horizon": "^5.2",

composer.lock

@@ -51,4 +51,9 @@
         'access_secret' => env('TWITTER_ACCESS_SECRET'),
     ],
 
+    'telegram-bot-api' => [
+        'token' => env('TELEGRAM_BOT_TOKEN'),
+        'channel' => env('TELEGRAM_CHANNEL'),
+    ],
+
 ];