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"
  }'

import requests
import os

api_key = os.getenv("DCYCLE_API_KEY")
org_id = os.getenv("DCYCLE_ORG_ID")

headers = {
    "Authorization": f"Bearer {api_key}",
    "x-organization-id": org_id,
    "x-user-id": user_id,
    "Content-Type": "application/json"
}

payload = {
    "requests_file_name": "shipments_2024-11.csv"
}

response = requests.post(
    "https://api.dcycle.io/api/v1/logistics/presigned_url",
    headers=headers,
    json=payload
)

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

print(f"Upload URL obtained: {upload_url[:50]}...")
print(f"File ID: {file_id}")

const axios = require('axios');

const apiKey = process.env.DCYCLE_API_KEY;
const orgId = process.env.DCYCLE_ORG_ID;

const headers = {
  'Authorization': `Bearer ${apiKey}`,
  'x-organization-id': orgId,
  'x-user-id': userId,
  'Content-Type': 'application/json'
};

const payload = {
  requests_file_name: "shipments_2024-11.csv"
};

axios.post(
  'https://api.dcycle.io/api/v1/logistics/presigned_url',
  payload,
  { headers }
)
.then(response => {
  const { upload_url, file_id } = response.data.requests;
  console.log('Upload URL:', upload_url.substring(0, 50) + '...');
  console.log('File ID:', file_id);
})
.catch(error => console.error(error));

# 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

# Read CSV file
with open('shipments_2024-11.csv', 'rb') as file:
    csv_data = file.read()

# Upload to S3
response = requests.put(
    upload_url,
    data=csv_data,
    headers={'Content-Type': 'text/csv'}
)

if response.status_code == 200:
    print("✅ File uploaded successfully")
else:
    print(f"❌ Error: {response.status_code}")

const fs = require('fs');
const axios = require('axios');

// Read CSV file
const csvData = fs.readFileSync('shipments_2024-11.csv');

// Upload to S3
axios.put(uploadUrl, csvData, {
  headers: { 'Content-Type': 'text/csv' }
})
.then(() => console.log('✅ File uploaded successfully'))
.catch(error => console.error('❌ Error:', error));

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")

#!/bin/bash

# Variables
API_KEY="${DCYCLE_API_KEY}"
ORG_ID="${DCYCLE_ORG_ID}"
CSV_FILE="shipments_2024-11.csv"
BASE_URL="https://api.dcycle.io"

# 1. Get presigned URL
echo "📤 Requesting presigned URL..."
RESPONSE=$(curl -s -X POST "${BASE_URL}/api/v1/logistics/presigned_url" \
  -H "Authorization: Bearer ${API_KEY}" \
  -H "x-organization-id: ${ORG_ID}" \
  -H "x-user-id: ${DCYCLE_USER_ID}" \
  -H "Content-Type: application/json" \
  -d "{\"requests_file_name\": \"${CSV_FILE}\"}")

UPLOAD_URL=$(echo $RESPONSE | jq -r '.requests.upload_url')
FILE_ID=$(echo $RESPONSE | jq -r '.requests.file_id')

echo "✅ URL obtained (File ID: ${FILE_ID})"

# 2. Upload file
echo "📤 Uploading CSV file..."
curl -X PUT "${UPLOAD_URL}" \
  -H "Content-Type: text/csv" \
  --data-binary @"${CSV_FILE}"

echo "✅ File uploaded successfully"
echo "⏳ File is being processed..."