cmd

type AuthCommand struct{}

type ChAccCmdService struct{}

type ChAccCmdServiceInterface interface {
	ViewChannelAccounts(ctx context.Context, dbConnectionPool db.DBConnectionPool) error
	CreateChannelAccounts(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, count int) error
	EnsureChannelAccountsCount(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, count int) error
	DeleteChannelAccount(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, opts txSubSvc.DeleteChannelAccountsOptions) error
	VerifyChannelAccounts(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, deleteInvalidAccounts bool) error
}

type ChannelAccountsCommand struct {
	// Shared:
	CrashTrackerClient  crashtracker.CrashTrackerClient
	TSSDBConnectionPool db.DBConnectionPool
	DistAccResolver     signing.DistributionAccountResolver
}

type DefaultTenantConfig struct {
	DefaultTenantOwnerEmail              string
	DefaultTenantOwnerFirstName          string
	DefaultTenantOwnerLastName           string
	DefaultTenantDistributionAccountType string
	DistributionPublicKey                string
}

type DistAccCmdService struct{}

type DistAccCmdServiceInterface interface {
	RotateDistributionAccount(ctx context.Context, distAccService DistributionAccountService) error
}

type DistributionAccountCommand struct {
	CrashTrackerClient    crashtracker.CrashTrackerClient
	TSSDBConnectionPool   db.DBConnectionPool
	DistAccResolver       signing.DistributionAccountResolver
	AdminDBConnectionPool db.DBConnectionPool
}

type DistributionAccountService struct {
	// contains filtered or unexported fields
}

type IntegrationTestsCommand struct {
	Service integrationtests.IntegrationTestsInterface
}

type MessageCommand struct{}

type MessengerService struct{}

type MessengerServiceInterface interface {
	GetClient(opts message.MessengerOptions) (message.MessengerClient, error)
	SendMessage(ctx context.Context, opts message.MessengerOptions, message message.Message) error
}

type MockDistAccCmdServiceInterface struct {
	mock.Mock
}

type ServeCommand struct{}

type ServerService struct{}

type ServerServiceInterface interface {
	StartServe(opts serve.ServeOptions, httpServer serve.HTTPServerInterface)
	StartMetricsServe(opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface)
	StartAdminServe(opts serveadmin.ServeOptions, httpServer serveadmin.HTTPServerInterface)
	GetSchedulerJobRegistrars(ctx context.Context,
		serveOpts serve.ServeOptions,
		schedulerOptions scheduler.SchedulerOptions,
		apAPIService anchorplatform.AnchorPlatformAPIServiceInterface,
		tssDBConnectionPool db.DBConnectionPool) ([]scheduler.SchedulerJobRegisterOption, error)
	SetupConsumers(ctx context.Context, o SetupConsumersOptions) error
}

type SetupConsumersOptions struct {
	EventBrokerOptions  cmdUtils.EventBrokerOptions
	ServeOpts           serve.ServeOptions
	TSSDBConnectionPool db.DBConnectionPool
}

type TenantsCommand struct{}

type TenantsService interface {
	EnsureDefaultTenant(ctx context.Context, cfg DefaultTenantConfig, opts cmdUtils.GlobalOptionsType) error
}

type TxSubmitterCommand struct{}

type TxSubmitterService struct{}

type TxSubmitterServiceInterface interface {
	StartSubmitter(context.Context, txSub.SubmitterOptions)
	StartMetricsServe(ctx context.Context, opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface, crashTrackerClient crashtracker.CrashTrackerClient)
}