Catch failed Integration

[Megafry]

Catch failed Integration
My customer needs to be notified immediately when an integration (e.g. HubSpot) fails.

Would adding an Event::on for yii\queue\Queue::EVENT_AFTER_ERROR be the right approach, or is there a specific event for integration failures?

Thanks for your help.

[engram-design]

Probably the best thing to check for, but we can also look at raising an error event on our end as well, which would work outside the queue.

[Megafry]

This would be great,
Can you provide the following information:

• JobId
• submission or submissionId
• integration
• integrationPayload
• error
• Pushed at
• Updated at
• Failed at

With this information, I can then check which integration failed and send an email to the right person.

[Megafry]

I noticed that you've already written a plugin for something similar.
My workaround for now:

Event::on(Queue::class, Queue::EVENT_AFTER_ERROR, function (ExecEvent $event) {
    QueueServices::sendFailedJobEmail($event);
});

<?php

namespace modules\ExtendFormie\services;

use Craft;
use craft\base\Component;
use verbb\formie\jobs\TriggerIntegration;
use verbb\formie\integrations\crm\HubSpot;
use verbb\formie\integrations\crm\HubSpotLegacy;

use yii\queue\ExecEvent;

class QueueServices extends Component
{
    // Public Methods
    // =========================================================================

    public static function sendFailedJobEmail(ExecEvent $event): void
    {
        // Only send on first attempt, else we just get hassled
        if ((int)$event->attempt !== 1) {
            return;
        }

        // only for formie 
        if (! $event->job instanceof TriggerIntegration) {
            return;
        }

        // only for specific integration
        $shouldSend = match (true) {
            $event->job->integration instanceof HubSpot,
            $event->job instanceof HubSpotLegacy => true,
            default => false,
        };

        if ($shouldSend === false) {
            return;
        }

        Craft::$app->getMailer()
            ->composeFromKey('extend_formie_failed_job')
            ->setTo('admin@test.com')
            ->send();
    }
}