diff options
| -rw-r--r-- | modules/roboctl/index.js | 162 |
1 files changed, 7 insertions, 155 deletions
diff --git a/modules/roboctl/index.js b/modules/roboctl/index.js index b9e67a19..bef53109 100644 --- a/modules/roboctl/index.js +++ b/modules/roboctl/index.js @@ -1,162 +1,14 @@ - -var connect = require('genericore').connect; - var config = { - irc: {} + "nick": "roboctl", + "server": "irc.freenode.net", + "port": 6667, + "channel": "#tincspasm" }; -connect(config.irc, { - debug: function (message) { - }, - ready: function (client) { - - } -}); - - - -// { -// userName: 'nodebot', -// realName: 'nodeJS IRC client', -// port: 6667, -// debug: false, -// showErrors: false, -// autoRejoin: true, -// channels: [], -// secure: false -// } - -var config = { - "irc": { - "nick": "a43243afds", - "server": "irc.freenode.net", - "port": 6667, - "channel": "#genericoredump" - }, - "amqp": { - "reconnect_timeout": 10000, - "connection": { - "host": "141.31.8.11", - "port": 5672, - "login": "shack", - "password": "shackit", - "vhost": "/" - }, - "exchange": { - "name": "log", - "options": { - "type": "fanout", - "passive": false, - "durable": false, - "auto_delete": false, - "internal": false, - "nowait": false - } - }, - "queue": { - "name": "irclog2", - "options": { - "passive": false, - "durable": false, - "exclusive": false, - "autoDelete": false, - "nowait": false - } - } - } -}; - -//var irc = require('./lib/irc'); -var irc = require('./lib/irc').createClient(config.irc); -var amqp = require('amqp'); - -// TODO var amqp = require('./lib/amqp').createClient(config.amqp); -// where createClient will bind to all connected (exchange,queue) pairs -// irc.connect({ -// ready: function () { -// amqp.connect({ -// message: function (message) { -// console.log(message); -// irc.privmsg(config.irc.channel, message.data); -// } -// }); -// } -// }); +irc = require('./lib/irc').createClient(config); // TODO call back when joined irc.connect(function () { - var connection = amqp.createConnection(config.amqp.connection); - connection.on('ready', function () { - var queue = connection.queue(config.amqp.queue.name, config.amqp.queue.options); - - queue.bind(config.amqp.exchange.name, config.amqp.queue.name); - - console.log('receiving messages'); - queue.subscribe(function (message) { - console.log(message.data); - irc.write(message.data); - }); - }); + console.log('like a boss'); + //irc.write(); }); - -// amqp.connect(function () { -// amqp.connection.exchange("log", config.amqp.exchange.options).on( -// 'open', function () { -// log = function (message) { -// exchange.publish(config.amqp.exchange.name, message); -// }; -// } -// ); -// -// tcp.serve(function (message) { -// var data = parse(message); -// log('[mailsrc,tcp] incoming: ' + data['Header-Fields']['Subject']); -// console.log('publishing: ' + data['Header-Fields'].From); -// amqp.publish({ type: 'mail', subtype: 0, data: data }); -// }); -// }); -// -// -// var client = new irc.Client(config.server, config.nick, { -// channels: [config.channel], -// }); -// -// client.on('error', function (err) { -// console.log('>>>\n' + require('sys').inspect(err)); -// }); -// -// -// var amqp = require('amqp'); -// client.join(config.channel, function () { -// -// var connection = amqp.createConnection(config.amqp.connection); -// -// // Wait for connection to become established. -// connection.on('ready', function () { -// // Create a queue and bind to all messages. -// // Use the default 'amq.topic' exchange -// var q = connection.queue(config.amqp.queue.name, config.amqp.queue); -// // Catch all messages -// q.bind(config.amqp.exchange.name, config.amqp.queue.name); -// -// // Receive messages -// console.log('receiving messages'); -// q.subscribe(function (message) { -// // Print messages to stdout -// console.log(message); -// client.say(config.channel, message.data); -// }); -// }); -// }); - - - - - -// client.on('pm', function (from, message) { -// sys.puts(from + ' => ME: ' + message); -// }); -// -// client.on('message#yourchannel', function (from, message) { -// sys.puts(from + ' => #yourchannel: ' + message); -// }); |