← Back to branch summary

~saurabhanandiit/gtg/exportFixed

« back to all changes in this revision

Viewing changes to GTG/backends/tweepy/api.py

Merge of my work on liblarch newbase and all the backends ported to liblarch
(which mainly means porting the datastore).
One failing test, will check it.

Show diffs side-by-side

added added

removed removed

Lines of Context:
GTG/backends/tweepy/api.py
 
1
# Tweepy
 
2
# Copyright 2009-2010 Joshua Roesslein
 
3
# See LICENSE for details.
 
4
 
 
5
import os
 
6
import mimetypes
 
7
 
 
8
from tweepy.binder import bind_api
 
9
from tweepy.error import TweepError
 
10
from tweepy.parsers import ModelParser
 
11
from tweepy.utils import list_to_csv
 
12
 
 
13
 
 
14
class API(object):
 
15
    """Twitter API"""
 
16
 
 
17
    def __init__(self, auth_handler=None,
 
18
            host='api.twitter.com', search_host='search.twitter.com',
 
19
             cache=None, secure=False, api_root='/1', search_root='',
 
20
            retry_count=0, retry_delay=0, retry_errors=None,
 
21
            parser=None):
 
22
        self.auth = auth_handler
 
23
        self.host = host
 
24
        self.search_host = search_host
 
25
        self.api_root = api_root
 
26
        self.search_root = search_root
 
27
        self.cache = cache
 
28
        self.secure = secure
 
29
        self.retry_count = retry_count
 
30
        self.retry_delay = retry_delay
 
31
        self.retry_errors = retry_errors
 
32
        self.parser = parser or ModelParser()
 
33
 
 
34
    """ statuses/public_timeline """
 
35
    public_timeline = bind_api(
 
36
        path = '/statuses/public_timeline.json',
 
37
        payload_type = 'status', payload_list = True,
 
38
        allowed_param = []
 
39
    )
 
40
 
 
41
    """ statuses/home_timeline """
 
42
    home_timeline = bind_api(
 
43
        path = '/statuses/home_timeline.json',
 
44
        payload_type = 'status', payload_list = True,
 
45
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
46
        require_auth = True
 
47
    )
 
48
 
 
49
    """ statuses/friends_timeline """
 
50
    friends_timeline = bind_api(
 
51
        path = '/statuses/friends_timeline.json',
 
52
        payload_type = 'status', payload_list = True,
 
53
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
54
        require_auth = True
 
55
    )
 
56
 
 
57
    """ statuses/user_timeline """
 
58
    user_timeline = bind_api(
 
59
        path = '/statuses/user_timeline.json',
 
60
        payload_type = 'status', payload_list = True,
 
61
        allowed_param = ['id', 'user_id', 'screen_name', 'since_id',
 
62
                          'max_id', 'count', 'page']
 
63
    )
 
64
 
 
65
    """ statuses/mentions """
 
66
    mentions = bind_api(
 
67
        path = '/statuses/mentions.json',
 
68
        payload_type = 'status', payload_list = True,
 
69
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
70
        require_auth = True
 
71
    )
 
72
 
 
73
    """/statuses/:id/retweeted_by.format"""
 
74
    retweeted_by = bind_api(
 
75
        path = '/statuses/{id}/retweeted_by.json',
 
76
        payload_type = 'status', payload_list = True,
 
77
        allowed_param = ['id', 'count', 'page'],
 
78
        require_auth = True
 
79
    )
 
80
 
 
81
    """/statuses/:id/retweeted_by/ids.format"""
 
82
    retweeted_by_ids = bind_api(
 
83
        path = '/statuses/{id}/retweeted_by/ids.json',
 
84
        payload_type = 'ids',
 
85
        allowed_param = ['id', 'count', 'page'],
 
86
        require_auth = True
 
87
    )
 
88
 
 
89
    """ statuses/retweeted_by_me """
 
90
    retweeted_by_me = bind_api(
 
91
        path = '/statuses/retweeted_by_me.json',
 
92
        payload_type = 'status', payload_list = True,
 
93
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
94
        require_auth = True
 
95
    )
 
96
 
 
97
    """ statuses/retweeted_to_me """
 
