13644536682

Committed 04 Mar 2025 01:54AM UTC coverage: 100.0%. Remained the same

Build # 13644536682

Build Type

push

github

Committed by

web-flow

Commit Message

Update phpunit.xml

Run Details

148 of 148 relevant lines covered (100.0%)

93.62 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

100.0

/src/ApplyingJobInitialization.php

<?php

namespace Mpyw\LaravelCachedDatabaseStickiness;

use Illuminate\Database\ConnectionInterface;
use Illuminate\Database\DatabaseManager;
use Illuminate\Queue\Events\JobProcessing;
use Mpyw\LaravelCachedDatabaseStickiness\Events\ConnectionCreated;
use Mpyw\LaravelCachedDatabaseStickiness\JobInitializers\JobInitializerInterface;

class ApplyingJobInitialization
{
    /**
     * @var \Mpyw\LaravelCachedDatabaseStickiness\StickinessManager
     */
    protected $stickiness;

    /**
     * @var \Illuminate\Database\DatabaseManager
     */
    protected $db;

    /**
     * @var \Mpyw\LaravelCachedDatabaseStickiness\JobInitializers\JobInitializerInterface
     */
    protected $job;

    /**
     * @var bool[]
     */
    protected $recordsModifiedStates = [];

    /**
     * ApplyingJobInitialization constructor.
     *
     * @param \Mpyw\LaravelCachedDatabaseStickiness\StickinessManager                       $stickiness
     * @param \Illuminate\Database\DatabaseManager                                          $db
     * @param \Mpyw\LaravelCachedDatabaseStickiness\JobInitializers\JobInitializerInterface $initializer
     */
    public function __construct(StickinessManager $stickiness, DatabaseManager $db, JobInitializerInterface $initializer)
    {
        $this->stickiness = $stickiness;
        $this->db = $db;
        $this->job = $initializer;
    }

    /**
     * Initialize database stickiness state on already resolved connections before processing each job.
     *
     * @param  \Illuminate\Queue\Events\JobProcessing $event
     * @return $this
     */
    public function initializeOnResolvedConnections(JobProcessing $event)
    {
        foreach ($this->db->getConnections() as $connection) {
            /* @var \Illuminate\Database\Connection|\Illuminate\Database\ConnectionInterface $connection */
            $this->recordsModifiedStates[$connection->getName()] = $connection->hasModifiedRecords();
        }

        $this->job->initializeOnResolvedConnections($event);

        return $this;
    }

    /**
     * Initialize database stickiness state on newly created connection before processing each job.
     *
     * @param  \Illuminate\Queue\Events\JobProcessing                         $jobProcessingEvent
     * @param  \Mpyw\LaravelCachedDatabaseStickiness\Events\ConnectionCreated $connectionCreatedEvent
     * @return $this
     */
    public function initializeOnNewConnection(JobProcessing $jobProcessingEvent, ConnectionCreated $connectionCreatedEvent)
    {
        $connection = $connectionCreatedEvent->connection;

        $this->recordsModifiedStates[$connection->getName()] = $connection->hasModifiedRecords();

        $this->job->initializeOnNewConnection($jobProcessingEvent, $connectionCreatedEvent);

        return $this;
    }

    /**
     * Avoid revoking stickiness state initialization when DB::recordsHaveBeenModified() called on the Job execution.
     *
     * @param  \Illuminate\Database\Connection|\Illuminate\Database\ConnectionInterface $connection
     * @return $this
     */
    public function dontRevokeEffectsOn(ConnectionInterface $connection)
    {
        unset($this->recordsModifiedStates[$connection->getName()]);

        return $this;
    }

    /**
     * Revoke database stickiness state initialization after processing each job.
     */
    public function __destruct()
    {
        foreach ($this->db->getConnections() as $connection) {
            /* @var \Illuminate\Database\Connection|\Illuminate\Database\ConnectionInterface $connection */
            if (null !== $state = $this->recordsModifiedStates[$connection->getName()] ?? null) {
                $connection->setRecordModificationState($state);
            }
        }
    }
}

