Compare commits

...
9 Commits
4 changed files with 166 additions and 9337 deletions
+1 -1
View File
@@ -1,4 +1,4 @@
<p align="center">
<image src="./assets/maestro.svg" style="width:10rem">
<h1 align="center">Maestro</h1>
</p>
</p>
+13 -9217
View File
File diff suppressed because it is too large Load Diff
+33
View File
@@ -140,6 +140,17 @@ export class CatalogController {
return res;
}
@Get('data-status')
async createDataStatus(@Body() body) {
console.log(`/catalog`, 'ON CREATE DATA STATUS ROUTE');
const catalogService = new CatalogService();
const res = await catalogService.createDataStatus(body);
return res;
}
@Get('data-description')
async getDataDescription(@Body() body) {
console.log(`/catalog`, 'ON GET DATA DESCRIPTION ROUTE');
@@ -151,6 +162,17 @@ export class CatalogController {
return res;
}
@Post('data-description')
async createDataDescription(@Body() body) {
console.log(`/catalog`, 'ON CREATE DATA DESCRIPTION ROUTE');
const catalogService = new CatalogService();
const res = await catalogService.createDataDescription(body);
return res;
}
@Get('data-docs')
async getDataDocs(@Body() body) {
console.log(`/catalog`, 'ON GET DATA DOCS ROUTE');
@@ -162,6 +184,17 @@ export class CatalogController {
return res;
}
@Post('data-docs')
async createDataDocs(@Body() body) {
console.log(`/catalog`, 'ON CREATE DATA DOCS ROUTE');
const catalogService = new CatalogService();
const res = await catalogService.createDataDocs(body);
return res;
}
@Get('data-rating')
async getDataRating(@Body() body) {
console.log(`/catalog`, 'ON GET DATA RATING ROUTE');
+119 -119
View File
@@ -9,10 +9,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/all/`);
@@ -27,10 +25,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data_apps/`);
return data;
@@ -44,14 +40,13 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/data_apps/${id}/`,
);
return data;
}
@@ -63,10 +58,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/dashboard-metabase/`,
@@ -82,18 +75,17 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/dashboard-metabase/${id}`,
);
console.log(data);
const [, path] = data.iframe_url.split('.dadosfera');
const host = `https://metabase-${body.info.customer.toLowerCase()}.dadosfera.ai`;
data.iframe_url = host + path;
// const [, path] = data.iframe_url.split('.dadosfera');
// const host = `httpss://metabase-${body.info.customer.toLowerCase()}.dadosfera.ai`;
// data.iframe_url = host + path;
return data;
}
@@ -106,10 +98,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-metadata/`,
@@ -125,10 +115,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-metadata/`,
@@ -145,10 +133,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-metadata/${id}`,
@@ -164,10 +150,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/column-metadata/`,
@@ -184,10 +168,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/column-metadata/${id}/`,
@@ -203,10 +185,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data-preview/`, {
params: params,
@@ -222,15 +202,31 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data-status/`);
return data;
}
async createDataStatus(body) {
const customer =
body.info.customer.toLowerCase() === 'dadosfera'
? ``
: `-${body.info.customer.toLowerCase()}`;
const nimbusUrl =
process.env.ENV === 'prd'
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.post(
`${nimbusUrl}/api/catalog/data-status/`,
body,
);
return data;
}
async getDataDescription(body) {
const customer =
body.info.customer.toLowerCase() === 'dadosfera'
@@ -239,10 +235,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/data-description/`,
@@ -250,6 +244,24 @@ class CatalogService {
return data;
}
async createDataDescription(body) {
const customer =
body.info.customer.toLowerCase() === 'dadosfera'
? ``
: `-${body.info.customer.toLowerCase()}`;
const nimbusUrl =
process.env.ENV === 'prd'
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.post(
`${nimbusUrl}/api/catalog/data-description/`,
body,
);
return data;
}
async getDataDocs(body) {
const customer =
body.info.customer.toLowerCase() === 'dadosfera'
@@ -258,15 +270,31 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data-docs/`);
return data;
}
async createDataDocs(body) {
const customer =
body.info.customer.toLowerCase() === 'dadosfera'
? ``
: `-${body.info.customer.toLowerCase()}`;
const nimbusUrl =
process.env.ENV === 'prd'
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.post(
`${nimbusUrl}/api/catalog/data-docs/`,
body,
);
return data;
}
async getDataRating(body) {
const customer =
body.info.customer.toLowerCase() === 'dadosfera'
@@ -275,10 +303,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data-rating/`);
return data;
@@ -292,12 +318,10 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
const { data } = await axios.post(
`${nimbusUrl}/api/catalog/data-rating/`,
body,
);
@@ -312,10 +336,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/summary-rating/${id}`,
@@ -331,10 +353,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data-comment/`);
return data;
@@ -348,12 +368,10 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
const { data } = await axios.post(
`${nimbusUrl}/api/catalog/data-comment/`,
body,
);
@@ -368,10 +386,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/data-review/`, {
params: params,
@@ -387,12 +403,10 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/tags/`, body);
const { data } = await axios.post(`${nimbusUrl}/api/catalog/tags/`, body);
return data;
}
@@ -404,10 +418,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/tags/`, body);
return data;
@@ -421,10 +433,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-tags/`,
@@ -441,10 +451,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(`${nimbusUrl}/api/catalog/tags/${id}`);
return data;
@@ -458,12 +466,10 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
const { data } = await axios.post(
`${nimbusUrl}/api/catalog/table-tags/`,
body,
);
@@ -478,10 +484,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-tags/${id}`,
@@ -497,10 +501,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-rules/`,
@@ -517,10 +519,8 @@ class CatalogService {
const nimbusUrl =
process.env.ENV === 'prd'
? `${
process.env.NIMBUS_BASE_URL
}-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `http://nimbus-api${customer}.${process.env.ENV}.dadosfera`;
? `https://nimbus-${body.info.customer.toLowerCase()}.dadosfera.ai`
: `${process.env.NIMBUS_BASE_URL}${customer}.${process.env.ENV}.dadosfera`;
const { data } = await axios.get(
`${nimbusUrl}/api/catalog/table-rules/${id}`,