2011-08-09 00:44:29 -04:00
< ? php
2011-08-09 21:55:46 -04:00
require_once ( 'include/crypto.php' );
2011-08-16 02:19:17 -04:00
require_once ( 'include/items.php' );
2011-08-23 06:02:31 -04:00
require_once ( 'include/bb2diaspora.php' );
2011-08-28 08:00:30 -04:00
require_once ( 'include/contact_selectors.php' );
2011-08-09 00:44:29 -04:00
2011-09-14 22:33:42 -04:00
function diaspora_dispatch_public ( $msg ) {
2011-09-16 17:51:25 -04:00
$r = q ( " SELECT `user`.* FROM `user` WHERE `user`.`uid` IN ( SELECT `contact`.`uid` FROM `contact` WHERE `contact`.`network` = '%s' AND `contact`.`addr` = '%s' ) " ,
2011-09-14 22:33:42 -04:00
dbesc ( NETWORK_DIASPORA ),
dbesc ( $msg [ 'author' ])
);
if ( count ( $r )) {
foreach ( $r as $rr ) {
2011-09-16 17:51:25 -04:00
logger ( 'diaspora_public: delivering to: ' . $rr [ 'username' ]);
2011-09-14 22:33:42 -04:00
diaspora_dispatch ( $rr , $msg );
}
}
2011-09-16 17:51:25 -04:00
else
logger ( 'diaspora_public: no subscribers' );
2011-09-14 22:33:42 -04:00
}
2011-08-24 04:21:24 -04:00
function diaspora_dispatch ( $importer , $msg ) {
2011-09-14 22:33:42 -04:00
$ret = 0 ;
2011-08-24 04:21:24 -04:00
$parsed_xml = parse_xml_string ( $msg [ 'message' ], false );
$xmlbase = $parsed_xml -> post ;
if ( $xmlbase -> request ) {
2011-09-14 22:33:42 -04:00
$ret = diaspora_request ( $importer , $xmlbase -> request );
2011-08-24 04:21:24 -04:00
}
elseif ( $xmlbase -> status_message ) {
2011-09-14 22:33:42 -04:00
$ret = diaspora_post ( $importer , $xmlbase -> status_message );
2011-08-24 04:21:24 -04:00
}
elseif ( $xmlbase -> comment ) {
2011-09-14 22:33:42 -04:00
$ret = diaspora_comment ( $importer , $xmlbase -> comment , $msg );
2011-08-24 04:21:24 -04:00
}
elseif ( $xmlbase -> like ) {
2011-09-14 22:33:42 -04:00
$ret = diaspora_like ( $importer , $xmlbase -> like , $msg );
2011-08-24 04:21:24 -04:00
}
elseif ( $xmlbase -> retraction ) {
2011-09-14 22:33:42 -04:00
$ret = diaspora_retraction ( $importer , $xmlbase -> retraction , $msg );
2011-08-24 04:21:24 -04:00
}
elseif ( $xmlbase -> photo ) {
2011-09-14 22:33:42 -04:00
$ret = diaspora_photo ( $importer , $xmlbase -> photo , $msg );
2011-08-24 04:21:24 -04:00
}
else {
logger ( 'diaspora_dispatch: unknown message type: ' . print_r ( $xmlbase , true ));
}
2011-09-14 22:33:42 -04:00
return $ret ;
2011-08-24 04:21:24 -04:00
}
2011-08-22 22:27:40 -04:00
function diaspora_get_contact_by_handle ( $uid , $handle ) {
$r = q ( " SELECT * FROM `contact` WHERE `network` = '%s' AND `uid` = %d AND `addr` = '%s' LIMIT 1 " ,
dbesc ( NETWORK_DIASPORA ),
intval ( $uid ),
dbesc ( $handle )
);
if ( $r && count ( $r ))
return $r [ 0 ];
return false ;
}
function find_diaspora_person_by_handle ( $handle ) {
$r = q ( " select * from fcontact where network = '%s' and addr = '%s' limit 1 " ,
dbesc ( NETWORK_DIASPORA ),
dbesc ( $handle )
);
if ( count ( $r )) {
// update record occasionally so it doesn't get stale
$d = strtotime ( $r [ 0 ][ 'updated' ] . ' +00:00' );
if ( $d < strtotime ( 'now - 14 days' )) {
q ( " delete from fcontact where id = %d limit 1 " ,
intval ( $r [ 0 ][ 'id' ])
);
}
else
return $r [ 0 ];
}
require_once ( 'include/Scrape.php' );
$r = probe_url ( $handle , PROBE_DIASPORA );
if (( count ( $r )) && ( $r [ 'network' ] === NETWORK_DIASPORA )) {
add_fcontact ( $r );
return ( $r );
}
return false ;
}
2011-08-09 05:53:51 -04:00
function get_diaspora_key ( $uri ) {
logger ( 'Fetching diaspora key for: ' . $uri );
2011-08-18 07:20:30 -04:00
$r = find_diaspora_person_by_handle ( $uri );
if ( $r )
return $r [ 'pubkey' ];
2011-08-09 05:53:51 -04:00
return '' ;
}
2011-08-09 00:44:29 -04:00
2011-09-18 23:17:44 -04:00
function diaspora_pubmsg_build ( $msg , $user , $contact , $prvkey , $pubkey ) {
$a = get_app ();
logger ( 'diaspora_pubmsg_build: ' . $msg , LOGGER_DATA );
$handle = $user [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
$b64_data = base64_encode ( $msg );
$b64url_data = base64url_encode ( $b64_data );
$data = str_replace ( array ( " \n " , " \r " , " " , " \t " ), array ( '' , '' , '' , '' ), $b64url_data );
$type = 'application/xml' ;
$encoding = 'base64url' ;
$alg = 'RSA-SHA256' ;
$signable_data = $data . '.' . base64url_encode ( $type ) . '.'
. base64url_encode ( $encoding ) . '.' . base64url_encode ( $alg ) ;
$signature = rsa_sign ( $signable_data , $prvkey );
$sig = base64url_encode ( $signature );
$magic_env = <<< EOT
< ? xml version = '1.0' encoding = 'UTF-8' ?>
< diaspora xmlns = " https://joindiaspora.org/protocol " xmlns : me = " http://salmon-protocol.org/ns/magic-env " >
< header >
< author_id > $handle </ author_id >
</ header >
< me : env >
< me : encoding > base64url </ me : encoding >
< me : alg > RSA - SHA256 </ me : alg >
< me : data type = " application/xml " > $data </ me : data >
< me : sig > $sig </ me : sig >
</ me : env >
</ diaspora >
EOT ;
logger ( 'diaspora_pubmsg_build: magic_env: ' . $magic_env , LOGGER_DATA );
return $magic_env ;
}
2011-08-09 00:44:29 -04:00
function diaspora_msg_build ( $msg , $user , $contact , $prvkey , $pubkey ) {
$a = get_app ();
2011-08-19 07:48:54 -04:00
logger ( 'diaspora_msg_build: ' . $msg , LOGGER_DATA );
2011-08-09 00:51:56 -04:00
$inner_aes_key = random_string ( 32 );
2011-08-09 00:44:29 -04:00
$b_inner_aes_key = base64_encode ( $inner_aes_key );
2011-08-19 17:34:28 -04:00
$inner_iv = random_string ( 16 );
2011-08-09 00:44:29 -04:00
$b_inner_iv = base64_encode ( $inner_iv );
2011-08-09 00:51:56 -04:00
$outer_aes_key = random_string ( 32 );
2011-08-09 00:44:29 -04:00
$b_outer_aes_key = base64_encode ( $outer_aes_key );
2011-08-19 17:34:28 -04:00
$outer_iv = random_string ( 16 );
2011-08-09 00:44:29 -04:00
$b_outer_iv = base64_encode ( $outer_iv );
2011-09-15 20:47:16 -04:00
$handle = $user [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
2011-08-09 00:44:29 -04:00
2011-08-09 05:53:51 -04:00
$padded_data = pkcs5_pad ( $msg , 16 );
2011-08-09 00:44:29 -04:00
$inner_encrypted = mcrypt_encrypt ( MCRYPT_RIJNDAEL_128 , $inner_aes_key , $padded_data , MCRYPT_MODE_CBC , $inner_iv );
$b64_data = base64_encode ( $inner_encrypted );
2011-08-09 09:40:28 -04:00
2011-08-09 05:53:51 -04:00
2011-08-09 00:44:29 -04:00
$b64url_data = base64url_encode ( $b64_data );
2011-09-14 22:33:42 -04:00
$data = str_replace ( array ( " \n " , " \r " , " " , " \t " ), array ( '' , '' , '' , '' ), $b64url_data );
2011-09-15 20:47:16 -04:00
$type = 'application/xml' ;
2011-08-09 00:44:29 -04:00
$encoding = 'base64url' ;
$alg = 'RSA-SHA256' ;
2011-09-14 22:33:42 -04:00
$signable_data = $data . '.' . base64url_encode ( $type ) . '.'
. base64url_encode ( $encoding ) . '.' . base64url_encode ( $alg ) ;
2011-08-09 00:44:29 -04:00
2011-08-09 21:55:46 -04:00
$signature = rsa_sign ( $signable_data , $prvkey );
2011-08-09 00:44:29 -04:00
$sig = base64url_encode ( $signature );
$decrypted_header = <<< EOT
< decrypted_header >
< iv > $b_inner_iv </ iv >
< aes_key > $b_inner_aes_key </ aes_key >
2011-09-15 20:47:16 -04:00
< author_id > $handle </ author_id >
2011-08-09 00:44:29 -04:00
</ decrypted_header >
EOT ;
2011-08-09 05:53:51 -04:00
$decrypted_header = pkcs5_pad ( $decrypted_header , 16 );
2011-08-09 00:44:29 -04:00
2011-08-09 09:40:28 -04:00
$ciphertext = mcrypt_encrypt ( MCRYPT_RIJNDAEL_128 , $outer_aes_key , $decrypted_header , MCRYPT_MODE_CBC , $outer_iv );
2011-08-09 05:53:51 -04:00
$outer_json = json_encode ( array ( 'iv' => $b_outer_iv , 'key' => $b_outer_aes_key ));
2011-08-22 07:55:09 -04:00
2011-08-09 00:44:29 -04:00
$encrypted_outer_key_bundle = '' ;
openssl_public_encrypt ( $outer_json , $encrypted_outer_key_bundle , $pubkey );
2011-08-22 07:55:09 -04:00
2011-08-09 00:44:29 -04:00
$b64_encrypted_outer_key_bundle = base64_encode ( $encrypted_outer_key_bundle );
2011-08-22 07:55:09 -04:00
2011-08-29 00:41:42 -04:00
logger ( 'outer_bundle: ' . $b64_encrypted_outer_key_bundle . ' key: ' . $pubkey , LOGGER_DATA );
2011-08-22 07:55:09 -04:00
2011-08-09 00:44:29 -04:00
$encrypted_header_json_object = json_encode ( array ( 'aes_key' => base64_encode ( $encrypted_outer_key_bundle ),
'ciphertext' => base64_encode ( $ciphertext )));
2011-08-21 20:24:50 -04:00
$cipher_json = base64_encode ( $encrypted_header_json_object );
$encrypted_header = '<encrypted_header>' . $cipher_json . '</encrypted_header>' ;
2011-08-09 00:44:29 -04:00
2011-08-09 05:53:51 -04:00
$magic_env = <<< EOT
2011-08-09 00:44:29 -04:00
< ? xml version = '1.0' encoding = 'UTF-8' ?>
2011-09-16 17:46:04 -04:00
< diaspora xmlns = " https://joindiaspora.org/protocol " xmlns : me = " http://salmon-protocol.org/ns/magic-env " >
2011-08-09 00:44:29 -04:00
$encrypted_header
2011-09-16 17:46:04 -04:00
< me : env >
2011-08-09 00:44:29 -04:00
< me : encoding > base64url </ me : encoding >
< me : alg > RSA - SHA256 </ me : alg >
2011-09-14 22:33:42 -04:00
< me : data type = " application/xml " > $data </ me : data >
2011-08-09 00:44:29 -04:00
< me : sig > $sig </ me : sig >
</ me : env >
2011-09-16 17:46:04 -04:00
</ diaspora >
2011-08-09 00:44:29 -04:00
EOT ;
2011-08-19 07:48:54 -04:00
logger ( 'diaspora_msg_build: magic_env: ' . $magic_env , LOGGER_DATA );
2011-08-09 00:44:29 -04:00
return $magic_env ;
2011-08-09 05:53:51 -04:00
}
2011-08-17 07:24:26 -04:00
/**
*
* diaspora_decode ( $importer , $xml )
* array $importer -> from user table
* string $xml -> urldecoded Diaspora salmon
*
* Returns array
* 'message' -> decoded Diaspora XML message
* 'author' -> author diaspora handle
* 'key' -> author public key ( converted to pkcs #8)
*
* Author and key are used elsewhere to save a lookup for verifying replies and likes
*/
2011-08-09 05:53:51 -04:00
2011-08-15 08:27:24 -04:00
2011-08-17 07:24:26 -04:00
function diaspora_decode ( $importer , $xml ) {
2011-08-15 08:27:24 -04:00
2011-09-14 22:33:42 -04:00
$public = false ;
2011-08-09 09:40:28 -04:00
$basedom = parse_xml_string ( $xml );
2011-08-09 05:53:51 -04:00
2011-09-15 20:47:16 -04:00
$children = $basedom -> children ( 'https://joindiaspora.com/protocol' );
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
if ( $children -> header ) {
$public = true ;
2011-09-16 17:57:41 -04:00
$author_link = str_replace ( 'acct:' , '' , $children -> header -> author_id );
2011-09-14 22:33:42 -04:00
}
else {
2011-08-17 07:24:26 -04:00
2011-09-14 22:33:42 -04:00
$encrypted_header = json_decode ( base64_decode ( $children -> encrypted_header ));
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
$encrypted_aes_key_bundle = base64_decode ( $encrypted_header -> aes_key );
$ciphertext = base64_decode ( $encrypted_header -> ciphertext );
$outer_key_bundle = '' ;
openssl_private_decrypt ( $encrypted_aes_key_bundle , $outer_key_bundle , $importer [ 'prvkey' ]);
$j_outer_key_bundle = json_decode ( $outer_key_bundle );
$outer_iv = base64_decode ( $j_outer_key_bundle -> iv );
$outer_key = base64_decode ( $j_outer_key_bundle -> key );
$decrypted = mcrypt_decrypt ( MCRYPT_RIJNDAEL_128 , $outer_key , $ciphertext , MCRYPT_MODE_CBC , $outer_iv );
$decrypted = pkcs5_unpad ( $decrypted );
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
/**
* $decrypted now contains something like
*
* < decrypted_header >
* < iv > 8 e + G2 + ET8l5BPuW0sVTnQw ==</ iv >
* < aes_key > UvSMb4puPeB14STkcDWq + 4 QE302Edu15oaprAQSkLKU =</ aes_key >
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
***** OBSOLETE
2011-08-15 09:27:17 -04:00
2011-09-14 22:33:42 -04:00
* < author >
* < name > Ryan Hughes </ name >
* < uri > acct : galaxor @ diaspora . pirateship . org </ uri >
* </ author >
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
***** CURRENT
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
* < author_id > acct : galaxor @ diaspora . priateship . org </ author_id >
2011-08-20 07:53:11 -04:00
2011-09-14 22:33:42 -04:00
***** END DIFFS
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
* </ decrypted_header >
*/
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
logger ( 'decrypted: ' . $decrypted , LOGGER_DEBUG );
$idom = parse_xml_string ( $decrypted , false );
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
$inner_iv = base64_decode ( $idom -> iv );
$inner_aes_key = base64_decode ( $idom -> aes_key );
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
$author_link = str_replace ( 'acct:' , '' , $idom -> author_id );
}
2011-08-09 05:53:51 -04:00
$dom = $basedom -> children ( NAMESPACE_SALMON_ME );
// figure out where in the DOM tree our data is hiding
if ( $dom -> provenance -> data )
$base = $dom -> provenance ;
elseif ( $dom -> env -> data )
$base = $dom -> env ;
elseif ( $dom -> data )
$base = $dom ;
if ( ! $base ) {
logger ( 'mod-diaspora: unable to locate salmon data in xml ' );
2011-08-14 23:38:31 -04:00
http_status_exit ( 400 );
2011-08-09 05:53:51 -04:00
}
// Stash the signature away for now. We have to find their key or it won't be good for anything.
$signature = base64url_decode ( $base -> sig );
// unpack the data
// strip whitespace so our data element will return to one big base64 blob
$data = str_replace ( array ( " " , " \t " , " \r " , " \n " ), array ( " " , " " , " " , " " ), $base -> data );
2011-08-17 07:24:26 -04:00
2011-08-09 05:53:51 -04:00
// stash away some other stuff for later
$type = $base -> data [ 0 ] -> attributes () -> type [ 0 ];
$keyhash = $base -> sig [ 0 ] -> attributes () -> keyhash [ 0 ];
$encoding = $base -> encoding ;
$alg = $base -> alg ;
2011-08-17 07:24:26 -04:00
2011-09-14 22:33:42 -04:00
$signed_data = $data . '.' . base64url_encode ( $type ) . '.' . base64url_encode ( $encoding ) . '.' . base64url_encode ( $alg );
2011-08-09 05:53:51 -04:00
// decode the data
$data = base64url_decode ( $data );
2011-09-14 22:33:42 -04:00
if ( $public ) {
$inner_decrypted = $data ;
}
else {
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
// Decode the encrypted blob
2011-08-09 05:53:51 -04:00
2011-09-14 22:33:42 -04:00
$inner_encrypted = base64_decode ( $data );
$inner_decrypted = mcrypt_decrypt ( MCRYPT_RIJNDAEL_128 , $inner_aes_key , $inner_encrypted , MCRYPT_MODE_CBC , $inner_iv );
$inner_decrypted = pkcs5_unpad ( $inner_decrypted );
}
2011-08-09 05:53:51 -04:00
if ( ! $author_link ) {
logger ( 'mod-diaspora: Could not retrieve author URI.' );
2011-08-09 21:55:46 -04:00
http_status_exit ( 400 );
2011-08-09 05:53:51 -04:00
}
// Once we have the author URI, go to the web and try to find their public key
2011-08-20 18:09:09 -04:00
// (first this will look it up locally if it is in the fcontact cache)
// This will also convert diaspora public key from pkcs#1 to pkcs#8
2011-08-09 05:53:51 -04:00
logger ( 'mod-diaspora: Fetching key for ' . $author_link );
$key = get_diaspora_key ( $author_link );
if ( ! $key ) {
2011-08-09 09:40:28 -04:00
logger ( 'mod-diaspora: Could not retrieve author key.' );
2011-08-09 21:55:46 -04:00
http_status_exit ( 400 );
2011-08-09 05:53:51 -04:00
}
2011-08-09 21:55:46 -04:00
$verify = rsa_verify ( $signed_data , $signature , $key );
2011-08-09 05:53:51 -04:00
if ( ! $verify ) {
logger ( 'mod-diaspora: Message did not verify. Discarding.' );
2011-09-15 20:47:16 -04:00
// http_status_exit(400);
2011-08-09 05:53:51 -04:00
}
logger ( 'mod-diaspora: Message verified.' );
2011-08-17 01:31:14 -04:00
return array ( 'message' => $inner_decrypted , 'author' => $author_link , 'key' => $key );
2011-08-09 05:53:51 -04:00
}
2011-08-18 07:20:30 -04:00
2011-08-16 02:19:17 -04:00
function diaspora_request ( $importer , $xml ) {
2011-08-10 08:10:48 -04:00
2011-08-16 03:52:34 -04:00
$sender_handle = unxmlify ( $xml -> sender_handle );
$recipient_handle = unxmlify ( $xml -> recipient_handle );
2011-08-12 06:01:11 -04:00
if ( ! $sender_handle || ! $recipient_handle )
return ;
2011-08-16 02:19:17 -04:00
$contact = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $sender_handle );
if ( $contact ) {
2011-08-17 07:24:26 -04:00
// perhaps we were already sharing with this person. Now they're sharing with us.
// That makes us friends.
2011-08-16 02:19:17 -04:00
if ( $contact [ 'rel' ] == CONTACT_IS_FOLLOWER ) {
2011-08-19 00:31:34 -04:00
q ( " UPDATE `contact` SET `rel` = %d, `writable` = 1 WHERE `id` = %d AND `uid` = %d LIMIT 1 " ,
2011-08-16 02:19:17 -04:00
intval ( CONTACT_IS_FRIEND ),
intval ( $contact [ 'id' ]),
intval ( $importer [ 'uid' ])
);
}
// send notification?
2011-08-12 06:01:11 -04:00
return ;
}
2011-08-19 01:01:35 -04:00
$ret = find_diaspora_person_by_handle ( $sender_handle );
2011-08-13 09:52:33 -04:00
2011-08-12 06:01:11 -04:00
if (( ! count ( $ret )) || ( $ret [ 'network' ] != NETWORK_DIASPORA )) {
logger ( 'diaspora_request: Cannot resolve diaspora handle ' . $sender_handle . ' for ' . $recipient_handle );
return ;
2011-08-13 09:52:33 -04:00
}
2011-08-19 01:03:58 -04:00
2011-08-13 09:52:33 -04:00
$r = q ( " INSERT INTO `contact` (`uid`, `network`,`addr`,`created`,`url`,`name`,`nick`,`photo`,`pubkey`,`notify`,`poll`,`blocked`,`priority`)
VALUES ( % d , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , % d , % d ) " ,
intval ( $importer [ 'uid' ]),
dbesc ( $ret [ 'network' ]),
dbesc ( $ret [ 'addr' ]),
datetime_convert (),
dbesc ( $ret [ 'url' ]),
dbesc ( $ret [ 'name' ]),
dbesc ( $ret [ 'nick' ]),
dbesc ( $ret [ 'photo' ]),
dbesc ( $ret [ 'pubkey' ]),
dbesc ( $ret [ 'notify' ]),
dbesc ( $ret [ 'poll' ]),
1 ,
2
);
// find the contact record we just created
2011-08-16 03:52:34 -04:00
$contact_record = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $sender_handle );
2011-08-12 06:01:11 -04:00
2011-08-13 09:52:33 -04:00
$hash = random_string () . ( string ) time (); // Generate a confirm_key
2011-08-16 03:52:34 -04:00
if ( $contact_record ) {
2011-08-19 00:50:41 -04:00
$ret = q ( " INSERT INTO `intro` ( `uid`, `contact-id`, `blocked`, `knowyou`, `note`, `hash`, `datetime` )
2011-08-19 01:03:58 -04:00
VALUES ( % d , % d , % d , % d , '%s' , '%s' , '%s' ) " ,
2011-08-13 09:52:33 -04:00
intval ( $importer [ 'uid' ]),
intval ( $contact_record [ 'id' ]),
0 ,
2011-08-19 01:03:58 -04:00
0 ,
2011-08-13 09:52:33 -04:00
dbesc ( t ( 'Sharing notification from Diaspora network' )),
dbesc ( $hash ),
dbesc ( datetime_convert ())
);
}
2011-08-19 01:03:58 -04:00
2011-08-13 09:52:33 -04:00
return ;
2011-08-10 08:10:48 -04:00
}
2011-08-16 02:19:17 -04:00
function diaspora_post ( $importer , $xml ) {
2011-08-10 08:10:48 -04:00
2011-09-03 08:23:36 -04:00
$a = get_app ();
2011-08-13 19:39:59 -04:00
$guid = notags ( unxmlify ( $xml -> guid ));
$diaspora_handle = notags ( unxmlify ( $xml -> diaspora_handle ));
2011-08-16 02:19:17 -04:00
$contact = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $diaspora_handle );
if ( ! $contact )
return ;
if (( $contact [ 'rel' ] == CONTACT_IS_FOLLOWER ) || ( $contact [ 'blocked' ]) || ( $contact [ 'readonly' ])) {
logger ( 'diaspora_post: Ignoring this author.' );
2011-09-14 22:33:42 -04:00
return 202 ;
2011-08-16 02:19:17 -04:00
}
2011-08-13 19:39:59 -04:00
$message_id = $diaspora_handle . ':' . $guid ;
$r = q ( " SELECT `id` FROM `item` WHERE `uid` = %d AND `uri` = '%s' AND `guid` = '%s' LIMIT 1 " ,
intval ( $importer [ 'uid' ]),
dbesc ( $message_id ),
dbesc ( $guid )
);
2011-08-30 01:50:41 -04:00
if ( count ( $r )) {
logger ( 'diaspora_post: message exists: ' . $guid );
2011-08-13 19:39:59 -04:00
return ;
2011-08-30 01:50:41 -04:00
}
2011-08-13 19:39:59 -04:00
2011-08-13 22:03:59 -04:00
// allocate a guid on our system - we aren't fixing any collisions.
// we're ignoring them
$g = q ( " select * from guid where guid = '%s' limit 1 " ,
dbesc ( $guid )
2011-08-13 19:39:59 -04:00
);
2011-08-13 22:03:59 -04:00
if ( ! count ( $g )) {
q ( " insert into guid ( guid ) values ( '%s' ) " ,
dbesc ( $guid )
);
}
2011-08-13 19:39:59 -04:00
$created = unxmlify ( $xml -> created_at );
$private = (( unxmlify ( $xml -> public ) == 'false' ) ? 1 : 0 );
2011-08-25 19:37:27 -04:00
$body = diaspora2bb ( $xml -> raw_message );
2011-08-13 19:39:59 -04:00
$datarray = array ();
$datarray [ 'uid' ] = $importer [ 'uid' ];
$datarray [ 'contact-id' ] = $contact [ 'id' ];
$datarray [ 'wall' ] = 0 ;
$datarray [ 'guid' ] = $guid ;
2011-08-15 22:39:49 -04:00
$datarray [ 'uri' ] = $datarray [ 'parent-uri' ] = $message_id ;
2011-08-16 00:01:44 -04:00
$datarray [ 'created' ] = $datarray [ 'edited' ] = datetime_convert ( 'UTC' , 'UTC' , $created );
$datarray [ 'private' ] = $private ;
$datarray [ 'parent' ] = 0 ;
2011-08-13 22:03:59 -04:00
$datarray [ 'owner-name' ] = $contact [ 'name' ];
$datarray [ 'owner-link' ] = $contact [ 'url' ];
$datarray [ 'owner-avatar' ] = $contact [ 'thumb' ];
2011-08-13 19:39:59 -04:00
$datarray [ 'author-name' ] = $contact [ 'name' ];
$datarray [ 'author-link' ] = $contact [ 'url' ];
$datarray [ 'author-avatar' ] = $contact [ 'thumb' ];
2011-08-15 22:46:47 -04:00
$datarray [ 'body' ] = $body ;
2011-08-26 20:52:24 -04:00
$datarray [ 'app' ] = 'Diaspora' ;
2011-08-13 19:39:59 -04:00
2011-09-01 00:46:37 -04:00
$message_id = item_store ( $datarray );
if ( $message_id ) {
q ( " update item set plink = '%s' where id = %d limit 1 " ,
dbesc ( $a -> get_baseurl () . '/display/' . $importer [ 'nickname' ] . '/' . $message_id ),
intval ( $message_id )
);
}
2011-08-13 19:39:59 -04:00
return ;
2011-08-10 08:10:48 -04:00
}
2011-08-17 01:31:14 -04:00
function diaspora_comment ( $importer , $xml , $msg ) {
2011-08-17 07:24:26 -04:00
2011-09-03 08:23:36 -04:00
$a = get_app ();
2011-08-13 22:03:59 -04:00
$guid = notags ( unxmlify ( $xml -> guid ));
2011-08-17 07:24:26 -04:00
$parent_guid = notags ( unxmlify ( $xml -> parent_guid ));
2011-08-13 22:03:59 -04:00
$diaspora_handle = notags ( unxmlify ( $xml -> diaspora_handle ));
2011-08-17 07:24:26 -04:00
$target_type = notags ( unxmlify ( $xml -> target_type ));
$text = unxmlify ( $xml -> text );
$author_signature = notags ( unxmlify ( $xml -> author_signature ));
2011-08-16 02:19:17 -04:00
2011-08-17 07:24:26 -04:00
$parent_author_signature = (( $xml -> parent_author_signature ) ? notags ( unxmlify ( $xml -> parent_author_signature )) : '' );
2011-08-16 02:19:17 -04:00
2011-08-17 07:24:26 -04:00
$text = $xml -> text ;
$contact = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $msg [ 'author' ]);
2011-08-30 01:50:41 -04:00
if ( ! $contact ) {
logger ( 'diaspora_comment: cannot find contact: ' . $msg [ 'author' ]);
2011-08-16 02:19:17 -04:00
return ;
2011-08-30 01:50:41 -04:00
}
2011-08-16 02:19:17 -04:00
if (( $contact [ 'rel' ] == CONTACT_IS_FOLLOWER ) || ( $contact [ 'blocked' ]) || ( $contact [ 'readonly' ])) {
logger ( 'diaspora_comment: Ignoring this author.' );
2011-09-14 22:33:42 -04:00
return 202 ;
2011-08-16 02:19:17 -04:00
}
2011-08-26 20:52:24 -04:00
$r = q ( " SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
intval ( $importer [ 'uid' ]),
dbesc ( $guid )
);
if ( count ( $r )) {
2011-08-30 01:50:41 -04:00
logger ( 'diaspora_comment: our comment just got relayed back to us (or there was a guid collision) : ' . $guid );
2011-08-26 20:52:24 -04:00
return ;
}
2011-08-17 07:24:26 -04:00
$r = q ( " SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
2011-08-13 22:03:59 -04:00
intval ( $importer [ 'uid' ]),
2011-08-17 07:24:26 -04:00
dbesc ( $parent_guid )
2011-08-13 22:03:59 -04:00
);
2011-08-17 07:24:26 -04:00
if ( ! count ( $r )) {
2011-08-19 05:53:44 -04:00
logger ( 'diaspora_comment: parent item not found: parent: ' . $parent_guid . ' item: ' . $guid );
2011-08-13 22:03:59 -04:00
return ;
2011-08-17 07:24:26 -04:00
}
$parent_item = $r [ 0 ];
2011-08-13 22:03:59 -04:00
2011-08-17 07:24:26 -04:00
$author_signed_data = $guid . ';' . $parent_guid . ';' . $text . ';' . $diaspora_handle ;
$author_signature = base64_decode ( $author_signature );
2011-08-20 20:50:39 -04:00
if ( strcasecmp ( $diaspora_handle , $msg [ 'author' ]) == 0 ) {
2011-08-17 07:24:26 -04:00
$person = $contact ;
$key = $msg [ 'key' ];
}
else {
2011-08-18 07:20:30 -04:00
$person = find_diaspora_person_by_handle ( $diaspora_handle );
2011-08-17 07:24:26 -04:00
if ( is_array ( $person ) && x ( $person , 'pubkey' ))
$key = $person [ 'pubkey' ];
else {
logger ( 'diaspora_comment: unable to find author details' );
return ;
}
}
2011-09-14 22:33:42 -04:00
if ( ! rsa_verify ( $author_signed_data , $author_signature , $key , 'sha256' )) {
2011-08-17 07:24:26 -04:00
logger ( 'diaspora_comment: verification failed.' );
2011-08-20 23:54:03 -04:00
return ;
2011-08-17 07:24:26 -04:00
}
2011-08-13 22:03:59 -04:00
2011-08-18 08:08:39 -04:00
2011-08-17 07:24:26 -04:00
if ( $parent_author_signature ) {
2011-08-23 22:54:35 -04:00
$owner_signed_data = $guid . ';' . $parent_guid . ';' . $text . ';' . $diaspora_handle ;
2011-08-17 07:24:26 -04:00
$parent_author_signature = base64_decode ( $parent_author_signature );
$key = $msg [ 'key' ];
2011-09-14 22:33:42 -04:00
if ( ! rsa_verify ( $owner_signed_data , $parent_author_signature , $key , 'sha256' )) {
2011-08-17 07:24:26 -04:00
logger ( 'diaspora_comment: owner verification failed.' );
2011-08-20 23:54:03 -04:00
return ;
2011-08-17 07:24:26 -04:00
}
}
// Phew! Everything checks out. Now create an item.
2011-08-25 19:37:27 -04:00
$body = diaspora2bb ( $text );
2011-08-17 07:24:26 -04:00
$message_id = $diaspora_handle . ':' . $guid ;
$datarray = array ();
$datarray [ 'uid' ] = $importer [ 'uid' ];
$datarray [ 'contact-id' ] = $contact [ 'id' ];
$datarray [ 'wall' ] = $parent_item [ 'wall' ];
$datarray [ 'gravity' ] = GRAVITY_COMMENT ;
$datarray [ 'guid' ] = $guid ;
$datarray [ 'uri' ] = $message_id ;
$datarray [ 'parent-uri' ] = $parent_item [ 'uri' ];
// No timestamps for comments? OK, we'll the use current time.
$datarray [ 'created' ] = $datarray [ 'edited' ] = datetime_convert ();
$datarray [ 'private' ] = $parent_item [ 'private' ];
$datarray [ 'owner-name' ] = $contact [ 'name' ];
$datarray [ 'owner-link' ] = $contact [ 'url' ];
$datarray [ 'owner-avatar' ] = $contact [ 'thumb' ];
$datarray [ 'author-name' ] = $person [ 'name' ];
$datarray [ 'author-link' ] = $person [ 'url' ];
$datarray [ 'author-avatar' ] = (( x ( $person , 'thumb' )) ? $person [ 'thumb' ] : $person [ 'photo' ]);
$datarray [ 'body' ] = $body ;
2011-08-26 20:52:24 -04:00
$datarray [ 'app' ] = 'Diaspora' ;
2011-08-17 07:24:26 -04:00
2011-08-18 08:08:39 -04:00
$message_id = item_store ( $datarray );
2011-09-01 00:46:37 -04:00
if ( $message_id ) {
q ( " update item set plink = '%s' where id = %d limit 1 " ,
dbesc ( $a -> get_baseurl () . '/display/' . $importer [ 'nickname' ] . '/' . $message_id ),
intval ( $message_id )
);
}
2011-08-18 08:08:39 -04:00
if ( ! $parent_author_signature ) {
q ( " insert into sign (`iid`,`signed_text`,`signature`,`signer`) values (%d,'%s','%s','%s') " ,
intval ( $message_id ),
dbesc ( $author_signed_data ),
dbesc ( base64_encode ( $author_signature )),
dbesc ( $diaspora_handle )
);
2011-08-17 07:24:26 -04:00
2011-08-24 07:42:28 -04:00
// if the message isn't already being relayed, notify others
// the existence of parent_author_signature means the parent_author or owner
// is already relaying.
2011-08-22 22:27:40 -04:00
2011-08-24 07:42:28 -04:00
proc_run ( 'php' , 'include/notifier.php' , 'comment' , $message_id );
}
2011-08-17 07:24:26 -04:00
return ;
2011-08-10 08:10:48 -04:00
}
2011-08-23 21:17:35 -04:00
function diaspora_photo ( $importer , $xml , $msg ) {
2011-09-03 08:23:36 -04:00
$a = get_app ();
2011-08-23 21:17:35 -04:00
$remote_photo_path = notags ( unxmlify ( $xml -> remote_photo_path ));
$remote_photo_name = notags ( unxmlify ( $xml -> remote_photo_name ));
$status_message_guid = notags ( unxmlify ( $xml -> status_message_guid ));
$guid = notags ( unxmlify ( $xml -> guid ));
$diaspora_handle = notags ( unxmlify ( $xml -> diaspora_handle ));
$public = notags ( unxmlify ( $xml -> public ));
$created_at = notags ( unxmlify ( $xml_created_at ));
$contact = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $msg [ 'author' ]);
if ( ! $contact )
return ;
if (( $contact [ 'rel' ] == CONTACT_IS_FOLLOWER ) || ( $contact [ 'blocked' ]) || ( $contact [ 'readonly' ])) {
logger ( 'diaspora_photo: Ignoring this author.' );
2011-09-14 22:33:42 -04:00
return 202 ;
2011-08-23 21:17:35 -04:00
}
$r = q ( " SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
intval ( $importer [ 'uid' ]),
dbesc ( $status_message_guid )
);
if ( ! count ( $r )) {
logger ( 'diaspora_photo: parent item not found: parent: ' . $parent_guid . ' item: ' . $guid );
return ;
}
$parent_item = $r [ 0 ];
$link_text = '[img]' . $remote_photo_path . $remote_photo_name . '[/img]' . " \n " ;
$r = q ( " update item set `body` = '%s' where `id` = %d and `uid` = %d limit 1 " ,
dbesc ( $link_text . $parent_item [ 'body' ]),
intval ( $parent_item [ 'id' ]),
intval ( $parent_item [ 'uid' ])
);
return ;
}
2011-08-17 01:31:14 -04:00
function diaspora_like ( $importer , $xml , $msg ) {
2011-08-10 08:10:48 -04:00
2011-08-20 21:08:43 -04:00
$a = get_app ();
2011-08-13 22:03:59 -04:00
$guid = notags ( unxmlify ( $xml -> guid ));
2011-08-17 01:31:14 -04:00
$parent_guid = notags ( unxmlify ( $xml -> parent_guid ));
2011-08-13 22:03:59 -04:00
$diaspora_handle = notags ( unxmlify ( $xml -> diaspora_handle ));
2011-08-17 01:31:14 -04:00
$target_type = notags ( unxmlify ( $xml -> target_type ));
$positive = notags ( unxmlify ( $xml -> positive ));
2011-08-17 07:24:26 -04:00
$author_signature = notags ( unxmlify ( $xml -> author_signature ));
2011-08-16 02:19:17 -04:00
2011-08-17 01:31:14 -04:00
$parent_author_signature = (( $xml -> parent_author_signature ) ? notags ( unxmlify ( $xml -> parent_author_signature )) : '' );
2011-08-16 02:19:17 -04:00
2011-08-17 07:24:26 -04:00
// likes on comments not supported here and likes on photos not supported by Diaspora
2011-08-17 01:31:14 -04:00
if ( $target_type !== 'Post' )
return ;
2011-08-17 07:24:26 -04:00
$contact = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $msg [ 'author' ]);
2011-08-30 01:50:41 -04:00
if ( ! $contact ) {
logger ( 'diaspora_like: cannot find contact: ' . $msg [ 'author' ]);
2011-08-16 02:19:17 -04:00
return ;
2011-08-30 01:50:41 -04:00
}
2011-08-16 02:19:17 -04:00
if (( $contact [ 'rel' ] == CONTACT_IS_FOLLOWER ) || ( $contact [ 'blocked' ]) || ( $contact [ 'readonly' ])) {
logger ( 'diaspora_like: Ignoring this author.' );
2011-09-14 22:33:42 -04:00
return 202 ;
2011-08-16 02:19:17 -04:00
}
2011-08-17 01:31:14 -04:00
$r = q ( " SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
2011-08-13 22:03:59 -04:00
intval ( $importer [ 'uid' ]),
2011-08-17 01:31:14 -04:00
dbesc ( $parent_guid )
2011-08-13 22:03:59 -04:00
);
2011-08-17 01:31:14 -04:00
if ( ! count ( $r )) {
logger ( 'diaspora_like: parent item not found: ' . $guid );
2011-08-13 22:03:59 -04:00
return ;
2011-08-17 01:31:14 -04:00
}
2011-08-13 22:03:59 -04:00
2011-08-17 01:31:14 -04:00
$parent_item = $r [ 0 ];
2011-08-20 21:05:05 -04:00
$r = q ( " SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
2011-08-17 01:31:14 -04:00
intval ( $importer [ 'uid' ]),
dbesc ( $guid )
2011-08-13 22:03:59 -04:00
);
2011-08-17 01:31:14 -04:00
if ( count ( $r )) {
if ( $positive === 'true' ) {
logger ( 'diaspora_like: duplicate like: ' . $guid );
return ;
}
if ( $positive === 'false' ) {
q ( " UPDATE `item` SET `deleted` = 1 WHERE `id` = %d AND `uid` = %d LIMIT 1 " ,
intval ( $r [ 0 ][ 'id' ]),
intval ( $importer [ 'uid' ])
);
// FIXME
// send notification via proc_run()
return ;
}
}
if ( $positive === 'false' ) {
logger ( 'diaspora_like: unlike received with no corresponding like' );
return ;
}
2011-08-22 04:57:52 -04:00
$author_signed_data = $guid . ';' . $target_type . ';' . $parent_guid . ';' . $positive . ';' . $diaspora_handle ;
2011-08-17 01:31:14 -04:00
$author_signature = base64_decode ( $author_signature );
2011-08-20 20:50:39 -04:00
if ( strcasecmp ( $diaspora_handle , $msg [ 'author' ]) == 0 ) {
2011-08-17 07:24:26 -04:00
$person = $contact ;
2011-08-17 01:31:14 -04:00
$key = $msg [ 'key' ];
2011-08-17 07:24:26 -04:00
}
else {
2011-08-18 07:20:30 -04:00
$person = find_diaspora_person_by_handle ( $diaspora_handle );
2011-08-17 07:24:26 -04:00
if ( is_array ( $person ) && x ( $person , 'pubkey' ))
$key = $person [ 'pubkey' ];
else {
2011-08-21 07:18:39 -04:00
logger ( 'diaspora_like: unable to find author details' );
2011-08-17 07:24:26 -04:00
return ;
}
}
2011-08-17 01:31:14 -04:00
2011-09-14 22:33:42 -04:00
if ( ! rsa_verify ( $author_signed_data , $author_signature , $key , 'sha256' )) {
2011-08-17 01:31:14 -04:00
logger ( 'diaspora_like: verification failed.' );
2011-08-22 04:57:52 -04:00
return ;
2011-08-17 01:31:14 -04:00
}
2011-08-13 22:03:59 -04:00
2011-08-17 01:31:14 -04:00
if ( $parent_author_signature ) {
2011-08-30 22:20:56 -04:00
$owner_signed_data = $guid . ';' . $target_type . ';' . $parent_guid . ';' . $positive . ';' . $diaspora_handle ;
2011-08-13 22:03:59 -04:00
2011-08-17 01:31:14 -04:00
$parent_author_signature = base64_decode ( $parent_author_signature );
2011-08-13 22:03:59 -04:00
2011-08-17 01:31:14 -04:00
$key = $msg [ 'key' ];
2011-09-14 22:33:42 -04:00
if ( ! rsa_verify ( $owner_signed_data , $parent_author_signature , $key , 'sha256' )) {
2011-08-17 01:31:14 -04:00
logger ( 'diaspora_like: owner verification failed.' );
2011-08-22 04:57:52 -04:00
return ;
2011-08-17 01:31:14 -04:00
}
}
// Phew! Everything checks out. Now create an item.
$uri = $diaspora_handle . ':' . $guid ;
2011-08-17 07:24:26 -04:00
$activity = ACTIVITY_LIKE ;
2011-08-17 01:31:14 -04:00
$post_type = (( $parent_item [ 'resource-id' ]) ? t ( 'photo' ) : t ( 'status' ));
$objtype = (( $parent_item [ 'resource-id' ]) ? ACTIVITY_OBJ_PHOTO : ACTIVITY_OBJ_NOTE );
$link = xmlify ( '<link rel="alternate" type="text/html" href="' . $a -> get_baseurl () . '/display/' . $importer [ 'nickname' ] . '/' . $parent_item [ 'id' ] . '" />' . " \n " ) ;
$body = $parent_item [ 'body' ];
2011-08-13 22:03:59 -04:00
$obj = <<< EOT
< object >
< type > $objtype </ type >
< local > 1 </ local >
2011-08-17 01:31:14 -04:00
< id > { $parent_item [ 'uri' ]} </ id >
2011-08-13 22:03:59 -04:00
< link > $link </ link >
< title ></ title >
< content > $body </ content >
</ object >
EOT ;
2011-08-17 01:31:14 -04:00
$bodyverb = t ( '%1$s likes %2$s\'s %3$s' );
2011-08-13 22:03:59 -04:00
$arr = array ();
$arr [ 'uri' ] = $uri ;
2011-08-17 01:31:14 -04:00
$arr [ 'uid' ] = $importer [ 'uid' ];
2011-08-20 21:14:19 -04:00
$arr [ 'guid' ] = $guid ;
2011-08-13 22:03:59 -04:00
$arr [ 'contact-id' ] = $contact [ 'id' ];
$arr [ 'type' ] = 'activity' ;
2011-08-17 01:31:14 -04:00
$arr [ 'wall' ] = $parent_item [ 'wall' ];
2011-08-13 22:03:59 -04:00
$arr [ 'gravity' ] = GRAVITY_LIKE ;
2011-08-17 01:31:14 -04:00
$arr [ 'parent' ] = $parent_item [ 'id' ];
$arr [ 'parent-uri' ] = $parent_item [ 'uri' ];
2011-08-20 21:14:19 -04:00
$arr [ 'owner-name' ] = $contact [ 'name' ];
$arr [ 'owner-link' ] = $contact [ 'url' ];
$arr [ 'owner-avatar' ] = $contact [ 'thumb' ];
2011-08-17 01:31:14 -04:00
2011-08-20 21:14:19 -04:00
$arr [ 'author-name' ] = $person [ 'name' ];
$arr [ 'author-link' ] = $person [ 'url' ];
$arr [ 'author-avatar' ] = (( x ( $person , 'thumb' )) ? $person [ 'thumb' ] : $person [ 'photo' ]);
2011-08-13 22:03:59 -04:00
$ulink = '[url=' . $contact [ 'url' ] . ']' . $contact [ 'name' ] . '[/url]' ;
2011-08-17 01:31:14 -04:00
$alink = '[url=' . $parent_item [ 'author-link' ] . ']' . $parent_item [ 'author-name' ] . '[/url]' ;
$plink = '[url=' . $a -> get_baseurl () . '/display/' . $importer [ 'nickname' ] . '/' . $parent_item [ 'id' ] . ']' . $post_type . '[/url]' ;
2011-08-13 22:03:59 -04:00
$arr [ 'body' ] = sprintf ( $bodyverb , $ulink , $alink , $plink );
2011-08-26 20:52:24 -04:00
$arr [ 'app' ] = 'Diaspora' ;
2011-08-17 07:24:26 -04:00
$arr [ 'private' ] = $parent_item [ 'private' ];
2011-08-13 22:03:59 -04:00
$arr [ 'verb' ] = $activity ;
$arr [ 'object-type' ] = $objtype ;
$arr [ 'object' ] = $obj ;
$arr [ 'visible' ] = 1 ;
$arr [ 'unseen' ] = 1 ;
$arr [ 'last-child' ] = 0 ;
2011-08-18 08:08:39 -04:00
$message_id = item_store ( $arr );
2011-08-13 22:03:59 -04:00
2011-09-01 00:46:37 -04:00
if ( $message_id ) {
q ( " update item set plink = '%s' where id = %d limit 1 " ,
dbesc ( $a -> get_baseurl () . '/display/' . $importer [ 'nickname' ] . '/' . $message_id ),
intval ( $message_id )
);
}
2011-08-18 08:08:39 -04:00
if ( ! $parent_author_signature ) {
q ( " insert into sign (`iid`,`signed_text`,`signature`,`signer`) values (%d,'%s','%s','%s') " ,
intval ( $message_id ),
dbesc ( $author_signed_data ),
dbesc ( base64_encode ( $author_signature )),
dbesc ( $diaspora_handle )
);
}
2011-08-13 22:03:59 -04:00
2011-08-24 07:42:28 -04:00
// if the message isn't already being relayed, notify others
// the existence of parent_author_signature means the parent_author or owner
// is already relaying.
if ( ! $parent_author_signature )
proc_run ( 'php' , 'include/notifier.php' , 'comment' , $message_id );
2011-08-13 22:03:59 -04:00
2011-08-18 08:08:39 -04:00
return ;
2011-08-10 08:10:48 -04:00
}
2011-08-16 02:19:17 -04:00
function diaspora_retraction ( $importer , $xml ) {
$guid = notags ( unxmlify ( $xml -> guid ));
$diaspora_handle = notags ( unxmlify ( $xml -> diaspora_handle ));
2011-08-22 23:35:34 -04:00
$type = notags ( unxmlify ( $xml -> type ));
2011-08-16 02:19:17 -04:00
$contact = diaspora_get_contact_by_handle ( $importer [ 'uid' ], $diaspora_handle );
if ( ! $contact )
return ;
2011-08-22 23:35:34 -04:00
if ( $type === 'Person' ) {
contact_remove ( $contact [ 'id' ]);
}
elseif ( $type === 'Post' ) {
$r = q ( " select * from item where guid = '%s' and uid = %d limit 1 " ,
dbesc ( 'guid' ),
intval ( $importer [ 'uid' ])
);
if ( count ( $r )) {
if ( link_compare ( $r [ 0 ][ 'author-link' ], $contact [ 'url' ])) {
q ( " update item set `deleted` = 1, `changed` = '%s' where `id` = %d limit 1 " ,
dbesc ( datetime_convert ()),
intval ( $r [ 0 ][ 'id' ])
);
}
}
}
2011-08-10 08:10:48 -04:00
2011-09-14 22:33:42 -04:00
return 202 ;
2011-08-22 23:35:34 -04:00
// NOTREACHED
2011-08-10 08:10:48 -04:00
}
2011-08-14 23:38:31 -04:00
function diaspora_share ( $me , $contact ) {
$a = get_app ();
$myaddr = $me [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
$theiraddr = $contact [ 'addr' ];
$tpl = get_markup_template ( 'diaspora_share.tpl' );
$msg = replace_macros ( $tpl , array (
2011-08-19 08:20:30 -04:00
'$sender' => $myaddr ,
2011-08-14 23:38:31 -04:00
'$recipient' => $theiraddr
));
2011-08-19 05:24:30 -04:00
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $me , $contact , $me [ 'prvkey' ], $contact [ 'pubkey' ])));
2011-08-14 23:38:31 -04:00
2011-08-24 04:21:24 -04:00
return ( diaspora_transmit ( $owner , $contact , $slap ));
2011-08-14 23:38:31 -04:00
}
2011-08-22 23:35:34 -04:00
function diaspora_unshare ( $me , $contact ) {
$a = get_app ();
$myaddr = $me [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
$tpl = get_markup_template ( 'diaspora_retract.tpl' );
$msg = replace_macros ( $tpl , array (
'$guid' => $me [ 'guid' ],
'$type' => 'Person' ,
'$handle' => $myaddr
));
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $me , $contact , $me [ 'prvkey' ], $contact [ 'pubkey' ])));
2011-08-24 04:21:24 -04:00
return ( diaspora_transmit ( $owner , $contact , $slap ));
2011-08-22 23:35:34 -04:00
}
2011-08-15 00:23:02 -04:00
function diaspora_send_status ( $item , $owner , $contact ) {
$a = get_app ();
2011-08-19 00:09:44 -04:00
$myaddr = $owner [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
2011-08-15 00:23:02 -04:00
$theiraddr = $contact [ 'addr' ];
2011-08-23 21:17:35 -04:00
$images = array ();
$body = $item [ 'body' ];
$cnt = preg_match_all ( '|\[img\](.*?)\[\/img\]|' , $body , $matches , PREG_SET_ORDER );
if ( $cnt ) {
foreach ( $matches as $mtch ) {
$detail = array ();
$detail [ 'str' ] = $mtch [ 0 ];
2011-08-23 21:50:18 -04:00
$detail [ 'path' ] = dirname ( $mtch [ 1 ]) . '/' ;
2011-08-23 21:17:35 -04:00
$detail [ 'file' ] = basename ( $mtch [ 1 ]);
$detail [ 'guid' ] = $item [ 'guid' ];
$detail [ 'handle' ] = $myaddr ;
$images [] = $detail ;
2011-08-23 22:01:08 -04:00
$body = str_replace ( $detail [ 'str' ], t ( 'link' ), $body );
2011-08-23 21:17:35 -04:00
}
}
2011-08-26 20:52:24 -04:00
$body = xmlify ( html_entity_decode ( bb2diaspora ( $body )));
2011-08-15 00:23:02 -04:00
$public = (( $item [ 'private' ]) ? 'false' : 'true' );
require_once ( 'include/datetime.php' );
2011-08-29 21:01:59 -04:00
$created = datetime_convert ( 'UTC' , 'UTC' , $item [ 'created' ], 'Y-m-d H:i:s \U\T\C' );
2011-08-15 00:23:02 -04:00
$tpl = get_markup_template ( 'diaspora_post.tpl' );
$msg = replace_macros ( $tpl , array (
'$body' => $body ,
'$guid' => $item [ 'guid' ],
'$handle' => xmlify ( $myaddr ),
'$public' => $public ,
'$created' => $created
));
2011-08-23 21:50:18 -04:00
logger ( 'diaspora_send_status: ' . $owner [ 'username' ] . ' -> ' . $contact [ 'name' ] . ' base message: ' . $msg , LOGGER_DATA );
2011-08-15 00:23:02 -04:00
2011-08-19 05:24:30 -04:00
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $owner , $contact , $owner [ 'uprvkey' ], $contact [ 'pubkey' ])));
2011-08-15 00:23:02 -04:00
2011-08-24 04:21:24 -04:00
$return_code = diaspora_transmit ( $owner , $contact , $slap );
2011-08-23 21:17:35 -04:00
if ( count ( $images )) {
diaspora_send_images ( $item , $owner , $contact , $images );
}
2011-08-15 00:23:02 -04:00
return $return_code ;
}
2011-08-19 00:09:44 -04:00
2011-08-23 21:17:35 -04:00
function diaspora_send_images ( $item , $owner , $contact , $images ) {
$a = get_app ();
if ( ! count ( $images ))
return ;
$mysite = substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 ) . '/photo' ;
$tpl = get_markup_template ( 'diaspora_photo.tpl' );
foreach ( $images as $image ) {
if ( ! stristr ( $image [ 'path' ], $mysite ))
continue ;
$resource = str_replace ( '.jpg' , '' , $image [ 'file' ]);
$resource = substr ( $resource , 0 , strpos ( $resource , '-' ));
$r = q ( " select * from photo where `resource-id` = '%s' and `uid` = %d limit 1 " ,
dbesc ( $resource ),
intval ( $owner [ 'uid' ])
);
if ( ! count ( $r ))
continue ;
$public = (( $r [ 0 ][ 'allow_cid' ] || $r [ 0 ][ 'allow_gid' ] || $r [ 0 ][ 'deny_cid' ] || $r [ 0 ][ 'deny_gid' ]) ? 'false' : 'true' );
$msg = replace_macros ( $tpl , array (
'$path' => xmlify ( $image [ 'path' ]),
'$filename' => xmlify ( $image [ 'file' ]),
'$msg_guid' => xmlify ( $image [ 'guid' ]),
'$guid' => xmlify ( $r [ 0 ][ 'guid' ]),
'$handle' => xmlify ( $image [ 'handle' ]),
'$public' => xmlify ( $public ),
2011-08-29 21:01:59 -04:00
'$created_at' => xmlify ( datetime_convert ( 'UTC' , 'UTC' , $r [ 0 ][ 'created' ], 'Y-m-d H:i:s \U\T\C' ))
2011-08-23 21:17:35 -04:00
));
2011-08-24 04:21:24 -04:00
2011-08-23 21:17:35 -04:00
logger ( 'diaspora_send_photo: base message: ' . $msg , LOGGER_DATA );
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $owner , $contact , $owner [ 'uprvkey' ], $contact [ 'pubkey' ])));
2011-08-24 04:21:24 -04:00
diaspora_transmit ( $owner , $contact , $slap );
2011-08-23 21:17:35 -04:00
}
}
2011-08-19 00:09:44 -04:00
function diaspora_send_followup ( $item , $owner , $contact ) {
$a = get_app ();
2011-08-19 05:24:30 -04:00
$myaddr = $owner [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
2011-08-19 00:09:44 -04:00
$theiraddr = $contact [ 'addr' ];
$p = q ( " select guid from item where parent = %d limit 1 " ,
$item [ 'parent' ]
);
if ( count ( $p ))
$parent_guid = $p [ 0 ][ 'guid' ];
else
return ;
if ( $item [ 'verb' ] === ACTIVITY_LIKE ) {
$tpl = get_markup_template ( 'diaspora_like.tpl' );
$like = true ;
$target_type = 'Post' ;
$positive = (( $item [ 'deleted' ]) ? 'false' : 'true' );
}
else {
$tpl = get_markup_template ( 'diaspora_comment.tpl' );
$like = false ;
}
2011-08-26 20:52:24 -04:00
$text = html_entity_decode ( bb2diaspora ( $item [ 'body' ]));
2011-08-19 00:09:44 -04:00
// sign it
if ( $like )
2011-08-23 04:00:29 -04:00
$signed_text = $item [ 'guid' ] . ';' . $target_type . ';' . $parent_guid . ';' . $positive . ';' . $myaddr ;
2011-08-19 00:09:44 -04:00
else
2011-08-19 05:24:30 -04:00
$signed_text = $item [ 'guid' ] . ';' . $parent_guid . ';' . $text . ';' . $myaddr ;
2011-08-19 00:09:44 -04:00
2011-09-14 22:33:42 -04:00
$authorsig = base64_encode ( rsa_sign ( $signed_text , $owner [ 'uprvkey' ], 'sha256' ));
2011-08-19 00:09:44 -04:00
$msg = replace_macros ( $tpl , array (
'$guid' => xmlify ( $item [ 'guid' ]),
'$parent_guid' => xmlify ( $parent_guid ),
'$target_type' => xmlify ( $target_type ),
'$authorsig' => xmlify ( $authorsig ),
2011-08-19 05:24:30 -04:00
'$body' => xmlify ( $text ),
2011-08-19 00:09:44 -04:00
'$positive' => xmlify ( $positive ),
2011-08-19 05:24:30 -04:00
'$handle' => xmlify ( $myaddr )
2011-08-19 00:09:44 -04:00
));
logger ( 'diaspora_followup: base message: ' . $msg , LOGGER_DATA );
2011-08-19 05:24:30 -04:00
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $owner , $contact , $owner [ 'uprvkey' ], $contact [ 'pubkey' ])));
2011-08-19 00:09:44 -04:00
2011-08-24 04:21:24 -04:00
return ( diaspora_transmit ( $owner , $contact , $slap ));
2011-08-19 00:09:44 -04:00
}
function diaspora_send_relay ( $item , $owner , $contact ) {
2011-08-19 05:24:30 -04:00
$a = get_app ();
$myaddr = $owner [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
$theiraddr = $contact [ 'addr' ];
2011-08-19 00:09:44 -04:00
$p = q ( " select guid from item where parent = %d limit 1 " ,
$item [ 'parent' ]
);
if ( count ( $p ))
$parent_guid = $p [ 0 ][ 'guid' ];
else
return ;
if ( $item [ 'verb' ] === ACTIVITY_LIKE ) {
$tpl = get_markup_template ( 'diaspora_like_relay.tpl' );
$like = true ;
$target_type = 'Post' ;
$positive = (( $item [ 'deleted' ]) ? 'false' : 'true' );
}
else {
$tpl = get_markup_template ( 'diaspora_comment_relay.tpl' );
$like = false ;
}
2011-08-28 08:04:49 -04:00
$body = $item [ 'body' ];
$text = html_entity_decode ( bb2diaspora ( $body ));
2011-08-19 00:09:44 -04:00
2011-08-26 10:29:22 -04:00
// fetch the original signature if somebody sent the post to us to relay
2011-08-29 03:51:08 -04:00
// If we are relaying for a reply originating on our own account, there wasn't a 'send to relay'
2011-08-26 10:29:22 -04:00
// action. It wasn't needed. In that case create the original signature and the
// owner (parent author) signature
2011-08-29 03:51:08 -04:00
// comments from other networks will be relayed under our name, with a brief
// preamble to describe what's happening and noting the real author
2011-08-19 00:09:44 -04:00
2011-08-26 10:29:22 -04:00
$r = q ( " select * from sign where iid = %d limit 1 " ,
intval ( $item [ 'id' ])
);
if ( count ( $r )) {
$orig_sign = $r [ 0 ];
$signed_text = $orig_sign [ 'signed_text' ];
$authorsig = $orig_sign [ 'signature' ];
2011-08-29 03:51:08 -04:00
$handle = $orig_sign [ 'signer' ];
2011-08-26 10:29:22 -04:00
}
else {
2011-08-28 08:00:30 -04:00
2011-08-28 22:22:27 -04:00
$itemcontact = q ( " select * from contact where `id` = %d limit 1 " ,
intval ( $item [ 'contact-id' ])
);
if ( count ( $itemcontact )) {
if ( ! $itemcontact [ 0 ][ 'self' ]) {
$prefix = sprintf ( t ( '[Relayed] Comment authored by %s from network %s' ),
'[' . $item [ 'author-name' ] . ']' . '(' . $item [ 'author-link' ] . ')' ,
network_to_name ( $itemcontact [ 'network' ])) . " \n " ;
$body = $prefix . $body ;
}
}
else {
2011-08-28 08:00:30 -04:00
2011-08-28 22:22:27 -04:00
if ( $like )
$signed_text = $item [ 'guid' ] . ';' . $target_type . ';' . $parent_guid . ';' . $positive . ';' . $myaddr ;
else
$signed_text = $item [ 'guid' ] . ';' . $parent_guid . ';' . $text . ';' . $myaddr ;
2011-08-28 08:00:30 -04:00
2011-09-14 22:33:42 -04:00
$authorsig = base64_encode ( rsa_sign ( $signed_text , $owner [ 'uprvkey' ], 'sha256' ));
2011-08-28 08:00:30 -04:00
2011-08-28 22:22:27 -04:00
q ( " insert into sign (`iid`,`signed_text`,`signature`,`signer`) values (%d,'%s','%s','%s') " ,
intval ( $item [ 'id' ]),
dbesc ( $signed_text ),
dbesc ( base64_encode ( $authorsig )),
dbesc ( $myaddr )
);
2011-08-29 03:51:08 -04:00
$handle = $myaddr ;
2011-08-28 22:22:27 -04:00
}
2011-08-26 10:29:22 -04:00
}
// sign it
2011-08-19 00:09:44 -04:00
2011-09-14 22:33:42 -04:00
$parentauthorsig = base64_encode ( rsa_sign ( $signed_text , $owner [ 'uprvkey' ], 'sha256' ));
2011-08-19 00:09:44 -04:00
$msg = replace_macros ( $tpl , array (
'$guid' => xmlify ( $item [ 'guid' ]),
'$parent_guid' => xmlify ( $parent_guid ),
'$target_type' => xmlify ( $target_type ),
'$authorsig' => xmlify ( $orig_sign [ 'signature' ]),
'$parentsig' => xmlify ( $parentauthorsig ),
2011-08-26 10:29:22 -04:00
'$body' => xmlify ( $text ),
2011-08-19 00:09:44 -04:00
'$positive' => xmlify ( $positive ),
2011-08-29 03:51:08 -04:00
'$handle' => xmlify ( $handle )
2011-08-19 00:09:44 -04:00
));
logger ( 'diaspora_relay_comment: base message: ' . $msg , LOGGER_DATA );
2011-08-19 05:24:30 -04:00
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $owner , $contact , $owner [ 'uprvkey' ], $contact [ 'pubkey' ])));
2011-08-19 00:09:44 -04:00
2011-08-24 04:21:24 -04:00
return ( diaspora_transmit ( $owner , $contact , $slap ));
2011-08-19 00:09:44 -04:00
}
function diaspora_send_retraction ( $item , $owner , $contact ) {
2011-08-22 23:35:34 -04:00
$a = get_app ();
$myaddr = $owner [ 'nickname' ] . '@' . substr ( $a -> get_baseurl (), strpos ( $a -> get_baseurl (), '://' ) + 3 );
2011-08-19 00:09:44 -04:00
2011-08-22 23:35:34 -04:00
$tpl = get_markup_template ( 'diaspora_retract.tpl' );
$msg = replace_macros ( $tpl , array (
'$guid' => $item [ 'guid' ],
'$type' => 'Post' ,
'$handle' => $myaddr
));
2011-08-19 00:09:44 -04:00
2011-08-22 23:35:34 -04:00
$slap = 'xml=' . urlencode ( urlencode ( diaspora_msg_build ( $msg , $owner , $contact , $owner [ 'uprvkey' ], $contact [ 'pubkey' ])));
2011-08-19 00:09:44 -04:00
2011-08-24 04:21:24 -04:00
return ( diaspora_transmit ( $owner , $contact , $slap ));
}
function diaspora_transmit ( $owner , $contact , $slap ) {
$a = get_app ();
2011-08-22 23:35:34 -04:00
post_url ( $contact [ 'notify' ] . '/' , $slap );
$return_code = $a -> get_curl_code ();
2011-08-24 04:21:24 -04:00
logger ( 'diaspora_transmit: returns: ' . $return_code );
if ( ! $return_code ) {
logger ( 'diaspora_transmit: queue message' );
// queue message for redelivery
q ( " INSERT INTO `queue` ( `cid`, `created`, `last`, `content`)
VALUES ( % d , '%s' , '%s' , '%s' ) " ,
intval ( $contact [ 'id' ]),
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
dbesc ( $slap )
);
}
2011-08-19 00:09:44 -04:00
2011-08-24 04:21:24 -04:00
return (( $return_code ) ? $return_code : ( - 1 ));
}