valky_host

Running

App Files Files Community

Pepguy commited on Jul 22, 2025

Commit

03d1608

verified ·

1 Parent(s): e2c6f21

Update app.js

Browse files

Files changed (1) hide show

app.js +96 -104

app.js CHANGED Viewed

@@ -1,104 +1,96 @@
-import { serve } from "bun";
-import { createClient } from "redis";
-const redis = createClient(); // defaults to localhost:6379
-await redis.connect();
-serve({
-  port: 7860,
-  async fetch(req) {
-    const url = new URL(req.url);
-    const method = req.method;
-    // HTML test UI
-    if (url.pathname === "/" && method === "GET") {
-      return new Response(`
-        <!DOCTYPE html>
-        <html>
-        <head><title>Redis Test UI</title></head>
-        <body>
-          <h1>Redis Testing Interface</h1>
-          <h2>Save Key</h2>
-          <form id="saveForm">
-            Key: <input name="key" /> Value: <input name="value" />
-            <button type="submit">Save</button>
-          </form>
-          <h2>Get Key</h2>
-          <form id="getForm">
-            Key: <input name="getKey" />
-            <button type="submit">Fetch</button>
-          </form>
-          <h2>Delete Key</h2>
-          <form id="delForm">
-            Key: <input name="delKey" />
-            <button type="submit">Delete</button>
-          </form>
-          <pre id="out"></pre>
-          <script>
-            const out = document.getElementById("out");
-            document.getElementById("saveForm").onsubmit = async (e) => {
-              e.preventDefault();
-              const key = e.target.key.value;
-              const value = e.target.value.value;
-              const res = await fetch("/save", {
-                method: "POST",
-                headers: { "Content-Type": "application/json" },
-                body: JSON.stringify({ key, value }),
-              });
-              out.textContent = await res.text();
-            };
-            document.getElementById("getForm").onsubmit = async (e) => {
-              e.preventDefault();
-              const key = e.target.getKey.value;
-              const res = await fetch("/get?key=" + key);
-              out.textContent = await res.text();
-            };
-            document.getElementById("delForm").onsubmit = async (e) => {
-              e.preventDefault();
-              const key = e.target.delKey.value;
-              const res = await fetch("/delete?key=" + key, { method: "DELETE" });
-              out.textContent = await res.text();
-            };
-          </script>
-        </body>
-        </html>
-      `, {
-        headers: { "Content-Type": "text/html" },
-      });
-    }
-    // Save key-value
-    if (url.pathname === "/save" && method === "POST") {
-      const { key, value } = await req.json();
-      if (!key || !value) return new Response("Missing key or value", { status: 400 });
-      await redis.set(key, value);
-      return new Response("Saved: " + key);
-    }
-    // Get key
-    if (url.pathname === "/get" && method === "GET") {
-      const key = url.searchParams.get("key");
-      if (!key) return new Response("Missing key", { status: 400 });
-      const val = await redis.get(key);
-      return new Response(val ?? "Key not found");
-    }
-    // Delete key
-    if (url.pathname === "/delete" && method === "DELETE") {
-      const key = url.searchParams.get("key");
-      if (!key) return new Response("Missing key", { status: 400 });
-      const deleted = await redis.del(key);
-      return new Response(deleted ? "Deleted" : "Key not found");
-    }
-    return new Response("404 Not Found", { status: 404 });
-  }
-});

+const express = require("express");
+const fs = require("fs");
+const path = require("path");
+const { createClient } = require("redis");
+const { google } = require("googleapis");
+const app = express();
+const redis = createClient();
+app.use(express.json());
+const SCOPES = ["https://www.googleapis.com/auth/drive.file"];
+const TOKEN_PATH = "token.json";
+const CREDENTIALS_PATH = "credentials.json";
+async function getAuthClient() {
+  const credentials = JSON.parse(fs.readFileSync(CREDENTIALS_PATH));
+  const token = JSON.parse(fs.readFileSync(TOKEN_PATH));
+  const auth = new google.auth.OAuth2(
+    credentials.installed.client_id,
+    credentials.installed.client_secret,
+    credentials.installed.redirect_uris[0]
+  );
+  auth.setCredentials(token);
+  return auth;
+}
+async function getAllRedisData() {
+  const keys = await redis.keys("*");
+  const result = {};
+  for (const key of keys) result[key] = await redis.get(key);
+  return result;
+}
+async function uploadToDrive(filename) {
+  const auth = await getAuthClient();
+  const drive = google.drive({ version: "v3", auth });
+  const fileMetadata = { name: path.basename(filename) };
+  const media = {
+    mimeType: "application/json",
+    body: fs.createReadStream(filename),
+  };
+  const res = await drive.files.create({
+    resource: fileMetadata,
+    media,
+    fields: "id",
+  });
+  return res.data.id;
+}
+app.get("/", (_, res) => {
+  res.sendFile(path.join(__dirname, "index.html"));
+});
+app.post("/save", async (req, res) => {
+  const { key, value } = req.body;
+  if (!key || !value) return res.status(400).send("Missing key or value");
+  await redis.set(key, value);
+  res.send("Saved");
+});
+app.get("/get", async (req, res) => {
+  const key = req.query.key;
+  if (!key) return res.status(400).send("Missing key");
+  const value = await redis.get(key);
+  res.send(value ?? "Key not found");
+});
+app.delete("/delete", async (req, res) => {
+  const key = req.query.key;
+  if (!key) return res.status(400).send("Missing key");
+  const deleted = await redis.del(key);
+  res.send(deleted ? "Deleted" : "Key not found");
+});
+app.get("/all", async (_, res) => {
+  const data = await getAllRedisData();
+  res.json(data);
+});
+app.get("/backup", async (_, res) => {
+  const data = await getAllRedisData();
+  const filename = `redis_backup_${Date.now()}.json`;
+  fs.writeFileSync(filename, JSON.stringify(data, null, 2));
+  const fileId = await uploadToDrive(filename);
+  res.send("Uploaded. File ID: " + fileId);
+});
+(async () => {
+  await redis.connect();
+  const port = process.env.PORT || 7860;
+  app.listen(port, () => console.log("Server running on", port));
+})();