chore(userservice): report status on app_subscriptions_check and stri…

…pe_email_updater
gobitfly · Sep 26, 2024 · 4f17f95 · 4f17f95
1 parent 115bf7f
commit 4f17f95
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/backend/pkg/userservice/appsubscription_oracle.go b/backend/pkg/userservice/appsubscription_oracle.go
@@ -12,6 +12,7 @@ import (
 	"github.com/gobitfly/beaconchain/pkg/commons/db"
 	"github.com/gobitfly/beaconchain/pkg/commons/log"
 	"github.com/gobitfly/beaconchain/pkg/commons/metrics"
+	"github.com/gobitfly/beaconchain/pkg/commons/services"
 	"github.com/gobitfly/beaconchain/pkg/commons/types"
 	"github.com/gobitfly/beaconchain/pkg/commons/utils"
 
@@ -93,6 +94,8 @@ func CheckMobileSubscriptions() {
 			updateValidationState(receipt, valid)
 		}
 
+		services.ReportStatus("app_subscriptions_check", "Running", nil)
+
 		log.InfoWithFields(log.Fields{"subscriptions": len(receipts), "duration": time.Since(start)}, "subscription update completed")
 		time.Sleep(time.Hour * 4)
 	}

diff --git a/backend/pkg/userservice/stripe_email_updater.go b/backend/pkg/userservice/stripe_email_updater.go
@@ -10,6 +10,7 @@ import (
 
 	"github.com/gobitfly/beaconchain/pkg/commons/db"
 	"github.com/gobitfly/beaconchain/pkg/commons/log"
+	"github.com/gobitfly/beaconchain/pkg/commons/services"
 	"github.com/gobitfly/beaconchain/pkg/commons/utils"
 	"github.com/lib/pq"
 )
@@ -50,6 +51,8 @@ func StripeEmailUpdater() {
 			}
 		}
 
+		services.ReportStatus("stripe_email_updater", "Running", nil)
+
 		time.Sleep(time.Minute)
 	}
 }