aboutsummaryrefslogtreecommitdiffstats
path: root/lib/strfry.ts
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2025-01-14 15:50:49 -0800
committerAdam Soltys <[email protected]>2025-01-14 15:50:49 -0800
commitb21b536817449b88c028a6cbe8ca6f21f4abcb46 (patch)
treeeb174dc4b27ebf61f654143fff18adb2ca8bc801 /lib/strfry.ts
parent6560cc552aa8fecff14292bfa31e8369c42c2c73 (diff)
downloadcoinos-server-b21b536817449b88c028a6cbe8ca6f21f4abcb46.tar.gz
coinos-server-b21b536817449b88c028a6cbe8ca6f21f4abcb46.zip
use strfry scan
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`);