修復タイマーを実装

Author: otiai10

package.json

@@ -19,7 +19,8 @@
     "jstorm": "^0.17.0",
     "react": "^18.2.0",
     "react-dom": "^18.2.0",
-    "react-router-dom": "^6.17.0"
+    "react-router-dom": "^6.17.0",
+    "tesseract.js": "^5.1.1"
   },
   "devDependencies": {
     "@testing-library/jest-dom": "^6.5.0",

pnpm-lock.yaml

@@ -19,10 +19,12 @@ chrome.notifications.onClicked.addListener(onClicked.listener());
 // queueを見てるcronを起動
 chrome.alarms.create('/cron/queues', { periodInMinutes: 0.5 });
 
-import { Launcher } from "./services/Launcher";
-import { Frame } from "./models/Frame";
-(async () => {
-  const launcher = new Launcher();
-  const frame = await Frame.memory();
-  launcher.launch(frame);
-})();
+// import { Launcher } from "./services/Launcher";
+// import { Frame } from "./models/Frame";
+// (async () => {
+//   const launcher = new Launcher();
+//   const frame = await Frame.memory();
+//   launcher.launch(frame);
+// })();
+
+

src/background.ts

@@ -1,5 +1,10 @@
-import { Router } from "chromite";
+import { Logger, Router } from "chromite";
 import { Frame } from "../models/Frame";
+import { type Page } from "tesseract.js";
+import { EntryType, Recovery } from "../models/entry";
+import { H, M, S, sleep } from "../utils";
+import Queue from "../models/Queue";
+import { TriggerType } from "../models/entry/Base";
 
 const onMessage = new Router<chrome.runtime.ExtensionMessageEvent>();
 
@@ -8,4 +13,16 @@ onMessage.on("/frame/memory:track", async (req) => {
   return await frame.update({ position: req.position, size: req.size });
 });
 
+onMessage.on("/injected/dmm/ocr:result", async (req) => {
+  const data = req.data as Page;
+  const dock = req[EntryType.RECOVERY].dock;
+  const [h, m, s] = data.text.split(":").map(Number);
+  new Logger("ocr").info({ h, m, s });
+  const r = new Recovery(dock, (h * H + m * M + s * S));
+  await Queue.create({ type: EntryType.RECOVERY, params: r, scheduled: Date.now() + r.time });
+  await chrome.notifications.create(r.$n.id(TriggerType.START), r.$n.options(TriggerType.START));
+  await sleep(6 * 1000);
+  await chrome.notifications.clear(r.$n.id(TriggerType.START));
+});
+
 export { onMessage };

src/controllers/Message.ts

@@ -8,3 +8,9 @@ export interface MissionStartFormData {
     // api_token: string[];
     // api_verno: string[];
 }
+
+export interface RecoveryStartFormData {
+    api_highspeed: string[];
+    api_ndock_id: string[];
+    api_ship_id: string[];
+}

src/controllers/WebRequest/datatypes.ts

@@ -1,10 +1,14 @@
-import { Router } from "chromite";
+import {
+  // Logger,
+  Router,
+} from "chromite";
 
 import {
   onPort,
   onMissionStart,
   onMissionReturnInstruction,
   onMissionResult,
+  onRecoveryStart,
 } from "./kcsapi";
 
 const onBeforeRequest = new Router<chrome.webRequest.WebRequestBodyEvent>(async (details) => {
@@ -16,6 +20,7 @@ onBeforeRequest.on("/kcsapi/api_port/port", onPort);
 onBeforeRequest.on("/kcsapi/api_req_mission/start", onMissionStart); // 遠征に出したとき
 onBeforeRequest.on("/kcsapi/api_req_mission/return_instruction", onMissionReturnInstruction); // 遠征帰還命令出したとき
 onBeforeRequest.on("/kcsapi/api_req_mission/result", onMissionResult); // 遠征結果の回収をしたとき
+onBeforeRequest.on("/kcsapi/api_req_nyukyo/start", onRecoveryStart); // 修復用の入渠をしようとしたとき
 
 onBeforeRequest.onNotFound(async (
   // detail: chrome.webRequest.WebRequestBodyDetails,

src/controllers/WebRequest/index.ts

@@ -2,9 +2,10 @@ import { Logger } from "chromite";
 import { missions } from "../../catalog";
 import { sleep } from "../../utils";
 import Queue from "../../models/Queue";
-import { MissionStartFormData } from "./datatypes";
+import { MissionStartFormData, RecoveryStartFormData } from "./datatypes";
 import { EntryType, Mission } from "../../models/entry";
 import { TriggerType } from "../../models/entry/Base";
+import { TabService } from "../../services/TabService";
 
 const log = new Logger("WebRequest");
 
@@ -29,4 +30,16 @@ export async function onMissionReturnInstruction(details: chrome.webRequest.WebR
 
 export async function onMissionResult(details: chrome.webRequest.WebRequestBodyDetails) {
   log.info("onMissionResult", details);
-}
+}
+
+export async function onRecoveryStart(details: chrome.webRequest.WebRequestBodyDetails) {
+  const data = details.requestBody?.formData as unknown as RecoveryStartFormData;
+  const dock = data.api_ndock_id[0];
+  const tab = await new TabService().get(details.tabId);
+  const url = await chrome.tabs.captureVisibleTab(tab.windowId, { format: "jpeg" });
+  await chrome.tabs.sendMessage(details.tabId, {
+    __action__: "/injected/dmm/ocr",
+    url, purpose: EntryType.RECOVERY,
+    [EntryType.RECOVERY]: { dock }
+  });
+}