| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  | <?php | 
					
						
							|  |  |  | /* | 
					
						
							|  |  |  |  * StatusNet - the distributed open-source microblogging tool | 
					
						
							|  |  |  |  * Copyright (C) 2010, StatusNet, Inc. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * This program is free software: you can redistribute it and/or modify | 
					
						
							|  |  |  |  * it under the terms of the GNU Affero General Public License as published by | 
					
						
							|  |  |  |  * the Free Software Foundation, either version 3 of the License, or | 
					
						
							|  |  |  |  * (at your option) any later version. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * This program is distributed in the hope that it will be useful, | 
					
						
							|  |  |  |  * but WITHOUT ANY WARRANTY; without even the implied warranty of | 
					
						
							|  |  |  |  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | 
					
						
							|  |  |  |  * GNU Affero General Public License for more details. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * You should have received a copy of the GNU Affero General Public License | 
					
						
							|  |  |  |  * along with this program.  If not, see <http://www.gnu.org/licenses/>. | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /** | 
					
						
							|  |  |  |  * Send a Salmon notification in the background. | 
					
						
							|  |  |  |  * @package OStatusPlugin | 
					
						
							|  |  |  |  * @author Brion Vibber <brion@status.net> | 
					
						
							|  |  |  |  */ | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  | class SalmonQueueHandler extends QueueHandler | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  | { | 
					
						
							|  |  |  |     function transport() | 
					
						
							|  |  |  |     { | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |         return 'salmon'; | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |     } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     function handle($data) | 
					
						
							|  |  |  |     { | 
					
						
							|  |  |  |         assert(is_array($data)); | 
					
						
							|  |  |  |         assert(is_string($data['salmonuri'])); | 
					
						
							|  |  |  |         assert(is_string($data['entry'])); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-02-26 14:21:21 -05:00
										 |  |  |         $actor = Profile::staticGet($data['actor']); | 
					
						
							|  |  |  |          | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |         $salmon = new Salmon(); | 
					
						
							| 
									
										
										
										
											2010-02-26 14:21:21 -05:00
										 |  |  |         $salmon->post($data['salmonuri'], $data['entry'], $actor); | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  | 
 | 
					
						
							|  |  |  |         // @fixme detect failure and attempt to resend
 | 
					
						
							|  |  |  |         return true; | 
					
						
							|  |  |  |     } | 
					
						
							|  |  |  | } |