Package app.ductape.sdk.database.triggers

Class TriggerProcessor

java.lang.Object

app.ductape.sdk.database.triggers.TriggerProcessor

All Implemented Interfaces:

TriggerTypes.TriggerManager

public class TriggerProcessor
extends Object
implements TriggerTypes.TriggerManager

In-memory trigger registry + persisted-shape CRUD (TriggerTypes.TriggerManager). Session triggers follow TS register(table, definition) with '*' for global.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	TriggerProcessor.AfterTriggerHook
static interface	TriggerProcessor.BeforeTriggerHook
static interface	TriggerProcessor.OnErrorHook
static final record	TriggerProcessor.TableTrigger
static interface	TriggerProcessor.TriggerActionRunner

Constructor Summary

Constructors

Constructor	Description
TriggerProcessor()

Method Summary

Modifier and Type	Method	Description
TriggerTypes.PersistedTrigger	create(TriggerTypes.CreateTriggerInput input)
void	create(Map<String,Object> trigger)	Legacy path: raw map stored as persisted-shaped trigger (tests / adapters).
boolean	delete(String tag)
boolean	evaluateCondition(Map<String,Object> condition, TriggerTypes.TriggerContext context)	TS evaluateCondition for map-shaped conditions (no custom functions).
Object	executeActionByType(String actionTypeWire, Map<String,Object> action, TriggerTypes.TriggerContext context)
TriggerTypes.TriggerResult	executeTrigger(TriggerTypes.TriggerDefinition trigger, TriggerTypes.TriggerContext context)	TS executeTrigger (sync): condition evaluation, optional parallel actions, retries per action.
List<TriggerTypes.TriggerResult>	executeTriggers(TriggerTypes.TriggerEvent event, TriggerTypes.TriggerContext context)	TS executeTriggers: runs session-registered triggers for context.table() and event.
TriggerTypes.PersistedTrigger	fetch(String tag)
Map<String,Object>	get(String tag)	Legacy get by tag.
Object	getDuctapeInstance()
TriggerTypes.TriggerConfig	getTriggerConfig()
List<TriggerTypes.TriggerDefinition>	getTriggersForEvent(String table, TriggerTypes.TriggerEvent event)	TS getTriggersForEvent: merges triggers for table and "*", filters by event, default priority 100 when null.
List<TriggerTypes.PersistedTrigger>	list(TriggerTypes.ListTriggersOptions options)
List<Map<String,Object>>	list(String databaseTag)	Legacy list by database tag.
void	register(String table, TriggerTypes.TriggerDefinition trigger)	TS register(table, trigger) — table "*" = global.
void	registerAll(List<TriggerProcessor.TableTrigger> rows)
void	setActionRunner(TriggerProcessor.TriggerActionRunner runner)
void	setAfterTriggerHook(TriggerProcessor.AfterTriggerHook hook)
void	setBeforeTriggerHook(TriggerProcessor.BeforeTriggerHook hook)
void	setDefaultContext(String product, String database)	Used when creating/updating persisted records via TriggerTypes.TriggerManager.
void	setDuctapeInstance(Object instance)	TS parity with trigger-processor.ts#setDuctapeInstance.
void	setOnErrorHook(TriggerProcessor.OnErrorHook hook)
void	setTriggerConfig(TriggerTypes.TriggerConfig config)
boolean	unregister(String table, String triggerName)	TS unregister(table, triggerName) — matches TriggerTypes.TriggerDefinition.name().
TriggerTypes.PersistedTrigger	update(String tag, TriggerTypes.UpdateTriggerInput input)

Methods inherited from class java.lang.Object

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

Constructor Details

TriggerProcessor

public TriggerProcessor()

Method Details

setTriggerConfig

public void setTriggerConfig(TriggerTypes.TriggerConfig config)

getTriggerConfig

public TriggerTypes.TriggerConfig getTriggerConfig()

setActionRunner

public void setActionRunner(TriggerProcessor.TriggerActionRunner runner)

setBeforeTriggerHook

public void setBeforeTriggerHook(TriggerProcessor.BeforeTriggerHook hook)

setAfterTriggerHook

public void setAfterTriggerHook(TriggerProcessor.AfterTriggerHook hook)

setOnErrorHook

public void setOnErrorHook(TriggerProcessor.OnErrorHook hook)

setDuctapeInstance

public void setDuctapeInstance(Object instance)

TS parity with trigger-processor.ts#setDuctapeInstance.

getDuctapeInstance

public Object getDuctapeInstance()

setDefaultContext

public void setDefaultContext(String product,
 String database)

Used when creating/updating persisted records via TriggerTypes.TriggerManager.

register

public void register(String table,
 TriggerTypes.TriggerDefinition trigger)

TS register(table, trigger) — table "*" = global.

registerAll

public void registerAll(List<TriggerProcessor.TableTrigger> rows)

unregister

public boolean unregister(String table,
 String triggerName)

TS unregister(table, triggerName) — matches TriggerTypes.TriggerDefinition.name().

getTriggersForEvent

public List<TriggerTypes.TriggerDefinition> getTriggersForEvent(String table,
 TriggerTypes.TriggerEvent event)

TS getTriggersForEvent: merges triggers for table and "*", filters by event, default priority 100 when null.

executeTriggers

public List<TriggerTypes.TriggerResult> executeTriggers(TriggerTypes.TriggerEvent event,
 TriggerTypes.TriggerContext context)

TS executeTriggers: runs session-registered triggers for context.table() and event.

executeTrigger

public TriggerTypes.TriggerResult executeTrigger(TriggerTypes.TriggerDefinition trigger,
 TriggerTypes.TriggerContext context)

TS executeTrigger (sync): condition evaluation, optional parallel actions, retries per action.

evaluateCondition

public boolean evaluateCondition(Map<String,Object> condition,
 TriggerTypes.TriggerContext context)

TS evaluateCondition for map-shaped conditions (no custom functions).

executeActionByType

public Object executeActionByType(String actionTypeWire,
 Map<String,Object> action,
 TriggerTypes.TriggerContext context)
                           throws Exception

Throws:

Exception

create

public void create(Map<String,Object> trigger)

Legacy path: raw map stored as persisted-shaped trigger (tests / adapters).

list

public List<Map<String,Object>> list(String databaseTag)

Legacy list by database tag.

get

public Map<String,Object> get(String tag)

Legacy get by tag.

create

public TriggerTypes.PersistedTrigger create(TriggerTypes.CreateTriggerInput input)
                                     throws Exception

Specified by:

create in interface TriggerTypes.TriggerManager

Throws:

Exception

list

public List<TriggerTypes.PersistedTrigger> list(TriggerTypes.ListTriggersOptions options)
                                         throws Exception

Specified by:

list in interface TriggerTypes.TriggerManager

Throws:

Exception

fetch

public TriggerTypes.PersistedTrigger fetch(String tag)
                                    throws Exception

Specified by:

fetch in interface TriggerTypes.TriggerManager

Throws:

Exception

update

public TriggerTypes.PersistedTrigger update(String tag,
 TriggerTypes.UpdateTriggerInput input)
                                     throws Exception

Specified by:

update in interface TriggerTypes.TriggerManager

Throws:

Exception

delete

public boolean delete(String tag)
               throws Exception

Specified by:

delete in interface TriggerTypes.TriggerManager

Throws:

Exception