// // SpecCtrl.swift // // // Created by Michiel Carman on 11/9/21. // import Foundation import Vapor import Fluent import FluentPostgresDriver final class SpecCtrl{ //Create Unit func create(req: Request) throws -> EventLoopFuture{ let input = try req.content.decode(mdlSpec.Input.self) let output = self.createUnit(input) return self.save(output, req, input) } //Update Unit func update(req: Request) throws -> EventLoopFuture{ let input = try req.content.decode(mdlSpec.Input.self) return try qbase(req: req).first().unwrap(or: Abort(.notFound)).flatMap{output in self.mapOutput(output, input) return self.save(output, req: req) } } //Get all Divisions func readAll(req: Request) throws -> EventLoopFuture>{ return try qbase(req: req) .paginate(for: req) .map{ page in page.map{ self.createRead($0) } } } //Get 1 Division func read(req: Request) throws -> EventLoopFuture{ return try qbase(req: req).first().unwrap(or: Abort(.internalServerError)).map{self.createRead($0)} } //Delete 1 Division func delete(req: Request) throws -> EventLoopFuture{ guard let id = req.parameters.get("id", as: Int.self) else{ throw Abort(.badRequest) } return mdlSpec.find(id, on: req.db).unwrap(or: Abort(.notFound)).flatMap{ $0.delete(on: req.db)}.map{.ok} } } extension SpecCtrl{ //Query Settings func qbase(req: Request) throws -> QueryBuilder { let query = mdlSpec.query(on: req.db) .with(\.$item) .with(\.$specitems) .with(\.$templatecategoryitemspecs) if let id = req.parameters.get("id", as: Int.self){ return query.filter(\.$id == id) } else{ return query } } //create Output func createRead(_ output: mdlSpec) -> mdlSpec.Output { return mdlSpec.Output( id: output.id!, name: output.name, numberoftests: output.numberoftests, isactive: output.isactive, createdate: output.createdate, createuserid: output.createuserid, updatedate: output.updatedate, updateuserid: output.updateuserid, item: output.$item.value!, specitems: output.$specitems.value!, templatecategoryitemspecs: output.$templatecategoryitemspecs.value! ) } func mapOutput(_ output: Optional.WrappedType, _ input: mdlSpec.Input){ output.name = input.name; output.numberoftests = input.numberoftests; output.isactive = input.isactive; output.createdate = input.createdate; output.updatedate = input.updatedate; output.createuserid = input.createuserid; output.updateuserid = input.updateuserid; output.$item.id = input.item.id!; output.$specitems.value = input.specitems!; output.$templatecategoryitemspecs.value = input.templatecategoryitemspecs!; } func createUnit(_ input: mdlSpec.Input) -> mdlSpec { return mdlSpec( id: input.id ?? nil , name: input.name , numberoftests: input.numberoftests , isactive: input.isactive , createuserid: input.createuserid ?? -1 , createdate: input.createdate , updateuserid: input.updateuserid ?? -1 , updatedate: input.updatedate , item: input.item , specitems: input.specitems , templatecategoryitemspecs: input.templatecategoryitemspecs ) } //update function func save(_ output: Optional.WrappedType, req: Request) -> EventLoopFuture { return output .save(on: req.db) .map{mdlSpec.Output( id: output.id! , name: output.name , numberoftests: output.numberoftests , isactive: output.isactive , createdate: output.createdate , createuserid: output.createuserid , updatedate: output.updatedate , updateuserid: output.updateuserid , item: output.item , specitems: output.specitems , templatecategoryitemspecs: output.templatecategoryitemspecs ) } } //create function func save(_ output: mdlSpec, _ req: Request, _ input: mdlSpec.Input) -> EventLoopFuture { return output .save(on: req.db) .map{ mdlSpec.Output( id: output.id! , name: output.name , numberoftests: output.numberoftests , isactive: output.isactive , createdate: output.createdate , createuserid: output.createuserid , updatedate: output.updatedate , updateuserid: output.updateuserid , item: input.item , specitems: input.specitems , templatecategoryitemspecs: input.templatecategoryitemspecs ) } } } extension SpecCtrl: RouteCollection{ func boot(routes: RoutesBuilder) throws{ let apigroup = routes.grouped("specs") apigroup.get("", use: readAll) apigroup.get(":id", use: read) apigroup.post("", use: create) apigroup.post(":id", use: update) apigroup.delete(":id", use: delete) } }