Added realtime streams for all and showstream timelines
This commit is contained in:
parent
44820d296d
commit
49e91ec7d0
@ -7,8 +7,17 @@ var MeteorUpdater = function()
|
|||||||
|
|
||||||
init: function(server, port, timeline)
|
init: function(server, port, timeline)
|
||||||
{
|
{
|
||||||
|
var screen_name;
|
||||||
|
|
||||||
Meteor.callbacks["process"] = function(data) {
|
Meteor.callbacks["process"] = function(data) {
|
||||||
RealtimeUpdate.receive(JSON.parse(data));
|
var d = JSON.parse(data);
|
||||||
|
screen_name = d['user']['screen_name'];
|
||||||
|
|
||||||
|
if (timeline == 'public' ||
|
||||||
|
$('address .url')[0].href+screen_name+'/all' == window.location.href ||
|
||||||
|
$('address .url')[0].href+screen_name == window.location.href) {
|
||||||
|
RealtimeUpdate.receive(d);
|
||||||
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
Meteor.host = server;
|
Meteor.host = server;
|
||||||
|
@ -63,9 +63,11 @@ class RealtimePlugin extends Plugin
|
|||||||
{
|
{
|
||||||
$path = null;
|
$path = null;
|
||||||
|
|
||||||
switch ($action->trimmed('action')) {
|
$a = $action->trimmed('action');
|
||||||
case 'public':
|
|
||||||
$path = array('public');
|
switch ($a) {
|
||||||
|
case 'public': case 'all': case 'replies': case 'showstream':
|
||||||
|
$path = array($a);
|
||||||
break;
|
break;
|
||||||
case 'tag':
|
case 'tag':
|
||||||
$tag = $action->trimmed('tag');
|
$tag = $action->trimmed('tag');
|
||||||
@ -108,11 +110,13 @@ class RealtimePlugin extends Plugin
|
|||||||
{
|
{
|
||||||
$paths = array();
|
$paths = array();
|
||||||
|
|
||||||
// XXX: Add other timelines; this is just for the public one
|
// TODO: Replies timeline
|
||||||
|
|
||||||
if ($notice->is_local ||
|
if ($notice->is_local ||
|
||||||
($notice->is_local == 0 && !common_config('public', 'localonly'))) {
|
($notice->is_local == 0 && !common_config('public', 'localonly'))) {
|
||||||
$paths[] = array('public');
|
foreach (array('public', 'all', 'replies', 'showstream') as $a) {
|
||||||
|
$paths[] = array($a);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
$tags = $this->getNoticeTags($notice);
|
$tags = $this->getNoticeTags($notice);
|
||||||
|
Loading…
Reference in New Issue
Block a user