server.js

// https://deno.land/std@0.194.0/http/server.ts?s=serve

import { serve } from "http/server.ts";
// https://deno.land/std@0.194.0/http/file_server.ts?s=serveDir
import { serveDir } from "http/file_server.ts";
import "https://deno.land/std@0.203.0/dotenv/mod.ts";

const waitingList = new Map();
const clientsMap = new Map();   // all clients
const userDataMap = new Map(); // 名前と出来事を記録するマップ
/**
* APIリクエストを処理する
*/
Deno.serve({
  port: 8080,

  handler: async (req) => {
    if (req.headers.get("upgrade") === "websocket") {
      const { socket, response } = Deno.upgradeWebSocket(req);

      socket.onopen = () => {
        // 接続したときの処理
        console.log("CONNECTED");
        socket.send(JSON.stringify({
          event: "connected",
        }));
      };
      socket.onmessage = (message) => {
        const data = JSON.parse(message.data);
        // 受信したときの処理
        switch (data.event) {
          // 送ってきた“もの”のイベント類
          case "matching-request": {
            clientsMap.set(data.myName, socket);
            userDataMap.set("myName", data.myName); // 自分の名前、相手の名前、相手のできごとを保存
            userDataMap.set("myActive", data.myActive);
            userDataMap.set("pairName", data.pairName);
            userDataMap.set("pairActive", data.pairActive);
            console.log(data.pairName, data.pairActive);
            console.log(`matching-request received! user-data: ${data.myName},${data.pairName},${data.pairActive}`);
            const previousName = waitingList.get(data.pairName);  // get previous user's name

            if ((previousName != null) && (previousName === data.myName)) {
              // マッチングに成功した時の処理
              const jsonA = JSON.stringify({ event: "matching-success", pairName: data.pairName, pairActive: data.pairActive });
              const jsonB = JSON.stringify({ event: "matching-success", pairName: data.myName, pairActive: data.myActive });

              const clientA = clientsMap.get(data.myName);
              clientA.send(jsonA);
              const clientB = clientsMap.get(data.pairName);
              clientB.send(jsonB);
            } else {
              // マッチング待ちの時の処理
              waitingList.set(data.myName, data.pairName);
              const json = JSON.stringify({ event: "send-success" });
              socket.send(json);
            }
            break;
          }
          default:
            break;
        }
      };
      socket.onclose = () => console.log("DISCONNECTED"); // 接続が終わったときの処理

      socket.onerror = (error) => console.error("ERROR:", error); // エラーが発生したときの処理

      return response;

    } else {
      const pathname = new URL(req.url).pathname;
      console.log(pathname);

      if (req.method == "POST" && pathname === "/activity") {
        // アクティビティの保存処理
        const dbClient = await getkvData();
        const dateNow = new Date();
        const timeNow = dateNow.toISOString();

        const json = await req.json();
        const username = json["user_name"];
        const activity = json["activity"];
        const userIcon = json["user_icon"]
        // pngをjpegに変えること
        const image = json["image"];

        const result = await saveAll(dbClient, username, activity, image, timeNow);
        const result2 = await saveUserIcon(dbClient, username, userIcon, timeNow);
        console.log(`activity: ${result}`);
        console.log(`user_icon: ${result2}`);

        return new Response("ok");
      }


      if (req.method == "POST" && pathname === "/history") {
        // アクティビティの保存処理aaaaa
        const dbClient = await getkvData();
        console.log(dbClient);
        const dateNow = new Date();
        const timeNow = dateNow.toISOString();

        const json = await req.json();
        const username = json["username"];
        const pairname = json["pairname"];
        const pairactive = json["pairactive"];
        // pngをjpegに変えること
        console.log("setDB!!", username, pairname, pairactive);
        const result = await saveMatchAll(dbClient, username, pairname, pairactive, timeNow);
        console.log(`history = ${result}`);
        return new Response(result);
      }

      if (req.method == "GET" && pathname === "/image") {
        // マッチ画面で相手の画像を返す処理
        const url = new URL(req.url);
        const pairName = url.searchParams.get("pair_name");
        const pairAct = url.searchParams.get("pair_active");

        const kv = await getkvData(); // Databaseを開く

        if (pairName != null && pairAct == null) {
          // ユーザーネームだけならユーザーのアイコンを返す
          const image = await getUserIconImage(kv, pairName);
          const userIconValue = await image.value.img;
          return new Response(JSON.stringify({
            image: userIconValue
          })
          );
        }

        const imageGet = await getActivityImage(kv, pairName, pairAct);
        const pairActImg = await imageGet.value.img;
        console.log(`pairActImg = ${pairActImg}`);
        console.log(await imageGet.value.img);
        return new Response(JSON.stringify({
          image: imageGet.value.img,
        })
        );
      }
      if (req.method == "POST" && pathname === "/histories") {
        console.log("abc");
        const json = await req.json();  // JSONのデータを受け取る
        const username = json["username"]; // ペアした人の名前、活動をGet
        console.log(username);
        const kv = await getkvData();
        console.log(kv);
        await kv.set(["teacher", 2], { name: "じぇいぴー先生" });
        const getResult = await kv.get(["teacher", 2]);
        console.log("get_result: ", getResult);
        const listresult = kv.list({
          prefix: ["username", "hoge", "history"],
        });
        let array = [];
        let index = 0;
        for await (const item of listresult) {
          console.log("tetete")
          console.log(item.value);
          array.push(item.value);
          index++;
          if (index >= 5) {
            break;
          }
        }
        return new Response(array);
      }
      // publicフォルダ内にあるファイルを返す
      return serveDir(req, {

        fsRoot: "public",
        urlRoot: "",
        showDirListing: true,
        enableCors: true,
      });
    }
  }
});

async function getkvData() {//denokvをオープンする関数
  return await Deno.openKv(Deno.env.get("URL"));
}

async function saveAll(kv, username, activity, image, time) {
  return await kv.set(
    ["username", username, "activity", activity, "image"],
    {
      img: image,
      time: time
    }
  );
}

async function saveUserIcon(kv, username, image, time) {
  return await kv.set(
    ["username", username, "icon", "image"],
    {
      img: image,
      time: time
    }
  );
}

async function saveMatchAll(kv, username, pairname, pairactive, time) {
  console.log(kv);
  return await kv.set(
    ["username", username, "history", "time", time],
    {   //value
      pairName: pairname,
      pairActive: pairactive,
      time: time
    }
  );
}

async function getActivityImage(kv, username, activity) {
  return await kv.get(["username", username, "activity", activity, "image"]);
}

async function getUserIconImage(kv, username) {
  return await kv.get(["username", username, "icon", "image"]);
}