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()]);
+ }
+}