mirror of
https://github.com/tauri-apps/plugins-workspace.git
synced 2026-04-29 12:06:01 +02:00
53 lines
1.2 KiB
TypeScript
53 lines
1.2 KiB
TypeScript
import { invoke } from "@tauri-apps/api/tauri";
|
|
import { appWindow } from "@tauri-apps/api/window";
|
|
|
|
interface ProgressPayload {
|
|
id: number;
|
|
progress: number;
|
|
total: number;
|
|
}
|
|
|
|
type ProgressHandler = (progress: number, total: number) => void;
|
|
const handlers: Map<number, ProgressHandler> = new Map();
|
|
let listening = false;
|
|
|
|
async function listenToUploadEventIfNeeded(): Promise<void> {
|
|
if (listening) {
|
|
return await Promise.resolve();
|
|
}
|
|
return await appWindow
|
|
.listen<ProgressPayload>("upload://progress", ({ payload }) => {
|
|
const handler = handlers.get(payload.id);
|
|
if (handler != null) {
|
|
handler(payload.progress, payload.total);
|
|
}
|
|
})
|
|
.then(() => {
|
|
listening = true;
|
|
});
|
|
}
|
|
|
|
export default async function upload(
|
|
url: string,
|
|
filePath: string,
|
|
progressHandler?: ProgressHandler,
|
|
headers?: Map<string, string>
|
|
): Promise<void> {
|
|
const ids = new Uint32Array(1);
|
|
window.crypto.getRandomValues(ids);
|
|
const id = ids[0];
|
|
|
|
if (progressHandler != null) {
|
|
handlers.set(id, progressHandler);
|
|
}
|
|
|
|
await listenToUploadEventIfNeeded();
|
|
|
|
await invoke("plugin:upload|upload", {
|
|
id,
|
|
url,
|
|
filePath,
|
|
headers: headers ?? {},
|
|
});
|
|
}
|