Socketstream (0.3) serverseitigen Code Verwirrung

Question

Ich versuche genau zu verstehen, wo/wie ich node.js/Socketstream Server-Code implementieren sollte, die unabhängig von Client-RPC-Aufrufe ausgeführt wird. Als einfaches Beispiel versuche ich so etwas wie dies eine regelmäßige Uhr Update angeschlossenen Clients zu schieben auf der Server-Seite mit:

var pushTime = function() { 
    d = new Date(); 
    ss.publish.all('newServerTime', d); 
    return; 
}; 

setInterval(pushTime, 1000); 

und dem Kunden auf diese veröffentlichen Ereignis abonnieren Einrichtung sorta wie folgt aus:

ss.event.on('newServerTime', function(time) { 
    return $('#serverTime').val(time); 
}); 

Problem: wo stelle ich die serverseitige pushTime-Funktion her? Die Dokumente legen nahe, die/server/rpc Baum so habe ich es in /server/rpc/demo.js aber das ergibt diesen Fehler:

Reference: ss ist nicht

definiert Wohlgemerkt, ich bin nicht setzen der Code im Block export.actions; Ich glaube, das ist nur für Client-RPC-Anrufe.

versuchte ich ss am Anfang der Datei setzen:

ss = require('socketstream'); 

aber das muss doch falsch sein - jetzt die ‚publish.all‘ Methode nicht existiert.

Ich habe versucht, den Code an der Unterseite von app.js, gleich nach dem Aufruf von ss.start. Wieder heißt das, dass die publish.all-Methode nicht existiert (vielleicht erst, wenn ein Client angeschlossen ist?). Ich bin verloren. Jede Hilfe wird geschätzt; hoffe das war klar.

Answer 1

Yup, Sie könnten diesen Code in Ihre Aktionen setzen, nichts, um Sie zu stoppen, aber besser, es in Ihre 'app.js' Datei zu legen.

Um die interne API von app.js zugreifen (derjenige, der bis zum/server/rpc Aktion Dateien gesendet wird) verwenden ss.api

Daher müssen Sie rufen:

ss.api.publish.all() 

aus Ihre 'app.js'-Datei.

Entschuldigung, dies wurde zuvor nicht dokumentiert. Ich werde die Dokumente in Kürze aktualisieren.

Owen

Answer 2

Sie wissen nicht, wenn es um die Coding-Standards erfüllt, aber das funktioniert wahrscheinlich:

/server/rpc/demo.js

exports.actions = function(req, res, ss) { 
    setTimeout(function() { 
     ss.publish.all("newServerTime", new Date()); 
    }, 1000); 
} 

Wenn Sie die Dokumentation zu lesen Ich denke, man kann missbrauchen Aktionen für so ziemlich alles, nicht nur für RPC-Antworten.