98
    retweeted_to_me = bind_api(
 
99
        path = '/statuses/retweeted_to_me.json',
 
100
        payload_type = 'status', payload_list = True,
 
101
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
102
        require_auth = True
 
103
    )
 
104
 
 
105
    """ statuses/retweets_of_me """
 
106
    retweets_of_me = bind_api(
 
107
        path = '/statuses/retweets_of_me.json',
 
108
        payload_type = 'status', payload_list = True,
 
109
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
110
        require_auth = True
 
111
    )
 
112
 
 
113
    """ statuses/show """
 
114
    get_status = bind_api(
 
115
        path = '/statuses/show.json',
 
116
        payload_type = 'status',
 
117
        allowed_param = ['id']
 
118
    )
 
119
 
 
120
    """ statuses/update """
 
121
    update_status = bind_api(
 
122
        path = '/statuses/update.json',
 
123
        method = 'POST',
 
124
        payload_type = 'status',
 
125
        allowed_param = ['status', 'in_reply_to_status_id', 'lat', 'long', 'source', 'place_id'],
 
126
        require_auth = True
 
127
    )
 
128
 
 
129
    """ statuses/destroy """
 
130
    destroy_status = bind_api(
 
131
        path = '/statuses/destroy.json',
 
132
        method = 'DELETE',
 
133
        payload_type = 'status',
 
134
        allowed_param = ['id'],
 
135
        require_auth = True
 
136
    )
 
137
 
 
138
    """ statuses/retweet """
 
139
    retweet = bind_api(
 
140
        path = '/statuses/retweet/{id}.json',
 
141
        method = 'POST',
 
142
        payload_type = 'status',
 
143
        allowed_param = ['id'],
 
144
        require_auth = True
 
145
    )
 
146
 
 
147
    """ statuses/retweets """
 
148
    retweets = bind_api(
 
149
        path = '/statuses/retweets/{id}.json',
 
150
        payload_type = 'status', payload_list = True,
 
151
        allowed_param = ['id', 'count'],
 
152
        require_auth = True
 
153
    )
 
154
 
 
155
    """ users/show """
 
156
    get_user = bind_api(
 
157
        path = '/users/show.json',
 
158
        payload_type = 'user',
 
159
        allowed_param = ['id', 'user_id', 'screen_name']
 
160
    )
 
161
 
 
162
    """ Perform bulk look up of users from user ID or screenname """
 
163
    def lookup_users(self, user_ids=None, screen_names=None):
 
164
        return self._lookup_users(list_to_csv(user_ids), list_to_csv(screen_names))
 
165
 
 
166
    _lookup_users = bind_api(
 
167
        path = '/users/lookup.json',
 
168
        payload_type = 'user', payload_list = True,
 
169
        allowed_param = ['user_id', 'screen_name'],
 
170
        require_auth = True
 
171
    )
 
172
 
 
173
    """ Get the authenticated user """
 
174
    def me(self):
 
175
        return self.get_user(screen_name=self.auth.get_username())
 
176
 
 
177
    """ users/search """
 
178
    search_users = bind_api(
 
179
        path = '/users/search.json',
 
180
        payload_type = 'user', payload_list = True,
 
181
        require_auth = True,
 
182
        allowed_param = ['q', 'per_page', 'page']
 
183
    )
 
184
 
 
185
    """ statuses/friends """
 
186
    friends = bind_api(
 
187
        path = '/statuses/friends.json',
 
188
        payload_type = 'user', payload_list = True,
 
189
        allowed_param = ['id', 'user_id', 'screen_name', 'page', 'cursor']
 
190
    )
 
191
 
 
192
    """ statuses/followers """
 
193
    followers = bind_api(
 
194
        path = '/statuses/followers.json',
 
195
        payload_type = 'user', payload_list = True,
 
196
        allowed_param = ['id', 'user_id', 'screen_name', 'page', 'cursor']
 
197
    )
 
198
 
 
199
    """ direct_messages """
 
200
    direct_messages = bind_api(
 
201
        path = '/direct_messages.json',
 
202
        payload_type = 'direct_message', payload_list = True,
 
203
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
204
        require_auth = True
 
205
    )
 
