feat: publish sponsor update domain event when company is updated

Author: smarcet

app/Jobs/CompanyEventJob.php

@@ -0,0 +1,68 @@
+<?php namespace App\Jobs;
+/*
+ * Copyright 2025 OpenStack Foundation
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ **/
+use App\Events\SponsorServices\SponsorDomainEvents;
+use App\Models\Foundation\Summit\Repositories\ISponsorRepository;
+use App\Services\Model\Imp\Factories\RabbitPublisherFactory;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Log;
+
+class CompanyEventJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public $tries = 5;
+
+    private $op;
+
+    private $company_id;
+
+    /**
+     * @param int $company_id
+     * @param string $op
+     */
+    public function __construct(int $company_id, string $op){
+        $this->op = $op;
+        $this->company_id = $company_id;
+        Log::debug(sprintf("CompanyEventJob::construct op %s company_id %s", $op, $this->company_id));
+    }
+
+    /**
+     * @param ISponsorRepository $sponsor_repository
+     * @return void
+     */
+    public function handle(ISponsorRepository $sponsor_repository){
+        Log::debug(sprintf("CompanyEventJob::handle op %s company_id %s", $this->op, $this->company_id));
+        $excerpt = $sponsor_repository->getSponsorsExcerptByCompanyID($this->company_id);
+        $domain_event_publisher_service = RabbitPublisherFactory::make('domain_events_message_broker');
+        Log::debug(sprintf("CompanyEventJob::handle excerpt %s", json_encode($excerpt)));
+        foreach($excerpt as $entry) {
+            $payload = [
+                'id' => intval($entry['sponsor_id'])
+            ];
+            $routing_key = $this->op == 'UPDATE' ? SponsorDomainEvents::SponsorUpdated : SponsorDomainEvents::SponsorDeleted;
+            $domain_event_publisher_service->publish($payload, $routing_key);
+        }
+    }
+
+
+    public function failed(\Throwable $e): void
+    {
+        Log::error("CompanyEventJob::failed {$e->getMessage()}");
+    }
+
+}

app/Jobs/SponsorServices/PublishSponsorServiceDomainEventsJob.php

@@ -44,8 +44,8 @@ public function handle(): void
     {
         try {
             Log::debug(sprintf("PublishSponsorServiceDomainEventsJob::handle payload %s event_type %s", json_encode($this->payload), $this->event_type));
-            $sponsor_services_publisher = RabbitPublisherFactory::make('domain_events_message_broker');
-            $sponsor_services_publisher->publish($this->payload, $this->event_type);
+            $domain_event_publisher_service = RabbitPublisherFactory::make('domain_events_message_broker');
+            $domain_event_publisher_service->publish($this->payload, $this->event_type);
         } catch (\Exception $ex) {
             Log::error($ex);
             throw $ex;

app/Models/Foundation/Summit/Repositories/ISponsorRepository.php

@@ -18,5 +18,9 @@
  */
 interface ISponsorRepository extends IBaseRepository
 {
-
+    /**
+     * @param int $company_id
+     * @return array
+     */
+    public function getSponsorsExcerptByCompanyID(int $company_id):array;
 }

app/Repositories/Summit/DoctrineSponsorRepository.php

@@ -11,13 +11,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  **/
+
 use App\Models\Foundation\Summit\Repositories\ISponsorRepository;
 use App\Repositories\SilverStripeDoctrineRepository;
+use Doctrine\DBAL\ParameterType;
 use Doctrine\ORM\QueryBuilder;
 use models\summit\Sponsor;
 use utils\DoctrineFilterMapping;
 use utils\DoctrineHavingFilterMapping;
-use utils\DoctrineJoinFilterMapping;
 use utils\DoctrineLeftJoinFilterMapping;
 use utils\Filter;
 use utils\Order;
@@ -99,4 +100,30 @@ protected function getBaseEntity()
     {
        return Sponsor::class;
     }
+
+    /**
+     * @param int $company_id
+     * @return array
+     */
+    public function getSponsorsExcerptByCompanyID(int $company_id):array{
+        try {
+            $sql = <<<SQL
+SELECT Sponsor.ID AS sponsor_id, Sponsor.SummitID as summit_id FROM Sponsor
+         WHERE Sponsor.CompanyID = :company_id
+SQL;
+
+            $bindings = ['company_id' => $company_id];
+            $types = [
+                'company_id'  => ParameterType::INTEGER
+            ];
+
+            $stm = $this->getEntityManager()->getConnection()->executeQuery($sql, $bindings, $types);
+
+            return $stm->fetchAllAssociative();
+
+        } catch (\Exception $ex) {
+
+        }
+        return [];
+    }
 }

app/Services/Model/Imp/CompanyService.php

@@ -12,6 +12,7 @@
  * limitations under the License.
  **/
 use App\Http\Utils\IFileUploader;
+use App\Jobs\CompanyEventJob;
 use App\Models\Foundation\Main\Factories\CompanyFactory;
 use App\Services\Model\AbstractService;
 use App\Services\Model\ICompanyService;
@@ -86,7 +87,7 @@ public function addCompany(array $payload): Company
      */
     public function updateCompany(int $company_id, array $payload): Company
     {
-        return $this->tx_service->transaction(function() use($company_id, $payload){
+        $company = $this->tx_service->transaction(function() use($company_id, $payload){
             $company = $this->repository->getById($company_id);
             if(is_null($company) || !$company instanceof Company)
                 throw new EntityNotFoundException(sprintf("company %s not found.", $company_id));
@@ -100,6 +101,8 @@ public function updateCompany(int $company_id, array $payload): Company
 
             return CompanyFactory::populate($company, $payload);
         });
+        CompanyEventJob::dispatch($company_id, "UPDATE");
+        return $company;
     }
 
     /**
@@ -113,7 +116,7 @@ public function deleteCompany(int $company_id): void
             $company = $this->repository->getById($company_id);
             if(is_null($company))
                 throw new EntityNotFoundException(sprintf("company %s not found.", $company_id));
-
+            CompanyEventJob::dispatch($company_id, "DELETE");
             $this->repository->delete($company);
         });
     }