curl -X POST "https://api.dcycle.io/api/v1/purchases/bulk/csv" \
  -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 '{
    "file_name": "2024_q1_purchases.csv"
  }'

import requests
import os

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

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

payload = {
    "file_name": "2024_q1_purchases.csv"
}

response = requests.post(
    "https://api.dcycle.io/api/v1/purchases/bulk/csv",
    headers=headers,
    json=payload
)

result = response.json()
upload_url = result["upload_url"]
file_id = result["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 userId = process.env.DCYCLE_USER_ID;

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

const payload = {
  file_name: '2024_q1_purchases.csv'
};

axios.post(
  'https://api.dcycle.io/api/v1/purchases/bulk/csv',
  payload,
  { headers }
)
.then(response => {
  const { upload_url, file_id } = response.data;
  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 @2024_q1_purchases.csv

import requests

# Read CSV file
with open('2024_q1_purchases.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('2024_q1_purchases.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 DcyclePurchases:
    def __init__(self, api_key, org_id, user_id):
        self.api_key = api_key
        self.org_id = org_id
        self.user_id = user_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/purchases/bulk/csv",
            headers=self.headers,
            json={"file_name": file_name}
        )
        response.raise_for_status()

        upload_url = response.json()["upload_url"]
        file_id = response.json()["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 purchases
        purchases = self.get_purchases()
        print(f"✅ Total purchases: {purchases['total']}")

        return file_id

    def get_purchases(self, page=1, size=50):
        """List purchases"""
        response = requests.get(
            f"{self.base_url}/api/v1/purchases",
            headers=self.headers,
            params={"page": page, "size": size}
        )
        response.raise_for_status()
        return response.json()

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

    client.upload_csv("2024_q1_purchases.csv")

#!/bin/bash

# Variables
API_KEY="${DCYCLE_API_KEY}"
ORG_ID="${DCYCLE_ORG_ID}"
USER_ID="${DCYCLE_USER_ID}"
CSV_FILE="2024_q1_purchases.csv"
BASE_URL="https://api.dcycle.io"

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

UPLOAD_URL=$(echo $RESPONSE | jq -r '.upload_url')
FILE_ID=$(echo $RESPONSE | jq -r '.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..."