Feat/notify video was created

composer.json

@@ -33,7 +33,8 @@
     "elasticsearch/elasticsearch": "^7",
     "monolog/monolog": "^3",
 
-    "endclothing/prometheus_client_php": "^1"
+    "endclothing/prometheus_client_php": "^1",
+    "abraham/twitteroauth": "^4.0"
   },
   "require-dev": {
     "ext-xdebug": "*",

src/Mooc/Videos/Application/Create/VideoCreator.php

@@ -8,23 +8,28 @@
 use CodelyTv\Mooc\Shared\Domain\Videos\VideoUrl;
 use CodelyTv\Mooc\Videos\Domain\Video;
 use CodelyTv\Mooc\Videos\Domain\VideoId;
+use CodelyTv\Mooc\Videos\Domain\VideoNotificationSender;
 use CodelyTv\Mooc\Videos\Domain\VideoRepository;
 use CodelyTv\Mooc\Videos\Domain\VideoTitle;
 use CodelyTv\Mooc\Videos\Domain\VideoType;
 use CodelyTv\Shared\Domain\Bus\Event\EventBus;
 
 final class VideoCreator
 {
-    public function __construct(private readonly VideoRepository $repository, private readonly EventBus $bus)
-    {
-    }
+    public function __construct(
+        private readonly VideoRepository $repository,
+        private readonly EventBus $bus,
+        private readonly ?VideoNotificationSender $notificationSender = null
+    ) {}
 
     public function create(VideoId $id, VideoType $type, VideoTitle $title, VideoUrl $url, CourseId $courseId): void
     {
         $video = Video::create($id, $type, $title, $url, $courseId);
 
         $this->repository->save($video);
 
+        $this->notificationSender?->videoCreated($video);
+
         $this->bus->publish(...$video->pullDomainEvents());
     }
 }

src/Mooc/Videos/Domain/VideoNotificationSender.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CodelyTv\Mooc\Videos\Domain;
+
+use CodelyTv\Shared\Domain\Notification\Notification;
+use CodelyTv\Shared\Domain\Notification\Notificator;
+
+final class VideoNotificationSender
+{
+    public function __construct(private readonly Notificator $notificator) {}
+
+    public function videoCreated(Video $video): void
+    {
+        $this->notificator->notify(
+            new Notification("A new video has been published: " . $video->title()->value() . ". Check it out!")
+        );
+    }
+}

src/Shared/Domain/Notification/Notification.php

@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CodelyTv\Shared\Domain\Notification;
+
+final class Notification
+{
+    public function __construct(private readonly string $text) {}
+
+    public function getText(): string {
+        return $this->text;
+    }
+}

src/Shared/Domain/Notification/Notificator.php

@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CodelyTv\Shared\Domain\Notification;
+
+interface Notificator
+{
+    public function notify(Notification $notification): void;
+}

src/Shared/Infrastructure/Notification/TwitterNotificator.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CodelyTv\Shared\Infrastructure\Notification;
+
+use Abraham\TwitterOAuth\TwitterOAuth;
+use CodelyTv\Shared\Domain\Notification\Notification;
+use CodelyTv\Shared\Domain\Notification\Notificator;
+
+final class TwitterNotificator implements Notificator
+{
+    private readonly TwitterOAuth $client;
+
+    public function __construct(string $key, string $secret, string $accessToken, string $accessTokenSecret)
+    {
+        $this->client = new TwitterOAuth($key, $secret, $accessToken, $accessTokenSecret);
+    }
+
+    public function notify(Notification $notification): void
+    {
+        $this->client->post("statuses/update", ["status" => $notification->getText()]);
+    }
+}