Merge pull request #98 from roahoki/development

Initial release: Version 1.1.0

Author: eiacobelli

Diff for: README.md

@@ -31,6 +31,9 @@ MQTT_PORT = 9000
 MQTT_USER = students
 MQTT_PASSWORD = iic2173-2024-2-students
 MQTT_PROTOCOL = mqtt
+
+CELERY_BROKER_URL=redis://redis-broker:6379/0
+CELERY_RESULT_BACKEND=redis://redis-broker:6379/0
 ```
 
 2. Bajar contenedores de docker si están arriba: 
@@ -328,3 +331,104 @@ En nuestro caso, en el frontend cuando se presiona Generar Boleta se hace una ll
 # Pasos Workers
 
 Redis y celery hace una abstracción del uso de encolamiento y el acceso de los consumers vía polling para la realización de las tareas, por lo que al levantar el back las recomendaciones se realizarán accediendo al back 
+
+
+# Flujos y pasos en la configuración de IaaC
+
+La configuración de **Infrastructure as Code (IaaC)** se realiza utilizando AWS CDK (Cloud Development Kit) en un stack llamado `my-cdk-project-stack`. Este stack crea y configura automáticamente los recursos de AWS necesarios para la operación del backend de la aplicación **The Goat BACKEND**.
+
+#### Flujo de Configuración del Código
+1. **Inicialización del App**
+   - El archivo principal `bin/my-cdk-project.ts` contiene la inicialización de la aplicación CDK.
+   - Configura la cuenta y la región donde se desplegarán los recursos:
+     ```typescript
+     const app = new cdk.App();
+     new BackendInfrastructureStack(app, 'BackendInfrastructureStack', {
+       env: { 
+         account: '577638367697', 
+         region: 'us-east-2' 
+       },
+       description: 'Infrastructure stack for existing backend instance'
+     });
+     ```
+
+2. **Referenciar Recursos Existentes**
+   - Se reutilizan recursos como la **VPC** y una instancia **EC2** existentes, lo que garantiza eficiencia y consistencia en la infraestructura.
+
+3. **Creación de Recursos**
+   - Se definen y configuran nuevos recursos, como un bucket **S3** para registros y respaldos, alarmas de **CloudWatch** para monitoreo, un tópico **SNS** para notificaciones, y un **Security Group** adicional para el control del tráfico de red.
+
+4. **Asignación de Roles y Políticas**
+   - Se crea un rol **IAM** con permisos específicos para acceder al bucket de S3 y a **AWS Systems Manager**, asegurando que la instancia EC2 tenga los privilegios necesarios para gestionar la infraestructura de manera segura.
+
+5. **Alertas y Monitoreo**
+   - Se configuran alarmas de **CloudWatch** para supervisar la utilización de CPU y los fallos en los checks de estado de la instancia EC2, enviando notificaciones al tópico SNS en caso de problemas.
+
+6. **Salida de Información**
+   - Se generan outputs útiles (como el ARN del tópico SNS, el nombre del bucket S3 y el ID de la instancia EC2) para facilitar el acceso a los recursos configurados.
+
+#### Pasos de Implementación
+
+1. **Instalar AWS CDK y Configurar el Entorno**
+   - Instala AWS CDK con `npm install -g aws-cdk`.
+   - Configura las credenciales de AWS utilizando `aws configure`.
+
+2. **Definir el Stack**
+   - El código de configuración se encuentra en `lib/my-cdk-project-stack.ts` y la inicialización del app en `bin/my-cdk-project.ts`.
+
+3. **Inicializar y Desplegar el Stack**
+   - Asegúrate de instalar las dependencias del proyecto:
+     ```bash
+     npm install
+     ```
+   - Ejecuta el comando para sintetizar el stack:
+     ```bash
+     cdk synth
+     ```
+   - Despliega el stack en tu cuenta de AWS:
+     ```bash
+     cdk deploy
+     ```
+   - Confirma los cambios durante el despliegue si es necesario.
+
+4. **Detalles del Código**
+   - **Inicializar el App:**
+     ```typescript
+     const app = new cdk.App();
+     new BackendInfrastructureStack(app, 'BackendInfrastructureStack', {
+       env: { 
+         account: '577638367697', 
+         region: 'us-east-2' 
+       },
+       description: 'Infrastructure stack for existing backend instance'
+     });
+     ```
+   - **Referenciar VPC e Instancia EC2 existentes:**
+     ```typescript
+     const existingVpc = ec2.Vpc.fromLookup(this, 'CDKVPC', {
+       vpcId: 'vpc-033aded37d02f7e0a',
+     });
+     const instanceId = 'i-0bb10936c1c1fb634';
+     ```
+   - **Crear un Bucket S3 para Logs:**
+     ```typescript
+     const logsBucket = new s3.Bucket(this, 'BackendLogsBucket', {
+       bucketName: `backend-logs-${this.account}-${this.region}`,
+       removalPolicy: cdk.RemovalPolicy.RETAIN,
+       encryption: s3.BucketEncryption.S3_MANAGED,
+     });
+     ```
+   - **Configurar Roles y Permisos:**
+     ```typescript
+     const backendRole = new iam.Role(this, 'BackendInstanceRole', {
+       assumedBy: new iam.ServicePrincipal('ec2.amazonaws.com'),
+       roleName: 'backend-instance-role'
+     });
+     backendRole.addManagedPolicy(
+       iam.ManagedPolicy.fromAwsManagedPolicyName('AmazonSSMManagedInstanceCore')
+     );
+     ```
+
+5. **Verificar la Configuración**
+   - Usa la consola de AWS para confirmar que los recursos se han creado correctamente (S3, alarmas, tópico SNS, etc.).
+   - Verifica los logs y notificaciones para asegurar que las alarmas y los flujos de datos funcionan como se espera.

Diff for: api/src/app.js

@@ -15,15 +15,6 @@ app.use(KoaLogger());
 // Use bodyParser middleware
 app.use(bodyParser());
 
-// app.use(async (ctx, next) => {
-//   ctx.set('Access-Control-Allow-Origin', 'http://localhost:5173');
-//   ctx.set('Access-Control-Allow-Credentials', 'true');
-//   ctx.set('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE, OPTIONS');
-//   ctx.set('Access-Control-Allow-Headers', 'Content-Type, Authorization');
-//   await next();
-// });
-// =======
-// Use CORS middleware
 app.use(cors());
 
 

Diff for: api/src/config/checkAdmin.js

@@ -0,0 +1,13 @@
+const { User } = require('../models'); // Ajusta la ruta al modelo de usuario
+
+const checkAdmin = async (ctx, next) => {
+    console.log(ctx, "ctx");
+    const user = await User.findOne({ where: { email: ctx.state.user.email } });
+    if (user && user.isAdmin) {
+        return next();
+    }
+    ctx.status = 403;
+    ctx.body = { error: 'Access denied: Admins only.' };
+};
+
+module.exports = checkAdmin;

Diff for: api/src/migrations/20241120125611-create-adminrequest.js

@@ -0,0 +1,85 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.createTable('AdminRequests', {
+      request_id: {
+        type: Sequelize.UUID,
+        defaultValue: Sequelize.UUIDV4,
+        allowNull: false,
+        primaryKey: true,
+      },
+      group_id: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      fixture_id: {
+        type: Sequelize.INTEGER,
+        allowNull: false,
+      },
+      league_name: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      round: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      date: {
+        type: Sequelize.DATEONLY,
+        allowNull: false,
+      },
+      result: {
+        type: Sequelize.STRING,
+        allowNull: true,
+      },
+      deposit_token: {
+        type: Sequelize.STRING,
+        defaultValue: "",
+        allowNull: true,
+      },
+      datetime: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      quantity: {
+        type: Sequelize.INTEGER,
+        allowNull: false,
+      },
+      seller: {
+        type: Sequelize.INTEGER,
+        allowNull: false,
+        defaultValue: 15, // Valor por defecto
+      },
+      status: {
+        type: Sequelize.STRING,
+        allowNull: false,
+        defaultValue: 'pending',
+      },
+      ip_address: {
+        type: Sequelize.STRING,
+        allowNull: true,
+      },
+      location: {
+        type: Sequelize.STRING,
+        allowNull: true,
+      },
+      wallet: {
+        type: Sequelize.BOOLEAN,
+        allowNull: false,
+      },
+      createdAt: {
+        allowNull: false,
+        type: Sequelize.DATE,
+      },
+      updatedAt: {
+        allowNull: false,
+        type: Sequelize.DATE,
+      },
+    });
+  },
+
+  async down(queryInterface) {
+    await queryInterface.dropTable('AdminRequests');
+  },
+};

Diff for: api/src/migrations/20241121114732-create-auction-offer.js

@@ -0,0 +1,57 @@
+"use strict";
+
+module.exports = {
+    async up(queryInterface, Sequelize) {
+        await queryInterface.createTable("AuctionOffers", {
+            id: {
+                allowNull: false,
+                autoIncrement: true,
+                primaryKey: true,
+                type: Sequelize.INTEGER,
+            },
+            auction_id: {
+                type: Sequelize.UUID,
+                allowNull: false,
+            },
+            proposal_id: {
+                type: Sequelize.UUID,
+                allowNull: true,
+            },
+            fixture_id: {
+                type: Sequelize.INTEGER,
+                allowNull: false,
+            },
+            league_name: {
+                type: Sequelize.STRING,
+                allowNull: false,
+            },
+            round: {
+                type: Sequelize.STRING,
+                allowNull: false,
+            },
+            result: {
+                type: Sequelize.STRING,
+                allowNull: false,
+            },
+            quantity: {
+                type: Sequelize.INTEGER,
+                allowNull: false,
+            },
+            group_id: {
+                type: Sequelize.INTEGER,
+                allowNull: false,
+            },
+            createdAt: {
+                allowNull: false,
+                type: Sequelize.DATE,
+            },
+            updatedAt: {
+                allowNull: false,
+                type: Sequelize.DATE,
+            },
+        });
+    },
+    async down(queryInterface, Sequelize) {
+        await queryInterface.dropTable("AuctionOffers");
+    },
+};

Diff for: api/src/migrations/20241123183222-add-status-to-auction-offers.js

@@ -0,0 +1,11 @@
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+      await queryInterface.addColumn('AuctionOffers', 'type', {
+          type: Sequelize.STRING,
+          allowNull: false
+      });
+  },
+  down: async (queryInterface, Sequelize) => {
+      await queryInterface.removeColumn('AuctionOffers', 'type');
+  }
+};

Diff for: api/src/migrations/20241123203802-add-request-id-to-auctionoffer.js

@@ -0,0 +1,15 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.addColumn('AuctionOffers', 'request_id', {
+      type: Sequelize.UUID,
+      allowNull: true, // Puede ser nulo para ofertas de otros equipos
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    await queryInterface.removeColumn('AuctionOffers', 'request_id');
+  },
+};
+

Diff for: api/src/migrations/20241125142059-add-isAdmin-to-users.js

@@ -0,0 +1,16 @@
+'use strict';
+
+module.exports = {
+    up: async (queryInterface, Sequelize) => {
+        await queryInterface.addColumn('Users', 'isAdmin', {
+            type: Sequelize.BOOLEAN,
+            allowNull: false,
+            defaultValue: false,
+        });
+    },
+
+    down: async (queryInterface, Sequelize) => {
+        await queryInterface.removeColumn('Users', 'isAdmin');
+    },
+};
+

Diff for: api/src/migrations/20241125163120-add-discount-to-admin-requests.js

@@ -0,0 +1,16 @@
+'use strict';
+
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    await queryInterface.addColumn('AdminRequests', 'discount', {
+      type: Sequelize.FLOAT,
+      defaultValue: 0,
+      allowNull: false,
+    });
+  },
+
+  down: async (queryInterface, Sequelize) => {
+    await queryInterface.removeColumn('AdminRequests', 'discount');
+  },
+};
+