QueueSpoolJob::execute()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 6
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 4
CRAP Score 1

Importance

Changes 0
Metric Value
cc 1
eloc 3
nc 1
nop 1
dl 0
loc 6
ccs 4
cts 4
cp 1
crap 1
rs 9.4285
c 0
b 0
f 0
1
<?php
2
/**
3
 * @link https://github.com/Izumi-kun/yii2-spoolmailer
4
 * @copyright Copyright (c) 2017 Viktor Khokhryakov
5
 * @license http://opensource.org/licenses/BSD-3-Clause
6
 */
7
8
namespace izumi\spoolmailer\spools;
9
10
use izumi\spoolmailer\ImportedMessage;
11
use Swift_Message;
12
use yii\base\BaseObject;
13
use yii\base\InvalidConfigException;
14
use yii\di\Instance;
15
use yii\mail\BaseMailer;
16
use yii\queue\JobInterface;
17
use yii\queue\Queue;
18
19
/**
20
 * Job for QueueSpool.
21
 *
22
 * @author Viktor Khokhryakov <[email protected]>
23
 */
24
class QueueSpoolJob extends BaseObject implements JobInterface
25
{
26
    /**
27
     * @var array|string the application component ID of the mailer object.
28
     */
29
    public $mailer = 'mailer';
30
    /**
31
     * @var Swift_Message
32
     */
33
    public $message;
34
35
    /**
36
     * @inheritdoc
37
     */
38 4
    public function init()
39
    {
40 4
        if (!$this->message instanceof Swift_Message) {
41 1
            throw new InvalidConfigException('The message should be an instance of "Swift_Message".');
42
        }
43 3
    }
44
45
    /**
46
     * @param Queue $queue which pushed and is handling the job
47
     * @throws InvalidConfigException
48
     */
49 1
    public function execute($queue)
50
    {
51
        /** @var BaseMailer $mailer */
52 1
        $mailer = Instance::ensure($this->mailer, BaseMailer::class);
53 1
        $message = new ImportedMessage($this->message);
54 1
        $mailer->send($message);
55 1
    }
56
}
57