feat: Integrate Bitget for Rate Fetching & Median Calculation Across Multiple Providers

.env.example

@@ -4,12 +4,12 @@ DEBUG=True
 ALLOWED_HOSTS=0.0.0.0
 SERVER_HOST=0.0.0.0
 SERVER_PORT=8000
+SERVER_URL=http://localhost:8000
 JWT_ACCESS_LIFESPAN=15
 JWT_REFRESH_LIFESPAN=10080
 HMAC_TIMESTAMP_AGE=5
 ENVIRONMENT=local # local, staging, production
 SENTRY_DSN=
-HOST_DOMAIN=http://localhost:8000
 
 # Database Config
 DB_NAME=paycrest

.github/workflows/atlas-migrate.yml

@@ -0,0 +1,25 @@
+name: Atlas Database Migrations
+
+on:
+  push:
+    branches:
+      - main
+      - stable
+
+jobs:
+  migrate:
+    runs-on: ubuntu-latest
+    environment: ${{ github.ref == 'refs/heads/main' && 'staging' || 'production' }}
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Install Atlas
+        run: |
+          curl -sSf https://atlasgo.sh | sh
+          echo "$HOME/.atlas/bin" >> $GITHUB_PATH
+
+      - name: Run Migrations
+        run: |
+          atlas migrate apply \
+            --dir "file://ent/migrate/migrations" \
+            --url "${{ secrets.DB_URL }}" 

README.md

@@ -50,14 +50,14 @@ docker-compose up -d
 chmod +x scripts/import_db.sh
 
 # run the script to seed db with sample configured sender & provider profile
