1 | <?php |
||
10 | class StorableSender implements DelayedSenderInterface |
||
11 | { |
||
12 | /** |
||
13 | * @var RecordProvider |
||
14 | */ |
||
15 | protected $recordProvider; |
||
16 | |||
17 | /** |
||
18 | * @var SmsSenderInterface |
||
19 | */ |
||
20 | protected $sender; |
||
21 | |||
22 | /** |
||
23 | * @var Logger |
||
24 | */ |
||
25 | protected $logger; |
||
26 | |||
27 | public function __construct(RecordProvider $recordProvider, SmsSender $sender, Logger $logger = null) |
||
28 | { |
||
29 | $this->recordProvider = $recordProvider; |
||
30 | $this->sender = $sender; |
||
31 | $this->logger = $logger; |
||
32 | } |
||
33 | |||
34 | /** |
||
35 | * {@inheritDoc} |
||
36 | */ |
||
37 | public function flush() |
||
38 | { |
||
39 | if ($this->sender instanceof DelayedSenderInterface) { |
||
40 | list($sentMessages, $errors) = $this->sender->flush(); |
||
|
|||
41 | |||
42 | foreach ($errors as $error) { |
||
43 | $this->logger->logError($error, $this->getProviderClass()); |
||
44 | } |
||
45 | } |
||
46 | } |
||
47 | |||
48 | /** |
||
49 | * {@inheritdoc} |
||
50 | */ |
||
51 | public function send($recipient, $body, $originator = '') |
||
52 | { |
||
53 | $this->activateProvider(); |
||
54 | |||
55 | if ($this->logger) { |
||
56 | $time = microtime(true); |
||
57 | $result = $this->sender->send($recipient, $body, $originator); |
||
58 | $duration = microtime(true) - $time; |
||
59 | |||
60 | $this->logger->logMessage($result, $duration, $this->getProviderClass()); |
||
61 | } else { |
||
62 | $result = $this->sender->send($recipient, $body, $originator); |
||
63 | } |
||
64 | |||
65 | $this->recordProvider->storeResult($result); |
||
66 | |||
67 | return $result; |
||
68 | } |
||
69 | |||
70 | /** |
||
71 | * Activate default provider. |
||
72 | */ |
||
73 | public function activateProvider() |
||
74 | { |
||
75 | $provider = $this->recordProvider->getProvider()->getActivedProvider(); |
||
76 | $this->using($provider->getName()); |
||
77 | } |
||
78 | |||
79 | /** |
||
80 | * @param $name |
||
81 | * |
||
82 | * @return $this |
||
83 | */ |
||
84 | public function using($name) |
||
85 | { |
||
86 | $this->sender->using($name); |
||
87 | |||
88 | $pvd = $this->recordProvider->getProvider()->findByName($name); |
||
89 | $provider = $this->sender->getProvider(); |
||
90 | |||
91 | if ($provider instanceof ProviderInterface && $pvd) { |
||
92 | $provider->applyOptions($pvd->getParameters()); |
||
93 | } |
||
94 | |||
95 | return $this; |
||
96 | } |
||
97 | |||
98 | /** |
||
99 | * {@inheritdoc} |
||
100 | */ |
||
101 | public function acceptCallback($provider, array $response) |
||
102 | { |
||
103 | $provider = $this->using($provider)->sender->getProvider(); |
||
104 | |||
105 | if ($provider instanceof ProviderInterface) { |
||
106 | $provider->processCallback($response); |
||
107 | $provider->accept($this->recordProvider); |
||
108 | } |
||
109 | } |
||
110 | |||
111 | /** |
||
112 | * Allows to proxy method calls to the real SMS sender. |
||
113 | * |
||
114 | * @param $name |
||
115 | * @param $arguments |
||
116 | * |
||
117 | * @return StorableSender|SmsSenderInterface |
||
118 | */ |
||
119 | public function __call($name, $arguments) |
||
120 | { |
||
121 | if (is_callable(array($this->sender, $name))) { |
||
122 | $result = call_user_func_array(array($this->sender, $name), $arguments); |
||
123 | |||
124 | // don't break fluid interfaces |
||
125 | return $result instanceof SmsSenderInterface ? $this : $result; |
||
126 | } |
||
127 | } |
||
128 | |||
129 | /** |
||
130 | * @return null|string |
||
131 | */ |
||
132 | protected function getProviderClass() |
||
136 | } |
||
137 |
This checks looks for assignemnts to variables using the
list(...)
function, where not all assigned variables are subsequently used.Consider the following code example.
Only the variables
$a
and$c
are used. There was no need to assign$b
.Instead, the list call could have been.