Browse Source
- Add an "Explore" page to discover new contacts
- Add an "Explore" page to discover new contacts
- New table "RosterLink" which split the Roster informations from the Contact table - Update all the widgets for the new DB structure - Clean lot of old stuffs in the code - New time detection for the server time - Improve page loading speed by reducing number of DB request and request answer sizepull/16/head
Jaussoin Timothée
13 years ago
31 changed files with 406 additions and 1179 deletions
-
36image.php
-
8loader.php
-
10system/Cache.php
-
43system/Controller/ControllerMain.php
-
103system/Datas/Attachment.php
-
88system/Datas/Contact.php
-
9system/Datas/Post.php
-
31system/Datas/RosterLink.php
-
797system/Jabber.php
-
55system/Utils.php
-
22system/Widget/WidgetCommon.php
-
63system/Widget/widgets/Chat/Chat.php
-
8system/Widget/widgets/Chat/chat.css
-
1system/Widget/widgets/ContactCard/ContactCard.php
-
33system/Widget/widgets/ContactInfo/ContactInfo.php
-
4system/Widget/widgets/ContactSummary/ContactSummary.php
-
55system/Widget/widgets/Explore/Explore.php
-
44system/Widget/widgets/Explore/explore.css
-
10system/Widget/widgets/Feed/Feed.php
-
4system/Widget/widgets/Login/Login.php
-
4system/Widget/widgets/Logout/Logout.php
-
78system/Widget/widgets/Notifs/Notifs.php
-
1system/Widget/widgets/Profile/Profile.php
-
3system/Widget/widgets/ProfileData/ProfileData.php
-
29system/Widget/widgets/Roster/Roster.php
-
2system/Widget/widgets/Syndication/Syndication.php
-
16system/Widget/widgets/Vcard/Vcard.php
-
1system/Widget/widgets/Wall/Wall.php
-
1themes/movim/config.tpl
-
25themes/movim/explore.tpl
-
1themes/movim/friend.tpl
@ -1,103 +0,0 @@ |
|||
<?php |
|||
|
|||
class Attachment extends DatajarBase { |
|||
protected $key; |
|||
protected $jid; |
|||
|
|||
protected $node; |
|||
protected $attachmentid; |
|||
|
|||
protected $title; |
|||
protected $type; |
|||
|
|||
protected $length; |
|||
|
|||
protected $link; |
|||
protected $thumb; |
|||
|
|||
protected function type_init() { |
|||
$this->key = DatajarType::varchar(128); |
|||
$this->jid = DatajarType::varchar(128); |
|||
|
|||
$this->node = DatajarType::varchar(128); |
|||
$this->attachmentid = DatajarType::varchar(128); |
|||
|
|||
$this->title = DatajarType::varchar(128); |
|||
$this->type = DatajarType::varchar(128); |
|||
|
|||
$this->length = DatajarType::int(); |
|||
|
|||
$this->link = DatajarType::varchar(128); |
|||
$this->thumb = DatajarType::varchar(128); |
|||
} |
|||
|
|||
public function getData($data) { |
|||
return $this->$data->getval(); |
|||
} |
|||
} |
|||
|
|||
class AttachmentHandler { |
|||
static function getAttachment($key, $node) { |
|||
global $sdb; |
|||
$attachment = $sdb->select('Attachment', array('key' => $key, 'node'=> $node)); |
|||
if($attachment != false) |
|||
return $attachment; |
|||
else |
|||
return false; |
|||
} |
|||
|
|||
function saveAttachment($array, $jid, $from, $node) { |
|||
global $sdb; |
|||
$attachment = $sdb->select('Attachment', array( |
|||
'key' => $jid, |
|||
'jid' => $from, |
|||
'node'=> $node, |
|||
'attachmentid' => sha1($array['@attributes']['href']. |
|||
$array['@attributes']['title']. |
|||
$array['@attributes']['length']) |
|||
)); |
|||
|
|||
if($attachment == false) { |
|||
$attachment = new Attachment(); |
|||
$attachment->key = $jid; |
|||
$attachment->jid = $from; |
|||
|
|||
$attachment->node = $node; |
|||
$attachment->attachmentid = sha1($array['@attributes']['href']. |
|||
$array['@attributes']['title']. |
|||
$array['@attributes']['length']); |
|||
|
|||
$attachment->title = $array['@attributes']['title']; |
|||
$attachment->type = $array['@attributes']['type']; |
|||
|
|||
$attachment->length = $array['@attributes']['length']; |
|||
|
|||
$attachment->link = $array['@attributes']['href']; |
|||
$attachment->thumb = $array['link'][0]['@attributes']['href']; |
|||
|
|||
$sdb->save($attachment); |
|||
} else { |
|||
global $sdb; |
|||
$attachment = new Attachment(); |
|||
$sdb->load($attachment, array( |
|||
'key' => $jid, |
|||
'jid' => $from, |
|||
'node'=> $node, |
|||
'attachmentid' => sha1($array['@attributes']['href']. |
|||
$array['@attributes']['title']. |
|||
$array['@attributes']['length']) |
|||
)); |
|||
|
|||
$attachment->title = $array['@attributes']['title']; |
|||
$attachment->type = $array['@attributes']['type']; |
|||
|
|||
$attachment->length = $array['@attributes']['length']; |
|||
|
|||
$attachment->link = $array['@attributes']['href']; |
|||
$attachment->thumb = $array['link'][0]['@attributes']['href']; |
|||
|
|||
$sdb->save($attachment); |
|||
|
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,31 @@ |
|||
<?php |
|||
|
|||
class RosterLink extends DatajarBase { |
|||
public $key; |
|||
public $jid; |
|||
|
|||
public $rostername; |
|||
public $rosterask; |
|||
public $rostersubscription; |
|||
|
|||
public $group; |
|||
|
|||
public $chaton; |
|||
|
|||
protected function type_init() { |
|||
$this->key = DatajarType::varchar(128); |
|||
$this->jid = DatajarType::varchar(128); |
|||
|
|||
$this->rostername = DatajarType::varchar(128); |
|||
$this->rosterask = DatajarType::varchar(128); |
|||
$this->rostersubscription = DatajarType::varchar(128); |
|||
|
|||
$this->group = DatajarType::varchar(128); |
|||
|
|||
$this->chaton = DatajarType::int(); |
|||
} |
|||
|
|||
public function getData($data) { |
|||
return trim($this->$data->getval()); |
|||
} |
|||
} |
|||
@ -1,797 +0,0 @@ |
|||
<?php |
|||
|
|||
/** |
|||
* @file Jabber.php |
|||
* This file is part of MOVIM. |
|||
* |
|||
* @brief Wrapper around Jaxl to handle mid-level functionalities |
|||
* |
|||
* @author Etenil <etenil@etenilsrealm.nl> |
|||
* |
|||
* @version 1.0 |
|||
* @date 13 October 2010 |
|||
* |
|||
* Copyright (C)2010 Movim Project |
|||
* |
|||
* See COPYING for licensing information. |
|||
*/ |
|||
|
|||
//include(LIB_PATH . 'Jaxl/core/jaxl.class.php');
|
|||
|
|||
class Jabber |
|||
{ |
|||
private static $instance; |
|||
private $jaxl; |
|||
private $payload; |
|||
|
|||
/** |
|||
* Firing up basic parts of jaxl and setting variables. |
|||
*/ |
|||
private function __construct($jid) |
|||
{ |
|||
$userConf = UserConf::getConf($jid); |
|||
|
|||
$serverConf = Conf::getServerConf(); |
|||
|
|||
$sess = Session::start(APP_NAME); |
|||
|
|||
$sess->remove('jid'); // ???
|
|||
|
|||
$this->jaxl = new JAXL(array( |
|||
// User Configuration
|
|||
'resource' => "Movim", |
|||
|
|||
// Here we need to exchange the host and domain to allow the connexion, Jaxl bug ?
|
|||
'host' => $userConf['domain'], |
|||
'domain' => $userConf['host'], |
|||
|
|||
'boshHost' => $userConf['boshHost'], |
|||
'boshSuffix' => $userConf['boshSuffix'], |
|||
'boshPort' => $userConf['boshPort'], |
|||
|
|||
// Server configuration
|
|||
'boshCookieTTL' => $serverConf['boshCookieTTL'], |
|||
'boshCookiePath' => $serverConf['boshCookiePath'], |
|||
'boshCookieDomain' => $serverConf['boshCookieDomain'], |
|||
'boshCookieHTTPS' => $serverConf['boshCookieHTTPS'], |
|||
'boshCookieHTTPOnly' => $serverConf['boshCookieHTTPOnly'], |
|||
'logLevel' => $serverConf['logLevel'], |
|||
'boshOut'=>false, |
|||
|
|||
)); |
|||
// Loading required XEPS
|
|||
$this->jaxl->requires(array( |
|||
'JAXL0030', // Service Discovery
|
|||
'JAXL0054', // VCard
|
|||
'JAXL0060', // Pubsub
|
|||
'JAXL0107', // User Mood
|
|||
'JAXL0118', // User Tune
|
|||
'JAXL0115', // Entity Capabilities
|
|||
'JAXL0133', // Service Administration
|
|||
'JAXL0085', // Chat State Notification
|
|||
'JAXL0092', // Software Version
|
|||
'JAXL0203', // Delayed Delivery
|
|||
'JAXL0202', // Entity Time
|
|||
'JAXL0206', // Jabber over Bosh
|
|||
'JAXL0277' // Microblogging
|
|||
)); |
|||
|
|||
// Defining call-backs
|
|||
|
|||
// Connect-Disconnect
|
|||
$this->jaxl->addPlugin('jaxl_post_auth', array(&$this, 'postAuth')); |
|||
$this->jaxl->addPlugin('jaxl_post_auth_failure', array(&$this, 'postAuthFailure')); |
|||
$this->jaxl->addPlugin('jaxl_post_disconnect', array(&$this, 'postDisconnect')); |
|||
$this->jaxl->addPlugin('jaxl_get_auth_mech', array(&$this, 'postAuthMech')); |
|||
|
|||
// The handlers
|
|||
$this->jaxl->addPlugin('jaxl_get_iq', array(&$this, 'getIq')); |
|||
$this->jaxl->addPlugin('jaxl_get_message', array(&$this, 'getMessage')); |
|||
$this->jaxl->addPlugin('jaxl_get_presence', array(&$this, 'getPresence')); |
|||
|
|||
// Others hooks
|
|||
$this->jaxl->addPlugin('jaxl_get_bosh_curl_error', array(&$this, 'boshCurlError')); |
|||
$this->jaxl->addplugin('jaxl_get_empty_body', array(&$this, 'getEmptyBody')); |
|||
} |
|||
|
|||
/** |
|||
* Get the current instance |
|||
* |
|||
* @param string $jid = false |
|||
* @return instance |
|||
*/ |
|||
static public function getInstance($jid = false) |
|||
{ |
|||
if(!is_object(self::$instance)) { |
|||
if(!$jid) { |
|||
$user = new User(); |
|||
if(!$user->isLogged()) { |
|||
return false; |
|||
throw new MovimException(t("User not logged in.")); |
|||
} else { |
|||
$jid = $user->getLogin(); |
|||
if($jid = "") |
|||
throw new MovimException(t("JID not provided.")); |
|||
} |
|||
} else { |
|||
self::$instance = new Jabber($jid); |
|||
} |
|||
} |
|||
return self::$instance; |
|||
} |
|||
|
|||
function destroy() |
|||
{ |
|||
self::$instance = null; |
|||
} |
|||
|
|||
/** |
|||
* Start the BOSH connection |
|||
* |
|||
* @param string $jid |
|||
* @param string $pass |
|||
* @return void |
|||
*/ |
|||
public function login($jid, $pass) |
|||
{ |
|||
if(!checkJid($jid)) { |
|||
throw new MovimException(t("jid '%s' is incorrect", $jid)); |
|||
} else { |
|||
$id = explode('@',$jid); |
|||
$user = $id[0]; |
|||
|
|||
$this->jaxl->user = $user; |
|||
$this->jaxl->pass = $pass; |
|||
$this->jaxl->startCore('bosh'); |
|||
} |
|||
|
|||
self::setStatus($presence['status'], $presence['show'], false, true); |
|||
} |
|||
|
|||
/** |
|||
* postAuth |
|||
* |
|||
* @return void |
|||
*/ |
|||
public function postAuth() { |
|||
|
|||
} |
|||
|
|||
/** |
|||
* postAuthFailure |
|||
* |
|||
* @return void |
|||
*/ |
|||
public function postAuthFailure() { |
|||
$this->jaxl->shutdown(); |
|||
|
|||
throw new MovimException("Login error.", 300); |
|||
|
|||
$user = new User(); |
|||
$user->desauth(); |
|||
} |
|||
|
|||
/** |
|||
* Return the current ressource |
|||
* |
|||
* @return string |
|||
*/ |
|||
public function getResource() |
|||
{ |
|||
$res = JAXLUtil::splitJid($this->jaxl->jid); |
|||
return $res[2]; |
|||
} |
|||
|
|||
/** |
|||
* Return the current Cleaned Jid |
|||
* |
|||
* @return string |
|||
*/ |
|||
public function getCleanJid() { |
|||
$jid = $this->jaxl->jid; |
|||
$res = JAXLUtil::splitJid($jid); |
|||
return $res[0].'@'.$res[1]; |
|||
} |
|||
|
|||
public function boshCurlError() { |
|||
// $this->jaxl->shutdown();
|
|||
// throw new MovimException("Bosh connection error.");
|
|||
// $user = new User();
|
|||
// $user->desauth();
|
|||
} |
|||
|
|||
/** |
|||
* Auth mechanism |
|||
* |
|||
* @param array $mechanism |
|||
* @return void |
|||
*/ |
|||
public function postAuthMech($mechanism) { |
|||
if(in_array("DIGEST-MD5", $mechanism)) |
|||
$this->jaxl->auth('DIGEST-MD5'); |
|||
elseif(in_array("PLAIN", $mechanism)) |
|||
$this->jaxl->auth('PLAIN'); |
|||
} |
|||
|
|||
/** |
|||
* Close the BOSH connection |
|||
* |
|||
* @return void |
|||
*/ |
|||
public function logout() |
|||
{ |
|||
$this->jaxl->JAXL0206('endStream'); |
|||
} |
|||
|
|||
/** |
|||
* postDisconnect |
|||
* |
|||
* @param array $data |
|||
* @return void |
|||
*/ |
|||
public function postDisconnect($data) |
|||
{ |
|||
$evt = new Event(); |
|||
$evt->runEvent('postdisconnected', $data); |
|||
} |
|||
|
|||
/** |
|||
* Pings the server. This must be done regularly in order to keep the |
|||
* session running |
|||
* |
|||
* @return void |
|||
*/ |
|||
public function pingServer() |
|||
{ |
|||
$this->jaxl->JAXL0206('ping'); |
|||
} |
|||
|
|||
/** |
|||
* Get an empty body |
|||
* |
|||
* @param array $payload |
|||
* @return void |
|||
*/ |
|||
public function getEmptyBody($payload) { |
|||
$evt = new Event(); |
|||
// Oooooh, am I disconnected??
|
|||
if(preg_match('/condition=[\'"]item-not-found[\'"]/', $payload) || preg_match('/condition=[\'"]improper-addressing[\'"]/', $payload)) { |
|||
$this->postAuthFailure(); |
|||
} else { |
|||
$evt->runEvent('incomingemptybody', 'ping'); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Iq handler |
|||
* |
|||
* @param array $payload |
|||
* @return void |
|||
*/ |
|||
public function getIq($payload) { |
|||
$payload = $payload['movim']; |
|||
|
|||
global $sdb; |
|||
$evt = new Event(); |
|||
|
|||
// Holy mackerel, that's a vcard!
|
|||
if(is_array($payload['vCard']) && |
|||
$payload['@attributes']['type'] != 'error') |
|||
{ |
|||
$c = new ContactHandler(); |
|||
|
|||
// If the vcard is mine
|
|||
if($payload['@attributes']['from'] == $this->getCleanJid() || |
|||
$payload['@attributes']['from'] == NULL ) |
|||
{ |
|||
$contact = $c->get($this->getCleanJid()); |
|||
$contact->setContact($payload); |
|||
$sdb->save($contact); |
|||
$evt->runEvent('myvcard', $payload); |
|||
} |
|||
|
|||
// Yo it's your vcard dude !
|
|||
elseif(isset($payload['@attributes']['from'])) { |
|||
$contact = $c->get($payload['@attributes']['from']); |
|||
$contact->setContact($payload); |
|||
$sdb->save($contact); |
|||
$evt->runEvent('vcard', $contact); |
|||
} |
|||
} |
|||
|
|||
elseif($payload['@attributes']['xmlns'] == 'http://jabber.org/protocol/disco#info') { |
|||
global $sdb; |
|||
|
|||
$c = new CapsHandler(); |
|||
$caps = $c->get($payload['query']['@attributes']['node']); |
|||
$caps->setCaps($payload['query']); |
|||
|
|||
$sdb->save($caps); |
|||
} |
|||
|
|||
// Roster case
|
|||
elseif($payload['@attributes']['xmlns'] == 'jabber:iq:roster') { |
|||
global $sdb; |
|||
|
|||
// If we got the full roster list
|
|||
if($payload['@attributes']['type'] == 'result') { |
|||
|
|||
foreach($payload['query']['item'] as $item) { |
|||
// If we've got only one item in the roster we use it as the only one
|
|||
if(isset($item['subscription'])) |
|||
$item = $payload['query']['item']; |
|||
|
|||
$c = new ContactHandler(); |
|||
$contact = $c->get($item['@attributes']['jid']); |
|||
$contact->setContactRosterItem($item); |
|||
$sdb->save($contact); |
|||
} |
|||
|
|||
$evt->runEvent('roster', $payload); |
|||
} |
|||
// If we got only one item
|
|||
elseif($payload['@attributes']['type'] == "set") { |
|||
$c = new ContactHandler(); |
|||
|
|||
$item = $payload['query']['item']; |
|||
$contact = $c->get($item['@attributes']['jid']); |
|||
|
|||
// It's a new contact !
|
|||
if($item['@attributes']['subscription'] == 'remove') { |
|||
$evt->runEvent('contactremove', $item['@attributes']['jid']); |
|||
} |
|||
// Contact removed
|
|||
elseif(in_array($item['@attributes']['subscription'], array('from', 'to', 'both'))) { |
|||
$contact->setContactRosterItem($item); |
|||
$sdb->save($contact); |
|||
$evt->runEvent('contactadd', $item['@attributes']['jid']); |
|||
} |
|||
} |
|||
} |
|||
// Pubsub case
|
|||
elseif(isset($payload['pubsub']) && !(isset($payload['error']))) { |
|||
list($xmlns, $parent) = explode("/", $payload['pubsub']['items']['@attributes']['node']); |
|||
|
|||
if(isset($payload['pubsub']['items']['item'])) { |
|||
foreach($payload['pubsub']['items']['item'] as $item) { |
|||
|
|||
if(isset($item['id'])) |
|||
$item = $payload['pubsub']['items']['item']; |
|||
|
|||
// We've got a new Post !
|
|||
if(isset($item['@attributes']) && isset($item['entry'])) { |
|||
$c = new PostHandler(); |
|||
$post = $c->get($this->getCleanJid(), $item['@attributes']['id']); |
|||
|
|||
// We save it in the database
|
|||
if($xmlns == 'urn:xmpp:microblog:0') |
|||
$post->setPost($item, $payload['@attributes']['from']); |
|||
elseif($xmlns == 'urn:xmpp:microblog:0:comments') |
|||
$post->setPost($item, $payload['@attributes']['from'], $parent); |
|||
|
|||
$sdb->save($post); |
|||
|
|||
// And we run the correct event
|
|||
if($xmlns == 'urn:xmpp:microblog:0') { |
|||
$evt->runEvent('post', $item['@attributes']['id']); |
|||
$evt->runEvent('stream', $payload); |
|||
} elseif($xmlns == 'urn:xmpp:microblog:0:comments') |
|||
$evt->runEvent('comment', $parent); |
|||
} |
|||
} |
|||
} elseif(isset($payload['pubsub']['publish']['@attributes']['node'])) { |
|||
list($xmlns, $id) = explode("/", $payload['pubsub']['publish']['@attributes']['node']); |
|||
if($payload['pubsub']['publish']['@attributes']['node'] == 'urn:xmpp:microblog:0') { |
|||
$this->getWallItem($this->getCleanJid(), $payload['pubsub']['publish']['item']['@attributes']['id']); |
|||
} |
|||
$this->getComments($payload['@attributes']['from'], $id); |
|||
} else { |
|||
$evt->runEvent('nocomment', $parent); |
|||
if($xmlns == 'urn:xmpp:microblog:0') |
|||
$evt->runEvent('nostream', $parent); |
|||
} |
|||
} |
|||
elseif(isset($payload['pubsub']) && isset($payload['error'])) { |
|||
list($xmlns, $parent) = explode("/", $payload['pubsub']['items']['@attributes']['node']); |
|||
if(isset($payload['error']['item-not-found'])) { |
|||
if($xmlns == 'urn:xmpp:microblog:0:comments') |
|||
$evt->runEvent('nocommentstream', $parent); |
|||
else |
|||
$evt->runEvent('nostream', $parent); |
|||
} |
|||
elseif(in_array( $payload['error']['@attributes']['code'], array(501, 503)) && |
|||
$payload['pubsub']['create']['@attributes']['node'] == 'urn:xmpp:microblog:0') { |
|||
$conf = new ConfVar(); |
|||
$sdb->load($conf, array( |
|||
'login' => $this->getCleanJid() |
|||
)); |
|||
$conf->set('first', 3); |
|||
$sdb->save($conf); |
|||
} |
|||
elseif(isset($payload['error']['feature-not-implemented']) || |
|||
isset($payload['error']['not-authorized']) || |
|||
isset($payload['error']['service-unavailable']) || |
|||
isset($payload['error']['item-not-found'])) { |
|||
$evt->runEvent('nostream'); |
|||
} |
|||
} |
|||
elseif(isset($payload['error'])) { |
|||
$evt->runEvent('nostream'); |
|||
} |
|||
|
|||
else { |
|||
$evt->runEvent('none', var_export($payload, true)); |
|||
} |
|||
|
|||
$evt->runEvent('incomingemptybody', 'ping'); |
|||
} |
|||
|
|||
/** |
|||
* Message handler |
|||
* |
|||
* @param array $payloads |
|||
* @return void |
|||
*/ |
|||
public function getMessage($payloads) { |
|||
$evt = new Event(); |
|||
|
|||
foreach($payloads as $payload) { |
|||
|
|||
if($payload['offline'] != JAXL0203::$ns && $payload['type'] == 'chat') { // reject offline message
|
|||
|
|||
if($payload['chatState'] == 'active' && $payload['body'] == NULL) |
|||
$evt->runEvent('incomeactive', $payload); |
|||
elseif($payload['chatState'] == 'composing') |
|||
$evt->runEvent('composing', $payload); |
|||
elseif($payload['chatState'] == 'paused') |
|||
$evt->runEvent('paused', $payload); |
|||
|
|||
else { |
|||
global $sdb; |
|||
$m = new Message(); |
|||
$m->setMessageChat($payload['movim']); |
|||
$sdb->save($m); |
|||
|
|||
$evt->runEvent('message', $m); |
|||
} |
|||
} elseif($payload['movim']['event']['items']['@attributes']['node'] == 'urn:xmpp:microblog:0') { |
|||
$payload = $payload['movim']; |
|||
|
|||
if(isset($payload['event']['items']['item'])) { |
|||
global $sdb; |
|||
$c = new PostHandler(); |
|||
$post = $c->get($this->getCleanJid(), $payload['event']['items']['item']['@attributes']['id']); |
|||
if($post->getData('nodeid') == $payload['event']['items']['item']['@attributes']['id']) |
|||
$new = true; |
|||
$post->setPost($payload['event']['items']['item'], $payload['@attributes']['from'], false, $this->getCleanJid()); |
|||
$sdb->save($post); |
|||
} |
|||
|
|||
if($new == false) { |
|||
$sess = Session::start(APP_NAME); |
|||
if($sess->get('currentcontact') == $payload['@attributes']['from']) { |
|||
$evt->runEvent('currentpost', $payload); |
|||
} |
|||
|
|||
if($payload['@attributes']['from'] != $this->getCleanJid()) |
|||
$evt->runEvent('post', $payload['event']['items']['item']['@attributes']['id']); |
|||
} |
|||
} |
|||
} |
|||
|
|||
$evt->runEvent('incomingemptybody', 'ping'); |
|||
} |
|||
|
|||
/** |
|||
* Presence handler |
|||
* |
|||
* @param array $payloads |
|||
* @return void |
|||
*/ |
|||
public function getPresence($payloads) { |
|||
global $sdb; |
|||
$evt = new Event(); |
|||
|
|||
foreach($payloads as $payload) { |
|||
|
|||
$payload = $payload['movim']; |
|||
if($payload['@attributes']['type'] == 'subscribe') { |
|||
$evt->runEvent('subscribe', $payload); |
|||
} |
|||
else { |
|||
|
|||
// We update the presences
|
|||
list($jid, $ressource) = explode('/',$payload['@attributes']['from']); |
|||
|
|||
// We ask for the entity-capabilities and we prevent to ask our own capabilities
|
|||
if(isset($payload['c']) && $jid != $this->getCleanJid()) { |
|||
$c = new CapsHandler(); |
|||
$caps = $c->get($payload['c']['@attributes']['node'].'#'.$payload['c']['@attributes']['ver']); |
|||
|
|||
// We ask for the caps only if we haven't found it in the database
|
|||
if($caps->getData('category') == null) { |
|||
$this->jaxl->JAXL0030( |
|||
'discoInfo', |
|||
$payload['@attributes']['from'], |
|||
$this->getCleanJid(), |
|||
false, |
|||
$payload['c']['@attributes']['node'].'#'.$payload['c']['@attributes']['ver'] |
|||
); |
|||
} |
|||
} |
|||
|
|||
$presence = $sdb->select('Presence', array( |
|||
'key' => $this->getCleanJid(), |
|||
'jid' => $jid, |
|||
'ressource' => $ressource |
|||
)); |
|||
if($presence == false) { |
|||
$presence = new Presence(); |
|||
$presence->setPresence($payload); |
|||
$sdb->save($presence); |
|||
} else { |
|||
$presence = new Presence(); |
|||
$sdb->load($presence, array( |
|||
'key' => $this->getCleanJid(), |
|||
'jid' => $jid, |
|||
'ressource' => $ressource |
|||
)); |
|||
$presence->setPresence($payload); |
|||
$sdb->save($presence); |
|||
} |
|||
|
|||
if($payload['@attributes']['from'] == $payload['@attributes']['to']) |
|||
$evt->runEvent('mypresence', $presence); |
|||
|
|||
$evt->runEvent('presence', $presence); |
|||
} |
|||
} |
|||
|
|||
$evt->runEvent('incomingemptybody', 'ping'); |
|||
} |
|||
|
|||
/** |
|||
* Ask for a vCard |
|||
* |
|||
* @param string $jid = false |
|||
* @return void |
|||
*/ |
|||
public function getVCard($jid = false) |
|||
{ |
|||
$this->jaxl->JAXL0054('getVCard', $jid, $this->jaxl->jid, false); |
|||
} |
|||
|
|||
/** |
|||
* sendVcard |
|||
* |
|||
* @param array $vcard |
|||
* @return void |
|||
*/ |
|||
public function updateVcard($vcard) |
|||
{ |
|||
$this->jaxl->JAXL0054('updateVCard', $vcard); |
|||
$this->jaxl->JAXL0054('getVCard', false, $this->jaxl->jid, false); |
|||
} |
|||
|
|||
/** |
|||
* Create personnal microblog node |
|||
* |
|||
* @return void |
|||
*/ |
|||
|
|||
public function createNode() |
|||
{ |
|||
$this->jaxl->JAXL0277('createNode', $this->getCleanJid()); |
|||
} |
|||
|
|||
/** |
|||
* Subscribe to a node |
|||
* |
|||
* @param unknown $jid = false |
|||
* @return void |
|||
*/ |
|||
|
|||
public function subscribeNode($jid) |
|||
{ |
|||
$this->jaxl->JAXL0277('subscribeNode', $this->getCleanJid(), $jid); |
|||
} |
|||
|
|||
/** |
|||
* Ask for some items |
|||
* |
|||
* @param unknown $jid = false |
|||
* @return void |
|||
*/ |
|||
public function getWall($jid = false) { |
|||
$this->jaxl->JAXL0277('getItems', $jid); |
|||
} |
|||
|
|||
/** |
|||
* Ask for an item |
|||
* |
|||
* @param unknown $jid = false |
|||
* @return void |
|||
*/ |
|||
public function getWallItem($jid = false, $id) { |
|||
$this->jaxl->JAXL0277('getItem', $jid, $id); |
|||
} |
|||
|
|||
/** |
|||
* Ask for some comments of an article |
|||
* |
|||
* @param string $jid |
|||
* @param string $id |
|||
* @return void |
|||
*/ |
|||
public function getComments($place, $id) { |
|||
$this->jaxl->JAXL0277('getComments', $place, $id); |
|||
} |
|||
|
|||
/** |
|||
* Service Discovery |
|||
* |
|||
* @param string $jid = false |
|||
* @return void |
|||
*/ |
|||
public function discover($jid = false) |
|||
{ |
|||
$this->jaxl->JAXL0277('getItems', 'edhelas@jappix.com'); |
|||
} |
|||
|
|||
public function discoNodes($pod) |
|||
{ |
|||
$this->jaxl->JAXL0060('discoNodes', $pod, $this->jaxl->jid); |
|||
} |
|||
|
|||
/** |
|||
* Get some items about a node |
|||
* |
|||
* @param string $pod |
|||
* @param string $node |
|||
* @return void |
|||
*/ |
|||
public function discoItems($pod, $node) |
|||
{ |
|||
$this->jaxl->JAXL0060('getNodeItems', $pod, $this->jaxl->jid, $node); |
|||
} |
|||
|
|||
/** |
|||
* Publish an item on microblog feed |
|||
* |
|||
* @param string $content |
|||
* @return void |
|||
*/ |
|||
public function publishItem($content) |
|||
{ |
|||
$id = md5(openssl_random_pseudo_bytes(5)); |
|||
$this->jaxl->JAXL0277('createCommentNode', $this->getCleanJid() ,$id); |
|||
$this->jaxl->JAXL0277('publishItem', $this->getCleanJid() ,$content, false, false, $id); |
|||
} |
|||
|
|||
/** |
|||
* Publish a comment on a microblog item |
|||
* |
|||
* @param string $content |
|||
* @return void |
|||
*/ |
|||
public function publishComment($place, $id, $content) |
|||
{ |
|||
$this->jaxl->JAXL0277('publishComment', $place, $id ,$content, $this->getCleanJid()); |
|||
} |
|||
|
|||
/** |
|||
* Ask for the roster |
|||
* |
|||
* @return void |
|||
*/ |
|||
public function getRosterList() |
|||
{ |
|||
$this->jaxl->getRosterList(); |
|||
} |
|||
|
|||
/** |
|||
* Set a new status |
|||
* |
|||
* @param string $status |
|||
* @param string $show |
|||
* @return void |
|||
*/ |
|||
public function setStatus($status, $show) |
|||
{ |
|||
$this->jaxl->setStatus($status, $show, 41, false); |
|||
} |
|||
|
|||
/** |
|||
* Send a message |
|||
* |
|||
* @param string $addressee |
|||
* @param steirng $body |
|||
* @return void |
|||
*/ |
|||
public function sendMessage($addressee, $body) |
|||
{ |
|||
// Checking on the jid.
|
|||
if(checkJid($addressee)) { |
|||
$this->jaxl->sendMessage($addressee, $body, false, 'chat'); |
|||
} else { |
|||
throw new MovimException("Incorrect JID `$addressee'"); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Subscribe to a contact request |
|||
* |
|||
* @param unknown $jid |
|||
* @return void |
|||
*/ |
|||
public function subscribedContact($jid) { |
|||
if(checkJid($jid)) { |
|||
$this->jaxl->subscribed($jid); |
|||
$this->jaxl->addRoster($jid); |
|||
} else { |
|||
throw new MovimException("Incorrect JID `$jid'"); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Accecpt a new contact |
|||
* |
|||
* @param string $jid |
|||
* @param string $group |
|||
* @param string $alias |
|||
* @return void |
|||
*/ |
|||
public function acceptContact($jid, $group, $alias) |
|||
{ |
|||
if(checkJid($jid)) { |
|||
$this->jaxl->addRoster($jid, $group, $alias); |
|||
$this->jaxl->subscribe($jid); |
|||
} else { |
|||
throw new MovimException("Incorrect JID `$jid'"); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Add a new contact |
|||
* |
|||
* @param string $jid |
|||
* @param string $grJaxloup |
|||
* @param string $alias |
|||
* @return void |
|||
*/ |
|||
public function addContact($jid, $group, $alias) { |
|||
if(checkJid($jid)) { |
|||
$this->jaxl->subscribe($jid); |
|||
} else { |
|||
throw new MovimException("Incorrect JID `$jid'"); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Remove a contact |
|||
* |
|||
* @param string $jid |
|||
* @return void |
|||
*/ |
|||
public function removeContact($jid) { |
|||
if(checkJid($jid)) { |
|||
$this->jaxl->deleteRoster($jid); |
|||
$this->jaxl->unsubscribe($jid); |
|||
} else { |
|||
throw new MovimException("Incorrect JID `$jid'"); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Unsubscribe to a contact |
|||
* |
|||
* @param unknown $jid |
|||
* @return void |
|||
*/ |
|||
public function unsubscribed($jid) { |
|||
$this->jaxl->unsubscribed($jid); |
|||
} |
|||
|
|||
} |
|||
|
|||
?>
|
|||
@ -0,0 +1,55 @@ |
|||
<?php |
|||
|
|||
class Explore extends WidgetCommon { |
|||
function WidgetLoad() |
|||
{ |
|||
$this->addcss('explore.css'); |
|||
} |
|||
|
|||
function build() |
|||
{ |
|||
$users_limit = 20; |
|||
|
|||
$gender = getGender(); |
|||
$marital = getMarital(); |
|||
|
|||
$query = Contact::query()->select() |
|||
->where(array( |
|||
'public' => 1)) |
|||
->limit(0, $users_limit); |
|||
$users = Contact::run_query($query); |
|||
|
|||
/*$users_number = sizeof($users); |
|||
|
|||
if($users_number < $users_limit) { |
|||
$users_fill = array(); |
|||
for($i = 0; $i<$users_limit-$users_number; $i++) |
|||
array_push($users_fill, new Contact()); |
|||
|
|||
$users = array_merge($users, $users_fill); |
|||
}*/ |
|||
|
|||
shuffle($users); |
|||
?>
|
|||
<div id="explore"> |
|||
<?php |
|||
foreach($users as $user) { |
|||
echo ' |
|||
<a href="?q=friend&f='.$user->getData('jid').'"> |
|||
<div class="contactbox"> |
|||
<img class="avatar" src="'.$user->getPhoto('m').'"/> |
|||
<div class="desc">'.prepareString($user->getData('desc')).'</div> |
|||
<span class="name">'.$user->getTrueName().'</span> |
|||
<span class="asv">'. |
|||
$user->getAge().' '. |
|||
$gender[$user->getData('gender')].'<br />'. |
|||
$marital[$user->getData('marital')].' |
|||
</span> |
|||
</div> |
|||
</a>'; |
|||
} |
|||
?>
|
|||
</div> |
|||
<?php |
|||
} |
|||
} |
|||
@ -0,0 +1,44 @@ |
|||
#explore { |
|||
padding: 1.5em; |
|||
padding-top: 0px; |
|||
margin-bottom: 2em; |
|||
} |
|||
|
|||
.contactbox { |
|||
height: 50px; |
|||
padding: 1.5em 0px; |
|||
border-bottom: 1px solid #DDD; |
|||
} |
|||
|
|||
.contactbox:hover { |
|||
background-color: #F9F9F9; |
|||
} |
|||
|
|||
.contactbox img.avatar { |
|||
height: 50px; |
|||
width: 50px; |
|||
float: left; |
|||
margin-right: 10px; |
|||
border-radius: 4px; |
|||
} |
|||
|
|||
.contactbox .name { |
|||
font-weight: bold; |
|||
display: block; |
|||
text-overflow: ellipsis; |
|||
max-width: 30%; |
|||
white-space: nowrap; |
|||
} |
|||
|
|||
.contactbox .asv { |
|||
color: #888; |
|||
} |
|||
|
|||
.contactbox .desc { |
|||
width: 50%; |
|||
height: 100%; |
|||
float: right; |
|||
overflow: hidden; |
|||
text-overflow: ellipsis; |
|||
white-space: pre-wrap; |
|||
} |
|||
@ -0,0 +1,25 @@ |
|||
<?php /* -*- mode: html -*- */ |
|||
?> |
|||
<?php $this->widget('Poller');?> |
|||
<?php $this->widget('Logout');?> |
|||
<?php $this->widget('Chat');?> |
|||
|
|||
<div id="head"> |
|||
<?php $this->widget('Profile');?> |
|||
</div> |
|||
|
|||
<div id="main"> |
|||
<div id="left"> |
|||
<?php $this->widget('ProfileData');?> |
|||
</div> |
|||
<div id="center" class="protect black"> |
|||
<h1><?php echo t('Explore'); ?></h1> |
|||
<?php $this->widget('Explore');?> |
|||
</div> |
|||
</div> |
|||
|
|||
<div id="right"> |
|||
<?php $this->widget('Notifs');?> |
|||
<?php $this->widget('Roster');?> |
|||
</div> |
|||
|
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue