include/queue.php

   1 <?php
   2 require_once("boot.php");
   3 require_once('include/queue_fn.php');
   4
   5 function queue_run(&$argv, &$argc){
   6         global $a, $db;
   7
   8         if(is_null($a)){
   9                 $a = new App;
  10         }
  11
  12         if(is_null($db)){
  13                 @include(".htconfig.php");
  14                 require_once("include/dba.php");
  15                 $db = new dba($db_host, $db_user, $db_pass, $db_data);
  16                 unset($db_host, $db_user, $db_pass, $db_data);
  17         };
  18
  19
  20         require_once("include/session.php");
  21         require_once("include/datetime.php");
  22         require_once('include/items.php');
  23         require_once('include/bbcode.php');
  24
  25         load_config('config');
  26         load_config('system');
  27
  28         if ($hostname =  get_config('system', 'hostname'))
  29                 $a->set_hostname($hostname);
  30
  31         $a->set_baseurl(get_config('system','url'));
  32
  33         load_hooks();
  34
  35         if($argc > 1)
  36                 $queue_id = intval($argv[1]);
  37         else
  38                 $queue_id = 0;
  39
  40         $deadguys = array();
  41
  42         logger('queue: start');
  43
  44         $interval = ((get_config('system','delivery_interval') === false) ? 2 : intval(get_config('system','delivery_interval')));
  45
  46         $r = q("select * from deliverq where 1");
  47         if($r) {
  48                 foreach($r as $rr) {
  49                         logger('queue: deliverq');
  50                         proc_run('php','include/delivery.php',$rr['cmd'],$rr['item'],$rr['contact']);
  51                         if($interval)
  52                                 @time_sleep_until(microtime(true) + (float) $interval);
  53                 }
  54         }
  55
  56         $r = q("SELECT `queue`.*, `contact`.`name`, `contact`.`uid` FROM `queue`
  57                 LEFT JOIN `contact` ON `queue`.`cid` = `contact`.`id`
  58                 WHERE `queue`.`created` < UTC_TIMESTAMP() - INTERVAL 3 DAY");
  59         if($r) {
  60                 foreach($r as $rr) {
  61                         logger('Removing expired queue item for ' . $rr['name'] . ', uid=' . $rr['uid']);
  62                         logger('Expired queue data :' . $rr['content'], LOGGER_DATA);
  63                 }
  64                 q("DELETE FROM `queue` WHERE `created` < UTC_TIMESTAMP() - INTERVAL 3 DAY");
  65         }
  66
  67         if($queue_id) {
  68                 $r = q("SELECT `id` FROM `queue` WHERE `id` = %d LIMIT 1",
  69                         intval($queue_id)
  70                 );
  71         }
  72         else {
  73
  74                 // For the first 12 hours we'll try to deliver every 15 minutes
  75                 // After that, we'll only attempt delivery once per hour.
  76
  77                 $r = q("SELECT `id` FROM `queue` WHERE (( `created` > UTC_TIMESTAMP() - INTERVAL 12 HOUR && `last` < UTC_TIMESTAMP() - INTERVAL 15 MINUTE ) OR ( `last` < UTC_TIMESTAMP() - INTERVAL 1 HOUR ))");
  78         }
  79         if(! $r){
  80                 return;
  81         }
  82
  83         if(! $queue_id)
  84                 call_hooks('queue_predeliver', $a, $r);
  85
  86
  87         // delivery loop
  88
  89         require_once('include/salmon.php');
  90         require_once('include/diaspora.php');
  91
  92         foreach($r as $q_item) {
  93
  94                 // queue_predeliver hooks may have changed the queue db details,
  95                 // so check again if this entry still needs processing
  96
  97                 if($queue_id) {
  98                         $qi = q("select * from queue where `id` = %d limit 1",
  99                                 intval($queue_id)
 100                         );
 101                 }
 102                 else {
 103                         $qi = q("SELECT * FROM `queue` WHERE `id` = %d AND `last` < UTC_TIMESTAMP() - INTERVAL 15 MINUTE ",
 104                                 intval($q_item['id'])
 105                         );
 106                 }
 107                 if(! count($qi))
 108                         continue;
 109
 110
 111                 $c = q("SELECT * FROM `contact` WHERE `id` = %d LIMIT 1",
 112                         intval($qi[0]['cid'])
 113                 );
 114                 if(! count($c)) {
 115                         remove_queue_item($q_item['id']);
 116                         continue;
 117                 }
 118                 if(in_array($c[0]['notify'],$deadguys)) {
 119                                 logger('queue: skipping known dead url: ' . $c[0]['notify']);
 120                                 update_queue_time($q_item['id']);
 121                                 continue;
 122                 }
 123
 124                 $u = q("SELECT `user`.*, `user`.`pubkey` AS `upubkey`, `user`.`prvkey` AS `uprvkey`
 125                         FROM `user` WHERE `uid` = %d LIMIT 1",
 126                         intval($c[0]['uid'])
 127                 );
 128                 if(! count($u)) {
 129                         remove_queue_item($q_item['id']);
 130                         continue;
 131                 }
 132
 133                 $data      = $qi[0]['content'];
 134                 $public    = $qi[0]['batch'];
 135                 $contact   = $c[0];
 136                 $owner     = $u[0];
 137
 138                 $deliver_status = 0;
 139
 140                 switch($contact['network']) {
 141                         case NETWORK_DFRN:
 142                                 logger('queue: dfrndelivery: item ' . $q_item['id'] . ' for ' . $contact['name']);
 143                                 $deliver_status = dfrn_deliver($owner,$contact,$data);
 144
 145                                 if($deliver_status == (-1)) {
 146                                         update_queue_time($q_item['id']);
 147                                         $deadguys[] = $contact['notify'];
 148                                 }
 149                                 else {
 150                                         remove_queue_item($q_item['id']);
 151                                 }
 152                                 break;
 153                         case NETWORK_OSTATUS:
 154                                 if($contact['notify']) {
 155                                         logger('queue: slapdelivery: item ' . $q_item['id'] . ' for ' . $contact['name']);
 156                                         $deliver_status = slapper($owner,$contact['notify'],$data);
 157
 158                                         if($deliver_status == (-1))
 159                                                 update_queue_time($q_item['id']);
 160                                         else
 161                                                 remove_queue_item($q_item['id']);
 162                                 }
 163                                 break;
 164                         case NETWORK_DIASPORA:
 165                                 if($contact['notify']) {
 166                                         logger('queue: diaspora_delivery: item ' . $q_item['id'] . ' for ' . $contact['name']);
 167                                         $deliver_status = diaspora_transmit($owner,$contact,$data,$public,true);
 168
 169                                         if($deliver_status == (-1))
 170                                                 update_queue_time($q_item['id']);
 171                                         else
 172                                                 remove_queue_item($q_item['id']);
 173                                 }
 174                                 break;
 175
 176                         default:
 177                                 $params = array('owner' => $owner, 'contact' => $contact, 'queue' => $q_item, 'result' => false);
 178                                 call_hooks('queue_deliver', $a, $params);
 179
 180                                 if($params['result'])
 181                                                 remove_queue_item($q_item['id']);
 182                                 else
 183                                                 update_queue_time($q_item['id']);
 184
 185                                 break;
 186
 187                 }
 188         }
 189
 190         return;
 191
 192 }
 193
 194 if (array_search(__file__,get_included_files())===0){
 195   queue_run($argv,$argc);
 196   killme();
 197 }