b.santos/cloud-cap-samples
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

changing tests. removing importData func

Browse Source
This commit is contained in:
Dzmitry_Tamashevich@epam.com
2020-11-25 23:05:10 +03:00
committed by Daniel Hutzel
parent 029ba61098
commit a04cc0c25f
10 changed files with 241 additions and 600 deletions
Download Patch File Download Diff File Expand all files Collapse all files

141
media-store/util/importData.js
View File

@@ -1,141 +0,0 @@
const cds = require("@sap/cds");
const bcrypt = require("bcryptjs");
const saltRounds = 10;
const FIRST_INDEX = 0;
const ZERO_VALUE = 0;
const SECOND_INDEX = 1;
const ID_IF_NOT_FOUND = "ID";
const SRC_STORAGE_NAME = "sqlite:chinook.db";
const camelCaseToSnake = (str) =>
str.replace(
/[a-z][A-Z]/g,
(letters) =>
`${letters[FIRST_INDEX].toLowerCase()}_${letters[
SECOND_INDEX
].toLowerCase()}`
);
const omitID = (str) => {
return str.replace(/_ID$/g, "");
};
const omitId = (str) => {
return str.replace(/Id$/g, "");
};
const chooseFromTargetColumns = (targetColumns) => {
return (srcColumn) => {
const result = targetColumns.find((targetColumn) => {
const one = omitId(srcColumn).toUpperCase();
const two = omitID(targetColumn).toUpperCase();
if (one === two) {
return true;
}
return false;
});
return result ? result : ID_IF_NOT_FOUND;
};
};
const reorderTargetColumns = (srcColumns, targetColumns) => {
const mapColumn = chooseFromTargetColumns(targetColumns);
return srcColumns.map(mapColumn);
};
const elementsToColumns = (elements) => {
return Object.values(elements).map((element) =>
element.target ? `${element.name}_ID` : element.name
);
};
const constructInsertQuery = (targetEntityName) => {
return (row, columns) =>
INSERT.into(targetEntityName).columns(columns).rows(row);
};
/**
* The MAIN ISSUE such import is that it depends on:
* - snake case table names
* - camel case column names
* of chinook.db
* There is 'Launch import' task in .vscode folder for debugging.
*/
async function importData(targetDb) {
try {
const targetCSNEntitiesNames = Object.keys(targetDb.entities);
const someEntry = await targetDb.run(
SELECT.one(targetCSNEntitiesNames[FIRST_INDEX])
);
if (!!someEntry) {
return;
}
const targetCSNEntities = Object.values(targetDb.entities);
const srcStorage = await cds.connect.to(SRC_STORAGE_NAME);
const hashedPassword = await new Promise((resolve, reject) =>
bcrypt.hash("some", saltRounds, (error, hash) => {
if (error) {
reject(error);
}
resolve(hash);
})
);
console.log("hashedPassword", hashedPassword);
for (index in targetCSNEntities) {
const targetEntityName = targetCSNEntitiesNames[index];
console.log(`[LOG]: Processing ${targetEntityName}`);
const { elements } = targetCSNEntities[index];
const targetColumns = elementsToColumns(elements); // e.g. ['ID', ..., 'total', 'customer_ID']
const srcEntityName = camelCaseToSnake(targetEntityName);
const insertQuery = constructInsertQuery(targetEntityName);
let srcResultRows;
try {
srcResultRows = await srcStorage.run(`
SELECT * from ${srcEntityName}
`); // e.g. [ { AlbumId:1, ArtistId:1, Title:'some' }, ... ]
} catch (e) {
console.log("[ERROR]: while trying to read source table", e.message);
continue;
}
if (!srcResultRows || srcResultRows.length < ZERO_VALUE) {
console.log(
`[LOG] Skipping ${targetEntityName}.
There is no data provided in ${SRC_STORAGE_NAME}, ${srcEntityName}`
);
continue;
}
const srcColumns = Object.keys(srcResultRows[FIRST_INDEX]);
const columns = reorderTargetColumns(srcColumns, targetColumns);
if (new Set(columns).size !== columns.length) {
throw new Error(
`Some ${targetEntityName} column name is mismatched in ${SRC_STORAGE_NAME} ${srcEntityName}`
);
}
// for mock auth
if (srcEntityName === "Employees" || srcEntityName === "Customers") {
columns.push("password");
srcResultRows = srcResultRows.map((row) => ({
...row,
password: hashedPassword,
}));
}
const transaction = await targetDb.tx();
await transaction.run(
srcResultRows.map((row) => insertQuery(Object.values(row), columns))
);
await transaction.commit();
}
console.log("[LOG]: ", "Import completed");
} catch (errors) {
console.error(errors);
}
}
module.exports = { importData };