Package app.ductape.sdk.graph

Class GraphService

java.lang.Object

app.ductape.sdk.graph.GraphService

public class GraphService
extends Object

Graph operations facade; tracks sdk/ts/src/graph/graphs.service.ts (see PARITY_MAP.md + PARITY_ROADMAP.md § Graph for Redisson-native processJob and adapter depth).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	GraphService.GraphActionDispatchSubsystem	TS graphs.service.ts#get action().dispatch — predefined graph-action jobs tagged graph-action:{graph}:{event} (vs GraphService.GraphActionDispatchSubsystem.dispatch(java.util.Map<java.lang.String, java.lang.Object>) for raw graph-operation jobs).
protected static enum	GraphService.ScheduledGraphDispatchChannel	Mirrors TS graph.dispatch vs graph.action.dispatch.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIG_ENSURE_GRAPH_JOBS	When Boolean.TRUE, dispatch(java.util.Map<java.lang.String, java.lang.Object>) runs TS-like fetchJob/createJob via ProductsService.ensureGraphOperationJobForDispatch(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, long) before the processor hook (requires reachable Products API).
static final String	CONFIG_RECORD_JOB_EXECUTION	When Boolean.TRUE, dispatch(java.util.Map<java.lang.String, java.lang.Object>) POSTs a TS-like job execution record (see ProcessorApiService.createJobExecution(java.util.Map<java.lang.String, java.lang.Object>, app.ductape.sdk.core.RequestContext)) after building processor input.
static final String	CONFIG_SYNCHRONOUS_GRAPH_DISPATCH	When Boolean.TRUE, dispatch(java.util.Map<java.lang.String, java.lang.Object>) / dispatchGraphAction(java.util.Map<java.lang.String, java.lang.Object>) execute the graph operation (or graph-action) **synchronously** on the connected adapter, mirroring TS processorService.processJob + worker behavior for the operation surface when no Redisson queue is configured.

Constructor Summary

Constructors

Constructor	Description
GraphService(EnvType env, RequestContext auth)
GraphService(EnvType env, RequestContext auth, ProductsService productsService)
GraphService(EnvType env, RequestContext auth, ProductsService productsService, ProcessorApiService processorApi)

Method Summary

