mirror of
https://github.com/dadosfera/maestro.git
synced 2026-09-10 10:04:49 +00:00
72 lines
2.1 KiB
TypeScript
72 lines
2.1 KiB
TypeScript
import { Body, Controller, Delete, Get, Param, Post, Put, Redirect } from '@nestjs/common';
|
|
import { Payload } from '@nestjs/microservices';
|
|
import axios from 'axios';
|
|
import { Console } from 'console';
|
|
import { CreateInputGrpcClientDto } from './dto/create-input-grpc-client.dto';
|
|
import { UpdateInputGrpcClientDto } from './dto/update-input-grpc-client.dto';
|
|
|
|
@Controller('input')
|
|
export class InputRestClientController {
|
|
|
|
|
|
@Get('/test-connection/')
|
|
async testConnection(){
|
|
console.log(process.env.DEV_URL+`/test-connection`, "ON TEST CONNECTION ROUTE")
|
|
await axios.get(process.env.DEV_URL+`/test-connection`).then( (response) => {
|
|
return response
|
|
})
|
|
}
|
|
|
|
@Post()
|
|
async create(@Body() createInputDto: CreateInputGrpcClientDto){
|
|
console.log(createInputDto)
|
|
console.log(process.env.DEV_URL+`/input`, "ON CREATE ROUTE")
|
|
|
|
await axios.post(process.env.DEV_URL+'/input',createInputDto).then( (response) => {
|
|
return response
|
|
})
|
|
}
|
|
|
|
@Get()
|
|
async list(){
|
|
console.log(process.env.DEV_URL+`/input`, "ON GET ROUTE")
|
|
await axios.get(process.env.DEV_URL+`/input`).then( (response) => {
|
|
return response
|
|
})
|
|
}
|
|
|
|
|
|
@Get('/:id')
|
|
async show(@Param() id: string){
|
|
console.log(process.env.DEV_URL+`/input/${id}`, "ON SHOW ROUTE")
|
|
await axios.get(process.env.DEV_URL+`/input/${id}`).then( (response) => {
|
|
return response
|
|
})
|
|
}
|
|
|
|
|
|
@Put(':id')
|
|
async update(
|
|
@Payload() updateInputDto: UpdateInputGrpcClientDto,
|
|
@Param() id: string,
|
|
){
|
|
console.log(process.env.DEV_URL+`/input/${id}`, "ON UPDATE ROUTE")
|
|
await axios.put(process.env.DEV_URL+`input/${id}`,updateInputDto).then( (response) => {
|
|
return response
|
|
})
|
|
}
|
|
|
|
|
|
@Delete(':id')
|
|
async delete(@Param() id: string){
|
|
console.log(process.env.DEV_URL+`/input/${id}`, "ON DELETE ROUTE")
|
|
|
|
await axios.delete(process.env.DEV_URL+`/input/${id}`).then( (response) => {
|
|
return response
|
|
})
|
|
}
|
|
|
|
|
|
|
|
}
|