Package app.ductape.sdk.api.services

Class ProcessorApiService

java.lang.Object

app.ductape.sdk.api.services.ProcessorApiService

public class ProcessorApiService
extends Object

Constructor Summary

Constructors

Constructor	Description
ProcessorApiService(EnvType environment)
ProcessorApiService(String baseUrl)	Test/integration constructor for explicit base URL (e.g., MockWebServer).

Method Summary

Modifier and Type	Method	Description
void	addToRemoteCache(Map<String,Object> payload, RequestContext auth)
List<Map<String,Object>>	batchFetch(List<String> ids, RequestContext auth)
List<Map<String,Object>>	batchWrite(List<Map<String,Object>> items, RequestContext auth)
Map<String,Object>	checkIdempotency(Map<String,Object> payload, RequestContext auth)
boolean	checkSessionRevoked(Map<String,Object> payload, RequestContext auth)
void	createJobExecution(Map<String,Object> payload, RequestContext auth)	TS processorApi.service#createJobExecution: enqueue-side job tracker row.
void	createSessionInfo(Map<String,Object> payload, RequestContext auth)
boolean	deleteCacheValue(String key, RequestContext auth)	TS deleteCacheValue: DELETE Urls.CACHE_VALUE_DELETE.
Map<String,Object>	deleteCacheValues(Map<String,Object> payload, RequestContext auth)	TS deleteCacheValues: DELETE Urls.CACHE_VALUES with product/cache filters.
Map<String,Object>	failBrokerMessage(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	fetchCacheValues(Map<String,Object> payload, RequestContext auth)	TS fetchCacheValues: GET Urls.CACHE_VALUES with workspace auth query params.
Map<String,Object>	fetchCacheValuesDashboard(Map<String,Object> payload, RequestContext auth)	TS fetchCacheValuesDashboard: GET Urls.CACHE_VALUES_DASHBOARD.
Object	fetchRemoteCacheByKey(String key, RequestContext auth)
List<Map<String,Object>>	fetchRemoteCaches(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	fetchResult(String processId, RequestContext auth)
Map<String,Object>	getBrokerComprehensiveStats(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerConsumers(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerDashboard(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerDeadLetters(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerEvent(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerEvents(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerEventStats(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerMessageStats(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	getBrokerProducers(Map<String,Object> payload, RequestContext auth)
DuctapeHttpClient	http()
List<Map<String,Object>>	listSessions(Map<String,Object> payload, RequestContext auth)
<T> T	processProduct(String productId, Map<String,Object> payload, RequestContext auth)	TS processorApi.service#processProduct: POST to Urls.PROCESS_INTEGRATION_URL for server-side component execution (database, graph, workflows, etc.).
Map<String,Object>	queryBrokerMessages(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	queryNotificationMessageLogs(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	registerBrokerConsumer(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	replayBrokerEvent(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	reprocessDLQ(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	retryBrokerMessage(Map<String,Object> payload, RequestContext auth)
void	revokeSession(Map<String,Object> payload, RequestContext auth)
void	saveFileURL(Map<String,Object> payload, RequestContext auth)
void	saveResult(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	trackBrokerMessage(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	trackBrokerMessageIdempotent(Map<String,Object> payload, RequestContext auth)
Map<String,Object>	updateBrokerConsumerStatus(Map<String,Object> payload, RequestContext auth)
void	updateJobExecutionPhase(Map<String,Object> payload, RequestContext auth)	TS processorApi.service#updateJobExecutionPhase: non-fatal tracker phase update.
boolean	validateRefreshToken(Map<String,Object> payload, RequestContext auth)

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessorApiService

public ProcessorApiService(EnvType environment)

ProcessorApiService

public ProcessorApiService(String baseUrl)

Test/integration constructor for explicit base URL (e.g., MockWebServer).

Method Details

http

public DuctapeHttpClient http()

saveFileURL

public void saveFileURL(Map<String,Object> payload,
 RequestContext auth)

saveResult

public void saveResult(Map<String,Object> payload,
 RequestContext auth)

batchWrite

public List<Map<String,Object>> batchWrite(List<Map<String,Object>> items,
 RequestContext auth)

batchFetch

public List<Map<String,Object>> batchFetch(List<String> ids,
 RequestContext auth)

fetchResult

public Map<String,Object> fetchResult(String processId,
 RequestContext auth)

fetchRemoteCacheByKey

public Object fetchRemoteCacheByKey(String key,
 RequestContext auth)

fetchRemoteCaches

public List<Map<String,Object>> fetchRemoteCaches(Map<String,Object> payload,
 RequestContext auth)

addToRemoteCache

public void addToRemoteCache(Map<String,Object> payload,
 RequestContext auth)

fetchCacheValues

public Map<String,Object> fetchCacheValues(Map<String,Object> payload,
 RequestContext auth)

TS fetchCacheValues: GET Urls.CACHE_VALUES with workspace auth query params. On failure returns an empty page (mirrors TS catch default object).

fetchCacheValuesDashboard

public Map<String,Object> fetchCacheValuesDashboard(Map<String,Object> payload,
 RequestContext auth)

TS fetchCacheValuesDashboard: GET Urls.CACHE_VALUES_DASHBOARD.

deleteCacheValue

public boolean deleteCacheValue(String key,
 RequestContext auth)

TS deleteCacheValue: DELETE Urls.CACHE_VALUE_DELETE.

deleteCacheValues

public Map<String,Object> deleteCacheValues(Map<String,Object> payload,
 RequestContext auth)

TS deleteCacheValues: DELETE Urls.CACHE_VALUES with product/cache filters.

createSessionInfo

public void createSessionInfo(Map<String,Object> payload,
 RequestContext auth)

revokeSession

public void revokeSession(Map<String,Object> payload,
 RequestContext auth)

listSessions

public List<Map<String,Object>> listSessions(Map<String,Object> payload,
 RequestContext auth)

validateRefreshToken

public boolean validateRefreshToken(Map<String,Object> payload,
 RequestContext auth)

checkSessionRevoked

public boolean checkSessionRevoked(Map<String,Object> payload,
 RequestContext auth)

getBrokerEvents

public Map<String,Object> getBrokerEvents(Map<String,Object> payload,
 RequestContext auth)

getBrokerEvent

public Map<String,Object> getBrokerEvent(Map<String,Object> payload,
 RequestContext auth)

replayBrokerEvent

public Map<String,Object> replayBrokerEvent(Map<String,Object> payload,
 RequestContext auth)

getBrokerEventStats

public Map<String,Object> getBrokerEventStats(Map<String,Object> payload,
 RequestContext auth)

reprocessDLQ

public Map<String,Object> reprocessDLQ(Map<String,Object> payload,
 RequestContext auth)

checkIdempotency

public Map<String,Object> checkIdempotency(Map<String,Object> payload,
 RequestContext auth)

queryNotificationMessageLogs

public Map<String,Object> queryNotificationMessageLogs(Map<String,Object> payload,
 RequestContext auth)

trackBrokerMessage

public Map<String,Object> trackBrokerMessage(Map<String,Object> payload,
 RequestContext auth)

trackBrokerMessageIdempotent

public Map<String,Object> trackBrokerMessageIdempotent(Map<String,Object> payload,
 RequestContext auth)

registerBrokerConsumer

public Map<String,Object> registerBrokerConsumer(Map<String,Object> payload,
 RequestContext auth)

updateBrokerConsumerStatus

public Map<String,Object> updateBrokerConsumerStatus(Map<String,Object> payload,
 RequestContext auth)

getBrokerMessageStats

public Map<String,Object> getBrokerMessageStats(Map<String,Object> payload,
 RequestContext auth)

retryBrokerMessage

public Map<String,Object> retryBrokerMessage(Map<String,Object> payload,
 RequestContext auth)

failBrokerMessage

public Map<String,Object> failBrokerMessage(Map<String,Object> payload,
 RequestContext auth)

queryBrokerMessages

public Map<String,Object> queryBrokerMessages(Map<String,Object> payload,
 RequestContext auth)

getBrokerProducers

public Map<String,Object> getBrokerProducers(Map<String,Object> payload,
 RequestContext auth)

getBrokerConsumers

public Map<String,Object> getBrokerConsumers(Map<String,Object> payload,
 RequestContext auth)

getBrokerDeadLetters

public Map<String,Object> getBrokerDeadLetters(Map<String,Object> payload,
 RequestContext auth)

getBrokerComprehensiveStats

public Map<String,Object> getBrokerComprehensiveStats(Map<String,Object> payload,
 RequestContext auth)

getBrokerDashboard

public Map<String,Object> getBrokerDashboard(Map<String,Object> payload,
 RequestContext auth)

processProduct

public <T> T processProduct(String productId,
 Map<String,Object> payload,
 RequestContext auth)

TS processorApi.service#processProduct: POST to Urls.PROCESS_INTEGRATION_URL for server-side component execution (database, graph, workflows, etc.).

createJobExecution

public void createJobExecution(Map<String,Object> payload,
 RequestContext auth)

TS processorApi.service#createJobExecution: enqueue-side job tracker row. Fire-and-forget (HTTP failures are swallowed—mirrors TS catch / non-throwing callers).

updateJobExecutionPhase

public void updateJobExecutionPhase(Map<String,Object> payload,
 RequestContext auth)

TS processorApi.service#updateJobExecutionPhase: non-fatal tracker phase update.