contract

type Connection interface {
	SetNext(connection Connection)
	CountByUsername(ctx context.Context, username string) (int, error)
	Count(ctx context.Context) (int, error)
}

type DeviceRepository interface {
	Save(ctx context.Context, device *entity.Device) error
	Exists(ctx context.Context, device *entity.Device) bool
	DeleteByUsername(ctx context.Context, username string) error
	CountByUsername(ctx context.Context, username string) (int, error)
	ListByUsername(ctx context.Context, username string) ([]*entity.Device, error)
	ListAll(ctx context.Context) ([]*entity.Device, error)
}

type Executor interface {
	Execute(ctx context.Context, command string) (string, error)
}

type UserCacheService interface {
	Set(value *entity.User, ttl time.Duration)
	Get(username string) (*entity.User, bool)
}

type UserDAO interface {
	FindByUsername(ctx context.Context, username string) (*entity.User, error)
}

type UserRepository interface {
	FindByUsername(ctx context.Context, username string) (*entity.User, error)
}