apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-01 09:29:38 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Use HashSet for gateway term service sets

Browse source
This commit is contained in:
elpresidank 2026-06-04 05:34:15 -05:00
parent 0862250dab
commit 3a256096f8
2 changed files with 22 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

14
ts/packages/flow/src/gateway/dispatch/serialize.ts
View file

@ -29,7 +29,7 @@ import {
type Term,
type Triple,
} from "@trustgraph/base";
import { Effect, Match } from "effect";
import { Effect, HashSet, Match } from "effect";
import * as O from "effect/Option";
import * as S from "effect/Schema";
@ -251,23 +251,23 @@ function deepInternalToClient(value: unknown): unknown {
* Services whose requests contain Term/Triple fields that need translation.
* All other services pass through without term translation.
*/
const TERM_BEARING_REQUEST_SERVICES = new Set([
const TERM_BEARING_REQUEST_SERVICES = HashSet.make(
"triples",
"knowledge",
"librarian",
]);
);
/**
* Services whose responses contain Term/Triple fields that need translation.
*/
const TERM_BEARING_RESPONSE_SERVICES = new Set([
const TERM_BEARING_RESPONSE_SERVICES = HashSet.make(
"triples",
"graph-embeddings",
"knowledge",
"librarian",
"graph-rag",
"agent",
]);
);
// ---------- Top-level request / response translators ----------
@ -280,7 +280,7 @@ const TERM_BEARING_RESPONSE_SERVICES = new Set([
* scalar fields (query strings, limits, etc.).
*/
export function translateRequest(service: string, body: unknown): unknown {
if (TERM_BEARING_REQUEST_SERVICES.has(service)) {
if (HashSet.has(TERM_BEARING_REQUEST_SERVICES, service)) {
return deepClientToInternal(body);
}
return body;
@ -309,7 +309,7 @@ export const translateRequestEffect = (
* All other services pass through unchanged.
*/
export function translateResponse(service: string, response: unknown): unknown {
if (TERM_BEARING_RESPONSE_SERVICES.has(service)) {
if (HashSet.has(TERM_BEARING_RESPONSE_SERVICES, service)) {
return deepInternalToClient(response);
}
return response;