Update database requests

README.md

@@ -8,4 +8,48 @@ pinned: false
 license: mit
 ---
 
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# Bee3HiveAPI
+
+🏢 A robust API for managing and interacting with the Bee3Hive system.
+
+## Overview
+
+Bee3HiveAPI is a Docker-based application that provides a comprehensive interface for the Bee3Hive ecosystem. It offers functionalities for data management, user interactions, and system operations within the Bee3Hive platform.
+
+## Features
+
+- Docker-based deployment for easy setup and scalability
+- RESTful API endpoints for Bee3Hive operations
+- Secure authentication and authorization
+- Data management and retrieval capabilities
+- Integration with Bee3Hive core functionalities
+
+## Getting Started
+
+1. Clone the repository
+2. Install Docker and Docker Compose
+3. Build and run the Docker container:
+   ```
+   docker-compose up --build
+   ```
+4. Access the API at `http://localhost:<port>`
+
+## API Documentation
+
+Detailed API documentation is available at `/docs` endpoint after starting the server.
+
+## License
+
+This project is licensed under the MIT License. See the [LICENSE](LICENSE) file for details.
+
+## Contributing
+
+Contributions are welcome! Please read our [Contributing Guidelines](CONTRIBUTING.md) for more information.
+
+## Support
+
+For support or questions, please open an issue in the GitHub repository or contact the maintainers.
+
+---
+
+Powered by [Hugging Face](https://huggingface.co/)

index.js

@@ -4,27 +4,14 @@ const { sha } = require("sha256quanvn");
 const { PrismaClient } = require("@prisma/client");
 const multer = require("multer");
 const fs = require("fs");
-const path = require("path");
-const streamToBlob = require("stream-to-blob");
 const statusMonitor = require("express-status-monitor")({
     path: "/bee3hivestatuspagethatnoonewillrememberthisurl",
     title: "Bee3Hive API Status",
 });
 const cors = require("cors");
-const { resolveSoa } = require("dns");
-const prisma = new PrismaClient();
+const { withAccelerate } = require("@prisma/extension-accelerate")
+const prisma = new PrismaClient().$extends(withAccelerate())
 const app = express();
-// const http = require("http");
-// const server = http.createServer(app);
-// const { type } = require("os");
-// const io = require("socket.io")(server, {
-//     maxHttpBufferSize: 1e8,
-//     rejectUnauthorized: false,
-//     cors: {
-//         origin: "*",
-//         methods: ["GET", "POST"],
-//     },
-// });
 
 const SALT = process.env.PRIVATE_KEY;
 
@@ -63,6 +50,14 @@ function uniq(a) {
 }
 
 
+/**
+ * Generates a new JSON Web Token for the given user ID, and returns it as a string.
+ *
+ * The token is valid for 1 day, and is signed with the server's private key.
+ *
+ * @param {number} id - The user's ID.
+ * @return {string} A new JSON Web Token, as a string.
+ */
 const generateJWT = async (id) => {
     const header = {
         alg: "SHA256QUANVN",
@@ -71,7 +66,7 @@ const generateJWT = async (id) => {
 
     const payload = {
         id: id,
-        exp: Date.now() + 3600000 * 24, // 1 days
+        exp: Date.now() + 3600000 * 24 * 7, // 7 days
     };
 
     await prisma.users.update({
@@ -158,81 +153,6 @@ const upload = multer({
 
 const current_connections = [];
 
-// io.on("connection", (socket) => {
-//     info("A IPFS Services connected id=" + socket.id);
-
-//     socket.on("availible", () => {
-//         info("Services id=" + socket.id + " availible");
-//         current_connections.push(socket.id);
-//     });
-
-//     socket.emit("health_check");
-
-//     const interval = setInterval(() => {
-//         //* Health check
-//         info("Send health_check");
-//         socket.emit("health_check");
-//     }, 60000);
-
-//     socket.on("health", (data) => {
-//         info(
-//             "Services id=" +
-//             socket.id +
-//             " " +
-//             data.healthy +
-//             " availible=" +
-//             data.availible +
-//             " ping=" +
-//             Math.abs(Date.now() - data.now) +
-//             "ms"
-//         ); //* Check if services is healthy
-//     });
-
-//     socket.on("unavailible", () => {
-//         info("Services id=" + socket.id + " unavailible");
-//         for (let i = 0; i < current_connections.length; i++) {
-//             if (current_connections[i] === socket.id) {
-//                 current_connections.splice(i, 1);
-//                 break;
-//             }
-//         }
-//     });
-
-//     socket.on("delete", async (data) => {
-//         info("File Successfully uploaded, writing record");
-//         console.log(data); //* The data is comsumed by the IPFS services
-
-//         try {
-//             await prisma.storage.create({
-//                 data: {
-//                     handle: data.handle,
-//                     username: data.username,
-//                     CID: data.ipfs[0].Hash,
-//                     dir: data.directory,
-//                 },
-//             });
-//         } catch (e) {
-//             warn("Creating record fail");
-//         }
-
-//         //* Remove the initial file
-//         fs.unlinkSync("uploads/" + data.relative_path);
-//         info(`File ${data.relative_path} deleted`);
-//     });
-
-//     socket.on("disconnect", () => {
-//         info("A IPFS Services disconnected");
-//         clearInterval(interval);
-//         //* Removing services when disconnected (died)
-//         for (let i = 0; i < current_connections.length; i++) {
-//             if (current_connections[i] === socket.id) {
-//                 current_connections.splice(i, 1);
-//                 break;
-//             }
-//         }
-//     });
-// });
-
 app.use(
     cors({
         origin: "*",
@@ -251,6 +171,28 @@ app.get(
     statusMonitor.pageRoute
 );
 
+app.get("/bee3hive/internal/files/:node_id", async (req, res) => {
+    // TODO: Make database query for services
+    const node_id = req.params.node_id;
+    const record = await prisma.storage.findMany({
+        where: {
+            handle: node_id,
+        },
+        cacheStrategy: {
+            ttl: 60, //* 1 min
+        },
+    })
+
+    if(!record) {
+        res.sendStatus(404);
+        return;
+    }
+
+    res.send(record);
+})
+
+// TODO: Make database query for services
+
 app.post("/auth/email/register", async (req, res) => {
     let { username, email, password } = req.body;
 

package-lock.json

@@ -10,7 +10,8 @@
       "license": "ISC",
       "dependencies": {
         "@huggingface/hub": "^0.15.1",
-        "@prisma/client": "^5.18.0",
+        "@prisma/client": "^5.19.0",
+        "@prisma/extension-accelerate": "^1.1.0",
         "cors": "^2.8.5",
         "express": "^4.19.2",
         "express-status-monitor": "^1.3.4",
@@ -20,7 +21,7 @@
         "stream-to-blob": "^2.0.1"
       },
       "devDependencies": {
-        "prisma": "^5.18.0"
+        "prisma": "^5.19.0"
       }
     },
     "node_modules/@huggingface/hub": {
@@ -41,9 +42,9 @@
       "integrity": "sha512-sCtp+A6sq6NXoUU7NXuXWoVNNjKddk1GTQIh3cJ6illF8S4zmFoerCVRvFf19BdgICGvF+RVZiv9sGGK9KRDTg=="
     },
     "node_modules/@prisma/client": {
-      "version": "5.18.0",
-      "resolved": "https://registry.npmjs.org/@prisma/client/-/client-5.18.0.tgz",
-      "integrity": "sha512-BWivkLh+af1kqC89zCJYkHsRcyWsM8/JHpsDMM76DjP3ZdEquJhXa4IeX+HkWPnwJ5FanxEJFZZDTWiDs/Kvyw==",
+      "version": "5.19.0",
+      "resolved": "https://registry.npmjs.org/@prisma/client/-/client-5.19.0.tgz",
+      "integrity": "sha512-CzOpau+q1kEWQyoQMvlnXIHqPvwmWbh48xZ4n8KWbAql0p8PC0BIgSTYW5ncxXa4JSEff0tcoxSZB874wDstdg==",
       "hasInstallScript": true,
       "engines": {
         "node": ">=16.13"
@@ -58,48 +59,59 @@
       }
     },
     "node_modules/@prisma/debug": {
-      "version": "5.18.0",
-      "resolved": "https://registry.npmjs.org/@prisma/debug/-/debug-5.18.0.tgz",
-      "integrity": "sha512-f+ZvpTLidSo3LMJxQPVgAxdAjzv5OpzAo/eF8qZqbwvgi2F5cTOI9XCpdRzJYA0iGfajjwjOKKrVq64vkxEfUw==",
+      "version": "5.19.0",
+      "resolved": "https://registry.npmjs.org/@prisma/debug/-/debug-5.19.0.tgz",
+      "integrity": "sha512-+b/G0ubAZlrS+JSiDhXnYV5DF/aTJ3pinktkiV/L4TtLRLZO6SVGyFELgxBsicCTWJ2ZMu5vEV/jTtYCdjFTRA==",
       "devOptional": true
     },
     "node_modules/@prisma/engines": {
-      "version": "5.18.0",
-      "resolved": "https://registry.npmjs.org/@prisma/engines/-/engines-5.18.0.tgz",
-      "integrity": "sha512-ofmpGLeJ2q2P0wa/XaEgTnX/IsLnvSp/gZts0zjgLNdBhfuj2lowOOPmDcfKljLQUXMvAek3lw5T01kHmCG8rg==",
+      "version": "5.19.0",
+      "resolved": "https://registry.npmjs.org/@prisma/engines/-/engines-5.19.0.tgz",
+      "integrity": "sha512-UtW+0m4HYoRSSR3LoDGKF3Ud4BSMWYlLEt4slTnuP1mI+vrV3zaDoiAPmejdAT76vCN5UqnWURbkXxf66nSylQ==",
       "devOptional": true,
       "hasInstallScript": true,
       "dependencies": {
-        "@prisma/debug": "5.18.0",
-        "@prisma/engines-version": "5.18.0-25.4c784e32044a8a016d99474bd02a3b6123742169",
-        "@prisma/fetch-engine": "5.18.0",
-        "@prisma/get-platform": "5.18.0"
+        "@prisma/debug": "5.19.0",
+        "@prisma/engines-version": "5.19.0-31.5fe21811a6ba0b952a3bc71400666511fe3b902f",
+        "@prisma/fetch-engine": "5.19.0",
+        "@prisma/get-platform": "5.19.0"
       }
     },
     "node_modules/@prisma/engines-version": {
-      "version": "5.18.0-25.4c784e32044a8a016d99474bd02a3b6123742169",
-      "resolved": "https://registry.npmjs.org/@prisma/engines-version/-/engines-version-5.18.0-25.4c784e32044a8a016d99474bd02a3b6123742169.tgz",
-      "integrity": "sha512-a/+LpJj8vYU3nmtkg+N3X51ddbt35yYrRe8wqHTJtYQt7l1f8kjIBcCs6sHJvodW/EK5XGvboOiwm47fmNrbgg==",
+      "version": "5.19.0-31.5fe21811a6ba0b952a3bc71400666511fe3b902f",
+      "resolved": "https://registry.npmjs.org/@prisma/engines-version/-/engines-version-5.19.0-31.5fe21811a6ba0b952a3bc71400666511fe3b902f.tgz",
+      "integrity": "sha512-GimI9aZIFy/yvvR11KfXRn3pliFn1QAkdebVlsXlnoh5uk0YhLblVmeYiHfsu+wDA7BeKqYT4sFfzg8mutzuWw==",
       "devOptional": true
     },
+    "node_modules/@prisma/extension-accelerate": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npmjs.org/@prisma/extension-accelerate/-/extension-accelerate-1.1.0.tgz",
+      "integrity": "sha512-sESjhBZ4ywQjAVpKzsfhxyNu+9txIM5I6M1MPBaJBq/xDlqmniIAhlwIEt9KLtO80zqPxqbZYes18zrkgYqNiQ==",
+      "engines": {
+        "node": ">=16"
+      },
+      "peerDependencies": {
+        "@prisma/client": ">=4.16.1"
+      }
+    },
     "node_modules/@prisma/fetch-engine": {
-      "version": "5.18.0",
-      "resolved": "https://registry.npmjs.org/@prisma/fetch-engine/-/fetch-engine-5.18.0.tgz",
-      "integrity": "sha512-I/3u0x2n31rGaAuBRx2YK4eB7R/1zCuayo2DGwSpGyrJWsZesrV7QVw7ND0/Suxeo/vLkJ5OwuBqHoCxvTHpOg==",
+      "version": "5.19.0",
+      "resolved": "https://registry.npmjs.org/@prisma/fetch-engine/-/fetch-engine-5.19.0.tgz",
+      "integrity": "sha512-oOiPNtmJX0cP/ebu7BBEouJvCw8T84/MFD/Hf2zlqjxkK4ojl38bB9i9J5LAxotL6WlYVThKdxc7HqoWnPOhqQ==",
       "devOptional": true,
       "dependencies": {
-        "@prisma/debug": "5.18.0",
-        "@prisma/engines-version": "5.18.0-25.4c784e32044a8a016d99474bd02a3b6123742169",
-        "@prisma/get-platform": "5.18.0"
+        "@prisma/debug": "5.19.0",
+        "@prisma/engines-version": "5.19.0-31.5fe21811a6ba0b952a3bc71400666511fe3b902f",
+        "@prisma/get-platform": "5.19.0"
       }
     },
     "node_modules/@prisma/get-platform": {
-      "version": "5.18.0",
-      "resolved": "https://registry.npmjs.org/@prisma/get-platform/-/get-platform-5.18.0.tgz",
-      "integrity": "sha512-Tk+m7+uhqcKDgnMnFN0lRiH7Ewea0OEsZZs9pqXa7i3+7svS3FSCqDBCaM9x5fmhhkufiG0BtunJVDka+46DlA==",
+      "version": "5.19.0",
+      "resolved": "https://registry.npmjs.org/@prisma/get-platform/-/get-platform-5.19.0.tgz",
+      "integrity": "sha512-s9DWkZKnuP4Y8uy6yZfvqQ/9X3/+2KYf3IZUVZz5OstJdGBJrBlbmIuMl81917wp5TuK/1k2TpHNCEdpYLPKmg==",
       "devOptional": true,
       "dependencies": {
-        "@prisma/debug": "5.18.0"
+        "@prisma/debug": "5.19.0"
       }
     },
     "node_modules/@socket.io/component-emitter": {
@@ -781,6 +793,20 @@
         "node": ">= 0.6"
       }
     },
+    "node_modules/fsevents": {
+      "version": "2.3.3",
+      "resolved": "https://registry.npmjs.org/fsevents/-/fsevents-2.3.3.tgz",
+      "integrity": "sha512-5xoDfX+fL7faATnagmWPpbFtwh/R77WmMMqqHGS65C3vvB0YHrgF+B1YmZ3441tMj5n63k0212XNoJwzlhffQw==",
+      "dev": true,
+      "hasInstallScript": true,
+      "optional": true,
+      "os": [
+        "darwin"
+      ],
+      "engines": {
+        "node": "^8.16.0 || ^10.6.0 || >=11.0.0"
+      }
+    },
     "node_modules/function-bind": {
       "version": "1.1.2",
       "resolved": "https://registry.npmjs.org/function-bind/-/function-bind-1.1.2.tgz",
@@ -1138,19 +1164,22 @@
       }
     },
     "node_modules/prisma": {
-      "version": "5.18.0",
-      "resolved": "https://registry.npmjs.org/prisma/-/prisma-5.18.0.tgz",
-      "integrity": "sha512-+TrSIxZsh64OPOmaSgVPH7ALL9dfU0jceYaMJXsNrTkFHO7/3RANi5K2ZiPB1De9+KDxCWn7jvRq8y8pvk+o9g==",
+      "version": "5.19.0",
+      "resolved": "https://registry.npmjs.org/prisma/-/prisma-5.19.0.tgz",
+      "integrity": "sha512-Pu7lUKpVyTx8cVwM26dYh8NdvMOkMnJXzE8L6cikFuR4JwyMU5NKofQkWyxJKlTT4fNjmcnibTvklV8oVMrn+g==",
       "devOptional": true,
       "hasInstallScript": true,
       "dependencies": {
-        "@prisma/engines": "5.18.0"
+        "@prisma/engines": "5.19.0"
       },
       "bin": {
         "prisma": "build/index.js"
       },
       "engines": {
         "node": ">=16.13"
+      },
+      "optionalDependencies": {
+        "fsevents": "2.3.3"
       }
     },
     "node_modules/process-nextick-args": {

package.json

@@ -11,7 +11,8 @@
   "description": "",
   "dependencies": {
     "@huggingface/hub": "^0.15.1",
-    "@prisma/client": "^5.18.0",
+    "@prisma/client": "^5.19.0",
+    "@prisma/extension-accelerate": "^1.1.0",
     "cors": "^2.8.5",
     "express": "^4.19.2",
     "express-status-monitor": "^1.3.4",
@@ -21,6 +22,6 @@
     "stream-to-blob": "^2.0.1"
   },
   "devDependencies": {
-    "prisma": "^5.18.0"
+    "prisma": "^5.19.0"
   }
 }

prisma/bruh.txt

@@ -1,22 +0,0 @@
-/// This model or at least one of its fields has comments in the database, and requires an additional setup for migrations: Read more: https://pris.ly/d/database-comments
-/// This model contains row level security and requires additional setup for migrations. Visit https://pris.ly/d/row-level-security for more info.
-model Users {
-  id            BigInt    @id @default(autoincrement())
-  created_at    DateTime  @default(now()) @db.Timestamptz(6)
-  username      String    @unique
-  password_hash String
-  email         String?   @unique
-  phone         String?
-  last_login    DateTime? @db.Time(6)
-}
-
-/// This model or at least one of its fields has comments in the database, and requires an additional setup for migrations: Read more: https://pris.ly/d/database-comments
-/// This model contains row level security and requires additional setup for migrations. Visit https://pris.ly/d/row-level-security for more info.
-model Storage {
-  id         BigInt   @id @default(autoincrement())
-  created_at DateTime @default(now()) @db.Timestamptz(6)
-  CID        String   @unique @default("CID")
-  username   String
-  handle     String
-  dir        String?  @default("/")
-}