Create AWS Connection for Private S3 Assets

# This is for terminal/command line use
# Replace YOUR_API_KEY with your actual API key
# Replace 123456789012 with your AWS Account ID
# Replace us-east-2 with your S3 bucket's region

curl --request POST \
  --url https://api.pictory.ai/pictoryapis/v1/awsconnections \
  --header 'Authorization: YOUR_API_KEY' \
  --header 'accept: application/json' \
  --header 'content-type: application/json' \
  --data '{
    "name": "PictoryPrivateVideosConnection",
    "description": "Pictory Private Videos Connection",
    "awsAccountId": "123456789012",
    "awsRegion": "us-east-2",
    "enabled": true
  }' | python -m json.tool

// For use in web applications or Node.js
// Replace 'YOUR_API_KEY' with your actual API key
// Replace '123456789012' with your AWS Account ID
// Replace 'us-east-2' with your S3 bucket's region

const createAWSConnection = async (apiKey) => {
  const response = await fetch('https://api.pictory.ai/pictoryapis/v1/awsconnections', {
    method: 'POST',
    headers: {
      'Authorization': `${apiKey}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      name: 'PictoryPrivateVideosConnection',
      description: 'Pictory Private Videos Connection',
      awsAccountId: '123456789012',  // ← Replace with your AWS Account ID
      awsRegion: 'us-east-2',        // ← Replace with your region
      enabled: true
    })
  });

  if (!response.ok) {
    const error = await response.json();
    throw new Error(`Failed: ${error.message}`);
  }

  return await response.json();
};

// How to use it:
try {
  const connection = await createAWSConnection('YOUR_API_KEY');
  console.log('Success! Connection ID:', connection.connectionId);
  console.log('Save this ID for making video requests!');
} catch (error) {
  console.error('Error:', error.message);
}

# For Python applications
# First install requests: pip install requests
# Replace 'YOUR_API_KEY' with your actual API key
# Replace '123456789012' with your AWS Account ID
# Replace 'us-east-2' with your S3 bucket's region

import requests

def create_aws_connection(api_key):
    """Create AWS connection to access private S3 assets"""
    url = "https://api.pictory.ai/pictoryapis/v1/awsconnections"

    headers = {
        "Authorization": api_key,
        "Content-Type": "application/json"
    }

    payload = {
        "name": "PictoryPrivateVideosConnection",
        "description": "Pictory Private Videos Connection",
        "awsAccountId": "123456789012",  # ← Replace with your AWS Account ID
        "awsRegion": "us-east-2",        # ← Replace with your region
        "enabled": True
    }

    response = requests.post(url, headers=headers, json=payload)
    response.raise_for_status()  # Raises error if request failed

    return response.json()

# How to use it:
try:
    connection = create_aws_connection("YOUR_API_KEY")
    print(f"Success! Connection ID: {connection['connectionId']}")
    print(f"Save this ID for making video requests!")
except requests.exceptions.HTTPError as e:
    error = e.response.json()
    print(f"Error: {error.get('message', 'Request failed')}")

<?php
// For PHP applications
// Replace 'YOUR_API_KEY' with your actual API key
// Replace '123456789012' with your AWS Account ID
// Replace 'us-east-2' with your S3 bucket's region

function createAWSConnection($apiKey) {
    $url = 'https://api.pictory.ai/pictoryapis/v1/awsconnections';

    $payload = [
        'name' => 'PictoryPrivateVideosConnection',
        'description' => 'Pictory Private Videos Connection',
        'awsAccountId' => '123456789012',  // ← Replace with your AWS Account ID
        'awsRegion' => 'us-east-2',        // ← Replace with your region
        'enabled' => true
    ];

    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: ' . $apiKey,
        'Content-Type: application/json'
    ]);

    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    if ($httpCode !== 201) {
        $error = json_decode($response, true);
        throw new Exception($error['message'] ?? 'Request failed');
    }

    return json_decode($response, true);
}

// How to use it:
try {
    $connection = createAWSConnection('YOUR_API_KEY');
    echo "Success! Connection ID: " . $connection['connectionId'] . "\n";
    echo "Save this ID for making video requests!\n";
} catch (Exception $e) {
    echo "Error: " . $e->getMessage() . "\n";
}
?>

// For Go applications
// Replace "YOUR_API_KEY" with your actual API key
// Replace "123456789012" with your AWS Account ID
// Replace "us-east-2" with your S3 bucket's region

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "io"
    "net/http"
)

type AWSConnectionRequest struct {
    Name         string `json:"name"`
    Description  string `json:"description"`
    AWSAccountID string `json:"awsAccountId"`
    AWSRegion    string `json:"awsRegion"`
    Enabled      bool   `json:"enabled"`
}

type AWSConnectionResponse struct {
    ConnectionID string `json:"connectionId"`
    Name         string `json:"name"`
    AWSAccountID string `json:"awsAccountId"`
    AWSRegion    string `json:"awsRegion"`
    Enabled      bool   `json:"enabled"`
    Version      int    `json:"version"`
}

func createAWSConnection(apiKey string) (*AWSConnectionResponse, error) {
    url := "https://api.pictory.ai/pictoryapis/v1/awsconnections"

    req := AWSConnectionRequest{
        Name:         "PictoryPrivateVideosConnection",
        Description:  "Pictory Private Videos Connection",
        AWSAccountID: "123456789012",  // ← Replace with your AWS Account ID
        AWSRegion:    "us-east-2",     // ← Replace with your region
        Enabled:      true,
    }

    jsonData, err := json.Marshal(req)
    if err != nil {
        return nil, err
    }

    httpReq, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonData))
    if err != nil {
        return nil, err
    }

    httpReq.Header.Set("Authorization", apiKey)
    httpReq.Header.Set("Content-Type", "application/json")

    client := &http.Client{}
    resp, err := client.Do(httpReq)
    if err != nil {
        return nil, err
    }
    defer resp.Body.Close()

    body, err := io.ReadAll(resp.Body)
    if err != nil {
        return nil, err
    }

    if resp.StatusCode != http.StatusCreated {
        return nil, fmt.Errorf("request failed (status %d): %s", resp.StatusCode, string(body))
    }

    var result AWSConnectionResponse
    if err := json.Unmarshal(body, &result); err != nil {
        return nil, err
    }

    return &result, nil
}

// How to use it:
func main() {
    connection, err := createAWSConnection("YOUR_API_KEY")
    if err != nil {
        panic(err)
    }

    fmt.Printf("Success! Connection ID: %s\n", connection.ConnectionID)
    fmt.Println("Save this ID for making video requests!")
}