206
 
 
207
    """ direct_messages/sent """
 
208
    sent_direct_messages = bind_api(
 
209
        path = '/direct_messages/sent.json',
 
210
        payload_type = 'direct_message', payload_list = True,
 
211
        allowed_param = ['since_id', 'max_id', 'count', 'page'],
 
212
        require_auth = True
 
213
    )
 
214
 
 
215
    """ direct_messages/new """
 
216
    send_direct_message = bind_api(
 
217
        path = '/direct_messages/new.json',
 
218
        method = 'POST',
 
219
        payload_type = 'direct_message',
 
220
        allowed_param = ['user', 'screen_name', 'user_id', 'text'],
 
221
        require_auth = True
 
222
    )
 
223
 
 
224
    """ direct_messages/destroy """
 
225
    destroy_direct_message = bind_api(
 
226
        path = '/direct_messages/destroy.json',
 
227
        method = 'DELETE',
 
228
        payload_type = 'direct_message',
 
229
        allowed_param = ['id'],
 
230
        require_auth = True
 
231
    )
 
232
 
 
233
    """ friendships/create """
 
234
    create_friendship = bind_api(
 
235
        path = '/friendships/create.json',
 
236
        method = 'POST',
 
237
        payload_type = 'user',
 
238
        allowed_param = ['id', 'user_id', 'screen_name', 'follow'],
 
239
        require_auth = True
 
240
    )
 
241
 
 
242
    """ friendships/destroy """
 
243
    destroy_friendship = bind_api(
 
244
        path = '/friendships/destroy.json',
 
245
        method = 'DELETE',
 
246
        payload_type = 'user',
 
247
        allowed_param = ['id', 'user_id', 'screen_name'],
 
248
        require_auth = True
 
249
    )
 
250
 
 
251
    """ friendships/exists """
 
252
    exists_friendship = bind_api(
 
253
        path = '/friendships/exists.json',
 
254
        payload_type = 'json',
 
255
        allowed_param = ['user_a', 'user_b']
 
256
    )
 
257
 
 
258
    """ friendships/show """
 
259
    show_friendship = bind_api(
 
260
        path = '/friendships/show.json',
 
261
        payload_type = 'friendship',
 
262
        allowed_param = ['source_id', 'source_screen_name',
 
263
                          'target_id', 'target_screen_name']
 
264
    )
 
265
 
 
266
    """ friends/ids """
 
267
    friends_ids = bind_api(
 
268
        path = '/friends/ids.json',
 
269
        payload_type = 'ids',
 
270
        allowed_param = ['id', 'user_id', 'screen_name', 'cursor']
 
271
    )
 
272
 
 
273
    """ friendships/incoming """
 
274
    friendships_incoming = bind_api(
 
275
        path = '/friendships/incoming.json',
 
276
        payload_type = 'ids',
 
277
        allowed_param = ['cursor']
 
278
    )
 
279
 
 
280
    """ friendships/outgoing"""
 
281
    friendships_outgoing = bind_api(
 
282
        path = '/friendships/outgoing.json',
 
283
        payload_type = 'ids',
 
284
        allowed_param = ['cursor']
 
285
    )
 
286
 
 
287
    """ followers/ids """
 
288
    followers_ids = bind_api(
 
289
        path = '/followers/ids.json',
 
290
        payload_type = 'ids',
 
291
        allowed_param = ['id', 'user_id', 'screen_name', 'cursor']
 
292
    )
 
293
 
 
294
    """ account/verify_credentials """
 
295
    def verify_credentials(self):
 
296
        try:
 
297
            return bind_api(
 
298
                path = '/account/verify_credentials.json',
 
299
                payload_type = 'user',
 
300
                require_auth = True
 
301
            )(self)
 
302
        except TweepError:
 
303
            return False
 
304
 
 
305
    """ account/rate_limit_status """
 
306
    rate_limit_status = bind_api(
 
307
        path = '/account/rate_limit_status.json',
 
308
        payload_type = 'json'
 
309
    )
 
310
 
 
311
    """ account/update_delivery_device """
 
