dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-28 18:46:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

import test small refactor

Browse Source
This commit is contained in:
Jan Prochazka
2024-09-17 12:40:41 +02:00
parent 880912806a
commit 503e09ddd1
1 changed files with 19 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
integration-tests/__tests__/import-formats.spec.js
View File

@@ -16,11 +16,27 @@ const CSV_DATA = `Issue Number; Title; Github URL; Labels; State; Created At; Up
792; "FEAT: Wayland support"; https://github.com/dbgate/dbgate/issues/792; ""; closed; 05/19/2024; 05/21/2024; VosaXalo; 792; "FEAT: Wayland support"; https://github.com/dbgate/dbgate/issues/792; ""; closed; 05/19/2024; 05/21/2024; VosaXalo;
`; `;
async function getReaderRows(reader) {
const jsonLinesFileName = tmp.tmpNameSync();
const writer = await dbgateApi.jsonLinesWriter({
fileName: jsonLinesFileName,
});
await dbgateApi.copyStream(reader, writer);
const jsonData = fs.readFileSync(jsonLinesFileName, 'utf-8');
const rows = jsonData
.split('\n')
.filter(x => x.trim() !== '')
.map(x => JSON.parse(x));
return rows;
}
test('csv import test', async () => { test('csv import test', async () => {
const dbgatePluginCsv = requirePlugin('dbgate-plugin-csv'); const dbgatePluginCsv = requirePlugin('dbgate-plugin-csv');
const csvFileName = tmp.tmpNameSync(); const csvFileName = tmp.tmpNameSync();
const jsonlFileName = tmp.tmpNameSync();
fs.writeFileSync(csvFileName, CSV_DATA); fs.writeFileSync(csvFileName, CSV_DATA);
@@ -28,16 +44,8 @@ test('csv import test', async () => {
fileName: csvFileName, fileName: csvFileName,
}); });
const writer = await dbgateApi.jsonLinesWriter({ const rows = await getReaderRows(reader);
fileName: jsonlFileName,
});
await dbgateApi.copyStream(reader, writer);
const jsonData = fs.readFileSync(jsonlFileName, 'utf-8');
const rows = jsonData
.split('\n')
.filter(x => x.trim() !== '')
.map(x => JSON.parse(x));
expect(rows[0].columns).toEqual([ expect(rows[0].columns).toEqual([
{ columnName: 'Issue Number' }, { columnName: 'Issue Number' },
{ columnName: 'Title' }, { columnName: 'Title' },
@@ -65,7 +73,6 @@ test('csv import test', async () => {
test('JSON array import test', async () => { test('JSON array import test', async () => {
const jsonFileName = tmp.tmpNameSync(); const jsonFileName = tmp.tmpNameSync();
const jsonLinesFileName = tmp.tmpNameSync();
fs.writeFileSync( fs.writeFileSync(
jsonFileName, jsonFileName,
@@ -79,16 +86,8 @@ test('JSON array import test', async () => {
fileName: jsonFileName, fileName: jsonFileName,
}); });
const writer = await dbgateApi.jsonLinesWriter({ const rows = await getReaderRows(reader);
fileName: jsonLinesFileName,
});
await dbgateApi.copyStream(reader, writer);
const jsonData = fs.readFileSync(jsonLinesFileName, 'utf-8');
const rows = jsonData
.split('\n')
.filter(x => x.trim() !== '')
.map(x => JSON.parse(x));
expect(rows.length).toEqual(2); expect(rows.length).toEqual(2);
expect(rows[0]).toEqual({ expect(rows[0]).toEqual({
id: 1, id: 1,