aboutsummaryrefslogtreecommitdiffstats
path: root/lib/strfry.ts
diff options
context:
space:
mode:
Diffstat (limited to 'lib/strfry.ts')
-rw-r--r--lib/strfry.ts16
1 files changed, 8 insertions, 8 deletions
diff --git a/lib/strfry.ts b/lib/strfry.ts
index 9caa539e..231e3533 100644
--- a/lib/strfry.ts
+++ b/lib/strfry.ts
@@ -1,5 +1,5 @@
-import { createServer, connect } from "net";
import { randomUUID } from "crypto";
+import { connect, createServer } from "net";
const exec = async (cmd) =>
new Promise((resolve, reject) => {
@@ -13,7 +13,6 @@ const exec = async (cmd) =>
const results = [];
socket.on("data", (data) => {
resultBuffer += data.toString();
-
const parts = resultBuffer.split("\n");
for (let i = 0; i < parts.length - 1; i++) {
@@ -44,16 +43,17 @@ const exec = async (cmd) =>
controlClient.end();
});
- controlClient.on("error", (e) =>
- reject(`Control socket error: ${e.message}`),
- );
+ controlClient.on("error", (e) => {
+ reject(`Control socket error: ${e.message}`);
+ });
});
- resultServer.on("error", (e) =>
- reject(`Result server error: ${e.message}`),
- );
+ resultServer.on("error", (e) => {
+ reject(`Result server error: ${e.message}`);
+ });
});
+export const count = (f) => exec(`scan --count '${JSON.stringify(f)}'\n`);
export const scan = (f) => exec(`scan '${JSON.stringify(f)}'\n`);
export const sync = (r, f) =>
exec(`sync ${r} --dir down --filter '${JSON.stringify(f)}'\n`);