publish: v1.0.4

bin/server/lib/file-server.ts

@@ -80,14 +80,15 @@ export class FileServer {
         if (req) {
           sending = true;
           // send stream to the receiver
+          const { readable, writable } = new TransformStream();
           await new Promise<void>(async (r) => {
             try {
-              const { readable, writable } = new TransformStream();
               const file: File | null = (await req.formData()).get(
                 "file"
               ) as any;
               file?.stream()?.pipeTo(writable);
               resolve(readable);
+              console.log(`piping file to response: ${name}`);
               // wait for receiver to consume the stream
               const timeout = setTimeout(() => {
                 clearInterval(timer);
@@ -102,6 +103,7 @@ export class FileServer {
               }, 2000);
             } catch (err) {
               r();
+              writable.close();
               console.error(`error sending stream: ${err}`);
             }
           });

package.json

@@ -1,6 +1,6 @@
 {
   "name": "filestream",
-  "version": "1.0.3",
+  "version": "1.0.4",
   "description": "",
   "type": "module",
   "scripts": {

src-tauri/tauri.conf.json

@@ -7,7 +7,7 @@
   },
   "package": {
     "productName": "filestream",
-    "version": "1.0.3"
+    "version": "1.0.4"
   },
   "tauri": {
     "allowlist": {

src/routes/+page.svelte

@@ -10,11 +10,12 @@
   import QrcodeView from "../comp/qrcode-view.svelte";
   import Username from "../comp/username.svelte";
   import { Child, Command } from "@tauri-apps/api/shell";
-  import { resourceDir } from "@tauri-apps/api/path";
+  import { resolveResource } from "@tauri-apps/api/path";
 
   let server = new FileServer();
   let command: Command | undefined;
   let process: Child | undefined;
+  let webFiles: string | undefined;
   let showQr = false;
 
   onMount(async () => {
@@ -27,7 +28,7 @@
           let shareAddr = `${serverAddr}/?s=${encodeURIComponent(serverAddr)}`;
           server.serverAddr = serverAddr;
           server.shareAddr = shareAddr;
-          console.log(info, serverAddr, shareAddr);
+          console.log(info, { serverAddr, shareAddr, webFiles });
         }
       }
       server.connect();
@@ -42,17 +43,17 @@
 
   const startProcess = () =>
     new Promise<any>(async (resolve) => {
-      command = Command.sidecar(
-        "bin/server",
-        encodeURIComponent(await resourceDir())
-      );
+      webFiles = await resolveResource("../build");
+      command = Command.sidecar("bin/server", encodeURIComponent(webFiles));
       command.on("error", (_) => resolve(process?.kill()));
       command.on("close", (_) => resolve(process?.kill()));
       command.stdout.on("data", (d) => {
         try {
           let json = JSON.parse(String(d));
           resolve(json);
-        } catch (_) {}
+        } catch (_) {
+          console.log(d);
+        }
       });
       process = await command.spawn();
     });