Compare commits

..

No commits in common. "c1b4e668e2152d83b61477081b754f41128ca8bc" and "8d4fcfba5c972d1c353e75a4c9e92a23a3b852c5" have entirely different histories.

4 changed files with 31 additions and 30 deletions

View File

@ -21,7 +21,7 @@ export const PinningNetworkBanner = () => {
const itemsLeft = useMemo( const itemsLeft = useMemo(
() => () =>
data?.items.filter((item: PinningStatus) => data?.items.filter((item: PinningStatus) =>
item.status.includes("processing"), item.status.includes("inprogress"),
) || [], ) || [],
[data], [data],
); );

View File

@ -1,36 +1,30 @@
import {PROTOCOL_S5, Sdk} from "@lumeweb/portal-sdk";
import {useSdk} from "~/components/lib/sdk-context.js";
import {S5Client} from "@lumeweb/s5-js";
export interface PinningStatus { export interface PinningStatus {
id: string; id: string;
progress: number; progress: number;
status: 'processing' | 'completed'; status: 'inprogress' | 'completed' | 'stale';
} }
// biome-ignore lint/complexity/noStaticOnlyClass: <explanation> // biome-ignore lint/complexity/noStaticOnlyClass: <explanation>
export class PinningProcess { export class PinningProcess {
private static instances: Map<string, PinningStatus> = new Map(); private static instances: Map<string, PinningStatus> = new Map();
private static sdk?: Sdk;
static async pin(id: string): Promise<{ success: boolean; message: string }> { static async pin(id: string): Promise<{ success: boolean; message: string }> {
const s5 = PinningProcess.sdk?.protocols().get<S5Client>(PROTOCOL_S5)!.getSdk()!;
if (PinningProcess.instances.has(id)) { if (PinningProcess.instances.has(id)) {
return { success: false, message: "ID is already being processed" }; return { success: false, message: "ID is already being processed" };
} }
const pinningStatus: PinningStatus = {id, progress: 0, status: 'processing'}; const pinningStatus: PinningStatus = { id, progress: 0, status: 'inprogress' };
PinningProcess.instances.set(id, pinningStatus); PinningProcess.instances.set(id, pinningStatus);
await s5.pin(id); // Simulate async progress
(async () => { (async () => {
const ret = await s5.pinStatus(id); for (let progress = 1; progress <= 100; progress++) {
pinningStatus.progress = ret.progress; await new Promise(resolve => setTimeout(resolve, Math.floor(Math.random() * (500 - 100 + 1)) + 100)); // Simulate time passing with random duration between 100 and 500
if (ret.status === 'completed') { pinningStatus.progress = progress;
if (progress === 100) {
pinningStatus.status = 'completed'; pinningStatus.status = 'completed';
} }
}
})(); })();
return { success: true, message: "Pinning process started" }; return { success: true, message: "Pinning process started" };
@ -41,8 +35,7 @@ export class PinningProcess {
return { success: false, message: "ID not found or not being processed" }; return { success: false, message: "ID not found or not being processed" };
} }
await PinningProcess.sdk?.protocols().get<S5Client>(PROTOCOL_S5)!.getSdk().unpin(id); PinningProcess.instances.delete(id);
return { success: true, message: "Pinning process removed" } return { success: true, message: "Pinning process removed" }
} }
@ -58,8 +51,18 @@ export class PinningProcess {
yield allStatuses ?? []; // Yield the final statuses yield allStatuses ?? []; // Yield the final statuses
} }
}
public static setupSdk(sdk: Sdk) { // Example usage:
PinningProcess.sdk = sdk; // (async () => {
} // const { success, message } = await PinningProcess.pin("123");
} // console.log(message);
// if (success) {
// const progressGenerator = PinningProcess.pollProgress("123");
// let result = progressGenerator.next();
// while (!result.done) {
// console.log(result.value); // Log the progress
// result = progressGenerator.next();
// }
// }
// })();

View File

@ -21,7 +21,6 @@ import { Sdk } from "@lumeweb/portal-sdk";
import resources from "~/data/resources.js"; import resources from "~/data/resources.js";
import { QueryClient, QueryClientProvider } from "@tanstack/react-query"; import { QueryClient, QueryClientProvider } from "@tanstack/react-query";
import { useMemo } from "react"; import { useMemo } from "react";
import {PinningProcess} from "~/data/pinning.js";
export const links: LinksFunction = () => [ export const links: LinksFunction = () => [
{ rel: "stylesheet", href: stylesheet }, { rel: "stylesheet", href: stylesheet },
@ -51,7 +50,6 @@ export function Layout({ children }: { children: React.ReactNode }) {
function App() { function App() {
const sdk = useSdk(); const sdk = useSdk();
const providers = useMemo(() => getProviders(sdk as Sdk), [sdk]); const providers = useMemo(() => getProviders(sdk as Sdk), [sdk]);
useMemo(() => PinningProcess.setupSdk(sdk as Sdk), [sdk]);
return ( return (
<QueryClientProvider client={queryClient}> <QueryClientProvider client={queryClient}>
<Refine <Refine

View File

@ -17,7 +17,7 @@
"@conform-to/zod": "^1.0.2", "@conform-to/zod": "^1.0.2",
"@fontsource-variable/manrope": "^5.0.19", "@fontsource-variable/manrope": "^5.0.19",
"@radix-ui/react-accordion": "^1.1.2", "@radix-ui/react-accordion": "^1.1.2",
"@lumeweb/portal-sdk": "0.0.0-20240322221532", "@lumeweb/portal-sdk": "0.0.0-20240321203634",
"@radix-ui/react-avatar": "^1.0.4", "@radix-ui/react-avatar": "^1.0.4",
"@radix-ui/react-checkbox": "^1.0.4", "@radix-ui/react-checkbox": "^1.0.4",
"@radix-ui/react-dialog": "^1.0.5", "@radix-ui/react-dialog": "^1.0.5",