Windshaft-cartodb/lib/cartodb/api/overviews_metadata_api.js

41 lines
1.4 KiB
JavaScript
Raw Normal View History

var SubstitutionTokens = require('../utils/substitution-tokens');
function OverviewsMetadataApi(pgQueryRunner) {
this.pgQueryRunner = pgQueryRunner;
2016-01-20 02:31:43 +08:00
}
module.exports = OverviewsMetadataApi;
2016-01-20 02:31:43 +08:00
function prepareSql(sql) {
return sql && SubstitutionTokens.replace(sql, {
bbox: 'ST_MakeEnvelope(0,0,0,0)',
scale_denominator: '0',
pixel_width: '1',
pixel_height: '1'
});
}
2016-01-20 02:31:43 +08:00
OverviewsMetadataApi.prototype.getOverviewsMetadata = function (username, sql, callback) {
2016-04-20 20:30:13 +08:00
// FIXME: Currently using internal function _cdb_schema_name
// CDB_Overviews should provide the schema information directly.
var query = 'SELECT *, _cdb_schema_name(base_table)' +
' FROM CDB_Overviews(CDB_QueryTablesText($windshaft$' + prepareSql(sql) + '$windshaft$))';
this.pgQueryRunner.run(username, query, function handleOverviewsRows(err, rows) {
if (err){
2016-02-24 01:15:14 +08:00
callback(err);
return;
2016-01-20 18:51:46 +08:00
}
var metadata = rows.reduce(function(metadata, row){
var table = row.base_table;
var schema = row._cdb_schema_name;
2016-04-21 00:01:34 +08:00
if ( !metadata[table] ) {
metadata[table] = {};
}
2016-04-21 00:01:34 +08:00
metadata[table][row.z] = { table: row.overview_table };
metadata[table].schema = schema;
return metadata;
}, {});
return callback(null, metadata);
2016-01-20 02:31:43 +08:00
});
};