🎨 Improve the Id request messages

CheesecakeLabs · Nov 1, 2023 · ed05036 · ed05036
1 parent 7fb67cb
commit ed05036
Show file tree

Hide file tree

Showing 3 changed files with 31 additions and 7 deletions.
diff --git a/backend/internal/controller/http/v1/assets.go b/backend/internal/controller/http/v1/assets.go
@@ -217,13 +217,15 @@ func (r *assetsRoutes) createAsset(c *gin.Context) {
 		})
 	}
 
+	Id := generateID()
 	_, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: sponsor.Key.PublicKey,
 		PublicKeys: []string{sponsor.Key.PublicKey, distPk, issuerPk},
 		Operations: ops,
 	})
 	if err != nil {
-		r.logger.Error(err, "http - v1 - create asset - send message")
+		r.logger.Error(err, fmt.Sprintf("http - v1 - create asset - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 	}
@@ -376,13 +378,15 @@ func (r *assetsRoutes) mintAsset(c *gin.Context) {
 			Origin: asset.Issuer.Key.PublicKey,
 		},
 	}
+	Id := generateID()
 	_, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: asset.Issuer.Key.PublicKey,
 		PublicKeys: []string{asset.Issuer.Key.PublicKey},
 		Operations: ops,
 	})
 	if err != nil {
-		r.logger.Error(err, "http - v1 - mint asset - send message")
+		r.logger.Error(err, fmt.Sprintf("http - v1 - mint asset - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 	}
@@ -474,12 +478,15 @@ func (r *assetsRoutes) burnAsset(c *gin.Context) {
 		},
 	}
 
+	Id := generateID()
 	_, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: asset.Distributor.Key.PublicKey,
 		PublicKeys: []string{asset.Distributor.Key.PublicKey},
 		Operations: ops,
 	})
 	if err != nil {
+		r.logger.Error(err, fmt.Sprintf("http - v1 - burn asset - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 
@@ -580,13 +587,15 @@ func (r *assetsRoutes) transferAsset(c *gin.Context) {
 		},
 	}
 
+	Id := generateID()
 	_, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: sourceWallet.Key.PublicKey,
 		PublicKeys: []string{sourceWallet.Key.PublicKey},
 		Operations: ops,
 	})
 	if err != nil {
-		r.logger.Error(err, "http - v1 - transfer asset - send message")
+		r.logger.Error(err, fmt.Sprintf("http - v1 - transfer asset - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 	}
@@ -684,13 +693,15 @@ func (r *assetsRoutes) clawbackAsset(c *gin.Context) {
 		},
 	}
 
+	Id := generateID()
 	_, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: sponsor.Key.PublicKey,
 		PublicKeys: []string{asset.Issuer.Key.PublicKey, sponsor.Key.PublicKey},
 		Operations: ops,
 	})
 	if err != nil {
-		r.logger.Error(err, "http - v1 - clawback asset - send message")
+		r.logger.Error(err, fmt.Sprintf("http - v1 - clawback asset - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 	}
@@ -789,13 +800,15 @@ func (r *assetsRoutes) updateAuthFlags(c *gin.Context) {
 		return
 	}
 
+	Id := generateID()
 	_, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: sponsor.Key.PublicKey,
 		PublicKeys: []string{asset.Issuer.Key.PublicKey, sponsor.Key.PublicKey},
 		Operations: []entity.Operation{op},
 	})
 	if err != nil {
-		r.logger.Error(err, "http - v1 - update auth flags - send message")
+		r.logger.Error(err, fmt.Sprintf("http - v1 - update auth flags- send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 

diff --git a/backend/internal/controller/http/v1/utils.go b/backend/internal/controller/http/v1/utils.go
@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"strings"
+	"time"
 
 	"github.com/CheesecakeLabs/token-factory-v2/backend/internal/entity"
 	"github.com/bitly/go-notify"
@@ -109,3 +110,9 @@ func createLogDescription(transaction int, assetCode string, setFlags, clearFlag
 		return "Unrecognized transaction type"
 	}
 }
+
+// Generate ID
+func generateID() int {
+	currentTimeInMillis := int(time.Now().UnixNano() / int64(time.Millisecond))
+	return currentTimeInMillis
+}
diff --git a/backend/internal/controller/http/v1/vault.go b/backend/internal/controller/http/v1/vault.go
@@ -135,13 +135,15 @@ func (r *vaultRoutes) createVault(c *gin.Context) {
 		})
 	}
 
+	Id := generateID()
 	res, err = r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: sponsor.Key.PublicKey,
 		PublicKeys: []string{sponsor.Key.PublicKey, walletPk},
 		Operations: ops,
 	})
 	if err != nil {
-		r.l.Error(err, "http - v1 - create vault - SendMessage")
+		r.l.Error(err, fmt.Sprintf("http - v1 - create vault - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 	}
@@ -352,13 +354,15 @@ func (r *vaultRoutes) updateVaultAsset(c *gin.Context) {
 		}
 	}
 
+	Id := generateID()
 	res, err := r.m.SendMessage(entity.EnvelopeChannel, entity.EnvelopeRequest{
+		Id:         Id,
 		MainSource: sponsor.Key.PublicKey,
 		PublicKeys: []string{sponsor.Key.PublicKey, vault.Wallet.Key.PublicKey},
 		Operations: ops,
 	})
 	if err != nil {
-		r.l.Error(err, "http - v1 - update vault asset - SendMessage")
+		r.l.Error(err, fmt.Sprintf("http - v1 - update vault - send message %d", Id))
 		errorResponse(c, http.StatusInternalServerError, "starlabs messaging problems", err)
 		return
 	}