cartodb/CartoDB-SQL-API
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

removing old metrics in copy

Browse Source
This commit is contained in:
Simon Martín 2018-06-08 13:33:17 +02:00
parent c62ef15dda
commit 8e8ccc9c67
2 changed files with 2 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
app/controllers/copy_controller.js
View File

@ -90,23 +90,15 @@ function handleCopyFrom (streamCopy) {
res.locals.userDbParams,
res.locals.user,
req.get('content-encoding') === 'gzip',
function(err, metrics) { // TODO: remove when data-ingestion log works: {time, rows}
function(err, metrics) {
if (err) {
return next(err);
}
// TODO: remove when data-ingestion log works
const { time, rows, type, format, gzip, size } = metrics;
const { time, rows } = metrics;
if (!time || !rows) {
return next(new Error("No rows copied"));
}
// TODO: remove when data-ingestion log works
if (req.profiler) {
req.profiler.add({copyFrom: { type, format, gzip, size, rows, time }});
res.header('X-SQLAPI-Profiler', req.profiler.toJSONString());
}
res.send({
time,

22
test/acceptance/copy-endpoints.js
View File

@ -46,17 +46,6 @@ describe('copy-endpoints', function() {
const response = JSON.parse(res.body);
assert.equal(!!response.time, true);
assert.strictEqual(response.total_rows, 6);
assert.ok(res.headers['x-sqlapi-profiler']);
const headers = JSON.parse(res.headers['x-sqlapi-profiler']);
assert.ok(headers.copyFrom);
const metrics = headers.copyFrom;
assert.equal(metrics.size, 57);
assert.equal(metrics.format, 'CSV');
assert.equal(metrics.time, response.time);
assert.equal(metrics.rows, response.total_rows);
assert.equal(metrics.gzip, false);
done();
});
});
@ -175,17 +164,6 @@ describe('copy-endpoints', function() {
const response = JSON.parse(res.body);
assert.equal(!!response.time, true);
assert.strictEqual(response.total_rows, 6);
assert.ok(res.headers['x-sqlapi-profiler']);
const headers = JSON.parse(res.headers['x-sqlapi-profiler']);
assert.ok(headers.copyFrom);
const metrics = headers.copyFrom;
assert.equal(metrics.size, 57);
assert.equal(metrics.format, 'CSV');
assert.equal(metrics.time, response.time);
assert.equal(metrics.rows, response.total_rows);
assert.equal(metrics.gzip, true);
done();
});
});