2016-02-27 22:54:17 +00:00
< ? php
/**
* @ file include / diaspora . php
* @ brief The implementation of the diaspora protocol
*/
2016-03-01 06:57:26 +00:00
require_once ( " include/items.php " );
2016-02-28 18:05:23 +00:00
require_once ( " include/bb2diaspora.php " );
2016-02-27 22:54:17 +00:00
require_once ( " include/Scrape.php " );
2016-02-28 18:05:23 +00:00
require_once ( " include/Contact.php " );
2016-02-29 07:02:50 +00:00
require_once ( " include/Photo.php " );
require_once ( " include/socgraph.php " );
2016-03-01 06:57:26 +00:00
require_once ( " include/group.php " );
2016-03-05 23:53:30 +00:00
require_once ( " include/xml.php " );
require_once ( " include/datetime.php " );
2016-02-27 22:54:17 +00:00
2016-03-03 22:34:17 +00:00
/**
2016-03-05 23:53:30 +00:00
* @ brief This class contain functions to create and send Diaspora XML files
2016-03-03 22:34:17 +00:00
*
*/
2016-03-05 23:53:30 +00:00
class diaspora {
2016-02-27 22:54:17 +00:00
2016-03-05 23:53:30 +00:00
public static function fetch_relay () {
2016-02-27 22:54:17 +00:00
2016-03-05 23:53:30 +00:00
$serverdata = get_config ( " system " , " relay_server " );
if ( $serverdata == " " )
return array ();
2016-02-29 07:02:50 +00:00
2016-03-05 23:53:30 +00:00
$relay = array ();
2016-02-27 22:54:17 +00:00
2016-03-05 23:53:30 +00:00
$servers = explode ( " , " , $serverdata );
foreach ( $servers AS $server ) {
$server = trim ( $server );
$batch = $server . " /receive/public " ;
$relais = q ( " SELECT `batch`, `id`, `name`,`network` FROM `contact` WHERE `uid` = 0 AND `batch` = '%s' LIMIT 1 " , dbesc ( $batch ));
if ( ! $relais ) {
$addr = " relay@ " . str_replace ( " http:// " , " " , normalise_link ( $server ));
$r = q ( " INSERT INTO `contact` (`uid`, `created`, `name`, `nick`, `addr`, `url`, `nurl`, `batch`, `network`, `rel`, `blocked`, `pending`, `writable`, `name-date`, `uri-date`, `avatar-date`)
VALUES ( 0 , '%s' , '%s' , 'relay' , '%s' , '%s' , '%s' , '%s' , '%s' , % d , 0 , 0 , 1 , '%s' , '%s' , '%s' ) " ,
datetime_convert (),
dbesc ( $addr ),
dbesc ( $addr ),
dbesc ( $server ),
dbesc ( normalise_link ( $server )),
dbesc ( $batch ),
dbesc ( NETWORK_DIASPORA ),
intval ( CONTACT_IS_FOLLOWER ),
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ())
);
$relais = q ( " SELECT `batch`, `id`, `name`,`network` FROM `contact` WHERE `uid` = 0 AND `batch` = '%s' LIMIT 1 " , dbesc ( $batch ));
if ( $relais )
$relay [] = $relais [ 0 ];
} else
$relay [] = $relais [ 0 ];
2016-02-29 07:02:50 +00:00
}
2016-03-03 22:34:17 +00:00
2016-03-05 23:53:30 +00:00
return $relay ;
}
2016-02-27 22:54:17 +00:00
2016-03-03 22:34:17 +00:00
/**
* @ brief Dispatches public messages and find the fitting receivers
*
* @ param array $msg The post that will be dispatched
*
* @ return bool Was the message accepted ?
*/
2016-02-27 22:54:17 +00:00
public static function dispatch_public ( $msg ) {
$enabled = intval ( get_config ( " system " , " diaspora_enabled " ));
if ( ! $enabled ) {
2016-02-29 07:02:50 +00:00
logger ( " diaspora is disabled " );
2016-02-27 22:54:17 +00:00
return false ;
}
// Use a dummy importer to import the data for the public copy
$importer = array ( " uid " => 0 , " page-flags " => PAGE_FREELOVE );
2016-02-29 22:54:25 +00:00
$item_id = self :: dispatch ( $importer , $msg );
2016-02-27 22:54:17 +00:00
// Now distribute it to the followers
$r = q ( " SELECT `user`.* FROM `user` WHERE `user`.`uid` IN
( SELECT `contact` . `uid` FROM `contact` WHERE `contact` . `network` = '%s' AND `contact` . `addr` = '%s' )
AND NOT `account_expired` AND NOT `account_removed` " ,
dbesc ( NETWORK_DIASPORA ),
dbesc ( $msg [ " author " ])
);
2016-03-04 22:28:43 +00:00
if ( $r ) {
2016-02-27 22:54:17 +00:00
foreach ( $r as $rr ) {
logger ( " delivering to: " . $rr [ " username " ]);
self :: dispatch ( $rr , $msg );
}
} else
logger ( " No subscribers for " . $msg [ " author " ] . " " . print_r ( $msg , true ));
2016-02-29 22:54:25 +00:00
return $item_id ;
2016-02-27 22:54:17 +00:00
}
2016-03-03 22:34:17 +00:00
/**
* @ brief Dispatches the different message types to the different functions
*
* @ param array $importer Array of the importer user
* @ param array $msg The post that will be dispatched
*
* @ return bool Was the message accepted ?
*/
2016-02-27 22:54:17 +00:00
public static function dispatch ( $importer , $msg ) {
// The sender is the handle of the contact that sent the message.
// This will often be different with relayed messages (for example "like" and "comment")
2016-02-28 18:05:23 +00:00
$sender = $msg [ " author " ];
2016-02-27 22:54:17 +00:00
2016-02-29 22:54:25 +00:00
if ( ! diaspora :: valid_posting ( $msg , $fields )) {
2016-02-27 22:54:17 +00:00
logger ( " Invalid posting " );
return false ;
}
$type = $fields -> getName ();
switch ( $type ) {
2016-03-12 18:19:20 +00:00
case " account_deletion " :
2016-03-04 23:27:44 +00:00
return self :: receive_account_deletion ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " comment " :
2016-03-04 23:27:44 +00:00
return self :: receive_comment ( $importer , $sender , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " conversation " :
2016-03-04 23:27:44 +00:00
return self :: receive_conversation ( $importer , $msg , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " like " :
2016-03-04 23:27:44 +00:00
return self :: receive_like ( $importer , $sender , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " message " :
2016-03-04 23:27:44 +00:00
return self :: receive_message ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
case " participation " : // Not implemented
2016-03-04 23:27:44 +00:00
return self :: receive_participation ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " photo " : // Not implemented
2016-03-04 23:27:44 +00:00
return self :: receive_photo ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
case " poll_participation " : // Not implemented
2016-03-04 23:27:44 +00:00
return self :: receive_poll_participation ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " profile " :
2016-03-04 23:27:44 +00:00
return self :: receive_profile ( $importer , $fields );
2016-02-27 22:54:17 +00:00
case " request " :
2016-03-04 23:27:44 +00:00
return self :: receive_request ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " reshare " :
2016-03-04 23:27:44 +00:00
return self :: receive_reshare ( $importer , $fields );
2016-02-27 22:54:17 +00:00
2016-03-12 18:19:20 +00:00
case " retraction " :
2016-03-04 23:27:44 +00:00
return self :: receive_retraction ( $importer , $sender , $fields );
2016-03-03 22:34:17 +00:00
2016-03-12 18:19:20 +00:00
case " status_message " :
2016-03-04 23:27:44 +00:00
return self :: receive_status_message ( $importer , $fields );
2016-02-27 22:54:17 +00:00
default :
logger ( " Unknown message type " . $type );
return false ;
}
return true ;
}
/**
* @ brief Checks if a posting is valid and fetches the data fields .
*
* This function does not only check the signature .
* It also does the conversion between the old and the new diaspora format .
*
* @ param array $msg Array with the XML , the sender handle and the sender signature
2016-02-29 07:02:50 +00:00
* @ param object $fields SimpleXML object that contains the posting when it is valid
2016-02-27 22:54:17 +00:00
*
* @ return bool Is the posting valid ?
*/
2016-02-29 22:54:25 +00:00
private function valid_posting ( $msg , & $fields ) {
2016-02-27 22:54:17 +00:00
2016-02-28 18:05:23 +00:00
$data = parse_xml_string ( $msg [ " message " ], false );
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
if ( ! is_object ( $data ))
return false ;
2016-02-27 22:54:17 +00:00
$first_child = $data -> getName ();
2016-02-29 07:02:50 +00:00
// Is this the new or the old version?
2016-02-27 22:54:17 +00:00
if ( $data -> getName () == " XML " ) {
$oldXML = true ;
foreach ( $data -> post -> children () as $child )
$element = $child ;
} else {
$oldXML = false ;
$element = $data ;
}
$type = $element -> getName ();
2016-03-03 22:34:17 +00:00
$orig_type = $type ;
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
// All retractions are handled identically from now on.
// In the new version there will only be "retraction".
2016-02-27 22:54:17 +00:00
if ( in_array ( $type , array ( " signed_retraction " , " relayable_retraction " )))
$type = " retraction " ;
$fields = new SimpleXMLElement ( " < " . $type . " /> " );
$signed_data = " " ;
2016-02-29 07:02:50 +00:00
foreach ( $element -> children () AS $fieldname => $entry ) {
2016-02-27 22:54:17 +00:00
if ( $oldXML ) {
// Translation for the old XML structure
if ( $fieldname == " diaspora_handle " )
$fieldname = " author " ;
if ( $fieldname == " participant_handles " )
$fieldname = " participants " ;
if ( in_array ( $type , array ( " like " , " participation " ))) {
if ( $fieldname == " target_type " )
$fieldname = " parent_type " ;
}
if ( $fieldname == " sender_handle " )
$fieldname = " author " ;
if ( $fieldname == " recipient_handle " )
$fieldname = " recipient " ;
if ( $fieldname == " root_diaspora_id " )
$fieldname = " root_author " ;
if ( $type == " retraction " ) {
if ( $fieldname == " post_guid " )
$fieldname = " target_guid " ;
if ( $fieldname == " type " )
$fieldname = " target_type " ;
}
}
if ( $fieldname == " author_signature " )
2016-02-29 07:02:50 +00:00
$author_signature = base64_decode ( $entry );
2016-02-27 22:54:17 +00:00
elseif ( $fieldname == " parent_author_signature " )
2016-02-29 07:02:50 +00:00
$parent_author_signature = base64_decode ( $entry );
2016-02-27 22:54:17 +00:00
elseif ( $fieldname != " target_author_signature " ) {
if ( $signed_data != " " ) {
$signed_data .= " ; " ;
$signed_data_parent .= " ; " ;
}
2016-02-29 07:02:50 +00:00
$signed_data .= $entry ;
2016-02-27 22:54:17 +00:00
}
2016-03-03 22:34:17 +00:00
if ( ! in_array ( $fieldname , array ( " parent_author_signature " , " target_author_signature " )) OR
( $orig_type == " relayable_retraction " ))
2016-02-29 07:02:50 +00:00
xml :: copy ( $entry , $fields , $fieldname );
2016-02-27 22:54:17 +00:00
}
2016-02-29 07:02:50 +00:00
// This is something that shouldn't happen at all.
if ( in_array ( $type , array ( " status_message " , " reshare " , " profile " )))
2016-02-28 18:05:23 +00:00
if ( $msg [ " author " ] != $fields -> author ) {
2016-02-27 22:54:17 +00:00
logger ( " Message handle is not the same as envelope sender. Quitting this message. " );
return false ;
}
2016-02-29 07:02:50 +00:00
// Only some message types have signatures. So we quit here for the other types.
2016-03-01 22:21:56 +00:00
if ( ! in_array ( $type , array ( " comment " , " message " , " like " )))
2016-02-27 22:54:17 +00:00
return true ;
2016-02-29 07:02:50 +00:00
// No author_signature? This is a must, so we quit.
2016-02-27 22:54:17 +00:00
if ( ! isset ( $author_signature ))
return false ;
if ( isset ( $parent_author_signature )) {
2016-02-28 18:05:23 +00:00
$key = self :: get_key ( $msg [ " author " ]);
2016-02-27 22:54:17 +00:00
if ( ! rsa_verify ( $signed_data , $parent_author_signature , $key , " sha256 " ))
return false ;
}
$key = self :: get_key ( $fields -> author );
return rsa_verify ( $signed_data , $author_signature , $key , " sha256 " );
}
2016-03-03 22:34:17 +00:00
/**
* @ brief Fetches the public key for a given handle
*
* @ param string $handle The handle
*
* @ return string The public key
*/
2016-02-27 22:54:17 +00:00
private function get_key ( $handle ) {
logger ( " Fetching diaspora key for: " . $handle );
$r = self :: get_person_by_handle ( $handle );
if ( $r )
return $r [ " pubkey " ];
return " " ;
}
2016-03-03 22:34:17 +00:00
/**
* @ brief Fetches data for a given handle
*
* @ param string $handle The handle
*
* @ return array the queried data
*/
2016-02-27 22:54:17 +00:00
private function get_person_by_handle ( $handle ) {
$r = q ( " SELECT * FROM `fcontact` WHERE `network` = '%s' AND `addr` = '%s' LIMIT 1 " ,
dbesc ( NETWORK_DIASPORA ),
dbesc ( $handle )
);
2016-03-04 22:28:43 +00:00
if ( $r ) {
2016-02-27 22:54:17 +00:00
$person = $r [ 0 ];
logger ( " In cache " . print_r ( $r , true ), LOGGER_DEBUG );
// update record occasionally so it doesn't get stale
$d = strtotime ( $person [ " updated " ] . " +00:00 " );
if ( $d < strtotime ( " now - 14 days " ))
$update = true ;
}
if ( ! $person OR $update ) {
logger ( " create or refresh " , LOGGER_DEBUG );
$r = probe_url ( $handle , PROBE_DIASPORA );
// Note that Friendica contacts will return a "Diaspora person"
// if Diaspora connectivity is enabled on their server
2016-03-04 22:28:43 +00:00
if ( $r AND ( $r [ " network " ] === NETWORK_DIASPORA )) {
2016-02-27 22:54:17 +00:00
self :: add_fcontact ( $r , $update );
$person = $r ;
}
}
return $person ;
}
2016-03-03 22:34:17 +00:00
/**
* @ brief Updates the fcontact table
*
* @ param array $arr The fcontact data
* @ param bool $update Update or insert ?
*
* @ return string The id of the fcontact entry
*/
2016-02-27 22:54:17 +00:00
private function add_fcontact ( $arr , $update = false ) {
/// @todo Remove this function from include/network.php
if ( $update ) {
$r = q ( " UPDATE `fcontact` SET
`name` = '%s' ,
`photo` = '%s' ,
`request` = '%s' ,
`nick` = '%s' ,
`addr` = '%s' ,
`batch` = '%s' ,
`notify` = '%s' ,
`poll` = '%s' ,
`confirm` = '%s' ,
`alias` = '%s' ,
`pubkey` = '%s' ,
`updated` = '%s'
WHERE `url` = '%s' AND `network` = '%s' " ,
dbesc ( $arr [ " name " ]),
dbesc ( $arr [ " photo " ]),
dbesc ( $arr [ " request " ]),
dbesc ( $arr [ " nick " ]),
dbesc ( $arr [ " addr " ]),
dbesc ( $arr [ " batch " ]),
dbesc ( $arr [ " notify " ]),
dbesc ( $arr [ " poll " ]),
dbesc ( $arr [ " confirm " ]),
dbesc ( $arr [ " alias " ]),
dbesc ( $arr [ " pubkey " ]),
dbesc ( datetime_convert ()),
dbesc ( $arr [ " url " ]),
dbesc ( $arr [ " network " ])
);
} else {
$r = q ( " INSERT INTO `fcontact` (`url`,`name`,`photo`,`request`,`nick`,`addr`,
`batch` , `notify` , `poll` , `confirm` , `network` , `alias` , `pubkey` , `updated` )
VALUES ( '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' ) " ,
dbesc ( $arr [ " url " ]),
dbesc ( $arr [ " name " ]),
dbesc ( $arr [ " photo " ]),
dbesc ( $arr [ " request " ]),
dbesc ( $arr [ " nick " ]),
dbesc ( $arr [ " addr " ]),
dbesc ( $arr [ " batch " ]),
dbesc ( $arr [ " notify " ]),
dbesc ( $arr [ " poll " ]),
dbesc ( $arr [ " confirm " ]),
dbesc ( $arr [ " network " ]),
dbesc ( $arr [ " alias " ]),
dbesc ( $arr [ " pubkey " ]),
dbesc ( datetime_convert ())
);
}
return $r ;
}
private function get_contact_by_handle ( $uid , $handle ) {
$r = q ( " SELECT * FROM `contact` WHERE `uid` = %d AND `addr` = '%s' LIMIT 1 " ,
intval ( $uid ),
dbesc ( $handle )
);
2016-03-04 22:28:43 +00:00
if ( $r )
2016-02-27 22:54:17 +00:00
return $r [ 0 ];
$handle_parts = explode ( " @ " , $handle );
2016-03-04 22:28:43 +00:00
$nurl_sql = " %%:// " . $handle_parts [ 1 ] . " %%/profile/ " . $handle_parts [ 0 ];
2016-02-27 22:54:17 +00:00
$r = q ( " SELECT * FROM `contact` WHERE `network` = '%s' AND `uid` = %d AND `nurl` LIKE '%s' LIMIT 1 " ,
dbesc ( NETWORK_DFRN ),
intval ( $uid ),
dbesc ( $nurl_sql )
);
2016-03-04 22:28:43 +00:00
if ( $r )
2016-02-27 22:54:17 +00:00
return $r [ 0 ];
return false ;
}
2016-03-01 06:57:26 +00:00
private function post_allow ( $importer , $contact , $is_comment = false ) {
// perhaps we were already sharing with this person. Now they're sharing with us.
// That makes us friends.
// Normally this should have handled by getting a request - but this could get lost
if ( $contact [ " rel " ] == CONTACT_IS_FOLLOWER && in_array ( $importer [ " page-flags " ], array ( PAGE_FREELOVE ))) {
q ( " UPDATE `contact` SET `rel` = %d, `writable` = 1 WHERE `id` = %d AND `uid` = %d " ,
intval ( CONTACT_IS_FRIEND ),
intval ( $contact [ " id " ]),
intval ( $importer [ " uid " ])
);
$contact [ " rel " ] = CONTACT_IS_FRIEND ;
logger ( " defining user " . $contact [ " nick " ] . " as friend " );
}
if (( $contact [ " blocked " ]) || ( $contact [ " readonly " ]) || ( $contact [ " archive " ]))
return false ;
if ( $contact [ " rel " ] == CONTACT_IS_SHARING || $contact [ " rel " ] == CONTACT_IS_FRIEND )
return true ;
if ( $contact [ " rel " ] == CONTACT_IS_FOLLOWER )
if (( $importer [ " page-flags " ] == PAGE_COMMUNITY ) OR $is_comment )
return true ;
// Messages for the global users are always accepted
if ( $importer [ " uid " ] == 0 )
return true ;
return false ;
}
private function get_allowed_contact_by_handle ( $importer , $handle , $is_comment = false ) {
$contact = self :: get_contact_by_handle ( $importer [ " uid " ], $handle );
if ( ! $contact ) {
logger ( " A Contact for handle " . $handle . " and user " . $importer [ " uid " ] . " was not found " );
return false ;
}
if ( ! self :: post_allow ( $importer , $contact , false )) {
logger ( " The handle: " . $handle . " is not allowed to post to user " . $importer [ " uid " ]);
return false ;
}
return $contact ;
}
private function message_exists ( $uid , $guid ) {
$r = q ( " SELECT `id` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
intval ( $uid ),
dbesc ( $guid )
);
2016-03-04 22:28:43 +00:00
if ( $r ) {
2016-03-01 06:57:26 +00:00
logger ( " message " . $guid . " already exists for user " . $uid );
return false ;
}
return true ;
}
2016-02-28 18:05:23 +00:00
private function fetch_guid ( $item ) {
preg_replace_callback ( " & \ [url=/posts/([^ \ [ \ ]]*) \ ](.*) \ [ \ /url \ ]&Usi " ,
function ( $match ) use ( $item ){
return ( self :: fetch_guid_sub ( $match , $item ));
}, $item [ " body " ]);
}
private function fetch_guid_sub ( $match , $item ) {
if ( ! self :: store_by_guid ( $match [ 1 ], $item [ " author-link " ]))
self :: store_by_guid ( $match [ 1 ], $item [ " owner-link " ]);
}
private function store_by_guid ( $guid , $server , $uid = 0 ) {
$serverparts = parse_url ( $server );
$server = $serverparts [ " scheme " ] . " :// " . $serverparts [ " host " ];
logger ( " Trying to fetch item " . $guid . " from " . $server , LOGGER_DEBUG );
2016-02-29 07:02:50 +00:00
$msg = self :: fetch_message ( $guid , $server );
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
if ( ! $msg )
2016-02-28 18:05:23 +00:00
return false ;
logger ( " Successfully fetched item " . $guid . " from " . $server , LOGGER_DEBUG );
2016-02-29 07:02:50 +00:00
// Now call the dispatcher
return self :: dispatch_public ( $msg );
}
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
private function fetch_message ( $guid , $server , $level = 0 ) {
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
if ( $level > 5 )
return false ;
2016-02-27 22:54:17 +00:00
2016-03-03 22:34:17 +00:00
// This will work for Diaspora and newer Friendica servers
2016-02-29 07:02:50 +00:00
$source_url = $server . " /p/ " . $guid . " .xml " ;
$x = fetch_url ( $source_url );
if ( ! $x )
return false ;
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
$source_xml = parse_xml_string ( $x , false );
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
if ( ! is_object ( $source_xml ))
return false ;
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
if ( $source_xml -> post -> reshare ) {
// Reshare of a reshare - old Diaspora version
return self :: fetch_message ( $source_xml -> post -> reshare -> root_guid , $server , ++ $level );
} elseif ( $source_xml -> getName () == " reshare " ) {
// Reshare of a reshare - new Diaspora version
return self :: fetch_message ( $source_xml -> root_guid , $server , ++ $level );
}
2016-02-28 18:05:23 +00:00
2016-03-09 18:30:04 +00:00
$author = " " ;
2016-02-29 07:02:50 +00:00
// Fetch the author - for the old and the new Diaspora version
if ( $source_xml -> post -> status_message -> diaspora_handle )
$author = ( string ) $source_xml -> post -> status_message -> diaspora_handle ;
2016-03-09 18:30:04 +00:00
elseif ( $source_xml -> author AND ( $source_xml -> getName () == " status_message " ))
2016-02-29 07:02:50 +00:00
$author = ( string ) $source_xml -> author ;
2016-02-28 18:05:23 +00:00
2016-03-09 18:30:04 +00:00
// If this isn't a "status_message" then quit
2016-02-29 07:02:50 +00:00
if ( ! $author )
2016-02-28 18:05:23 +00:00
return false ;
2016-02-29 07:02:50 +00:00
$msg = array ( " message " => $x , " author " => $author );
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
$msg [ " key " ] = self :: get_key ( $msg [ " author " ]);
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
return $msg ;
2016-02-28 18:05:23 +00:00
}
private function fetch_parent_item ( $uid , $guid , $author , $contact ) {
2016-02-29 07:02:50 +00:00
$r = q ( " SELECT `id`, `body`, `wall`, `uri`, `private`, `origin`,
`author-name` , `author-link` , `author-avatar` ,
`owner-name` , `owner-link` , `owner-avatar`
2016-02-28 18:05:23 +00:00
FROM `item` WHERE `uid` = % d AND `guid` = '%s' LIMIT 1 " ,
intval ( $uid ), dbesc ( $guid ));
2016-03-04 22:28:43 +00:00
if ( ! $r ) {
2016-02-28 18:05:23 +00:00
$result = self :: store_by_guid ( $guid , $contact [ " url " ], $uid );
if ( ! $result ) {
$person = self :: get_person_by_handle ( $author );
$result = self :: store_by_guid ( $guid , $person [ " url " ], $uid );
}
if ( $result ) {
logger ( " Fetched missing item " . $guid . " - result: " . $result , LOGGER_DEBUG );
2016-02-29 07:02:50 +00:00
$r = q ( " SELECT `id`, `body`, `wall`, `uri`, `private`, `origin`,
`author-name` , `author-link` , `author-avatar` ,
`owner-name` , `owner-link` , `owner-avatar`
2016-02-28 18:05:23 +00:00
FROM `item` WHERE `uid` = % d AND `guid` = '%s' LIMIT 1 " ,
intval ( $uid ), dbesc ( $guid ));
}
}
2016-03-04 22:28:43 +00:00
if ( ! $r ) {
2016-02-28 18:05:23 +00:00
logger ( " parent item not found: parent: " . $guid . " item: " . $guid );
return false ;
} else
return $r [ 0 ];
}
2016-02-27 22:54:17 +00:00
2016-02-29 07:02:50 +00:00
private function get_author_contact_by_url ( $contact , $person , $uid ) {
$r = q ( " SELECT `id`, `network` FROM `contact` WHERE `nurl` = '%s' AND `uid` = %d LIMIT 1 " ,
dbesc ( normalise_link ( $person [ " url " ])), intval ( $uid ));
if ( $r ) {
$cid = $r [ 0 ][ " id " ];
$network = $r [ 0 ][ " network " ];
} else {
$cid = $contact [ " id " ];
$network = NETWORK_DIASPORA ;
}
return ( array ( " cid " => $cid , " network " => $network ));
}
public static function is_redmatrix ( $url ) {
return ( strstr ( $url , " /channel/ " ));
}
private function plink ( $addr , $guid ) {
2016-03-02 22:28:20 +00:00
$r = q ( " SELECT `url`, `nick`, `network` FROM `fcontact` WHERE `addr`='%s' LIMIT 1 " , dbesc ( $addr ));
2016-02-29 07:02:50 +00:00
2016-03-02 22:28:20 +00:00
// Fallback
if ( ! $r )
return " https:// " . substr ( $addr , strpos ( $addr , " @ " ) + 1 ) . " /posts/ " . $guid ;
2016-02-29 07:02:50 +00:00
2016-03-02 22:28:20 +00:00
// Friendica contacts are often detected as Diaspora contacts in the "fcontact" table
// So we try another way as well.
$s = q ( " SELECT `network` FROM `gcontact` WHERE `nurl`='%s' LIMIT 1 " , dbesc ( normalise_link ( $r [ 0 ][ " url " ])));
if ( $s )
$r [ 0 ][ " network " ] = $s [ 0 ][ " network " ];
2016-02-29 07:02:50 +00:00
2016-03-02 22:28:20 +00:00
if ( $r [ 0 ][ " network " ] == NETWORK_DFRN )
return ( str_replace ( " /profile/ " . $r [ 0 ][ " nick " ] . " / " , " /display/ " . $guid , $r [ 0 ][ " url " ] . " / " ));
2016-02-29 07:02:50 +00:00
2016-03-02 22:28:20 +00:00
if ( self :: is_redmatrix ( $r [ 0 ][ " url " ]))
return $r [ 0 ][ " url " ] . " /?f=&mid= " . $guid ;
2016-02-29 07:02:50 +00:00
2016-03-02 22:28:20 +00:00
return " https:// " . substr ( $addr , strpos ( $addr , " @ " ) + 1 ) . " /posts/ " . $guid ;
2016-02-29 07:02:50 +00:00
}
2016-03-04 23:27:44 +00:00
private function receive_account_deletion ( $importer , $data ) {
2016-02-29 22:54:25 +00:00
$author = notags ( unxmlify ( $data -> author ));
$contact = self :: get_contact_by_handle ( $importer [ " uid " ], $author );
if ( ! $contact ) {
2016-03-01 06:57:26 +00:00
logger ( " cannot find contact for author: " . $author );
2016-02-29 22:54:25 +00:00
return false ;
}
// We now remove the contact
contact_remove ( $contact [ " id " ]);
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_comment ( $importer , $sender , $data ) {
2016-02-27 22:54:17 +00:00
$guid = notags ( unxmlify ( $data -> guid ));
$parent_guid = notags ( unxmlify ( $data -> parent_guid ));
$text = unxmlify ( $data -> text );
$author = notags ( unxmlify ( $data -> author ));
2016-03-01 06:57:26 +00:00
$contact = self :: get_allowed_contact_by_handle ( $importer , $sender , true );
if ( ! $contact )
2016-02-28 18:05:23 +00:00
return false ;
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
if ( self :: message_exists ( $importer [ " uid " ], $guid ))
2016-02-29 07:02:50 +00:00
return false ;
2016-02-28 18:05:23 +00:00
$parent_item = self :: fetch_parent_item ( $importer [ " uid " ], $parent_guid , $author , $contact );
if ( ! $parent_item )
return false ;
$person = self :: get_person_by_handle ( $author );
if ( ! is_array ( $person )) {
logger ( " unable to find author details " );
return false ;
}
// Fetch the contact id - if we know this contact
2016-02-29 07:02:50 +00:00
$author_contact = self :: get_author_contact_by_url ( $contact , $person , $importer [ " uid " ]);
2016-02-28 18:05:23 +00:00
$datarray = array ();
$datarray [ " uid " ] = $importer [ " uid " ];
2016-02-29 07:02:50 +00:00
$datarray [ " contact-id " ] = $author_contact [ " cid " ];
$datarray [ " network " ] = $author_contact [ " network " ];
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
$datarray [ " author-name " ] = $person [ " name " ];
$datarray [ " author-link " ] = $person [ " url " ];
$datarray [ " author-avatar " ] = (( x ( $person , " thumb " )) ? $person [ " thumb " ] : $person [ " photo " ]);
2016-02-28 18:05:23 +00:00
$datarray [ " owner-name " ] = $contact [ " name " ];
$datarray [ " owner-link " ] = $contact [ " url " ];
$datarray [ " owner-avatar " ] = (( x ( $contact , " thumb " )) ? $contact [ " thumb " ] : $contact [ " photo " ]);
2016-02-29 07:02:50 +00:00
$datarray [ " guid " ] = $guid ;
$datarray [ " uri " ] = $author . " : " . $guid ;
$datarray [ " type " ] = " remote-comment " ;
$datarray [ " verb " ] = ACTIVITY_POST ;
$datarray [ " gravity " ] = GRAVITY_COMMENT ;
$datarray [ " parent-uri " ] = $parent_item [ " uri " ];
2016-02-28 18:05:23 +00:00
$datarray [ " object-type " ] = ACTIVITY_OBJ_COMMENT ;
2016-02-29 07:02:50 +00:00
$datarray [ " object " ] = json_encode ( $data );
$datarray [ " body " ] = diaspora2bb ( $text );
2016-02-28 18:05:23 +00:00
self :: fetch_guid ( $datarray );
2016-02-29 07:02:50 +00:00
$message_id = item_store ( $datarray );
// print_r($datarray);
2016-02-28 18:05:23 +00:00
// If we are the origin of the parent we store the original data and notify our followers
if ( $message_id AND $parent_item [ " origin " ]) {
// Formerly we stored the signed text, the signature and the author in different fields.
2016-03-03 22:34:17 +00:00
// We now store the raw data so that we are more flexible.
2016-02-28 18:05:23 +00:00
q ( " INSERT INTO `sign` (`iid`,`signed_text`) VALUES (%d,'%s') " ,
intval ( $message_id ),
dbesc ( json_encode ( $data ))
);
// notify others
proc_run ( " php " , " include/notifier.php " , " comment-import " , $message_id );
}
return $message_id ;
2016-02-27 22:54:17 +00:00
}
2016-03-04 23:27:44 +00:00
private function receive_conversation_message ( $importer , $contact , $data , $msg , $mesg ) {
2016-03-04 22:28:43 +00:00
$guid = notags ( unxmlify ( $data -> guid ));
$subject = notags ( unxmlify ( $data -> subject ));
$author = notags ( unxmlify ( $data -> author ));
2016-03-02 22:28:20 +00:00
$reply = 0 ;
$msg_guid = notags ( unxmlify ( $mesg -> guid ));
$msg_parent_guid = notags ( unxmlify ( $mesg -> parent_guid ));
$msg_parent_author_signature = notags ( unxmlify ( $mesg -> parent_author_signature ));
$msg_author_signature = notags ( unxmlify ( $mesg -> author_signature ));
$msg_text = unxmlify ( $mesg -> text );
2016-03-04 22:28:43 +00:00
$msg_created_at = datetime_convert ( " UTC " , " UTC " , notags ( unxmlify ( $mesg -> created_at )));
2016-03-04 23:27:44 +00:00
2016-03-05 00:30:49 +00:00
// "diaspora_handle" is the element name from the old version
// "author" is the element name from the new version
if ( $mesg -> author )
2016-03-04 23:27:44 +00:00
$msg_author = notags ( unxmlify ( $mesg -> author ));
2016-03-05 00:30:49 +00:00
elseif ( $mesg -> diaspora_handle )
$msg_author = notags ( unxmlify ( $mesg -> diaspora_handle ));
2016-03-04 23:27:44 +00:00
else
return false ;
2016-03-02 22:28:20 +00:00
$msg_conversation_guid = notags ( unxmlify ( $mesg -> conversation_guid ));
2016-03-04 22:28:43 +00:00
2016-03-02 22:28:20 +00:00
if ( $msg_conversation_guid != $guid ) {
2016-03-04 22:28:43 +00:00
logger ( " message conversation guid does not belong to the current conversation. " );
return false ;
2016-03-02 22:28:20 +00:00
}
$body = diaspora2bb ( $msg_text );
2016-03-04 22:28:43 +00:00
$message_uri = $msg_author . " : " . $msg_guid ;
2016-03-02 22:28:20 +00:00
2016-03-04 22:28:43 +00:00
$author_signed_data = $msg_guid . " ; " . $msg_parent_guid . " ; " . $msg_text . " ; " . unxmlify ( $mesg -> created_at ) . " ; " . $msg_author . " ; " . $msg_conversation_guid ;
2016-03-02 22:28:20 +00:00
$author_signature = base64_decode ( $msg_author_signature );
2016-03-04 22:28:43 +00:00
if ( strcasecmp ( $msg_author , $msg [ " author " ]) == 0 ) {
2016-03-02 22:28:20 +00:00
$person = $contact ;
$key = $msg [ " key " ];
2016-03-04 22:28:43 +00:00
} else {
$person = self :: get_person_by_handle ( $msg_author );
2016-03-02 22:28:20 +00:00
2016-03-04 22:28:43 +00:00
if ( is_array ( $person ) && x ( $person , " pubkey " ))
2016-03-02 22:28:20 +00:00
$key = $person [ " pubkey " ];
else {
2016-03-04 22:28:43 +00:00
logger ( " unable to find author details " );
return false ;
2016-03-02 22:28:20 +00:00
}
}
2016-03-04 22:28:43 +00:00
if ( ! rsa_verify ( $author_signed_data , $author_signature , $key , " sha256 " )) {
logger ( " verification failed. " );
return false ;
2016-03-02 22:28:20 +00:00
}
if ( $msg_parent_author_signature ) {
2016-03-04 22:28:43 +00:00
$owner_signed_data = $msg_guid . " ; " . $msg_parent_guid . " ; " . $msg_text . " ; " . unxmlify ( $mesg -> created_at ) . " ; " . $msg_author . " ; " . $msg_conversation_guid ;
2016-03-02 22:28:20 +00:00
$parent_author_signature = base64_decode ( $msg_parent_author_signature );
$key = $msg [ " key " ];
2016-03-04 22:28:43 +00:00
if ( ! rsa_verify ( $owner_signed_data , $parent_author_signature , $key , " sha256 " )) {
logger ( " owner verification failed. " );
return false ;
2016-03-02 22:28:20 +00:00
}
}
2016-03-04 22:28:43 +00:00
$r = q ( " SELECT `id` FROM `mail` WHERE `uri` = '%s' LIMIT 1 " ,
dbesc ( $message_uri )
2016-03-02 22:28:20 +00:00
);
2016-03-04 22:28:43 +00:00
if ( $r ) {
logger ( " duplicate message already delivered. " , LOGGER_DEBUG );
return false ;
2016-03-02 22:28:20 +00:00
}
2016-03-04 22:28:43 +00:00
q ( " INSERT INTO `mail` (`uid`, `guid`, `convid`, `from-name`,`from-photo`,`from-url`,`contact-id`,`title`,`body`,`seen`,`reply`,`uri`,`parent-uri`,`created`)
VALUES ( % d , '%s' , % d , '%s' , '%s' , '%s' , % d , '%s' , '%s' , % d , % d , '%s' , '%s' , '%s' ) " ,
2016-03-02 22:28:20 +00:00
intval ( $importer [ " uid " ]),
dbesc ( $msg_guid ),
intval ( $conversation [ " id " ]),
dbesc ( $person [ " name " ]),
dbesc ( $person [ " photo " ]),
dbesc ( $person [ " url " ]),
intval ( $contact [ " id " ]),
dbesc ( $subject ),
dbesc ( $body ),
0 ,
0 ,
2016-03-04 22:28:43 +00:00
dbesc ( $message_uri ),
dbesc ( $author . " : " . $guid ),
2016-03-02 22:28:20 +00:00
dbesc ( $msg_created_at )
);
2016-03-04 22:28:43 +00:00
q ( " UPDATE `conv` SET `updated` = '%s' WHERE `id` = %d " ,
2016-03-02 22:28:20 +00:00
dbesc ( datetime_convert ()),
intval ( $conversation [ " id " ])
);
notification ( array (
2016-03-04 22:28:43 +00:00
" type " => NOTIFY_MAIL ,
" notify_flags " => $importer [ " notify-flags " ],
" language " => $importer [ " language " ],
" to_name " => $importer [ " username " ],
" to_email " => $importer [ " email " ],
" uid " => $importer [ " uid " ],
" item " => array ( " subject " => $subject , " body " => $body ),
" source_name " => $person [ " name " ],
" source_link " => $person [ " url " ],
" source_photo " => $person [ " thumb " ],
" verb " => ACTIVITY_POST ,
" otype " => " mail "
2016-03-02 22:28:20 +00:00
));
}
2016-03-04 22:28:43 +00:00
2016-03-04 23:27:44 +00:00
private function receive_conversation ( $importer , $msg , $data ) {
2016-03-04 22:28:43 +00:00
$guid = notags ( unxmlify ( $data -> guid ));
$subject = notags ( unxmlify ( $data -> subject ));
$created_at = datetime_convert ( " UTC " , " UTC " , notags ( unxmlify ( $data -> created_at )));
$author = notags ( unxmlify ( $data -> author ));
$participants = notags ( unxmlify ( $data -> participants ));
$messages = $data -> message ;
if ( ! count ( $messages )) {
logger ( " empty conversation " );
return false ;
}
$contact = self :: get_allowed_contact_by_handle ( $importer , $msg [ " author " ], true );
if ( ! $contact )
return false ;
$conversation = null ;
$c = q ( " SELECT * FROM `conv` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
intval ( $importer [ " uid " ]),
dbesc ( $guid )
);
if ( $c )
$conversation = $c [ 0 ];
else {
$r = q ( " INSERT INTO `conv` (`uid`, `guid`, `creator`, `created`, `updated`, `subject`, `recips`)
VALUES ( % d , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' ) " ,
intval ( $importer [ " uid " ]),
dbesc ( $guid ),
dbesc ( $author ),
dbesc ( datetime_convert ( " UTC " , " UTC " , $created_at )),
dbesc ( datetime_convert ()),
dbesc ( $subject ),
dbesc ( $participants )
);
if ( $r )
$c = q ( " SELECT * FROM `conv` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
intval ( $importer [ " uid " ]),
dbesc ( $guid )
);
if ( $c )
$conversation = $c [ 0 ];
}
if ( ! $conversation ) {
logger ( " unable to create conversation. " );
return ;
}
foreach ( $messages as $mesg )
2016-03-04 23:27:44 +00:00
self :: receive_conversation_message ( $importer , $contact , $data , $msg , $mesg );
2016-03-04 22:28:43 +00:00
2016-02-27 22:54:17 +00:00
return true ;
}
2016-02-29 07:02:50 +00:00
private function construct_like_body ( $contact , $parent_item , $guid ) {
$bodyverb = t ( '%1$s likes %2$s\'s %3$s' );
$ulink = " [url= " . $contact [ " url " ] . " ] " . $contact [ " name " ] . " [/url] " ;
$alink = " [url= " . $parent_item [ " author-link " ] . " ] " . $parent_item [ " author-name " ] . " [/url] " ;
$plink = " [url= " . App :: get_baseurl () . " /display/ " . urlencode ( $guid ) . " ] " . t ( " status " ) . " [/url] " ;
return sprintf ( $bodyverb , $ulink , $alink , $plink );
}
private function construct_like_object ( $importer , $parent_item ) {
$objtype = ACTIVITY_OBJ_NOTE ;
$link = xmlify ( '<link rel="alternate" type="text/html" href="' . App :: get_baseurl () . " /display/ " . $importer [ " nickname " ] . " / " . $parent_item [ " id " ] . '" />' . " \n " ) ;
$parent_body = $parent_item [ " body " ];
$obj = <<< EOT
< object >
< type > $objtype </ type >
< local > 1 </ local >
< id > { $parent_item [ " uri " ]} </ id >
< link > $link </ link >
< title ></ title >
< content > $parent_body </ content >
</ object >
EOT ;
return $obj ;
}
2016-03-04 23:27:44 +00:00
private function receive_like ( $importer , $sender , $data ) {
2016-02-28 18:05:23 +00:00
$positive = notags ( unxmlify ( $data -> positive ));
$guid = notags ( unxmlify ( $data -> guid ));
$parent_type = notags ( unxmlify ( $data -> parent_type ));
$parent_guid = notags ( unxmlify ( $data -> parent_guid ));
$author = notags ( unxmlify ( $data -> author ));
// likes on comments aren't supported by Diaspora - only on posts
2016-03-01 22:21:56 +00:00
// But maybe this will be supported in the future, so we will accept it.
if ( ! in_array ( $parent_type , array ( " Post " , " Comment " )))
2016-02-28 18:05:23 +00:00
return false ;
2016-03-01 06:57:26 +00:00
$contact = self :: get_allowed_contact_by_handle ( $importer , $sender , true );
if ( ! $contact )
2016-02-28 18:05:23 +00:00
return false ;
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
if ( self :: message_exists ( $importer [ " uid " ], $guid ))
2016-02-28 18:05:23 +00:00
return false ;
2016-02-29 07:02:50 +00:00
2016-02-28 18:05:23 +00:00
$parent_item = self :: fetch_parent_item ( $importer [ " uid " ], $parent_guid , $author , $contact );
if ( ! $parent_item )
return false ;
$person = self :: get_person_by_handle ( $author );
if ( ! is_array ( $person )) {
logger ( " unable to find author details " );
return false ;
}
// Fetch the contact id - if we know this contact
2016-02-29 07:02:50 +00:00
$author_contact = self :: get_author_contact_by_url ( $contact , $person , $importer [ " uid " ]);
2016-02-28 18:05:23 +00:00
2016-03-01 22:21:56 +00:00
// "positive" = "false" would be a Dislike - wich isn't currently supported by Diaspora
// We would accept this anyhow.
if ( $positive === " true " )
$verb = ACTIVITY_LIKE ;
else
$verb = ACTIVITY_DISLIKE ;
2016-02-28 18:05:23 +00:00
$datarray = array ();
$datarray [ " uid " ] = $importer [ " uid " ];
2016-02-29 07:02:50 +00:00
$datarray [ " contact-id " ] = $author_contact [ " cid " ];
$datarray [ " network " ] = $author_contact [ " network " ];
$datarray [ " author-name " ] = $person [ " name " ];
$datarray [ " author-link " ] = $person [ " url " ];
$datarray [ " author-avatar " ] = (( x ( $person , " thumb " )) ? $person [ " thumb " ] : $person [ " photo " ]);
2016-02-28 18:05:23 +00:00
$datarray [ " owner-name " ] = $contact [ " name " ];
$datarray [ " owner-link " ] = $contact [ " url " ];
$datarray [ " owner-avatar " ] = (( x ( $contact , " thumb " )) ? $contact [ " thumb " ] : $contact [ " photo " ]);
2016-02-29 07:02:50 +00:00
$datarray [ " guid " ] = $guid ;
$datarray [ " uri " ] = $author . " : " . $guid ;
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
$datarray [ " type " ] = " activity " ;
2016-03-01 22:21:56 +00:00
$datarray [ " verb " ] = $verb ;
2016-02-29 07:02:50 +00:00
$datarray [ " gravity " ] = GRAVITY_LIKE ;
$datarray [ " parent-uri " ] = $parent_item [ " uri " ];
2016-02-28 18:05:23 +00:00
2016-02-29 07:02:50 +00:00
$datarray [ " object-type " ] = ACTIVITY_OBJ_NOTE ;
$datarray [ " object " ] = self :: construct_like_object ( $importer , $parent_item );
$datarray [ " body " ] = self :: construct_like_body ( $contact , $parent_item , $guid );
$message_id = item_store ( $datarray );
2016-03-03 22:34:17 +00:00
// print_r($datarray);
2016-02-28 18:05:23 +00:00
// If we are the origin of the parent we store the original data and notify our followers
if ( $message_id AND $parent_item [ " origin " ]) {
// Formerly we stored the signed text, the signature and the author in different fields.
2016-03-03 22:34:17 +00:00
// We now store the raw data so that we are more flexible.
2016-02-28 18:05:23 +00:00
q ( " INSERT INTO `sign` (`iid`,`signed_text`) VALUES (%d,'%s') " ,
intval ( $message_id ),
dbesc ( json_encode ( $data ))
);
// notify others
proc_run ( " php " , " include/notifier.php " , " comment-import " , $message_id );
}
2016-02-29 07:02:50 +00:00
return $message_id ;
2016-02-27 22:54:17 +00:00
}
2016-03-04 23:27:44 +00:00
private function receive_message ( $importer , $data ) {
2016-02-29 07:02:50 +00:00
$guid = notags ( unxmlify ( $data -> guid ));
$parent_guid = notags ( unxmlify ( $data -> parent_guid ));
$text = unxmlify ( $data -> text );
$created_at = datetime_convert ( " UTC " , " UTC " , notags ( unxmlify ( $data -> created_at )));
$author = notags ( unxmlify ( $data -> author ));
$conversation_guid = notags ( unxmlify ( $data -> conversation_guid ));
2016-03-01 06:57:26 +00:00
$contact = self :: get_allowed_contact_by_handle ( $importer , $author , true );
if ( ! $contact )
2016-02-29 07:02:50 +00:00
return false ;
$conversation = null ;
$c = q ( " SELECT * FROM `conv` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1 " ,
intval ( $importer [ " uid " ]),
dbesc ( $conversation_guid )
);
2016-03-04 22:28:43 +00:00
if ( $c )
2016-02-29 07:02:50 +00:00
$conversation = $c [ 0 ];
else {
logger ( " conversation not available. " );
return false ;
}
$reply = 0 ;
$body = diaspora2bb ( $text );
2016-03-04 22:28:43 +00:00
$message_uri = $author . " : " . $guid ;
2016-02-29 07:02:50 +00:00
$person = self :: get_person_by_handle ( $author );
if ( ! $person ) {
logger ( " unable to find author details " );
return false ;
}
$r = q ( " SELECT `id` FROM `mail` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1 " ,
2016-03-04 22:28:43 +00:00
dbesc ( $message_uri ),
2016-02-29 07:02:50 +00:00
intval ( $importer [ " uid " ])
);
2016-03-04 22:28:43 +00:00
if ( $r ) {
2016-02-29 07:02:50 +00:00
logger ( " duplicate message already delivered. " , LOGGER_DEBUG );
return false ;
}
q ( " INSERT INTO `mail` (`uid`, `guid`, `convid`, `from-name`,`from-photo`,`from-url`,`contact-id`,`title`,`body`,`seen`,`reply`,`uri`,`parent-uri`,`created`)
VALUES ( % d , '%s' , % d , '%s' , '%s' , '%s' , % d , '%s' , '%s' , % d , % d , '%s' , '%s' , '%s' ) " ,
intval ( $importer [ " uid " ]),
dbesc ( $guid ),
intval ( $conversation [ " id " ]),
dbesc ( $person [ " name " ]),
dbesc ( $person [ " photo " ]),
dbesc ( $person [ " url " ]),
intval ( $contact [ " id " ]),
dbesc ( $conversation [ " subject " ]),
dbesc ( $body ),
0 ,
1 ,
2016-03-04 22:28:43 +00:00
dbesc ( $message_uri ),
dbesc ( $author . " : " . $parent_guid ),
2016-02-29 07:02:50 +00:00
dbesc ( $created_at )
);
q ( " UPDATE `conv` SET `updated` = '%s' WHERE `id` = %d " ,
dbesc ( datetime_convert ()),
intval ( $conversation [ " id " ])
);
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_participation ( $importer , $data ) {
2016-02-29 22:54:25 +00:00
// I'm not sure if we can fully support this message type
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_photo ( $importer , $data ) {
2016-02-29 22:54:25 +00:00
// There doesn't seem to be a reason for this function, since the photo data is transmitted in the status message as well
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_poll_participation ( $importer , $data ) {
2016-02-29 22:54:25 +00:00
// We don't support polls by now
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_profile ( $importer , $data ) {
2016-02-29 07:02:50 +00:00
$author = notags ( unxmlify ( $data -> author ));
$contact = self :: get_contact_by_handle ( $importer [ " uid " ], $author );
if ( ! $contact )
return ;
$name = unxmlify ( $data -> first_name ) . (( strlen ( $data -> last_name )) ? " " . unxmlify ( $data -> last_name ) : " " );
$image_url = unxmlify ( $data -> image_url );
$birthday = unxmlify ( $data -> birthday );
$location = diaspora2bb ( unxmlify ( $data -> location ));
$about = diaspora2bb ( unxmlify ( $data -> bio ));
$gender = unxmlify ( $data -> gender );
$searchable = ( unxmlify ( $data -> searchable ) == " true " );
$nsfw = ( unxmlify ( $data -> nsfw ) == " true " );
$tags = unxmlify ( $data -> tag_string );
$tags = explode ( " # " , $tags );
$keywords = array ();
foreach ( $tags as $tag ) {
$tag = trim ( strtolower ( $tag ));
if ( $tag != " " )
$keywords [] = $tag ;
}
$keywords = implode ( " , " , $keywords );
$handle_parts = explode ( " @ " , $author );
$nick = $handle_parts [ 0 ];
if ( $name === " " )
$name = $handle_parts [ 0 ];
if ( preg_match ( " |^https?://| " , $image_url ) === 0 )
$image_url = " http:// " . $handle_parts [ 1 ] . $image_url ;
update_contact_avatar ( $image_url , $importer [ " uid " ], $contact [ " id " ]);
// Generic birthday. We don't know the timezone. The year is irrelevant.
$birthday = str_replace ( " 1000 " , " 1901 " , $birthday );
if ( $birthday != " " )
$birthday = datetime_convert ( " UTC " , " UTC " , $birthday , " Y-m-d " );
// this is to prevent multiple birthday notifications in a single year
// if we already have a stored birthday and the 'm-d' part hasn't changed, preserve the entry, which will preserve the notify year
if ( substr ( $birthday , 5 ) === substr ( $contact [ " bd " ], 5 ))
$birthday = $contact [ " bd " ];
$r = q ( " UPDATE `contact` SET `name` = '%s', `nick` = '%s', `addr` = '%s', `name-date` = '%s', `bd` = '%s',
`location` = '%s' , `about` = '%s' , `keywords` = '%s' , `gender` = '%s' WHERE `id` = % d AND `uid` = % d " ,
dbesc ( $name ),
dbesc ( $nick ),
dbesc ( $author ),
dbesc ( datetime_convert ()),
dbesc ( $birthday ),
dbesc ( $location ),
dbesc ( $about ),
dbesc ( $keywords ),
dbesc ( $gender ),
intval ( $contact [ " id " ]),
intval ( $importer [ " uid " ])
);
if ( $searchable ) {
poco_check ( $contact [ " url " ], $name , NETWORK_DIASPORA , $image_url , $about , $location , $gender , $keywords , " " ,
datetime_convert (), 2 , $contact [ " id " ], $importer [ " uid " ]);
}
$gcontact = array ( " url " => $contact [ " url " ], " network " => NETWORK_DIASPORA , " generation " => 2 ,
" photo " => $image_url , " name " => $name , " location " => $location ,
" about " => $about , " birthday " => $birthday , " gender " => $gender ,
" addr " => $author , " nick " => $nick , " keywords " => $keywords ,
" hide " => ! $searchable , " nsfw " => $nsfw );
update_gcontact ( $gcontact );
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_request_make_friend ( $importer , $contact ) {
2016-03-05 23:53:30 +00:00
$a = get_app ();
2016-02-29 07:02:50 +00:00
if ( $contact [ " rel " ] == CONTACT_IS_FOLLOWER && in_array ( $importer [ " page-flags " ], array ( PAGE_FREELOVE ))) {
q ( " UPDATE `contact` SET `rel` = %d, `writable` = 1 WHERE `id` = %d AND `uid` = %d " ,
intval ( CONTACT_IS_FRIEND ),
intval ( $contact [ " id " ]),
intval ( $importer [ " uid " ])
);
}
// send notification
$r = q ( " SELECT `hide-friends` FROM `profile` WHERE `uid` = %d AND `is-default` = 1 LIMIT 1 " ,
intval ( $importer [ " uid " ])
);
2016-03-04 23:27:44 +00:00
if ( $r && ! $r [ 0 ][ " hide-friends " ] && ! $contact [ " hidden " ] && intval ( get_pconfig ( $importer [ " uid " ], " system " , " post_newfriend " ))) {
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$self = q ( " SELECT * FROM `contact` WHERE `self` AND `uid` = %d LIMIT 1 " ,
2016-02-29 07:02:50 +00:00
intval ( $importer [ " uid " ])
);
// they are not CONTACT_IS_FOLLOWER anymore but that's what we have in the array
2016-03-04 22:28:43 +00:00
if ( $self && $contact [ " rel " ] == CONTACT_IS_FOLLOWER ) {
2016-02-29 07:02:50 +00:00
$arr = array ();
2016-03-05 23:53:30 +00:00
$arr [ " uri " ] = $arr [ " parent-uri " ] = item_new_uri ( $a -> get_hostname (), $importer [ " uid " ]);
2016-02-29 07:02:50 +00:00
$arr [ " uid " ] = $importer [ " uid " ];
$arr [ " contact-id " ] = $self [ 0 ][ " id " ];
$arr [ " wall " ] = 1 ;
$arr [ " type " ] = 'wall' ;
$arr [ " gravity " ] = 0 ;
$arr [ " origin " ] = 1 ;
$arr [ " author-name " ] = $arr [ " owner-name " ] = $self [ 0 ][ " name " ];
$arr [ " author-link " ] = $arr [ " owner-link " ] = $self [ 0 ][ " url " ];
$arr [ " author-avatar " ] = $arr [ " owner-avatar " ] = $self [ 0 ][ " thumb " ];
$arr [ " verb " ] = ACTIVITY_FRIEND ;
$arr [ " object-type " ] = ACTIVITY_OBJ_PERSON ;
2016-03-04 23:27:44 +00:00
$A = " [url= " . $self [ 0 ][ " url " ] . " ] " . $self [ 0 ][ " name " ] . " [/url] " ;
$B = " [url= " . $contact [ " url " ] . " ] " . $contact [ " name " ] . " [/url] " ;
$BPhoto = " [url= " . $contact [ " url " ] . " ][img] " . $contact [ " thumb " ] . " [/img][/url] " ;
$arr [ " body " ] = sprintf ( t ( " %1 $s is now friends with %2 $s " ), $A , $B ) . " \n \n \n " . $Bphoto ;
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$arr [ " object " ] = " <object><type> " . ACTIVITY_OBJ_PERSON . " </type><title> " . $contact [ " name " ] . " </title> "
. " <id> " . $contact [ " url " ] . " / " . $contact [ " name " ] . " </id> " ;
$arr [ " object " ] .= " <link> " . xmlify ( '<link rel="alternate" type="text/html" href="' . $contact [ " url " ] . '" />' . " \n " );
$arr [ " object " ] .= xmlify ( '<link rel="photo" type="image/jpeg" href="' . $contact [ " thumb " ] . '" />' . " \n " );
$arr [ " object " ] .= " </link></object> \n " ;
2016-02-29 07:02:50 +00:00
$arr [ " last-child " ] = 1 ;
$arr [ " allow_cid " ] = $user [ 0 ][ " allow_cid " ];
$arr [ " allow_gid " ] = $user [ 0 ][ " allow_gid " ];
$arr [ " deny_cid " ] = $user [ 0 ][ " deny_cid " ];
$arr [ " deny_gid " ] = $user [ 0 ][ " deny_gid " ];
$i = item_store ( $arr );
if ( $i )
2016-03-04 23:27:44 +00:00
proc_run ( " php " , " include/notifier.php " , " activity " , $i );
2016-02-29 07:02:50 +00:00
}
}
}
2016-03-04 23:27:44 +00:00
private function receive_request ( $importer , $data ) {
$author = unxmlify ( $data -> author );
$recipient = unxmlify ( $data -> recipient );
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
if ( ! $author || ! $recipient )
return ;
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$contact = self :: get_contact_by_handle ( $importer [ " uid " ], $author );
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
if ( $contact ) {
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
// perhaps we were already sharing with this person. Now they're sharing with us.
// That makes us friends.
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
self :: receive_request_make_friend ( $importer , $contact );
return true ;
}
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$ret = self :: get_person_by_handle ( $author );
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
if ( ! $ret || ( $ret [ " network " ] != NETWORK_DIASPORA )) {
logger ( " Cannot resolve diaspora handle " . $author . " for " . $recipient );
return false ;
}
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$batch = (( $ret [ " batch " ]) ? $ret [ " batch " ] : implode ( " / " , array_slice ( explode ( " / " , $ret [ " url " ]), 0 , 3 )) . " /receive/public " );
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$r = q ( " INSERT INTO `contact` (`uid`, `network`,`addr`,`created`,`url`,`nurl`,`batch`,`name`,`nick`,`photo`,`pubkey`,`notify`,`poll`,`blocked`,`priority`)
VALUES ( % d , '%s' , '%s' , '%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 ( normalise_link ( $ret [ " url " ])),
dbesc ( $batch ),
dbesc ( $ret [ " name " ]),
dbesc ( $ret [ " nick " ]),
dbesc ( $ret [ " photo " ]),
dbesc ( $ret [ " pubkey " ]),
dbesc ( $ret [ " notify " ]),
dbesc ( $ret [ " poll " ]),
1 ,
2
);
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
// find the contact record we just created
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$contact_record = self :: get_contact_by_handle ( $importer [ " uid " ], $author );
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
if ( ! $contact_record ) {
logger ( " unable to locate newly created contact record. " );
return ;
}
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$g = q ( " SELECT `def_gid` FROM `user` WHERE `uid` = %d LIMIT 1 " ,
intval ( $importer [ " uid " ])
2016-02-29 07:02:50 +00:00
);
2016-03-04 23:27:44 +00:00
if ( $g && intval ( $g [ 0 ][ " def_gid " ]))
group_add_member ( $importer [ " uid " ], " " , $contact_record [ " id " ], $g [ 0 ][ " def_gid " ]);
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
if ( $importer [ " page-flags " ] == PAGE_NORMAL ) {
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$hash = random_string () . ( string ) time (); // Generate a confirm_key
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
$ret = q ( " INSERT INTO `intro` (`uid`, `contact-id`, `blocked`, `knowyou`, `note`, `hash`, `datetime`)
VALUES ( % d , % d , % d , % d , '%s' , '%s' , '%s' ) " ,
intval ( $importer [ " uid " ]),
intval ( $contact_record [ " id " ]),
0 ,
0 ,
dbesc ( t ( " Sharing notification from Diaspora network " )),
dbesc ( $hash ),
dbesc ( datetime_convert ())
);
} else {
// automatic friend approval
update_contact_avatar ( $contact_record [ " photo " ], $importer [ " uid " ], $contact_record [ " id " ]);
// technically they are sharing with us (CONTACT_IS_SHARING),
// but if our page-type is PAGE_COMMUNITY or PAGE_SOAPBOX
// we are going to change the relationship and make them a follower.
if ( $importer [ " page-flags " ] == PAGE_FREELOVE )
$new_relation = CONTACT_IS_FRIEND ;
else
$new_relation = CONTACT_IS_FOLLOWER ;
$r = q ( " UPDATE `contact` SET `rel` = %d,
`name-date` = '%s' ,
`uri-date` = '%s' ,
`blocked` = 0 ,
`pending` = 0 ,
`writable` = 1
WHERE `id` = % d
" ,
intval ( $new_relation ),
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
intval ( $contact_record [ " id " ])
);
$u = q ( " SELECT * FROM `user` WHERE `uid` = %d LIMIT 1 " , intval ( $importer [ " uid " ]));
if ( $u )
2016-03-12 18:19:20 +00:00
$ret = self :: send_share ( $u [ 0 ], $contact_record );
2016-03-04 23:27:44 +00:00
}
2016-02-29 07:02:50 +00:00
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-01 06:57:26 +00:00
private function get_original_item ( $guid , $orig_author , $author ) {
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
// Do we already have this item?
2016-03-01 06:57:26 +00:00
$r = q ( " SELECT `body`, `tag`, `app`, `created`, `object-type`, `uri`, `guid`,
`author-name` , `author-link` , `author-avatar`
FROM `item` WHERE `guid` = '%s' AND `visible` AND NOT `deleted` AND `body` != '' LIMIT 1 " ,
dbesc ( $guid ));
2016-03-04 22:28:43 +00:00
if ( $r ) {
2016-03-01 06:57:26 +00:00
logger ( " reshared message " . $guid . " already exists on system. " );
2016-02-29 22:54:25 +00:00
// Maybe it is already a reshared item?
// Then refetch the content, since there can be many side effects with reshared posts from other networks or reshares from reshares
2016-03-05 23:53:30 +00:00
if ( self :: is_reshare ( $r [ 0 ][ " body " ]))
2016-02-29 22:54:25 +00:00
$r = array ();
2016-03-01 06:57:26 +00:00
else
return $r [ 0 ];
2016-02-29 07:02:50 +00:00
}
2016-03-04 22:28:43 +00:00
if ( ! $r ) {
$server = " https:// " . substr ( $orig_author , strpos ( $orig_author , " @ " ) + 1 );
2016-03-01 06:57:26 +00:00
logger ( " 1st try: reshared message " . $guid . " will be fetched from original server: " . $server );
$item_id = self :: store_by_guid ( $guid , $server );
2016-02-29 22:54:25 +00:00
2016-03-01 06:57:26 +00:00
if ( ! $item_id ) {
2016-03-04 22:28:43 +00:00
$server = " http:// " . substr ( $orig_author , strpos ( $orig_author , " @ " ) + 1 );
2016-03-09 18:30:04 +00:00
logger ( " 2nd try: reshared message " . $guid . " will be fetched from original server: " . $server );
$item_id = self :: store_by_guid ( $guid , $server );
}
// Deactivated by now since there is a risk that someone could manipulate postings through this method
/* if ( ! $item_id ) {
$server = " https:// " . substr ( $author , strpos ( $author , " @ " ) + 1 );
logger ( " 3rd try: reshared message " . $guid . " will be fetched from sharer's server: " . $server );
$item_id = self :: store_by_guid ( $guid , $server );
2016-02-29 22:54:25 +00:00
}
2016-03-01 06:57:26 +00:00
if ( ! $item_id ) {
2016-03-04 22:28:43 +00:00
$server = " http:// " . substr ( $author , strpos ( $author , " @ " ) + 1 );
2016-03-01 06:57:26 +00:00
logger ( " 4th try: reshared message " . $guid . " will be fetched from sharer's server: " . $server );
2016-03-09 18:30:04 +00:00
$item_id = self :: store_by_guid ( $guid , $server );
2016-02-29 22:54:25 +00:00
}
2016-03-09 18:30:04 +00:00
*/
2016-03-01 06:57:26 +00:00
if ( $item_id ) {
$r = q ( " SELECT `body`, `tag`, `app`, `created`, `object-type`, `uri`, `guid`,
`author-name` , `author-link` , `author-avatar`
FROM `item` WHERE `id` = % d AND `visible` AND NOT `deleted` AND `body` != '' LIMIT 1 " ,
intval ( $item_id ));
if ( $r )
return $r [ 0 ];
2016-02-29 22:54:25 +00:00
}
}
2016-03-01 06:57:26 +00:00
return false ;
}
2016-02-29 07:02:50 +00:00
2016-03-04 23:27:44 +00:00
private function receive_reshare ( $importer , $data ) {
2016-03-01 06:57:26 +00:00
$root_author = notags ( unxmlify ( $data -> root_author ));
$root_guid = notags ( unxmlify ( $data -> root_guid ));
$guid = notags ( unxmlify ( $data -> guid ));
$author = notags ( unxmlify ( $data -> author ));
$public = notags ( unxmlify ( $data -> public ));
$created_at = notags ( unxmlify ( $data -> created_at ));
$contact = self :: get_allowed_contact_by_handle ( $importer , $author , false );
if ( ! $contact )
return false ;
2016-03-03 22:34:17 +00:00
if ( self :: message_exists ( $importer [ " uid " ], $guid ))
return false ;
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
$original_item = self :: get_original_item ( $root_guid , $root_author , $author );
if ( ! $original_item )
return false ;
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
$datarray = array ();
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
$datarray [ " uid " ] = $importer [ " uid " ];
$datarray [ " contact-id " ] = $contact [ " id " ];
$datarray [ " network " ] = NETWORK_DIASPORA ;
2016-02-29 07:02:50 +00:00
$datarray [ " author-name " ] = $contact [ " name " ];
$datarray [ " author-link " ] = $contact [ " url " ];
2016-02-29 22:54:25 +00:00
$datarray [ " author-avatar " ] = (( x ( $contact , " thumb " )) ? $contact [ " thumb " ] : $contact [ " photo " ]);
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
$datarray [ " owner-name " ] = $datarray [ " author-name " ];
$datarray [ " owner-link " ] = $datarray [ " author-link " ];
$datarray [ " owner-avatar " ] = $datarray [ " author-avatar " ];
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
$datarray [ " guid " ] = $guid ;
$datarray [ " uri " ] = $datarray [ " parent-uri " ] = $author . " : " . $guid ;
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
$datarray [ " verb " ] = ACTIVITY_POST ;
$datarray [ " gravity " ] = GRAVITY_PARENT ;
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
$datarray [ " object " ] = json_encode ( $data );
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
$prefix = share_header ( $original_item [ " author-name " ], $original_item [ " author-link " ], $original_item [ " author-avatar " ],
$original_item [ " guid " ], $original_item [ " created " ], $original_item [ " uri " ]);
$datarray [ " body " ] = $prefix . $original_item [ " body " ] . " [/share] " ;
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
$datarray [ " tag " ] = $original_item [ " tag " ];
$datarray [ " app " ] = $original_item [ " app " ];
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
$datarray [ " plink " ] = self :: plink ( $author , $guid );
$datarray [ " private " ] = (( $public == " false " ) ? 1 : 0 );
2016-02-29 22:54:25 +00:00
$datarray [ " changed " ] = $datarray [ " created " ] = $datarray [ " edited " ] = datetime_convert ( " UTC " , " UTC " , $created_at );
2016-02-29 07:02:50 +00:00
2016-03-01 06:57:26 +00:00
$datarray [ " object-type " ] = $original_item [ " object-type " ];
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
self :: fetch_guid ( $datarray );
2016-03-03 22:34:17 +00:00
$message_id = item_store ( $datarray );
// print_r($datarray);
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
return $message_id ;
2016-02-27 22:54:17 +00:00
}
2016-03-02 22:28:20 +00:00
private function item_retraction ( $importer , $contact , $data ) {
2016-03-03 22:34:17 +00:00
$target_type = notags ( unxmlify ( $data -> target_type ));
2016-03-02 22:28:20 +00:00
$target_guid = notags ( unxmlify ( $data -> target_guid ));
2016-03-03 22:34:17 +00:00
$author = notags ( unxmlify ( $data -> author ));
$person = self :: get_person_by_handle ( $author );
if ( ! is_array ( $person )) {
logger ( " unable to find author detail for " . $author );
return false ;
}
2016-03-02 22:28:20 +00:00
$r = q ( " SELECT `id`, `parent`, `parent-uri`, `author-link` FROM `item` WHERE `guid` = '%s' AND `uid` = %d AND NOT `file` LIKE '%%[%%' LIMIT 1 " ,
dbesc ( $target_guid ),
intval ( $importer [ " uid " ])
);
if ( ! $r )
return false ;
// Only delete it if the author really fits
2016-03-03 22:34:17 +00:00
if ( ! link_compare ( $r [ 0 ][ " author-link " ], $person [ " url " ]))
return false ;
// Check if the sender is the thread owner
$p = q ( " SELECT `author-link`, `origin` FROM `item` WHERE `id` = %d " ,
intval ( $r [ 0 ][ " parent " ]));
// Only delete it if the parent author really fits
if ( ! link_compare ( $p [ 0 ][ " author-link " ], $contact [ " url " ]))
2016-03-02 22:28:20 +00:00
return false ;
// Currently we don't have a central deletion function that we could use in this case. The function "item_drop" doesn't work for that case
q ( " UPDATE `item` SET `deleted` = 1, `edited` = '%s', `changed` = '%s', `body` = '' , `title` = '' WHERE `id` = %d " ,
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
intval ( $r [ 0 ][ " id " ])
);
delete_thread ( $r [ 0 ][ " id " ], $r [ 0 ][ " parent-uri " ]);
// Now check if the retraction needs to be relayed by us
2016-03-03 22:34:17 +00:00
if ( $p [ 0 ][ " origin " ]) {
2016-03-02 22:28:20 +00:00
2016-03-03 22:34:17 +00:00
// Formerly we stored the signed text, the signature and the author in different fields.
// We now store the raw data so that we are more flexible.
2016-03-07 14:20:48 +00:00
q ( " INSERT INTO `sign` (`retract_iid`,`signed_text`) VALUES (%d,'%s') " ,
2016-03-03 22:34:17 +00:00
intval ( $r [ 0 ][ " id " ]),
dbesc ( json_encode ( $data ))
);
2016-03-02 22:28:20 +00:00
2016-03-03 22:34:17 +00:00
// notify others
proc_run ( " php " , " include/notifier.php " , " drop " , $r [ 0 ][ " id " ]);
2016-03-02 22:28:20 +00:00
}
}
2016-03-04 23:27:44 +00:00
private function receive_retraction ( $importer , $sender , $data ) {
2016-03-02 22:28:20 +00:00
$target_type = notags ( unxmlify ( $data -> target_type ));
2016-03-03 22:34:17 +00:00
$contact = self :: get_contact_by_handle ( $importer [ " uid " ], $sender );
2016-03-02 22:28:20 +00:00
if ( ! $contact ) {
2016-03-03 22:34:17 +00:00
logger ( " cannot find contact for sender: " . $sender . " and user " . $importer [ " uid " ]);
2016-03-02 22:28:20 +00:00
return false ;
}
switch ( $target_type ) {
2016-03-03 22:34:17 +00:00
case " Comment " :
case " Like " :
case " Post " : // "Post" will be supported in a future version
case " Reshare " :
case " StatusMessage " :
return self :: item_retraction ( $importer , $contact , $data );;
2016-03-02 22:28:20 +00:00
2016-03-12 18:19:20 +00:00
case " Person " :
/// @todo What should we do with an "unshare"?
// Removing the contact isn't correct since we still can read the public items
//contact_remove($contact["id"]);
2016-03-02 22:28:20 +00:00
return true ;
default :
logger ( " Unknown target type " . $target_type );
2016-03-03 22:34:17 +00:00
return false ;
2016-03-02 22:28:20 +00:00
}
2016-02-27 22:54:17 +00:00
return true ;
}
2016-03-04 23:27:44 +00:00
private function receive_status_message ( $importer , $data ) {
2016-02-29 07:02:50 +00:00
$raw_message = unxmlify ( $data -> raw_message );
$guid = notags ( unxmlify ( $data -> guid ));
$author = notags ( unxmlify ( $data -> author ));
$public = notags ( unxmlify ( $data -> public ));
$created_at = notags ( unxmlify ( $data -> created_at ));
$provider_display_name = notags ( unxmlify ( $data -> provider_display_name ));
2016-03-01 22:21:56 +00:00
/// @todo enable support for polls
2016-03-02 22:28:20 +00:00
//if ($data->poll) {
// foreach ($data->poll AS $poll)
// print_r($poll);
// die("poll!\n");
//}
2016-03-01 06:57:26 +00:00
$contact = self :: get_allowed_contact_by_handle ( $importer , $author , false );
if ( ! $contact )
2016-02-29 07:02:50 +00:00
return false ;
2016-02-29 22:54:25 +00:00
2016-03-03 22:34:17 +00:00
if ( self :: message_exists ( $importer [ " uid " ], $guid ))
return false ;
2016-02-29 22:54:25 +00:00
$address = array ();
if ( $data -> location )
foreach ( $data -> location -> children () AS $fieldname => $data )
$address [ $fieldname ] = notags ( unxmlify ( $data ));
2016-02-29 07:02:50 +00:00
$body = diaspora2bb ( $raw_message );
2016-03-02 22:39:50 +00:00
$datarray = array ();
if ( $data -> photo ) {
2016-03-01 22:21:56 +00:00
foreach ( $data -> photo AS $photo )
$body = " [img] " . $photo -> remote_photo_path . $photo -> remote_photo_name . " [/img] \n " . $body ;
2016-02-29 22:54:25 +00:00
2016-02-29 07:02:50 +00:00
$datarray [ " object-type " ] = ACTIVITY_OBJ_PHOTO ;
2016-03-02 22:39:50 +00:00
} else {
2016-02-29 07:02:50 +00:00
$datarray [ " object-type " ] = ACTIVITY_OBJ_NOTE ;
2016-03-02 22:39:50 +00:00
2016-02-29 07:02:50 +00:00
// Add OEmbed and other information to the body
if ( ! self :: is_redmatrix ( $contact [ " url " ]))
$body = add_page_info_to_body ( $body , false , true );
}
$datarray [ " uid " ] = $importer [ " uid " ];
$datarray [ " contact-id " ] = $contact [ " id " ];
$datarray [ " network " ] = NETWORK_DIASPORA ;
$datarray [ " author-name " ] = $contact [ " name " ];
$datarray [ " author-link " ] = $contact [ " url " ];
$datarray [ " author-avatar " ] = (( x ( $contact , " thumb " )) ? $contact [ " thumb " ] : $contact [ " photo " ]);
$datarray [ " owner-name " ] = $datarray [ " author-name " ];
$datarray [ " owner-link " ] = $datarray [ " author-link " ];
$datarray [ " owner-avatar " ] = $datarray [ " author-avatar " ];
$datarray [ " guid " ] = $guid ;
$datarray [ " uri " ] = $datarray [ " parent-uri " ] = $author . " : " . $guid ;
$datarray [ " verb " ] = ACTIVITY_POST ;
$datarray [ " gravity " ] = GRAVITY_PARENT ;
$datarray [ " object " ] = json_encode ( $data );
$datarray [ " body " ] = $body ;
if ( $provider_display_name != " " )
$datarray [ " app " ] = $provider_display_name ;
2016-03-01 06:57:26 +00:00
$datarray [ " plink " ] = self :: plink ( $author , $guid );
$datarray [ " private " ] = (( $public == " false " ) ? 1 : 0 );
2016-02-29 07:02:50 +00:00
$datarray [ " changed " ] = $datarray [ " created " ] = $datarray [ " edited " ] = datetime_convert ( " UTC " , " UTC " , $created_at );
2016-02-29 22:54:25 +00:00
if ( isset ( $address [ " address " ]))
$datarray [ " location " ] = $address [ " address " ];
2016-02-29 07:02:50 +00:00
2016-02-29 22:54:25 +00:00
if ( isset ( $address [ " lat " ]) AND isset ( $address [ " lng " ]))
$datarray [ " coord " ] = $address [ " lat " ] . " " . $address [ " lng " ];
2016-02-29 07:02:50 +00:00
self :: fetch_guid ( $datarray );
2016-03-03 22:34:17 +00:00
$message_id = item_store ( $datarray );
// print_r($datarray);
2016-02-29 07:02:50 +00:00
logger ( " Stored item with message id " . $message_id , LOGGER_DEBUG );
return $message_id ;
2016-02-27 22:54:17 +00:00
}
2016-03-05 23:53:30 +00:00
/*******************************************************************************************
* Here come all the functions that are needed to transmit data with the Diaspora protocol *
*******************************************************************************************/
private function get_my_handle ( $me ) {
if ( $contact [ " addr " ] != " " )
return $contact [ " addr " ];
// Normally we should have a filled "addr" field - but in the past this wasn't the case
// So - just in case - we build the the address here.
return $me [ " nickname " ] . " @ " . substr ( App :: get_baseurl (), strpos ( App :: get_baseurl (), " :// " ) + 3 );
}
2016-03-06 10:41:51 +00:00
private function build_public_message ( $msg , $user , $contact , $prvkey , $pubkey ) {
2016-03-05 23:53:30 +00:00
logger ( " Message: " . $msg , LOGGER_DATA );
$handle = self :: get_my_handle ( $user );
$b64url_data = base64url_encode ( $msg );
$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.com/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 ( " magic_env: " . $magic_env , LOGGER_DATA );
return $magic_env ;
}
private function build_private_message ( $msg , $user , $contact , $prvkey , $pubkey ) {
logger ( " Message: " . $msg , LOGGER_DATA );
// without a public key nothing will work
if ( ! $pubkey ) {
logger ( " pubkey missing: contact id: " . $contact [ " id " ]);
return false ;
}
$inner_aes_key = random_string ( 32 );
$b_inner_aes_key = base64_encode ( $inner_aes_key );
$inner_iv = random_string ( 16 );
$b_inner_iv = base64_encode ( $inner_iv );
$outer_aes_key = random_string ( 32 );
$b_outer_aes_key = base64_encode ( $outer_aes_key );
$outer_iv = random_string ( 16 );
$b_outer_iv = base64_encode ( $outer_iv );
$handle = self :: get_my_handle ( $user );
$padded_data = pkcs5_pad ( $msg , 16 );
$inner_encrypted = mcrypt_encrypt ( MCRYPT_RIJNDAEL_128 , $inner_aes_key , $padded_data , MCRYPT_MODE_CBC , $inner_iv );
$b64_data = base64_encode ( $inner_encrypted );
$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 );
$decrypted_header = <<< EOT
< decrypted_header >
< iv > $b_inner_iv </ iv >
< aes_key > $b_inner_aes_key </ aes_key >
< author_id > $handle </ author_id >
</ decrypted_header >
EOT ;
$decrypted_header = pkcs5_pad ( $decrypted_header , 16 );
$ciphertext = mcrypt_encrypt ( MCRYPT_RIJNDAEL_128 , $outer_aes_key , $decrypted_header , MCRYPT_MODE_CBC , $outer_iv );
$outer_json = json_encode ( array ( " iv " => $b_outer_iv , " key " => $b_outer_aes_key ));
$encrypted_outer_key_bundle = " " ;
openssl_public_encrypt ( $outer_json , $encrypted_outer_key_bundle , $pubkey );
$b64_encrypted_outer_key_bundle = base64_encode ( $encrypted_outer_key_bundle );
logger ( " outer_bundle: " . $b64_encrypted_outer_key_bundle . " key: " . $pubkey , LOGGER_DATA );
$encrypted_header_json_object = json_encode ( array ( " aes_key " => base64_encode ( $encrypted_outer_key_bundle ),
" ciphertext " => base64_encode ( $ciphertext )));
$cipher_json = base64_encode ( $encrypted_header_json_object );
$encrypted_header = " <encrypted_header> " . $cipher_json . " </encrypted_header> " ;
$magic_env = <<< EOT
< ? xml version = '1.0' encoding = 'UTF-8' ?>
< diaspora xmlns = " https://joindiaspora.com/protocol " xmlns : me = " http://salmon-protocol.org/ns/magic-env " >
$encrypted_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 ( " magic_env: " . $magic_env , LOGGER_DATA );
return $magic_env ;
}
private function build_message ( $msg , $user , $contact , $prvkey , $pubkey , $public = false ) {
if ( $public )
$magic_env = self :: build_public_message ( $msg , $user , $contact , $prvkey , $pubkey );
else
$magic_env = self :: build_private_message ( $msg , $user , $contact , $prvkey , $pubkey );
// The data that will be transmitted is double encoded via "urlencode", strange ...
$slap = " xml= " . urlencode ( urlencode ( $magic_env ));
return $slap ;
}
2016-03-07 07:17:21 +00:00
private function get_signature ( $owner , $message ) {
$sigmsg = $message ;
unset ( $sigmsg [ " author_signature " ]);
unset ( $sigmsg [ " parent_author_signature " ]);
$signed_text = implode ( " ; " , $sigmsg );
return base64_encode ( rsa_sign ( $signed_text , $owner [ " uprvkey " ], " sha256 " ));
}
2016-03-05 23:53:30 +00:00
private function transmit ( $owner , $contact , $slap , $public_batch , $queue_run = false , $guid = " " ) {
$a = get_app ();
$enabled = intval ( get_config ( " system " , " diaspora_enabled " ));
if ( ! $enabled )
return 200 ;
$logid = random_string ( 4 );
$dest_url = (( $public_batch ) ? $contact [ " batch " ] : $contact [ " notify " ]);
if ( ! $dest_url ) {
logger ( " no url for contact: " . $contact [ " id " ] . " batch mode = " . $public_batch );
return 0 ;
}
logger ( " transmit: " . $logid . " - " . $guid . " " . $dest_url );
if ( ! $queue_run && was_recently_delayed ( $contact [ " id " ])) {
$return_code = 0 ;
} else {
if ( ! intval ( get_config ( " system " , " diaspora_test " ))) {
post_url ( $dest_url . " / " , $slap );
$return_code = $a -> get_curl_code ();
} else {
logger ( " test_mode " );
return 200 ;
}
}
logger ( " transmit: " . $logid . " - " . $guid . " returns: " . $return_code );
if ( ! $return_code || (( $return_code == 503 ) && ( stristr ( $a -> get_curl_headers (), " retry-after " )))) {
logger ( " queue message " );
$r = q ( " SELECT `id` FROM `queue` WHERE `cid` = %d AND `network` = '%s' AND `content` = '%s' AND `batch` = %d LIMIT 1 " ,
intval ( $contact [ " id " ]),
dbesc ( NETWORK_DIASPORA ),
dbesc ( $slap ),
intval ( $public_batch )
);
if ( count ( $r )) {
logger ( " add_to_queue ignored - identical item already in queue " );
} else {
// queue message for redelivery
add_to_queue ( $contact [ " id " ], NETWORK_DIASPORA , $slap , $public_batch );
}
}
return (( $return_code ) ? $return_code : ( - 1 ));
}
2016-03-12 18:19:20 +00:00
private function build_and_transmit ( $owner , $contact , $type , $message , $public_batch = false , $guid = " " ) {
$data = array ( " XML " => array ( " post " => array ( $type => $message )));
2016-03-05 23:53:30 +00:00
$msg = xml :: from_array ( $data , $xml );
2016-03-12 18:19:20 +00:00
logger ( 'message: ' . $msg , LOGGER_DATA );
logger ( 'send guid ' . $guid , LOGGER_DEBUG );
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
$slap = self :: build_message ( $msg , $owner , $contact , $owner [ 'uprvkey' ], $contact [ 'pubkey' ], $public_batch );
die ( $slap );
$return_code = self :: transmit ( $owner , $contact , $slap , $public_batch , false , $guid );
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
logger ( " guid: " . $item [ " guid " ] . " result " . $return_code , LOGGER_DEBUG );
return $return_code ;
2016-03-05 23:53:30 +00:00
}
2016-03-12 18:19:20 +00:00
public static function send_share ( $owner , $contact ) {
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
$message = array ( " sender_handle " => self :: get_my_handle ( $owner ),
" recipient_handle " => $contact [ " addr " ]);
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
return self :: build_and_transmit ( $owner , $contact , " request " , $message );
}
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
public static function send_unshare ( $owner , $contact ) {
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
$message = array ( " post_guid " => $owner [ " guid " ],
" diaspora_handle " => self :: get_my_handle ( $owner ),
" type " => " Person " );
return self :: build_and_transmit ( $owner , $contact , " retraction " , $message );
2016-03-05 23:53:30 +00:00
}
2016-03-06 10:41:51 +00:00
private function is_reshare ( $body ) {
2016-03-05 23:53:30 +00:00
$body = trim ( $body );
// Skip if it isn't a pure repeated messages
// Does it start with a share?
if ( strpos ( $body , " [share " ) > 0 )
return ( false );
// Does it end with a share?
if ( strlen ( $body ) > ( strrpos ( $body , " [/share] " ) + 8 ))
return ( false );
$attributes = preg_replace ( " / \ [share(.*?) \ ] \ s?(.*?) \ s? \ [ \ /share \ ] \ s?/ism " , " $ 1 " , $body );
// Skip if there is no shared message in there
if ( $body == $attributes )
return ( false );
$guid = " " ;
preg_match ( " /guid='(.*?)'/ism " , $attributes , $matches );
if ( $matches [ 1 ] != " " )
$guid = $matches [ 1 ];
preg_match ( '/guid="(.*?)"/ism' , $attributes , $matches );
if ( $matches [ 1 ] != " " )
$guid = $matches [ 1 ];
if ( $guid != " " ) {
$r = q ( " SELECT `contact-id` FROM `item` WHERE `guid` = '%s' AND `network` IN ('%s', '%s') LIMIT 1 " ,
dbesc ( $guid ), NETWORK_DFRN , NETWORK_DIASPORA );
if ( $r ) {
$ret = array ();
$ret [ " root_handle " ] = diaspora_handle_from_contact ( $r [ 0 ][ " contact-id " ]);
$ret [ " root_guid " ] = $guid ;
return ( $ret );
}
}
$profile = " " ;
preg_match ( " /profile='(.*?)'/ism " , $attributes , $matches );
if ( $matches [ 1 ] != " " )
$profile = $matches [ 1 ];
preg_match ( '/profile="(.*?)"/ism' , $attributes , $matches );
if ( $matches [ 1 ] != " " )
$profile = $matches [ 1 ];
$ret = array ();
$ret [ " root_handle " ] = preg_replace ( " =https?://(.*)/u/(.*)=ism " , " $ 2@ $ 1 " , $profile );
if (( $ret [ " root_handle " ] == $profile ) OR ( $ret [ " root_handle " ] == " " ))
return ( false );
$link = " " ;
preg_match ( " /link='(.*?)'/ism " , $attributes , $matches );
if ( $matches [ 1 ] != " " )
$link = $matches [ 1 ];
preg_match ( '/link="(.*?)"/ism' , $attributes , $matches );
if ( $matches [ 1 ] != " " )
$link = $matches [ 1 ];
$ret [ " root_guid " ] = preg_replace ( " =https?://(.*)/posts/(.*)=ism " , " $ 2 " , $link );
if (( $ret [ " root_guid " ] == $link ) OR ( $ret [ " root_guid " ] == " " ))
return ( false );
return ( $ret );
}
2016-03-06 10:41:51 +00:00
public static function send_status ( $item , $owner , $contact , $public_batch = false ) {
2016-03-05 23:53:30 +00:00
$myaddr = self :: get_my_handle ( $owner );
$public = (( $item [ " private " ]) ? " false " : " true " );
$created = datetime_convert ( " UTC " , " UTC " , $item [ " created " ], 'Y-m-d H:i:s \U\T\C' );
// Detect a share element and do a reshare
if ( ! $item [ 'private' ] AND ( $ret = self :: is_reshare ( $item [ " body " ]))) {
$message = array ( " root_diaspora_id " => $ret [ " root_handle " ],
" root_guid " => $ret [ " root_guid " ],
" guid " => $item [ " guid " ],
" diaspora_handle " => $myaddr ,
" public " => $public ,
" created_at " => $created ,
" provider_display_name " => $item [ " app " ]);
2016-03-12 18:19:20 +00:00
$type = " reshare " ;
2016-03-05 23:53:30 +00:00
} else {
2016-03-12 18:19:20 +00:00
$title = $item [ " title " ];
$body = $item [ " body " ];
// convert to markdown
$body = html_entity_decode ( bb2diaspora ( $body ));
// Adding the title
if ( strlen ( $title ))
$body = " ## " . html_entity_decode ( $title ) . " \n \n " . $body ;
if ( $item [ " attach " ]) {
$cnt = preg_match_all ( '/href=\"(.*?)\"(.*?)title=\"(.*?)\"/ism' , $item [ " attach " ], $matches , PREG_SET_ORDER );
if ( cnt ) {
$body .= " \n " . t ( " Attachments: " ) . " \n " ;
foreach ( $matches as $mtch )
$body .= " [ " . $mtch [ 3 ] . " ]( " . $mtch [ 1 ] . " ) \n " ;
}
}
2016-03-05 23:53:30 +00:00
$location = array ();
if ( $item [ " location " ] != " " )
$location [ " address " ] = $item [ " location " ];
if ( $item [ " coord " ] != " " ) {
$coord = explode ( " " , $item [ " coord " ]);
$location [ " lat " ] = $coord [ 0 ];
$location [ " lng " ] = $coord [ 1 ];
}
$message = array ( " raw_message " => $body ,
" location " => $location ,
" guid " => $item [ " guid " ],
" diaspora_handle " => $myaddr ,
" public " => $public ,
" created_at " => $created ,
" provider_display_name " => $item [ " app " ]);
if ( count ( $location ) == 0 )
unset ( $message [ " location " ]);
2016-03-12 18:19:20 +00:00
$type = " status_message " ;
2016-03-05 23:53:30 +00:00
}
2016-03-12 18:19:20 +00:00
return self :: build_and_transmit ( $owner , $contact , $type , $message , $public_batch , $item [ " guid " ]);
2016-03-05 23:53:30 +00:00
}
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
private function construct_like ( $item , $owner ) {
2016-03-05 23:53:30 +00:00
2016-03-12 18:19:20 +00:00
$myaddr = self :: get_my_handle ( $owner );
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
$p = q ( " SELECT `guid`, `uri`, `parent-uri` FROM `item` WHERE `uri` = '%s' LIMIT 1 " ,
dbesc ( $item [ " thr-parent " ]));
if ( ! $p )
return false ;
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
$parent = $p [ 0 ];
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
$target_type = ( $parent [ " uri " ] === $parent [ " parent-uri " ] ? " Post " : " Comment " );
$positive = " true " ;
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
return ( array ( " positive " => $positive ,
" guid " => $item [ " guid " ],
" target_type " => $target_type ,
" parent_guid " => $parent [ " guid " ],
" author_signature " => $authorsig ,
" diaspora_handle " => $myaddr ));
2016-03-06 21:49:50 +00:00
}
2016-03-12 18:19:20 +00:00
private function construct_comment ( $item , $owner ) {
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
$myaddr = self :: get_my_handle ( $owner );
2016-03-07 00:34:06 +00:00
2016-03-12 18:19:20 +00:00
$p = q ( " SELECT `guid` FROM `item` WHERE `parent` = %d AND `id` = %d LIMIT 1 " ,
intval ( $item [ " parent " ]),
intval ( $item [ " parent " ])
);
2016-03-06 10:41:51 +00:00
2016-03-12 18:19:20 +00:00
if ( ! $p )
return false ;
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
$parent = $p [ 0 ];
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
$text = html_entity_decode ( bb2diaspora ( $item [ " body " ]));
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
return ( array ( " guid " => $item [ " guid " ],
" parent_guid " => $parent [ " guid " ],
" author_signature " => " " ,
" text " => $text ,
" diaspora_handle " => $myaddr ));
2016-03-06 21:49:50 +00:00
}
public static function send_followup ( $item , $owner , $contact , $public_batch = false ) {
2016-03-06 10:41:51 +00:00
2016-03-12 18:19:20 +00:00
if ( $item [ 'verb' ] === ACTIVITY_LIKE ) {
$message = self :: construct_like ( $item , $owner );
$type = " like " ;
} else {
$message = self :: construct_comment ( $item , $owner );
$type = " comment " ;
}
2016-03-06 10:41:51 +00:00
2016-03-12 18:19:20 +00:00
if ( ! $message )
return false ;
2016-03-06 10:41:51 +00:00
2016-03-12 18:19:20 +00:00
$message [ " author_signature " ] = self :: get_signature ( $owner , $message );
2016-03-06 21:49:50 +00:00
2016-03-12 18:19:20 +00:00
return self :: build_and_transmit ( $owner , $contact , $type , $message , $public_batch , $item [ " guid " ]);
2016-03-06 10:41:51 +00:00
}
2016-03-06 21:49:50 +00:00
2016-03-07 00:34:06 +00:00
function send_relay ( $item , $owner , $contact , $public_batch = false ) {
2016-03-12 18:19:20 +00:00
if ( $item [ " deleted " ]) {
2016-03-07 00:34:06 +00:00
$sql_sign_id = " retract_iid " ;
2016-03-12 18:19:20 +00:00
$type = " relayable_retraction " ;
} elseif ( $item [ 'verb' ] === ACTIVITY_LIKE ) {
2016-03-07 00:34:06 +00:00
$sql_sign_id = " iid " ;
2016-03-12 18:19:20 +00:00
$type = " like " ;
} else {
$sql_sign_id = " iid " ;
$type = " comment " ;
}
2016-03-07 00:34:06 +00:00
// fetch the original signature if the relayable was created by a Diaspora
// or DFRN user.
$r = q ( " SELECT `signed_text`, `signature`, `signer` FROM `sign` WHERE ` " . $sql_sign_id . " ` = %d LIMIT 1 " ,
intval ( $item [ " id " ])
);
2016-03-12 18:19:20 +00:00
if ( ! $r )
return self :: send_followup ( $item , $owner , $contact , $public_batch );
$orig_sign = $r [ 0 ];
2016-03-07 00:34:06 +00:00
2016-03-12 18:19:20 +00:00
// Old way - can be removed for the master branch
if ( $orig_sign [ 'signed_text' ] AND $orig_sign [ 'signature' ] AND $orig_sign [ 'signer' ]) {
2016-03-07 00:34:06 +00:00
2016-03-12 18:19:20 +00:00
// Split the signed text
$signed_parts = explode ( " ; " , $orig_sign [ 'signed_text' ]);
if ( $item [ " deleted " ])
$message = array ( " parent_author_signature " => " " ,
" target_guid " => $signed_parts [ 0 ],
" target_type " => $signed_parts [ 1 ],
" sender_handle " => $orig_sign [ 'signer' ],
" target_author_signature " => $orig_sign [ 'signature' ]);
elseif ( $item [ 'verb' ] === ACTIVITY_LIKE )
$message = array ( " positive " => $signed_parts [ 0 ],
2016-03-07 07:17:21 +00:00
" guid " => $signed_parts [ 1 ],
" target_type " => $signed_parts [ 2 ],
" parent_guid " => $signed_parts [ 3 ],
" parent_author_signature " => " " ,
" author_signature " => $orig_sign [ 'signature' ],
" diaspora_handle " => $signed_parts [ 4 ]);
2016-03-12 18:19:20 +00:00
else {
2016-03-07 07:17:21 +00:00
// Remove the comment guid
$guid = array_shift ( $signed_parts );
2016-03-07 00:34:06 +00:00
2016-03-07 07:17:21 +00:00
// Remove the parent guid
$parent_guid = array_shift ( $signed_parts );
2016-03-07 00:34:06 +00:00
2016-03-07 07:17:21 +00:00
// Remove the handle
$handle = array_pop ( $signed_parts );
2016-03-07 00:34:06 +00:00
2016-03-07 07:17:21 +00:00
// Glue the parts together
$text = implode ( " ; " , $signed_parts );
2016-03-07 00:34:06 +00:00
2016-03-12 18:19:20 +00:00
$message = array ( " guid " => $guid ,
2016-03-07 07:17:21 +00:00
" parent_guid " => $parent_guid ,
" parent_author_signature " => " " ,
" author_signature " => $orig_sign [ 'signature' ],
" text " => implode ( " ; " , $signed_parts ),
" diaspora_handle " => $handle );
}
2016-03-12 18:19:20 +00:00
} else { // New way
$message = json_decode ( $orig_sign [ 'signed_text' ]);
2016-03-07 00:34:06 +00:00
}
2016-03-12 18:19:20 +00:00
if ( $item [ " deleted " ]) {
$signed_text = $message [ " target_guid " ] . ';' . $message [ " target_type " ];
$message [ " parent_author_signature " ] = base64_encode ( rsa_sign ( $signed_text , $owner [ " uprvkey " ], " sha256 " ));
} else
$message [ " parent_author_signature " ] = self :: get_signature ( $owner , $message );
2016-03-07 00:34:06 +00:00
2016-03-12 18:19:20 +00:00
return self :: build_and_transmit ( $owner , $contact , $type , $message , $public_batch , $item [ " guid " ]);
2016-03-07 00:34:06 +00:00
}
2016-03-06 10:41:51 +00:00
public static function send_retraction ( $item , $owner , $contact , $public_batch = false ) {
2016-03-06 00:37:47 +00:00
$myaddr = self :: get_my_handle ( $owner );
// Check whether the retraction is for a top-level post or whether it's a relayable
if ( $item [ " uri " ] !== $item [ " parent-uri " ]) {
$msg_type = " relayable_retraction " ;
$target_type = (( $item [ " verb " ] === ACTIVITY_LIKE ) ? " Like " : " Comment " );
} else {
$msg_type = " signed_retraction " ;
$target_type = " StatusMessage " ;
}
$signed_text = $item [ " guid " ] . " ; " . $target_type ;
$message = array ( " target_guid " => $item [ 'guid' ],
" target_type " => $target_type ,
" sender_handle " => $myaddr ,
" target_author_signature " => base64_encode ( rsa_sign ( $signed_text , $owner [ 'uprvkey' ], 'sha256' )));
2016-03-12 18:19:20 +00:00
return self :: build_and_transmit ( $owner , $contact , $msg_type , $message , $public_batch , $item [ " guid " ]);
2016-03-06 00:37:47 +00:00
}
2016-03-12 18:19:20 +00:00
public static function send_mail ( $item , $owner , $contact ) {
2016-03-05 23:53:30 +00:00
$myaddr = self :: get_my_handle ( $owner );
$r = q ( " SELECT * FROM `conv` WHERE `id` = %d AND `uid` = %d LIMIT 1 " ,
intval ( $item [ " convid " ]),
intval ( $item [ " uid " ])
);
if ( ! count ( $r )) {
logger ( " conversation not found. " );
return ;
}
$cnv = $r [ 0 ];
$conv = array (
" guid " => $cnv [ " guid " ],
" subject " => $cnv [ " subject " ],
" created_at " => datetime_convert ( " UTC " , " UTC " , $cnv [ 'created' ], 'Y-m-d H:i:s \U\T\C' ),
" diaspora_handle " => $cnv [ " creator " ],
" participant_handles " => $cnv [ " recips " ]
);
$body = bb2diaspora ( $item [ " body " ]);
$created = datetime_convert ( " UTC " , " UTC " , $item [ " created " ], 'Y-m-d H:i:s \U\T\C' );
$signed_text = $item [ " guid " ] . " ; " . $cnv [ " guid " ] . " ; " . $body . " ; " . $created . " ; " . $myaddr . " ; " . $cnv [ 'guid' ];
$sig = base64_encode ( rsa_sign ( $signed_text , $owner [ " uprvkey " ], " sha256 " ));
$msg = array (
" guid " => $item [ " guid " ],
" parent_guid " => $cnv [ " guid " ],
" parent_author_signature " => $sig ,
" author_signature " => $sig ,
" text " => $body ,
" created_at " => $created ,
" diaspora_handle " => $myaddr ,
" conversation_guid " => $cnv [ " guid " ]
);
2016-03-12 18:19:20 +00:00
if ( $item [ " reply " ]) {
$message = $msg ;
$type = " message " ;
} else {
2016-03-05 23:53:30 +00:00
$message = array ( " guid " => $cnv [ " guid " ],
" subject " => $cnv [ " subject " ],
" created_at " => datetime_convert ( " UTC " , " UTC " , $cnv [ 'created' ], 'Y-m-d H:i:s \U\T\C' ),
" message " => $msg ,
" diaspora_handle " => $cnv [ " creator " ],
" participant_handles " => $cnv [ " recips " ]);
2016-03-12 18:19:20 +00:00
$type = " conversation " ;
2016-03-05 23:53:30 +00:00
}
2016-03-12 18:19:20 +00:00
return self :: build_and_transmit ( $owner , $contact , $type , $message , false , $item [ " guid " ]);
2016-03-05 23:53:30 +00:00
}
2016-02-27 22:54:17 +00:00
}
?>