server.deno.js

import { serveDir } from 'https://deno.land/std@0.151.0/http/file_server.ts';
import { getCookies } from 'https://deno.land/std@0.74.0/http/mod.ts';
import { UserGame } from './model/UserGame.js';

import {
  DIFFICULTY_STRING,
  OUTPUT_TOPRANKING_NUMBER,
  THEME_SENTENCES,
} from './utils/constantValue.js';
import { MuxAsyncIterator } from 'https://deno.land/std@0.151.0/async/mux_async_iterator.ts';

function makeId() {
  return crypto.randomUUID();
}

/**
 * ランダムな文章とそのローマ字文章の組み合わせを出力
 * @returns [漢字入り文章,読み方]
 */
function getRandomThemeSentence(difficulty) {
  return THEME_SENTENCES[difficulty][
    Math.floor(Math.random() * THEME_SENTENCES[difficulty].length)
  ];
}

/**
 * エラーレスポンス生成
 * @param {String} errorMessage bodyのerrorMessageに載せる文字列
 * @param {String} errorCode bodyのerrorCodeに載せる文字列
 * @returns 400番のエラーレスポンス
 */
function makeErrorResponse(errorMessage, errorCode) {
  return new Response(
    JSON.stringify({
      'errorMessage': errorMessage,
      'errorCode': errorCode,
    }),
    {
      status: 400,
      headers: { 'Content-Type': 'application/json; charset=utf-8' },
    },
  );
}

/**
 * 200番レスポンスを生成
 * @param {JSON} bodyJson bodyに入れる辞書型
 * @returns 200番のレスポンス
 */
function make200Response(bodyJson) {
  return new Response(
    JSON.stringify(bodyJson),
    {
      status: 200,
      headers: { 'Content-Type': 'application/json; charset=utf-8' },
    },
  );
}

// idをキーにuserGameのインスタンスを保持する辞書型
const userGames = {};

