import { FastMCP } from "fastmcp";
import { z } from "zod";
import { LunchMoneyClient } from "../api/client.js";
import { formatErrorForMCP } from "../utils/errors.js";
import {
transactionFilterSchema,
createTransactionSchema,
updateTransactionSchema,
bulkUpdateTransactionsSchema,
idSchema,
} from "../schemas/index.js";
import { TransactionsResponse, Transaction } from "../types/index.js";
export function registerTransactionTools(
server: FastMCP,
client: LunchMoneyClient
) {
server.addTool({
name: "getTransactions",
description:
"List transactions with advanced filtering options including date range, category, tags, account, and status",
parameters: transactionFilterSchema,
execute: async (args: z.infer<typeof transactionFilterSchema>) => {
try {
const response = await client.get<TransactionsResponse>(
"/transactions",
args
);
return JSON.stringify(response, null, 2);
} catch (error) {
return formatErrorForMCP(error);
}
},
});
server.addTool({
name: "createTransaction",
description: "Create a new transaction (expense, income, or transfer)",
parameters: createTransactionSchema,
execute: async (args: z.infer<typeof createTransactionSchema>) => {
try {
const transaction = await client.post<{ transaction: Transaction }>(
"/transactions",
args
);
return JSON.stringify(transaction, null, 2);
} catch (error) {
return formatErrorForMCP(error);
}
},
});
server.addTool({
name: "updateTransaction",
description: "Update an existing transaction's properties",
parameters: idSchema.merge(updateTransactionSchema),
execute: async (args: z.infer<typeof idSchema> & z.infer<typeof updateTransactionSchema>) => {
try {
const { id, ...updateData } = args;
const transaction = await client.put<{ transaction: Transaction }>(
`/transactions/${id}`,
updateData
);
return JSON.stringify(transaction, null, 2);
} catch (error) {
return formatErrorForMCP(error);
}
},
});
server.addTool({
name: "deleteTransaction",
description: "Delete a transaction by ID",
parameters: idSchema,
execute: async (args: z.infer<typeof idSchema>) => {
try {
await client.delete(`/transactions/${args.id}`);
return `Transaction ${args.id} deleted successfully`;
} catch (error) {
return formatErrorForMCP(error);
}
},
});
server.addTool({
name: "bulkUpdateTransactions",
description:
"Bulk update multiple transactions with the same changes (category, tags, notes, status)",
parameters: bulkUpdateTransactionsSchema,
execute: async (args: z.infer<typeof bulkUpdateTransactionsSchema>) => {
try {
const result = await client.post<{ updated: number }>(
"/transactions/bulk",
args
);
return JSON.stringify(result, null, 2);
} catch (error) {
return formatErrorForMCP(error);
}
},
});
}
