index.js

import ApiClient from './lib/ApiClient.js';

// CMS API client
const api = new ApiClient({
  baseUrl: process.env.APCMS_API_ROOT,
  defaultHeaders: {
    Authorization: `Bearer ${process.env.APCMS_API_TOKEN}`
  }
});

// Unique ID for this process instance.
// Only one PipelineTask runner can claim a specific task at a time.  This
// allows multiple runners to help distribute the load of many new tasks, while
// ensuring only one runner works in a particular task.
const taskRunnerId = crypto.randomUUID();

// "Claim" a task to start
const [ task ] = await api.post('pipelineTasks', 'claim', {
  taskRunnerId,
  label: 'example'
});

// If no task, there's nothing to do
if (!task) {
  console.debug('No tasks.');
  process.exit(0);
}

// Start processing the task
try {
  console.debug('Starting Task: ', task);

  task.Asset.Variants = await api.get('assets', task.Asset.id, 'variants');
  console.debug('Asset:', task.Asset);

  // ***** TODO TODO TODO *****
  //
  // This is where you put your custom code for how you want to handle the asset.
  // Use the CMS API to manipulate the data.  For example, perhaps you wish to
  // update the tags of an asset:
  //
  //    task.Asset.tags = {
  //      ...task.Asset.tags,
  //      ARTIST: 'EXAMPLE ARTIST',
  //      TITLE: 'EXAMPLE TITLE'
  //    };
  //    await api.put('assets', task.Asset.id, task.Asset);
  //
  // ***** TODO TODO TODO *****

  // Task succeeded.  Clear it.
  await api.delete('pipelineTasks', task.id);
  console.debug('Success.');

} catch(e) {
  console.error('Task failed.', e);

  // Tell the API that the task failed, so it can be retried later
  await api.put('pipelineTasks', task.id, {
    ...task,
    taskRunnerId: null,
    status: 'failed',
    failCount: task.failCount + 1,
    taskRunnerUpdated: new Date()
  });

  process.exit(1);
}