Handling SQS events example

bref.php

<?php

define('LARAVEL_START', microtime(true));

require __DIR__.'/vendor/autoload.php';

$app = require_once __DIR__ . '/bootstrap/app.php';

// Laravel does not create that directory automatically so we have to create it
// You can remove this if you do not use views in your application (e.g. for an API)
if (!is_dir(storage_path('framework/views'))) {
    if (!mkdir(storage_path('framework/views'), 0755, true)) {
        throw new \RuntimeException('Cannot create directory ' . storage_path('framework/views'));
    }
}

$bref = new \Bref\Application;

$bref->httpHandler($app->getBrefHttpAdapter());

$non_http_events_handler = function (array $event) use ($app) {

    $statuses = [];

    /**
     * Get the console kernel
     */
    $kernel = $app->make(\App\Console\Kernel::class);

    /**
     * Boot the kernel to make the container ready
     */
    $kernel->bootstrap();

    $container = resolve(\Psr\Container\ContainerInterface::class);

    /**
     * SQS events
     */
    foreach ($event['Records'] ?? [] as $record) {

        /**
         * Fire the job manually
         */
        $job = new \Illuminate\Queue\Jobs\SyncJob($container, $record['body'], 'sync', 'sync');

        $job->fire();

        $statuses[] = 1;
    }

    return [
        'statusCode' => 200,
        'headers'    => [
            'Content-Type'                     => 'application/json',
            'Access-Control-Allow-Origin'      => '*',
            'Access-Control-Allow-Credentials' => true,
        ],
        'body'       => ['message' => 'All good in the hood :)'],
        'status'     => $statuses,
    ];
};

$bref->simpleHandler($non_http_events_handler);

$bref->run();