feat(api): provide flag if user has v1 specific notifications

Author: LuccaBitfly

backend/pkg/api/data_access/notifications.go

@@ -2112,3 +2112,20 @@ func (d *DataAccessService) QueueTestPushNotification(ctx context.Context, userI
 func (d *DataAccessService) QueueTestWebhookNotification(ctx context.Context, userId uint64, webhookUrl string, isDiscordWebhook bool) error {
 	return notification.SendTestWebhookNotification(ctx, types.UserId(userId), webhookUrl, isDiscordWebhook)
 }
+
+// hasUserV1NotificationSubscriptions checks if a user has any v1 notification subscriptions.
+// Since some notification events are indistinguishable from v1 and v2, only validator-related that are not v2 are checked.
+func (d *DataAccessService) hasUserV1NotificationSubscriptions(ctx context.Context, userId uint64) (bool, error) {
+	now := time.Now()
+	ds := goqu.Dialect("postgres").
+		Select(goqu.COUNT(goqu.I("id"))).
+		From(goqu.T("users_subscriptions")).
+		Where(
+			goqu.I("user_id").Eq(userId),
+			goqu.I("event_name").Like("validator%"),
+			goqu.I("event_filter").NotLike("vdb:%"),
+		)
+	count, err := runQuery[int](ctx, d.userReader, ds)
+	log.Info("time it took", time.Since(now))
+	return count > 0, err
+}

backend/pkg/api/data_access/user.go

@@ -289,7 +289,33 @@ func (d *DataAccessService) GetUserIdByResetHash(ctx context.Context, hash strin
 }
 
 func (d *DataAccessService) GetUserInfo(ctx context.Context, userId uint64) (*t.UserInfo, error) {
-	return db.GetUserInfo(ctx, userId, d.userReader)
+	wg := errgroup.Group{}
+
+	var userInfo *t.UserInfo
+	wg.Go(func() error {
+		var err error
+		userInfo, err = db.GetUserInfo(ctx, userId, d.userReader)
+		if err != nil {
+			err = fmt.Errorf("error retrieving user info: %w", err)
+		}
+		return err
+	})
+
+	var hasV1Notifications bool
+	wg.Go(func() error {
+		var err error
+		hasV1Notifications, err = d.hasUserV1NotificationSubscriptions(ctx, userId)
+		if err != nil {
+			return fmt.Errorf("error retrieving if user has v1 notifications: %w", err)
+		}
+		return nil
+	})
+	err := wg.Wait()
+	if userInfo != nil {
+		userInfo.HasV1Notifications = hasV1Notifications
+	}
+
+	return userInfo, err
 }
 
 func (d *DataAccessService) GetProductSummary(ctx context.Context) (*t.ProductSummary, error) {

backend/pkg/api/types/user.go

@@ -6,13 +6,14 @@ const UserGroupAdmin = "ADMIN"
 const UserGroupDev = "DEV"
 
 type UserInfo struct {
-	Id            uint64             `json:"id"`
-	UserGroup     string             `json:"-"`
-	Email         string             `json:"email"`
-	ApiKeys       []string           `json:"api_keys"`
-	ApiPerks      ApiPerks           `json:"api_perks"`
-	PremiumPerks  PremiumPerks       `json:"premium_perks"`
-	Subscriptions []UserSubscription `json:"subscriptions"`
+	Id                 uint64             `json:"id"`
+	UserGroup          string             `json:"-"`
+	Email              string             `json:"email"`
+	ApiKeys            []string           `json:"api_keys"`
+	ApiPerks           ApiPerks           `json:"api_perks"`
+	PremiumPerks       PremiumPerks       `json:"premium_perks"`
+	Subscriptions      []UserSubscription `json:"subscriptions"`
+	HasV1Notifications bool               `json:"has_v1_notifications"`
 }
 
 type UserSubscription struct {

frontend/types/api/user.ts

@@ -14,6 +14,7 @@ export interface UserInfo {
   api_perks: ApiPerks;
   premium_perks: PremiumPerks;
   subscriptions: UserSubscription[];
+  has_v1_notifications: boolean;
 }
 export interface UserSubscription {
   product_id: string;