-./scripts/import_db.sh
+./scripts/import_db.sh -h localhost
 ```
 
 3. Run our sandbox provision node and connect it to your local aggregator by following the [instructions here](https://paycrest.notion.site/run-sandbox-provision-node)
 
 Here, we’d make use of a demo provision node and connect it to our local aggregator
 
-That's it! The server will now be running at http://localhost:8000. You can use an API testing tool like Postman or cURL to interact with the API.
+That's it! The server will now be running at http://localhost:8000. You can use an API testing tool like Postman or cURL to interact with the Sender API using the sandbox API Key `11f93de0-d304-4498-8b7b-6cecbc5b2dd8`.
 
 
 ## Usage

config/config.go

@@ -21,6 +21,8 @@ type Configuration struct {
 func SetupConfig() error {
 	var configuration *Configuration
 
+	viper.AddConfigPath("../../../..")
+	viper.AddConfigPath("../../..")
 	viper.AddConfigPath("../..")
 	viper.AddConfigPath("..")
 	viper.AddConfigPath(".")

config/server.go

@@ -15,7 +15,7 @@ type ServerConfiguration struct {
 	AllowedHosts             string
 	Environment              string
 	SentryDSN                string
-	HostDomain               string
+	ServerURL                string
 	RateLimitUnauthenticated int
 	RateLimitAuthenticated   int
 	SlackWebhookURL          string
@@ -33,6 +33,7 @@ func ServerConfig() *ServerConfiguration {
 	viper.SetDefault("RATE_LIMIT_UNAUTHENTICATED", 5)
 	viper.SetDefault("RATE_LIMIT_AUTHENTICATED", 100)
 	viper.SetDefault("SLACK_WEBHOOK_URL", "")
+	viper.SetDefault("SERVER_URL", "")
 
 	return &ServerConfiguration{
 		Debug:                    viper.GetBool("DEBUG"),
@@ -42,7 +43,7 @@ func ServerConfig() *ServerConfiguration {
 		AllowedHosts:             viper.GetString("ALLOWED_HOSTS"),
 		Environment:              viper.GetString("ENVIRONMENT"),
 		SentryDSN:                viper.GetString("SENTRY_DSN"),
-		HostDomain:               viper.GetString("HOST_DOMAIN"),
+		ServerURL:                viper.GetString("SERVER_URL"),
 		RateLimitUnauthenticated: viper.GetInt("RATE_LIMIT_UNAUTHENTICATED"),
 		RateLimitAuthenticated:   viper.GetInt("RATE_LIMIT_AUTHENTICATED"),
 		SlackWebhookURL:          viper.GetString("SLACK_WEBHOOK_URL"),

controllers/accounts/auth.go

@@ -58,7 +58,7 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 
 	tx, err := db.Client.Tx(ctx)
 	if err != nil {
-		logger.Errorf("error: %v", err)
+		logger.Errorf("Error: Failed to create new user: %v", err)
 		u.APIResponse(ctx, http.StatusInternalServerError, "error",
 			"Failed to create new user", nil)
 		return
@@ -99,7 +99,7 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 	user, err := userCreate.Save(ctx)
 	if err != nil {
 		_ = tx.Rollback()
-		logger.Errorf("error: %v", err)
+		logger.Errorf("Error: Failed to save new user: %v", err)
 		u.APIResponse(ctx, http.StatusInternalServerError, "error",
 			"Failed to create new user", nil)
 		return
@@ -113,13 +113,16 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 		SetExpiryAt(time.Now().Add(authConf.PasswordResetLifespan)).
 		Save(ctx)
 	if err != nil {
-		logger.Errorf("error: %v", err)
+		logger.Errorf("Error: Failed to create verification token: %v", err)
 	}
 
 	if serverConf.Environment == "production" {
 		if verificationToken != nil {
 			if _, err := ctrl.emailService.SendVerificationEmail(ctx, verificationToken.Token, user.Email, user.FirstName); err != nil {
-				logger.Errorf("error: %v", err)
+				logger.WithFields(logger.Fields{
+					"Error": fmt.Sprintf("%v", err),
+					"UserID": user.ID,
+				}).Errorf("Failed to send verification email")
 			}
 		}
 	}
@@ -180,7 +183,10 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 			Save(ctx)
 		if err != nil {
 			_ = tx.Rollback()
-			logger.Errorf("error: %v", err)
+			logger.WithFields(logger.Fields{
+				"Error": fmt.Sprintf("%v", err),
+				"UserID": user.ID,
+			}).Errorf("Failed to create provider profile")
 			u.APIResponse(ctx, http.StatusInternalServerError, "error",
 				"Failed to create new user", nil)
 			return
@@ -190,7 +196,11 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 		_, _, err = ctrl.apiKeyService.GenerateAPIKey(ctx, tx, nil, provider)
 		if err != nil {
 			_ = tx.Rollback()
-			logger.Errorf("error: %v", err)
+			logger.WithFields(logger.Fields{
+				"Error": fmt.Sprintf("%v", err),
+				"UserID": user.ID,
+				"ProviderID": provider.ID,
+			}).Errorf("Failed to create API key for provider")
 			u.APIResponse(ctx, http.StatusInternalServerError, "error",
 				"Failed to create new user", nil)
 			return
@@ -205,7 +215,10 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 			Save(ctx)
 		if err != nil {
 			_ = tx.Rollback()
-			logger.Errorf("error: %v", err)
+			logger.WithFields(logger.Fields{
+				"Error": fmt.Sprintf("%v", err),
+				"UserID": user.ID,
+			}).Errorf("Failed to create sender profile")
 			u.APIResponse(ctx, http.StatusInternalServerError, "error",
 				"Failed to create new user", nil)
 			return
@@ -215,15 +228,19 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 		_, _, err = ctrl.apiKeyService.GenerateAPIKey(ctx, tx, sender, nil)
 		if err != nil {
 			_ = tx.Rollback()
-			logger.Errorf("error: %v", err)
+			logger.WithFields(logger.Fields{
+				"Error": fmt.Sprintf("%v", err),
+				"UserID": user.ID,
+				"SenderID": sender.ID,
+			}).Errorf("Failed to create API key for sender")
 			u.APIResponse(ctx, http.StatusInternalServerError, "error",
 				"Failed to create new user", nil)
 			return
 		}
 	}
 
 	if err := tx.Commit(); err != nil {
-		logger.Errorf("error: %v", err)
+		logger.Errorf("Error: Failed to commit transaction: %v", err)
 		u.APIResponse(ctx, http.StatusInternalServerError, "error",
 			"Failed to create new user", nil)
 		return
@@ -246,7 +263,7 @@ func (ctrl *AuthController) Register(ctx *gin.Context) {
 	// Send Slack notification
 	if serverConf.Environment == "production" {
 		if err := ctrl.slackService.SendUserSignupNotification(user, scopes, providerCurrencies); err != nil {
-			logger.Errorf("failed to send Slack notification: %v", err)
+			logger.Errorf("Failed to send Slack notification: %v", err)
 		}
 	}
 }
@@ -296,7 +313,7 @@ func (ctrl *AuthController) Login(ctx *gin.Context) {
 	accessToken, refreshToken, err := token.GeneratePairJWT(user.ID.String(), user.Scope)
 
 	if err != nil {
-		logger.Errorf("error: %v", err)
+		logger.Errorf("Error : Failed to create token pair during login: %v", err)
 		u.APIResponse(ctx, http.StatusInternalServerError, "error",
 			"Failed to create token pair", nil,
 		)