312
    set_delivery_device = bind_api(
 
313
        path = '/account/update_delivery_device.json',
 
314
        method = 'POST',
 
315
        allowed_param = ['device'],
 
316
        payload_type = 'user',
 
317
        require_auth = True
 
318
    )
 
319
 
 
320
    """ account/update_profile_colors """
 
321
    update_profile_colors = bind_api(
 
322
        path = '/account/update_profile_colors.json',
 
323
        method = 'POST',
 
324
        payload_type = 'user',
 
325
        allowed_param = ['profile_background_color', 'profile_text_color',
 
326
                          'profile_link_color', 'profile_sidebar_fill_color',
 
327
                          'profile_sidebar_border_color'],
 
328
        require_auth = True
 
329
    )
 
330
 
 
331
    """ account/update_profile_image """
 
332
    def update_profile_image(self, filename):
 
333
        headers, post_data = API._pack_image(filename, 700)
 
334
        return bind_api(
 
335
            path = '/account/update_profile_image.json',
 
336
            method = 'POST',
 
337
            payload_type = 'user',
 
338
            require_auth = True
 
339
        )(self, post_data=post_data, headers=headers)
 
340
 
 
341
    """ account/update_profile_background_image """
 
342
    def update_profile_background_image(self, filename, *args, **kargs):
 
343
        headers, post_data = API._pack_image(filename, 800)
 
344
        bind_api(
 
345
            path = '/account/update_profile_background_image.json',
 
346
            method = 'POST',
 
347
            payload_type = 'user',
 
348
            allowed_param = ['tile'],
 
349
            require_auth = True
 
350
        )(self, post_data=post_data, headers=headers)
 
351
 
 
352
    """ account/update_profile """
 
353
    update_profile = bind_api(
 
354
        path = '/account/update_profile.json',
 
355
        method = 'POST',
 
356
        payload_type = 'user',
 
357
        allowed_param = ['name', 'url', 'location', 'description'],
 
358
        require_auth = True
 
359
    )
 
360
 
 
361
    """ favorites """
 
362
    favorites = bind_api(
 
363
        path = '/favorites.json',
 
364
        payload_type = 'status', payload_list = True,
 
365
        allowed_param = ['id', 'page']
 
366
    )
 
367
 
 
368
    """ favorites/create """
 
369
    create_favorite = bind_api(
 
370
        path = '/favorites/create/{id}.json',
 
371
        method = 'POST',
 
372
        payload_type = 'status',
 
373
        allowed_param = ['id'],
 
374
        require_auth = True
 
375
    )
 
376
 
 
377
    """ favorites/destroy """
 
378
    destroy_favorite = bind_api(
 
379
        path = '/favorites/destroy/{id}.json',
 
380
        method = 'DELETE',
 
381
        payload_type = 'status',
 
382
        allowed_param = ['id'],
 
383
        require_auth = True
 
384
    )
 
385
 
 
386
    """ notifications/follow """
 
387
    enable_notifications = bind_api(
 
388
        path = '/notifications/follow.json',
 
389
        method = 'POST',
 
390
        payload_type = 'user',
 
391
        allowed_param = ['id', 'user_id', 'screen_name'],
 
392
        require_auth = True
 
393
    )
 
394
 
 
395
    """ notifications/leave """
 
396
    disable_notifications = bind_api(
 
397
        path = '/notifications/leave.json',
 
398
        method = 'POST',
 
399
        payload_type = 'user',
 
400
        allowed_param = ['id', 'user_id', 'screen_name'],
 
401
        require_auth = True
 
402
    )
 
403
 
 
404
    """ blocks/create """
 
405
    create_block = bind_api(
 
406
        path = '/blocks/create.json',
 
407
        method = 'POST',
 
408
        payload_type = 'user',
 
409
        allowed_param = ['id', 'user_id', 'screen_name'],
 
410
        require_auth = True
 
411
    )
 
412
 
 
413
    """ blocks/destroy """
 
414
    destroy_block = bind_api(
 
415
        path = '/blocks/destroy.json',
 
416
        method = 'DELETE',
 
417
        payload_type = 'user',
 
418
        allowed_param = ['id', 'user_id', 'screen_name'],
 
419
        require_auth = True
 
420
    )
 
