feat: add market result store

This commit is contained in:
2026-04-20 20:06:21 +08:00
parent 649de1608c
commit 98dc078a15
3 changed files with 179 additions and 0 deletions
+63
View File
@@ -0,0 +1,63 @@
import type {
MarketApiFailureReason,
MarketRecord,
MarketRowSnapshot
} from "./types";
import type { AfterSearchRates } from "./types";
export function createMarketResultStore() {
const records = new Map<string, MarketRecord>();
return {
getRecord(authorId: string) {
return records.get(authorId) ?? null;
},
listRecords() {
return Array.from(records.values());
},
setAuthorFailed(authorId: string, reason: MarketApiFailureReason) {
const existingRecord = ensureRecord(authorId);
existingRecord.status = "failed";
existingRecord.failureReason = reason;
},
setAuthorLoading(authorId: string) {
const existingRecord = ensureRecord(authorId);
existingRecord.status = "loading";
delete existingRecord.failureReason;
},
setAuthorSuccess(authorId: string, rates: Required<AfterSearchRates>) {
const existingRecord = ensureRecord(authorId);
existingRecord.status = "success";
existingRecord.rates = rates;
delete existingRecord.failureReason;
},
upsertMarketRow(row: MarketRowSnapshot) {
const existingRecord = records.get(row.authorId);
if (existingRecord) {
return existingRecord;
}
const nextRecord: MarketRecord = {
...row,
status: "idle"
};
records.set(row.authorId, nextRecord);
return nextRecord;
}
};
function ensureRecord(authorId: string): MarketRecord {
const existingRecord = records.get(authorId);
if (existingRecord) {
return existingRecord;
}
const nextRecord: MarketRecord = {
authorId,
authorName: authorId,
status: "idle"
};
records.set(authorId, nextRecord);
return nextRecord;
}
}