Files
planilla/mcp/modules/asistencias.js
2025-06-03 17:23:29 -06:00

110 lines
3.7 KiB
JavaScript

import { ResourceTemplate } from "@modelcontextprotocol/sdk/server/mcp.js";
import { z } from "zod";
import { fetchJSON } from "../lib/api.js";
const log = (...args) => console.log("[MCP]", ...args);
export default function registerAsistencias(server) {
server.resource("asistencia-list", "asistencia://list", async (uri) => {
log("Recurso solicitado", "asistencia-list");
const asistencias = await fetchJSON("/api/asistencias");
return { contents: [{ uri: uri.href, text: JSON.stringify(asistencias) }] };
});
server.resource(
"asistencia",
new ResourceTemplate("asistencia://{id}", { list: undefined }),
async (uri, { id }) => {
log("Recurso solicitado", `asistencia ${id}`);
const asistencia = await fetchJSON(`/api/asistencias/${id}`);
return { contents: [{ uri: uri.href, text: JSON.stringify(asistencia) }] };
}
);
server.tool(
"create-asistencia",
"Crea una asistencia",
{
empleado_id: z.number(),
entrada: z.string().optional(),
salida: z.string().optional(),
historial: z.string().optional(),
observacion: z.string().optional(),
estado: z.string().optional(),
fecha_anulado: z.string().optional(),
creador_id: z.number().optional(),
modificado_id: z.number().optional(),
anulador_id: z.number().optional(),
},
async (params) => {
log("Tool invocada", "create-asistencia", params);
const asistencia = await fetchJSON("/api/asistencias", {
method: "POST",
body: JSON.stringify(params),
});
return { content: [{ type: "text", text: JSON.stringify(asistencia) }] };
}
);
server.tool(
"update-asistencia",
"Actualiza una asistencia",
{
id: z.number(),
empleado_id: z.number().optional(),
entrada: z.string().optional(),
salida: z.string().optional(),
historial: z.string().optional(),
observacion: z.string().optional(),
estado: z.string().optional(),
fecha_anulado: z.string().optional(),
modificado_id: z.number().optional(),
anulador_id: z.number().optional(),
},
async ({ id, ...updates }) => {
log("Tool invocada", "update-asistencia", { id, ...updates });
const asistencia = await fetchJSON(`/api/asistencias/${id}`, {
method: "PUT",
body: JSON.stringify(updates),
});
return { content: [{ type: "text", text: JSON.stringify(asistencia) }] };
}
);
server.tool(
"delete-asistencia",
"Elimina una asistencia",
{ id: z.number() },
async ({ id }) => {
log("Tool invocada", "delete-asistencia", { id });
await fetchJSON(`/api/asistencias/${id}`, { method: "DELETE" });
return { content: [{ type: "text", text: `Asistencia ${id} eliminada` }] };
}
);
server.tool(
"search-asistencias",
"Busca asistencias. `q` matchea id o empleado_id. Si no se envían argumentos se devuelven los primeros 100 registros.",
{
q: z.string().optional(),
empleado_id: z.number().optional(),
estado: z.string().optional(),
entrada_desde: z.string().optional(),
entrada_hasta: z.string().optional(),
salida_desde: z.string().optional(),
salida_hasta: z.string().optional(),
},
async (params) => {
log("Tool invocada", "search-asistencias", params);
const qs = new URLSearchParams(
Object.entries(params)
.filter(([, v]) => v !== undefined)
.map(([k, v]) => [k, String(v)])
);
if (qs.toString() === "") qs.append("limit", "100");
const asistencias = await fetchJSON(`/api/asistencias/search?${qs.toString()}`);
return { content: [{ type: "text", text: JSON.stringify(asistencias) }] };
}
);
}