Rhombus MCP Server

import { postApi } from "../network.js"; import type { SavedVehicle, VehicleEvent, VehicleEventsArgs, VehicleLabels, } from "../types/lpr-tool-types.js"; import type schema from "../types/schema.js"; import { formatTimestamp, type RequestModifiers } from "../util.js"; export async function getVehicleEvents( args: VehicleEventsArgs, timeZone: string, requestModifiers?: RequestModifiers, sessionId?: string ): Promise<VehicleEvent[]> { const requestArgs: schema["Vehicle_GetVehicleEventsWSRequest"] = { deviceUuidFilter: args.deviceUuidFilter, locationUuidFilter: args.locationUuidFilter, vehicleLabelQuery: args.vehicleLabelQuery, licensePlateFuzzyQuery: args.licensePlateFuzzyQuery, startTimeMs: args.startTime ? new Date(args.startTime).getTime() : undefined, endTimeMs: args.endTime ? new Date(args.endTime).getTime() : undefined, }; const res = await postApi<schema["Vehicle_GetVehicleEventsWSResponse"]>({ route: "/vehicle/getVehicleEvents", body: requestArgs, modifiers: requestModifiers, sessionId, }); if (res.error) { throw new Error(JSON.stringify(res)); } return ( res.events?.map( event => ({ uuid: event.uuid ?? "", deviceUuid: event.deviceUuid ?? undefined, eventTimestamp: formatTimestamp(event.eventTimestamp ?? Date.now(), timeZone), imageS3Key: event.imageS3Key ?? undefined, thumbnailS3Key: event.thumbnailS3Key ?? undefined, locationUuid: event.locationUuid ?? undefined, vehicleLicensePlate: event.vehicleLicensePlate ?? "No License Plate", }) satisfies VehicleEvent ) ?? [] ); } export async function getSavedVehicles( timeZone: string, requestModifiers?: RequestModifiers, sessionId?: string ): Promise<SavedVehicle[]> { const res = await postApi<schema["Vehicle_GetVehiclesWSResponse"]>({ route: "/vehicle/getVehicles", body: {}, modifiers: requestModifiers, sessionId, }); if (res.error) { throw new Error(JSON.stringify(res)); } return ( res.vehicles?.map( vehicle => ({ createdTimestamp: formatTimestamp(vehicle.createdAtMillis ?? Date.now(), timeZone), name: vehicle.name ?? "No Name", description: vehicle.description ?? "No Description", licensePlate: vehicle.licensePlate ?? "No License Plate", orgUuid: vehicle.orgUuid ?? "", }) satisfies SavedVehicle ) ?? [] ); } export async function getVehicleLabels( requestModifiers?: RequestModifiers, sessionId?: string ): Promise<VehicleLabels> { const res = await postApi<schema["Vehicle_GetVehicleLabelsForOrgWSResponse"]>({ route: "/vehicle/getVehicleLabelsForOrg", body: {}, modifiers: requestModifiers, sessionId, }); if (res.error) { throw new Error(JSON.stringify(res)); } const processedVehicleLabels: VehicleLabels = {}; for (const [licensePlate, labels] of Object.entries(res.vehicleLabels ?? {})) { const filteredLabels = labels?.filter(label => label !== null) ?? []; if (!filteredLabels || filteredLabels.length === 0) { continue; } processedVehicleLabels[licensePlate] = filteredLabels; } return processedVehicleLabels; }