import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
import { z, ZodTypeAny } from 'zod';
import { type Ctx, resolveAuth } from '../context.js';
import { currencyZOD, getAPIuser, InferFromShape, structData } from '../support/toolsData.js';
import { BASE } from '../support/http.js';
export function registerPaymentsTools(server: McpServer) {
const getSendMoneyShape = {
to: z.string().describe("Email, phone or Solana wallet"),
amount: z.number().positive().describe("Amount to send"),
currency: currencyZOD.describe("Currency of specified amount to send"),
title: z.string().optional().describe("A title for the transaction shown to the receiver")
};
server.registerTool(
'send_money',
{
title: "Send money",
description: "Send money to an email, Solana wallet or phone number.",
inputSchema: getSendMoneyShape, // ZodRawShape,
//annotations: { readOnlyHint: true }
annotations: { title: 'Send money', destructiveHint: true, openWorldHint: true }
},
async ({ to, amount, currency, title }) => {
const { apiKey } = resolveAuth(undefined, undefined);
var jsP = {
myKey: apiKey,
to,
amount,
currencyUsed: currency,
title
}
const fet = await fetch(BASE + '/api/tr4usr', {
method: 'POST',
headers: {
Accept: 'application.json',
'Content-Type': 'application/json'
},
body: JSON.stringify(jsP)
});
var dat = await fet.text();
process.stderr.write(`[caisse][info] dat ${dat}\n`);
//console.log(dat);
var result = JSON.parse(dat);
//console.log(result);
return structData(result) as any;
//return tmpRes;
/*return {
content: [{ type: 'text', text: "Error" }],
structuredContent: { type: 'text', text: "Error" },
};*/
/*
*/
}
);
const getCreatePLinkShape = {
receivingPayment: z.string().optional().describe("Email, phone or Solana wallet of the recipient of the payment"),
amount: z.number().positive().describe("Amount to request"),
currency: currencyZOD.describe("Currency of specified amount to request"),
title: z.string().optional().describe("A title for the payment shown to the payer"),
description: z.string().optional().describe("A description, shown in the payment page"),
returnOKURL: z.string().optional().describe("Optional : URL to redirect the client to after successfull payment"),
returnURL: z.string().optional().describe("Optional : URL to redirect the client to after failed payment"),
logo: z.string().optional().describe("Optional : URL to an image displayed in payment page"),
param: z.string().optional().describe("Custom parameter"),
webhook: z.string().optional().describe("HTTP webhook to call on payment success"),
notificationEmail: z.string().optional().describe("Email to notify on payment success")
};
server.registerTool(
'request_payment_link',
{
title: "Create a payment link",
description: "Create a payment link in order to request a payment",
inputSchema: getCreatePLinkShape, // ZodRawShape,
annotations: { title: "Create a payment link", readOnlyHint: true }
},
async (reqBody) => {
//const { apiKey } = resolveAuth(undefined, ctx);
if (reqBody.title) {
reqBody.title = reqBody.title.split('\u20AC').join('euro');
}
if (!reqBody.receivingPayment) {
const { apiKey } = resolveAuth(undefined, undefined);
var result = await getAPIuser(apiKey);
if (result.pubk) reqBody.receivingPayment = result.pubk;
if (result.error) {
return structData(result);
}
}
if (!reqBody.receivingPayment) {
return structData({
error: 'receivingPayment parameter required'
});
}
var req = await fetch(BASE + '/api/createPLink', {
method: 'POST',
body: JSON.stringify(reqBody)
});
var plink_Info = await req.json();
return structData(plink_Info) as any;
}
);
const getGetUserShape = {};
server.registerTool(
'get_my_wallet_info',
{
title: "Wallet infos and balance",
description: "Retrieve the wallet infos about the connected P-Link account (Solana wallet address, wallet balance)",
inputSchema: getGetUserShape, // ZodRawShape,
annotations: { title: "Wallet infos and balance", readOnlyHint: true }
},
async (reqBody) => {
const { apiKey } = resolveAuth(undefined, undefined);
var jsP = {
myKey: apiKey
}
process.stderr.write(`[caisse][info] XapiKey ${apiKey}\n`);
const fet = await fetch(BASE + '/api/getAPIUser', {
method: 'POST',
headers: {
Accept: 'application.json',
'Content-Type': 'application/json'
},
body: JSON.stringify(jsP)
});
var dat = await fet.text();
process.stderr.write(`[caisse][info] dat2 ${dat}\n`);
var result = JSON.parse(dat);
if (result?.pubk) {
process.stderr.write(`[caisse][info] fetch wallet infos\n`);
const walletInfos = await fetch(BASE + '/api/walletInfos/' + result.pubk + '/1');
const walletBalance = await walletInfos.json();
result = { ...result, ...walletBalance };
}
return structData(result) as any;
}
);
const getGetTrxStateShape = {
trxID: z.string().optional().describe("The transaction ID")
};
server.registerTool(
'get_transaction_state',
{
title: "Get transaction state",
description: "Retrieve the state and details of a transaction using Solana trx ID",
inputSchema: getGetTrxStateShape, // ZodRawShape,
annotations: { title: "Get transaction state", readOnlyHint: true }
},
async ({ trxID }) => {
const fet = await fetch(BASE + '/api/trxState/' + trxID + '/' + new Date().getTime());
var dat = await fet.text();
process.stderr.write(`[caisse][info] dat2 ${dat}\n`);
var result = JSON.parse(dat);
return structData(result) as any;
}
);
const getWalletHistoryShape = {
walletAddress: z.string().optional().describe("The wallet address")
};
server.registerTool(
'get_wallet_history',
{
title: "Get wallet history",
description: "Retrieve list of the transactions related to the specified Solana wallet address",
inputSchema: getWalletHistoryShape, // ZodRawShape,
annotations: { title: "Get wallet history", readOnlyHint: true }
},
async (param) => {
const fet = await fetch(BASE + '/api/walletHistory/' + param.walletAddress + '/' + new Date().getTime());
var dat = await fet.text();
process.stderr.write(`[caisse][info] dat2 ${dat}\n`);
var result = JSON.parse(dat);
return structData(result) as any;
}
);
}
