fix(ccaas): return query payloads and align grpcio 1.83.1

Signed-off-by: kmilo <kmilo.denis.glez@yandex.com>

Author: kmilodenisglez

README.md

@@ -11,7 +11,7 @@ Requirements
 ------------
 - Python 3.10+ (3.11 recommended)
 - See `requirements.txt` for runtime dependencies. Key packages:
-	- `grpcio==1.51.3`
+	- `grpcio==1.83.1`
 	- `protobuf>=7.35.1`
 	- `grpclib==0.4.3`
 

examples/ccaas/asset-transfer-basic/README.md

@@ -28,7 +28,6 @@ cd /path/to/fabric-chaincode-python
 python3 -m venv .venv
 source .venv/bin/activate
 pip install -r requirements.txt
-pip install "grpcio>=1.83.1"
 ```
 
 ### 2. Package the Chaincode
@@ -94,14 +93,18 @@ source .venv/bin/activate
 cd /path/to/test-network-nano-bash
 . ./peer1admin.sh
 PACKAGE_ID=$(peer lifecycle chaincode queryinstalled --output json | \
-  jq -r '.installed_chaincodes[] | select(.references.mychannel? != null) | \
-  select(.references.mychannel.chaincodes[]? .name=="basic") | .package_id')
+  jq -r '
+  .installed_chaincodes[]
+  | select(.references.mychannel? != null)
+  | select(any(.references.mychannel.chaincodes[]?; .name == "basic"))
+  | .package_id
+  ')
 
 # Start the server
 cd /path/to/fabric-chaincode-python
 export CHAINCODE_ID="$PACKAGE_ID"
 export CHAINCODE_SERVER_ADDRESS=127.0.0.1:9999
-python examples/ccaas/asset-transfer-basic/main.py
+./.venv/bin/python examples/ccaas/asset-transfer-basic/main.py
 ```
 
 ### 6. Invoke & Query
@@ -183,7 +186,8 @@ Tells Fabric that this is a CCAAS package:
 ### Server won't start
 - Ensure `CHAINCODE_ID` matches the package-id from `peer lifecycle chaincode install`
 - Check that `connection.json` address is accessible from the peer
-- Verify gRPC is installed: `pip install "grpcio>=1.83.1"`
+- Verify dependencies are installed: `pip install -r requirements.txt`
+- Verify you're using the project venv: `./.venv/bin/python -c "import grpc; print(grpc.__version__)"`
 
 ### Peer can't reach chaincode
 - Check firewall rules allowing port 9999

examples/ccaas/asset-transfer-basic/main.py

@@ -78,7 +78,9 @@ async def invoke(self, stub: ChaincodeStubInterface) -> pb.Response:
                 return pb.Response(status=ResponseCode.ERROR, message="ReadAsset requires 1 argument")
             asset_id = inputs[0]
             result = await self.read_asset(stub, asset_id)
-            return pb.Response(status=ResponseCode.OK, message=result)
+            if not result:
+                return pb.Response(status=ResponseCode.ERROR, message=f"Asset {asset_id} does not exist")
+            return pb.Response(status=ResponseCode.OK, payload=result)
 
         elif action == "DeleteAsset":
             if len(inputs) < 1:
@@ -89,7 +91,7 @@ async def invoke(self, stub: ChaincodeStubInterface) -> pb.Response:
 
         elif action == "GetAllAssets":
             results = await self.get_all_assets(stub)
-            return pb.Response(status=ResponseCode.OK, message=results)
+            return pb.Response(status=ResponseCode.OK, payload=results.encode())
 
         else:
             return pb.Response(status=ResponseCode.ERROR, message=f"Unknown function: {action}")

examples/ccaas/asset-transfer-sbe/README.md

@@ -55,7 +55,6 @@ pip install -r requirements.txt
 export CHAINCODE_ID=asset_transfer_sbe_1:<package_hash>
 export CHAINCODE_SERVER_ADDRESS=127.0.0.1:9999
 
-cd examples/ccaas/asset-transfer-sbe
 python main.py
 ```
 

examples/ccaas/asset-transfer-sbe/main.py

@@ -61,7 +61,7 @@ async def invoke(self, stub: ChaincodeStubInterface) -> pb.Response:
                 if len(args) != 1:
                     return self._error("AssetExists requires 1 argument: assetId")
                 exists = await self.asset_exists(stub, args[0])
-                return pb.Response(status=ResponseCode.OK, message=str(exists).lower())
+                return pb.Response(status=ResponseCode.OK, payload=str(exists).lower().encode())
 
             if fn == "InitLedger":
                 return await self.init_ledger(stub)
@@ -100,7 +100,7 @@ async def read_asset(self, stub: ChaincodeStubInterface, asset_id: str) -> pb.Re
         asset_bytes = await stub.get_state(asset_id)
         if not asset_bytes:
             return self._error(f"The asset {asset_id} does not exist")
-        return pb.Response(status=ResponseCode.OK, message=asset_bytes.decode())
+        return pb.Response(status=ResponseCode.OK, payload=asset_bytes)
 
     async def update_asset(self, stub: ChaincodeStubInterface, asset_id: str, new_value: str) -> pb.Response:
         asset_data = await stub.get_state(asset_id)

pyproject.toml

@@ -10,7 +10,7 @@ readme = "README.md"
 license = {text = "Apache License v2.0"}
 requires-python = ">=3.10"
 dependencies = [
-    "grpcio>=1.51.3",
+    "grpcio>=1.83.1",
     "grpclib>=0.4.3",
     "protobuf>=7.35.1"
 ]

requirements.txt

@@ -1,3 +1,3 @@
-grpcio==1.51.3
+grpcio==1.83.1
 grpclib==0.4.3
 protobuf>=7.35.1