import { Authorized, Body, Delete, Get, JsonController, OnUndefined, Param, Post, Put } from 'routing-controllers'; import { OpenAPI, ResponseSchema } from 'routing-controllers-openapi'; import { getConnectionManager, Repository } from 'typeorm'; import { EntityFromBody } from 'typeorm-routing-controllers-extensions'; import { TrackIdsNotMatchingError, TrackNotFoundError } from "../errors/TrackErrors"; import { CreateTrack } from '../models/actions/CreateTrack'; import { Track } from '../models/entities/Track'; import { ResponseEmpty } from '../models/responses/ResponseEmpty'; import { ResponseTrack } from '../models/responses/ResponseTrack'; @JsonController('/tracks') @OpenAPI({ security: [{ "AuthToken": [] }] }) export class TrackController { private trackRepository: Repository; /** * Gets the repository of this controller's model/entity. */ constructor() { this.trackRepository = getConnectionManager().get().getRepository(Track); } @Get() @Authorized("TRACK:GET") @ResponseSchema(ResponseTrack, { isArray: true }) async getAll() { let responseTracks: ResponseTrack[] = new Array(); const tracks = await this.trackRepository.find(); tracks.forEach(track => { responseTracks.push(new ResponseTrack(track)); }); return responseTracks; } @Get('/:id') @Authorized("TRACK:GET") @ResponseSchema(ResponseTrack) @ResponseSchema(TrackNotFoundError, { statusCode: 404 }) @OnUndefined(TrackNotFoundError) @OpenAPI({ description: "Returns a track of a specified id (if it exists)" }) async getOne(@Param('id') id: number) { let track = await this.trackRepository.findOne({ id: id }); if (!track) { throw new TrackNotFoundError(); } return new ResponseTrack(track); } @Post() @Authorized("TRACK:CREATE") @ResponseSchema(ResponseTrack) @OpenAPI({ description: "Create a new track object (id will be generated automagicly)." }) async post( @Body({ validate: true }) track: CreateTrack ) { return new ResponseTrack(await this.trackRepository.save(track.toTrack())); } @Put('/:id') @Authorized("TRACK:UPDATE") @ResponseSchema(ResponseTrack) @ResponseSchema(TrackNotFoundError, { statusCode: 404 }) @ResponseSchema(TrackIdsNotMatchingError, { statusCode: 406 }) @OpenAPI({ description: "Update a track object (id can't be changed)." }) async put(@Param('id') id: number, @EntityFromBody() track: Track) { let oldTrack = await this.trackRepository.findOne({ id: id }); if (!oldTrack) { throw new TrackNotFoundError(); } if (oldTrack.id != track.id) { throw new TrackIdsNotMatchingError(); } await this.trackRepository.save(track); return new ResponseTrack(track); } @Delete('/:id') @Authorized("TRACK:DELETE") @ResponseSchema(ResponseTrack) @ResponseSchema(ResponseEmpty, { statusCode: 204 }) @OnUndefined(204) @OpenAPI({ description: "Delete a specified track (if it exists)." }) async remove(@Param("id") id: number) { let track = await this.trackRepository.findOne({ id: id }); if (!track) { return null; } await this.trackRepository.delete(track); return new ResponseTrack(track); } }