First commit with part of the service working.

Author: carlosalaniz

.vscode/launch.json

@@ -0,0 +1,35 @@
+{
+  // Use IntelliSense to learn about possible attributes.
+  // Hover to view descriptions of existing attributes.
+  // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "name": "Dev",
+      "type": "node",
+      "request": "launch",
+      "runtimeExecutable": "node",
+      "runtimeArgs": ["--nolazy", "-r", "ts-node/register/transpile-only"],
+
+      "args": ["src/index.ts", "--example", "hello"],
+
+      "cwd": "${workspaceRoot}",
+      "internalConsoleOptions": "openOnSessionStart",
+      "skipFiles": ["<node_internals>/**", "node_modules/**"]
+    },
+    {
+      "name": "PROD",
+      "type": "node",
+      "request": "launch",
+      "runtimeExecutable": "node",
+      "runtimeArgs": ["--nolazy", "-r", "ts-node/register/transpile-only"],
+      "args": ["src/index.ts", "--example", "hello"],
+      "env": {
+        "NODE_ENV": "production"
+      },
+      "cwd": "${workspaceRoot}",
+      "internalConsoleOptions": "openOnSessionStart",
+      "skipFiles": ["<node_internals>/**", "node_modules/**"]
+    }
+  ]
+}

package-lock.json

@@ -30,8 +30,9 @@
     "typescript": "^4.6.4"
   },
   "dependencies": {
-    "body-parser": "^1.18.2",
-    "express": "^4.16.3",
+    "class-transformer": "^0.5.1",
+    "class-validator": "^0.13.2",
+    "express": "^4.18.1",
     "mysql": "^2.15.0",
     "reflect-metadata": "^0.1.13",
     "typeorm": "^0.3.6"

package.json

@@ -0,0 +1,107 @@
+import { plainToInstance } from "class-transformer";
+import { Request, Response } from "express";
+import { AppDataSource } from "../data-source";
+import { Miner } from "../entity/Miner";
+import { MinerStateAudit } from "../entity/MinerStateAudit";
+import { now } from "../helpers/nowTimestamp";
+import { AddMinerDTO } from "../mapper/AddMinerDTO";
+import { ChangeMinerStateDto } from "../mapper/ChangeMinerStateDto";
+import { MinerDTO } from "../mapper/MinerDTO";
+import { UpdateMinerDTO } from "../mapper/UpdateMinerDTO";
+
+
+/**
+ * Loads all posts from the database.
+ */
+export class MinerController {
+    static async getAllMiners(request: Request, response: Response) {
+
+    }
+
+    static async getAllUserMiners(request: Request, response: Response) {
+        // get a post repository to perform operations with post
+        const minerRepository = AppDataSource.manager.getRepository(Miner);
+
+        // get user id
+        const user_id = request.params.id
+
+        // get all miners
+        const miners = await minerRepository.findBy({
+            owner_id: +user_id // where id is your column name
+        });
+
+        // return loaded miner(s)
+        response.send(plainToInstance(MinerDTO, miners));
+
+    }
+
+    static async addMiner(request: Request, response: Response) {
+        // get a post repository to perform operations with post
+        const minerRepository = AppDataSource.manager.getRepository(Miner);
+
+        // convert body to defined object. 
+        const minerDto = plainToInstance(AddMinerDTO, request.body);
+
+        // create a real post object 
+        const newMiner = minerRepository.create(minerDto);
+
+        // save received post
+        await minerRepository.save(newMiner);
+
+        // return saved miner(s) back
+        response.send(plainToInstance(MinerDTO, newMiner));
+    }
+
+    static async updateMinerRecord(request: Request, response: Response) {
+        // get a post repository to perform operations with post
+        const minerRepository = AppDataSource.manager.getRepository(Miner);
+        const stateChangeAuditRepository = AppDataSource.manager.getRepository(MinerStateAudit);
+
+        // convert body to defined object. 
+        const updateMinerDto = plainToInstance(UpdateMinerDTO, request.body);
+
+        // get miner 
+        var miner = await minerRepository.findOneBy({
+            id: updateMinerDto.miner_id // where id is your column name
+        });
+
+        // miner not found
+        if (!miner) {
+            response.status(404);
+            response.end();
+            return;
+        }
+
+        // Update the object.
+        const updateTime = now();
+
+        let auditRecord;
+        for (let prop in miner) {
+            if (updateMinerDto.hasOwnProperty(prop)) {
+                if (prop === "state") {
+                    auditRecord = await stateChangeAuditRepository.create(
+                        {
+                            miner_id: updateMinerDto.miner_id,
+                            previous_state: miner.state,
+                            new_state: updateMinerDto.state,
+                            changed_at: updateTime
+                        }
+                    );
+                    miner.last_state_change = updateTime;
+                }
+                miner[prop] = updateMinerDto[prop];
+            }
+        }
+
+        // save updated object
+        await AppDataSource.manager.transaction(async (transactionalEntityManager) => {
+            await transactionalEntityManager.save(miner)
+            if (auditRecord) {
+                await transactionalEntityManager.save(auditRecord)
+            }
+        })
+
+        // return saved miner(s) back
+        response.send(plainToInstance(MinerDTO, miner));
+    }
+}