421
 
 
422
    """ blocks/exists """
 
423
    def exists_block(self, *args, **kargs):
 
424
        try:
 
425
            bind_api(
 
426
                path = '/blocks/exists.json',
 
427
                allowed_param = ['id', 'user_id', 'screen_name'],
 
428
                require_auth = True
 
429
            )(self, *args, **kargs)
 
430
        except TweepError:
 
431
            return False
 
432
        return True
 
433
 
 
434
    """ blocks/blocking """
 
435
    blocks = bind_api(
 
436
        path = '/blocks/blocking.json',
 
437
        payload_type = 'user', payload_list = True,
 
438
        allowed_param = ['page'],
 
439
        require_auth = True
 
440
    )
 
441
 
 
442
    """ blocks/blocking/ids """
 
443
    blocks_ids = bind_api(
 
444
        path = '/blocks/blocking/ids.json',
 
445
        payload_type = 'json',
 
446
        require_auth = True
 
447
    )
 
448
 
 
449
    """ report_spam """
 
450
    report_spam = bind_api(
 
451
        path = '/report_spam.json',
 
452
        method = 'POST',
 
453
        payload_type = 'user',
 
454
        allowed_param = ['id', 'user_id', 'screen_name'],
 
455
        require_auth = True
 
456
    )
 
457
 
 
458
    """ saved_searches """
 
459
    saved_searches = bind_api(
 
460
        path = '/saved_searches.json',
 
461
        payload_type = 'saved_search', payload_list = True,
 
462
        require_auth = True
 
463
    )
 
464
 
 
465
    """ saved_searches/show """
 
466
    get_saved_search = bind_api(
 
467
        path = '/saved_searches/show/{id}.json',
 
468
        payload_type = 'saved_search',
 
469
        allowed_param = ['id'],
 
470
        require_auth = True
 
471
    )
 
472
 
 
473
    """ saved_searches/create """
 
474
    create_saved_search = bind_api(
 
475
        path = '/saved_searches/create.json',
 
476
        method = 'POST',
 
477
        payload_type = 'saved_search',
 
478
        allowed_param = ['query'],
 
479
        require_auth = True
 
480
    )
 
481
 
 
482
    """ saved_searches/destroy """
 
483
    destroy_saved_search = bind_api(
 
484
        path = '/saved_searches/destroy/{id}.json',
 
485
        method = 'DELETE',
 
486
        payload_type = 'saved_search',
 
487
        allowed_param = ['id'],
 
488
        require_auth = True
 
489
    )
 
490
 
 
491
    """ help/test """
 
492
    def test(self):
 
493
        try:
 
494
            bind_api(
 
495
                path = '/help/test.json',
 
496
            )(self)
 
497
        except TweepError:
 
498
            return False
 
499
        return True
 
500
 
 
501
    def create_list(self, *args, **kargs):
 
502
        return bind_api(
 
503
            path = '/%s/lists.json' % self.auth.get_username(),
 
504
            method = 'POST',
 
505
            payload_type = 'list',
 
506
            allowed_param = ['name', 'mode', 'description'],
 
507
            require_auth = True
 
508
        )(self, *args, **kargs)
 
509
 
 
510
    def destroy_list(self, slug):
 
511
        return bind_api(
 
512
            path = '/%s/lists/%s.json' % (self.auth.get_username(), slug),
 
513
            method = 'DELETE',
 
514
            payload_type = 'list',
 
515
            require_auth = True
 
516
        )(self)
 
517
 
 
518
    def update_list(self, slug, *args, **kargs):
 
519
        return bind_api(
 
520
            path = '/%s/lists/%s.json' % (self.auth.get_username(), slug),
 
521
            method = 'POST',
 
522
            payload_type = 'list',
 
523
            allowed_param = ['name', 'mode', 'description'],
 
524
            require_auth = True
 
525
        )(self, *args, **kargs)
 
526
 
 
527
    lists = bind_api(
 
528
        path = '/{user}/lists.json',
 
529
        payload_type = 'list', payload_list = True,
 
530
        allowed_param = ['user', 'cursor'],
 
531
        require_auth = True
 
532
    )
 
