as-soon - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

dist/cli.js

@@ -48,2 +48,3 @@ #!/usr/bin/env node
 var commandToUse = command;
+console.log(`"${commandToUse}"`);
 loadEnv({ mode: deploymentContext });
@@ -79,13 +80,16 @@ function _execute() {
     } else {
-      let tmp_subscription = yield watcher.subscribe(path.dirname(absolute_path), (err, events) => {
-        for (const event of events) {
-          if (event.type === "create" && path.normalize(event.path) === absolute_path) {
-            tmp_subscription == null ? void 0 : tmp_subscription.unsubscribe();
-            tmp_subscription = void 0;
-            setTimeout((v) => {
-              subscribe_target(absolute_path, execute);
-            }, 500);
+      let tmp_subscription = yield watcher.subscribe(
+        path.dirname(absolute_path),
+        (err, events) => {
+          for (const event of events) {
+            if (event.type === "create" && path.normalize(event.path) === absolute_path) {
+              tmp_subscription == null ? void 0 : tmp_subscription.unsubscribe();
+              tmp_subscription = void 0;
+              setTimeout((v) => {
+                subscribe_target(absolute_path, execute);
+              }, 500);
+            }
           }
         }
-      });
+      );
     }
@@ -97,4 +101,11 @@ });
     const execute = debounce(_execute, 50);
