mirror of
https://github.com/hanzoai/replicate.git
synced 2026-10-30 18:23:20 +00:00
zeekay
a485f34a14
- All source files, configs, docs, CI renamed - Binary: replicate (not litestream) - Config: replicate.yml (litestream.yml as fallback) - Env: REPLICATE_* (LITESTREAM_* as fallback) - Socket: /var/run/replicate.sock - Image: ghcr.io/hanzoai/replicate - Module: github.com/hanzoai/replicate - Package name: replicate (Go), replicate-vfs (npm/pip/gem) - VFS: registered as "replicate", pragmas replicate_* - C exports: ReplicateVFSRegister, GoReplicate* - Windows service: Replicate - Systemd unit: replicate.service - Upstream attribution preserved (README, upgrade test scripts)
36 lines
905 B
Python
Executable File
36 lines
905 B
Python
Executable File
#!/usr/bin/env python3
|
|
import sys
|
|
import os
|
|
import time
|
|
from moto.server import ThreadedMotoServer
|
|
import boto3
|
|
import subprocess
|
|
|
|
cmd = sys.argv[1:]
|
|
if len(cmd) == 0:
|
|
print(f"usage: {sys.argv[0]} <command> [arguments]", file=sys.stderr)
|
|
sys.exit(1)
|
|
|
|
env = os.environ.copy() | {
|
|
"REPLICATE_S3_ACCESS_KEY_ID": "lite",
|
|
"REPLICATE_S3_SECRET_ACCESS_KEY": "stream",
|
|
"REPLICATE_S3_BUCKET": f"test{int(time.time())}",
|
|
"REPLICATE_S3_ENDPOINT": "http://127.0.0.1:5000",
|
|
"REPLICATE_S3_FORCE_PATH_STYLE": "true",
|
|
}
|
|
|
|
server = ThreadedMotoServer()
|
|
server.start()
|
|
|
|
s3 = boto3.client(
|
|
"s3",
|
|
aws_access_key_id=env["REPLICATE_S3_ACCESS_KEY_ID"],
|
|
aws_secret_access_key=env["REPLICATE_S3_SECRET_ACCESS_KEY"],
|
|
endpoint_url=env["REPLICATE_S3_ENDPOINT"]
|
|
).create_bucket(Bucket=env["REPLICATE_S3_BUCKET"])
|
|
|
|
proc = subprocess.run(cmd, env=env)
|
|
|
|
server.stop()
|
|
sys.exit(proc.returncode)
|