var express = require('express'),
    wrap = require('../index'),
    should = require('should'),
    request = require('supertest');

function asyncText(err, text, cb) {
  setImmediate(function() {
    cb(err, text);
  });
}

function thunk(err, text) {
  return function(cb) {
    asyncText(err, text, cb);
  };
}

describe('co-express', function() {
  it('supports a single generator route', function(done) {
    var app = express();

    app.get('/', wrap(function* (req, res, next) {
      res.send('it works!');
    }));

    request(app)
      .get('/')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('it works!');
        done();
      });
  });

  it('supports multiple generator routes', function(done) {
    var app = express();

    app.get('/', wrap(function* (req, res, next) {
      req.val = yield thunk(null, 'thunk');
      next();
    }), wrap(function* (req, res, next) {
      req.val += yield thunk(null, 'thunk');
      next();
    }), wrap(function* (req, res) {
      res.send(req.val + 'func');
    }));

    request(app)
      .get('/')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('thunkthunkfunc');
        done();
      });
  });

  it('doesn\'t alter application object', function(done) {
    var app = express();

    app.get('/', wrap(function* (req, res, next) {
      res.send('it works!');
    }));

    app.set('it', 'works!');

    request(app)
      .get('/')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('it works!');
        app.get('it').should.equal('works!');
        done();
      });
  });


  it('supports param', function(done) {
    var app = express();
    const map = {
      33: 'user number 33'
    };
    app.param('id', wrap(function* (req, res, next, id) {
      id.should.equal('33');
      req.user = map[id];
      next();
    }));
    app.get('/:id', wrap(function* (req, res, next) {
      res.send(req.user);
    }));

    request(app)
      .get('/33')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('user number 33');
        done();
      });
  });

  it('supports param and catches errors thrown in generator', function(done) {
    var app = express();
    const map = {
      33: 'user number 33'
    };
    app.param('id', wrap(function* (req, res, next, id) {
      id.should.equal('33');
      req.user = map[id];
      throw new Error('param test error');
    }));
    app.get('/:id', wrap(function* (req, res, next) {
      res.send(req.user);
    }));
    app.use(wrap(function* (err, req, res, next) {
      err.message.should.equal('param test error');
      if (err) {
          res.status(500).send(err.message);
      }
    }));

    request(app)
      .get('/33')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('param test error');
        done();
      });
  });

  it('supports param and catches errors called with next', function(done) {
    var app = express();
    const map = {
      33: 'user number 33'
    };
    app.param('id', wrap(function* (req, res, next, id) {
      id.should.equal('33');
      req.user = map[id];
      next(new Error('param test error'));
    }));
    app.get('/:id', wrap(function* (req, res, next) {
      res.send(req.user);
    }));
    app.use(wrap(function* (err, req, res, next) {
      err.message.should.equal('param test error');
      if (err) {
          res.status(500).send(err.message);
      }
    }));

    request(app)
      .get('/33')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('param test error');
        done();
      });
  });

  it('passes uncaught exceptions', function(done) {
    var app = express();

    app.get('/', wrap(function* (req, res, next) {
      var val = yield thunk(new Error('thunk error'));
      res.send(val);
    }));

    app.use(function(err, req, res, next) {
      if (err && err.message === 'thunk error') {
        res.send('caught');
      } else {
        next(err);
      }
    });

    request(app)
      .get('/')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('caught');
        done();
      });
  });

  it('supports error routes', function(done) {
    var app = express();

    app.get('/', wrap(function* (req, res, next) {
      var val = yield thunk(new Error('thunk error'));
      res.send(val);
    }));

    app.use(wrap(function* (err, req, res, next) {
      if (err && err.message === 'thunk error') {
        res.send('caught');
      } else {
        next(err);
      }
    }));

    request(app)
      .get('/')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('caught');
        done();
      });
  });

  it('supports app.route()', function(done) {
    var app = express();

    var books = app.route('/books');

    books.get(wrap(function* (req, res, next) {
      req.val = yield thunk(null, 'thunk');
      next();
    }), wrap(function* (req, res, next) {
      req.val += yield thunk(null, 'thunk');
      next();
    }), wrap(function* (req, res) {
      res.send(req.val + 'func');
    }));


    request(app)
      .get('/books')
      .end(function(err, res) {
        should.not.exist(err);
        res.text.should.equal('thunkthunkfunc');
        done();
      });
  });
});