diff options
| author | Adam Soltys <[email protected]> | 2025-01-14 15:50:49 -0800 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2025-01-14 15:50:49 -0800 |
| commit | b21b536817449b88c028a6cbe8ca6f21f4abcb46 (patch) | |
| tree | eb174dc4b27ebf61f654143fff18adb2ca8bc801 /lib/strfry.ts | |
| parent | 6560cc552aa8fecff14292bfa31e8369c42c2c73 (diff) | |
| download | coinos-server-b21b536817449b88c028a6cbe8ca6f21f4abcb46.tar.gz coinos-server-b21b536817449b88c028a6cbe8ca6f21f4abcb46.zip | |
use strfry scan
Diffstat (limited to 'lib/strfry.ts')
| -rw-r--r-- | lib/strfry.ts | 16 |
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`); |
