feat: serious backend stuff (no auth yet)

Author: frixaco

server/prisma/schema.prisma

@@ -2,17 +2,44 @@
 // learn more about it in the docs: https://pris.ly/d/prisma-schema
 
 generator client {
-  provider = "prisma-client-js"
+  provider        = "prisma-client-js"
   previewFeatures = ["referentialIntegrity"]
 }
 
 datasource db {
-  provider = "mysql"
-  url = env("DATABASE_URL")
+  provider             = "mysql"
+  url                  = env("DATABASE_URL")
   referentialIntegrity = "prisma"
 }
 
 model User {
-  id      Int      @id @default(autoincrement())
-  name    String?
+  id        Int      @id @default(autoincrement())
+  username  String
+  password  String
+  email     String
+  devices   Device[]
+  changes   Change[]
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+}
+
+model Change {
+  id        Int      @id @default(autoincrement())
+  changes   String // JSON stringified { staged: '...', unstaged: '...' }
+  device    Device   @relation(fields: [deviceId], references: [id])
+  deviceId  Int
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+  owner     User?    @relation(fields: [ownerId], references: [id])
+  ownerId   Int?
+}
+
+model Device {
+  id        Int      @id @default(autoincrement())
+  name      String
+  owner     User     @relation(fields: [ownerId], references: [id])
+  ownerId   Int
+  changes   Change[]
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
 }

server/src/db.ts

@@ -0,0 +1,5 @@
+import { PrismaClient } from "@prisma/client";
+
+const db = new PrismaClient();
+
+export default db;

server/src/index.ts

@@ -1,4 +1,3 @@
-import { PrismaClient } from "@prisma/client";
 import express from "express";
 
 const PORT = process.env.PORT || 3001;
@@ -7,34 +6,11 @@ const app = express();
 
 app.use(express.json());
 
