Interface: JobStore

Defined in: packages/executor/src/executor.ts:32

@cfxdevkit/executor

On-chain strategy execution engine for Conflux DevKit.

Provides the runtime primitives needed to build keepers, bots, or AI agents that execute on-chain strategies (limit orders, DCA, TWAP, spot swaps).

Key exports:

Job types (LimitOrderJob, DCAJob, TWAPJob, SwapJob) + params
Strategy types (LimitOrderStrategy, DCAStrategy, TWAPStrategy, SwapStrategy)
SafetyGuard — circuit-breaker / swap-cap / retry-cap
RetryQueue — exponential backoff with jitter
PriceChecker — pluggable price source + condition evaluation
KeeperClient interface + KeeperClientImpl (viem / AutomationManager)
Executor — orchestrator that ties all of the above together
AutomationLogger — injectable logger interface (no runtime dep)

Methods

getActiveJobs()

getActiveJobs(): Promise<Job[]>

Defined in: packages/executor/src/executor.ts:33

Returns

Promise<Job[]>

incrementRetry()

incrementRetry(jobId): Promise<void>

Defined in: packages/executor/src/executor.ts:54

Parameters

jobId

string

Returns

Promise<void>

markActive()

markActive(jobId): Promise<void>

Defined in: packages/executor/src/executor.ts:34

Parameters

jobId

string

Returns

Promise<void>

markCancelled()

markCancelled(jobId): Promise<void>

Defined in: packages/executor/src/executor.ts:57

Mark a job cancelled — use when on-chain status is CANCELLED.

Parameters

jobId

string

Returns

Promise<void>

markDCATick()

markDCATick(jobId, txHash, newSwapsCompleted, nextExecution, amountOut?): Promise<void>

Defined in: packages/executor/src/executor.ts:46

Record one completed DCA tick. Updates swapsCompleted + nextExecution in params_json and inserts an execution record. Sets status → ‘executed’ when all swaps are done, otherwise keeps the job ‘active’ so subsequent ticks can run.

Parameters

jobId

string

txHash

string

newSwapsCompleted

number

nextExecution

number

amountOut?

string | null

Returns

Promise<void>

markExecuted()

markExecuted(jobId, txHash, amountOut?): Promise<void>

Defined in: packages/executor/src/executor.ts:35

Parameters

jobId

string

txHash

string

amountOut?

string | null

Returns

Promise<void>

markExpired()

markExpired(jobId): Promise<void>

Defined in: packages/executor/src/executor.ts:55

Parameters

jobId

string

Returns

Promise<void>

markFailed()

markFailed(jobId, error): Promise<void>

Defined in: packages/executor/src/executor.ts:53

Parameters

jobId

string

error

string

Returns

Promise<void>

updateLastError()

updateLastError(jobId, error): Promise<void>

Defined in: packages/executor/src/executor.ts:59

Record the latest error message without changing status or incrementing retries.

Parameters

jobId

string

error

string

Returns

Promise<void>