Modifier and Type	Method	Description
GraphService.GraphActionDispatchSubsystem	action()
Map<String,Object>	addLabels(Map<String,Object> options)	TS addLabels: options include id and labels.
Map<String,Object>	allPaths(Map<String,Object> options)
Map<String,Object>	beginTransaction(Map<String,Object> options)
protected Map<String,Object>	buildGraphJobProcessorInput(Map<String,Object> data, Map<String,Object> schedule, String jobTag, long startAt)	TS IJobProcessorInput fields used by graph dispatch.
void	closeAll()
void	commitTransaction(Map<String,Object> transaction)
Map<String,Object>	connect(Map<String,Object> config)
Map<String,Object>	countNodes(Map<String,Object> options)	TS ICountNodesResult: { count }.
Map<String,Object>	countRelationships(Map<String,Object> options)	TS ICountRelationshipsResult: { count }.
void	create(Map<String,Object> graphConfig, String productTag)
Map<String,Object>	createAction(Map<String,Object> options, String productTag)
Map<String,Object>	createNode(Map<String,Object> options)
Map<String,Object>	createNodeConstraint(Map<String,Object> options)
Map<String,Object>	createNodeIndex(Map<String,Object> options)
Map<String,Object>	createRelationship(Map<String,Object> options)
Map<String,Object>	createRelationshipIndex(Map<String,Object> options)
void	delete(String graphTag, String productTag)
void	deleteAction(String actionTag, String graphTag, String productTag)
Map<String,Object>	deleteNode(Map<String,Object> options)
Map<String,Object>	deleteRelationship(Map<String,Object> options)
void	disconnect()
Map<String,Object>	dispatch(Map<String,Object> data)	TS graphs.service.ts#dispatch: schedule semantics, graph-operation:{graph}:{operation} job tag, prepareGraphDispatchJob(app.ductape.sdk.graph.GraphService.ScheduledGraphDispatchChannel, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, java.lang.Object>, long) then dispatchGraphProcessorJob(java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, app.ductape.sdk.graph.GraphService.ScheduledGraphDispatchChannel) with TS-shaped processor input, then job_id/status payload.
Map<String,Object>	dispatchGraphAction(Map<String,Object> data)	Direct Java alias for TS graph.action.dispatch when fluent action() is not desirable.
protected void	dispatchGraphProcessorJob(String jobId, Map<String,Object> jobInput, GraphService.ScheduledGraphDispatchChannel dispatchChannel)	TS: processorService.processJob(jobInput).
Map<String,Object>	dropConstraint(String constraintName)	TS dropConstraint(name: string) after connect.
Map<String,Object>	dropConstraint(Map<String,Object> options)
Map<String,Object>	dropIndex(String indexName)	TS dropIndex(name: string) after connect.
Map<String,Object>	dropIndex(Map<String,Object> options)	TS drop index — resolves name or legacy index key after context merge.
Map<String,Object>	execute(Map<String,Object> options)	TS convenience entry where execute maps to predefined graph-action execution (parallel to TS overloads).
Map<String,Object>	executeAction(Map<String,Object> options)
<T> T	executeTransaction(Function<Map<String,Object>,T> callback, Map<String,Object> options)	TS graph.executeTransaction(cb, txnOptions) analogue — executes within GraphTransactionManager begin/commit rollback semantics for the resolved connection adapter.
Map<String,Object>	fetch(String graphTag, String productTag)
List<Map<String,Object>>	fetchAll(String productTag)
List<Map<String,Object>>	fetchAllGraphs(String productTag)
Map<String,Object>	fetchConfig(String productTag, String graphTag)
List<Map<String,Object>>	fetchConfigs(String productTag)
Map<String,Object>	fetchGraphByTag(String productTag, String graphTag)
Map<String,Object>	findConnectedComponents(Map<String,Object> options)
Map<String,Object>	findNodeById(Object id)	TS findNodeById(id) ergonomic form after connect(Map) — product/graph/env are merged from current context.
Map<String,Object>	findNodeById(Map<String,Object> options)	TS findNodeById — expects id plus connection context (graph, env, …).
Map<String,Object>	findNodes(Map<String,Object> options)
Map<String,Object>	findRelationshipById(Object id)	Same as findRelationshipById(Map) with only an id once connected.
Map<String,Object>	findRelationshipById(Map<String,Object> options)	TS findRelationshipById.
Map<String,Object>	findRelationships(Map<String,Object> options)
Map<String,Object>	fullTextSearch(Map<String,Object> options)	TS fullTextSearch / IFullTextSearchResult.
Map<String,Object>	getAction(String actionTag, String graphTag, String productTag)
Map<String,Object>	getConfig()
Map<String,Object>	getCurrentContext()
Map<String,Object>	getNeighborhood(Map<String,Object> options)
Map<String,Object>	getSchemaSnapshot()
Map<String,Object>	getSchemaSnapshot(String productTag, String env, String graphTag)
Map<String,Object>	getStatistics()	TS IGraphStatistics: nodeCount, relationshipCount, optional nodesByLabel, relationshipsByType.
List<Map<String,Object>>	listActions(String graphTag, String productTag)
Map<String,Object>	listConstraints()
Map<String,Object>	listIndexes()
Map<String,Object>	listLabels()
Map<String,Object>	listRelationshipTypes()
Map<String,Object>	mergeNode(Map<String,Object> options)
Map<String,Object>	mergeRelationship(Map<String,Object> options)
protected void	prepareGraphDispatchJob(GraphService.ScheduledGraphDispatchChannel dispatchChannel, String productTag, String graph, String logicalName, String jobTag, Map<String,Object> dispatchData, Map<String,Object> schedule, long startAt)	TS: productBuilder.fetchJob / createJob before processJob.
Map<String,Object>	processGraphActionJob(Map<String,Object> data)	Worker-side entry point for graph_action jobs claimed off the Redisson queue.
Map<String,Object>	processGraphOperationJob(Map<String,Object> data)	Worker-side entry point for graph_operation jobs claimed off the Redisson queue.
protected Map<String,Object>	processProcessorJob(GraphService.ScheduledGraphDispatchChannel channel, Map<String,Object> data)	Internal worker entry used by processGraphOperationJob(java.util.Map<java.lang.String, java.lang.Object>) / processGraphActionJob(java.util.Map<java.lang.String, java.lang.Object>).
Map<String,Object>	query(String queryString, Map<String,Object> params)
Map<String,Object>	rawQuery(Map<String,Object> options)	TS query() / IRawQueryResult: records, optional summary.
Map<String,Object>	removeLabels(Map<String,Object> options)
void	rollbackTransaction(Map<String,Object> transaction)
void	setGraphJobQueueAdapter(JobsService.JobQueueAdapter graphJobQueueAdapter)	Redisson-native queue hook used by Ductape.
Map<String,Object>	setLabels(Map<String,Object> options)
void	setLogApiService(LogApiService logApiService)	TS parity: setting a LogApiService enables structured connect-log emission (Graph connect - initiated/success/failed) with the GRAPH_CONNECT_LOG_DEBOUNCE_MS (15s) suppression window.
void	setRuntimeDefaults(RuntimeDefaults runtimeDefaults)
Map<String,Object>	shortestPath(Map<String,Object> options)
boolean	supportsFeature(GraphTypes.GraphFeature feature)
boolean	supportsFeature(String feature)
Map<String,Object>	testConnection(Map<String,Object> config)
Map<String,Object>	traverse(Map<String,Object> options)	TS traverse() / ITraverseResult.
void	update(String graphTag, Map<String,Object> updates, String productTag)	TS graphs.service.ts#update: persist via product API when productTag is set, merge into localConfigs, and refresh active connection contexts when envs change.
Map<String,Object>	updateAction(Map<String,Object> options, String productTag)
void	updateConfig(Map<String,Object> config)
Map<String,Object>	updateNode(Map<String,Object> options)
Map<String,Object>	updateRelationship(Map<String,Object> options)
Map<String,Object>	vectorSearch(Map<String,Object> options)	TS vectorSearch / IVectorSearchResult.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CONFIG_ENSURE_GRAPH_JOBS

