Merge pull request #1707 from bakaphp/feat-zoho-lead-reciever-job

Merge pull request #1655 from bakaphp/hotfix-zoho-lead

src/Domains/Connectors/Zoho/Jobs/SyncZohoLeadFromReceiverJob.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Kanvas\Connectors\Zoho\Jobs;
+
+use Kanvas\Connectors\Zoho\Actions\SyncZohoLeadAction;
+use Kanvas\Guild\Leads\Models\LeadReceiver;
+use Kanvas\Workflow\Jobs\ProcessWebhookJob;
+
+class SyncZohoLeadFromReceiverJob extends ProcessWebhookJob
+{
+    public function execute(): array
+    {
+        $zohoLeadId = $this->webhookRequest->payload['entity_id'] ?? null;
+        $leadReceiver = LeadReceiver::getByIdFromCompanyApp(
+            $this->receiver->configuration['receiver_id'],
+            $this->receiver->company,
+            $this->receiver->app
+        );
+
+        if (! $zohoLeadId) {
+            return [
+                'message' => 'Zoho Lead ID not found',
+            ];
+        }
+
+        $syncLead = new SyncZohoLeadAction(
+            $this->receiver->app,
+            $this->receiver->company,
+            $leadReceiver,
+            $zohoLeadId
+        );
+
+        $lead = $syncLead->execute();
+
+        return [
+            'message' => 'Lead created successfully via receiver ' . $leadReceiver->uuid,
+            'receiver' => $leadReceiver->getId(),
+            'lead' => $lead->getId(),
+        ];
+    }
+}