| 
									
										
										
										
											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/>. | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /** | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |  * @package QueueHandler | 
					
						
							|  |  |  |  * @maintainer Brion Vibber <brion@status.net> | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |  */ | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  | 
 | 
					
						
							|  |  |  | class ProfileQueueHandler extends QueueHandler | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |     function transport() | 
					
						
							|  |  |  |     { | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |         return 'profile'; | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |     } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |     function handle($profile) | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |     { | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |         if (!($profile instanceof Profile)) { | 
					
						
							|  |  |  |             common_log(LOG_ERR, "Got a bogus profile, not broadcasting"); | 
					
						
							|  |  |  |             return true; | 
					
						
							|  |  |  |         } | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |         if (Event::handle('StartBroadcastProfile', array($profile))) { | 
					
						
							|  |  |  |             require_once(INSTALLDIR.'/lib/omb.php'); | 
					
						
							| 
									
										
										
										
											2010-02-25 21:06:16 -08:00
										 |  |  |             try { | 
					
						
							|  |  |  |                 omb_broadcast_profile($profile); | 
					
						
							|  |  |  |             } catch (Exception $e) { | 
					
						
							|  |  |  |                 common_log(LOG_ERR, "Failed sending OMB profiles: " . $e->getMessage()); | 
					
						
							|  |  |  |             } | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  |         } | 
					
						
							|  |  |  |         Event::handle('EndBroadcastProfile', array($profile)); | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  |         return true; | 
					
						
							|  |  |  |     } | 
					
						
							| 
									
										
										
										
											2010-02-24 20:36:36 +00:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-02-24 02:19:13 +00:00
										 |  |  | } |