Update

functions/deps.ts

@@ -44,3 +44,4 @@ export {
 export {
   type AuthInput,
 } from "https://dev.zaubrik.com/[email protected]/server/mod.ts";
+export { queue } from "https://dev.zaubrik.com/[email protected]/generator.js";

functions/log.ts

@@ -0,0 +1,16 @@
+import { join, queue } from "./deps.ts";
+import { ensureSymlinkedDataDirectorySync } from "./fs.ts";
+
+/**
+ * ```js
+ * const log = logTo("server.localhost", "./worker.log");
+ * log.next("aaaaaaaaa");
+ * log.next("bbbbbbbbb");
+ * ```
+ */
+export function logTo(dirname: string, filename: string) {
+  return queue(async (message: string) => {
+    const dataPath = join(ensureSymlinkedDataDirectorySync(dirname), filename);
+    await Deno.writeTextFile(dataPath, message + "\n", { append: true });
+  });
+}

middlewares/deps.ts

@@ -61,6 +61,7 @@ export {
   type UrlProperties,
 } from "https://dev.zaubrik.com/[email protected]/url.js";
 export { copyResponse } from "https://dev.zaubrik.com/[email protected]/response.js";
+export { queue } from "https://dev.zaubrik.com/[email protected]/generator.js";
 export {
   isEmpty,
 } from "https://dev.zaubrik.com/[email protected]/collections/length.js";

middlewares/log.ts

@@ -5,6 +5,7 @@ import {
   isPresent,
   isUrl,
   join,
+  queue,
 } from "./deps.ts";
 import { getPathnameFs, resolveMainModule } from "../functions/path.ts";
 
@@ -29,28 +30,6 @@ function createLog<C extends Context>(ctx: C) {
   };
 }
 
-// deno-lint-ignore no-explicit-any
-export function queue(f: any) {
-  // deno-lint-ignore no-explicit-any
-  async function* makeGenerator(): any {
-    // deno-lint-ignore no-explicit-any
-    let passedValue: any;
-    // deno-lint-ignore no-explicit-any
-    let result: any;
-    let i = 0;
-    while (true) {
-      // deno-lint-ignore no-explicit-any
-      passedValue = yield result as any;
-      // deno-lint-ignore no-explicit-any
-      result = await f(passedValue, i) as any;
-      i++;
-    }
-  }
-  const generator = makeGenerator();
-  generator.next();
-  return generator;
-}
-
 function logWithOptions(path: string, options: LoggerOptions) {
   Deno.mkdirSync(dirname(path), { recursive: true });
   return async ({ logObject, error }: {
@@ -61,7 +40,7 @@ function logWithOptions(path: string, options: LoggerOptions) {
       console.error(error);
     }
     if (options.print) {
-      console.log(JSON.stringify(logObject, null, 4));
+      console.log(JSON.stringify(logObject, null, 2));
     }
     if (options.file) {
       await Deno.writeTextFile(path, JSON.stringify(logObject) + "\n", {