summaryrefslogtreecommitdiffstats
path: root/modules
diff options
context:
space:
mode:
Diffstat (limited to 'modules')
-rw-r--r--modules/roboctl/index.js162
-rw-r--r--modules/roboctl/lib/irc.js67
2 files changed, 229 insertions, 0 deletions
diff --git a/modules/roboctl/index.js b/modules/roboctl/index.js
new file mode 100644
index 00000000..b9e67a19
--- /dev/null
+++ b/modules/roboctl/index.js
@@ -0,0 +1,162 @@
+
+var connect = require('genericore').connect;
+
+var config = {
+ irc: {}
+};
+
+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);
+// }
+// });
+// }
+// });
+
+// 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);
+ });
+ });
+});
+
+// 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);
+// });
diff --git a/modules/roboctl/lib/irc.js b/modules/roboctl/lib/irc.js
new file mode 100644
index 00000000..5f904a74
--- /dev/null
+++ b/modules/roboctl/lib/irc.js
@@ -0,0 +1,67 @@
+
+var Client = function (config) {
+ var client = this;
+ var net = require('net');
+ var sys = require('sys');
+ var log = function (x) {
+ sys.puts('TCP server: ' + x);
+ };
+
+ client.connect = function (callback) {
+ var stream = net.createConnection(config.port, config.server);
+ stream.on('connect', function () {
+ stream.write(
+ 'NICK ' + config.nick + '\n' +
+ 'USER ' + config.nick + ' 0 *:Karl Koch\n' +
+ 'JOIN ' + config.channel + '\n'
+ );
+ //client.write = function (text) {
+ // stream.write('PRIVMSG ' + config.channel + ' :' + text);
+ //};
+ client.write = msg_start_send;
+ callback();
+ });
+ //stream.on('secure', function () {
+ //});
+
+ var msg = [];
+
+ var msg_start_send = function (x) {
+ client.write = msg_append;
+ setTimeout(function () {
+ var x = msg.join('\n') + '\n';
+ msg = [];
+ client.write = msg_start_send;
+ stream.write('PRIVMSG ' + config.channel + ' :' + x);
+ }, 1000);
+ };
+
+ var msg_append = function (x) {
+ msg[msg.length] = x;
+ };
+
+
+ stream.on('data', function (data) {
+ data = String(data);
+ log('' + data + '');
+ if (data.substring(0,4) === 'PING') {
+ log('PONG!');
+ stream.write('PONG ' + data.substring(4));
+ }
+ });
+ //stream.on('end', function () {
+ //});
+ //stream.on('timeout', function () {
+ //});
+ //stream.on('drain', function () {
+ //});
+ //stream.on('error', function (exception) {
+ //});
+ //stream.on('clonse', function (exception) {
+ //});
+ };
+};
+
+exports.createClient = function (config) {
+ return new Client(config);
+};