ledger

type CommandCompletion interface {
	CompletionStream(ctx context.Context, req *model.CompletionStreamRequest) (<-chan *model.CompletionStreamResponse, <-chan error)
}

type CommandService interface {
	SubmitAndWait(ctx context.Context, req *model.SubmitAndWaitRequest) (*model.SubmitAndWaitResponse, error)
	// New method added to interface
	SubmitAndWaitForTransaction(ctx context.Context, req *model.SubmitAndWaitRequest) (*model.SubmitAndWaitForTransactionResponse, error)
}

type CommandSubmission interface {
	Submit(ctx context.Context, req *model.SubmitRequest) (*model.SubmitResponse, error)
}

type EventQuery interface {
	GetEventsByContractID(ctx context.Context, req *model.GetEventsByContractIDRequest) (*model.GetEventsByContractIDResponse, error)
}

type InteractiveSubmissionService interface {
	PrepareSubmission(ctx context.Context, req *model.PrepareSubmissionRequest) (*model.PrepareSubmissionResponse, error)
	ExecuteSubmission(ctx context.Context, req *model.ExecuteSubmissionRequest) (*model.ExecuteSubmissionResponse, error)
	GetPreferredPackageVersion(ctx context.Context, req *model.GetPreferredPackageVersionRequest) (*model.GetPreferredPackageVersionResponse, error)
}

type PackageService interface {
	ListPackages(ctx context.Context, req *model.ListPackagesRequest) (*model.ListPackagesResponse, error)
	GetPackage(ctx context.Context, req *model.GetPackageRequest) (*model.GetPackageResponse, error)
	GetPackageStatus(ctx context.Context, req *model.GetPackageStatusRequest) (*model.GetPackageStatusResponse, error)
}

type StateService interface {
	GetActiveContracts(ctx context.Context, req *model.GetActiveContractsRequest) (<-chan *model.GetActiveContractsResponse, <-chan error)
	GetConnectedSynchronizers(ctx context.Context, req *model.GetConnectedSynchronizersRequest) (*model.GetConnectedSynchronizersResponse, error)
	GetLedgerEnd(ctx context.Context, req *model.GetLedgerEndRequest) (*model.GetLedgerEndResponse, error)
	GetLatestPrunedOffsets(ctx context.Context, req *model.GetLatestPrunedOffsetsRequest) (*model.GetLatestPrunedOffsetsResponse, error)
}

type UpdateService interface {
	GetUpdates(ctx context.Context, req *model.GetUpdatesRequest) (<-chan *model.GetUpdatesResponse, <-chan error)
	GetUpdateById(ctx context.Context, req *model.GetUpdateByIDRequest) (*model.GetUpdateResponse, error)
	GetTransactionByID(ctx context.Context, req *model.GetTransactionByIDRequest) (*model.GetTransactionResponse, error)
	GetTransactionByOffset(ctx context.Context, req *model.GetTransactionByOffsetRequest) (*model.GetTransactionResponse, error)
}

type VersionService interface {
	GetLedgerAPIVersion(ctx context.Context, req *model.GetLedgerAPIVersionRequest) (*model.GetLedgerAPIVersionResponse, error)
}