6c47537f47
Closes #128 Includes testcase, which required enhancing assert.response to handle errors. Changes app controller to a function that only reads configuration when executed (rather than when only require'd).
107 lines
3.4 KiB
JavaScript
107 lines
3.4 KiB
JavaScript
require('../helper');
|
|
require('../support/assert');
|
|
|
|
var app = require(global.settings.app_root + '/app/controllers/app')()
|
|
, assert = require('assert')
|
|
, querystring = require('querystring')
|
|
, _ = require('underscore')
|
|
;
|
|
|
|
// allow lots of emitters to be set to silence warning
|
|
app.setMaxListeners(0);
|
|
|
|
suite('x_cache_channel', function() {
|
|
|
|
assert.contains = function(ary, elem) {
|
|
assert.ok(_.contains(ary,elem), 'missing "' + elem +'" from x-cache-channel: '+ ary);
|
|
};
|
|
|
|
test('supports joins', function(done) {
|
|
var query = querystring.stringify({
|
|
q: "SELECT a.name as an, b.name as bn FROM untitle_table_4 a left join private_table b ON (a.cartodb_id = b.cartodb_id)",
|
|
api_key: 1234
|
|
});
|
|
assert.response(app, {
|
|
url: '/api/v1/sql?' + query,
|
|
headers: {host: 'vizzuality.cartodb.com' },
|
|
method: 'GET'
|
|
},{ }, function(res) {
|
|
assert.equal(res.statusCode, 200, res.body);
|
|
// Check x-cache headers
|
|
var cc = res.headers['x-cache-channel'].split(':');
|
|
assert.equal(cc[0], 'cartodb_test_user_1_db');
|
|
var tt = cc[1].split(',');
|
|
assert.equal(tt.length, 2);
|
|
assert.contains(tt, 'private_table');
|
|
assert.contains(tt, 'untitle_table_4');
|
|
done();
|
|
});
|
|
});
|
|
|
|
test('supports multistatements', function(done) {
|
|
var query = querystring.stringify({
|
|
q: "SELECT * FROM untitle_table_4; SELECT * FROM private_table",
|
|
api_key: 1234
|
|
});
|
|
assert.response(app, {
|
|
url: '/api/v1/sql?' + query,
|
|
headers: {host: 'vizzuality.cartodb.com' },
|
|
method: 'GET'
|
|
},{ }, function(res) {
|
|
assert.equal(res.statusCode, 200, res.body);
|
|
// Check x-cache headers
|
|
var cc = res.headers['x-cache-channel'].split(':');
|
|
assert.equal(cc[0], 'cartodb_test_user_1_db');
|
|
var tt = cc[1].split(',');
|
|
assert.equal(tt.length, 2);
|
|
assert.contains(tt, 'private_table');
|
|
assert.contains(tt, 'untitle_table_4');
|
|
done();
|
|
});
|
|
});
|
|
|
|
test('supports explicit transactions', function(done) {
|
|
var query = querystring.stringify({
|
|
q: "BEGIN; SELECT * FROM untitle_table_4; COMMIT; BEGIN; SELECT * FROM private_table; COMMIT;",
|
|
api_key: 1234
|
|
});
|
|
assert.response(app, {
|
|
url: '/api/v1/sql?' + query,
|
|
headers: {host: 'vizzuality.cartodb.com' },
|
|
method: 'GET'
|
|
},{ }, function(res) {
|
|
assert.equal(res.statusCode, 200, res.body);
|
|
// Check x-cache headers
|
|
var cc = res.headers['x-cache-channel'].split(':');
|
|
assert.equal(cc[0], 'cartodb_test_user_1_db');
|
|
var tt = cc[1].split(',');
|
|
assert.equal(tt.length, 2);
|
|
assert.contains(tt, 'private_table');
|
|
assert.contains(tt, 'untitle_table_4');
|
|
done();
|
|
});
|
|
});
|
|
|
|
test('survives partial transactions', function(done) {
|
|
var query = querystring.stringify({
|
|
q: "BEGIN; SELECT * FROM untitle_table_4",
|
|
api_key: 1234
|
|
});
|
|
assert.response(app, {
|
|
url: '/api/v1/sql?' + query,
|
|
headers: {host: 'vizzuality.cartodb.com' },
|
|
method: 'GET'
|
|
},{ }, function(res) {
|
|
assert.equal(res.statusCode, 200, res.body);
|
|
// Check x-cache headers
|
|
var cc = res.headers['x-cache-channel'].split(':');
|
|
assert.equal(cc[0], 'cartodb_test_user_1_db');
|
|
var tt = cc[1].split(',');
|
|
assert.equal(tt.length, 1);
|
|
assert.contains(tt, 'untitle_table_4');
|
|
done();
|
|
});
|
|
});
|
|
|
|
});
|