import { Request, Response } from "express" import { SimUsecases } from "./Sim.usecases.js" import { activationValidator, iccidValidator } from "./httpValidators.js" import { companyFromIccid } from "#domain/companies.js" import { BodyValidator } from "sim-shared/aplication/BodyValidator.js" export class SimController { private simUseCases: SimUsecases constructor(args: { simUseCases: SimUsecases, }) { this.simUseCases = args.simUseCases this.activation = this.activation.bind(this) } /** * TODO: * En proceso, tiene varios problemas * * Abstrae el proceso de * Peticion -> validacion del body -> map del body -> useCase -> OK/ERR * * Representa el dato original *

Representa el dato después del mapeo */ public controllerGenerator(args: { validator?: BodyValidator, mapBody?: (body: O) => P, useCase: (args: P) => Promise, onError: (args: O | P, error: string) => void, onSuccess: (args: P) => void, }) { return async (req: Request, res: Response) => { const body = req.body // 1. Validacion del body try { if (args.validator != undefined) args.validator.validate(body) } catch (e) { if (args.onError != undefined) args.onError(body, e as string) res.status(422).json({ errors: { msg: e } }) } // 2. Transformacion del body let data: P = body; try { if (args.mapBody != undefined) data = args.mapBody(body) } catch (e) { res.status(422).json({ errors: { msg: "Error parseando el body: " + e } }) } // 3. Aplicacion del UseCase try { const usecaseResult = await args.useCase(data) // 4. Se devuelve al usuario el caso de exito res.status(200).json( usecaseResult ).send() args.onSuccess(data) } catch (err) { // 4.1 Error del caso de uso res.status(500).json({ errors: { msg: "Error general:" + err } }).send() return; } } } public test() { return this.controllerGenerator<{ iccid: string, offer: string }, { iccid: string }>({ validator: iccidValidator, useCase: (args) => this.simUseCases.test(args), onError: (data, error) => console.error(error), onSuccess: (data) => { console.log("OK", data) } }) } public preactivation() { return async (req: Request, res: Response) => { console.warn("[!] Se deberia de usar la peticion /sim/activate directamente") try { iccidValidator.validate(req.body) } catch (e) { res.status(422).json({ errors: { msg: e } }) } const { iccid } = req.body const compañia = companyFromIccid(iccid) try { await this.simUseCases.preActivation({ iccid, compañia }) res.status(200).json({ iccid: iccid, operation: "activation" }).send() } catch (err) { console.error("Error activando la sim ", req.body) res.status(500).json({ errors: { msg: "Error general de activation" } }).send() return; } } } public activation() { return async (req: Request, res: Response) => { try { activationValidator.validate(req.body) } catch (e) { res.status(422).json({ errors: { msg: e } }) console.error("[!] Error validando mensaje") return; } const { iccid, offer } = req.body const compañia = companyFromIccid(iccid) if (compañia == undefined) { res.status(500).json({ errors: { msg: "El iccid no pertenece a una compañia conocida" } }) return; } try { await this.simUseCases.activation({ iccid, compañia, offer }) res.status(200).json({ iccid: iccid, operation: "activation" }).send() return; } catch (err) { console.error("Error activando la sim ", req.body) res.status(500).json({ errors: { msg: "Error general de activation" } }).send() return; } } } public cancelation() { return async (req: Request, res: Response) => { try { iccidValidator.validate(req.body) } catch (e) { res.status(422).json({ errors: { msg: e } }) } const { iccid } = req.body const compañia = companyFromIccid(iccid) try { await this.simUseCases.cancelation({ iccid, compañia }) res.status(200).json({ iccid: iccid, operation: "cancelation" }) } catch (err) { console.error("Error cancelando la sim ", req.body) res.status(500).json({ errors: { msg: "Error general de cancelacion" } }) } } } public pause() { return async (req: Request, res: Response) => { try { iccidValidator.validate(req.body) } catch (e) { res.status(422).json({ errors: { msg: e } }) } const { iccid } = req.body const compañia = companyFromIccid(iccid) try { await this.simUseCases.pause({ iccid, compañia }) res.status(200).json({ iccid: iccid, operation: "cancelation" }) } catch (err) { console.error("Error pausando la sim ", req.body) res.status(500).json({ errors: { msg: "Error pausando la sim" } }) } } } public free() { return async (req: Request, res: Response) => { try { iccidValidator.validate(req.body) } catch (e) { res.status(422).json({ errors: { msg: e } }) } const { iccid } = req.body const compañia = companyFromIccid(iccid) try { await this.simUseCases.cancelation({ iccid, compañia }) res.status(200).json({ iccid: iccid, operation: "liberacion" }) } catch (err) { console.error("Error liberando la sim ", req.body) res.status(500).json({ errors: { msg: "Error general de liberacion" } }) } } } public save() { return async (req: Request, res: Response) => { try { iccidValidator.validate(req.body) } catch (e) { res.status(422).json({ errors: { msg: e } }) } const { iccid } = req.body const compañia = companyFromIccid(iccid) try { await this.simUseCases.cancelation({ iccid, compañia }) res.status(200).json({ iccid: iccid, operation: "cancelation" }) } catch (err) { console.error("Error activando la sim ", req.body) res.status(500).json({ errors: { msg: "Error general de activation" } }) } } } }