expire-tiles.js

/*
node-tileserver Copyright (C) 2014 Alexander Matheisen
This program comes with ABSOLUTELY NO WARRANTY.
This is free software, and you are welcome to redistribute it under certain conditions.
See https://github.com/rurseekatze/node-tileserver for details.
*/


// include necessary modules
os = require('os');
rbush = require('rbush');
assert = require('assert');
url = require("url");
mkdirp = require('mkdirp');
pg = require('pg');
toobusy = require('toobusy-js');
byline = require('byline');
touch = require("touch");
Canvas = require('canvas');
events = require('events');
log4js = require('log4js');
fs = require('graceful-fs');

// load configuraion file
configuration = require('./config.json');

// configure logging
log4js.configure(
{
	appenders:
	[
		{
			"type": "logLevelFilter",
			"level": "ERROR",
			"appender":
			{
				"type": "file",
				"filename": 'expiring.log',
				'maxLogSize': 20480,
				'backups': 0
			}
		},
		{
			"type": "logLevelFilter",
			"level": "INFO",
			"appender":
			{
				"type": "console"
			}
		}
	]
});
logger = log4js.getLogger();
logger.setLevel('TRACE');

// load classes
Tile = require('./tile.js');
Tilequeue = require('./queue.js');

if (process.argv[2] && process.argv[2].length > 0 && fs.existsSync(process.argv[2]))
{
	expireTileList(process.argv[2], function(err)
	{
		if (err)
		{
			console.log('Some problems occurred.');
			process.exit(1);
		}
		else
		{
			console.log('Finished.');
			process.exit(code=0);
		}
	});
}
else
{
	console.log('Given filename invalid or file cannot be found.');
	process.exit(code=0);
}


// load an osm2pgsql list of expired tiles and marks all tiles as expired
function expireTileList(filename, callback)
{
	console.log('Checking if list of expired tiles exists...');
	if (fs.existsSync(filename))
	{
		console.log('Reading list of expired tiles...');
		var stream = byline(fs.createReadStream(filename));

		stream.on('data', function(line)
		{
			var param = line.toString().split("/");
			var tile = new Tile(param[0], param[1], param[2]);

			tile.expire();

			// mark child tiles
			var tileset = tile.getChildren();
			for (var tilesetIndex=0; tilesetIndex<tileset.length; tilesetIndex++)
			{
				tileset[tilesetIndex].expire();
				tileset[tilesetIndex] = null;
			}

			// mark parent tiles
			var parentTileset = tile.getParents();
			for (var parentIndex=0; parentIndex<parentTileset.length; parentIndex++)
			{
				parentTileset[parentIndex].expire();
				parentTileset[parentIndex] = null;
			}
		});

		stream.on('end', function(line)
		{
			console.log('Expired tiles successfully marked.');
			return process.nextTick(function()
			{
				callback(false);
			});
		});

		stream.on('error', function(line)
		{
			console.log('Cannot read list of expired tiles. Aborting.');
			return process.nextTick(function()
			{
				callback(true);
			});
		});
	}
	else
	{
		console.log('Cannot find expired-tiles-file. Aborting.');
		return process.nextTick(function()
		{
			callback(true);
		});
	}
}