533
 
 
534
    lists_memberships = bind_api(
 
535
        path = '/{user}/lists/memberships.json',
 
536
        payload_type = 'list', payload_list = True,
 
537
        allowed_param = ['user', 'cursor'],
 
538
        require_auth = True
 
539
    )
 
540
 
 
541
    lists_subscriptions = bind_api(
 
542
        path = '/{user}/lists/subscriptions.json',
 
543
        payload_type = 'list', payload_list = True,
 
544
        allowed_param = ['user', 'cursor'],
 
545
        require_auth = True
 
546
    )
 
547
 
 
548
    list_timeline = bind_api(
 
549
        path = '/{owner}/lists/{slug}/statuses.json',
 
550
        payload_type = 'status', payload_list = True,
 
551
        allowed_param = ['owner', 'slug', 'since_id', 'max_id', 'per_page', 'page']
 
552
    )
 
553
 
 
554
    get_list = bind_api(
 
555
        path = '/{owner}/lists/{slug}.json',
 
556
        payload_type = 'list',
 
557
        allowed_param = ['owner', 'slug']
 
558
    )
 
559
 
 
560
    def add_list_member(self, slug, *args, **kargs):
 
561
        return bind_api(
 
562
            path = '/%s/%s/members.json' % (self.auth.get_username(), slug),
 
563
            method = 'POST',
 
564
            payload_type = 'list',
 
565
            allowed_param = ['id'],
 
566
            require_auth = True
 
567
        )(self, *args, **kargs)
 
568
 
 
569
    def remove_list_member(self, slug, *args, **kargs):
 
570
        return bind_api(
 
571
            path = '/%s/%s/members.json' % (self.auth.get_username(), slug),
 
572
            method = 'DELETE',
 
573
            payload_type = 'list',
 
574
            allowed_param = ['id'],
 
575
            require_auth = True
 
576
        )(self, *args, **kargs)
 
577
 
 
578
    list_members = bind_api(
 
579
        path = '/{owner}/{slug}/members.json',
 
580
        payload_type = 'user', payload_list = True,
 
581
        allowed_param = ['owner', 'slug', 'cursor']
 
582
    )
 
583
 
 
584
    def is_list_member(self, owner, slug, user_id):
 
585
        try:
 
586
            return bind_api(
 
587
                path = '/%s/%s/members/%s.json' % (owner, slug, user_id),
 
588
                payload_type = 'user'
 
589
            )(self)
 
590
        except TweepError:
 
591
            return False
 
592
 
 
593
    subscribe_list = bind_api(
 
594
        path = '/{owner}/{slug}/subscribers.json',
 
595
        method = 'POST',
 
596
        payload_type = 'list',
 
597
        allowed_param = ['owner', 'slug'],
 
598
        require_auth = True
 
599
    )
 
600
 
 
601
    unsubscribe_list = bind_api(
 
602
        path = '/{owner}/{slug}/subscribers.json',
 
603
        method = 'DELETE',
 
604
        payload_type = 'list',
 
605
        allowed_param = ['owner', 'slug'],
 
606
        require_auth = True
 
607
    )
 
608
 
 
609
    list_subscribers = bind_api(
 
610
        path = '/{owner}/{slug}/subscribers.json',
 
611
        payload_type = 'user', payload_list = True,
 
612
        allowed_param = ['owner', 'slug', 'cursor']
 
613
    )
 
614
 
 
615
    def is_subscribed_list(self, owner, slug, user_id):
 
616
        try:
 
617
            return bind_api(
 
618
                path = '/%s/%s/subscribers/%s.json' % (owner, slug, user_id),
 
619
                payload_type = 'user'
 
620
            )(self)
 
621
        except TweepError:
 
622
            return False
 
623
 
 
624
    """ trends/available """
 
625
    trends_available = bind_api(
 
626
        path = '/trends/available.json',
 
627
        payload_type = 'json',
 
628
        allowed_param = ['lat', 'long']
 
629
    )
 
630
 
 
631
    """ trends/location """
 
