txcommon

type BatchPinData struct {
	Batch      *core.BatchPersisted `json:"batch"`
	Contexts   []*fftypes.Bytes32   `json:"contexts"`
	PayloadRef string               `json:"payloadRef"`
}

type BatchedTransactionInsert struct {
	Input  TransactionInsertInput
	Output struct {
		IdempotencyError error
		Transaction      *core.Transaction
	}
}

type BlockchainInvokeData struct {
	Request  *core.ContractCallRequest `json:"request"`
	BatchPin *BatchPinData             `json:"batchPin"`
}

type Helper interface {
	SubmitNewTransaction(ctx context.Context, txType core.TransactionType, idempotencyKey core.IdempotencyKey) (*fftypes.UUID, error)
	SubmitNewTransactionBatch(ctx context.Context, namespace string, batch []*BatchedTransactionInsert) error
	PersistTransaction(ctx context.Context, id *fftypes.UUID, txType core.TransactionType, blockchainTXID string) (valid bool, err error)
	AddBlockchainTX(ctx context.Context, tx *core.Transaction, blockchainTXID string) error
	InsertOrGetBlockchainEvent(ctx context.Context, event *core.BlockchainEvent) (existing *core.BlockchainEvent, err error)
	InsertNewBlockchainEvents(ctx context.Context, events []*core.BlockchainEvent) (inserted []*core.BlockchainEvent, err error)
	GetTransactionByIDCached(ctx context.Context, id *fftypes.UUID) (*core.Transaction, error)
	GetBlockchainEventByIDCached(ctx context.Context, id *fftypes.UUID) (*core.BlockchainEvent, error)
	FindOperationInTransaction(ctx context.Context, tx *fftypes.UUID, opType core.OpType) (*core.Operation, error)
}

type TransactionInsertInput struct {
	Type           core.TransactionType
	IdempotencyKey core.IdempotencyKey
}