Google Cloud Platform (GCP) Services

server:
  port: 4747

providers:
  gcp:
    services:
      gcs:
        enabled: true
        data_dir: ./data/gcp/gcs
      gcpsecrets:
        enabled: true
      gcppubsub:
        enabled: true

export STORAGE_EMULATOR_HOST="http://127.0.0.1:4747"
export GOOGLE_APPLICATION_CREDENTIALS="/dev/null"

import base64
import requests

endpoint = "http://localhost:4747"
project = "local-project"
headers = {"Authorization": "Bearer local-token"}

# 1. Create a secret
requests.post(
    f"{endpoint}/v1/projects/{project}/secrets?secretId=DatabasePassword",
    json={"replication": {"automatic": {}}},
    headers=headers,
)

# 2. Add a secret version
payload = base64.b64encode(b"ProductionDatabasePassword123").decode()
requests.post(
    f"{endpoint}/v1/projects/{project}/secrets/DatabasePassword:addVersion",
    json={"payload": {"data": payload}},
    headers=headers,
)

# 3. Access secret version (latest)
resp = requests.get(
    f"{endpoint}/v1/projects/{project}/secrets/DatabasePassword/versions/latest:access",
    headers=headers,
)
retrieved = base64.b64decode(resp.json()["payload"]["data"]).decode()
print("Retrieved secret:", retrieved)

import base64
import requests

endpoint = "http://localhost:4747"
project = "local-project"
headers = {"Authorization": "Bearer local-token"}

# 1. Create a topic
requests.put(
    f"{endpoint}/v1/projects/{project}/topics/order-events",
    headers=headers,
)

# 2. Create a subscription
requests.put(
    f"{endpoint}/v1/projects/{project}/subscriptions/order-worker",
    json={"topic": f"projects/{project}/topics/order-events"},
    headers=headers,
)

# 3. Publish a message
msg_data = base64.b64encode(b"order_id=456 status=paid").decode()
requests.post(
    f"{endpoint}/v1/projects/{project}/topics/order-events:publish",
    json={"messages": [{"data": msg_data}]},
    headers=headers,
)

# 4. Pull and acknowledge message
pull_resp = requests.post(
    f"{endpoint}/v1/projects/{project}/subscriptions/order-worker:pull",
    json={"maxMessages": 10},
    headers=headers,
)
messages = pull_resp.json().get("receivedMessages", [])
for m in messages:
    ack_id = m["ackId"]
    content = base64.b64decode(m["message"]["data"]).decode()
    print("Received:", content)
    requests.post(
        f"{endpoint}/v1/projects/{project}/subscriptions/order-worker:acknowledge",
        json={"ackIds": [ack_id]},
        headers=headers,
    )