PaymentStore

interface PaymentStore {
  create(payment: Payment): Promise<void> | void;
  update(payment: Payment): Promise<void> | void;
  get(id: string): Promise<Payment | undefined> | Payment | undefined;
  listActive(scope?: PaymentScope): Promise<Payment[]> | Payment[];
}

import { InMemoryPaymentStore } from "merchantid";

const store = new InMemoryPaymentStore();

import type { Payment, PaymentScope, PaymentStore } from "merchantid";

class DatabasePaymentStore implements PaymentStore {
  async create(payment: Payment): Promise<void> {
    // Gunakan transaksi database dan unique constraint pada scope + uniqueAmount
    // untuk baris yang masih pending.
    await db.payments.insert(payment);
  }

  async update(payment: Payment): Promise<void> {
    await db.payments.update(payment.id, payment);
  }

  async get(id: string): Promise<Payment | undefined> {
    return db.payments.get(id);
  }

  async listActive(scope?: PaymentScope): Promise<Payment[]> {
    return db.payments.listPending(scope);
  }
}