public static final String CONFIG_ENSURE_GRAPH_JOBS

When Boolean.TRUE, dispatch(java.util.Map<java.lang.String, java.lang.Object>) runs TS-like fetchJob/createJob via ProductsService.ensureGraphOperationJobForDispatch(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, long) before the processor hook (requires reachable Products API).

See Also:

• Constant Field Values

CONFIG_RECORD_JOB_EXECUTION

public static final String CONFIG_RECORD_JOB_EXECUTION

When Boolean.TRUE, dispatch(java.util.Map<java.lang.String, java.lang.Object>) POSTs a TS-like job execution record (see ProcessorApiService.createJobExecution(java.util.Map<java.lang.String, java.lang.Object>, app.ductape.sdk.core.RequestContext)) after building processor input.

See Also:

• Constant Field Values

CONFIG_SYNCHRONOUS_GRAPH_DISPATCH

public static final String CONFIG_SYNCHRONOUS_GRAPH_DISPATCH

When Boolean.TRUE, dispatch(java.util.Map<java.lang.String, java.lang.Object>) / dispatchGraphAction(java.util.Map<java.lang.String, java.lang.Object>) execute the graph operation (or graph-action) **synchronously** on the connected adapter, mirroring TS processorService.processJob + worker behavior for the operation surface when no Redisson queue is configured. Requires an active connect(Map) with matching product/graph/env. Production Bolt graphs use Neo4jBoltGraphAdapter when connectionUrl is a Bolt/Neo4j URI.

