@@ -11,58 +11,58 @@ discard block |
||
11 | 11 | |
12 | 12 | $lastBlogActivity = $activityRepository->getActivityLastUpdateByType('blog'); |
13 | 13 | if ($lastBlogActivity === false) { |
14 | - $lastBlogActivityDateTime = new DateTime('2008-05-03'); |
|
14 | + $lastBlogActivityDateTime = new DateTime('2008-05-03'); |
|
15 | 15 | } else { |
16 | - $lastBlogActivityDateTime = new DateTime($lastBlogActivity['updated_at']); |
|
17 | - $lastBlogActivityDateTime->modify('-5 days'); |
|
16 | + $lastBlogActivityDateTime = new DateTime($lastBlogActivity['updated_at']); |
|
17 | + $lastBlogActivityDateTime->modify('-5 days'); |
|
18 | 18 | } |
19 | 19 | $newBlogActivity = $blogRepository->getBlogsUpdatedSince($lastBlogActivityDateTime); |
20 | 20 | foreach ($newBlogActivity as $blog) { |
21 | - $uniqueBlogCheck = $activityRepository->getActivityByTypeId('blog', $blog['id']); |
|
22 | - if ($uniqueBlogCheck !== false) { |
|
23 | - continue; |
|
24 | - } |
|
25 | - |
|
26 | - $blogData = json_decode($blog['metadata'], true); |
|
27 | - $message = sprintf( |
|
28 | - 'Blogged about %s | %s.', |
|
29 | - str_replace('-', ' ', $blogData['category']), |
|
30 | - $blogData['title'] |
|
31 | - ); |
|
32 | - |
|
33 | - if (isset($blogData['enclosure'])) { |
|
34 | - $messageLong = sprintf( |
|
35 | - "<h4><a href=\"%s\" title=\"Jacob Emerick's Blog | %s\">%s</a></h4>\n" . |
|
36 | - "<img src=\"%s\" alt=\"Blog | %s\" />\n" . |
|
37 | - "<p>%s [<a href=\"%s\">read more</a></a>]</p>", |
|
38 | - $blogData['link'], |
|
39 | - $blogData['title'], |
|
40 | - $blogData['title'], |
|
41 | - $blogData['enclosure']['@attributes']['url'], |
|
42 | - $blogData['title'], |
|
43 | - htmlentities($blogData['description']), |
|
44 | - $blogData['link'] |
|
45 | - ); |
|
46 | - } else { |
|
47 | - $messageLong = sprintf( |
|
48 | - "<h4><a href=\"%s\" title=\"Jacob Emerick's Blog | %s\">%s</a></h4>\n" . |
|
49 | - "<p>%s [<a href=\"%s\">read more</a></a>]</p>", |
|
50 | - $blogData['link'], |
|
51 | - $blogData['title'], |
|
52 | - $blogData['title'], |
|
53 | - htmlentities($blogData['description']), |
|
54 | - $blogData['link'] |
|
55 | - ); |
|
56 | - } |
|
57 | - |
|
58 | - $activityRepository->insertActivity( |
|
59 | - $message, |
|
60 | - $messageLong, |
|
61 | - (new DateTime($blog['datetime'])), |
|
62 | - [], |
|
63 | - 'blog', |
|
64 | - $blog['id'] |
|
65 | - ); |
|
21 | + $uniqueBlogCheck = $activityRepository->getActivityByTypeId('blog', $blog['id']); |
|
22 | + if ($uniqueBlogCheck !== false) { |
|
23 | + continue; |
|
24 | + } |
|
25 | + |
|
26 | + $blogData = json_decode($blog['metadata'], true); |
|
27 | + $message = sprintf( |
|
28 | + 'Blogged about %s | %s.', |
|
29 | + str_replace('-', ' ', $blogData['category']), |
|
30 | + $blogData['title'] |
|
31 | + ); |
|
32 | + |
|
33 | + if (isset($blogData['enclosure'])) { |
|
34 | + $messageLong = sprintf( |
|
35 | + "<h4><a href=\"%s\" title=\"Jacob Emerick's Blog | %s\">%s</a></h4>\n" . |
|
36 | + "<img src=\"%s\" alt=\"Blog | %s\" />\n" . |
|
37 | + "<p>%s [<a href=\"%s\">read more</a></a>]</p>", |
|
38 | + $blogData['link'], |
|
39 | + $blogData['title'], |
|
40 | + $blogData['title'], |
|
41 | + $blogData['enclosure']['@attributes']['url'], |
|
42 | + $blogData['title'], |
|
43 | + htmlentities($blogData['description']), |
|
44 | + $blogData['link'] |
|
45 | + ); |
|
46 | + } else { |
|
47 | + $messageLong = sprintf( |
|
48 | + "<h4><a href=\"%s\" title=\"Jacob Emerick's Blog | %s\">%s</a></h4>\n" . |
|
49 | + "<p>%s [<a href=\"%s\">read more</a></a>]</p>", |
|
50 | + $blogData['link'], |
|
51 | + $blogData['title'], |
|
52 | + $blogData['title'], |
|
53 | + htmlentities($blogData['description']), |
|
54 | + $blogData['link'] |
|
55 | + ); |
|
56 | + } |
|
57 | + |
|
58 | + $activityRepository->insertActivity( |
|
59 | + $message, |
|
60 | + $messageLong, |
|
61 | + (new DateTime($blog['datetime'])), |
|
62 | + [], |
|
63 | + 'blog', |
|
64 | + $blog['id'] |
|
65 | + ); |
|
66 | 66 | } |
67 | 67 | |
68 | 68 | use Jacobemerick\Web\Domain\Stream\BlogComment\MysqlBlogCommentRepository as BlogCommentRepository; |
@@ -70,30 +70,30 @@ discard block |
||
70 | 70 | $blogCommentActivity = $blogCommentRepository->getBlogComments(); |
71 | 71 | $blogCommentHolder = []; |
72 | 72 | foreach ($blogCommentActivity as $blogComment) { |
73 | - $blogPermalink = $blogComment['permalink']; |
|
74 | - $blogPermalink = explode('#', $blogPermalink); |
|
75 | - $blogPermalink = current($blogPermalink); |
|
76 | - |
|
77 | - $blog = $blogRepository->getBlogByPermalink($blogPermalink); |
|
78 | - if (!array_key_exists($blog['id'], $blogCommentHolder)) { |
|
79 | - $blogCommentHolder[$blog['id']] = 1; |
|
80 | - } else { |
|
81 | - $blogCommentHolder[$blog['id']]++; |
|
82 | - } |
|
73 | + $blogPermalink = $blogComment['permalink']; |
|
74 | + $blogPermalink = explode('#', $blogPermalink); |
|
75 | + $blogPermalink = current($blogPermalink); |
|
76 | + |
|
77 | + $blog = $blogRepository->getBlogByPermalink($blogPermalink); |
|
78 | + if (!array_key_exists($blog['id'], $blogCommentHolder)) { |
|
79 | + $blogCommentHolder[$blog['id']] = 1; |
|
80 | + } else { |
|
81 | + $blogCommentHolder[$blog['id']]++; |
|
82 | + } |
|
83 | 83 | } |
84 | 84 | |
85 | 85 | foreach ($blogCommentHolder as $blogId => $commentCount) { |
86 | - $blogActivity = $activityRepository->getActivityByTypeId('blog', $blogId); |
|
87 | - $blogActivityMetadata = json_decode($blogActivity['metadata'], true); |
|
88 | - if ( |
|
89 | - !isset($blogActivityMetadata['comments']) || |
|
90 | - $blogActivityMetadata['comments'] != $commentCount |
|
91 | - ) { |
|
92 | - $activityRepository->updateActivityMetadata( |
|
93 | - $blogActivity['id'], |
|
94 | - ['comments' => $commentCount] |
|
95 | - ); |
|
96 | - } |
|
86 | + $blogActivity = $activityRepository->getActivityByTypeId('blog', $blogId); |
|
87 | + $blogActivityMetadata = json_decode($blogActivity['metadata'], true); |
|
88 | + if ( |
|
89 | + !isset($blogActivityMetadata['comments']) || |
|
90 | + $blogActivityMetadata['comments'] != $commentCount |
|
91 | + ) { |
|
92 | + $activityRepository->updateActivityMetadata( |
|
93 | + $blogActivity['id'], |
|
94 | + ['comments' => $commentCount] |
|
95 | + ); |
|
96 | + } |
|
97 | 97 | } |
98 | 98 | |
99 | 99 | // distance |
@@ -102,67 +102,67 @@ discard block |
||
102 | 102 | |
103 | 103 | $lastDailyMileActivity = $activityRepository->getActivityLastUpdateByType('distance'); |
104 | 104 | if ($lastDailyMileActivity === false) { |
105 | - $lastDailyMileActivityDateTime = new DateTime('2008-05-03'); |
|
105 | + $lastDailyMileActivityDateTime = new DateTime('2008-05-03'); |
|
106 | 106 | } else { |
107 | - $lastDailyMileActivityDateTime = new DateTime($lastDailyMileActivity['updated_at']); |
|
108 | - $lastDailyMileActivityDateTime->modify('-5 days'); |
|
107 | + $lastDailyMileActivityDateTime = new DateTime($lastDailyMileActivity['updated_at']); |
|
108 | + $lastDailyMileActivityDateTime->modify('-5 days'); |
|
109 | 109 | } |
110 | 110 | $newDailyMileActivity = $dailyMileRepository->getDailyMilesUpdatedSince($lastDailyMileActivityDateTime); |
111 | 111 | foreach ($newDailyMileActivity as $dailyMile) { |
112 | - $uniqueDailyMileCheck = $activityRepository->getActivityByTypeId('distance', $dailyMile['id']); |
|
113 | - if ($uniqueDailyMileCheck !== false) { |
|
114 | - continue; |
|
115 | - } |
|
116 | - |
|
117 | - $dailyMileData = json_decode($dailyMile['metadata'], true); |
|
118 | - if ($dailyMile['type'] == 'Hiking') { |
|
119 | - $message = sprintf( |
|
120 | - '%s %.2f %s and felt %s.', |
|
121 | - 'Hiked', |
|
122 | - $dailyMileData['workout']['distance']['value'], |
|
123 | - $dailyMileData['workout']['distance']['units'], |
|
124 | - $dailyMileData['workout']['felt'] |
|
125 | - ); |
|
126 | - $messageLong = "<p>{$message}</p>"; |
|
127 | - if (isset($dailyMileData['workout']['title'])) { |
|
128 | - $messageLong .= "\n<p>I was hiking up around the {$dailyMileData['workout']['title']} area.</p>"; |
|
129 | - } |
|
130 | - } else if ($dailyMile['type'] == 'Running') { |
|
131 | - $message = sprintf( |
|
132 | - '%s %.2f %s and felt %s.', |
|
133 | - 'Ran', |
|
134 | - $dailyMileData['workout']['distance']['value'], |
|
135 | - $dailyMileData['workout']['distance']['units'], |
|
136 | - $dailyMileData['workout']['felt'] |
|
137 | - ); |
|
138 | - $messageLong = "<p>{$message}</p>"; |
|
139 | - if (isset($dailyMileData['message'])) { |
|
140 | - $messageLong .= "\n<p>Afterwards, I was all like '{$dailyMileData['message']}'.</p>"; |
|
141 | - } |
|
142 | - } else if ($dailyMile['type'] == 'Walking') { |
|
143 | - $message = sprintf( |
|
144 | - '%s %.2f %s and felt %s.', |
|
145 | - 'Walked', |
|
146 | - $dailyMileData['workout']['distance']['value'], |
|
147 | - $dailyMileData['workout']['distance']['units'], |
|
148 | - $dailyMileData['workout']['felt'] |
|
149 | - ); |
|
150 | - $messageLong = "<p>{$message}</p>"; |
|
151 | - if (isset($dailyMileData['message'])) { |
|
152 | - $messageLong .= "\n<p>{$dailyMileData['message']}</p>"; |
|
153 | - } |
|
154 | - } else { |
|
155 | - continue; |
|
156 | - } |
|
157 | - |
|
158 | - $activityRepository->insertActivity( |
|
159 | - $message, |
|
160 | - $messageLong, |
|
161 | - (new DateTime($dailyMile['datetime'])), |
|
162 | - [], |
|
163 | - 'distance', |
|
164 | - $dailyMile['id'] |
|
165 | - ); |
|
112 | + $uniqueDailyMileCheck = $activityRepository->getActivityByTypeId('distance', $dailyMile['id']); |
|
113 | + if ($uniqueDailyMileCheck !== false) { |
|
114 | + continue; |
|
115 | + } |
|
116 | + |
|
117 | + $dailyMileData = json_decode($dailyMile['metadata'], true); |
|
118 | + if ($dailyMile['type'] == 'Hiking') { |
|
119 | + $message = sprintf( |
|
120 | + '%s %.2f %s and felt %s.', |
|
121 | + 'Hiked', |
|
122 | + $dailyMileData['workout']['distance']['value'], |
|
123 | + $dailyMileData['workout']['distance']['units'], |
|
124 | + $dailyMileData['workout']['felt'] |
|
125 | + ); |
|
126 | + $messageLong = "<p>{$message}</p>"; |
|
127 | + if (isset($dailyMileData['workout']['title'])) { |
|
128 | + $messageLong .= "\n<p>I was hiking up around the {$dailyMileData['workout']['title']} area.</p>"; |
|
129 | + } |
|
130 | + } else if ($dailyMile['type'] == 'Running') { |
|
131 | + $message = sprintf( |
|
132 | + '%s %.2f %s and felt %s.', |
|
133 | + 'Ran', |
|
134 | + $dailyMileData['workout']['distance']['value'], |
|
135 | + $dailyMileData['workout']['distance']['units'], |
|
136 | + $dailyMileData['workout']['felt'] |
|
137 | + ); |
|
138 | + $messageLong = "<p>{$message}</p>"; |
|
139 | + if (isset($dailyMileData['message'])) { |
|
140 | + $messageLong .= "\n<p>Afterwards, I was all like '{$dailyMileData['message']}'.</p>"; |
|
141 | + } |
|
142 | + } else if ($dailyMile['type'] == 'Walking') { |
|
143 | + $message = sprintf( |
|
144 | + '%s %.2f %s and felt %s.', |
|
145 | + 'Walked', |
|
146 | + $dailyMileData['workout']['distance']['value'], |
|
147 | + $dailyMileData['workout']['distance']['units'], |
|
148 | + $dailyMileData['workout']['felt'] |
|
149 | + ); |
|
150 | + $messageLong = "<p>{$message}</p>"; |
|
151 | + if (isset($dailyMileData['message'])) { |
|
152 | + $messageLong .= "\n<p>{$dailyMileData['message']}</p>"; |
|
153 | + } |
|
154 | + } else { |
|
155 | + continue; |
|
156 | + } |
|
157 | + |
|
158 | + $activityRepository->insertActivity( |
|
159 | + $message, |
|
160 | + $messageLong, |
|
161 | + (new DateTime($dailyMile['datetime'])), |
|
162 | + [], |
|
163 | + 'distance', |
|
164 | + $dailyMile['id'] |
|
165 | + ); |
|
166 | 166 | } |
167 | 167 | |
168 | 168 | // github |
@@ -171,127 +171,127 @@ discard block |
||
171 | 171 | |
172 | 172 | $lastGithubActivity = $activityRepository->getActivityLastUpdateByType('git'); |
173 | 173 | if ($lastGithubActivity === false) { |
174 | - $lastGithubActivityDateTime = new DateTime('2015-10-01'); |
|
174 | + $lastGithubActivityDateTime = new DateTime('2015-10-01'); |
|
175 | 175 | } else { |
176 | - $lastGithubActivityDateTime = new DateTime($lastGithubActivity['updated_at']); |
|
177 | - $lastGithubActivityDateTime->modify('-5 days'); |
|
176 | + $lastGithubActivityDateTime = new DateTime($lastGithubActivity['updated_at']); |
|
177 | + $lastGithubActivityDateTime->modify('-5 days'); |
|
178 | 178 | } |
179 | 179 | $newGithubActivity = $githubRepository->getGithubsUpdatedSince($lastGithubActivityDateTime); |
180 | 180 | foreach ($newGithubActivity as $github) { |
181 | - $uniqueGithubCheck = $activityRepository->getActivityByTypeId('git', $github['id']); |
|
182 | - if ($uniqueGithubCheck !== false) { |
|
183 | - continue; |
|
184 | - } |
|
185 | - |
|
186 | - $githubData = json_decode($github['metadata'], true); |
|
187 | - |
|
188 | - if ($github['type'] == 'CreateEvent') { |
|
189 | - if ( |
|
190 | - $githubData['payload']['ref_type'] == 'branch' || |
|
191 | - $githubData['payload']['ref_type'] == 'tag' |
|
192 | - ) { |
|
193 | - $message = sprintf( |
|
194 | - 'Created %s %s at %s.', |
|
195 | - $githubData['payload']['ref_type'], |
|
196 | - $githubData['payload']['ref'], |
|
197 | - $githubData['repo']['name'] |
|
198 | - ); |
|
199 | - $messageLong = sprintf( |
|
200 | - '<p>Created %s %s at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>', |
|
201 | - $githubData['payload']['ref_type'], |
|
202 | - $githubData['payload']['ref'], |
|
203 | - "https://github.com/{$githubData['repo']['name']}", |
|
204 | - $githubData['repo']['name'], |
|
205 | - $githubData['repo']['name'] |
|
206 | - ); |
|
207 | - } else if ($githubData['payload']['ref_type'] == 'repository') { |
|
208 | - $message = sprintf( |
|
209 | - 'Created %s %s.', |
|
210 | - $githubData['payload']['ref_type'], |
|
211 | - $githubData['repo']['name'] |
|
212 | - ); |
|
213 | - $messageLong = sprintf( |
|
214 | - '<p>Created %s <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>', |
|
215 | - $githubData['payload']['ref_type'], |
|
216 | - "https://github.com/{$githubData['repo']['name']}", |
|
217 | - $githubData['repo']['name'], |
|
218 | - $githubData['repo']['name'] |
|
219 | - ); |
|
220 | - } else { |
|
221 | - continue; |
|
222 | - } |
|
223 | - } else if ($github['type'] == 'ForkEvent') { |
|
224 | - $message = sprintf( |
|
225 | - 'Forked %s to %s', |
|
226 | - $githubData['repo']['name'], |
|
227 | - $githubData['payload']['forkee']['full_name'] |
|
228 | - ); |
|
229 | - $messageLong = sprintf( |
|
230 | - '<p>Forked <a href="%s" target="_blank" title="Github | %s">%s</a> to <a href="%s" target="_blank" title="Github | %s">%s</a>.', |
|
231 | - "https://github.com/{$githubData['repo']['name']}", |
|
232 | - $githubData['repo']['name'], |
|
233 | - $githubData['repo']['name'], |
|
234 | - $githubData['payload']['forkee']['html_url'], |
|
235 | - $githubData['payload']['forkee']['full_name'], |
|
236 | - $githubData['payload']['forkee']['full_name'] |
|
237 | - ); |
|
238 | - } else if ($github['type'] == 'PullRequestEvent') { |
|
239 | - $message = sprintf( |
|
240 | - '%s a pull request at %s', |
|
241 | - ucwords($githubData['payload']['action']), |
|
242 | - $githubData['repo']['name'] |
|
243 | - ); |
|
244 | - $messageLong = sprintf( |
|
245 | - '<p>%s pull request <a href="%s" target="_blank" title="Github | %s PR %d">%d</a> at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>', |
|
246 | - ucwords($githubData['payload']['action']), |
|
247 | - $githubData['payload']['pull_request']['html_url'], |
|
248 | - $githubData['repo']['name'], |
|
249 | - $githubData['payload']['number'], |
|
250 | - $githubData['payload']['number'], |
|
251 | - "https://github.com/{$githubData['repo']['name']}", |
|
252 | - $githubData['repo']['name'], |
|
253 | - $githubData['repo']['name'] |
|
254 | - ); |
|
255 | - } else if ($github['type'] == 'PushEvent') { |
|
256 | - $message = sprintf( |
|
257 | - 'Pushed some code at %s.', |
|
258 | - $githubData['repo']['name'] |
|
259 | - ); |
|
260 | - $messageLong = sprintf( |
|
261 | - "<p>Pushed some code at <a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a>.</p>\n", |
|
262 | - $githubData['payload']['ref'], |
|
263 | - "https://github.com/{$githubData['repo']['name']}", |
|
264 | - $githubData['repo']['name'], |
|
265 | - $githubData['repo']['name'] |
|
266 | - ); |
|
267 | - $messageLong .= "<ul>\n"; |
|
268 | - foreach ($githubData['payload']['commits'] as $commit) { |
|
269 | - $messageShort = $commit['message']; |
|
270 | - $messageShort = strtok($messageShort, "\n"); |
|
271 | - if (strlen($messageShort) > 72) { |
|
272 | - $messageShort = wordwrap($messageShort, 65); |
|
273 | - $messageShort = strtok($messageShort, "\n"); |
|
274 | - $messageShort .= '...'; |
|
275 | - } |
|
276 | - $messageLong .= sprintf( |
|
277 | - "<li><a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a> %s.</p>\n", |
|
278 | - "https://github.com/{$githubData['repo']['name']}/commit/{$commit['sha']}", |
|
279 | - substr($commit['sha'], 0, 7), |
|
280 | - substr($commit['sha'], 0, 7), |
|
281 | - $messageShort |
|
282 | - ); |
|
283 | - } |
|
284 | - $messageLong .= "</ul>"; |
|
285 | - } |
|
286 | - |
|
287 | - $activityRepository->insertActivity( |
|
288 | - $message, |
|
289 | - $messageLong, |
|
290 | - (new DateTime($github['datetime'])), |
|
291 | - [], |
|
292 | - 'git', |
|
293 | - $github['id'] |
|
294 | - ); |
|
181 | + $uniqueGithubCheck = $activityRepository->getActivityByTypeId('git', $github['id']); |
|
182 | + if ($uniqueGithubCheck !== false) { |
|
183 | + continue; |
|
184 | + } |
|
185 | + |
|
186 | + $githubData = json_decode($github['metadata'], true); |
|
187 | + |
|
188 | + if ($github['type'] == 'CreateEvent') { |
|
189 | + if ( |
|
190 | + $githubData['payload']['ref_type'] == 'branch' || |
|
191 | + $githubData['payload']['ref_type'] == 'tag' |
|
192 | + ) { |
|
193 | + $message = sprintf( |
|
194 | + 'Created %s %s at %s.', |
|
195 | + $githubData['payload']['ref_type'], |
|
196 | + $githubData['payload']['ref'], |
|
197 | + $githubData['repo']['name'] |
|
198 | + ); |
|
199 | + $messageLong = sprintf( |
|
200 | + '<p>Created %s %s at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>', |
|
201 | + $githubData['payload']['ref_type'], |
|
202 | + $githubData['payload']['ref'], |
|
203 | + "https://github.com/{$githubData['repo']['name']}", |
|
204 | + $githubData['repo']['name'], |
|
205 | + $githubData['repo']['name'] |
|
206 | + ); |
|
207 | + } else if ($githubData['payload']['ref_type'] == 'repository') { |
|
208 | + $message = sprintf( |
|
209 | + 'Created %s %s.', |
|
210 | + $githubData['payload']['ref_type'], |
|
211 | + $githubData['repo']['name'] |
|
212 | + ); |
|
213 | + $messageLong = sprintf( |
|
214 | + '<p>Created %s <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>', |
|
215 | + $githubData['payload']['ref_type'], |
|
216 | + "https://github.com/{$githubData['repo']['name']}", |
|
217 | + $githubData['repo']['name'], |
|
218 | + $githubData['repo']['name'] |
|
219 | + ); |
|
220 | + } else { |
|
221 | + continue; |
|
222 | + } |
|
223 | + } else if ($github['type'] == 'ForkEvent') { |
|
224 | + $message = sprintf( |
|
225 | + 'Forked %s to %s', |
|
226 | + $githubData['repo']['name'], |
|
227 | + $githubData['payload']['forkee']['full_name'] |
|
228 | + ); |
|
229 | + $messageLong = sprintf( |
|
230 | + '<p>Forked <a href="%s" target="_blank" title="Github | %s">%s</a> to <a href="%s" target="_blank" title="Github | %s">%s</a>.', |
|
231 | + "https://github.com/{$githubData['repo']['name']}", |
|
232 | + $githubData['repo']['name'], |
|
233 | + $githubData['repo']['name'], |
|
234 | + $githubData['payload']['forkee']['html_url'], |
|
235 | + $githubData['payload']['forkee']['full_name'], |
|
236 | + $githubData['payload']['forkee']['full_name'] |
|
237 | + ); |
|
238 | + } else if ($github['type'] == 'PullRequestEvent') { |
|
239 | + $message = sprintf( |
|
240 | + '%s a pull request at %s', |
|
241 | + ucwords($githubData['payload']['action']), |
|
242 | + $githubData['repo']['name'] |
|
243 | + ); |
|
244 | + $messageLong = sprintf( |
|
245 | + '<p>%s pull request <a href="%s" target="_blank" title="Github | %s PR %d">%d</a> at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>', |
|
246 | + ucwords($githubData['payload']['action']), |
|
247 | + $githubData['payload']['pull_request']['html_url'], |
|
248 | + $githubData['repo']['name'], |
|
249 | + $githubData['payload']['number'], |
|
250 | + $githubData['payload']['number'], |
|
251 | + "https://github.com/{$githubData['repo']['name']}", |
|
252 | + $githubData['repo']['name'], |
|
253 | + $githubData['repo']['name'] |
|
254 | + ); |
|
255 | + } else if ($github['type'] == 'PushEvent') { |
|
256 | + $message = sprintf( |
|
257 | + 'Pushed some code at %s.', |
|
258 | + $githubData['repo']['name'] |
|
259 | + ); |
|
260 | + $messageLong = sprintf( |
|
261 | + "<p>Pushed some code at <a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a>.</p>\n", |
|
262 | + $githubData['payload']['ref'], |
|
263 | + "https://github.com/{$githubData['repo']['name']}", |
|
264 | + $githubData['repo']['name'], |
|
265 | + $githubData['repo']['name'] |
|
266 | + ); |
|
267 | + $messageLong .= "<ul>\n"; |
|
268 | + foreach ($githubData['payload']['commits'] as $commit) { |
|
269 | + $messageShort = $commit['message']; |
|
270 | + $messageShort = strtok($messageShort, "\n"); |
|
271 | + if (strlen($messageShort) > 72) { |
|
272 | + $messageShort = wordwrap($messageShort, 65); |
|
273 | + $messageShort = strtok($messageShort, "\n"); |
|
274 | + $messageShort .= '...'; |
|
275 | + } |
|
276 | + $messageLong .= sprintf( |
|
277 | + "<li><a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a> %s.</p>\n", |
|
278 | + "https://github.com/{$githubData['repo']['name']}/commit/{$commit['sha']}", |
|
279 | + substr($commit['sha'], 0, 7), |
|
280 | + substr($commit['sha'], 0, 7), |
|
281 | + $messageShort |
|
282 | + ); |
|
283 | + } |
|
284 | + $messageLong .= "</ul>"; |
|
285 | + } |
|
286 | + |
|
287 | + $activityRepository->insertActivity( |
|
288 | + $message, |
|
289 | + $messageLong, |
|
290 | + (new DateTime($github['datetime'])), |
|
291 | + [], |
|
292 | + 'git', |
|
293 | + $github['id'] |
|
294 | + ); |
|
295 | 295 | } |
296 | 296 | |
297 | 297 | // books |
@@ -300,46 +300,46 @@ discard block |
||
300 | 300 | |
301 | 301 | $lastGoodreadActivity = $activityRepository->getActivityLastUpdateByType('book'); |
302 | 302 | if ($lastGoodreadActivity === false) { |
303 | - $lastGoodreadActivityDateTime = new DateTime('2010-08-28'); |
|
303 | + $lastGoodreadActivityDateTime = new DateTime('2010-08-28'); |
|
304 | 304 | } else { |
305 | - $lastGoodreadActivityDateTime = new DateTime($lastGoodreadActivity['updated_at']); |
|
306 | - $lastGoodreadActivityDateTime->modify('-5 days'); |
|
305 | + $lastGoodreadActivityDateTime = new DateTime($lastGoodreadActivity['updated_at']); |
|
306 | + $lastGoodreadActivityDateTime->modify('-5 days'); |
|
307 | 307 | } |
308 | 308 | $newGoodreadActivity = $goodreadRepository->getGoodreadsUpdatedSince($lastGoodreadActivityDateTime); |
309 | 309 | foreach ($newGoodreadActivity as $goodread) { |
310 | - $uniqueGoodreadCheck = $activityRepository->getActivityByTypeId('book', $goodread['id']); |
|
311 | - if ($uniqueGoodreadCheck !== false) { |
|
312 | - continue; |
|
313 | - } |
|
314 | - |
|
315 | - $goodreadData = json_decode($goodread['metadata'], true); |
|
316 | - |
|
317 | - if (empty($goodreadData['user_read_at'])) { |
|
318 | - continue; |
|
319 | - } |
|
320 | - |
|
321 | - $message = sprintf( |
|
322 | - 'Read %s by %s.', |
|
323 | - $goodreadData['title'], |
|
324 | - $goodreadData['author_name'] |
|
325 | - ); |
|
326 | - if (isset($goodreadData['book_large_image_url'])) { |
|
327 | - $messageLong = sprintf( |
|
328 | - "<img alt=\"Goodreads | %s\" src=\"%s\" />\n", |
|
329 | - $goodreadData['title'], |
|
330 | - $goodreadData['book_large_image_url'] |
|
331 | - ); |
|
332 | - } |
|
333 | - $messageLong .= "<p>{$message}</p>"; |
|
334 | - |
|
335 | - $activityRepository->insertActivity( |
|
336 | - $message, |
|
337 | - $messageLong, |
|
338 | - (new DateTime($goodread['datetime'])), |
|
339 | - [], |
|
340 | - 'book', |
|
341 | - $goodread['id'] |
|
342 | - ); |
|
310 | + $uniqueGoodreadCheck = $activityRepository->getActivityByTypeId('book', $goodread['id']); |
|
311 | + if ($uniqueGoodreadCheck !== false) { |
|
312 | + continue; |
|
313 | + } |
|
314 | + |
|
315 | + $goodreadData = json_decode($goodread['metadata'], true); |
|
316 | + |
|
317 | + if (empty($goodreadData['user_read_at'])) { |
|
318 | + continue; |
|
319 | + } |
|
320 | + |
|
321 | + $message = sprintf( |
|
322 | + 'Read %s by %s.', |
|
323 | + $goodreadData['title'], |
|
324 | + $goodreadData['author_name'] |
|
325 | + ); |
|
326 | + if (isset($goodreadData['book_large_image_url'])) { |
|
327 | + $messageLong = sprintf( |
|
328 | + "<img alt=\"Goodreads | %s\" src=\"%s\" />\n", |
|
329 | + $goodreadData['title'], |
|
330 | + $goodreadData['book_large_image_url'] |
|
331 | + ); |
|
332 | + } |
|
333 | + $messageLong .= "<p>{$message}</p>"; |
|
334 | + |
|
335 | + $activityRepository->insertActivity( |
|
336 | + $message, |
|
337 | + $messageLong, |
|
338 | + (new DateTime($goodread['datetime'])), |
|
339 | + [], |
|
340 | + 'book', |
|
341 | + $goodread['id'] |
|
342 | + ); |
|
343 | 343 | } |
344 | 344 | |
345 | 345 | |
@@ -348,118 +348,118 @@ discard block |
||
348 | 348 | |
349 | 349 | $lastTwitterActivity = $activityRepository->getActivityLastUpdateByType('twitter'); |
350 | 350 | if ($lastTwitterActivity === false) { |
351 | - $lastTwitterActivityDateTime = new DateTime('2010-03-10'); |
|
351 | + $lastTwitterActivityDateTime = new DateTime('2010-03-10'); |
|
352 | 352 | } else { |
353 | - $lastTwitterActivityDateTime = new DateTime($lastTwitterActivity['updated_at']); |
|
354 | - $lastTwitterActivityDateTime->modify('-5 days'); |
|
353 | + $lastTwitterActivityDateTime = new DateTime($lastTwitterActivity['updated_at']); |
|
354 | + $lastTwitterActivityDateTime->modify('-5 days'); |
|
355 | 355 | } |
356 | 356 | $newTwitterActivity = $twitterRepository->getTwittersUpdatedSince($lastTwitterActivityDateTime); |
357 | 357 | foreach ($newTwitterActivity as $twitter) { |
358 | - $twitterData = json_decode($twitter['metadata'], true); |
|
359 | - |
|
360 | - $uniqueTwitterCheck = $activityRepository->getActivityByTypeId('twitter', $twitter['id']); |
|
361 | - if ($uniqueTwitterCheck !== false) { |
|
362 | - $metadata = []; |
|
363 | - if ($twitterData['favorite_count'] > 0) { |
|
364 | - $metadata['favorites'] = $twitterData['favorite_count']; |
|
365 | - } |
|
366 | - if ($twitterData['retweet_count'] > 0) { |
|
367 | - $metadata['retweets'] = $twitterData['retweet_count']; |
|
368 | - } |
|
369 | - |
|
370 | - $activityRepository->updateActivityMetadata($twitter['id'], $metadata); |
|
371 | - continue; |
|
372 | - } |
|
373 | - |
|
374 | - if ( |
|
375 | - ($twitterData['in_reply_to_user_id'] != null || substr($twitterData['text'], 0, 1) === '@') && |
|
376 | - $twitterData['favorite_count'] == 0 && |
|
377 | - $twitterData['retweet_count'] == 0 |
|
378 | - ) { |
|
379 | - continue; |
|
380 | - } |
|
381 | - |
|
382 | - $message = "Tweeted | {$twitterData['text']}"; |
|
383 | - $message = trim(preg_replace('/\s+/', ' ', $message)); |
|
384 | - $message = mb_convert_encoding($message, 'HTML-ENTITIES', 'UTF-8'); |
|
385 | - |
|
386 | - $entityHolder = []; |
|
387 | - foreach ($twitterData['entities'] as $entityType => $entities) { |
|
388 | - foreach ($entities as $entity) { |
|
389 | - if ($entityType == 'hashtags') { |
|
390 | - $replace = sprintf( |
|
391 | - '<a href="https://twitter.com/search?q=%%23%s&src=hash" rel="nofollow" target="_blank">#%s</a>', |
|
392 | - $entity['text'], |
|
393 | - $entity['text'] |
|
394 | - ); |
|
395 | - } else if ($entityType == 'urls') { |
|
396 | - $replace = sprintf( |
|
397 | - '<a href="%s" rel="nofollow" target="_blank" title="%s">%s</a>', |
|
398 | - $entity['url'], |
|
399 | - $entity['expanded_url'], |
|
400 | - $entity['display_url'] |
|
401 | - ); |
|
402 | - } else if ($entityType == 'user_mentions') { |
|
403 | - $replace = sprintf( |
|
404 | - '<a href="https://twitter.com/%s" rel="nofollow" target="_blank" title="Twitter | %s">@%s</a>', |
|
405 | - strtolower($entity['screen_name']), |
|
406 | - $entity['name'], |
|
407 | - $entity['screen_name'] |
|
408 | - ); |
|
409 | - } else if ($entityType == 'media') { |
|
410 | - $replace = sprintf( |
|
411 | - "<a href=\"%s\" rel=\"nofollow\" target=\"_blank\" title=\"%s\">\n" . |
|
412 | - "<img src=\"%s:%s\" alt=\"%s\" height=\"%s\" width=\"%s\" />\n" . |
|
413 | - "</a>", |
|
414 | - $entity['url'], |
|
415 | - $entity['display_url'], |
|
416 | - $entity['media_url'], |
|
417 | - 'large', |
|
418 | - $entity['display_url'], |
|
419 | - $entity['sizes']['large']['h'], |
|
420 | - $entity['sizes']['large']['w'] |
|
421 | - ); |
|
422 | - } else { |
|
423 | - continue 2; |
|
424 | - } |
|
425 | - |
|
426 | - $entityHolder[$entity['indices'][0]] = [ |
|
427 | - 'start' => $entity['indices'][0], |
|
428 | - 'end' => $entity['indices'][1], |
|
429 | - 'replace' => $replace, |
|
430 | - ]; |
|
431 | - } |
|
432 | - } |
|
433 | - |
|
434 | - $messageLong = $twitterData['text']; |
|
435 | - krsort($entityHolder); |
|
436 | - foreach($entityHolder as $entity) |
|
437 | - { |
|
438 | - $messageLong = |
|
439 | - mb_substr($messageLong, 0, $entity['start']) . |
|
440 | - $entity['replace'] . |
|
441 | - mb_substr($messageLong, $entity['end'], null, 'UTF-8'); |
|
442 | - } |
|
443 | - $messageLong = mb_convert_encoding($messageLong, 'HTML-ENTITIES', 'UTF-8'); |
|
444 | - $messageLong = nl2br($messageLong, true); |
|
445 | - $messageLong = "<p>{$messageLong}</p>"; |
|
446 | - |
|
447 | - $metadata = []; |
|
448 | - if ($twitterData['favorite_count'] > 0) { |
|
449 | - $metadata['favorites'] = $twitterData['favorite_count']; |
|
450 | - } |
|
451 | - if ($twitterData['retweet_count'] > 0) { |
|
452 | - $metadata['retweets'] = $twitterData['retweet_count']; |
|
453 | - } |
|
454 | - |
|
455 | - $activityRepository->insertActivity( |
|
456 | - $message, |
|
457 | - $messageLong, |
|
458 | - (new DateTime($twitter['datetime'])), |
|
459 | - $metadata, |
|
460 | - 'twitter', |
|
461 | - $twitter['id'] |
|
462 | - ); |
|
358 | + $twitterData = json_decode($twitter['metadata'], true); |
|
359 | + |
|
360 | + $uniqueTwitterCheck = $activityRepository->getActivityByTypeId('twitter', $twitter['id']); |
|
361 | + if ($uniqueTwitterCheck !== false) { |
|
362 | + $metadata = []; |
|
363 | + if ($twitterData['favorite_count'] > 0) { |
|
364 | + $metadata['favorites'] = $twitterData['favorite_count']; |
|
365 | + } |
|
366 | + if ($twitterData['retweet_count'] > 0) { |
|
367 | + $metadata['retweets'] = $twitterData['retweet_count']; |
|
368 | + } |
|
369 | + |
|
370 | + $activityRepository->updateActivityMetadata($twitter['id'], $metadata); |
|
371 | + continue; |
|
372 | + } |
|
373 | + |
|
374 | + if ( |
|
375 | + ($twitterData['in_reply_to_user_id'] != null || substr($twitterData['text'], 0, 1) === '@') && |
|
376 | + $twitterData['favorite_count'] == 0 && |
|
377 | + $twitterData['retweet_count'] == 0 |
|
378 | + ) { |
|
379 | + continue; |
|
380 | + } |
|
381 | + |
|
382 | + $message = "Tweeted | {$twitterData['text']}"; |
|
383 | + $message = trim(preg_replace('/\s+/', ' ', $message)); |
|
384 | + $message = mb_convert_encoding($message, 'HTML-ENTITIES', 'UTF-8'); |
|
385 | + |
|
386 | + $entityHolder = []; |
|
387 | + foreach ($twitterData['entities'] as $entityType => $entities) { |
|
388 | + foreach ($entities as $entity) { |
|
389 | + if ($entityType == 'hashtags') { |
|
390 | + $replace = sprintf( |
|
391 | + '<a href="https://twitter.com/search?q=%%23%s&src=hash" rel="nofollow" target="_blank">#%s</a>', |
|
392 | + $entity['text'], |
|
393 | + $entity['text'] |
|
394 | + ); |
|
395 | + } else if ($entityType == 'urls') { |
|
396 | + $replace = sprintf( |
|
397 | + '<a href="%s" rel="nofollow" target="_blank" title="%s">%s</a>', |
|
398 | + $entity['url'], |
|
399 | + $entity['expanded_url'], |
|
400 | + $entity['display_url'] |
|
401 | + ); |
|
402 | + } else if ($entityType == 'user_mentions') { |
|
403 | + $replace = sprintf( |
|
404 | + '<a href="https://twitter.com/%s" rel="nofollow" target="_blank" title="Twitter | %s">@%s</a>', |
|
405 | + strtolower($entity['screen_name']), |
|
406 | + $entity['name'], |
|
407 | + $entity['screen_name'] |
|
408 | + ); |
|
409 | + } else if ($entityType == 'media') { |
|
410 | + $replace = sprintf( |
|
411 | + "<a href=\"%s\" rel=\"nofollow\" target=\"_blank\" title=\"%s\">\n" . |
|
412 | + "<img src=\"%s:%s\" alt=\"%s\" height=\"%s\" width=\"%s\" />\n" . |
|
413 | + "</a>", |
|
414 | + $entity['url'], |
|
415 | + $entity['display_url'], |
|
416 | + $entity['media_url'], |
|
417 | + 'large', |
|
418 | + $entity['display_url'], |
|
419 | + $entity['sizes']['large']['h'], |
|
420 | + $entity['sizes']['large']['w'] |
|
421 | + ); |
|
422 | + } else { |
|
423 | + continue 2; |
|
424 | + } |
|
425 | + |
|
426 | + $entityHolder[$entity['indices'][0]] = [ |
|
427 | + 'start' => $entity['indices'][0], |
|
428 | + 'end' => $entity['indices'][1], |
|
429 | + 'replace' => $replace, |
|
430 | + ]; |
|
431 | + } |
|
432 | + } |
|
433 | + |
|
434 | + $messageLong = $twitterData['text']; |
|
435 | + krsort($entityHolder); |
|
436 | + foreach($entityHolder as $entity) |
|
437 | + { |
|
438 | + $messageLong = |
|
439 | + mb_substr($messageLong, 0, $entity['start']) . |
|
440 | + $entity['replace'] . |
|
441 | + mb_substr($messageLong, $entity['end'], null, 'UTF-8'); |
|
442 | + } |
|
443 | + $messageLong = mb_convert_encoding($messageLong, 'HTML-ENTITIES', 'UTF-8'); |
|
444 | + $messageLong = nl2br($messageLong, true); |
|
445 | + $messageLong = "<p>{$messageLong}</p>"; |
|
446 | + |
|
447 | + $metadata = []; |
|
448 | + if ($twitterData['favorite_count'] > 0) { |
|
449 | + $metadata['favorites'] = $twitterData['favorite_count']; |
|
450 | + } |
|
451 | + if ($twitterData['retweet_count'] > 0) { |
|
452 | + $metadata['retweets'] = $twitterData['retweet_count']; |
|
453 | + } |
|
454 | + |
|
455 | + $activityRepository->insertActivity( |
|
456 | + $message, |
|
457 | + $messageLong, |
|
458 | + (new DateTime($twitter['datetime'])), |
|
459 | + $metadata, |
|
460 | + 'twitter', |
|
461 | + $twitter['id'] |
|
462 | + ); |
|
463 | 463 | } |
464 | 464 | |
465 | 465 | // youtube |
@@ -468,39 +468,39 @@ discard block |
||
468 | 468 | |
469 | 469 | $lastYouTubeActivity = $activityRepository->getActivityLastUpdateByType('youtube'); |
470 | 470 | if ($lastYouTubeActivity === false) { |
471 | - $lastYouTubeActivityDateTime = new DateTime('2010-08-28'); |
|
471 | + $lastYouTubeActivityDateTime = new DateTime('2010-08-28'); |
|
472 | 472 | } else { |
473 | - $lastYouTubeActivityDateTime = new DateTime($lastYouTubeActivity['updated_at']); |
|
474 | - $lastYouTubeActivityDateTime->modify('-5 days'); |
|
473 | + $lastYouTubeActivityDateTime = new DateTime($lastYouTubeActivity['updated_at']); |
|
474 | + $lastYouTubeActivityDateTime->modify('-5 days'); |
|
475 | 475 | } |
476 | 476 | $newYouTubeActivity = $youTubeRepository->getYouTubesUpdatedSince($lastYouTubeActivityDateTime); |
477 | 477 | foreach ($newYouTubeActivity as $youTube) { |
478 | - $uniqueYouTubeCheck = $activityRepository->getActivityByTypeId('youtube', $youTube['id']); |
|
479 | - if ($uniqueYouTubeCheck !== false) { |
|
480 | - continue; |
|
481 | - } |
|
482 | - |
|
483 | - $youTubeData = json_decode($youTube['metadata'], true); |
|
484 | - |
|
485 | - $message = sprintf( |
|
486 | - 'Favorited %s on YouTube.', |
|
487 | - $youTubeData['snippet']['title'] |
|
488 | - ); |
|
489 | - $messageLong = sprintf( |
|
490 | - "<iframe src=\"%s\" frameborder=\"0\" allowfullscreen></iframe>\n" . |
|
491 | - "<p>Favorited <a href=\"%s\" target=\"_blank\" title=\"YouTube | %s\">%s</a> on YouTube.</p>", |
|
492 | - "https://www.youtube.com/embed/{$youTubeData['contentDetails']['videoId']}", |
|
493 | - "https://youtu.be/{$youTubeData['contentDetails']['videoId']}", |
|
494 | - $youTubeData['snippet']['title'], |
|
495 | - $youTubeData['snippet']['title'] |
|
496 | - ); |
|
497 | - |
|
498 | - $activityRepository->insertActivity( |
|
499 | - $message, |
|
500 | - $messageLong, |
|
501 | - (new DateTime($youTube['datetime'])), |
|
502 | - [], |
|
503 | - 'youtube', |
|
504 | - $youTube['id'] |
|
505 | - ); |
|
478 | + $uniqueYouTubeCheck = $activityRepository->getActivityByTypeId('youtube', $youTube['id']); |
|
479 | + if ($uniqueYouTubeCheck !== false) { |
|
480 | + continue; |
|
481 | + } |
|
482 | + |
|
483 | + $youTubeData = json_decode($youTube['metadata'], true); |
|
484 | + |
|
485 | + $message = sprintf( |
|
486 | + 'Favorited %s on YouTube.', |
|
487 | + $youTubeData['snippet']['title'] |
|
488 | + ); |
|
489 | + $messageLong = sprintf( |
|
490 | + "<iframe src=\"%s\" frameborder=\"0\" allowfullscreen></iframe>\n" . |
|
491 | + "<p>Favorited <a href=\"%s\" target=\"_blank\" title=\"YouTube | %s\">%s</a> on YouTube.</p>", |
|
492 | + "https://www.youtube.com/embed/{$youTubeData['contentDetails']['videoId']}", |
|
493 | + "https://youtu.be/{$youTubeData['contentDetails']['videoId']}", |
|
494 | + $youTubeData['snippet']['title'], |
|
495 | + $youTubeData['snippet']['title'] |
|
496 | + ); |
|
497 | + |
|
498 | + $activityRepository->insertActivity( |
|
499 | + $message, |
|
500 | + $messageLong, |
|
501 | + (new DateTime($youTube['datetime'])), |
|
502 | + [], |
|
503 | + 'youtube', |
|
504 | + $youTube['id'] |
|
505 | + ); |
|
506 | 506 | } |