diamond_spec.js

var net = require('net');
var sys = require('sys');
var events = require('events');

var Diamond = function(){};
var Async = {}
Async.test_events = new events.EventEmitter();

Async.test = function(before_test_callback,test_callback) {
  before_test_callback.apply(this);
  Async.test_events.addListener("test_connect",
                                function() {                  
                                  test_callback.apply(this) 
                                  asyncSpecDone();
                                  Async.test_events.removeListener('test_connect',arguments.callee);
                                }
                              );
  asyncSpecWait(); 
};

Diamond.prototype.isConnected = false;

Diamond.prototype.connect = function(){
  this.isConnected = true;
};

Diamond.prototype.error = function(e) {
  sys.puts(e);
}; 

Diamond.prototype.start = function(config){
  var self = this;
  this.connection = net.createConnection(config.port,config.host);
  this.connection.addListener('connect',function() {
    self.connect();
    Async.test_events.emit("test_connect"); // trigger testing
  });
  this.connection.addListener('error',self.error);
  return this;
};

var net = require('net');
var server = net.createServer(function (stream) {
  stream.setEncoding('utf8');
  stream.addListener('connect', function () {
    stream.write('hello\r\n');
  });
  stream.addListener('data', function (data) {
    stream.write(data);
  });
  stream.addListener('end', function () {
    stream.write('goodbye\r\n');
    stream.end();
  });
});
server.listen(7000, 'localhost');


describe('diamond', function(){
  it('connects to database', function(){
    config = {
      host:'localhost',
      port:'7000',
    };
    var diamond = new Diamond();
    Async.test(
      function() {
        diamond.start(config);
      },
      function() {
        expect(diamond.isConnected).toEqual(true);
      });
  });
});

specs.js

var kiwi = require('kiwi')
var jasmine = kiwi.require('jazz');
var sys = require('sys');

// this is needed for asyncSpecWait and asyncSpecDone
for(var key in jasmine) {
  global[key] = jasmine[key];
}

jasmine.run(__dirname);

specs.sh

#!/bin/sh
../node/build/default/node specs.js $@

I want to fold away

Async.test_events.emit("test_connect"); // trigger testing

into Async.
Does anyone know a cross-cutting way to do this?
So i can still say - HEY - It's your turn to test your shit now .

Any ideas to

[email protected]