SeaweedFS

import os

from mirage import MountMode, Workspace
from mirage.vfs.seaweedfs import SeaweedFSConfig, SeaweedFSVFS

config = SeaweedFSConfig(
    bucket=os.environ["SEAWEEDFS_BUCKET"],
    endpoint_url=os.environ.get("SEAWEEDFS_ENDPOINT", "http://localhost:8333"),
    access_key_id=os.environ["SEAWEEDFS_ACCESS_KEY"],
    secret_access_key=os.environ["SEAWEEDFS_SECRET_KEY"],
    # Optional:
    # region="us-east-1",   # default
    # path_style=True,      # default; SeaweedFS uses path-style addressing
    # timeout=30,
    # proxy="http://proxy:8080",
)
vfs = SeaweedFSVFS(config)
ws = Workspace({"/seaweedfs": vfs}, mode=MountMode.WRITE)

import asyncio
import os

from dotenv import load_dotenv

from mirage import MountMode, Workspace
from mirage.vfs.seaweedfs import SeaweedFSConfig, SeaweedFSVFS

load_dotenv(".env.development")

config = SeaweedFSConfig(
    bucket=os.environ.get("SEAWEEDFS_BUCKET", "mirage-demo"),
    endpoint_url=os.environ.get("SEAWEEDFS_ENDPOINT", "http://localhost:8333"),
    access_key_id=os.environ.get("SEAWEEDFS_ACCESS_KEY", "any"),
    secret_access_key=os.environ.get("SEAWEEDFS_SECRET_KEY", "any"),
)
vfs = SeaweedFSVFS(config)


async def main() -> None:
    ws = Workspace({"/seaweedfs/": vfs}, mode=MountMode.READ)

    r = await ws.execute("ls /seaweedfs/")
    print(await r.stdout_str())

    r = await ws.execute("tree /seaweedfs/")
    print(await r.stdout_str())

    r = await ws.execute("cat /seaweedfs/data/config.json")
    print(await r.stdout_str())


if __name__ == "__main__":
    asyncio.run(main())