-    for (const p of options["w"]) {
-      const absolute_path = path.normalize(path.join(process.cwd(), p));
+    if (options["w"]) {
+      console.log(`listening on: ${options["w"].join(", ")}`);
+      for (const p of options["w"]) {
+        const absolute_path = path.normalize(path.join(process.cwd(), p));
+        listen(absolute_path, execute);
+      }
+    } else {
+      console.log(`listening on current folder`);
+      const absolute_path = path.normalize(process.cwd());
       listen(absolute_path, execute);
@@ -101,0 +112,0 @@ }

package.json

 {
 	"name": "as-soon",
-	"version": "0.0.4",
+	"version": "0.0.5",
 	"description": "watch and execute",
@@ -5,0 +5,0 @@ "publishConfig": {

src/cli.ts

 #!/usr/bin/env node
-import { execFileSync } from 'child_process';
-import watcher, { AsyncSubscription } from "@parcel/watcher";
-import path from "node:path";
-import fs from "node:fs";
-import { debounce } from "lodash";
-import { loadEnv } from "ldenv";
+import {execFileSync} from 'child_process';
+import watcher, {AsyncSubscription} from '@parcel/watcher';
+import path from 'node:path';
+import fs from 'node:fs';
+import {debounce} from 'lodash';
+import {loadEnv} from 'ldenv';
 
@@ -12,44 +12,46 @@ const args = process.argv.slice(2);
 function error(msg: string) {
-  console.error(msg);
-  process.exit(1);
+	console.error(msg);
+	process.exit(1);
 }
 
-let deploymentContext = "localhost";
+let deploymentContext = 'localhost';
 let argToConsume;
 let command: string | undefined;
 let commandArgs: string[] | undefined;
-const options: { [key: string]: string[] } = {};
+const options: {[key: string]: string[]} = {};
 for (let i = 0; i < args.length; i++) {
-  const arg = args[i];
-  if (arg.startsWith("--")) {
-    argToConsume = arg.substring(2);
-  } else if (arg.startsWith("-")) {
-    argToConsume = arg.substring(1);
-  } else {
-    if (argToConsume) {
-      if (options[argToConsume]) {
-        options[argToConsume].push(arg);
-      } else {
-        options[argToConsume] = [arg];
-      }
-      argToConsume = undefined;
-    } else {
-      command = arg;
-      commandArgs = args.slice(i + 1);
-      break;
-    }
-  }
+	const arg = args[i];
+	if (arg.startsWith('--')) {
+		argToConsume = arg.substring(2);
+	} else if (arg.startsWith('-')) {
+		argToConsume = arg.substring(1);
+	} else {
+		if (argToConsume) {
+			if (options[argToConsume]) {
+				options[argToConsume].push(arg);
+			} else {
+				options[argToConsume] = [arg];
+			}
+			argToConsume = undefined;
+		} else {
+			command = arg;
+			commandArgs = args.slice(i + 1);
+			break;
+		}
+	}
 }
 
 if (!command) {
-  error(`please specify a command`);
+	error(`please specify a command`);
 }
 const commandToUse = command!;
 
-loadEnv({ mode: deploymentContext });
+console.log(`"${commandToUse}"`);
 
+loadEnv({mode: deploymentContext});
+
 async function _execute() {
-  try {
-    execFileSync(commandToUse, commandArgs, { stdio: ["inherit", "inherit", "inherit"] });
-  } catch { }
+	try {
+		execFileSync(commandToUse, commandArgs, {stdio: ['inherit', 'inherit', 'inherit']});
+	} catch {}
 }
@@ -59,47 +61,58 @@
 async function subscribe_target(absolute_path: string, execute: () => void) {
-  // const c = ++counter;
-  const p = path.relative(process.cwd(), absolute_path);
-  const subscription = await watcher.subscribe(absolute_path, (err, events) => {
-    // console.log(`Files changed under ${p} (${c})`);
-    console.log(`Files changed under ${p}`);
-    for (const event of events) {
-      if (event.type === 'delete' && event.path === absolute_path) {
-        subscription.unsubscribe();
-        listen(absolute_path, execute);
-        return;
-      }
-    }
-    execute();
-  });
+	// const c = ++counter;
+	const p = path.relative(process.cwd(), absolute_path);
+	const subscription = await watcher.subscribe(absolute_path, (err, events) => {
+		// console.log(`Files changed under ${p} (${c})`);
+		console.log(`Files changed under ${p}`);
+		for (const event of events) {
+			if (event.type === 'delete' && event.path === absolute_path) {
+				subscription.unsubscribe();
+				listen(absolute_path, execute);
+				return;
+			}
+		}
+		execute();
+	});
 }
 
 async function listen(absolute_path: string, execute: () => void) {
-  if (fs.existsSync(absolute_path)) {
-    subscribe_target(absolute_path, execute);
-  } else {
-    // console.log(`${absolute_path} do not exist yet, listening on parent`)
-    let tmp_subscription: AsyncSubscription | undefined = await watcher.subscribe(path.dirname(absolute_path), (err, events) => {
-      for (const event of events) {
-        if (event.type === 'create' && path.normalize(event.path) === absolute_path) {
-          // console.log(`${absolute_path} just got created, listening for it...`);
-          tmp_subscription?.unsubscribe();
-          tmp_subscription = undefined;
-          // wrap in a timeout to ensure @parcel/watcher hook on the correct inode?
-          setTimeout(v => {
-            subscribe_target(absolute_path, execute);
-          }, 500);
-        }
-      }
-    });
-  }
+	if (fs.existsSync(absolute_path)) {
+		subscribe_target(absolute_path, execute);
+	} else {
+		// console.log(`${absolute_path} do not exist yet, listening on parent`)
+		let tmp_subscription: AsyncSubscription | undefined = await watcher.subscribe(
+			path.dirname(absolute_path),
+			(err, events) => {
+				for (const event of events) {
+					if (event.type === 'create' && path.normalize(event.path) === absolute_path) {
+						// console.log(`${absolute_path} just got created, listening for it...`);
+						tmp_subscription?.unsubscribe();
+						tmp_subscription = undefined;
+						// wrap in a timeout to ensure @parcel/watcher hook on the correct inode?
+						setTimeout((v) => {
+							subscribe_target(absolute_path, execute);
+						}, 500);
+					}
+				}
+			}
+		);
+	}
 }
 
 async function main() {
-  const execute = debounce(_execute, 50);
-  for (const p of options["w"]) {
-    const absolute_path = path.normalize(path.join(process.cwd(), p));
-    listen(absolute_path, execute);
-  }
-  execute();
+	const execute = debounce(_execute, 50);
+	if (options['w']) {
+		console.log(`listening on: ${options['w'].join(', ')}`);
+		for (const p of options['w']) {
+			const absolute_path = path.normalize(path.join(process.cwd(), p));
+			listen(absolute_path, execute);
+		}
+	} else {
+		console.log(`listening on current folder`);
+		const absolute_path = path.normalize(process.cwd());
+		listen(absolute_path, execute);
+	}
+
+	execute();
 }
 main();

No alert changes

Improved metrics

Total package byte prevSize

26777

8.09%

Number of package files

22

4.76%

Lines of code

449

7.93%

No dependency changes