include/notifier.php

   1 <?php
   2
   3 require_once("boot.php");
   4
   5 $a = new App;
   6
   7 @include(".htconfig.php");
   8 require_once("dba.php");
   9 $db = new dba($db_host, $db_user, $db_pass, $db_data, $install);
  10         unset($db_host, $db_user, $db_pass, $db_data);
  11
  12 require_once("session.php");
  13 require_once("datetime.php");
  14
  15 // FIXME - generalise for other content, probably create a notify queue in
  16 // the db with type and recipient list
  17
  18 if($argc < 3)
  19         exit;
  20
  21         $baseurl = trim(hex2bin($argv[1]));
  22
  23         $cmd = $argv[2];
  24
  25         switch($cmd) {
  26
  27                 default:
  28                         $item_id = intval($argv[3]);
  29                         if(! $item_id)
  30                                 killme();
  31                         break;
  32         }
  33
  34
  35         $recipients = array();
  36
  37         // find ancestors
  38
  39         $r = q("SELECT `parent`, `uid`, `edited` FROM `item` WHERE `id` = %d LIMIT 1",
  40                 intval($item_id)
  41         );
  42         if(! count($r))
  43                 killme();
  44
  45         $parent = $r[0]['parent'];
  46         $uid = $r[0]['uid'];
  47         $updated = $r[0]['edited'];
  48
  49         $items = q("SELECT * FROM `item` WHERE `parent` = %d ORDER BY `id` ASC",
  50                 intval($parent)
  51         );
  52
  53         if(! count($items))
  54                 killme();
  55
  56         $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` = 1 LIMIT 1",
  57                 intval($uid)
  58         );
  59
  60         if(count($r))
  61                 $owner = $r[0];
  62         else
  63                 killme();
  64
  65
  66         require_once('include/group.php');
  67
  68         $parent = $items[0];
  69
  70         if(strlen($parent['remote-id'])) {
  71                 $followup = true;
  72                 $conversant_str = dbesc($parent['contact-id']);
  73         }
  74         else {
  75                 $followup = false;
  76
  77                 $allow_people = expand_acl($parent['allow_cid']);
  78                 $allow_groups = expand_groups(expand_acl($parent['allow_gid']));
  79                 $deny_people = expand_acl($parent['deny_cid']);
  80                 $deny_groups = expand_groups(expand_acl($parent['deny_gid']));
  81
  82                 $conversants = array();
  83
  84                 foreach($items as $item) {
  85                         $recipients[] = $item['contact-id'];
  86                         $conversants[] = $item['contact-id'];
  87                 }
  88
  89                 $conversants = array_unique($conversants,SORT_NUMERIC);
  90
  91
  92                 $recipients = array_unique(array_merge($recipients,$allow_people,$allow_groups),SORT_NUMERIC);
  93                 $deny = array_unique(array_merge($deny_people,$deny_groups),SORT_NUMERIC);
  94                 $recipients = array_diff($recipients,$deny);
  95
  96                 $conversant_str = dbesc(implode(', ',$conversants));
  97         }
  98
  99         $r = q("SELECT * FROM `contact` WHERE `id` IN ( $conversant_str ) ");
 100
 101         if( ! count($r))
 102                 killme();
 103
 104         $contacts = $r;
 105
 106
 107         $feed_template = file_get_contents('view/atom_feed.tpl');
 108         $tomb_template = file_get_contents('view/atom_tomb.tpl');
 109         $item_template = file_get_contents('view/atom_item.tpl');
 110         $cmnt_template = file_get_contents('view/atom_cmnt.tpl');
 111
 112         $atom = '';
 113
 114
 115         $atom .= replace_macros($feed_template, array(
 116                         '$feed_id' => xmlify($baseurl),
 117                         '$feed_title' => xmlify($owner['name']),
 118                         '$feed_updated' => xmlify(datetime_convert('UTC', 'UTC', $updated . '+00:00' , 'Y-m-d\Th:i:s\Z')) ,
 119                         '$name' => xmlify($owner['name']),
 120                         '$profile_page' => xmlify($owner['url']),
 121                         '$thumb' => xmlify($owner['thumb'])
 122         ));
 123
 124         if($followup) {
 125                 $atom .= replace_macros($cmnt_template, array(
 126                         '$name' => xmlify($contact['name']),
 127                         '$profile_page' => xmlify($contact['url']),
 128                         '$thumb' => xmlify($contact['thumb']),
 129                         '$item_id' => xmlify("urn:X-dfrn:{$item['hash']}"),
 130                         '$title' => xmlify($item['title']),
 131                         '$updated' => xmlify(datetime_convert('UTC', 'UTC', $item['edited'] . '+00:00' , 'Y-m-d\Th:i:s\Z')),
 132                         '$content' =>xmlify($item['body']),
 133                         '$parent_id' => xmlify("{$items[0]['remote-id']}")
 134                 ));
 135         }
 136         else {
 137                 foreach($items as $item) {
 138                         if($item['deleted']) {
 139                                 $atom .= replace_macros($tomb_template, array(
 140                                         '$id' => xmlify("urn:X-dfrn:{$item['hash']}"),
 141                                         '$updated' => xmlify(datetime_convert('UTC', 'UTC', $item['edited'] . '+00:00' , 'Y-m-d\Th:i:s\Z'))
 142                                 ));
 143                         }
 144                         else {
 145                                 foreach($contacts as $contact) {
 146                                         if($item['contact-id'] == $contact['id']) {
 147                                                 if($item['parent'] == $item['id']) {
 148                                                         $atom .= replace_macros($item_template, array(
 149                                                                 '$name' => xmlify($contact['name']),
 150                                                                 '$profile_page' => xmlify($contact['url']),
 151                                                                 '$thumb' => xmlify($contact['thumb']),
 152                                                                 '$item_id' => xmlify("urn:X-dfrn:{$item['hash']}"),
 153                                                                 '$title' => xmlify($item['title']),
 154                                                                 '$updated' => xmlify(datetime_convert('UTC', 'UTC', $item['edited'] . '+00:00' , 'Y-m-d\Th:i:s\Z')),
 155                                                                 '$content' =>xmlify($item['body'])
 156                                                         ));
 157                                                 }
 158                                                 else {
 159                                                         $atom .= replace_macros($cmnt_template, array(
 160                                                                 '$name' => xmlify($contact['name']),
 161                                                                 '$profile_page' => xmlify($contact['url']),
 162                                                                 '$thumb' => xmlify($contact['thumb']),
 163                                                                 '$item_id' => xmlify("urn:X-dfrn:{$item['hash']}"),
 164                                                                 '$title' => xmlify($item['title']),
 165                                                                 '$updated' => xmlify(datetime_convert('UTC', 'UTC', $item['edited'] . '+00:00' , 'Y-m-d\Th:i:s\Z')),
 166                                                                 '$content' =>xmlify($item['body']),
 167                                                                 '$parent_id' => xmlify("urn:X-dfrn:{$items[0]['hash']}")
 168                                                         ));
 169                                                 }
 170                                         }
 171                                 }
 172                         }
 173                 }
 174         }
 175         $atom .= "</feed>";
 176
 177 print_r($atom);
 178
 179
 180 dbg(3);
 181
 182
 183
 184 print_r($recipients);
 185
 186         if($followup)
 187                 $recip_str = $parent['contact-id'];
 188         else
 189                 $recip_str = implode(', ', $recipients);
 190
 191         $r = q("SELECT * FROM `contact` WHERE `id` IN ( %s ) ",
 192                 dbesc($recip_str)
 193         );
 194         if(! count($r))
 195                 killme();
 196
 197         // delivery loop
 198
 199         foreach($r as $rr) {
 200                 if($rr['self'])
 201                         continue;
 202
 203                 if(! strlen($rr['dfrn-id']))
 204                         continue;
 205                 $url = $rr['notify'] . '?dfrn_id=' . $rr['dfrn-id'];
 206 print_r($url);
 207                 $xml = fetch_url($url);
 208 echo $xml;
 209
 210 print_r($xml);
 211                 if(! $xml)
 212                         continue;
 213
 214                 $res = simplexml_load_string($xml);
 215 print_r($res);
 216 var_dump($res);
 217
 218                 if((intval($res->status) != 0) || (! strlen($res->challenge)) || ($res->dfrn_id != $rr['dfrn-id']))
 219                         continue;
 220
 221                 $postvars = array();
 222
 223                 $postvars['dfrn_id'] = $rr['dfrn-id'];
 224                 $challenge = hex2bin($res->challenge);
 225 echo "dfrn-id:" . $res->dfrn_id . "\r\n";
 226 echo "challenge:" . $res->challenge . "\r\n";
 227 echo "pubkey:" . $rr['pubkey'] . "\r\n";
 228
 229                 openssl_public_decrypt($challenge,$postvars['challenge'],$rr['pubkey']);
 230
 231                 $postvars['data'] = $atom;
 232
 233 print_r($postvars);
 234                 $xml = post_url($url,$postvars);
 235
 236 print_r($xml);
 237         }
 238
 239         killme();
 240