Merge pull request #42 from takker99/feature-cache

✨ Implemented functions operating cache storages

Author: takker99

browser/dom/cache.ts

@@ -0,0 +1,77 @@
+/// <reference no-default-lib="true"/>
+/// <reference lib="esnext"/>
+/// <reference lib="dom" />
+
+/** scrapbox.ioが管理しているcache storageから、最新のresponseを取得する
+ *
+ * ほぼ https://scrapbox.io/daiiz/ScrapboxでのServiceWorkerとCacheの活用#5d2efaffadf4e70000651173 のパクリ
+ *
+ * @param request このrequestに対応するresponseが欲しい
+ * @param options search paramsを無視したいときとかに使う
+ * @return cacheがあればそのresponseを、なければ`undefined`を返す
+ */
+export const findLatestCache = async (
+  request: Request,
+  options?: CacheQueryOptions,
+): Promise<Response | undefined> => {
+  const cacheNames = await globalThis.caches.keys();
+
+  for (const date of cacheNames.sort().reverse()) {
+    const cache = await caches.open(date);
+    const res = await cache.match(request, options);
+    if (res) return res;
+  }
+};
+
+/** prefetchを実行する
+ *
+ * prefetchしたデータは`"prefetch"`と`"api-yyyy-MM-dd"`に格納される
+ *
+ * `"prefetch"`に格納されたデータは、次回のリクエストで返却されたときに削除される
+ *
+ * 回線が遅いときは例外を投げる
+ *
+ * @param urls prefetchしたいAPIのURLのリスト
+ */
+export const prefetch = async (
+  urls: (string | URL)[],
+): Promise<void> => {
+  await postMessage({
+    title: "prefetch",
+    body: { urls: urls.map((url) => url.toString()) },
+  });
+};
+
+/** 指定したAPIのcacheの更新を依頼する
+ *
+ * 更新は10秒ごとに1つずつ実行される
+ *
+ * @param cacheしたいAPIのURL
+ */
+export const fetchApiCache = async (
+  url: string,
+): Promise<void> => {
+  await postMessage({ title: "fetchApiCache", body: { url } });
+};
+
+const postMessage = <T, U = unknown>(
+  data: { title: string; body: T },
+): Promise<U> => {
+  const { controller } = navigator.serviceWorker;
+  if (!controller) {
+    const error = new Error();
+    error.name = "ServiceWorkerNotActiveYetError";
+    error.message = "Service worker is not active yet";
+    throw error;
+  }
+
+  return new Promise<U>((resolve, reject) => {
+    const channel = new MessageChannel();
+    channel.port1.addEventListener(
+      "message",
+      (event) =>
+        event.data?.error ? reject(event.data.error) : resolve(event.data),
+    );
+    controller.postMessage(data, [channel.port2]);
+  });
+};

browser/dom/mod.ts

@@ -7,3 +7,4 @@ export * from "./statusBar.ts";
 export * from "./caret.ts";
 export * from "./dom.ts";
 export * from "./openInTheSameTab.ts";
+export * from "./cache.ts";