See Also:

• Constant Field Values

Constructor Details

GraphService

public GraphService(EnvType env,
 RequestContext auth)

GraphService

public GraphService(EnvType env,
 RequestContext auth,
 ProductsService productsService)

GraphService

public GraphService(EnvType env,
 RequestContext auth,
 ProductsService productsService,
 ProcessorApiService processorApi)

Method Details

updateConfig

public void updateConfig(Map<String,Object> config)

setLogApiService

public void setLogApiService(LogApiService logApiService)

TS parity: setting a LogApiService enables structured connect-log emission (Graph connect - initiated/success/failed) with the GRAPH_CONNECT_LOG_DEBOUNCE_MS (15s) suppression window.

setRuntimeDefaults

public void setRuntimeDefaults(RuntimeDefaults runtimeDefaults)

getCurrentContext

public Map<String,Object> getCurrentContext()

getConfig

public Map<String,Object> getConfig()

setGraphJobQueueAdapter

public void setGraphJobQueueAdapter(JobsService.JobQueueAdapter graphJobQueueAdapter)

Redisson-native queue hook used by Ductape. When configured, dispatch(Map) / dispatchGraphAction(Map) enqueue graph processor jobs to the shared jobs queue instead of relying only on the local synchronous hook.

create

public void create(Map<String,Object> graphConfig,
 String productTag)

fetchConfigs

public List<Map<String,Object>> fetchConfigs(String productTag)

fetchConfig

public Map<String,Object> fetchConfig(String productTag,
 String graphTag)

fetchAllGraphs

public List<Map<String,Object>> fetchAllGraphs(String productTag)

fetchGraphByTag

public Map<String,Object> fetchGraphByTag(String productTag,
 String graphTag)

fetchAll

public List<Map<String,Object>> fetchAll(String productTag)

fetch

public Map<String,Object> fetch(String graphTag,
 String productTag)

update

public void update(String graphTag,
 Map<String,Object> updates,
 String productTag)

TS graphs.service.ts#update: persist via product API when productTag is set, merge into localConfigs, and refresh active connection contexts when envs change.

delete

public void delete(String graphTag,
 String productTag)

connect

public Map<String,Object> connect(Map<String,Object> config)

testConnection

public Map<String,Object> testConnection(Map<String,Object> config)

disconnect

public void disconnect()

closeAll

public void closeAll()

createNode

public Map<String,Object> createNode(Map<String,Object> options)

findNodes

public Map<String,Object> findNodes(Map<String,Object> options)

updateNode

public Map<String,Object> updateNode(Map<String,Object> options)

deleteNode

public Map<String,Object> deleteNode(Map<String,Object> options)

mergeNode

public Map<String,Object> mergeNode(Map<String,Object> options)

createRelationship

public Map<String,Object> createRelationship(Map<String,Object> options)

findRelationships

public Map<String,Object> findRelationships(Map<String,Object> options)

updateRelationship

public Map<String,Object> updateRelationship(Map<String,Object> options)

deleteRelationship

public Map<String,Object> deleteRelationship(Map<String,Object> options)

mergeRelationship

public Map<String,Object> mergeRelationship(Map<String,Object> options)

countNodes

public Map<String,Object> countNodes(Map<String,Object> options)

TS ICountNodesResult: { count }.

countRelationships

public Map<String,Object> countRelationships(Map<String,Object> options)

TS ICountRelationshipsResult: { count }.

getStatistics

public Map<String,Object> getStatistics()

TS IGraphStatistics: nodeCount, relationshipCount, optional nodesByLabel, relationshipsByType.

query

public Map<String,Object> query(String queryString,
 Map<String,Object> params)

rawQuery

public Map<String,Object> rawQuery(Map<String,Object> options)

TS query() / IRawQueryResult: records, optional summary.

traverse

public Map<String,Object> traverse(Map<String,Object> options)

TS traverse() / ITraverseResult.

listLabels

public Map<String,Object> listLabels()

listRelationshipTypes

public Map<String,Object> listRelationshipTypes()

listIndexes

public Map<String,Object> listIndexes()

listConstraints

public Map<String,Object> listConstraints()

findNodeById

public Map<String,Object> findNodeById(Map<String,Object> options)

TS findNodeById — expects id plus connection context (graph, env, …).

findRelationshipById

public Map<String,Object> findRelationshipById(Map<String,Object> options)

TS findRelationshipById.

findNodeById

public Map<String,Object> findNodeById(Object id)

TS findNodeById(id) ergonomic form after connect(Map) — product/graph/env are merged from current context.

findRelationshipById

public Map<String,Object> findRelationshipById(Object id)

Same as findRelationshipById(Map) with only an id once connected.

addLabels

public Map<String,Object> addLabels(Map<String,Object> options)

TS addLabels: options include id and labels.

removeLabels

public Map<String,Object> removeLabels(Map<String,Object> options)

setLabels

public Map<String,Object> setLabels(Map<String,Object> options)

createNodeIndex

public Map<String,Object> createNodeIndex(Map<String,Object> options)

createNodeConstraint

public Map<String,Object> createNodeConstraint(Map<String,Object> options)

createRelationshipIndex

public Map<String,Object> createRelationshipIndex(Map<String,Object> options)

dropIndex

public Map<String,Object> dropIndex(Map<String,Object> options)

TS drop index — resolves name or legacy index key after context merge.

dropConstraint

public Map<String,Object> dropConstraint(Map<String,Object> options)

dropIndex

public Map<String,Object> dropIndex(String indexName)

TS dropIndex(name: string) after connect.

dropConstraint

public Map<String,Object> dropConstraint(String constraintName)

TS dropConstraint(name: string) after connect.

shortestPath

public Map<String,Object> shortestPath(Map<String,Object> options)

allPaths

public Map<String,Object> allPaths(Map<String,Object> options)

getNeighborhood

public Map<String,Object> getNeighborhood(Map<String,Object> options)

findConnectedComponents

public Map<String,Object> findConnectedComponents(Map<String,Object> options)

fullTextSearch

public Map<String,Object> fullTextSearch(Map<String,Object> options)

TS fullTextSearch / IFullTextSearchResult.

vectorSearch

public Map<String,Object> vectorSearch(Map<String,Object> options)

TS vectorSearch / IVectorSearchResult.

getSchemaSnapshot

public Map<String,Object> getSchemaSnapshot()

getSchemaSnapshot

public Map<String,Object> getSchemaSnapshot(String productTag,
 String env,
 String graphTag)

createAction

public Map<String,Object> createAction(Map<String,Object> options,
 String productTag)

listActions

public List<Map<String,Object>> listActions(String graphTag,
 String productTag)

getAction

public Map<String,Object> getAction(String actionTag,
 String graphTag,
 String productTag)

updateAction

public Map<String,Object> updateAction(Map<String,Object> options,
 String productTag)

deleteAction

public void deleteAction(String actionTag,
 String graphTag,
 String productTag)

executeAction

public Map<String,Object> executeAction(Map<String,Object> options)

execute

public Map<String,Object> execute(Map<String,Object> options)

TS convenience entry where execute maps to predefined graph-action execution (parallel to TS overloads).

action

public GraphService.GraphActionDispatchSubsystem action()

dispatchGraphAction

public Map<String,Object> dispatchGraphAction(Map<String,Object> data)

Direct Java alias for TS graph.action.dispatch when fluent action() is not desirable.

dispatch

public Map<String,Object> dispatch(Map<String,Object> data)