632
    trends_location = bind_api(
 
633
        path = '/trends/{woeid}.json',
 
634
        payload_type = 'json',
 
635
        allowed_param = ['woeid']
 
636
    )
 
637
 
 
638
    """ search """
 
639
    search = bind_api(
 
640
        search_api = True,
 
641
        path = '/search.json',
 
642
        payload_type = 'search_result', payload_list = True,
 
643
        allowed_param = ['q', 'lang', 'locale', 'rpp', 'page', 'since_id', 'geocode', 'show_user', 'max_id', 'since', 'until', 'result_type']
 
644
    )
 
645
    search.pagination_mode = 'page'
 
646
 
 
647
    """ trends """
 
648
    trends = bind_api(
 
649
        path = '/trends.json',
 
650
        payload_type = 'json'
 
651
    )
 
652
 
 
653
    """ trends/current """
 
654
    trends_current = bind_api(
 
655
        path = '/trends/current.json',
 
656
        payload_type = 'json',
 
657
        allowed_param = ['exclude']
 
658
    )
 
659
 
 
660
    """ trends/daily """
 
661
    trends_daily = bind_api(
 
662
        path = '/trends/daily.json',
 
663
        payload_type = 'json',
 
664
        allowed_param = ['date', 'exclude']
 
665
    )
 
666
 
 
667
    """ trends/weekly """
 
668
    trends_weekly = bind_api(
 
669
        path = '/trends/weekly.json',
 
670
        payload_type = 'json',
 
671
        allowed_param = ['date', 'exclude']
 
672
    )
 
673
 
 
674
    """ geo/reverse_geocode """
 
675
    reverse_geocode = bind_api(
 
676
        path = '/geo/reverse_geocode.json',
 
677
        payload_type = 'json',
 
678
        allowed_param = ['lat', 'long', 'accuracy', 'granularity', 'max_results']
 
679
    )
 
680
 
 
681
    """ geo/nearby_places """
 
682
    nearby_places = bind_api(
 
683
        path = '/geo/nearby_places.json',
 
684
        payload_type = 'json',
 
685
        allowed_param = ['lat', 'long', 'ip', 'accuracy', 'granularity', 'max_results']
 
686
    )
 
687
 
 
688
    """ geo/id """
 
689
    geo_id = bind_api(
 
690
        path = '/geo/id/{id}.json',
 
691
        payload_type = 'json',
 
692
        allowed_param = ['id']
 
693
    )
 
694
 
 
695
    """ Internal use only """
 
696
    @staticmethod
 
697
    def _pack_image(filename, max_size):
 
698
        """Pack image from file into multipart-formdata post body"""
 
699
        # image must be less than 700kb in size
 
700
        try:
 
701
            if os.path.getsize(filename) > (max_size * 1024):
 
702
                raise TweepError('File is too big, must be less than 700kb.')
 
703
        except os.error, e:
 
704
            raise TweepError('Unable to access file')
 
705
 
 
706
        # image must be gif, jpeg, or png
 
707
        file_type = mimetypes.guess_type(filename)
 
708
        if file_type is None:
 
709
            raise TweepError('Could not determine file type')
 
710
        file_type = file_type[0]
 
711
        if file_type not in ['image/gif', 'image/jpeg', 'image/png']:
 
712
            raise TweepError('Invalid file type for image: %s' % file_type)
 
713
 
 
714
        # build the mulitpart-formdata body
 
715
        fp = open(filename, 'rb')
 
716
        BOUNDARY = 'Tw3ePy'
 
717
        body = []
 
718
        body.append('--' + BOUNDARY)
 
719
        body.append('Content-Disposition: form-data; name="image"; filename="%s"' % filename)
 
720
        body.append('Content-Type: %s' % file_type)
 
721
        body.append('')
 
722
        body.append(fp.read())
 
723
        body.append('--' + BOUNDARY + '--')
 
724
        body.append('')
 
725
        fp.close()
 
726
        body = '\r\n'.join(body)
 
727
 
 
728
        # build headers
 
729
        headers = {
 
730
            'Content-Type': 'multipart/form-data; boundary=Tw3ePy',
 
731
            'Content-Length': len(body)
 
732
        }
 
733
 
 
734
        return headers, body
 
735