-let data: any = null;
-
-const prisma = new PrismaClient();
-
-async function main() {
-  const allUsers = await prisma.user.findMany();
-  console.log("users", allUsers);
-}
-
-app.post(`/`, async (req, res) => {
-  data = req.body;
-  console.log("server: save data=", Object.keys(data.diff));
-  res.json({ success: true });
-});
-
-app.get(`/`, async (req, res) => {
-  console.log("server: get data=", Object.keys(data.diff));
-  res.json(data);
-});
-
-const server = app.listen(PORT, () => {
-  main()
-    .catch((e) => {
-      throw e;
-    })
-    .finally(async () => {
-      await prisma.$disconnect();
-    });
+app.use("/auth", require("./routes/auth"));
+app.use("/users", require("./routes/users"));
+app.use("/devices", require("./routes/devices"));
+app.use("/changes", require("./routes/changes"));
 
+app.listen(PORT, () => {
   console.log(`🚀 Server ready at: http://localhost:${PORT}`);
 });

server/src/middleware/auth.ts

@@ -0,0 +1,5 @@
+function authMdw(request: any, response: any, next: any) {
+  next();
+}
+
+export default authMdw;

server/src/routes/auth.ts

@@ -0,0 +1,4 @@
+import { Router } from "express";
+import authMdw from "../middleware/auth";
+
+const router = Router();

server/src/routes/changes.ts

@@ -0,0 +1,61 @@
+// SEND CHANGES, SAVE CHANGES, CLEAN CHANGES
+import { Router } from "express";
+import db from "../db";
+import authMdw from "../middleware/auth";
+
+const router = Router();
+
+router.get("/", authMdw, async (req, res) => {
+  try {
+    const { deviceId } = req.body;
+
+    const userId = 1; // JSONWEBTOKEN
+    const user = await db.user.findUnique({
+      where: {
+        id: userId,
+      },
+    });
+    if (!user) throw new Error("No user found");
+
+    const changes = await db.change.findMany({
+      where: {
+        ownerId: user.id,
+        deviceId,
+      },
+      take: 1,
+      orderBy: {
+        createdAt: "desc",
+      },
+    });
+
+    res.json({ diff: JSON.parse(changes[0].changes) });
+  } catch (error) {
+    res.status(500).json({ msg: "Something went wrong in the server!" });
+  }
+});
+
+router.post("/", authMdw, async (req, res) => {
+  try {
+    const { diff, deviceId } = req.body;
+
+    const userId = 1; // JSONWEBTOKEN
+    const user = await db.user.findUnique({
+      where: {
+        id: userId,
+      },
+    });
+    if (!user) throw new Error("User not found");
+
+    await db.change.create({
+      data: {
+        changes: JSON.stringify(diff),
+        ownerId: userId,
+        deviceId: deviceId,
+      },
+    });
+
+    res.json({ success: true });
+  } catch (err) {
+    res.status(500).json({ msg: "Something went wrong in the server!" });
+  }
+});

server/src/routes/devices.ts

@@ -0,0 +1,54 @@
+import { Router } from "express";
+import db from "../db";
+import authMdw from "../middleware/auth";
+
+const router = Router();
+
+router.post("/", authMdw, async (req, res) => {
+  try {
+    const userId = 1; // JSONWEBTOKEN
+    const user = await db.user.findUnique({
+      where: {
+        id: userId,
+      },
+    });
+    if (!user) throw new Error("User not found");
+
+    const { name } = req.body;
+
+    const devices = await db.device.create({
+      data: {
+        owner: {
+          connect: { id: user.id },
+        },
+        name,
+      },
+    });
+
+    res.json({ success: true });
+  } catch (error) {
+    res.status(500).json({ msg: "Something went wrong in the server!" });
+  }
+});
+
+router.get("/", authMdw, async (req, res) => {
+  try {
+    const userId = 1; // JSONWEBTOKEN
+    const user = await db.user.findUnique({
+      where: {
+        id: userId,
+      },
+    });
+    if (!user) throw new Error("User not found");
+
+    const devices = await db.device.findMany({
+      where: {
+        ownerId: user.id,
+      },
+    });
+
+    res.json({ devices });
+  } catch (error) {
+    res.status(500).json({ msg: "Something went wrong in the server!" });
+  }
+});

server/src/routes/users.ts

@@ -8,47 +8,50 @@ interface Device {
 
 function App() {
   const [devices, { mutate, refetch }] = createResource<Device[]>(async () => {
-    const response = await fetch("http://localhost:3001/api/devices", {
+    const response = await fetch("http://localhost:3001/devices", {
       method: "GET",
-      body: JSON.stringify({
-        userId: 1,
-      }),
+      // headers: JSONWEBTOKEN
     });
     const connectedDevices = await response.json();
     return connectedDevices;
   });
 
+  /**
+   * Send changes to the server.
+   * They can be accessed from any connected device by pressing 'Receive'
+   * button of the device that they were sent from (nice english i got there)
+   */
   const onSend = () => {
     console.log("onSend");
     vscodeApi.postMessage({
       type: "send",
     });
   };
 
-  const onReceive = () => {
+  /**
+   * Each device in devices list have a 'Receive' button
+   * which allows to download last changes from that device and apply them
+   */
+  const onReceive = (deviceId: string) => {
     console.log("onReceive");
     vscodeApi.postMessage({
       type: "receive",
+      deviceId,
     });
   };
 
   return (
     <div>
       <p>Devices</p>
 
-      <div>
-        <button onClick={onSend}>SEND</button>
-        <button onClick={onReceive}>RECEIVE</button>
-      </div>
-
       <div>
         <For each={devices()} fallback={<span>Empty</span>}>
           {(device) => (
             <div>
               <span>{`${device.name} - ${device.id}`}</span>
               <div>
                 <button onClick={onSend}>SEND</button>
-                <button onClick={onReceive}>RECEIVE</button>
+                <button onClick={() => onReceive(device.id)}>RECEIVE</button>
               </div>
             </div>
           )}