mirror of
https://github.com/dadosfera/maestro.git
synced 2026-09-07 03:34:49 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
faf6b1df75 | ||
|
|
422be4a422 | ||
|
|
da136e0ef0 | ||
|
|
737cc9b8ea | ||
|
|
23f6b179fd | ||
|
|
03e451c21d | ||
|
|
2646e3e4f6 |
+2
-10
@@ -1544,24 +1544,16 @@
|
||||
}
|
||||
},
|
||||
"info": {
|
||||
"title": "Maestro - fix/upload-files",
|
||||
"title": "Maestro - fix/delete-connector",
|
||||
"description": "This is the Maestro API",
|
||||
"version": "1.0.0",
|
||||
"contact": {}
|
||||
},
|
||||
"tags": [],
|
||||
"servers": [
|
||||
{
|
||||
"url": "https://maestro.stg.dadosfera.ai",
|
||||
"description": "Ambiente STG"
|
||||
},
|
||||
{
|
||||
"url": "https://maestro-2.stg.dadosfera.ai",
|
||||
"description": "Ambiente STG2"
|
||||
},
|
||||
{
|
||||
"url": "https://maestro.dadosfera.ai",
|
||||
"description": "Ambiente PRD"
|
||||
"description": "Dadosfera API"
|
||||
}
|
||||
],
|
||||
"components": {
|
||||
|
||||
+2
-15
@@ -4716,26 +4716,13 @@
|
||||
}
|
||||
},
|
||||
"info": {
|
||||
"title": "Maestro - fix/upload-files",
|
||||
"title": "Maestro - fix/delete-connector",
|
||||
"description": "This is the Maestro API",
|
||||
"version": "1.0.0",
|
||||
"contact": {}
|
||||
},
|
||||
"tags": [],
|
||||
"servers": [
|
||||
{
|
||||
"url": "https://maestro.stg.dadosfera.ai",
|
||||
"description": "Ambiente STG"
|
||||
},
|
||||
{
|
||||
"url": "https://maestro-2.stg.dadosfera.ai",
|
||||
"description": "Ambiente STG2"
|
||||
},
|
||||
{
|
||||
"url": "https://maestro.dadosfera.ai",
|
||||
"description": "Ambiente PRD"
|
||||
}
|
||||
],
|
||||
"servers": [],
|
||||
"components": {
|
||||
"securitySchemes": {
|
||||
"access-token": {
|
||||
|
||||
+7
-6
@@ -42,7 +42,7 @@ function configureSwagger(app: INestApplication) {
|
||||
}
|
||||
const swaggerTitle = branchName ? `Maestro - ${branchName}` : 'Maestro';
|
||||
|
||||
const config = new DocumentBuilder()
|
||||
const swaggerConfig = new DocumentBuilder()
|
||||
.setTitle(swaggerTitle)
|
||||
.setDescription('Documentation for Maestro gateway')
|
||||
.addSecurity('access-token', {
|
||||
@@ -50,11 +50,12 @@ function configureSwagger(app: INestApplication) {
|
||||
name: 'Authorization',
|
||||
in: 'header',
|
||||
})
|
||||
.setDescription('This is the Maestro API')
|
||||
.addServer('https://maestro.stg.dadosfera.ai', 'Ambiente STG')
|
||||
.addServer('https://maestro-2.stg.dadosfera.ai', 'Ambiente STG2')
|
||||
.addServer('https://maestro.dadosfera.ai', 'Ambiente PRD')
|
||||
.build();
|
||||
.setDescription('This is the Maestro API');
|
||||
|
||||
if (process.env.INTERNAL_SWAGGER !== 'true')
|
||||
swaggerConfig.addServer('https://maestro.dadosfera.ai', 'Dadosfera API');
|
||||
|
||||
const config = swaggerConfig.build();
|
||||
|
||||
const document = SwaggerModule.createDocument(app, config);
|
||||
|
||||
|
||||
@@ -273,16 +273,13 @@ export class ConnectorController {
|
||||
@Param('plugin') plugin: string,
|
||||
@Query('version') version: string,
|
||||
) {
|
||||
this.logger.info('/upload - Upload Connector Route');
|
||||
this.logger.info('DELETE /:plugin - Delete Connector Route');
|
||||
|
||||
const response: any = await this.connectorClientService.deleteConnector(
|
||||
const response = await this.connectorClientService.deleteConnector(
|
||||
plugin,
|
||||
version,
|
||||
);
|
||||
|
||||
return {
|
||||
message: response.message || 'ok',
|
||||
connector: { ...JSON.parse(response.connector) },
|
||||
};
|
||||
return { message: response.message, connector: response.connector };
|
||||
}
|
||||
}
|
||||
|
||||
@@ -233,15 +233,23 @@ export class PipelinesService implements OnModuleInit {
|
||||
const config_controls = (connector.config_controls || []).filter(
|
||||
(config_control) => {
|
||||
const path: string = config_control.name;
|
||||
|
||||
if (!objHasPath({ object: { properties }, path })) return false;
|
||||
|
||||
const default_value = getObjValueFromPath({
|
||||
let default_value = getObjValueFromPath({
|
||||
object: { properties },
|
||||
path,
|
||||
});
|
||||
if (default_value != undefined)
|
||||
|
||||
if (default_value != undefined) {
|
||||
if (
|
||||
path === 'properties.spreadsheet_id' &&
|
||||
typeof default_value === 'string'
|
||||
)
|
||||
default_value = 'https://docs.google.com/spreadsheets/d/'.concat(
|
||||
default_value,
|
||||
);
|
||||
config_control.default_value = default_value;
|
||||
}
|
||||
|
||||
return true;
|
||||
},
|
||||
@@ -251,7 +259,7 @@ export class PipelinesService implements OnModuleInit {
|
||||
pipeline: {
|
||||
...pipeline,
|
||||
config_controls,
|
||||
properties: properties,
|
||||
properties,
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
@@ -1,4 +1,7 @@
|
||||
export function getObjValueFromPath<T>(data: { object: T; path: string }): T {
|
||||
export function getObjValueFromPath<T extends object>(data: {
|
||||
object: T;
|
||||
path: string;
|
||||
}): any {
|
||||
const { object, path } = data;
|
||||
const keys = path.split('.');
|
||||
|
||||
|
||||
Reference in New Issue
Block a user