Fix: vm-connector used obsolete software

The vm-connector service used to run with obsolete versions of the aleph-sdk and Python.

Solution: Use the latest the version of the SDK and pin the version of dependencies.

Author: hoh

.github/workflows/test-new-runtime-examples.yml

@@ -79,7 +79,7 @@ jobs:
           ssh root@${DROPLET_IPV4} DEBIAN_FRONTEND=noninteractive "apt-get -o DPkg::Lock::Timeout=60 update"
           ssh root@${DROPLET_IPV4} DEBIAN_FRONTEND=noninteractive "apt-get -o DPkg::Lock::Timeout=60 upgrade -y"
           ssh root@${DROPLET_IPV4} DEBIAN_FRONTEND=noninteractive "apt-get -o DPkg::Lock::Timeout=60 install -y docker.io apparmor-profiles"
-          ssh root@${DROPLET_IPV4} "docker run -d -p 127.0.0.1:4021:4021/tcp --restart=always --name vm-connector alephim/vm-connector:alpha"
+          ssh root@${DROPLET_IPV4} "docker run -d -p 127.0.0.1:4021:4021/tcp --restart=always --name vm-connector alephim/vm-connector:2025-03"
 
           scp packaging/target/aleph-vm.debian-12.deb root@${DROPLET_IPV4}:/opt
           scp -pr ./examples root@${DROPLET_IPV4}:/opt/

.github/workflows/test-using-pytest.yml

@@ -11,7 +11,7 @@ jobs:
     services:
       # Run vm connector for the execution tests
       vm-connector:
-        image: alephim/vm-connector:alpha
+        image: alephim/vm-connector:2025-03
         ports:
           - 4021:4021
 

README.md

@@ -66,7 +66,7 @@ Unless your focus is developing the VM-Connector, using the Docker image is easi
    See the [VM-Connector README](./vm_connector/README.md) for more details.
 
    ```shell
-   docker run -d -p 127.0.0.1:4021:4021/tcp --restart=always --name vm-connector alephim/vm-connector:alpha
+   docker run -d -p 127.0.0.1:4021:4021/tcp --restart=always --name vm-connector alephim/vm-connector:2025-03
    ```
 
 2. **Install the Debian Package**

docker/vm_connector.dockerfile

@@ -1,11 +1,11 @@
-FROM python:3.9
+FROM python:3.13
 
 RUN apt-get update && apt-get -y upgrade && apt-get install -y \
      libsecp256k1-dev \
      zip \
      && rm -rf /var/lib/apt/lists/*
 
-RUN pip install fastapi aiofiles uvicorn aleph-client eth-account
+RUN pip install 'fastapi==0.115.11' 'aiofiles==24.1.0' 'uvicorn==0.34.0' 'aleph-sdk-python==1.4.0' 'setuptools==76.0.0'
 
 WORKDIR /opt
 ENV PYTHONPATH=/opt

vm_connector/README.md

@@ -20,17 +20,22 @@ apt update
 apt install -y docker.io
 ```
 
-### 2.b. Pull the Docker image 
+### 2.b. Build the docker image
+```shell
+docker build -f ./docker/vm_connector.dockerfile -t vm-connector .
+```
+
+### 2.c. Pull the Docker image 
 
 ```shell
-docker pull alephim/vm-connector:alpha
+docker pull alephim/vm-connector:2025-03
 ```
 
 ## 3. Running
 
 Run the Docker image
 ```shell
-docker run -d -p 4021:4021/tcp --restart=always --name vm-connector alephim/vm-connector:alpha
+docker run -d -p 4021:4021/tcp --restart=always --name vm-connector alephim/vm-connector:2025-03
 ```
 
 ## 4. Configuration

vm_connector/main.py

@@ -3,14 +3,16 @@
 from typing import Optional
 
 import aiohttp
-from aleph_client.asynchronous import create_post
-from aleph_client.chains.common import get_fallback_private_key
-from aleph_client.chains.ethereum import ETHAccount
-from aleph_client.types import StorageEnum
+from aleph_message.status import MessageStatus
 from fastapi import FastAPI, HTTPException, Request
 from fastapi.responses import Response, StreamingResponse
 from pydantic import BaseModel
 
+from aleph.sdk import AuthenticatedAlephHttpClient
+from aleph.sdk.chains.common import get_fallback_private_key
+from aleph.sdk.chains.ethereum import ETHAccount
+from aleph.sdk.types import StorageEnum
+
 from .conf import settings
 
 logger = logging.getLogger(__file__)
@@ -165,17 +167,21 @@ async def publish_data(body: PostBody):
     content = json.loads(message["item_content"])
     content_content = content["content"]
 
-    result = await create_post(
-        account=account,
-        post_content=content_content,
-        post_type=content["type"],
-        address=content["address"],
-        ref=None,
-        channel=message["channel"],
-        inline=True,
-        storage_engine=StorageEnum.storage,
-    )
-    return {"status": "success"}
+    async with AuthenticatedAlephHttpClient(account) as client:
+        result, status = await client.create_post(
+            post_content=content_content,
+            post_type=content["type"],
+            address=content["address"],
+            ref=None,
+            channel=message["channel"],
+            inline=True,
+            storage_engine=StorageEnum.storage,
+            sync=True,
+        )
+    if status == MessageStatus.PROCESSED:
+        return {"status": "success"}
+    else:
+        return {"status": "error"}
 
 
 @app.get("/properties")