Switch tests to mocha.

This commit is contained in:
Young Hahn
2013-07-12 04:22:00 -04:00
parent feeb49ac30
commit 4cf1dcc173
8 changed files with 303 additions and 551 deletions
+1 -1
View File
@@ -164,7 +164,7 @@ MBTiles.prototype.getTile = function(z, x, y, callback) {
'zoom_level = ? AND tile_column = ? AND tile_row = ?', 'zoom_level = ? AND tile_column = ? AND tile_row = ?',
z, x, y, z, x, y,
function(err, row) { function(err, row) {
if (!row || (err && err.errno == 1)) { if ((!err && !row) || (err && err.errno == 1)) {
return callback(new Error('Tile does not exist')); return callback(new Error('Tile does not exist'));
} else if (err) { } else if (err) {
return callback(err); return callback(err);
+2 -2
View File
@@ -36,12 +36,12 @@
"sphericalmercator": "~1.0.1" "sphericalmercator": "~1.0.1"
}, },
"devDependencies": { "devDependencies": {
"expresso": "~0.9.0" "mocha": "~1.8.2"
}, },
"engines": { "engines": {
"node": ">= 0.6.0" "node": ">= 0.6.0"
}, },
"scripts": { "scripts": {
"test": "expresso" "test": "mocha"
} }
} }
+65 -87
View File
@@ -1,98 +1,89 @@
process.env.NODE_ENV = 'test'; process.env.NODE_ENV = 'test';
var fs = require('fs'); var fs = require('fs');
var Step = require('step');
var MBTiles = require('..'); var MBTiles = require('..');
var assert = require('assert');
var fixtures = { var fixtures = {
plain_1: __dirname + '/fixtures/plain_1.mbtiles', plain_1: __dirname + '/fixtures/plain_1.mbtiles',
empty: __dirname + '/fixtures/empty.mbtiles' empty: __dirname + '/fixtures/empty.mbtiles'
}; };
try { fs.unlink(fixtures.empty); } catch (err) {} describe('info', function() {
before(function(done) {
try { fs.unlinkSync(fixtures.empty); } catch (err) {}
exports['get metadata'] = function(beforeExit, assert) { done();
var completed = false;
new MBTiles(fixtures.plain_1, function(err, mbtiles) {
if (err) throw err;
mbtiles.getInfo(function(err, data) {
completed = true;
if (err) throw err;
assert.deepEqual({
name: 'plain_1',
description: 'demo description',
version: '1.0.3',
scheme: 'tms',
minzoom: 0,
maxzoom: 4,
formatter: null,
center: [ 0, 7.500000001278025, 2 ],
bounds: [ -179.9999999749438, -69.99999999526695, 179.9999999749438, 84.99999999782301 ],
// These aren't part of TileJSON, but exist in an MBTiles file.
filesize: 561152,
type: 'baselayer',
id: 'plain_1',
basename: 'plain_1.mbtiles'
}, data);
})
}); });
it('get metadata', function(done) {
new MBTiles(fixtures.plain_1, function(err, mbtiles) {
assert.ifError(err);
beforeExit(function() { mbtiles.getInfo(function(err, data) {
assert.ok(completed); assert.ifError(err);
assert.deepEqual({
name: 'plain_1',
description: 'demo description',
version: '1.0.3',
scheme: 'tms',
minzoom: 0,
maxzoom: 4,
formatter: null,
center: [ 0, 7.500000001278025, 2 ],
bounds: [ -179.9999999749438, -69.99999999526695, 179.9999999749438, 84.99999999782301 ],
// These aren't part of TileJSON, but exist in an MBTiles file.
filesize: 561152,
type: 'baselayer',
id: 'plain_1',
basename: 'plain_1.mbtiles'
}, data);
done();
});
});
}); });
}; it('get/put metadata from empty file', function(done) {
this.timeout(5e3);
exports['get/put metadata from empty file'] = function(beforeExit, assert) { new MBTiles(fixtures.empty, function(err, mbtiles) {
var completion = {}; assert.ifError(err);
new MBTiles(fixtures.empty, function(err, mbtiles) { mbtiles.getInfo(function(err, data) {
if (err) throw err; assert.ifError(err);
completion.open = true;
mbtiles.getInfo(function(err, data) { assert.deepEqual({
if (err) throw err; basename: "empty.mbtiles",
completion.info = true; filesize: 0,
id: "empty",
scheme: "tms"
}, data);
assert.deepEqual({ mbtiles.putInfo({ version: '1.0.0' }, function(err) {
basename: "empty.mbtiles", assert.ok(err);
filesize: 0, assert.equal(err.message, 'MBTiles not in write mode');
id: "empty",
scheme: "tms"
}, data);
mbtiles.putInfo({ version: '1.0.0' }, function(err) { mbtiles.startWriting(function(err) {
assert.ok(err); assert.ifError(err);
assert.equal(err.message, 'MBTiles not in write mode');
completion.putFail = true;
mbtiles.startWriting(function(err) { mbtiles.putInfo({ version: '1.0.0' }, function(err) {
if (err) throw err; assert.ifError(err);
completion.startWriting = true;
mbtiles.putInfo({ version: '1.0.0' }, function(err) { mbtiles.stopWriting(function(err) {
if (err) throw err; assert.ifError(err);
completion.written = true;
mbtiles.stopWriting(function(err) { mbtiles.getInfo(function(err, data) {
if (err) throw err; assert.ifError(err);
completion.stopWriting = true;
mbtiles.getInfo(function(err, data) { assert.deepEqual({
if (err) throw err; basename: "empty.mbtiles",
completion.updatedInfo = true; filesize: 0,
id: "empty",
scheme: "tms",
version: "1.0.0"
}, data);
assert.deepEqual({ done();
basename: "empty.mbtiles", });
filesize: 0,
id: "empty",
scheme: "tms",
version: "1.0.0"
}, data);
}); });
}); });
}); });
@@ -100,17 +91,4 @@ exports['get/put metadata from empty file'] = function(beforeExit, assert) {
}); });
}); });
}); });
});
beforeExit(function() {
assert.deepEqual(completion, {
info: true,
open: true,
putFail: true,
startWriting: true,
stopWriting: true,
updatedInfo: true,
written: true
});
});
};
+13 -13
View File
@@ -1,23 +1,23 @@
process.env.NODE_ENV = 'test'; process.env.NODE_ENV = 'test';
var fs = require('fs'); var fs = require('fs');
var Step = require('step');
var MBTiles = require('..'); var MBTiles = require('..');
var assert = require('assert');
var fixtures = { var fixtures = {
doesnotexist: __dirname + '/doesnotexist' doesnotexist: __dirname + '/doesnotexist'
}; };
try { fs.unlink(fixtures.doesnotexist); } catch (err) {} describe('list', function() {
before(function(done) {
try { fs.unlinkSync(fixtures.doesnotexist); } catch (err) {}
exports['list'] = function(beforeExit, assert) { done();
var completed = false; beforeExit(function() { assert.ok(completed); });
MBTiles.list(fixtures.doesnotexist, function(err, list) {
completed = true;
assert.equal(err, null);
assert.deepEqual(list, {});
}); });
}; it('list', function(done) {
MBTiles.list(fixtures.doesnotexist, function(err, list) {
assert.ifError(err);
assert.deepEqual(list, {});
done();
});
});
});
+113 -224
View File
@@ -2,7 +2,7 @@ process.env.NODE_ENV = 'test';
var fs = require('fs'); var fs = require('fs');
var MBTiles = require('..'); var MBTiles = require('..');
var assert = require('assert');
var fixtures = { var fixtures = {
plain_1: __dirname + '/fixtures/plain_1.mbtiles', plain_1: __dirname + '/fixtures/plain_1.mbtiles',
@@ -13,244 +13,133 @@ var fixtures = {
corrupt: __dirname + '/fixtures/corrupt.mbtiles' corrupt: __dirname + '/fixtures/corrupt.mbtiles'
}; };
try { fs.unlink(fixtures.non_existent); } catch (err) {} function yieldsError(assert, error, msg, callback) {
function yieldsError(assert, status, error, msg) {
return function(err) { return function(err) {
assert.ok(err); assert.ok(err);
var re = new RegExp( "^" + msg, "i"); var re = new RegExp( "^" + msg, "i");
assert.ok(err.message.match(re)); assert.ok(err.message.match(re));
status[error]++; if (callback) callback();
}; };
} }
describe('read', function() {
var loaded = {};
exports['get tiles'] = function(beforeExit, assert) { before(function(done) {
var status = { try { fs.unlinkSync(fixtures.non_existent); } catch (err) {}
success: 0, done();
error: 0 });
}; before(function(done) {
var queue = Object.keys(fixtures);
var load = function() {
if (!queue.length) return done();
var key = queue.shift();
new MBTiles(fixtures[key], function(err, mbtiles) {
if (err) throw err;
loaded[key] = mbtiles;
load();
});
};
load();
});
new MBTiles(fixtures.plain_1, function(err, mbtiles) { fs.readdirSync(__dirname + '/fixtures/images/').forEach(function(file) {
if (err) throw err; var coords = file.match(/^plain_1_(\d+)_(\d+)_(\d+).png$/);
fs.readdirSync(__dirname + '/fixtures/images/').forEach(function(file) { if (!coords) return;
var coords = file.match(/^plain_1_(\d+)_(\d+)_(\d+).png$/);
if (coords) { // Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ. coords = [ coords[3], coords[1], coords[2] ];
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2]; coords[2] = Math.pow(2, coords[0]) - 1 - coords[2];
mbtiles.getTile(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, tile, headers) { it('tile ' + coords.join('/'), function(done) {
if (err) throw err; loaded.plain_1.getTile(coords[0] | 0, coords[1] | 0, coords[2] | 0, function(err, tile, headers) {
assert.deepEqual(tile, fs.readFileSync(__dirname + '/fixtures/images/' + file)); if (err) throw err;
assert.equal(headers['Content-Type'], 'image/png'); assert.deepEqual(tile, fs.readFileSync(__dirname + '/fixtures/images/' + file));
assert.ok(!isNaN(Date.parse(headers['Last-Modified']))); assert.equal(headers['Content-Type'], 'image/png');
assert.ok(/\d+-\d+/.test(headers['ETag'])); assert.ok(!isNaN(Date.parse(headers['Last-Modified'])));
status.success++; assert.ok(/\d+-\d+/.test(headers['ETag']));
}); done();
} });
}); });
it('grid ' + coords.join('/'), function(done) {
mbtiles.getTile(0, 1, 0, yieldsError(assert, status, 'error', 'Tile does not exist')); loaded.plain_1.getGrid(coords[0] | 0, coords[1] | 0, coords[2] | 0, yieldsError(assert, 'error', 'Grid does not exist', done));
mbtiles.getTile(-1, 0, 0, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(0, 0, 1, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(3, 1, -1, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(2, -3, 3, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(18, 2, 262140, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 0, 15, yieldsError(assert, status, 'error', 'Tile does not exist'));
});
beforeExit(function() {
assert.equal(status.success, 285);
assert.equal(status.error, 7);
});
};
exports['get grids'] = function(beforeExit, assert) {
var status = {
success: 0,
error: 0
};
new MBTiles(fixtures.plain_2, function(err, mbtiles) {
if (err) throw err;
fs.readdirSync(__dirname + '/fixtures/grids/').forEach(function(file) {
var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/);
if (coords) {
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
mbtiles.getGrid(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, grid, headers) {
if (err) throw err;
assert.deepEqual(JSON.stringify(grid), fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8'));
assert.equal(headers['Content-Type'], 'text/javascript');
assert.ok(!isNaN(Date.parse(headers['Last-Modified'])));
assert.ok(/\d+-\d+/.test(headers['ETag']));
status.success++;
});
}
}); });
mbtiles.getGrid(0, 1, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(-1, 0, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(0, 0, 1, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 1, -1, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(2, -3, 3, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(18, 2, 262140, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 0, 15, yieldsError(assert, status, 'error', 'Grid does not exist'));
}); });
[ [0,1,0],
[-1,0,0],
beforeExit(function() { [0,0,1],
assert.equal(status.success, 241); [3,1,-1],
assert.equal(status.error, 7); [2,-3,3],
}); [18,2,262140],
}; [4,0,15]
].forEach(function(coords) {
it('tile ' + coords.join('/'), function(done) {
exports['get grids from file without interaction'] = function(beforeExit, assert) { loaded.plain_1.getTile(coords[0], coords[1], coords[2], yieldsError(assert, 'error', 'Tile does not exist', done));
var status = {
success: 0,
error: 0
};
new MBTiles(fixtures.plain_1, function(err, mbtiles) {
if (err) throw err;
mbtiles.getGrid(0, 1, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(-1, 0, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(0, 0, -1, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 1, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(2, -3, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(18, 2, 3, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 0, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 3, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 4, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 5, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 13, 4, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 0, 14, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 0, 7, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 6, 2, yieldsError(assert, status, 'error', 'Grid does not exist'));
});
beforeExit(function() {
assert.equal(status.success, 0);
assert.equal(status.error, 14);
});
};
exports['get grids with different schema'] = function(beforeExit, assert) {
var status = {
success: 0,
error: 0
};
new MBTiles(fixtures.plain_4, function(err, mbtiles) {
if (err) throw err;
fs.readdirSync(__dirname + '/fixtures/grids/').forEach(function(file) {
var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/);
if (coords) {
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
mbtiles.getGrid(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, grid) {
if (err) throw err;
assert.deepEqual(JSON.stringify(grid), fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8'));
status.success++;
});
}
}); });
mbtiles.getGrid(0, 1, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(-1, 0, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(0, 0, 1, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 1, -1, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(2, -3, 3, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(18, 2, 262140, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 0, 15, yieldsError(assert, status, 'error', 'Grid does not exist'));
}); });
beforeExit(function() { fs.readdirSync(__dirname + '/fixtures/grids/').forEach(function(file) {
assert.equal(status.success, 241); var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/);
assert.equal(status.error, 7); if (!coords) return;
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords = [ coords[3], coords[1], coords[2] ];
coords[2] = Math.pow(2, coords[0]) - 1 - coords[2];
it('grid ' + coords.join('/'), function(done) {
loaded.plain_2.getGrid(coords[0] | 0, coords[1] | 0, coords[2] | 0, function(err, grid, headers) {
if (err) throw err;
assert.deepEqual(JSON.stringify(grid), fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8'));
assert.equal(headers['Content-Type'], 'text/javascript');
assert.ok(!isNaN(Date.parse(headers['Last-Modified'])));
assert.ok(/\d+-\d+/.test(headers['ETag']));
done();
});
});
it('grid alt ' + coords.join('/'), function(done) {
loaded.plain_4.getGrid(coords[0] | 0, coords[1] | 0, coords[2] | 0, function(err, grid, headers) {
if (err) throw err;
assert.deepEqual(JSON.stringify(grid), fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8'));
assert.equal(headers['Content-Type'], 'text/javascript');
assert.ok(!isNaN(Date.parse(headers['Last-Modified'])));
assert.ok(/\d+-\d+/.test(headers['ETag']));
done();
});
});
}); });
}; [ [0,1,0],
[-1,0,0],
[0,0,1],
exports['get grids from file without interaction'] = function(beforeExit, assert) { [3,1,-1],
var status = { [2,-3,3],
success: 0, [18,2,262140],
error: 0 [4,0,15]
}; ].forEach(function(coords) {
it('grid ' + coords.join('/'), function(done) {
new MBTiles(fixtures.plain_1, function(err, mbtiles) { loaded.plain_2.getGrid(coords[0], coords[1], coords[2], yieldsError(assert, 'error', 'Grid does not exist', done));
if (err) throw err; });
mbtiles.getGrid(0, 1, 0, yieldsError(assert, status, 'error', 'Grid does not exist')); it('grid alt ' + coords.join('/'), function(done) {
mbtiles.getGrid(-1, 0, 0, yieldsError(assert, status, 'error', 'Grid does not exist')); loaded.plain_4.getGrid(coords[0], coords[1], coords[2], yieldsError(assert, 'error', 'Grid does not exist', done));
mbtiles.getGrid(0, 0, -1, yieldsError(assert, status, 'error', 'Grid does not exist')); });
mbtiles.getGrid(3, 1, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(2, -3, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(18, 2, 3, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 0, 0, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 3, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 4, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 5, 8, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 13, 4, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(4, 0, 14, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 0, 7, yieldsError(assert, status, 'error', 'Grid does not exist'));
mbtiles.getGrid(3, 6, 2, yieldsError(assert, status, 'error', 'Grid does not exist'));
}); });
[ [0,1,0],
beforeExit(function() { [-1,0,0],
assert.equal(status.success, 0); [0,0,-1],
assert.equal(status.error, 14); [3,1,8],
[2,-3,0],
[18,2,3],
[4,0,0],
[4,3,8],
[4,4,8],
[4,5,8],
[4,13,4],
[4,0,14],
[3,0,7],
[3,6,2]
].forEach(function(coords) {
it('dne ' + coords.join('/'), function(done) {
loaded.non_existent.getTile(coords[0], coords[1], coords[2], yieldsError(assert, 'error', 'Tile does not exist', done));
});
it('corrupt ' + coords.join('/'), function(done) {
loaded.corrupt.getTile(coords[0], coords[1], coords[2], yieldsError(assert, 'error', 'SQLITE_CORRUPT: database disk image is malformed', done));
});
}); });
}; });
exports['get tiles from non-existent file'] = function(beforeExit, assert) {
var status = {
success: 0,
error: 0
};
new MBTiles(fixtures.non_existent, function(err, mbtiles) {
if (err) throw err;
mbtiles.getTile(0, 1, 0, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(-1, 0, 0, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(0, 0, -1, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(3, 1, 8, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(2, -3, 0, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(18, 2, 3, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 0, 0, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 3, 8, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 4, 8, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 5, 8, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 13, 4, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(4, 0, 14, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(3, 0, 7, yieldsError(assert, status, 'error', 'Tile does not exist'));
mbtiles.getTile(3, 6, 2, yieldsError(assert, status, 'error', 'Tile does not exist'));
});
beforeExit(function() {
assert.equal(status.success, 0);
assert.equal(status.error, 14);
});
};
exports['get tiles from corrupt file'] = function(beforeExit, assert) {
var status = {
success: 0,
error: 0
};
var error;
new MBTiles(fixtures.corrupt, function(err, mbtiles) {
error = err;
});
beforeExit(function() {
assert.throws(
function() {
throw err;
},
Error
);
});
};
-107
View File
@@ -1,107 +0,0 @@
process.env.NODE_ENV = 'test';
var fs = require('fs');
var MBTiles = require('..');
var fixtureDir = __dirname + '/fixtures/output';
var fixtures = {
source: __dirname + '/fixtures/plain_1.mbtiles',
destination: fixtureDir + '/write_3.mbtiles'
};
// Load entire database as buffer.
var file = fs.readFileSync(fixtures.source);
// Recreate output directory to remove previous tests.
try { fs.unlinkSync(fixtures.destination); } catch(err) {}
try { fs.mkdirSync(fixtureDir, 0755); } catch(err) {}
exports['test file reloading during copying'] = function(beforeExit, assert) {
var completed = false;
var status = {
success: 0,
error: 0
};
var tiles = [
[ 0, 0, 0 ],
[ 1, 0, 1 ],
[ 4, 0, 5 ],
[ 4, 0, 4 ],
[ 1, 0, 0 ],
[ 3, 6, 3 ],
[ 4, 8, 6 ],
[ 4, 9, 1 ],
[ 4, 9, 10 ],
[ 4, 9, 7 ],
[ 4, 9, 6 ]
];
var fd = fs.openSync(fixtures.destination, 'w');
// Start copying the file. Write first 100 KB and last 100 KB, then wait.
fs.writeSync(fd, file, 0, 100000, 0);
fs.writeSync(fd, file, 461152, 100000, 461152);
function writeRest() {
setTimeout(function() {
fs.writeSync(fd, file, 100000, 461152, 100000);
fs.closeSync(fd);
setTimeout(function() {
new MBTiles(fixtures.destination, function(err, mbtiles) {
var returned = 0;
tiles.forEach(function(c) {
mbtiles.getTile(c[0], c[1], c[2], function(err, tile) {
if (err) assert.ok(false, "Couldn't load tile " + c[0] + '/' + c[1] + '/' + c[2]);
else status.success++;
});
});
});
}, 2000);
}, 1000);
}
// Try reading.
new MBTiles(fixtures.destination, function(err, mbtiles) {
if (err) throw err;
mbtiles.getInfo(function(err, data) {
completed = true;
if (err) throw err;
assert.deepEqual({
name: 'plain_1',
description: 'demo description',
version: '1.0.3',
scheme: 'tms',
minzoom: 0,
maxzoom: 4,
formatter: null,
center: [ 0, 7.500000001278025, 2 ],
bounds: [ -179.9999999749438, -69.99999999526695, 179.9999999749438, 84.99999999782301 ],
// These aren't part of TileJSON, but exist in an MBTiles file.
filesize: 561152,
type: 'baselayer',
id: 'write_3',
basename: 'write_3.mbtiles'
}, data);
});
var returned = 0;
tiles.forEach(function(c) {
mbtiles.getTile(c[0], c[1], c[2], function(err, tile) {
if (++returned === tiles.length) writeRest();
if (err) status.error++;
else assert.ok(false, "Could unexpectedly load tile " + c[0] + '/' + c[1] + '/' + c[2]);
});
});
});
beforeExit(function() {
assert.ok(completed);
assert.equal(status.error, 11);
assert.equal(status.success, 11);
});
};
+54 -58
View File
@@ -3,70 +3,66 @@ process.env.NODE_ENV = 'test';
var fs = require('fs'); var fs = require('fs');
var assert = require('assert'); var assert = require('assert');
var MBTiles = require('..'); var MBTiles = require('..');
var fixtureDir = __dirname + '/fixtures/output'; var fixtureDir = __dirname + '/fixtures/output';
// Recreate output directory to remove previous tests. describe('write', function() {
try { fs.unlinkSync(fixtureDir + '/write_1.mbtiles'); } catch(err) {} before(function(done) {
try { fs.mkdirSync(fixtureDir, 0755); } catch(err) {} // Recreate output directory to remove previous tests.
try { fs.unlinkSync(fixtureDir + '/write_1.mbtiles'); } catch(err) {}
try { fs.mkdirSync(fixtureDir, 0755); } catch(err) {}
done();
});
it('test mbtiles file creation', function(done) {
this.timeout(20e3);
exports['test mbtiles file creation'] = function(beforeExit, assert) { var completed = { written: 0, read: 0 };
var completed = { written: 0, read: 0 }; new MBTiles(fixtureDir + '/write_1.mbtiles', function(err, mbtiles) {
new MBTiles(fixtureDir + '/write_1.mbtiles', function(err, mbtiles) { completed.open = true;
completed.open = true;
if (err) throw err;
mbtiles.startWriting(function(err) {
completed.started = true;
if (err) throw err; if (err) throw err;
fs.readdirSync(__dirname + '/fixtures/images/').forEach(insertTile); mbtiles.startWriting(function(err) {
}); completed.started = true;
function insertTile(file) {
var coords = file.match(/^plain_1_(\d+)_(\d+)_(\d+).png$/);
if (!coords) return;
// Flip Y coordinate because file names are TMS, but .putTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
var tile = fs.readFileSync(__dirname + '/fixtures/images/' + file);
mbtiles.putTile(coords[3] | 0, coords[1] | 0, coords[2] | 0, tile, function(err) {
if (err) throw err; if (err) throw err;
completed.written++;
if (completed.written === 285) {
mbtiles.stopWriting(function(err) {
completed.stopped = true;
if (err) throw err;
verifyWritten();
});
}
});
}
function verifyWritten() { fs.readdirSync(__dirname + '/fixtures/images/').forEach(insertTile);
fs.readdirSync(__dirname + '/fixtures/images/').forEach(function(file) { });
function insertTile(file) {
var coords = file.match(/^plain_1_(\d+)_(\d+)_(\d+).png$/); var coords = file.match(/^plain_1_(\d+)_(\d+)_(\d+).png$/);
if (coords) { if (!coords) return;
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
mbtiles.getTile(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, tile) {
if (err) throw err;
assert.deepEqual(tile, fs.readFileSync(__dirname + '/fixtures/images/' + file));
completed.read++;
});
}
});
}
});
beforeExit(function() { // Flip Y coordinate because file names are TMS, but .putTile() expects XYZ.
assert.deepEqual({ coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
open: true,
started: true, var tile = fs.readFileSync(__dirname + '/fixtures/images/' + file);
written: 285, mbtiles.putTile(coords[3] | 0, coords[1] | 0, coords[2] | 0, tile, function(err) {
read: 285, if (err) throw err;
stopped: true completed.written++;
}, completed); if (completed.written === 285) {
}) mbtiles.stopWriting(function(err) {
}; completed.stopped = true;
if (err) throw err;
verifyWritten();
});
}
});
}
function verifyWritten() {
fs.readdirSync(__dirname + '/fixtures/images/').forEach(function(file) {
var coords = file.match(/^plain_1_(\d+)_(\d+)_(\d+).png$/);
if (coords) {
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
mbtiles.getTile(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, tile) {
if (err) throw err;
assert.deepEqual(tile, fs.readFileSync(__dirname + '/fixtures/images/' + file));
completed.read++;
if (completed.read === 285) done();
});
}
});
}
});
});
});
+55 -59
View File
@@ -1,71 +1,67 @@
process.env.NODE_ENV = 'test'; process.env.NODE_ENV = 'test';
var fs = require('fs'); var fs = require('fs');
var assert = require('assert');
var MBTiles = require('..'); var MBTiles = require('..');
var fixtureDir = __dirname + '/fixtures/output'; var fixtureDir = __dirname + '/fixtures/output';
// Recreate output directory to remove previous tests. describe('write grids', function() {
try { fs.unlinkSync(fixtureDir + '/write_2.mbtiles'); } catch(err) {} before(function(done) {
try { fs.mkdirSync(fixtureDir, 0755); } catch(err) {} // Recreate output directory to remove previous tests.
try { fs.unlinkSync(fixtureDir + '/write_2.mbtiles'); } catch(err) {}
exports['test mbtiles file creation'] = function(beforeExit, assert) { try { fs.mkdirSync(fixtureDir, 0755); } catch(err) {}
var completed = { written: 0, read: 0 }; done();
new MBTiles(fixtureDir + '/write_2.mbtiles', function(err, mbtiles) { });
completed.open = true; it('test mbtiles file creation', function(done) {
if (err) throw err; this.timeout(20e3);
var completed = { written: 0, read: 0 };
mbtiles.startWriting(function(err) { new MBTiles(fixtureDir + '/write_2.mbtiles', function(err, mbtiles) {
completed.started = true; completed.open = true;
if (err) throw err; if (err) throw err;
fs.readdirSync(__dirname + '/fixtures/grids/').forEach(insertGrid); mbtiles.startWriting(function(err) {
}); completed.started = true;
function insertGrid(file) {
var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/);
if (!coords) return;
// Flip Y coordinate because file names are TMS, but .putGrid() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
var grid = fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8');
mbtiles.putGrid(coords[3] | 0, coords[1] | 0, coords[2] | 0, JSON.parse(grid), function(err) {
if (err) throw err; if (err) throw err;
completed.written++;
if (completed.written === 241) {
mbtiles.stopWriting(function(err) {
completed.stopped = true;
if (err) throw err;
verifyWritten();
});
}
});
}
function verifyWritten() { fs.readdirSync(__dirname + '/fixtures/grids/').forEach(insertGrid);
fs.readdirSync(__dirname + '/fixtures/grids/').forEach(function(file) { });
function insertGrid(file) {
var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/); var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/);
if (coords) { if (!coords) return;
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
mbtiles.getGrid(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, grid) {
if (err) throw err;
assert.deepEqual(JSON.stringify(grid), fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8'));
completed.read++;
});
}
});
}
});
beforeExit(function() { // Flip Y coordinate because file names are TMS, but .putGrid() expects XYZ.
assert.deepEqual({ coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
open: true,
started: true, var grid = fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8');
written: 241, mbtiles.putGrid(coords[3] | 0, coords[1] | 0, coords[2] | 0, JSON.parse(grid), function(err) {
read: 241, if (err) throw err;
stopped: true completed.written++;
}, completed); if (completed.written === 241) {
}) mbtiles.stopWriting(function(err) {
}; completed.stopped = true;
if (err) throw err;
verifyWritten();
});
}
});
}
function verifyWritten() {
fs.readdirSync(__dirname + '/fixtures/grids/').forEach(function(file) {
var coords = file.match(/^plain_2_(\d+)_(\d+)_(\d+).json$/);
if (coords) {
// Flip Y coordinate because file names are TMS, but .getTile() expects XYZ.
coords[2] = Math.pow(2, coords[3]) - 1 - coords[2];
mbtiles.getGrid(coords[3] | 0, coords[1] | 0, coords[2] | 0, function(err, grid) {
if (err) throw err;
assert.deepEqual(JSON.stringify(grid), fs.readFileSync(__dirname + '/fixtures/grids/' + file, 'utf8'));
completed.read++;
if (completed.read === 241) done();
});
}
});
}
});
});
});