import { type CallToolResult } from "@modelcontextprotocol/sdk/types.js";
import { buildClientSchema, getIntrospectionQuery, printSchema } from "graphql";
import { type IntrospectionQuery } from "graphql";
import { type Config } from "@/config.js";
import { parse } from "graphql/language/index.js";
export async function query(conf: Config, schemaName:string, query: string, variables?: string): Promise<CallToolResult> {
const url = `${conf.graphQL.endpoint}/${schemaName}?sc_apikey=${conf.graphQL.apiKey}`;
const parsedQuery = parse(query);
const response = await fetch(url, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
...conf.graphQL.headers,
},
body: JSON.stringify({
query,
variables,
}),
});
if (!response.ok) {
throw new Error(`GraphQL request failed: ${response.statusText}`);
}
const responseJson = await response.json();
if (responseJson.errors && responseJson.errors.length > 0) {
throw new Error(`GraphQL query errors: ${JSON.stringify(responseJson.errors)}`);
}
return {
content: [
{
type: "text",
text: responseJson.data ? JSON.stringify(responseJson.data, null, 2) : "No data returned",
},
],
isError: false,
}
}