Deno.serve(async (req) => {
  const pathname = new URL(req.url).pathname;
  console.log(pathname);

  // ユーザidをcookieに設定する
  if (req.method === 'GET' && pathname === '/getId') {
    if (getCookies(req)['id']) return new Response('id is already set');
    return new Response(
      'set id',
      {
        status: 200,
        headers: {
          'set-cookie': `id=${makeId()}; Max-Age=${2147483647}`,
        },
      },
    );
  }

  // ゲームスタートと同時に初期化
  if (req.method === 'POST' && pathname === '/solo/start') {
    if (!getCookies(req)['id']) {
      return makeErrorResponse('id in cookies is not set', '10001');
    }
    const id = getCookies(req)['id'];
    // 送られてきた難易度を取得
    const reqeustJson = await req.json();
    const difficulty = reqeustJson['difficulty'];
    // 送られた難易度が規定値以外ならエラー
    if (!DIFFICULTY_STRING.includes(difficulty)) {
      return makeErrorResponse('difficulty is different!', '10004');
    }
    const targetSentence = getRandomThemeSentence(difficulty);
    userGames[id] = new UserGame(
      id,
      difficulty,
      targetSentence[0],
      targetSentence[1],
    );
    return make200Response({
      'endTime': userGames[id].getEndTime(),
      'initializedScore': userGames[id].getInitializedScore(),
      'sentenceJapanese': userGames[id].getNowJapanese(),
      'sentenceAlphabet': userGames[id].getCompletedRoman() +
        userGames[id].getRemainingRoman(),
      'sentenceKana': userGames[id].getNowYomigana(),
      'expectedTime': userGames[id].calcExpectedTime(),
    });
  }

  // cookieのidからユーザごとに文章を取得する
  if (req.method === 'GET' && pathname === '/solo/getSentence') {
    if (!getCookies(req)['id']) {
      return makeErrorResponse('id in cookies is not set', '10001');
    }
    const id = getCookies(req)['id'];
    if (!userGames[id]) {
      return makeErrorResponse('UserGame insntance is not made', '10003');
    }
    return make200Response({
      'sentenceJapanese': userGames[id].getNowJapanese(),
      'sentenceAlphabet': userGames[id].getCompletedRoman() +
        userGames[id].getRemainingRoman(),
      'sentenceKana': userGames[id].getNowYomigana(),
      'expectedTime': userGames[id].calcExpectedTime(),
    });
  }

  // 1文字ごとに正誤判定を行う
  if (req.method === 'POST' && pathname === '/solo/sendCharacter') {
    if (!getCookies(req)['id']) {
      return makeErrorResponse('id in cookies is not set', '10001');
    }
    const id = getCookies(req)['id'];
    if (!userGames[id]) {
      return makeErrorResponse('UserGame insntance is not made', '10003');
    }
    const reqeustJson = await req.json();
    const sentChar = reqeustJson['alphabet'];
    const isCorrect = userGames[id].judgeAndCalcScore(sentChar);
    const response = make200Response({
      'isCorrect': isCorrect,
      'isCompleted': userGames[id].isCompleted(),
      'score': userGames[id].getTotalScore(),
      'meter': userGames[id].getMeter(),
      'fireworkSize': userGames[id].calcFireworkSize(),
      'enteredChars': userGames[id].getCompletedRoman(),
      'notEnteredChars': userGames[id].getRemainingRoman(),
      'enteredYomigana': userGames[id].getCompletedYomigana(),
      'notEnteredYomigana': userGames[id].getRemainingYomigana(),
    });
    // 前回と違う文章が出るまで再抽選
    if (userGames[id].isCompleted()) {
      let targetSentence = getRandomThemeSentence(
        userGames[id].getDifficulty(),
      );
      while (userGames[id].getNowJapanese() === targetSentence[0]) {
        targetSentence = getRandomThemeSentence(
          userGames[id].getDifficulty(),
        );
      }
      userGames[id].setSentenceNow(targetSentence[0], targetSentence[1]);
    }
    return response;
  }

  // 結果取得
  if (req.method === 'GET' && pathname === '/solo/getResult') {
    if (!getCookies(req)['id']) {
      return makeErrorResponse('id in cookies is not set', '10001');
    }
    const id = getCookies(req)['id'];
    if (!userGames[id]) {
      return makeErrorResponse('UserGame insntance is not made', '10003');
    }
    // Deno KVにアクセス
    const kv = await Deno.openKv();
    // ハイスコアを取得し、KVにないかもしくは今回の得点の方が高かったら更新
    const kvHighScore =
      (await kv.get(['highScore', userGames[id].getDifficulty(), id]))['value'];
    if (!kvHighScore || kvHighScore < userGames[id].getTotalScore()) {
      await kv.set(
        ['highScore', userGames[id].getDifficulty(), id],
        userGames[id].getTotalScore(),
      );
    }
    // ハイスコア再取得
    const highScore =
      (await kv.get(['highScore', userGames[id].getDifficulty(), id]))['value'];
    // ランキングスコア取得
    const rankingScore =
      (await kv.get(['ranking', userGames[id].getDifficulty(), id]))['value']
        ?.score;
    return make200Response({
      'score': userGames[id].getTotalScore(),
      'fireworkCount': userGames[id].calcTotalFireworks(),
      'typesPerSecond': userGames[id].calcTypesPerSecond(),
      'typeCount': userGames[id].getTotalCorrectTypeCount(),
      'typeMissCount': userGames[id].calcTotalMissType(),
      'highScore': highScore,
      'rankingScore': rankingScore,
    });
  }

  // ランキング送信
  if (req.method === 'POST' && pathname === '/solo/sendRanking') {
    if (!getCookies(req)['id']) {
      return makeErrorResponse('id in cookies is not set', '10001');
    }
    const id = getCookies(req)['id'];
    if (!userGames[id]) {
      return makeErrorResponse('UserGame insntance is not made', '10003');
    }
    // POST時に送信されてユーザーネームを取得
    const reqeustJson = await req.json();
    const userName = reqeustJson['userName'];
    // Deno KVにアクセス
    const kv = await Deno.openKv();
    // ハイスコア取得
    const highScore =
      (await kv.get(['highScore', userGames[id].getDifficulty(), id]))['value'];
    // キーと値を設定
    const kvKey = ['ranking', userGames[id].getDifficulty(), id];
    const kvValue = { 'score': highScore, 'userName': userName };
    // ランキングスコアが未登録、またはそれよりハイスコアが上ならスコアを登録する
    const rankingScore = (await kv.get(kvKey))['value']?.score;
    if (
      (highScore || highScore === 0) &&
      (!rankingScore || highScore > rankingScore)
    ) {
      const kvResult = await kv.set(kvKey, kvValue);
      return make200Response({
        'isSuccessful': kvResult['ok'],
      });
    } // ハイスコアがランキングスコア以下なら登録しない
    else {
      return make200Response({
        'isSuccessful': false,
      });
    }
  }

  if (req.method === 'POST' && pathname === '/solo/getRanking') {
    // 送られてきた難易度を取得
    const reqeustJson = await req.json();
    const difficulty = reqeustJson['difficulty'];
    // 送られた難易度が規定値以外ならエラー
    if (!DIFFICULTY_STRING.includes(difficulty)) {
      return makeErrorResponse('difficulty is different!', '10004');
    }
    // Deno KVにアクセス
    const kv = await Deno.openKv();
    // ランキングに登録されているkeyを取得してリスト化
    const listResult = await kv.list({ prefix: ['ranking', difficulty] });
    const listRanking = [];
    for await (const item of listResult) {
      listRanking.push(item['value']);
    }
    // 降順ソート
    listRanking.sort((a, b) => (a.score > b.score ? -1 : 1));
    // 上位10位までスライスして返答
    return make200Response({
      'top10Results': listRanking.slice(0, OUTPUT_TOPRANKING_NUMBER),
    });
  }

  return serveDir(req, {
    fsRoot: 'public',
    urlRoot: '',
    showDirListing: true,
    enableCors: true,
  });
});