get basic connection as a POC. Yay, it works

Author: benjaminws

frame.js

@@ -1,9 +1,55 @@
+var sys = require('sys');
+
 function Frame() {
     this.connected = false;
+    this.sock = '';
+    this.command = '';
+    this.headers = '';
+    this.body = '';
 
-    this.connect = function (sock) {
+    this.stomp_connect = function (sock) {
+        this.sock = sock;
         this.connected = true;
-        console.log('connected');
+        var args = Array();
+        var headers = Array();
+
+        args['command'] = 'CONNECT';
+        args['headers'] = headers;
+        frame_to_send = this.build_frame(args);
+        this.send_frame(frame_to_send);
+        console.log('connected to stomp');
+        return this;
+    };
+
+    this.build_frame = function(args, want_receipt) {
+        this.command = args['command'];
+        this.headers = args['headers'];
+        this.body = args['body'];
+        if (want_receipt) {
+           receipt_stamp = Math.floor(Math.random()*10000000+1);
+            this.headers['receipt'] = "-"
+           console.log(want_receipt);
+        }
+        return this;
+    };
+
+    this.as_string = function() {
+        command = this.command;
+        headers = this.headers;
+        body = this.body;
+        header_strs = Array();
+
+        for (var header in headers) {
+            header_strs.push(header + ':' + headers[header] + '\n');
+        }
+
+        frame = command + '\n' + header_strs.join() + '\n' + body + '\x00';
+
+        return frame;
+    };
+
+    this.send_frame = function(frame) {
+        this.sock.write(frame.as_string());
     };
 };
 

stomp.js

@@ -9,24 +9,36 @@ function Stomp(port, host) {
     this.connect = function() {
         port = this.port;
         host = this.host;
+        frame = this.frame;
+
         console.log('Connecting to ' + host + ':' + port);
-        net.createConnection(function (port, host) {
-            stream.on('connect', function () {
-                console.log('connected');
-                this.frame.connect(stream);
-            });
-            stream.on('data', function (data) {
-                stream.write(data);
-            });
-            stream.on('end', function () {
-                stream.write('goodbye\r\n');
-                stream.end();
-            });
+        client = net.createConnection(port, host);
+        console.dir(client);
+
+        client.addListener('connect', function () {
+            console.log('connected to socket');
+            connected_frame = frame.stomp_connect(client);
+            console.dir(connected_frame);
+        });
+        client.addListener('data', function (data) {
+            console.log("Got: " + data);
+            console.dir(connected_frame);
+        });
+        client.addListener('end', function () {
+            console.log('goodbye');
+        });
+        client.addListener('error', function (error) {
+            console.log(error);
+            console.log("error");
+        });
+        client.addListener('close', function (error) {
+            console.log("disconnected");
         });
     };
 }
 stomp = new Stomp(61613, 'localhost');
+stomp.connect();
 
-console.dir(stomp.connect());
+console.dir(stomp);
 
 module.exports = Stomp;