curl -X POST "https://api.dcycle.io/api/v1/logistics/presigned_url" \
  -H "Authorization: Bearer ${DCYCLE_API_KEY}" \
  -H "x-organization-id: ${DCYCLE_ORG_ID}" \
  -H "x-user-id: ${DCYCLE_USER_ID}" \
  -H "Content-Type: application/json" \
  -d '{
    "requests_file_name": "shipments_2024-11.csv"
  }'

# The presigned URL already includes authentication parameters
curl -X PUT "${UPLOAD_URL}" \
  -H "Content-Type: text/csv" \
  --data-binary @shipments_2024-11.csv

import requests
import os
from time import sleep

class DcycleLogistics:
    def __init__(self, api_key, org_id):
        self.api_key = api_key
        self.org_id = org_id
        self.base_url = "https://api.dcycle.io"
        self.headers = {
            "Authorization": f"Bearer {api_key}",
            "x-organization-id": org_id,
            "x-user-id": user_id,
            "Content-Type": "application/json"
        }

    def upload_csv(self, csv_file_path):
        """Complete CSV upload: presigned URL + upload + verification"""

        # 1. Get presigned URL
        file_name = os.path.basename(csv_file_path)
        response = requests.post(
            f"{self.base_url}/api/v1/logistics/presigned_url",
            headers=self.headers,
            json={"requests_file_name": file_name}
        )
        response.raise_for_status()

        upload_url = response.json()["requests"]["upload_url"]
        file_id = response.json()["requests"]["file_id"]

        print(f"✅ Presigned URL obtained (File ID: {file_id})")

        # 2. Upload file
        with open(csv_file_path, 'rb') as f:
            upload_response = requests.put(
                upload_url,
                data=f,
                headers={'Content-Type': 'text/csv'}
            )
        upload_response.raise_for_status()

        print(f"✅ File uploaded successfully")

        # 3. Wait for processing (optional)
        print("⏳ Processing... (this may take a few minutes)")
        sleep(30)  # Wait 30 seconds

        # 4. Verify clients
        clients = self.get_clients()
        print(f"✅ Available clients: {', '.join(clients)}")

        return file_id

    def get_clients(self):
        """List logistics clients"""
        response = requests.get(
            f"{self.base_url}/api/v1/logistics/clients",
            headers=self.headers
        )
        response.raise_for_status()
        return response.json()

# Usage
if __name__ == "__main__":
    client = DcycleLogistics(
        api_key=os.getenv("DCYCLE_API_KEY"),
        org_id=os.getenv("DCYCLE_ORG_ID")
    )

    client.upload_csv("shipments_2024-11.csv")