Update AWS Private Connection

# Update an AWS connection
# Replace YOUR_API_KEY with your actual API key
# Replace YOUR_CONNECTION_ID with your connection ID

curl --request PUT \
  --url https://api.pictory.ai/pictoryapis/v1/awsconnections/YOUR_CONNECTION_ID \
  --header 'Authorization: YOUR_API_KEY' \
  --header 'Content-Type: application/json' \
  --data '{
    "name": "UpdatedConnectionName",
    "description": "Updated connection description",
    "enabled": true,
    "version": 1
  }' | python -m json.tool

// Replace 'YOUR_API_KEY' with your actual API key
// Replace 'YOUR_CONNECTION_ID' with your connection ID

const updateAwsConnection = async (apiKey, connectionId, updates) => {
  const response = await fetch(`https://api.pictory.ai/pictoryapis/v1/awsconnections/${connectionId}`, {
    method: 'PUT',
    headers: {
      'Authorization': `${apiKey}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify(updates)
  });

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

  return await response.json();
};

// Usage
try {
  const connectionId = 'YOUR_CONNECTION_ID';  // ← Replace with your connection ID
  const updates = {
    name: 'UpdatedConnectionName',
    description: 'Updated connection description',
    enabled: true,
    version: 1  // Get current version from Get Connection by ID endpoint
  };

  const result = await updateAwsConnection('YOUR_API_KEY', connectionId, updates);  // ← Replace with your API key
  console.log('Updated Connection:', result);
  console.log('New Version:', result.version);
} catch (error) {
  console.error('Error:', error.message);
}

# Replace 'YOUR_API_KEY' with your actual API key
# Replace 'YOUR_CONNECTION_ID' with your connection ID

import requests

def update_aws_connection(api_key, connection_id, updates):
    """Update an existing AWS S3 connection"""
    url = f"https://api.pictory.ai/pictoryapis/v1/awsconnections/{connection_id}"

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

    response = requests.put(url, headers=headers, json=updates)
    response.raise_for_status()

    return response.json()

# Usage
try:
    connection_id = "YOUR_CONNECTION_ID"  # ← Replace with your connection ID
    updates = {
        "name": "UpdatedConnectionName",
        "description": "Updated connection description",
        "enabled": True,
        "version": 1  # Get current version from Get Connection by ID endpoint
    }

    result = update_aws_connection("YOUR_API_KEY", connection_id, updates)  # ← Replace with your API key
    print(f"Updated Connection: {result}")
    print(f"New Version: {result['version']}")
except requests.exceptions.HTTPError as e:
    if e.response.status_code == 404:
        print("Error: Connection not found")
    else:
        error = e.response.json()
        print(f"Error: {error.get('message', 'Request failed')}")

<?php
// Replace 'YOUR_API_KEY' with your actual API key
// Replace 'YOUR_CONNECTION_ID' with your connection ID

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

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

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

    if ($httpCode === 404) {
        throw new Exception('Connection not found');
    }

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

    return json_decode($response, true);
}

// Usage
try {
    $connectionId = 'YOUR_CONNECTION_ID';  // ← Replace with your connection ID
    $updates = [
        'name' => 'UpdatedConnectionName',
        'description' => 'Updated connection description',
        'enabled' => true,
        'version' => 1  // Get current version from Get Connection by ID endpoint
    ];

    $result = updateAwsConnection('YOUR_API_KEY', $connectionId, $updates);  // ← Replace with your API key
    echo "Updated Connection:\n";
    print_r($result);
    echo "New Version: " . $result['version'] . "\n";
} catch (Exception $e) {
    echo "Error: " . $e->getMessage() . "\n";
}
?>

// Replace "YOUR_API_KEY" with your actual API key
// Replace "YOUR_CONNECTION_ID" with your connection ID

package main

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

type UpdateAwsConnectionRequest struct {
    Name        string `json:"name"`
    Description string `json:"description"`
    Enabled     bool   `json:"enabled"`
    Version     int    `json:"version"`
}

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

func updateAwsConnection(apiKey, connectionId string, updates UpdateAwsConnectionRequest) (*AwsConnection, error) {
    url := fmt.Sprintf("https://api.pictory.ai/pictoryapis/v1/awsconnections/%s", connectionId)

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

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

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

    client := &http.Client{}
    resp, err := client.Do(req)
    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.StatusNotFound {
        return nil, fmt.Errorf("connection not found")
    }

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

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

    return &result, nil
}

// Usage
func main() {
    connectionId := "YOUR_CONNECTION_ID"  // ← Replace with your connection ID
    updates := UpdateAwsConnectionRequest{
        Name:        "UpdatedConnectionName",
        Description: "Updated connection description",
        Enabled:     true,
        Version:     1,  // Get current version from Get Connection by ID endpoint
    }

    result, err := updateAwsConnection("YOUR_API_KEY", connectionId, updates)  // ← Replace with your API key
    if err != nil {
        panic(err)
    }

    fmt.Printf("Updated Connection: %+v\n", result)
    fmt.Printf("New Version: %d\n", result.Version)
}