1	<?php
2
3	namespace Mpyw\LaravelCachedDatabaseStickiness;
4
5	use Illuminate\Database\ConnectionInterface;
6	use Illuminate\Database\DatabaseManager;
7	use Illuminate\Queue\Events\JobProcessing;
8	use Mpyw\LaravelCachedDatabaseStickiness\Events\ConnectionCreated;
9	use Mpyw\LaravelCachedDatabaseStickiness\JobInitializers\JobInitializerInterface;
10
11	class ApplyingJobInitialization
12	{
13	/**
14	* @var \Mpyw\LaravelCachedDatabaseStickiness\StickinessManager
15	*/
16	protected $stickiness;
17
18	/**
19	* @var \Illuminate\Database\DatabaseManager
20	*/
21	protected $db;
22
23	/**
24	* @var \Mpyw\LaravelCachedDatabaseStickiness\JobInitializers\JobInitializerInterface
25	*/
26	protected $job;
27
28	/**
29	* @var bool[]
30	*/
31	protected $recordsModifiedStates = [];
32
33	/**
34	* ApplyingJobInitialization constructor.
35	*
36	* @param \Mpyw\LaravelCachedDatabaseStickiness\StickinessManager $stickiness
37	* @param \Illuminate\Database\DatabaseManager $db
38	* @param \Mpyw\LaravelCachedDatabaseStickiness\JobInitializers\JobInitializerInterface $initializer
39	*/
40	public function __construct(StickinessManager $stickiness, DatabaseManager $db, JobInitializerInterface $initializer)
41	{
42	$this->stickiness = $stickiness;	80✔
43	$this->db = $db;	80✔
44	$this->job = $initializer;	80✔
45	}
46
47	/**
48	* Initialize database stickiness state on already resolved connections before processing each job.
49	*
50	* @param \Illuminate\Queue\Events\JobProcessing $event
51	* @return $this
52	*/
53	public function initializeOnResolvedConnections(JobProcessing $event)
54	{
55	foreach ($this->db->getConnections() as $connection) {	56✔
56	/* @var \Illuminate\Database\Connection\|\Illuminate\Database\ConnectionInterface $connection */
57	$this->recordsModifiedStates[$connection->getName()] = $connection->hasModifiedRecords();	40✔
58	}
59
60	$this->job->initializeOnResolvedConnections($event);	56✔
61
62	return $this;	56✔
63	}
64
65	/**
66	* Initialize database stickiness state on newly created connection before processing each job.
67	*
68	* @param \Illuminate\Queue\Events\JobProcessing $jobProcessingEvent
69	* @param \Mpyw\LaravelCachedDatabaseStickiness\Events\ConnectionCreated $connectionCreatedEvent
70	* @return $this
71	*/
72	public function initializeOnNewConnection(JobProcessing $jobProcessingEvent, ConnectionCreated $connectionCreatedEvent)
73	{
74	$connection = $connectionCreatedEvent->connection;	24✔
75
76	$this->recordsModifiedStates[$connection->getName()] = $connection->hasModifiedRecords();	24✔
77
78	$this->job->initializeOnNewConnection($jobProcessingEvent, $connectionCreatedEvent);	24✔
79
80	return $this;	24✔
81	}
82
83	/**
84	* Avoid revoking stickiness state initialization when DB::recordsHaveBeenModified() called on the Job execution.
85	*
86	* @param \Illuminate\Database\Connection\|\Illuminate\Database\ConnectionInterface $connection
87	* @return $this
88	*/
89	public function dontRevokeEffectsOn(ConnectionInterface $connection)
90	{
91	unset($this->recordsModifiedStates[$connection->getName()]);	16✔
92
93	return $this;	16✔
94	}
95
96	/**
97	* Revoke database stickiness state initialization after processing each job.
98	*/
99	public function __destruct()
100	{
101	foreach ($this->db->getConnections() as $connection) {	56✔
102	/* @var \Illuminate\Database\Connection\|\Illuminate\Database\ConnectionInterface $connection */
103	if (null !== $state = $this->recordsModifiedStates[$connection->getName()] ?? null) {	56✔
104	$connection->setRecordModificationState($state);	48✔
105	}
106	}
107	}
108	}

mpyw / laravel-cached-database-stickiness / 13644536682

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous