Package app.ductape.sdk.products.services

Class ProductsService

java.lang.Object

app.ductape.sdk.products.services.ProductsService

public class ProductsService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACTION_JOB_TYPE	TS JobEventTypes.ACTION discriminator for agent dispatch jobs.
static final String	COMPONENT_AGENT	TS ProductComponents.AGENT.
static final String	COMPONENT_ENV	TS ProductComponents.ENV.
static final String	COMPONENT_GRAPH	TS ProductComponents.GRAPH.
static final String	COMPONENT_JOB	TS ProductComponents.JOB.
static final String	COMPONENT_SESSION	TS ProductComponents.SESSION.
static final String	COMPONENT_VECTOR	TS ProductComponents.VECTOR.
static final String	FEATURE_JOB_TYPE	TS JobEventTypes.FEATURE discriminator for feature dispatch jobs.
static final String	GRAPH_ACTION_JOB_TYPE	TS JobEventTypes.GRAPH_ACTION discriminator for predefined graph-action jobs.
static final String	GRAPH_OPERATION_JOB_TYPE	TS JobEventTypes.GRAPH_OPERATION discriminator for job payloads.

Constructor Summary

Constructors

Constructor	Description
ProductsService(ProductsApiService api, CloudApiService cloudApi, RequestContext auth)
ProductsService(ProductsApiService api, RequestContext auth)
ProductsService(EnvType environment, RequestContext auth)

Method Summary

