refactor: add more queries for stake concentration

database/sqlc/queries/stake_concentration.sql

@@ -51,3 +51,12 @@ WHERE a.stock_id = $1 AND a.exchange_date <= $2
 ORDER BY a.exchange_date DESC
 LIMIT 60;
 
+-- name: HasStakeConcentration :one
+SELECT EXISTS (
+    SELECT 1 FROM stake_concentration
+    WHERE exchange_date = $1
+);
+
+-- name: GetStakeConcentrationLatestDataPoint :one
+SELECT exchange_date FROM stake_concentration
+ORDER BY exchange_date DESC LIMIT 1;

internal/app/adapter/adapter.go

@@ -37,6 +37,8 @@ type Adapter interface {
 		ctx context.Context,
 		stockID, date string,
 	) ([]*domain.CalculationBase, error)
+	HasStakeConcentration(ctx context.Context, exchangeDate string) (bool, error)
+	GetStakeConcentrationLatestDataPoint(ctx context.Context) (string, error)
 	CreatePickedStock(ctx context.Context, userID uuid.UUID, stockID string) error
 	DeletePickedStock(ctx context.Context, userID uuid.UUID, stockID string) error
 	ListPickedStocks(ctx context.Context, userID uuid.UUID) (*[]domain.PickedStock, error)
@@ -140,6 +142,14 @@ func (a *Imp) GetStakeConcentrationsWithVolumes(
 	return a.repo.GetStakeConcentrationsWithVolumes(ctx, stockID, date)
 }
 
+func (a *Imp) HasStakeConcentration(ctx context.Context, exchangeDate string) (bool, error) {
+	return a.repo.HasStakeConcentration(ctx, exchangeDate)
+}
+
+func (a *Imp) GetStakeConcentrationLatestDataPoint(ctx context.Context) (string, error) {
+	return a.repo.GetStakeConcentrationLatestDataPoint(ctx)
+}
+
 func (a *Imp) CreatePickedStock(
 	ctx context.Context,
 	userID uuid.UUID,

internal/app/adapter/sqlc/stake_concentration.go

@@ -47,6 +47,20 @@ func (repo *Repo) GetStakeConcentrationsWithVolumes(
 	return toDomainCalculationBaseList(result), nil
 }
 
+func (repo *Repo) HasStakeConcentration(ctx context.Context, exchangeDate string) (bool, error) {
+	return repo.primary().HasStakeConcentration(ctx, exchangeDate)
+}
+
+func (repo *Repo) GetStakeConcentrationLatestDataPoint(
+	ctx context.Context,
+) (string, error) {
+	exchangeDate, err := repo.primary().GetStakeConcentrationLatestDataPoint(ctx)
+	if err != nil {
+		return "", err
+	}
+	return exchangeDate, nil
+}
+
 func toSqlcBatchUpsertStakeConcentrationParams(
 	stakeConcentrations []*domain.StakeConcentration,
 ) *sqlcdb.BatchUpsertStakeConcentrationParams {