1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
namespace Liip\ImagineBundle\Imagine\Cache\Resolver; |
4
|
|
|
|
5
|
|
|
use Liip\ImagineBundle\Binary\BinaryInterface; |
6
|
|
|
use Liip\ImagineBundle\Exception\Imagine\Cache\Resolver\NotStorableException; |
7
|
|
|
use Psr\Log\LoggerInterface; |
8
|
|
|
|
9
|
|
|
class AmazonS3Resolver implements ResolverInterface |
10
|
|
|
{ |
11
|
|
|
/** |
12
|
|
|
* @var \AmazonS3 |
13
|
|
|
*/ |
14
|
|
|
protected $storage; |
15
|
|
|
|
16
|
|
|
/** |
17
|
|
|
* @var string |
18
|
|
|
*/ |
19
|
|
|
protected $bucket; |
20
|
|
|
|
21
|
|
|
/** |
22
|
|
|
* @var string |
23
|
|
|
*/ |
24
|
|
|
protected $acl; |
25
|
|
|
|
26
|
|
|
/** |
27
|
|
|
* @var array |
28
|
|
|
*/ |
29
|
|
|
protected $objUrlOptions; |
30
|
|
|
|
31
|
|
|
/** |
32
|
|
|
* @var LoggerInterface |
33
|
|
|
*/ |
34
|
|
|
protected $logger; |
35
|
|
|
|
36
|
|
|
/** |
37
|
|
|
* Constructs a cache resolver storing images on Amazon S3. |
38
|
|
|
* |
39
|
|
|
* @param \AmazonS3 $storage The Amazon S3 storage API. It's required to know authentication information. |
40
|
|
|
* @param string $bucket The bucket name to operate on. |
41
|
|
|
* @param string $acl The ACL to use when storing new objects. Default: owner read/write, public read |
42
|
|
|
* @param array $objUrlOptions A list of options to be passed when retrieving the object url from Amazon S3. |
43
|
|
|
*/ |
44
|
|
|
public function __construct(\AmazonS3 $storage, $bucket, $acl = \AmazonS3::ACL_PUBLIC, array $objUrlOptions = array()) |
45
|
|
|
{ |
46
|
|
|
$this->storage = $storage; |
47
|
|
|
$this->bucket = $bucket; |
48
|
|
|
$this->acl = $acl; |
49
|
|
|
$this->objUrlOptions = $objUrlOptions; |
50
|
|
|
} |
51
|
|
|
|
52
|
|
|
/** |
53
|
|
|
* @param LoggerInterface $logger |
54
|
|
|
*/ |
55
|
|
|
public function setLogger(LoggerInterface $logger) |
56
|
|
|
{ |
57
|
|
|
$this->logger = $logger; |
58
|
|
|
} |
59
|
|
|
|
60
|
|
|
/** |
61
|
|
|
* {@inheritdoc} |
62
|
|
|
*/ |
63
|
|
|
public function isStored($path, $filter) |
64
|
|
|
{ |
65
|
|
|
return $this->objectExists($this->getObjectPath($path, $filter)); |
66
|
|
|
} |
67
|
|
|
|
68
|
|
|
/** |
69
|
|
|
* {@inheritdoc} |
70
|
|
|
*/ |
71
|
|
|
public function resolve($path, $filter) |
72
|
|
|
{ |
73
|
|
|
return $this->getObjectUrl($this->getObjectPath($path, $filter)); |
|
|
|
|
74
|
|
|
} |
75
|
|
|
|
76
|
|
|
/** |
77
|
|
|
* {@inheritdoc} |
78
|
|
|
*/ |
79
|
|
|
public function store(BinaryInterface $binary, $path, $filter) |
80
|
|
|
{ |
81
|
|
|
$objectPath = $this->getObjectPath($path, $filter); |
82
|
|
|
|
83
|
|
|
$storageResponse = $this->storage->create_object($this->bucket, $objectPath, array( |
84
|
|
|
'body' => $binary->getContent(), |
85
|
|
|
'contentType' => $binary->getMimeType(), |
86
|
|
|
'length' => strlen($binary->getContent()), |
87
|
|
|
'acl' => $this->acl, |
88
|
|
|
)); |
89
|
|
|
|
90
|
|
|
if (!$storageResponse->isOK()) { |
91
|
|
|
$this->logError('The object could not be created on Amazon S3.', array( |
92
|
|
|
'objectPath' => $objectPath, |
93
|
|
|
'filter' => $filter, |
94
|
|
|
's3_response' => $storageResponse, |
95
|
|
|
)); |
96
|
|
|
|
97
|
|
|
throw new NotStorableException('The object could not be created on Amazon S3.'); |
98
|
|
|
} |
99
|
|
|
} |
100
|
|
|
|
101
|
|
|
/** |
102
|
|
|
* {@inheritdoc} |
103
|
|
|
*/ |
104
|
|
|
public function remove(array $paths, array $filters) |
105
|
|
|
{ |
106
|
|
|
if (empty($paths) && empty($filters)) { |
107
|
|
|
return; |
108
|
|
|
} |
109
|
|
|
|
110
|
|
|
if (empty($paths)) { |
111
|
|
|
if (!$this->storage->delete_all_objects($this->bucket, sprintf('/%s/i', implode('|', $filters)))) { |
112
|
|
|
$this->logError('The objects could not be deleted from Amazon S3.', array( |
113
|
|
|
'filters' => implode(', ', $filters), |
114
|
|
|
'bucket' => $this->bucket, |
115
|
|
|
)); |
116
|
|
|
} |
117
|
|
|
|
118
|
|
|
return; |
119
|
|
|
} |
120
|
|
|
|
121
|
|
|
foreach ($filters as $filter) { |
122
|
|
|
foreach ($paths as $path) { |
123
|
|
|
$objectPath = $this->getObjectPath($path, $filter); |
124
|
|
|
if (!$this->objectExists($objectPath)) { |
|
|
|
|
125
|
|
|
continue; |
126
|
|
|
} |
127
|
|
|
|
128
|
|
|
if (!$this->storage->delete_object($this->bucket, $objectPath)->isOK()) { |
129
|
|
|
$this->logError('The objects could not be deleted from Amazon S3.', array( |
130
|
|
|
'filter' => $filter, |
131
|
|
|
'bucket' => $this->bucket, |
132
|
|
|
'path' => $path, |
133
|
|
|
)); |
134
|
|
|
} |
135
|
|
|
} |
136
|
|
|
} |
137
|
|
|
} |
138
|
|
|
|
139
|
|
|
/** |
140
|
|
|
* Sets a single option to be passed when retrieving an objects URL. |
141
|
|
|
* |
142
|
|
|
* If the option is already set, it will be overwritten. |
143
|
|
|
* |
144
|
|
|
* @see \AmazonS3::get_object_url() for available options. |
145
|
|
|
* |
146
|
|
|
* @param string $key The name of the option. |
147
|
|
|
* @param mixed $value The value to be set. |
148
|
|
|
* |
149
|
|
|
* @return AmazonS3Resolver $this |
150
|
|
|
*/ |
151
|
|
|
public function setObjectUrlOption($key, $value) |
152
|
|
|
{ |
153
|
|
|
$this->objUrlOptions[$key] = $value; |
154
|
|
|
|
155
|
|
|
return $this; |
156
|
|
|
} |
157
|
|
|
|
158
|
|
|
/** |
159
|
|
|
* Returns the object path within the bucket. |
160
|
|
|
* |
161
|
|
|
* @param string $path The base path of the resource. |
162
|
|
|
* @param string $filter The name of the imagine filter in effect. |
163
|
|
|
* |
164
|
|
|
* @return string The path of the object on S3. |
165
|
|
|
*/ |
166
|
|
|
protected function getObjectPath($path, $filter) |
167
|
|
|
{ |
168
|
|
|
return str_replace('//', '/', $filter.'/'.$path); |
169
|
|
|
} |
170
|
|
|
|
171
|
|
|
/** |
172
|
|
|
* Returns the URL for an object saved on Amazon S3. |
173
|
|
|
* |
174
|
|
|
* @param string $path |
175
|
|
|
* |
176
|
|
|
* @return string |
177
|
|
|
*/ |
178
|
|
|
protected function getObjectUrl($path) |
179
|
|
|
{ |
180
|
|
|
return $this->storage->get_object_url($this->bucket, $path, 0, $this->objUrlOptions); |
181
|
|
|
} |
182
|
|
|
|
183
|
|
|
/** |
184
|
|
|
* Checks whether an object exists. |
185
|
|
|
* |
186
|
|
|
* @param string $objectPath |
187
|
|
|
* |
188
|
|
|
* @return bool |
189
|
|
|
*/ |
190
|
|
|
protected function objectExists($objectPath) |
191
|
|
|
{ |
192
|
|
|
return $this->storage->if_object_exists($this->bucket, $objectPath); |
193
|
|
|
} |
194
|
|
|
|
195
|
|
|
/** |
196
|
|
|
* @param mixed $message |
197
|
|
|
* @param array $context |
198
|
|
|
*/ |
199
|
|
|
protected function logError($message, array $context = array()) |
200
|
|
|
{ |
201
|
|
|
if ($this->logger) { |
202
|
|
|
$this->logger->error($message, $context); |
203
|
|
|
} |
204
|
|
|
} |
205
|
|
|
} |
206
|
|
|
|
If you return a value from a function or method, it should be a sub-type of the type that is given by the parent type f.e. an interface, or abstract method. This is more formally defined by the Lizkov substitution principle, and guarantees that classes that depend on the parent type can use any instance of a child type interchangably. This principle also belongs to the SOLID principles for object oriented design.
Let’s take a look at an example:
Our function
my_function
expects aPost
object, and outputs the author of the post. The base classPost
returns a simple string and outputting a simple string will work just fine. However, the child classBlogPost
which is a sub-type ofPost
instead decided to return anobject
, and is therefore violating the SOLID principles. If aBlogPost
were passed tomy_function
, PHP would not complain, but ultimately fail when executing thestrtoupper
call in its body.