Fix formatting

Author: taras

.github/workflows/verify.yaml

@@ -26,14 +26,13 @@ jobs:
         uses: denoland/setup-deno@v2
         with:
           deno-version: v2.x
+      - name: reload dependencies
+        run: deno cache --reload **/mod.ts
 
-      # - name: reload dependencies
-      #   run: deno cache --reload **/mod.ts
+      - run: deno check tasks/*.ts
 
-      # - run: deno check tasks/*.ts
+      - run: deno fmt --check
 
-      # - run: deno fmt --check
+      - run: deno lint
 
-      # - run: deno lint
-
-      - run: deno test --trace-leaks --allow-net --allow-read --allow-write --allow-env --allow-run --allow-ffi
+      - run: deno test --allow-net --allow-read --allow-write --allow-env --allow-run --allow-ffi

process/src/exec/posix.ts

@@ -1,18 +1,17 @@
 import { spawn as spawnProcess } from "node:child_process";
 import {
-all,
+  all,
   createSignal,
   Err,
   Ok,
-  race,
   type Result,
   sleep,
   spawn,
   withResolvers,
 } from "effection";
 import process from "node:process";
 import { once } from "../eventemitter.ts";
-import { box, useReadable } from "../helpers.ts";
+import { useReadable } from "../helpers.ts";
 import type { CreateOSProcess, ExitStatus, Writable } from "./api.ts";
 import { ExecError } from "./error.ts";
 
@@ -53,20 +52,20 @@ export const createPosixProcess: CreateOSProcess = function* createPosixProcess(
     stderrDone: withResolvers<void>(),
   };
 
-  yield* spawn(function*() {
-    yield* once(childProcess.stdout, 'readable');
+  yield* spawn(function* () {
+    yield* once(childProcess.stdout, "readable");
     console.log("posix > stdout is readable");
     io.stdoutReady.resolve();
-    yield* once(childProcess.stdout, 'end');
+    yield* once(childProcess.stdout, "end");
     console.log("posix > stdout is done");
     io.stdoutDone.resolve();
   });
 
-  yield* spawn(function*() {
-    yield* once(childProcess.stderr, 'readable');
+  yield* spawn(function* () {
+    yield* once(childProcess.stderr, "readable");
     console.log("posix > stderr is readable");
     io.stderrReady.resolve();
-    yield* once(childProcess.stderr, 'end');
+    yield* once(childProcess.stderr, "end");
     console.log("posix > err is done");
     io.stderrDone.resolve();
   });
@@ -103,11 +102,15 @@ export const createPosixProcess: CreateOSProcess = function* createPosixProcess(
       childProcess.stdin.write(data);
     },
   };
-  
+
   yield* spawn(function* () {
     try {
       let value = yield* once<ProcessResultValue>(childProcess, "close");
-      yield* all([io.stdoutReady.operation, io.stderrReady.operation, sleep(1)]);
+      yield* all([
+        io.stdoutReady.operation,
+        io.stderrReady.operation,
+        sleep(1),
+      ]);
       processResult.resolve(Ok(value));
     } finally {
       try {

process/src/exec/win32.ts

@@ -73,11 +73,10 @@ export const createWin32Process: CreateOSProcess = function* createWin32Process(
   });
 
   yield* spawn(function* trapError() {
-    const [error] = yield* once<Error[]>(childProcess, "error");    
+    const [error] = yield* once<Error[]>(childProcess, "error");
     processResult.resolve(Err(error));
   });
 
-
   let stdin: Writable<string> = {
     send(data: string) {
       childProcess.stdin.write(data);

process/test/daemon.test.ts

@@ -19,10 +19,10 @@ describe("daemon", () => {
       task = yield* spawn<void>(function* () {
         let proc = yield* daemon("deno", {
           arguments: ["run", "-A", "./fixtures/echo-server.ts"],
-          env: { 
-            PORT: "29000", 
+          env: {
+            PORT: "29000",
             PATH: process.env.PATH as string,
-            ... SystemRoot ? { SystemRoot } : {}
+            ...SystemRoot ? { SystemRoot } : {},
           },
           cwd: import.meta.dirname,
         });
@@ -69,10 +69,10 @@ describe("daemon", () => {
     beforeEach(function* () {
       let proc = yield* daemon("deno", {
         arguments: ["run", "-A", "./fixtures/echo-server.ts"],
-        env: { 
-          PORT: "29000", 
+        env: {
+          PORT: "29000",
           PATH: process.env.PATH as string,
-          ... SystemRoot ? { SystemRoot } : {} 
+          ...SystemRoot ? { SystemRoot } : {},
         },
         cwd: import.meta.dirname,
       });

watch/test/watch.test.ts

@@ -113,7 +113,7 @@ function* useFixture(): Operation<Fixture> {
   try {
     yield* until(emptyDir(tmpDir));
   } catch (e) {
-    console.log(`Encountered error clearing ${tmpDir}`)
+    console.log(`Encountered error clearing ${tmpDir}`);
     console.error(e);
   }
 
@@ -126,8 +126,8 @@ function* useFixture(): Operation<Fixture> {
       }),
     );
   } catch (e) {
-    console.log(`Encountered error copying from ${fixtureDir} to ${tmpDir}`)
-    console.error(e)
+    console.log(`Encountered error copying from ${fixtureDir} to ${tmpDir}`);
+    console.error(e);
   }
 
   return {
@@ -198,7 +198,6 @@ function* inspector(stream: Stream<Start, never>) {
           yield* sleep(10);
           expected = starts.length;
           let result = inspector.starts[inspector.starts.length - 1];
-          console.log(result)
           if (result.ok) {
             return result.value;
           } else {

watch/watch.ts

@@ -120,7 +120,6 @@ export function watch(options: WatchOptions): Stream<Start, never> {
       }
       let [, path] = args;
       if (fresh(500)(args) && !gitignored(path)) {
-        console.log(`received updated: ${JSON.stringify(args)}`)
         input.send(args);
       }
     });