Introduce endpoint for issued assets and change the way we return uni…

…t of measurement
qubic · May 23, 2024 · d905d9f · d905d9f
1 parent 2f65cd5
commit d905d9f
Show file tree

Hide file tree

Showing 5 changed files with 560 additions and 200 deletions.
diff --git a/foundation/rpc_server/rpc_server.go b/foundation/rpc_server/rpc_server.go
@@ -267,7 +267,6 @@ func (s *Server) Start() error {
 }
 
 func int8ArrayToString(array []int8) string {
-
 	runes := make([]rune, 0)
 
 	for _, char := range array {
@@ -280,6 +279,64 @@ func int8ArrayToString(array []int8) string {
 	return string(runes)
 }
 
+func int8ArrayToInt32Array(array []int8) []int32 {
+	ints := make([]int32, 0)
+
+	for _, smallInt := range array {
+		ints = append(ints, int32(smallInt))
+	}
+	return ints
+}
+
+func (s *Server) GetIssuedAssets(ctx context.Context, req *protobuff.IssuedAssetsRequest) (*protobuff.IssuedAssetsResponse, error) {
+	client, err := s.qPool.Get()
+	if err != nil {
+		return nil, status.Errorf(codes.Internal, "getting pool connection :%v", err)
+	}
+
+	assets, err := client.GetIssuedAssets(ctx, req.Identity)
+	if err != nil {
+		s.qPool.Close(client)
+		return nil, status.Errorf(codes.Internal, "getting issued assets from node %v", err)
+	}
+
+	s.qPool.Put(client)
+
+	issuedAssets := make([]*protobuff.IssuedAsset, 0)
+
+	for _, asset := range assets {
+
+		iAsset := asset.Data
+		var iAssetIdentity types.Identity
+		iAssetIdentity, err = iAssetIdentity.FromPubKey(iAsset.PublicKey, false)
+		if err != nil {
+			return nil, errors.Wrap(err, "failed to get identity for issued asset public key")
+		}
+
+		data := protobuff.IssuedAssetData{
+			IssuerIdentity:        iAssetIdentity.String(),
+			Type:                  uint32(iAsset.Type),
+			Name:                  int8ArrayToString(iAsset.Name[:]),
+			NumberOfDecimalPlaces: int32(iAsset.NumberOfDecimalPlaces),
+			UnitOfMeasurement:     int8ArrayToInt32Array(iAsset.UnitOfMeasurement[:]),
+		}
+
+		info := protobuff.AssetInfo{
+			Tick:          asset.Info.Tick,
+			UniverseIndex: asset.Info.UniverseIndex,
+		}
+
+		issuedAsset := protobuff.IssuedAsset{
+			Data: &data,
+			Info: &info,
+		}
+
+		issuedAssets = append(issuedAssets, &issuedAsset)
+	}
+
+	return &protobuff.IssuedAssetsResponse{IssuedAssets: issuedAssets}, nil
+}
+
 func (s *Server) GetOwnedAssets(ctx context.Context, req *protobuff.OwnedAssetsRequest) (*protobuff.OwnedAssetsResponse, error) {
 	client, err := s.qPool.Get()
 	if err != nil {
@@ -311,7 +368,7 @@ func (s *Server) GetOwnedAssets(ctx context.Context, req *protobuff.OwnedAssetsR
 			Type:                  uint32(iAsset.Type),
 			Name:                  int8ArrayToString(iAsset.Name[:]),
 			NumberOfDecimalPlaces: int32(iAsset.NumberOfDecimalPlaces),
-			UnitOfMeasurement:     int8ArrayToString(iAsset.UnitOfMeasurement[:]),
+			UnitOfMeasurement:     int8ArrayToInt32Array(iAsset.UnitOfMeasurement[:]),
 		}
 
 		var oAssetIdentity types.Identity
@@ -384,7 +441,7 @@ func (s *Server) GetPossessedAssets(ctx context.Context, req *protobuff.Possesse
 			Type:                  uint32(iAsset.Type),
 			Name:                  int8ArrayToString(iAsset.Name[:]),
 			NumberOfDecimalPlaces: int32(iAsset.NumberOfDecimalPlaces),
-			UnitOfMeasurement:     int8ArrayToString(iAsset.UnitOfMeasurement[:]),
+			UnitOfMeasurement:     int8ArrayToInt32Array(iAsset.UnitOfMeasurement[:]),
 		}
 
 		ownedAsset := protobuff.OwnedAssetData{