TS graphs.service.ts#dispatch: schedule semantics, graph-operation:{graph}:{operation} job tag, prepareGraphDispatchJob(app.ductape.sdk.graph.GraphService.ScheduledGraphDispatchChannel, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, java.lang.Object>, long) then dispatchGraphProcessorJob(java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, app.ductape.sdk.graph.GraphService.ScheduledGraphDispatchChannel) with TS-shaped processor input, then job_id/status payload. Optional integrations: CONFIG_ENSURE_GRAPH_JOBS, CONFIG_RECORD_JOB_EXECUTION (see hooks below).

prepareGraphDispatchJob

protected void prepareGraphDispatchJob(GraphService.ScheduledGraphDispatchChannel dispatchChannel,
 String productTag,
 String graph,
 String logicalName,
 String jobTag,
 Map<String,Object> dispatchData,
 Map<String,Object> schedule,
 long startAt)

TS: productBuilder.fetchJob / createJob before processJob. When CONFIG_ENSURE_GRAPH_JOBS is true, delegates to graph-action / graph-operation job upserts per channel; otherwise no-op.

dispatchGraphProcessorJob

protected void dispatchGraphProcessorJob(String jobId,
 Map<String,Object> jobInput,
 GraphService.ScheduledGraphDispatchChannel dispatchChannel)

TS: processorService.processJob(jobInput). In Java, this is Redisson-native when a JobsService.JobQueueAdapter is configured: dispatch builds the same graph worker payload TS enqueues, then ProcessorService.runJobs(java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, java.lang.Object>) calls #processProcessorJob(Map) to execute it. Without a queue adapter, the optional synchronous config preserves the local/no-Redis test path.

Parameters:

jobId - client-visible id (same string returned from dispatch(java.util.Map<java.lang.String, java.lang.Object>))

jobInput - TS-shaped IJobProcessorInput analogue

dispatchChannel - distinguishes graph-operation vs graph-action jobs for tracker payloads

buildGraphJobProcessorInput

protected Map<String,Object> buildGraphJobProcessorInput(Map<String,Object> data,
 Map<String,Object> schedule,
 String jobTag,
 long startAt)

TS IJobProcessorInput fields used by graph dispatch.

beginTransaction

public Map<String,Object> beginTransaction(Map<String,Object> options)

commitTransaction

public void commitTransaction(Map<String,Object> transaction)

rollbackTransaction

public void rollbackTransaction(Map<String,Object> transaction)

executeTransaction

public <T> T executeTransaction(Function<Map<String,Object>,T> callback,
 Map<String,Object> options)

TS graph.executeTransaction(cb, txnOptions) analogue — executes within GraphTransactionManager begin/commit rollback semantics for the resolved connection adapter.

supportsFeature

public boolean supportsFeature(GraphTypes.GraphFeature feature)

supportsFeature

public boolean supportsFeature(String feature)

processGraphOperationJob

public Map<String,Object> processGraphOperationJob(Map<String,Object> data)

Worker-side entry point for graph_operation jobs claimed off the Redisson queue. Mirrors the GRAPH_OPERATION branch of TS processor.service.ts#processJob.

processGraphActionJob

public Map<String,Object> processGraphActionJob(Map<String,Object> data)

Worker-side entry point for graph_action jobs claimed off the Redisson queue. Mirrors the GRAPH_ACTION branch of TS processor.service.ts#processJob.

processProcessorJob

protected Map<String,Object> processProcessorJob(GraphService.ScheduledGraphDispatchChannel channel,
 Map<String,Object> data)

Internal worker entry used by processGraphOperationJob(java.util.Map<java.lang.String, java.lang.Object>) / processGraphActionJob(java.util.Map<java.lang.String, java.lang.Object>). The data payload uses the same fields produced by buildGraphProcessorQueueInput(java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, app.ductape.sdk.graph.GraphService.ScheduledGraphDispatchChannel) (TS processor.service.ts GRAPH_* branches): product, env, graph, plus either operation (graph-operation jobs) or event (graph-action jobs).