@@ -6,40 +6,40 @@ |
||
6 | 6 | use Jacobemerick\Web\Domain\Stream\Twitter\MysqlTwitterRepository as TwitterRepository; |
7 | 7 | |
8 | 8 | $client = new TwitterOAuth( |
9 | - $config->twitter->consumer_key, |
|
10 | - $config->twitter->consumer_secret, |
|
11 | - $config->twitter->access_token, |
|
12 | - $config->twitter->access_token_secret |
|
9 | + $config->twitter->consumer_key, |
|
10 | + $config->twitter->consumer_secret, |
|
11 | + $config->twitter->access_token, |
|
12 | + $config->twitter->access_token_secret |
|
13 | 13 | ); |
14 | 14 | $client->setDecodeJsonAsArray(true); |
15 | 15 | |
16 | 16 | $twitterRepository = new TwitterRepository($container['db_connection_locator']); |
17 | 17 | |
18 | 18 | $recentTweets = $client->get('statuses/user_timeline', [ |
19 | - 'screen_name' => 'jpemeric', |
|
20 | - 'count' => 50, |
|
21 | - 'trim_user' => true, |
|
19 | + 'screen_name' => 'jpemeric', |
|
20 | + 'count' => 50, |
|
21 | + 'trim_user' => true, |
|
22 | 22 | ]); |
23 | 23 | |
24 | 24 | if (isset($recentTweets['errors'])) { |
25 | - throw new Exception("Error encountered with twitter api {$recentTweets['errors'][0]['message']}"); |
|
25 | + throw new Exception("Error encountered with twitter api {$recentTweets['errors'][0]['message']}"); |
|
26 | 26 | } |
27 | 27 | |
28 | 28 | foreach ($recentTweets as $tweet) { |
29 | - $uniqueTweetCheck = $twitterRepository->getTwitterByTweetId($tweet['id_str']); |
|
30 | - if ($uniqueTweetCheck !== false) { |
|
31 | - $currentTweetHash = md5($uniqueTweetCheck['metadata']); |
|
32 | - $newTweetHash = md5(json_encode($tweet)); |
|
33 | - if ($uniqueTweetCheck['metadata'] != json_encode($tweet)) { |
|
34 | - $twitterRepository->updateTweetMetadata($tweet['id_str'], $tweet); |
|
35 | - } |
|
36 | - continue; |
|
37 | - } |
|
38 | - |
|
39 | - $twitterRepository->insertTweet( |
|
40 | - $tweet['id_str'], |
|
41 | - (new DateTime($tweet['created_at']))->setTimezone($container['default_timezone']), |
|
42 | - $tweet |
|
43 | - ); |
|
29 | + $uniqueTweetCheck = $twitterRepository->getTwitterByTweetId($tweet['id_str']); |
|
30 | + if ($uniqueTweetCheck !== false) { |
|
31 | + $currentTweetHash = md5($uniqueTweetCheck['metadata']); |
|
32 | + $newTweetHash = md5(json_encode($tweet)); |
|
33 | + if ($uniqueTweetCheck['metadata'] != json_encode($tweet)) { |
|
34 | + $twitterRepository->updateTweetMetadata($tweet['id_str'], $tweet); |
|
35 | + } |
|
36 | + continue; |
|
37 | + } |
|
38 | + |
|
39 | + $twitterRepository->insertTweet( |
|
40 | + $tweet['id_str'], |
|
41 | + (new DateTime($tweet['created_at']))->setTimezone($container['default_timezone']), |
|
42 | + $tweet |
|
43 | + ); |
|
44 | 44 | } |
45 | 45 |