@@ -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 | |