repository

type HealthRepository interface {
	PingPG() error
	PingRedis() error
}

type ThreadRepository interface {
	FindThread(id uuid.UUID) (*entity.Thread, error)
	GetThreads(limit, offset int, visitID uuid.UUID) ([]entity.Thread, error)
	CountThread(visitID uuid.UUID) (int64, error)
	SoftDeleteThread(threadID uuid.UUID) error
	CreateThread(thread entity.Thread) (*entity.Thread, error)
	SetCacheData(ctx context.Context, key string, value []byte) (string, error)
	DeleteCacheData(ctx context.Context, key string) (int64, error)
	GetCacheData(ctx context.Context, key string) (string, error)
}

type UserRepository interface {
	FindUser(id uuid.UUID, email string) (*entity.User, error)
	GetUsers(limit, offset int, key, isAdmin string) ([]entity.User, error)
	CountUser(key, isAdmin string) (int64, error)
	SoftDeleteUser(userID uuid.UUID) error
	CreateUser(user entity.User) (*entity.User, error)
	CountExistingEmail(email string) (int64, error)
	UpdateUser(user entity.User) error
	GetUserMatrix(endpoint string, isAdmin bool) ([]entity.UserMatrix, error)
	SetCacheData(ctx context.Context, key string, value []byte) (string, error)
	DeleteCacheData(ctx context.Context, key string) (int64, error)
	GetCacheData(ctx context.Context, key string) (string, error)
}

type VisitRepository interface {
	FindVisit(id uuid.UUID) (*entity.Visit, error)
	GetVisits(limit, offset int) ([]entity.Visit, error)
	CountVisit() (int64, error)
	SoftDeleteVisit(visitID uuid.UUID) error
	CreateVisit(visit entity.Visit) (*entity.Visit, error)
	SetCacheData(ctx context.Context, key string, value []byte) (string, error)
	DeleteCacheData(ctx context.Context, key string) (int64, error)
	GetCacheData(ctx context.Context, key string) (string, error)
}