2013-02-26 01:09:40 +00:00
< ? php /** @file */
2011-08-26 14:29:22 +00:00
2011-01-28 13:04:18 +00:00
require_once ( " boot.php " );
2011-10-21 10:33:34 +00:00
require_once ( 'include/queue_fn.php' );
2012-02-24 06:11:26 +00:00
require_once ( 'include/html2plain.php' );
2011-01-28 13:04:18 +00:00
2011-09-04 12:07:25 +00:00
/*
* This file was at one time responsible for doing all deliveries , but this caused
* big problems on shared hosting systems , where the process might get killed by the
* hosting provider and nothing would get delivered .
* It now only delivers one message under certain cases , and invokes a queued
* delivery mechanism ( include / deliver . php ) to deliver individual contacts at
* controlled intervals .
* This has a much better chance of surviving random processes getting killed
* by the hosting provider .
2013-01-05 01:16:35 +00:00
*
* The basic flow is :
* Identify the type of message
* Collect any information that needs to be sent
* Convert it into a suitable generic format for sending
* Figure out who the recipients are and if we need to relay
* through a conversation owner
* Once we know what recipients are involved , collect a list of
* destination sites
* Build and store a queue item for each unique site and invoke
* a delivery process for each site or a small number of sites ( 1 - 3 )
* and add a slight delay between each delivery invocation if desired ( usually )
*
2011-09-04 12:07:25 +00:00
*/
2012-08-12 01:54:23 +00:00
/*
* The notifier is typically called with :
*
* proc_run ( 'php' , " include/notifier.php " , COMMAND , ITEM_ID );
*
* where COMMAND is one of the following :
*
* activity ( in diaspora . php , dfrn_confirm . php , profiles . php )
* comment - import ( in diaspora . php , items . php )
* comment - new ( in item . php )
* drop ( in diaspora . php , items . php , photos . php )
* edit_post ( in item . php )
* event ( in events . php )
* expire ( in items . php )
* like ( in like . php , poke . php )
* mail ( in message . php )
* tag ( in photos . php , poke . php , tagger . php )
* tgroup ( in items . php )
* wall - new ( in photos . php , item . php )
*
* and ITEM_ID is the id of the item in the database that needs to be sent to others .
2012-11-13 04:59:18 +00:00
*
* ZOT
2015-12-17 06:42:33 +00:00
* permission_create abook_id
2012-11-30 02:15:13 +00:00
* permission_update abook_id
2013-06-14 23:54:58 +00:00
* refresh_all channel_id
2013-09-18 03:50:09 +00:00
* purge_all channel_id
2013-08-15 03:09:02 +00:00
* expire channel_id
2012-11-28 01:09:01 +00:00
* relay item_id ( item was relayed to owner , we will deliver it as owner )
2015-12-10 02:30:30 +00:00
* single_activity item_id ( deliver to a singleton network from the appropriate clone )
* single_mail mail_id ( deliver to a singleton network from the appropriate clone )
2014-09-15 05:19:19 +00:00
* location channel_id
2014-10-31 02:15:03 +00:00
* request channel_id xchan_hash message_id
2015-01-29 00:52:17 +00:00
* rating xlink_id
2012-11-13 04:59:18 +00:00
*
2012-08-12 01:54:23 +00:00
*/
2012-11-13 04:59:18 +00:00
require_once ( 'include/cli_startup.php' );
require_once ( 'include/zot.php' );
2013-01-03 07:07:46 +00:00
require_once ( 'include/queue_fn.php' );
2015-12-16 22:47:30 +00:00
require_once ( 'include/session.php' );
require_once ( 'include/datetime.php' );
require_once ( 'include/items.php' );
require_once ( 'include/bbcode.php' );
require_once ( 'include/identity.php' );
require_once ( 'include/Contact.php' );
2012-08-12 01:54:23 +00:00
2011-01-28 13:04:18 +00:00
function notifier_run ( $argv , $argc ){
2012-11-13 04:59:18 +00:00
cli_startup ();
$a = get_app ();
2010-09-26 23:30:21 +00:00
2012-11-06 07:52:01 +00:00
2010-08-18 01:44:13 +00:00
if ( $argc < 3 )
2011-01-24 21:01:56 +00:00
return ;
2010-08-17 03:47:40 +00:00
2012-05-03 23:55:03 +00:00
logger ( 'notifier: invoked: ' . print_r ( $argv , true ), LOGGER_DEBUG );
2010-11-25 10:53:19 +00:00
2010-08-17 03:47:40 +00:00
$cmd = $argv [ 1 ];
2010-07-09 00:49:41 +00:00
2012-11-13 04:59:18 +00:00
$item_id = $argv [ 2 ];
$extra = (( $argc > 3 ) ? $argv [ 3 ] : null );
2012-11-15 01:02:30 +00:00
if ( ! $item_id )
return ;
2014-04-11 22:08:40 +00:00
$sys = get_sys_channel ();
2015-10-16 01:52:04 +00:00
$deliveries = array ();
$dead_hubs = array ();
$dh = q ( " select site_url from site where site_dead = 1 " );
2015-11-16 02:12:53 +00:00
if ( $dh ) {
2015-10-16 01:52:04 +00:00
foreach ( $dh as $dead ) {
$dead_hubs [] = $dead [ 'site_url' ];
}
}
2014-10-31 02:15:03 +00:00
$request = false ;
2011-08-26 14:29:22 +00:00
$mail = false ;
2011-02-11 11:17:16 +00:00
$top_level = false ;
2014-09-15 05:19:19 +00:00
$location = false ;
2010-07-08 14:03:25 +00:00
$recipients = array ();
2010-11-01 03:36:59 +00:00
$url_recipients = array ();
2011-08-17 03:43:34 +00:00
$normal_mode = true ;
2013-06-14 23:54:58 +00:00
$packet_type = 'undefined' ;
2010-07-09 00:49:41 +00:00
2011-08-17 03:43:34 +00:00
if ( $cmd === 'mail' ) {
$normal_mode = false ;
2011-08-26 14:29:22 +00:00
$mail = true ;
2012-12-06 00:44:07 +00:00
$private = true ;
2010-07-30 13:09:20 +00:00
$message = q ( " SELECT * FROM `mail` WHERE `id` = %d LIMIT 1 " ,
intval ( $item_id )
);
2014-09-23 11:34:35 +00:00
if ( ! $message ) {
2011-01-28 13:04:18 +00:00
return ;
2011-01-24 21:01:56 +00:00
}
2012-12-06 00:44:07 +00:00
xchan_mail_query ( $message [ 0 ]);
$uid = $message [ 0 ][ 'channel_id' ];
2015-01-09 00:02:15 +00:00
$recipients [] = $message [ 0 ][ 'from_xchan' ]; // include clones
2012-12-06 00:44:07 +00:00
$recipients [] = $message [ 0 ][ 'to_xchan' ];
2010-07-30 13:09:20 +00:00
$item = $message [ 0 ];
2012-12-06 00:44:07 +00:00
$encoded_item = encode_mail ( $item );
2012-12-19 00:29:57 +00:00
2012-12-06 00:44:07 +00:00
$s = q ( " select * from channel where channel_id = %d limit 1 " ,
intval ( $item [ 'channel_id' ])
);
if ( $s )
$channel = $s [ 0 ];
2012-12-19 00:29:57 +00:00
2014-10-31 02:15:03 +00:00
}
elseif ( $cmd === 'request' ) {
$channel_id = $item_id ;
$xchan = $argv [ 3 ];
$request_message_id = $argv [ 4 ];
$s = q ( " select * from channel where channel_id = %d limit 1 " ,
intval ( $channel_id )
);
if ( $s )
$channel = $s [ 0 ];
$private = true ;
$recipients [] = $xchan ;
$packet_type = 'request' ;
$normal_mode = false ;
2010-07-30 13:09:20 +00:00
}
2015-12-17 06:42:33 +00:00
elseif ( $cmd == 'permission_update' || $cmd == 'permission_create' ) {
// Get the (single) recipient
$r = q ( " select * from abook left join xchan on abook_xchan = xchan_hash where abook_id = %d and abook_self = 0 " ,
intval ( $item_id )
2011-03-16 00:31:49 +00:00
);
2015-12-17 06:42:33 +00:00
if ( $r ) {
$uid = $r [ 0 ][ 'abook_channel' ];
// Get the sender
$channel = channelx_by_n ( $uid );
if ( $channel ) {
$perm_update = array ( 'sender' => $channel , 'recipient' => $r [ 0 ], 'success' => false , 'deliveries' => '' );
2013-08-15 03:09:02 +00:00
2015-12-17 06:42:33 +00:00
if ( $cmd == 'permission_create' )
call_hooks ( 'permissions_create' , $perm_update );
else
call_hooks ( 'permissions_update' , $perm_update );
2011-08-26 14:29:22 +00:00
2015-12-17 06:42:33 +00:00
if ( $perm_update [ 'success' ]) {
if ( $perm_update [ 'deliveries' ]) {
$deliveries [] = $perm_update [ 'deliveries' ];
do_delivery ( $deliveries );
}
return ;
}
else {
$recipients [] = $r [ 0 ][ 'abook_xchan' ];
$private = false ;
$packet_type = 'refresh' ;
}
}
}
2011-06-27 02:30:57 +00:00
}
2013-06-14 23:54:58 +00:00
elseif ( $cmd === 'refresh_all' ) {
2013-06-18 09:51:43 +00:00
logger ( 'notifier: refresh_all: ' . $item_id );
2013-06-14 23:54:58 +00:00
$uid = $item_id ;
2015-12-17 06:42:33 +00:00
$channel = channelx_by_n ( $item_id );
2013-09-09 04:05:39 +00:00
$r = q ( " select abook_xchan from abook where abook_channel = %d " ,
intval ( $item_id )
2013-06-14 23:54:58 +00:00
);
if ( $r ) {
foreach ( $r as $rr ) {
$recipients [] = $rr [ 'abook_xchan' ];
}
}
$private = false ;
$packet_type = 'refresh' ;
}
2014-09-15 05:19:19 +00:00
elseif ( $cmd === 'location' ) {
logger ( 'notifier: location: ' . $item_id );
$s = q ( " select * from channel where channel_id = %d limit 1 " ,
intval ( $item_id )
);
if ( $s )
$channel = $s [ 0 ];
$uid = $item_id ;
$recipients = array ();
$r = q ( " select abook_xchan from abook where abook_channel = %d " ,
intval ( $item_id )
);
if ( $r ) {
foreach ( $r as $rr ) {
$recipients [] = $rr [ 'abook_xchan' ];
}
}
$encoded_item = array ( 'locations' => zot_encode_locations ( $channel ), 'type' => 'location' , 'encoding' => 'zot' );
$target_item = array ( 'aid' => $channel [ 'channel_account_id' ], 'uid' => $channel [ 'channel_id' ]);
$private = false ;
$packet_type = 'location' ;
$location = true ;
}
2013-09-18 03:50:09 +00:00
elseif ( $cmd === 'purge_all' ) {
logger ( 'notifier: purge_all: ' . $item_id );
$s = q ( " select * from channel where channel_id = %d limit 1 " ,
intval ( $item_id )
);
if ( $s )
$channel = $s [ 0 ];
$uid = $item_id ;
$recipients = array ();
$r = q ( " select abook_xchan from abook where abook_channel = %d " ,
intval ( $item_id )
);
if ( $r ) {
foreach ( $r as $rr ) {
$recipients [] = $rr [ 'abook_xchan' ];
}
}
$private = false ;
$packet_type = 'purge' ;
}
2010-07-30 13:09:20 +00:00
else {
2010-07-07 06:08:38 +00:00
2012-11-16 05:52:05 +00:00
// Normal items
2012-11-15 01:02:30 +00:00
2012-11-16 05:52:05 +00:00
// Fetch the target item
2012-11-28 01:09:01 +00:00
2012-11-16 05:52:05 +00:00
$r = q ( " SELECT * FROM item WHERE id = %d and parent != 0 LIMIT 1 " ,
2010-07-30 13:09:20 +00:00
intval ( $item_id )
);
2011-02-04 12:25:53 +00:00
2012-11-16 05:52:05 +00:00
if ( ! $r )
2011-01-28 13:04:18 +00:00
return ;
2012-11-28 01:09:01 +00:00
2012-11-15 01:02:30 +00:00
xchan_query ( $r );
2012-11-28 01:09:01 +00:00
2012-11-16 05:52:05 +00:00
$r = fetch_post_tags ( $r );
2011-08-17 03:43:34 +00:00
$target_item = $r [ 0 ];
2015-02-25 04:21:21 +00:00
$deleted_item = false ;
2013-01-29 03:24:36 +00:00
2015-05-19 00:20:59 +00:00
if ( intval ( $target_item [ 'item_deleted' ])) {
2013-01-29 03:24:36 +00:00
logger ( 'notifier: target item ITEM_DELETED' , LOGGER_DEBUG );
2015-02-25 04:21:21 +00:00
$deleted_item = true ;
}
2013-01-29 03:24:36 +00:00
2015-01-29 22:51:41 +00:00
if ( intval ( $target_item [ 'item_type' ]) != ITEM_TYPE_POST ) {
logger ( 'notifier: target item not forwardable: type ' . $target_item [ 'item_type' ], LOGGER_DEBUG );
return ;
}
2015-10-25 23:54:18 +00:00
if ( intval ( $target_item [ 'item_unpublished' ]) || intval ( $target_item [ 'item_delayed' ])) {
2015-01-29 22:51:41 +00:00
logger ( 'notifier: target item not published, so not forwardable' , LOGGER_DEBUG );
2013-09-02 03:11:04 +00:00
return ;
}
2013-06-16 02:31:38 +00:00
2015-04-30 04:49:43 +00:00
if ( strpos ( $target_item [ 'postopts' ], 'nodeliver' ) !== false ) {
logger ( 'notifier: target item is undeliverable' , LOGGER_DEBUG );
2013-09-02 03:11:04 +00:00
return ;
}
2013-06-16 02:31:38 +00:00
2015-06-29 23:56:18 +00:00
$s = q ( " select * from channel left join xchan on channel_hash = xchan_hash where channel_id = %d limit 1 " ,
2012-11-19 02:30:00 +00:00
intval ( $target_item [ 'uid' ])
);
2012-11-20 00:51:15 +00:00
if ( $s )
$channel = $s [ 0 ];
2012-11-19 02:30:00 +00:00
2014-03-21 08:14:51 +00:00
if ( $channel [ 'channel_hash' ] !== $target_item [ 'author_xchan' ] && $channel [ 'channel_hash' ] !== $target_item [ 'owner_xchan' ]) {
logger ( " notifier: Sending channel { $channel [ 'channel_hash' ] } is not owner { $target_item [ 'owner_xchan' ] } or author { $target_item [ 'author_xchan' ] } " );
return ;
}
2012-11-28 01:09:01 +00:00
2012-11-16 05:52:05 +00:00
if ( $target_item [ 'id' ] == $target_item [ 'parent' ]) {
$parent_item = $target_item ;
$top_level_post = true ;
}
else {
// fetch the parent item
$r = q ( " SELECT * from item where id = %d order by id asc " ,
2012-11-27 11:08:26 +00:00
intval ( $target_item [ 'parent' ])
2012-11-16 05:52:05 +00:00
);
2012-11-27 11:08:26 +00:00
2012-11-16 05:52:05 +00:00
if ( ! $r )
return ;
2015-04-24 04:13:59 +00:00
if ( strpos ( $r [ 0 ][ 'postopts' ], 'nodeliver' ) !== false ) {
logger ( 'notifier: target item is undeliverable' , LOGGER_DEBUG );
return ;
}
2012-11-16 05:52:05 +00:00
xchan_query ( $r );
$r = fetch_post_tags ( $r );
$parent_item = $r [ 0 ];
$top_level_post = false ;
}
2012-11-28 01:09:01 +00:00
2014-04-11 22:08:40 +00:00
// avoid looping of discover items 12/4/2014
if ( $sys && $parent_item [ 'uid' ] == $sys [ 'channel_id' ])
return ;
2012-11-16 05:52:05 +00:00
2012-11-16 23:53:02 +00:00
$encoded_item = encode_item ( $target_item );
2015-02-25 23:27:33 +00:00
// Send comments to the owner to re-deliver to everybody in the conversation
// We only do this if the item in question originated on this site. This prevents looping.
// To clarify, a site accepting a new comment is responsible for sending it to the owner for relay.
// Relaying should never be initiated on a post that arrived from elsewhere.
2015-02-26 00:51:39 +00:00
// We should normally be able to rely on ITEM_ORIGIN, but start_delivery_chain() incorrectly set this
// flag on comments for an extended period. So we'll also call comment_local_origin() which looks at
// the hostname in the message_id and provides a second (fallback) opinion.
2015-04-24 02:49:41 +00:00
$relay_to_owner = ((( ! $top_level_post ) && ( intval ( $target_item [ 'item_origin' ])) && comment_local_origin ( $target_item )) ? true : false );
2013-01-04 11:36:32 +00:00
2015-05-27 04:00:27 +00:00
2013-01-14 02:35:12 +00:00
$uplink = false ;
2013-01-04 11:36:32 +00:00
// $cmd === 'relay' indicates the owner is sending it to the original recipients
// don't allow the item in the relay command to relay to owner under any circumstances, it will loop
2013-01-25 00:44:10 +00:00
logger ( 'notifier: relay_to_owner: ' . (( $relay_to_owner ) ? 'true' : 'false' ), LOGGER_DATA );
logger ( 'notifier: top_level_post: ' . (( $top_level_post ) ? 'true' : 'false' ), LOGGER_DATA );
2013-01-04 11:36:32 +00:00
2013-01-14 02:35:12 +00:00
// tag_deliver'd post which needs to be sent back to the original author
2013-01-05 01:04:44 +00:00
2015-01-23 01:41:16 +00:00
if (( $cmd === 'uplink' ) && intval ( $parent_item [ 'item_uplink' ]) && ( ! $top_level_post )) {
2013-10-14 01:36:28 +00:00
logger ( 'notifier: uplink' );
$uplink = true ;
2013-01-14 02:35:12 +00:00
}
if (( $relay_to_owner || $uplink ) && ( $cmd !== 'relay' )) {
2012-11-16 05:52:05 +00:00
logger ( 'notifier: followup relay' , LOGGER_DEBUG );
2013-10-14 01:36:28 +00:00
$recipients = array (( $uplink ) ? $parent_item [ 'source_xchan' ] : $parent_item [ 'owner_xchan' ]);
2012-11-19 03:19:16 +00:00
$private = true ;
2012-11-16 23:53:02 +00:00
if ( ! $encoded_item [ 'flags' ])
$encoded_item [ 'flags' ] = array ();
$encoded_item [ 'flags' ][] = 'relay' ;
2012-11-16 05:52:05 +00:00
}
else {
logger ( 'notifier: normal distribution' , LOGGER_DEBUG );
2012-11-28 01:09:01 +00:00
if ( $cmd === 'relay' )
logger ( 'notifier: owner relay' );
2013-01-14 02:35:12 +00:00
// if our parent is a tag_delivery recipient, uplink to the original author causing
// a delivery fork.
2015-01-23 01:41:16 +00:00
if ( intval ( $parent_item [ 'item_uplink' ]) && ( ! $top_level_post ) && ( $cmd !== 'uplink' )) {
2013-01-14 02:35:12 +00:00
logger ( 'notifier: uplinking this item' );
proc_run ( 'php' , 'include/notifier.php' , 'uplink' , $item_id );
}
2012-11-19 03:19:16 +00:00
$private = false ;
$recipients = collect_recipients ( $parent_item , $private );
2012-11-16 05:52:05 +00:00
// FIXME add any additional recipients such as mentions, etc.
2012-11-16 23:53:02 +00:00
// don't send deletions onward for other people's stuff
// TODO verify this is needed - copied logic from same place in old code
2012-11-16 05:52:05 +00:00
2015-01-23 05:04:54 +00:00
if ( intval ( $target_item [ 'item_deleted' ]) && ( ! intval ( $target_item [ 'item_wall' ]))) {
2012-11-16 23:53:02 +00:00
logger ( 'notifier: ignoring delete notification for non-wall item' );
return ;
}
}
2012-11-16 05:52:05 +00:00
2012-12-06 00:44:07 +00:00
}
2012-11-16 05:52:05 +00:00
2014-08-26 03:57:10 +00:00
$walltowall = (( $top_level_post && $channel [ 'xchan_hash' ] === $target_item [ 'author_xchan' ]) ? true : false );
2012-12-06 00:44:07 +00:00
// Generic delivery section, we have an encoded item and recipients
// Now start the delivery process
2012-11-16 05:52:05 +00:00
2013-08-01 21:27:40 +00:00
$x = $encoded_item ;
$x [ 'title' ] = 'private' ;
$x [ 'body' ] = 'private' ;
logger ( 'notifier: encoded item: ' . print_r ( $x , true ), LOGGER_DATA );
2012-11-19 03:19:16 +00:00
2012-12-06 00:44:07 +00:00
stringify_array_elms ( $recipients );
if ( ! $recipients )
return ;
2012-11-28 01:09:01 +00:00
2013-07-22 00:19:16 +00:00
// logger('notifier: recipients: ' . print_r($recipients,true));
2012-12-06 00:44:07 +00:00
2013-07-22 00:19:16 +00:00
$env_recips = (( $private ) ? array () : null );
2014-08-23 04:37:08 +00:00
$details = q ( " select xchan_hash, xchan_instance_url, xchan_network, xchan_addr, xchan_guid, xchan_guid_sig from xchan where xchan_hash in ( " . implode ( ',' , $recipients ) . " ) " );
2013-07-22 00:19:16 +00:00
$recip_list = array ();
if ( $details ) {
foreach ( $details as $d ) {
2013-11-21 23:58:42 +00:00
2013-07-22 00:19:16 +00:00
$recip_list [] = $d [ 'xchan_addr' ] . ' (' . $d [ 'xchan_hash' ] . ')' ;
if ( $private )
2014-08-27 01:58:48 +00:00
$env_recips [] = array ( 'guid' => $d [ 'xchan_guid' ], 'guid_sig' => $d [ 'xchan_guid_sig' ], 'hash' => $d [ 'xchan_hash' ]);
2015-06-29 23:56:18 +00:00
if ( $d [ 'xchan_network' ] === 'mail' && $normal_mode ) {
$delivery_options = get_xconfig ( $d [ 'xchan_hash' ], 'system' , 'delivery_mode' );
if ( ! $delivery_options )
format_and_send_email ( $channel , $d , $target_item );
}
2011-08-26 14:29:22 +00:00
}
2012-12-06 00:44:07 +00:00
}
2011-08-26 03:35:55 +00:00
2013-09-13 11:51:55 +00:00
if (( $private ) && ( ! $env_recips )) {
// shouldn't happen
logger ( 'notifier: private message with no envelope recipients.' . print_r ( $argv , true ));
}
2013-07-22 00:19:16 +00:00
logger ( 'notifier: recipients (may be delivered to more if public): ' . print_r ( $recip_list , true ), LOGGER_DEBUG );
2012-12-06 00:44:07 +00:00
// Now we have collected recipients (except for external mentions, FIXME)
// Let's reduce this to a set of hubs.
2015-09-15 03:43:39 +00:00
$r = q ( " select * from hubloc where hubloc_hash in ( " . implode ( ',' , $recipients ) . " )
and hubloc_error = 0 and hubloc_deleted = 0 "
);
2014-01-23 06:07:47 +00:00
2012-12-06 00:44:07 +00:00
if ( ! $r ) {
logger ( 'notifier: no hubs' );
return ;
}
2014-12-17 09:50:43 +00:00
2012-12-06 00:44:07 +00:00
$hubs = $r ;
2013-01-05 00:28:33 +00:00
2015-09-15 03:43:39 +00:00
2014-12-17 19:57:16 +00:00
/**
* Reduce the hubs to those that are unique . For zot hubs , we need to verify uniqueness by the sitekey , since it may have been
* a re - install which has not yet been detected and pruned .
* For other networks which don 't have or require sitekeys, we' ll have to use the URL
*/
$hublist = array (); // this provides an easily printable list for the logs
$dhubs = array (); // delivery hubs where we store our resulting unique array
$keys = array (); // array of keys to check uniquness for zot hubs
$urls = array (); // array of urls to check uniqueness of hubs from other networks
2013-11-21 05:09:13 +00:00
2013-09-18 03:50:09 +00:00
foreach ( $hubs as $hub ) {
2015-09-15 03:43:39 +00:00
if ( in_array ( $hub [ 'hubloc_url' ], $dead_hubs )) {
logger ( 'skipping dead hub: ' . $hub [ 'hubloc_url' ], LOGGER_DEBUG );
continue ;
}
2014-12-17 19:57:16 +00:00
if ( $hub [ 'hubloc_network' ] == 'zot' ) {
if ( ! in_array ( $hub [ 'hubloc_sitekey' ], $keys )) {
$hublist [] = $hub [ 'hubloc_host' ];
$dhubs [] = $hub ;
2014-12-17 09:50:43 +00:00
$keys [] = $hub [ 'hubloc_sitekey' ];
2014-12-17 19:57:16 +00:00
}
}
else {
if ( ! in_array ( $hub [ 'hubloc_url' ], $urls )) {
$hublist [] = $hub [ 'hubloc_host' ];
$dhubs [] = $hub ;
$urls [] = $hub [ 'hubloc_url' ];
}
2013-09-18 03:50:09 +00:00
}
}
2013-07-22 00:19:16 +00:00
logger ( 'notifier: will notify/deliver to these hubs: ' . print_r ( $hublist , true ), LOGGER_DEBUG );
2012-12-06 00:44:07 +00:00
2014-12-17 09:50:43 +00:00
foreach ( $dhubs as $hub ) {
2014-05-03 00:29:04 +00:00
2015-08-03 00:38:34 +00:00
if ( $hub [ 'hubloc_network' ] !== 'zot' ) {
2014-08-26 03:57:10 +00:00
2015-08-03 00:38:34 +00:00
$narr = array (
2014-08-26 03:57:10 +00:00
'channel' => $channel ,
'env_recips' => $env_recips ,
'recipients' => $recipients ,
'item' => $item ,
'target_item' => $target_item ,
'hub' => $hub ,
'top_level_post' => $top_level_post ,
'private' => $private ,
'followup' => $followup ,
'relay_to_owner' => $relay_to_owner ,
'uplink' => $uplink ,
'cmd' => $cmd ,
'mail' => $mail ,
2014-09-15 05:19:19 +00:00
'location' => $location ,
2014-10-31 02:15:03 +00:00
'request' => $request ,
2014-08-26 03:57:10 +00:00
'normal_mode' => $normal_mode ,
'packet_type' => $packet_type ,
2015-09-30 04:08:12 +00:00
'walltowall' => $walltowall ,
'queued' => array ()
2015-08-03 00:38:34 +00:00
);
2014-08-26 03:57:10 +00:00
2015-08-03 00:38:34 +00:00
call_hooks ( 'notifier_hub' , $narr );
2015-09-30 04:08:12 +00:00
if ( $narr [ 'queued' ]) {
foreach ( $narr [ 'queued' ] as $pq )
$deliveries [] = $pq ;
}
2014-08-26 03:57:10 +00:00
continue ;
}
// default: zot protocol
2012-12-06 00:44:07 +00:00
$hash = random_string ();
2015-12-15 04:49:12 +00:00
$packet = null ;
2013-09-18 03:50:09 +00:00
if ( $packet_type === 'refresh' || $packet_type === 'purge' ) {
2015-12-15 04:49:12 +00:00
$packet = zot_build_packet ( $channel , $packet_type );
2013-06-14 23:54:58 +00:00
}
2014-10-31 02:15:03 +00:00
elseif ( $packet_type === 'request' ) {
2015-12-15 04:49:12 +00:00
$packet = zot_build_packet ( $channel , $packet_type , $env_recips , $hub [ 'hubloc_sitekey' ], $hash ,
array ( 'message_id' => $request_message_id )
2014-10-31 02:15:03 +00:00
);
}
2015-12-15 04:49:12 +00:00
if ( $packet ) {
queue_insert ( array (
'hash' => $hash ,
'account_id' => $channel [ 'channel_account_id' ],
'channel_id' => $channel [ 'channel_id' ],
'posturl' => $hub [ 'hubloc_callback' ],
'notify' => $packet
));
}
2013-06-14 23:54:58 +00:00
else {
2015-12-15 04:49:12 +00:00
$packet = zot_build_packet ( $channel , 'notify' , $env_recips ,(( $private ) ? $hub [ 'hubloc_sitekey' ] : null ), $hash );
queue_insert ( array (
'hash' => $hash ,
'account_id' => $target_item [ 'aid' ],
'channel_id' => $target_item [ 'uid' ],
'posturl' => $hub [ 'hubloc_callback' ],
'notify' => $packet ,
'msg' => json_encode ( $encoded_item )
));
2015-09-22 09:32:04 +00:00
// only create delivery reports for normal undeleted items
2015-11-01 23:51:45 +00:00
if ( is_array ( $target_item ) && array_key_exists ( 'postopts' , $target_item ) && ( ! $target_item [ 'item_deleted' ])) {
2015-09-22 09:32:04 +00:00
q ( " insert into dreport ( dreport_mid, dreport_site, dreport_recip, dreport_result, dreport_time, dreport_xchan, dreport_queue ) values ( '%s','%s','%s','%s','%s','%s','%s' ) " ,
dbesc ( $target_item [ 'mid' ]),
dbesc ( $hub [ 'hubloc_host' ]),
dbesc ( $hub [ 'hubloc_host' ]),
dbesc ( 'queued' ),
dbesc ( datetime_convert ()),
dbesc ( $channel [ 'channel_hash' ]),
dbesc ( $hash )
);
}
2013-06-14 23:54:58 +00:00
}
2011-08-26 03:35:55 +00:00
2015-09-25 06:02:41 +00:00
$deliveries [] = $hash ;
2011-01-31 22:01:38 +00:00
}
2015-09-25 05:51:47 +00:00
if ( $normal_mode ) {
$x = q ( " select * from hook where hook = 'notifier_normal' " );
if ( $x )
2015-10-02 11:51:57 +00:00
proc_run ( 'php' , 'include/deliver_hooks.php' , $target_item [ 'id' ]);
2015-09-25 05:51:47 +00:00
}
2015-10-16 01:52:04 +00:00
if ( $deliveries )
do_delivery ( $deliveries );
2013-07-22 00:19:16 +00:00
logger ( 'notifier: basic loop complete.' , LOGGER_DEBUG );
2011-10-12 01:24:37 +00:00
call_hooks ( 'notifier_end' , $target_item );
2013-07-22 00:19:16 +00:00
logger ( 'notifer: complete.' );
2011-01-28 13:04:18 +00:00
return ;
2012-11-19 02:30:00 +00:00
2011-01-28 13:04:18 +00:00
}
2010-07-08 05:44:22 +00:00
2012-11-19 02:30:00 +00:00
2011-01-28 13:04:18 +00:00
if ( array_search ( __file__ , get_included_files ()) === 0 ){
notifier_run ( $argv , $argc );
killme ();
}