equipo-programa a espera de pruebas

src/equipo-programa/equipo-programa.service.ts

@@ -1,12 +1,56 @@
-import { Injectable } from '@nestjs/common';
+import { ConflictException, Injectable } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
 import { Repository } from 'typeorm';
+import { Equipo } from 'src/equipo/entity/equipo.entity';
 import { EquipoPrograma } from './entity/equipo-programa.entity';
+import { Programa } from 'src/institucion-programa/entity/programa.entity';
+import { EquipoService } from '../equipo/equipo.service';
+import { InstitucionProgramaService } from '../institucion-programa/institucion-programa.service';
 
 @Injectable()
 export class EquipoProgramaService {
   constructor(
     @InjectRepository(EquipoPrograma)
-    private equipoProgramaRepository: Repository<EquipoPrograma>,
+    private repository: Repository<EquipoPrograma>,
+    private equipoService: EquipoService,
+    private institucionProgramaService: InstitucionProgramaService,
   ) {}
+
+  async create(id_equipo: number, id_programa: number) {
+    const equipo = await this.equipoService.findById(id_equipo);
+    const programa = await this.institucionProgramaService.findProgramaById(
+      id_programa,
+    );
+
+    return this.existeEquipoPrograma(equipo, programa).then(() =>
+      this.repository.save(this.repository.create({ equipo, programa })),
+    );
+  }
+
+  delete(id_equipo_programa: number) {
+    return this.findById(id_equipo_programa).then((equipoPrograma) =>
+      this.repository.remove(equipoPrograma),
+    );
+  }
+
+  existeEquipoPrograma(equipo: Equipo, programa: Programa) {
+    return this.repository
+      .findOne({ equipo, programa })
+      .then((equipoPrograma) => {
+        if (equipoPrograma)
+          throw new ConflictException(
+            'Ya existe un equipo programa con este equipo y este programa.',
+          );
+      });
+  }
+
+  findById(id_equipo_programa: number) {
+    return this.repository
+      .findOne({ id_equipo_programa })
+      .then((equipoPrograma) => {
+        if (!equipoPrograma)
+          throw new ConflictException('No existe este equipo programa.');
+        return equipoPrograma;
+      });
+  }
 }