Update Data Object

curl -X PUT "https://api.pretectum.io/v1/businessareas/20240115103000123a1b2c3d4e5f6789012345678901234/schemas/20240115103000456d1e2f3a4b5c6789012345678901234/datasets/20240925152201042a1b2c3d4e5f6789012345678901234/dataobjects/20240601120000123f1a2b3c4d5e6789012345678901234" \
  -H "Authorization: pre_your_api_key" \
  -H "Content-Type: application/json" \
  -H "Accept: application/json" \
  -d '{
    "_version": 1,
    "Email": "john.smith.updated@example.com",
    "Phone": "+1 555-999-8888",
    "Status": "Premium"
  }'

const apiKey = 'pre_your_api_key';
const businessAreaId = '20240115103000123a1b2c3d4e5f6789012345678901234';
const schemaId = '20240115103000456d1e2f3a4b5c6789012345678901234';
const datasetId = '20240925152201042a1b2c3d4e5f6789012345678901234';
const dataObjectId = '20240601120000123f1a2b3c4d5e6789012345678901234';

async function updateDataObject(businessAreaId, schemaId, datasetId, dataObjectId, data) {
  const response = await fetch(
    `https://api.pretectum.io/v1/businessareas/${businessAreaId}/schemas/${schemaId}/datasets/${datasetId}/dataobjects/${dataObjectId}`,
    {
      method: 'PUT',
      headers: {
        'Authorization': apiKey,
        'Content-Type': 'application/json',
        'Accept': 'application/json'
      },
      body: JSON.stringify(data)
    }
  );

  if (!response.ok) {
    throw new Error(`Failed to update data object: ${response.statusText}`);
  }

  // Returns 204 No Content on success
  return response.status === 204;
}

const updates = {
  '_version': 1,
  'Email': 'john.smith.updated@example.com',
  'Phone': '+1 555-999-8888',
  'Status': 'Premium'
};

const success = await updateDataObject(businessAreaId, schemaId, datasetId, dataObjectId, updates);
if (success) {
  console.log('Data object updated successfully');
}

import requests

api_key = 'pre_your_api_key'
business_area_id = '20240115103000123a1b2c3d4e5f6789012345678901234'
schema_id = '20240115103000456d1e2f3a4b5c6789012345678901234'
dataset_id = '20240925152201042a1b2c3d4e5f6789012345678901234'
data_object_id = '20240601120000123f1a2b3c4d5e6789012345678901234'

def update_data_object(business_area_id, schema_id, dataset_id, data_object_id, data):
    response = requests.put(
        f'https://api.pretectum.io/v1/businessareas/{business_area_id}/schemas/{schema_id}/datasets/{dataset_id}/dataobjects/{data_object_id}',
        json=data,
        headers={
            'Authorization': api_key,
            'Content-Type': 'application/json',
            'Accept': 'application/json'
        }
    )
    response.raise_for_status()
    # Returns 204 No Content on success
    return response.status_code == 204

updates = {
    '_version': 1,
    'Email': 'john.smith.updated@example.com',
    'Phone': '+1 555-999-8888',
    'Status': 'Premium'
}

success = update_data_object(business_area_id, schema_id, dataset_id, data_object_id, updates)
if success:
    print('Data object updated successfully')

async function updateWithRetry(businessAreaId, schemaId, datasetId, dataObjectId, updates, maxRetries = 3) {
  for (let attempt = 0; attempt < maxRetries; attempt++) {
    try {
      // Get current version
      const dataObjects = await getDataObjects(businessAreaId, schemaId, datasetId);
      const current = dataObjects.items.find(obj => obj._dataObjectId === dataObjectId);

      if (!current) {
        throw new Error('Data object not found');
      }

      // Attempt update with current version
      const success = await updateDataObject(
        businessAreaId,
        schemaId,
        datasetId,
        dataObjectId,
        { ...updates, _version: current._version }
      );

      if (success) {
        return true;
      }
    } catch (error) {
      if (attempt === maxRetries - 1) {
        throw error;
      }
      // Wait before retry
      await new Promise(resolve => setTimeout(resolve, 1000));
    }
  }
  return false;
}

import time

def update_with_retry(business_area_id, schema_id, dataset_id, data_object_id, updates, max_retries=3):
    for attempt in range(max_retries):
        try:
            # Get current version
            data_objects = get_data_objects(business_area_id, schema_id, dataset_id)
            current = next(
                (obj for obj in data_objects['items'] if obj['_dataObjectId'] == data_object_id),
                None
            )

            if not current:
                raise ValueError('Data object not found')

            # Attempt update with current version
            success = update_data_object(
                business_area_id,
                schema_id,
                dataset_id,
                data_object_id,
                {**updates, '_version': current['_version']}
            )

            if success:
                return True
        except Exception as error:
            if attempt == max_retries - 1:
                raise error
            # Wait before retry
            time.sleep(1)

    return False