mirror of
https://github.com/nocodb/nocodb.git
synced 2026-04-30 19:36:40 +00:00
chore(test): JS prettier for all files
Signed-off-by: Raju Udava <86527202+dstala@users.noreply.github.com>
This commit is contained in:
Raju Udava
@@ -15,93 +15,93 @@ const { rmdir, copyFile } = require("fs");
|
||||
|
||||
// https://stackoverflow.com/questions/61934443/read-excel-files-in-cypress
|
||||
const readXlsx = require("./read-xlsx");
|
||||
const makeServer = require('./server')
|
||||
const makeServer = require("./server");
|
||||
/**
|
||||
* @type {Cypress.PluginConfig}
|
||||
*/
|
||||
// eslint-disable-next-line no-unused-vars
|
||||
module.exports = (on, config) => {
|
||||
// `on` is used to hook into various events Cypress emits
|
||||
// `config` is the resolved Cypress config
|
||||
// `on` is used to hook into various events Cypress emits
|
||||
// `config` is the resolved Cypress config
|
||||
|
||||
// register utility tasks to read and parse Excel files
|
||||
on("task", {
|
||||
copyFile() {
|
||||
console.log("copyFile", __dirname)
|
||||
return new Promise((resolve, reject) => {
|
||||
copyFile("./scripts/cypress/fixtures/quickTest/noco_0_91_7.db", "./packages/nocodb/noco.db", (err) => {
|
||||
if(err) {
|
||||
console.log(err)
|
||||
return reject(err)
|
||||
}
|
||||
resolve(null);
|
||||
})
|
||||
})
|
||||
},
|
||||
deleteFolder(folderName) {
|
||||
console.log("deleting folder %s", folderName);
|
||||
// register utility tasks to read and parse Excel files
|
||||
on("task", {
|
||||
copyFile() {
|
||||
console.log("copyFile", __dirname);
|
||||
return new Promise((resolve, reject) => {
|
||||
copyFile(
|
||||
"./scripts/cypress/fixtures/quickTest/noco_0_91_7.db",
|
||||
"./packages/nocodb/noco.db",
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.log(err);
|
||||
return reject(err);
|
||||
}
|
||||
resolve(null);
|
||||
}
|
||||
);
|
||||
});
|
||||
},
|
||||
deleteFolder(folderName) {
|
||||
console.log("deleting folder %s", folderName);
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
rmdir(
|
||||
folderName,
|
||||
{ maxRetries: 10, recursive: true },
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(err);
|
||||
return new Promise((resolve, reject) => {
|
||||
rmdir(folderName, { maxRetries: 10, recursive: true }, (err) => {
|
||||
if (err) {
|
||||
console.error(err);
|
||||
|
||||
return reject(err);
|
||||
}
|
||||
return reject(err);
|
||||
}
|
||||
|
||||
resolve(null);
|
||||
}
|
||||
);
|
||||
});
|
||||
},
|
||||
readXlsx: readXlsx.read,
|
||||
readSheetList: readXlsx.sheetList,
|
||||
log(message) {
|
||||
console.log(`##Cypress>> ${message}`);
|
||||
return null;
|
||||
},
|
||||
queryDb: (query) => {
|
||||
return queryTestDb(query, config);
|
||||
},
|
||||
sqliteExec: (query) => {
|
||||
_sqliteExec(query);
|
||||
return null;
|
||||
},
|
||||
sqliteExecReturnValue: (query) => {
|
||||
return _sqliteExecReturnValue(query);
|
||||
},
|
||||
pgExec: (query) => {
|
||||
_pgExec(query);
|
||||
return null;
|
||||
},
|
||||
pgExecTest: (query) => {
|
||||
return _pgExecTest(query);
|
||||
}
|
||||
});
|
||||
resolve(null);
|
||||
});
|
||||
});
|
||||
},
|
||||
readXlsx: readXlsx.read,
|
||||
readSheetList: readXlsx.sheetList,
|
||||
log(message) {
|
||||
console.log(`##Cypress>> ${message}`);
|
||||
return null;
|
||||
},
|
||||
queryDb: (query) => {
|
||||
return queryTestDb(query, config);
|
||||
},
|
||||
sqliteExec: (query) => {
|
||||
_sqliteExec(query);
|
||||
return null;
|
||||
},
|
||||
sqliteExecReturnValue: (query) => {
|
||||
return _sqliteExecReturnValue(query);
|
||||
},
|
||||
pgExec: (query) => {
|
||||
_pgExec(query);
|
||||
return null;
|
||||
},
|
||||
pgExecTest: (query) => {
|
||||
return _pgExecTest(query);
|
||||
},
|
||||
});
|
||||
|
||||
let server, port, close
|
||||
let server, port, close;
|
||||
|
||||
on('before:spec', async (spec) => {
|
||||
// we can customize the server based on the spec about to run
|
||||
const info = await makeServer()
|
||||
// save the server instance information
|
||||
server = info.server
|
||||
port = info.port
|
||||
close = info.close
|
||||
console.log('started the server on port %d', port)
|
||||
})
|
||||
on("before:spec", async (spec) => {
|
||||
// we can customize the server based on the spec about to run
|
||||
const info = await makeServer();
|
||||
// save the server instance information
|
||||
server = info.server;
|
||||
port = info.port;
|
||||
close = info.close;
|
||||
console.log("started the server on port %d", port);
|
||||
});
|
||||
|
||||
on('after:spec', async (spec) => {
|
||||
if (!server) {
|
||||
console.log('no server to close')
|
||||
return
|
||||
}
|
||||
await close()
|
||||
console.log('closed the server running on port %d', port)
|
||||
})
|
||||
on("after:spec", async (spec) => {
|
||||
if (!server) {
|
||||
console.log("no server to close");
|
||||
return;
|
||||
}
|
||||
await close();
|
||||
console.log("closed the server running on port %d", port);
|
||||
});
|
||||
};
|
||||
|
||||
// mysql connection
|
||||
@@ -109,126 +109,127 @@ module.exports = (on, config) => {
|
||||
|
||||
const mysql = require("mysql2");
|
||||
function queryTestDb(query, config) {
|
||||
// creates a new mysql connection using credentials from cypress.json env's
|
||||
const connection = mysql.createConnection(config.env.db);
|
||||
// start connection to db
|
||||
connection.connect();
|
||||
// exec query + disconnect to db as a Promise
|
||||
return new Promise((resolve, reject) => {
|
||||
connection.query(query, (error, results) => {
|
||||
if (error) reject(error);
|
||||
else {
|
||||
connection.end();
|
||||
// console.log(results)
|
||||
return resolve(results);
|
||||
}
|
||||
});
|
||||
// creates a new mysql connection using credentials from cypress.json env's
|
||||
const connection = mysql.createConnection(config.env.db);
|
||||
// start connection to db
|
||||
connection.connect();
|
||||
// exec query + disconnect to db as a Promise
|
||||
return new Promise((resolve, reject) => {
|
||||
connection.query(query, (error, results) => {
|
||||
if (error) reject(error);
|
||||
else {
|
||||
connection.end();
|
||||
// console.log(results)
|
||||
return resolve(results);
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
// sqlite connection
|
||||
const sqlite3 = require("sqlite3").verbose();
|
||||
function _sqliteExecReturnValue(query) {
|
||||
// open the database
|
||||
console.log("Current directory: " + process.cwd());
|
||||
let db = new sqlite3.Database(
|
||||
"./scripts/cypress/fixtures/sqlite-sakila/sakila.db",
|
||||
sqlite3.OPEN_READWRITE,
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
} else {
|
||||
console.log("Connected to the noco xcdb database.");
|
||||
}
|
||||
}
|
||||
);
|
||||
// open the database
|
||||
console.log("Current directory: " + process.cwd());
|
||||
let db = new sqlite3.Database(
|
||||
"./scripts/cypress/fixtures/sqlite-sakila/sakila.db",
|
||||
sqlite3.OPEN_READWRITE,
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
} else {
|
||||
console.log("Connected to the noco xcdb database.");
|
||||
}
|
||||
}
|
||||
);
|
||||
|
||||
// exec query + disconnect to db as a Promise
|
||||
return new Promise((resolve, reject) => {
|
||||
db.get(query, [], (err, row) => {
|
||||
db.close();
|
||||
if (err) {
|
||||
reject(err);
|
||||
} else {
|
||||
return resolve(row);
|
||||
}
|
||||
});
|
||||
// exec query + disconnect to db as a Promise
|
||||
return new Promise((resolve, reject) => {
|
||||
db.get(query, [], (err, row) => {
|
||||
db.close();
|
||||
if (err) {
|
||||
reject(err);
|
||||
} else {
|
||||
return resolve(row);
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
function _sqliteExec(query) {
|
||||
// open the database
|
||||
console.log("Current directory: " + process.cwd());
|
||||
let db = new sqlite3.Database(
|
||||
"./scripts/cypress/fixtures/sqlite-sakila/sakila.db",
|
||||
sqlite3.OPEN_READWRITE,
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
} else {
|
||||
console.log("Connected to the noco xcdb database.");
|
||||
}
|
||||
}
|
||||
);
|
||||
// open the database
|
||||
console.log("Current directory: " + process.cwd());
|
||||
let db = new sqlite3.Database(
|
||||
"./scripts/cypress/fixtures/sqlite-sakila/sakila.db",
|
||||
sqlite3.OPEN_READWRITE,
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
} else {
|
||||
console.log("Connected to the noco xcdb database.");
|
||||
}
|
||||
}
|
||||
);
|
||||
|
||||
db.serialize(() => {
|
||||
db.run(query);
|
||||
});
|
||||
db.serialize(() => {
|
||||
db.run(query);
|
||||
});
|
||||
|
||||
db.close((err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
} else {
|
||||
console.log("Close the database connection.");
|
||||
}
|
||||
});
|
||||
db.close((err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
} else {
|
||||
console.log("Close the database connection.");
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
// pg connection
|
||||
const { Pool, Client } = require("pg");
|
||||
const pg_credentials = {
|
||||
user: "postgres",
|
||||
host: "localhost",
|
||||
database: "postgres",
|
||||
password: "password",
|
||||
port: 5432,
|
||||
user: "postgres",
|
||||
host: "localhost",
|
||||
database: "postgres",
|
||||
password: "password",
|
||||
port: 5432,
|
||||
};
|
||||
function _pgExec(query) {
|
||||
// open pg client connection
|
||||
const client = new Client(pg_credentials);
|
||||
client.connect();
|
||||
|
||||
// query & terminate
|
||||
client.query(query, (err, res) => {
|
||||
console.log(err, res);
|
||||
client.end();
|
||||
});
|
||||
}
|
||||
|
||||
function _pgExecTest(query, retryCount = 60) {
|
||||
return new Promise((resolve, reject) => {
|
||||
// open pg client connection
|
||||
const client = new Client(pg_credentials);
|
||||
client.connect();
|
||||
|
||||
client.connect().catch(() => {
|
||||
client.end();
|
||||
});
|
||||
|
||||
// query & terminate
|
||||
client.query(query, (err, res) => {
|
||||
console.log(err, res);
|
||||
client.end();
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
function _pgExecTest(query, retryCount = 60) {
|
||||
return new Promise((resolve, reject) => {
|
||||
// open pg client connection
|
||||
const client = new Client(pg_credentials);
|
||||
|
||||
client.connect().catch(() => {
|
||||
client.end();
|
||||
});
|
||||
|
||||
// query & terminate
|
||||
client.query(query, (err, res) => {
|
||||
if (err) {
|
||||
if (retryCount--)
|
||||
return setTimeout(() => _pgExecTest(query, retryCount).then(resolve).catch(reject), 2000);
|
||||
else
|
||||
reject(err);
|
||||
}
|
||||
|
||||
console.log('==== success ===', res);
|
||||
resolve(true);
|
||||
client.end();
|
||||
});
|
||||
if (err) {
|
||||
if (retryCount--)
|
||||
return setTimeout(
|
||||
() => _pgExecTest(query, retryCount).then(resolve).catch(reject),
|
||||
2000
|
||||
);
|
||||
else reject(err);
|
||||
}
|
||||
|
||||
console.log("==== success ===", res);
|
||||
resolve(true);
|
||||
client.end();
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -4,10 +4,10 @@ const fs = require("fs");
|
||||
const XLSX = require("xlsx");
|
||||
|
||||
const read = ({ file, sheet }) => {
|
||||
const buf = fs.readFileSync(file);
|
||||
const workbook = XLSX.read(buf, { type: "buffer" });
|
||||
const rows = XLSX.utils.sheet_to_json(workbook.Sheets[sheet]);
|
||||
return rows;
|
||||
const buf = fs.readFileSync(file);
|
||||
const workbook = XLSX.read(buf, { type: "buffer" });
|
||||
const rows = XLSX.utils.sheet_to_json(workbook.Sheets[sheet]);
|
||||
return rows;
|
||||
};
|
||||
|
||||
// const read = ({file, sheet}) => {
|
||||
@@ -21,13 +21,13 @@ const read = ({ file, sheet }) => {
|
||||
// }
|
||||
|
||||
const sheetList = ({ file }) => {
|
||||
const buf = fs.readFileSync(file);
|
||||
const workbook = XLSX.read(buf, { type: "buffer" });
|
||||
const rows = workbook.SheetNames;
|
||||
return rows;
|
||||
const buf = fs.readFileSync(file);
|
||||
const workbook = XLSX.read(buf, { type: "buffer" });
|
||||
const rows = workbook.SheetNames;
|
||||
return rows;
|
||||
};
|
||||
|
||||
module.exports = {
|
||||
read,
|
||||
sheetList,
|
||||
read,
|
||||
sheetList,
|
||||
};
|
||||
|
||||
@@ -1,65 +1,64 @@
|
||||
|
||||
// https://glebbahmutov.com/blog/restart-server/
|
||||
|
||||
const express = require('express')
|
||||
const bodyParser = require("body-parser")
|
||||
const express = require("express");
|
||||
const bodyParser = require("body-parser");
|
||||
|
||||
let request = []
|
||||
let request = [];
|
||||
|
||||
function makeServer() {
|
||||
const app = express()
|
||||
app.use(bodyParser.json())
|
||||
const app = express();
|
||||
app.use(bodyParser.json());
|
||||
|
||||
app.get("/hook/all", (req, res) => {
|
||||
// console.log(request)
|
||||
res.json(request)
|
||||
})
|
||||
res.json(request);
|
||||
});
|
||||
app.get("/hook/last", (req, res) => {
|
||||
if(request.length) {
|
||||
if (request.length) {
|
||||
// console.log(request[request.length - 1])
|
||||
res.json(request[request.length - 1])
|
||||
res.json(request[request.length - 1]);
|
||||
}
|
||||
})
|
||||
});
|
||||
app.get("/hook/count", (req, res) => {
|
||||
// console.log(request.length)
|
||||
res.json(request.length)
|
||||
})
|
||||
res.json(request.length);
|
||||
});
|
||||
app.get("/hook/clear", (req, res) => {
|
||||
request = []
|
||||
res.status(200).end()
|
||||
})
|
||||
request = [];
|
||||
res.status(200).end();
|
||||
});
|
||||
|
||||
app.post("/hook", (req, res) => {
|
||||
request.push(req.body)
|
||||
request.push(req.body);
|
||||
// console.log("/hook :: ", req.body) // Call your action on the request here
|
||||
res.status(200).end() // Responding is important
|
||||
})
|
||||
res.status(200).end(); // Responding is important
|
||||
});
|
||||
|
||||
app.post("/stop", (req, res) => {
|
||||
process.exit();
|
||||
})
|
||||
});
|
||||
|
||||
const port = 9090
|
||||
const port = 9090;
|
||||
|
||||
return new Promise((resolve) => {
|
||||
const server = app.listen(port, function () {
|
||||
const port = server.address().port
|
||||
console.log('Example app listening at port %d', port)
|
||||
const port = server.address().port;
|
||||
console.log("Example app listening at port %d", port);
|
||||
|
||||
// close the server
|
||||
const close = () => {
|
||||
return new Promise((resolve) => {
|
||||
console.log('closing server')
|
||||
server.close(resolve)
|
||||
})
|
||||
}
|
||||
console.log("closing server");
|
||||
server.close(resolve);
|
||||
});
|
||||
};
|
||||
|
||||
resolve({ server, port, close })
|
||||
})
|
||||
})
|
||||
resolve({ server, port, close });
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
module.exports = makeServer
|
||||
module.exports = makeServer;
|
||||
|
||||
/**
|
||||
* @copyright Copyright (c) 2021, Xgene Cloud Ltd
|
||||
|
||||
Reference in New Issue
Block a user