Modifier and Type	Method	Description
RequestContext	authContext()	Returns the workspace auth context used for product API calls.
BootstrapModels.BootstrapActionResponse	bootstrapAction(BootstrapModels.BootstrapActionParams params)
BootstrapModels.BootstrapBrokerResponse	bootstrapBroker(BootstrapModels.BootstrapBrokerParams params)
BootstrapModels.BootstrapDatabaseResponse	bootstrapDatabase(BootstrapModels.BootstrapDatabaseParams params)
Map<String,Object>	bootstrapFeature(BootstrapModels.BootstrapFeatureParams params)
BootstrapModels.BootstrapGraphResponse	bootstrapGraph(BootstrapModels.BootstrapGraphParams params)
BootstrapModels.BootstrapIntelligenceResponse	bootstrapIntelligence(BootstrapModels.BootstrapIntelligenceParams params)
BootstrapModels.BootstrapNotificationResponse	bootstrapNotification(BootstrapModels.BootstrapNotificationParams params)
BootstrapModels.BootstrapResilienceResponse	bootstrapResilience(BootstrapModels.BootstrapResilienceParams params)
BootstrapModels.BootstrapSessionResponse	bootstrapSession(BootstrapModels.BootstrapSessionParams params)
BootstrapModels.BootstrapStorageResponse	bootstrapStorage(BootstrapModels.BootstrapStorageParams params)
BootstrapModels.BootstrapVectorResponse	bootstrapVector(BootstrapModels.BootstrapVectorParams params)
ProductBuilder	builder(String productTag)	Sprint 3 — open the fluent ProductBuilder bound to this service for a given product tag.
Map<String,Object>	checkProductNameExists(String name)
CloudApiService	cloudApi()
void	createAgent(String productId, Map<String,Object> agentPayload)	TS createAgent: minimal update payload (caller validates).
void	createDatabase(String productTag, Map<String,Object> data)	TS createDatabase with cloud-linked env materialization.
void	createDatabase(String productTag, Map<String,Object> data, boolean throwIfExists)
void	createDatabaseAction(String productId, Map<String,Object> data)
void	createDatabaseAction(String productId, Map<String,Object> data, boolean throwErrorIfExists)
void	createDatabaseMigration(String productId, Map<String,Object> data)
void	createDatabaseMigration(String productId, Map<String,Object> data, boolean throwErrorIfExists)
void	createDatabaseTrigger(String productId, Map<String,Object> data)
void	createDatabaseTrigger(String productId, Map<String,Object> data, boolean throwErrorIfExists)
void	createEnv(String productId, Map<String,Object> envPayload)	TS createEnv: register a product environment component.
void	createGraph(String productTag, Map<String,Object> data)	TS createGraph with cloud-linked env materialization.
void	createGraph(String productTag, Map<String,Object> data, boolean throwIfExists)
void	createMessageBroker(String productTag, Map<String,Object> data)	TS createMessageBroker with cloud-linked env materialization.
void	createMessageBroker(String productTag, Map<String,Object> data, boolean throwIfExists)
void	createMessageBrokerTopic(String productTag, Map<String,Object> data)	TS sdk.events.topics.create: standalone topic create on an existing broker.
Map<String,Object>	createProduct(Map<String,Object> productPayload)
void	createStorage(String productTag, Map<String,Object> data)	TS createStorage with cloud-linked env materialization.
void	createStorage(String productTag, Map<String,Object> data, boolean throwIfExists)
void	createVector(String productTag, Map<String,Object> data)	TS createVector with cloud-linked env materialization.
void	createVector(String productTag, Map<String,Object> data, boolean throwIfExists)
void	deleteAgent(String productId, String tag)	TS deleteAgent(tag).
void	deleteDatabaseAction(String productId, String compositeTag)
void	deleteDatabaseMigration(String productId, String compositeTag)
void	deleteDatabaseTrigger(String productId, String compositeTag)
void	deleteGraph(String productId, String graphTag)	TS ProductsService.deleteGraph: remove a graph component from the product.
void	deleteProduct(String productId)
void	ensureActionJobForDispatch(String productTag, String app, String action, String jobTag, Map<String,Object> schedule, long startAt)	TS actions.dispatch: ensure an action product-job component exists with app/event keyed off the dispatched app + action tags.
void	ensureAgentJobForDispatch(String productTag, String agentTag, String jobTag, Map<String,Object> schedule, long startAt)	TS agents.service.ts#dispatch: ensure an action job exists (app=agent tag, event=execute).
void	ensureFeatureJobForDispatch(String productTag, String featureTag, String jobTag, Map<String,Object> schedule, long startAt)	TS features.service.ts#dispatch: ensure a feature job component exists before processJob.
void	ensureGraphActionJobForDispatch(String productTag, String graph, String event, String jobTag, Map<String,Object> schedule, long startAt)	TS graphs.service.ts#get action().dispatch: ensure a graph_action job exists before processor input.
void	ensureGraphOperationJobForDispatch(String productTag, String graph, String operation, String jobTag, Map<String,Object> schedule, long startAt)	TS graphs.service.ts#dispatch: ensure a graph_operation product job exists (creates via updateProduct when missing).
Map<String,Object>	fetchAgent(String productId, String tag)	TS fetchAgent(tag) via component lookup.
List<Map<String,Object>>	fetchAgents(String productId)	TS fetchAgents via fetchProductComponents(String, String).
Map<String,Object>	fetchDatabaseAction(String productId, String compositeTag, boolean throwIfMissing)
List<Map<String,Object>>	fetchDatabaseActions(String productId, String databaseTag)
Map<String,Object>	fetchDatabaseMigration(String productId, String compositeTag, boolean throwError)
List<Map<String,Object>>	fetchDatabaseMigrations(String productId, String databaseTag)
Map<String,Object>	fetchDatabaseTrigger(String productId, String compositeTag, boolean throwIfMissing)
List<Map<String,Object>>	fetchDatabaseTriggers(String productId, String databaseTag)
Map<String,Object>	fetchJob(String productId, String tag)	TS fetchJob(tag) via product API job component lookup.
Map<String,Object>	fetchProduct(String productId)
Map<String,Object>	fetchProductByTag(String productTag)
Map<String,Object>	fetchProductComponentByTag(String productId, String componentType, String tag)
List<Map<String,Object>>	fetchProductComponents(String productId, String componentType)
Map<String,Object>	fetchProductSessionUser(String ductapeUserId)
List<Map<String,Object>>	fetchProductSessionUsers(Map<String,Object> payload)
List<Map<String,Object>>	fetchProductStorageFiles(Map<String,Object> payload)
Map<String,Object>	fetchSession(String productId, String tag)	TS sdk.sessions.fetch(product, tag) -> ProductBuilder.fetchSession(tag): session *definition* fetch by tag.
List<Map<String,Object>>	fetchSessions(String productId)	TS sdk.sessions.list(product) -> ProductBuilder.fetchSessions(): session *definition* list, distinct from SessionsService.list/listActive (runtime active-session instances).
List<Map<String,Object>>	fetchWorkspaceProducts(String status)
BootstrapModels.GenerateExecutablePayloadResponse	generateExecutablePayload(BootstrapModels.GenerateExecutablePayloadParams params)
Map<String,Object>	initProduct(String id)
static String	productDocumentId(Map<String,Object> productRow)	Resolves Mongo-style _id or id from a fetched product envelope (processors / job executions).
Map<String,Object>	resolveDatabaseConfig(String productId, String databaseTag)	TS resolveDatabaseConfig: in-memory product.databases first, then API component fetch.
String	resolveProductIdByTag(String productTag)	TS ProductBuilder: resolve numeric/mongo product_id from a product tag via fetchProductByTag(String).
void	updateAgent(String productId, Map<String,Object> agentPayload)	TS updateAgent: merged payload with component/action.
void	updateAuth(RequestContext next)	Replace credentials for downstream API calls (TS cache/products updateConfig parity).
void	updateDatabase(String productTag, String tag, Map<String,Object> data)
void	updateDatabaseAction(String productId, Map<String,Object> data)
void	updateDatabaseMigration(String productId, Map<String,Object> data)
void	updateDatabaseTrigger(String productId, Map<String,Object> data)
void	updateGraph(String productTag, String tag, Map<String,Object> data)
void	updateJobDefinition(String productTag, String tag, Map<String,Object> data)	TS sdk.jobs.update(product, tag, data) -> ProductBuilder.updateJob(tag, data): job-*definition* CRUD (distinct from JobsService's runtime job tracker).
void	updateMessageBroker(String productTag, String tag, Map<String,Object> data)
void	updateMessageBrokerTopic(String productTag, String fullTag, Map<String,Object> data)	TS sdk.events.topics.update.
void	updateProduct(String productId, Map<String,Object> updatePayload)
void	updateSessionDefinition(String productTag, String tag, Map<String,Object> data)	TS sdk.sessions.update(product, tag, data) -> ProductBuilder.updateSession(tag, data): fetches the existing session-definition component, merges the supplied fields on top (defaulting tag to the original when not overridden, matching TS), and resends via updateProduct with component=session, action=update.
void	updateStorage(String productTag, String tag, Map<String,Object> data)
void	updateVector(String productTag, String tag, Map<String,Object> data)

Methods inherited from class java.lang.Object

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

Field Details

COMPONENT_JOB

public static final String COMPONENT_JOB

TS ProductComponents.JOB.

See Also:

• Constant Field Values

GRAPH_OPERATION_JOB_TYPE

public static final String GRAPH_OPERATION_JOB_TYPE

TS JobEventTypes.GRAPH_OPERATION discriminator for job payloads.

See Also:

• Constant Field Values

FEATURE_JOB_TYPE

public static final String FEATURE_JOB_TYPE

TS JobEventTypes.FEATURE discriminator for feature dispatch jobs.

See Also:

• Constant Field Values

ACTION_JOB_TYPE

public static final String ACTION_JOB_TYPE

TS JobEventTypes.ACTION discriminator for agent dispatch jobs.

See Also:

• Constant Field Values

COMPONENT_AGENT

public static final String COMPONENT_AGENT

TS ProductComponents.AGENT.

See Also:

• Constant Field Values

COMPONENT_SESSION

public static final String COMPONENT_SESSION

TS ProductComponents.SESSION.

See Also:

• Constant Field Values

COMPONENT_ENV

public static final String COMPONENT_ENV

TS ProductComponents.ENV.

See Also:

• Constant Field Values

COMPONENT_VECTOR

public static final String COMPONENT_VECTOR

TS ProductComponents.VECTOR.

See Also:

• Constant Field Values

COMPONENT_GRAPH

public static final String COMPONENT_GRAPH

TS ProductComponents.GRAPH.

See Also:

• Constant Field Values

GRAPH_ACTION_JOB_TYPE

public static final String GRAPH_ACTION_JOB_TYPE

TS JobEventTypes.GRAPH_ACTION discriminator for predefined graph-action jobs.

See Also:

• Constant Field Values

Constructor Details

ProductsService

public ProductsService(EnvType environment,
 RequestContext auth)

ProductsService

public ProductsService(ProductsApiService api,
 RequestContext auth)

ProductsService

public ProductsService(ProductsApiService api,
 CloudApiService cloudApi,
 RequestContext auth)

Method Details

cloudApi

public CloudApiService cloudApi()

createStorage

public void createStorage(String productTag,
 Map<String,Object> data)

TS createStorage with cloud-linked env materialization.

createStorage

public void createStorage(String productTag,
 Map<String,Object> data,
 boolean throwIfExists)

updateStorage

public void updateStorage(String productTag,
 String tag,
 Map<String,Object> data)

createMessageBroker

public void createMessageBroker(String productTag,
 Map<String,Object> data)

TS createMessageBroker with cloud-linked env materialization.

createMessageBroker

public void createMessageBroker(String productTag,
 Map<String,Object> data,
 boolean throwIfExists)

updateMessageBroker

public void updateMessageBroker(String productTag,
 String tag,
 Map<String,Object> data)

createMessageBrokerTopic

public void createMessageBrokerTopic(String productTag,
 Map<String,Object> data)

TS sdk.events.topics.create: standalone topic create on an existing broker. data.tag must be "brokerTag:topicTag".

updateMessageBrokerTopic

public void updateMessageBrokerTopic(String productTag,
 String fullTag,
 Map<String,Object> data)

TS sdk.events.topics.update.

createDatabase

public void createDatabase(String productTag,
 Map<String,Object> data)

TS createDatabase with cloud-linked env materialization.

createDatabase

public void createDatabase(String productTag,
 Map<String,Object> data,
 boolean throwIfExists)

updateDatabase

public void updateDatabase(String productTag,
 String tag,
 Map<String,Object> data)

createGraph

public void createGraph(String productTag,
 Map<String,Object> data)

TS createGraph with cloud-linked env materialization.

createGraph

public void createGraph(String productTag,
 Map<String,Object> data,
 boolean throwIfExists)

updateGraph

public void updateGraph(String productTag,
 String tag,
 Map<String,Object> data)

createVector

public void createVector(String productTag,
 Map<String,Object> data)

TS createVector with cloud-linked env materialization.

createVector

public void createVector(String productTag,
 Map<String,Object> data,
 boolean throwIfExists)

updateVector

public void updateVector(String productTag,
 String tag,
 Map<String,Object> data)

builder

public ProductBuilder builder(String productTag)

Sprint 3 — open the fluent ProductBuilder bound to this service for a given product tag.

updateAuth

public void updateAuth(RequestContext next)

Replace credentials for downstream API calls (TS cache/products updateConfig parity).

authContext

public RequestContext authContext()

Returns the workspace auth context used for product API calls.

createProduct

public Map<String,Object> createProduct(Map<String,Object> productPayload)

updateProduct

public void updateProduct(String productId,
 Map<String,Object> updatePayload)

deleteProduct

public void deleteProduct(String productId)

deleteGraph

public void deleteGraph(String productId,
 String graphTag)

TS ProductsService.deleteGraph: remove a graph component from the product.

fetchProduct

public Map<String,Object> fetchProduct(String productId)

fetchProductByTag

public Map<String,Object> fetchProductByTag(String productTag)

fetchWorkspaceProducts

public List<Map<String,Object>> fetchWorkspaceProducts(String status)

fetchProductStorageFiles

public List<Map<String,Object>> fetchProductStorageFiles(Map<String,Object> payload)

fetchProductSessionUsers

public List<Map<String,Object>> fetchProductSessionUsers(Map<String,Object> payload)

fetchProductSessionUser

public Map<String,Object> fetchProductSessionUser(String ductapeUserId)

checkProductNameExists

public Map<String,Object> checkProductNameExists(String name)

fetchProductComponents

public List<Map<String,Object>> fetchProductComponents(String productId,
 String componentType)

fetchProductComponentByTag

public Map<String,Object> fetchProductComponentByTag(String productId,
 String componentType,
 String tag)

resolveProductIdByTag

public String resolveProductIdByTag(String productTag)

TS ProductBuilder: resolve numeric/mongo product_id from a product tag via fetchProductByTag(String).

initProduct

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

bootstrapAction

public BootstrapModels.BootstrapActionResponse bootstrapAction(BootstrapModels.BootstrapActionParams params)

bootstrapNotification

public BootstrapModels.BootstrapNotificationResponse bootstrapNotification(BootstrapModels.BootstrapNotificationParams params)

bootstrapStorage

public BootstrapModels.BootstrapStorageResponse bootstrapStorage(BootstrapModels.BootstrapStorageParams params)

bootstrapSession

public BootstrapModels.BootstrapSessionResponse bootstrapSession(BootstrapModels.BootstrapSessionParams params)

bootstrapDatabase

public BootstrapModels.BootstrapDatabaseResponse bootstrapDatabase(BootstrapModels.BootstrapDatabaseParams params)

bootstrapBroker

public BootstrapModels.BootstrapBrokerResponse bootstrapBroker(BootstrapModels.BootstrapBrokerParams params)

bootstrapGraph

public BootstrapModels.BootstrapGraphResponse bootstrapGraph(BootstrapModels.BootstrapGraphParams params)

bootstrapVector

public BootstrapModels.BootstrapVectorResponse bootstrapVector(BootstrapModels.BootstrapVectorParams params)

bootstrapResilience

public BootstrapModels.BootstrapResilienceResponse bootstrapResilience(BootstrapModels.BootstrapResilienceParams params)

bootstrapIntelligence

public BootstrapModels.BootstrapIntelligenceResponse bootstrapIntelligence(BootstrapModels.BootstrapIntelligenceParams params)

bootstrapFeature

public Map<String,Object> bootstrapFeature(BootstrapModels.BootstrapFeatureParams params)

generateExecutablePayload

public BootstrapModels.GenerateExecutablePayloadResponse generateExecutablePayload(BootstrapModels.GenerateExecutablePayloadParams params)

fetchJob

public Map<String,Object> fetchJob(String productId,
 String tag)

TS fetchJob(tag) via product API job component lookup.

updateJobDefinition

public void updateJobDefinition(String productTag,
 String tag,
 Map<String,Object> data)

TS sdk.jobs.update(product, tag, data) -> ProductBuilder.updateJob(tag, data): job-*definition* CRUD (distinct from JobsService's runtime job tracker). Fetches the existing job component, merges the supplied fields on top, and resends via updateProduct with component=job, action=update.

fetchSessions

public List<Map<String,Object>> fetchSessions(String productId)

TS sdk.sessions.list(product) -> ProductBuilder.fetchSessions(): session *definition* list, distinct from SessionsService.list/listActive (runtime active-session instances).

fetchSession

public Map<String,Object> fetchSession(String productId,
 String tag)

TS sdk.sessions.fetch(product, tag) -> ProductBuilder.fetchSession(tag): session *definition* fetch by tag.

updateSessionDefinition

public void updateSessionDefinition(String productTag,
 String tag,
 Map<String,Object> data)

TS sdk.sessions.update(product, tag, data) -> ProductBuilder.updateSession(tag, data): fetches the existing session-definition component, merges the supplied fields on top (defaulting tag to the original when not overridden, matching TS), and resends via updateProduct with component=session, action=update.

ensureGraphOperationJobForDispatch

public void ensureGraphOperationJobForDispatch(String productTag,
 String graph,
 String operation,
 String jobTag,
 Map<String,Object> schedule,
 long startAt)

TS graphs.service.ts#dispatch: ensure a graph_operation product job exists (creates via updateProduct when missing). Resolves numeric product id from fetchProductByTag(productTag).

ensureFeatureJobForDispatch

public void ensureFeatureJobForDispatch(String productTag,
 String featureTag,
 String jobTag,
 Map<String,Object> schedule,
 long startAt)

TS features.service.ts#dispatch: ensure a feature job component exists before processJob.

ensureActionJobForDispatch

public void ensureActionJobForDispatch(String productTag,
 String app,
 String action,
 String jobTag,
 Map<String,Object> schedule,
 long startAt)

TS actions.dispatch: ensure an action product-job component exists with app/event keyed off the dispatched app + action tags. Idempotent — does nothing if the job already exists.

ensureAgentJobForDispatch

public void ensureAgentJobForDispatch(String productTag,
 String agentTag,
 String jobTag,
 Map<String,Object> schedule,
 long startAt)

TS agents.service.ts#dispatch: ensure an action job exists (app=agent tag, event=execute).

fetchAgents

public List<Map<String,Object>> fetchAgents(String productId)

TS fetchAgents via fetchProductComponents(String, String).

fetchAgent

public Map<String,Object> fetchAgent(String productId,
 String tag)

TS fetchAgent(tag) via component lookup.

createAgent

public void createAgent(String productId,
 Map<String,Object> agentPayload)

TS createAgent: minimal update payload (caller validates).

updateAgent

public void updateAgent(String productId,
 Map<String,Object> agentPayload)

TS updateAgent: merged payload with component/action.

deleteAgent

public void deleteAgent(String productId,
 String tag)

TS deleteAgent(tag).

createEnv

public void createEnv(String productId,
 Map<String,Object> envPayload)

TS createEnv: register a product environment component.

ensureGraphActionJobForDispatch

public void ensureGraphActionJobForDispatch(String productTag,
 String graph,
 String event,
 String jobTag,
 Map<String,Object> schedule,
 long startAt)

TS graphs.service.ts#get action().dispatch: ensure a graph_action job exists before processor input.

productDocumentId

public static String productDocumentId(Map<String,Object> productRow)

Resolves Mongo-style _id or id from a fetched product envelope (processors / job executions).

createDatabaseTrigger

public void createDatabaseTrigger(String productId,
 Map<String,Object> data,
 boolean throwErrorIfExists)

Parameters:

data - must include tag in the form database_tag:trigger_tag (other fields follow TS IProductDatabaseTrigger)

createDatabaseTrigger

public void createDatabaseTrigger(String productId,
 Map<String,Object> data)

updateDatabaseTrigger

public void updateDatabaseTrigger(String productId,
 Map<String,Object> data)

fetchDatabaseTrigger

public Map<String,Object> fetchDatabaseTrigger(String productId,
 String compositeTag,
 boolean throwIfMissing)

Parameters:

compositeTag - database_tag:trigger_tag

Returns:

the trigger map, or null if not found (or throws when throwIfMissing and missing)

fetchDatabaseTriggers

public List<Map<String,Object>> fetchDatabaseTriggers(String productId,
 String databaseTag)

deleteDatabaseTrigger

public void deleteDatabaseTrigger(String productId,
 String compositeTag)

createDatabaseMigration

public void createDatabaseMigration(String productId,
 Map<String,Object> data,
 boolean throwErrorIfExists)

createDatabaseMigration

public void createDatabaseMigration(String productId,
 Map<String,Object> data)

updateDatabaseMigration

public void updateDatabaseMigration(String productId,
 Map<String,Object> data)

fetchDatabaseMigration

public Map<String,Object> fetchDatabaseMigration(String productId,
 String compositeTag,
 boolean throwError)

fetchDatabaseMigrations

public List<Map<String,Object>> fetchDatabaseMigrations(String productId,
 String databaseTag)

deleteDatabaseMigration

public void deleteDatabaseMigration(String productId,
 String compositeTag)

createDatabaseAction

public void createDatabaseAction(String productId,
 Map<String,Object> data,
 boolean throwErrorIfExists)

createDatabaseAction

public void createDatabaseAction(String productId,
 Map<String,Object> data)

updateDatabaseAction

public void updateDatabaseAction(String productId,
 Map<String,Object> data)

fetchDatabaseAction

public Map<String,Object> fetchDatabaseAction(String productId,
 String compositeTag,
 boolean throwIfMissing)

fetchDatabaseActions

public List<Map<String,Object>> fetchDatabaseActions(String productId,
 String databaseTag)

deleteDatabaseAction

public void deleteDatabaseAction(String productId,
 String compositeTag)

resolveDatabaseConfig

public Map<String,Object> resolveDatabaseConfig(String productId,
 String databaseTag)

TS resolveDatabaseConfig: in-memory product.databases first, then API component fetch.