sarlink-portal/queries/wallet.ts

import { getServerSession } from "next-auth";
import { authOptions } from "@/app/auth";
import type {
	ApiError,
	ApiResponse,
	WalletTransaction,
} from "@/lib/backend-types";

type GenericGetResponseProps = {
	offset?: number;
	limit?: number;
	page?: number;
	[key: string]: string | number | undefined;
};
export async function getWaleltTransactions(
	params: GenericGetResponseProps,
	allTransactions = false,
) {
	// Build query string from all defined params
	const query = Object.entries(params)
		.filter(([_, value]) => value !== undefined && value !== "")
		.map(
			([key, value]) =>
				`${encodeURIComponent(key)}=${encodeURIComponent(String(value))}`,
		)
		.join("&");
	const session = await getServerSession(authOptions);
	const response = await fetch(
		`${process.env.SARLINK_API_BASE_URL}/api/billing/wallet-transactions/?${query}&all_transactions=${allTransactions}`,
		{
			method: "GET",
			headers: {
				"Content-Type": "application/json",
				Authorization: `Token ${session?.apiToken}`,
			},
		},
	);
	if (!response.ok) {
		const errorData = (await response.json()) as ApiError;
		const errorMessage =
			errorData.message || errorData.detail || "An error occurred.";
		const error = new Error(errorMessage);
		(error as ApiError & { details?: ApiError }).details = errorData; // Attach the errorData to the error object
		throw error;
	}
	const data = (await response.json()) as ApiResponse<WalletTransaction>;
	return data;
}