Cleaning exospherehost python sdk and adding first exospherehost runtime

exosphere-runtimes/cloud-storage-runtime/.gitignore

@@ -0,0 +1,66 @@
+# Python
+__pycache__/
+*.py[cod]
+*$py.class
+*.so
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# Virtual Environment
+venv/
+env/
+ENV/
+.env
+.venv/
+
+# IDE
+.vscode/
+*.swp
+*.swo
+.idea/
+*.iws
+*.iml
+*.ipr
+
+
+# Local development
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+# Database
+*.db
+*.sqlite3
+
+# OS generated files
+.DS_Store
+.DS_Store?
+._*
+.Spotlight-V100
+.Trashes
+ehthumbs.db
+Thumbs.db
+
+#logs 
+*.log
+logs/*.*
+!logs/.gitkeep
+
+# local files
+files/
+!files/.gitkeep

exosphere-runtimes/cloud-storage-runtime/.python-version

@@ -0,0 +1 @@
+3.12

exosphere-runtimes/cloud-storage-runtime/main.py

@@ -0,0 +1,14 @@
+from dotenv import load_dotenv
+from exospherehost import Runtime
+from nodes.list_s3_files import ListS3FilesNode
+
+# Load environment variables from .env file
+# EXOSPHERE_STATE_MANAGER_URI is the URI of the state manager
+# EXOSPHERE_API_KEY is the key of the runtime
+load_dotenv()
+
+Runtime(
+    name="cloud-storage-runtime",
+    namespace="exospherehost",
+    nodes=[ListS3FilesNode]
+).start()

exosphere-runtimes/cloud-storage-runtime/nodes/list_s3_files.py

@@ -0,0 +1,39 @@
+import boto3
+import os
+
+from exospherehost import BaseNode
+from typing import List
+from pydantic import BaseModel
+
+
+class ListS3FilesNode(BaseNode):
+
+    class Inputs(BaseModel):
+        bucket_name: str
+        prefix: str = ''
+        files_only: bool = False
+        recursive: bool = False
+
+    class Outputs(BaseModel):
+        key: str
+
+    class Secrets(BaseModel):
+        aws_access_key_id: str = os.getenv("S3_ACCESS_KEY_ID")
+        aws_secret_access_key: str = os.getenv("S3_SECRET_ACCESS_KEY")
+        aws_region: str = os.getenv("S3_REGION")
+
+    async def execute(self) -> List[Outputs]:
+        print(self.inputs)
+
+        s3_client = boto3.client(
+            's3',
+            aws_access_key_id=os.getenv("S3_ACCESS_KEY_ID"),
+            aws_secret_access_key=os.getenv("S3_SECRET_ACCESS_KEY"),
+            region_name=os.getenv("S3_REGION")
+        )
+        response = s3_client.list_objects_v2(Bucket=self.inputs.bucket_name, Prefix=self.inputs.prefix)
+
+        return [
+            self.Outputs(key=data['Key'])
+            for data in response['Contents']
+        ]

exosphere-runtimes/cloud-storage-runtime/pyproject.toml

@@ -0,0 +1,10 @@
+[project]
+name = "cloud-storage-runtime"
+version = "0.1.0"
+description = "Add your description here"
+readme = "README.md"
+requires-python = ">=3.12"
+dependencies = [
+    "boto3>=1.40.1",
+    "python-dotenv>=1.1.1",
+]