File Coverage

blib/lib/Cloudinary.pm
Criterion Covered Total %
statement 61 64 95.3
branch 26 32 81.2
condition 16 28 57.1
subroutine 11 11 100.0
pod 3 3 100.0
total 117 138 84.7


line stmt bran cond sub pod time code
1             package Cloudinary;
2 4     4   350904 use Mojo::Base -base;
  4         5  
  4         21  
3 4     4   398 use File::Basename;
  4         4  
  4         177  
4 4     4   13 use Mojo::UserAgent;
  4         6  
  4         15  
5 4     4   113 use Mojo::Util qw(sha1_sum url_escape);
  4         5  
  4         154  
6 4     4   14 use Scalar::Util 'weaken';
  4         5  
  4         4020  
7              
8             our $VERSION = '0.15';
9             our (%SHORTER, %LONGER);
10             my @SIGNATURE_KEYS = qw(callback eager format public_id tags timestamp transformation type);
11              
12             {
13             %LONGER = (
14             a => 'angle',
15             b => 'background',
16             c => 'crop',
17             d => 'default_image',
18             e => 'effect',
19             f => 'fetch_format',
20             g => 'gravity',
21             h => 'height',
22             l => 'overlay',
23             p => 'prefix',
24             q => 'quality',
25             r => 'radius',
26             t => 'named_transformation',
27             w => 'width',
28             x => 'x',
29             y => 'y',
30             );
31             %SHORTER = reverse %LONGER;
32             }
33              
34             has cloud_name => sub { die 'cloud_name is required in constructor' };
35             has api_key => sub { die 'api_key is required in constructor' };
36             has api_secret => sub { die 'api_secret is required in constructor' };
37             has private_cdn => sub { die 'private_cdn is required in constructor' };
38             has _api_url => 'http://api.cloudinary.com/v1_1';
39             has _public_cdn => 'http://res.cloudinary.com';
40             has _ua => sub {
41             my $ua = Mojo::UserAgent->new;
42              
43             $ua->on(
44             start => sub {
45             my ($ua, $tx) = @_;
46              
47             for my $part (@{$tx->req->content->parts}) {
48             my $content_type = $part->headers->content_type || '';
49             $part->headers->remove('Content-Type') if $content_type eq 'text/plain';
50             }
51             }
52             );
53              
54             return $ua;
55             };
56              
57             sub upload {
58 7     7 1 1919 my ($self, $args, $cb) = @_;
59              
60             # TODO: transformation, eager
61 7 100       25 $args = {file => $args} if ref $args ne 'HASH';
62 7   50     35 $args->{resource_type} ||= 'image';
63 7   66     22 $args->{timestamp} ||= time;
64              
65 7 100       25 die "Usage: \$self->upload({ file => ... })" unless defined $args->{file};
66              
67 6 50       14 if (ref $args->{tags} eq 'ARRAY') {
68 0         0 $args->{tags} = join ',', @{$args->{tags}};
  0         0  
69             }
70 6 100       29 if (UNIVERSAL::isa($args->{file}, 'Mojo::Asset')) {
    50          
71             $args->{file}
72 4   33     20 = {file => $args->{file}, filename => $args->{filename} || basename($args->{file}->path)};
73             }
74             elsif (UNIVERSAL::isa($args->{file}, 'Mojo::Upload')) {
75 0         0 $args->{file} = {file => $args->{file}->asset, filename => $args->{file}->filename};
76             }
77              
78             $self->_call_api(
79             upload => $args,
80             {
81             timestamp => time,
82 9         31 (map { ($_, $args->{$_}) } grep { defined $args->{$_} } @SIGNATURE_KEYS),
  48         50  
83             file => $args->{file},
84             },
85 6         147 $cb,
86             );
87             }
88              
89             sub destroy {
90 3     3 1 1135 my ($self, $args, $cb) = @_;
91              
92 3 100       16 $args = {public_id => $args} unless ref $args eq 'HASH';
93              
94 3 100       22 die "Usage: \$self->destroy({ public_id => ... })" unless defined $args->{public_id};
95              
96 2   50     13 $args->{resource_type} ||= 'image';
97              
98             $self->_call_api(
99             destroy => $args,
100             {
101             public_id => $args->{public_id},
102             timestamp => $args->{timestamp} || time,
103 2   66     23 type => $args->{type} || 'upload',
      50        
104             },
105             $cb,
106             );
107             }
108              
109             sub _call_api {
110 8     8   12 my ($self, $action, $args, $post, $cb) = @_;
111 8         21 my $url = join '/', $self->_api_url, $self->cloud_name, $args->{resource_type}, $action;
112 8         70 my $headers = {'Content-Type' => 'multipart/form-data'};
113              
114 8         18 $post->{api_key} = $self->api_key;
115 8         37 $post->{signature} = $self->_api_sign_request($post);
116              
117 8         17 Scalar::Util::weaken($self);
118             my $tx = $self->_ua->post(
119             $url, $headers,
120             form => $post,
121 8 100 50 2   19 $cb ? sub { $self->$cb($_[1]->res->json || {error => $_[1]->error || 'Unknown error'}) } : (),
  2         20095  
122             );
123              
124 8 100       89726 return $self if $cb; # non-blocking
125 6         17 my $res = $tx->error;
126 6 50 0     74 die $res->{message} || 'Unknown error' if $res;
127 6         11 $res = $tx->res->json;
128 6 100       473 die $res->{error} if $res->{error};
129 5         29 return $res;
130             }
131              
132             sub _api_sign_request {
133 10     10   594 my ($self, $args) = @_;
134 10         11 my @query;
135              
136 10         13 for my $k (@SIGNATURE_KEYS) {
137 80 100       368 push @query, "$k=" . url_escape($args->{$k}, '^A-Za-z0-9\-._~\/') if defined $args->{$k};
138             }
139              
140 10         36 $query[-1] .= $self->api_secret;
141              
142 10         118 sha1_sum join '&', @query;
143             }
144              
145             sub url_for {
146 6     6 1 13 my $self = shift;
147 6 50       15 my $public_id = shift or die 'Usage: $self->url_for($public_id, ...)';
148 6   100     16 my $args = shift || {};
149 6 100       27 my $format = $public_id =~ s/\.(\w+)// ? $1 : 'jpg';
150 6 50       25 my $url = Mojo::URL->new(delete $args->{secure} ? $self->private_cdn : $self->_public_cdn);
151              
152             $url->path(
153             join '/',
154 30         77 grep {length} $self->cloud_name,
155             $args->{resource_type} || 'image',
156             $args->{type} || 'upload',
157             join(',',
158 6   66     25 map { ($SHORTER{$_} || $_) . '_' . $args->{$_} }
159 6 50 50     695 grep { $_ ne 'resource_type' and $_ ne 'type' } sort keys %$args),
  7   100     55  
160             "$public_id.$format",
161             );
162              
163 6         385 return $url;
164             }
165              
166             1;
167              
168             =encoding utf8
169              
170             =head1 NAME
171              
172             Cloudinary - Talk with cloudinary.com
173              
174             =head1 VERSION
175              
176             0.15
177              
178             =head1 DESCRIPTION
179              
180             This module lets you interface to L.
181              
182             =head1 SYNOPSIS
183              
184             =head2 Standalone
185              
186             my $delay = Mojo::IOLoop->delay;
187             my $cloudinary = Cloudinary->new(cloud_name => "a", api_key => "b", api_secret => "c");
188              
189             $delay->begin;
190             $cloudinary->upload({file => {file => $path_to_file}}, sub {
191             my ($cloudinary, $res) = @_;
192             # ...
193             $delay->end;
194             },
195             });
196              
197             # let's you do multiple upload() in parallel
198             # just call $delay->begin once pr upload()
199             # and $delay->end in each callback given to upload()
200             $delay->wait;
201              
202             =head2 With mojolicious
203              
204             See L.
205              
206             =head2 Options
207              
208             As from 0.04 all methods support the short and long option, meaning
209             the examples below work the same:
210              
211             $self->url_for('billclinton.jpg' => { w => 50 });
212             $self->url_for('billclinton.jpg' => { width => 50 });
213              
214             =head2 url_for() examples
215              
216             $cloudinary->url_for('billclinton.jpg', { type => 'facebook' });
217             $cloudinary->url_for('billclinton.jpg', { type => 'twitter_name', h => 70, w => 100 });
218             $cloudinary->url_for('18913373.jpg', { type => 'twitter_name' });
219             $cloudinary->url_for('my-uploaded-image.jpg', { h => 50, w => 50 });
220             $cloudinary->url_for('myrawid', { resource_type => 'raw' });
221              
222             =head2 Aliases
223              
224             This module provides alias for the Cloudinary transformations:
225              
226             a = angle
227             b = background
228             c = crop
229             d = default_image
230             e = effect
231             f = fetch_format
232             g = gravity
233             h = height
234             l = overlay
235             p = prefix
236             q = quality
237             r = radius
238             t = named_transformation
239             w = width
240             x = x
241             y = y
242              
243             =head1 ATTRIBUTES
244              
245             =head2 cloud_name
246              
247             Your cloud name from L
248              
249             =head2 api_key
250              
251             Your API key from L
252              
253             =head2 api_secret
254              
255             Your API secret from L
256              
257             =head2 private_cdn
258              
259             Your private CDN url from L.
260              
261             =head1 METHODS
262              
263             =head2 upload
264              
265             $self->upload(
266             {
267             file => $binary_str | $url, # required
268             format => $str, # optional
269             public_id => $str, # optional
270             resource_type => $str, # image or raw. defaults to "image"
271             tags => ['foo', 'bar'], # optional
272             timestamp => $epoch, # time()
273             },
274             sub { my ($cloudinary, $res) = @_ }
275             );
276              
277             Will upload a file to L using the parameters given
278             L, L and L. C<$res> in the callback
279             will be the json response from cloudinary:
280              
281             {
282             url => $str,
283             secure_url => $str,
284             public_id => $str,
285             version => $str,
286             width => $int, # only for images
287             height => $int, # only for images
288             }
289              
290             C<$res> on error can be either C if there was an issue
291             connecting/communicating with cloudinary or a an error data structure:
292              
293             {error => {message: $str}}
294              
295             The C can be:
296              
297             =over 4
298              
299             =item * A hash
300              
301             { file => 'path/to/image' }
302              
303             =item * A L object.
304              
305             =item * A L object.
306              
307             =item * A URL
308              
309             =back
310              
311             C in callbacks will be the JSON response from L
312             as a hash ref. It may also be C if something went wrong with the
313             actual HTTP POST.
314              
315             See also L and
316             L.
317              
318             =head2 destroy
319              
320             $self->destroy(
321             {
322             public_id => $public_id,
323             resource_type => $str, # image or raw. defaults to "image"
324             },
325             sub { my ($cloudinary, $res) = @_; }
326             );
327              
328             Will delete an image from cloudinary, identified by C<$public_id>.
329             The callback will be called when the image got deleted or if an error occur.
330              
331             On error, look for:
332              
333             {error => {message: $str}}
334              
335             See also L.
336              
337             =head2 url_for
338              
339             $url_obj = $self->url_for("$public_id.$format", \%args);
340              
341             This method will return a public URL to the image at L.
342             It will use L or the public CDN and L to construct
343             the URL. The return value is a L object.
344              
345             Example C<%args>:
346              
347             {
348             h => 150, # height of image
349             w => 100, # width of image
350             resource_type => $str, # image or raw. defaults to "image"
351             secure => $bool, # use private_cdn or public cdn
352             type => $str, # upload, facebook. defaults to "upload"
353             }
354              
355             See also L
356             and L.
357              
358             =head1 COPYRIGHT & LICENSE
359              
360             This library is free software. You can redistribute it and/or
361             modify it under the same terms as Perl itself.
362              
363             =head1 AUTHOR
364              
365             Jan Henning Thorsen - jhthorsen@cpan.org
366              
367             =cut