YUKI Hiroshi
null+****@clear*****
Thu Oct 17 12:36:03 JST 2013
YUKI Hiroshi 2013-10-17 12:36:03 +0900 (Thu, 17 Oct 2013) New Revision: 52c0cb469f1a38f9bd43a149e320c04733d7a7c5 https://github.com/droonga/express-droonga/commit/52c0cb469f1a38f9bd43a149e320c04733d7a7c5 Message: Define "sha1sum()" as a utility method of droonga.command Modified files: lib/adapter/api/socket.io.js lib/adapter/command.js Modified: lib/adapter/api/socket.io.js (+2 -8) =================================================================== --- lib/adapter/api/socket.io.js 2013-10-16 19:12:30 +0900 (093bda0) +++ lib/adapter/api/socket.io.js 2013-10-17 12:36:03 +0900 (62b3f3f) @@ -1,12 +1,6 @@ var command = require('../command'); var crypto = require('crypto'); -function sha1sum(source) { - var hash = crypto.createHash('sha1'); - hash = hash.update(source); - return hash.digest('hex'); -} - module.exports = { // 'status': {}, @@ -14,7 +8,7 @@ module.exports = { 'watch': new command.SocketPublishSubscribe({ onSubscribe: function(data, connection) { - data.subscriber = /* data.subscriber || */ sha1sum(connection.routeToSelf); + data.subscriber = /* data.subscriber || */ command.sha1sum(connection.routeToSelf); data.route = /* data.route || */ connection.routeToSelf; connection.emit('watch.subscribe', data); }, @@ -22,7 +16,7 @@ module.exports = { socket.emit('watch.subscribe.response', data); }, onUnsubscribe: function(data, connection) { - data.subscriber = /* data.subscriber || */ sha1sum(connection.routeToSelf); + data.subscriber = /* data.subscriber || */ command.sha1sum(connection.routeToSelf); data.route = /* data.route || */ connection.routeToSelf; connection.emit('watch.unsubscribe', data); }, Modified: lib/adapter/command.js (+8 -0) =================================================================== --- lib/adapter/command.js 2013-10-16 19:12:30 +0900 (30ad665) +++ lib/adapter/command.js 2013-10-17 12:36:03 +0900 (49e11d1) @@ -104,3 +104,11 @@ function SocketPublishSubscribe(options) { util.inherits(SocketPublishSubscribe, PublishSubscribe); SocketRequestResponse.isInstance = PublishSubscribe.isInstance; exports.SocketPublishSubscribe = SocketPublishSubscribe; + + +function sha1sum(source) { + var hash = crypto.createHash('sha1'); + hash = hash.update(source); + return hash.digest('hex'); +} +exports.sha1sub = sha1sum; -------------- next part -------------- HTML����������������������������...Download