src/Subscriber/BitbucketEventSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber;
  5. use App\Services\Discord\DiscordMessageService;
  6. use Smalot\Bitbucket\Webhook\Event\EventBase;
  7. use Smalot\Bitbucket\Webhook\Event\RepoCommitStatusCreatedEvent;
  8. use Smalot\Bitbucket\Webhook\Event\RepoCommitStatusUpdatedEvent;
  9. use Smalot\Bitbucket\Webhook\Event\RepoPushEvent;
  10. use Smalot\Bitbucket\Webhook\Model\RepoPushModel;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class BitbucketEventSubscriber implements EventSubscriberInterface
  14. {
  16.     const COMMIT_STATUS_INPROGRESS = 'INPROGRESS';
  17.     const COMMIT_STATUS_SUCCESSFUL = 'SUCCESSFUL';
  18.     const COMMIT_STATUS_FAILED = 'FAILED';
  19.     const COMMIT_TAGGED_SUCCESSFUL = 'has new version';
  21.     const COLOR_RED = '#ED4245';
  22.     const COLOR_BLUE = '#5865F2';
  23.     const COLOR_GREEN = '#57F287';
  25.     private DiscordMessageService $discordMessageService;
  28.     public function __construct(DiscordMessageService $discordMessageService)
  29.     {
  30.         $this->discordMessageService = $discordMessageService;
  31.     }
  33.     public static function getSubscribedEvents()
  34.     {
  35.         // return the subscribed events, their methods and priorities
  36.         return [
  37.             RepoCommitStatusUpdatedEvent::class => 'onCommitStatusChanged',
  38.             RepoCommitStatusCreatedEvent::class => 'onCommitStatusChanged',
  39.             RepoPushEvent::class => 'onRepoPush',
  40.         ];
  41.     }
  43.     public function onRepoPush(EventBase $event): void
  44.     {
  45.         /** @var RepoPushModel $model */
  46.         $model = $event->getData();
  47.         $repository = $model->getRepository();
  48.         $push = $model->getPush();
  50.         if (
  51.             !empty($repository['project']['name']) &&
  52.             !empty($repository['name']) &&
  53.             !empty($push['changes'])
  54.         ) {
  55.             foreach ($push['changes'] as $change) {
  56.                 if (!empty($change['new']['type']) && $change['new']['type'] === 'tag' && !empty($change['new']['name'])) {
  57.                     $this->sendDiscordNotification(
  58.                         $repository['project']['name'],
  59.                         $repository['name'],
  60.                         null,
  61.                         self::COMMIT_TAGGED_SUCCESSFUL,
  62.                         $change['new']['name']
  63.                     );
  64.                 }
  65.             }
  66.         }
  67.     }
  70.     public function onCommitStatusChanged(EventBase $event): void
  71.     {
  72.         $repository = $event->getData()->getRepository();
  73.         $commitStatus = $event->getData()->getCommitStatus();
  75.         if (
  76.             !empty($repository['project']['name']) &&
  77.             !empty($repository['name']) &&
  78.             !empty($commitStatus['refname']) &&
  79.             !empty($commitStatus['name']) &&
  80.             !empty($commitStatus['state'])
  81.         ) {
  82.             $this->sendDiscordNotification(
  83.                 $repository['project']['name'],
  84.                 $repository['name'],
  85.                 $commitStatus['refname'],
  86.                 $commitStatus['name'],
  87.                 $commitStatus['state']
  88.             );
  89.         }
  90.     }
  92.     private function isAcceptableBranch(string $branch): bool
  93.     {
  94.         return $branch === "master" || preg_match('/^v\d+\.x$/',$branch);
  95.     }
  97.     private function sendDiscordNotification(string $project, string $repository, ?string $branch, string $status, string $state): void
  98.     {
  99.         if ( $branch === null || $this->isAcceptableBranch($branch) ) {
  100.             $message = ':bulb: ';
  101.             if ( $state === self::COMMIT_STATUS_SUCCESSFUL ) {
  102.                 $message .= ':white_check_mark: ';
  103.             }
  104.             elseif ( $state === self::COMMIT_STATUS_FAILED ) {
  105.                 $message .= ':no_entry_sign: ';
  106.             }
  107.             else {
  108.                 $message .= ':information_source: ';
  109.             }
  111.             $message .= '**' . $project . ' / ' . $repository . ':** '.$status.' `'.$state.'`';
  112.             $this->discordMessageService->send($message);
  113.         }
  114.     }
  117. }