added on proofStateUpdates

src/CashuWallet.ts

@@ -903,6 +903,27 @@ class CashuWallet {
 		};
 	}
 
+	async onProofStateUpdates(
+		proofs: Array<Proof>,
+		callback: (payload: ProofState) => void,
+		errorCallback: (e: Error) => void
+	): Promise<SubscriptionCanceller> {
+		await this.mint.connectWebSocket();
+		if (!this.mint.webSocketConnection) {
+			throw new Error('failed to establish WebSocket connection.');
+		}
+		const enc = new TextEncoder();
+		const ys = proofs.map((p: Proof) => hashToCurve(enc.encode(p.secret)).toHex(true));
+		const subId = this.mint.webSocketConnection.createSubscription(
+			{ kind: 'proof_state', filters: ys },
+			callback,
+			errorCallback
+		);
+		return () => {
+			this.mint.webSocketConnection?.cancelSubscription(subId, callback);
+		};
+	}
+
 	/**
 	 * Creates blinded messages for a given amount
 	 * @param amount amount to create blinded messages for

test/integration.test.ts

@@ -9,7 +9,9 @@ import {
 	CheckStateEnum,
 	MeltQuoteState,
 	MintQuotePayload,
-	MintQuoteState
+	MintQuoteResponse,
+	MintQuoteState,
+	ProofState
 } from '../src/model/types/index.js';
 import ws from 'ws';
 import { injectWebSocketImpl } from '../src/ws.js';
@@ -321,4 +323,36 @@ describe('mint api', () => {
 		expect(callbackRef).toHaveBeenCalledTimes(4);
 		expect(mint.webSocketConnection?.activeSubscriptions.length).toBe(0);
 	});
+	test('websocket proof state + mint quote updates', async () => {
+		const mint = new CashuMint(mintUrl);
+		const wallet = new CashuWallet(mint);
+
+		const quote = await wallet.createMintQuote(63);
+		await new Promise<void>((res) => {
+			function handleUpdate(p: MintQuoteResponse) {
+				if (p.state === MintQuoteState.PAID) {
+					res();
+				}
+			}
+			wallet.onMintQuoteUpdates([quote.quote], handleUpdate, (e) => {
+				console.log(e);
+			});
+		});
+		const { proofs } = await wallet.mintProofs(63, quote.quote);
+		const data = await new Promise<ProofState>((res) => {
+			wallet.onProofStateUpdates(
+				proofs,
+				(p) => {
+					if (p.state === CheckStateEnum.SPENT) {
+						res(p);
+					}
+				},
+				(e) => {
+					console.log(e);
+				}
+			);
+			wallet.swap(63, proofs);
+		});
+		console.log('final ws boss', data);
+	});
 });