JavaScript convenience wrapper for the AWS Cloud Directory API.

const CloudDirectoryClient = require('clouddirectory-client');

let client = new CloudDirectoryClient({
  DirectoryArn: '',
  Schema: 'myschema/1', // schema name / major version
});

let index = await client.createIndex({
  IndexName: 'sensors',
  IndexedAttributes: [{ sensor: 'sensor_id' }],
});

client.createObject({
  Attributes: {
    sensor: { sensor_id: 'abc123123' },
  },
  Parents: [{
    Selector: '/floors/ground_floor/server_room',
    LinkName: 'abc123123',
  }],
  Indexes: ['/sensors'],
  IncomingTypedLinks: [{
    Selector: '/floors/ground_floor',
    Attributes: {
      sensor_floor_association: {
        sensor_type: 'water',
        maintenance_date: '2015-04-03',
      },
    },
  }],
});

let sensors = client.listIncomingTypedLinks('/floors/ground_floor', {
  FloorSensorAssociation: { sensor_type: 'water' }
}).iterate();
for (let sensor of sensors) {
  console.log(await sensor);
}

new CloudDirectoryClient(options = {}) : Object

Options Hash (options):

• DirectoryArn (String, required), the Amazon Resource Name (ARN) that is associated with the Directory where the object resides.
• AppliedSchemaArn (String, required), the Amazon Resource Name (ARN) that is associated with the schema.
• Client (String), instance of AWS.CloudDirectory. Defaults to new AWS.CloudDirectory().
• MaxResults (Number), maximum number of items to be retrieved in a single call. Defaults to 10, max value is 30.
• ConsistencyLevel (String), represents the manner and timing in which the successful write or update of an object is reflected in a subsequent read operation of that same object. Possible values include: SERIALIZABLE and EVENTUAL (default).

The selector argument is ubiquitous and can take the following shape:

• Path /path/to/my/object
• Object Identifier $AQFnK8iyN7pMTbkTyChgMF7N8WyQmgMnRLS4yPVJfYRDQA
• List of Path Segments ['path', 'to', 'object'] (the leading slash is optional)

Resolves to null

client.attachObject(parentSelector, childSelector, linkName);

Resolves to null

client.attachTypedLink(sourceSelector, targetSelector, {
  [facetName]: { [attributeName]: attributeValue },
});

Resolves to null

client.deleteIndex(selector);

deleteIndex will detach an index from all its parents before it is deleted. This method will not attempt to remove all links to any children (which would orphan the children unless they have other parents). If the deletion of the index fails due to attached children, the whole transaction is rolled back.

Resolves to null

client.deleteObject(selector);

deleteObject will detach an object from all its parents and indices before it is deleted. This method will not attempt to remove all links to any children (which would orphan the children unless they have other parents). If the deletion of the object fails due to attached children, the whole transaction is rolled back.

Resolves to null

client.detachAllFromIndex(indexSelector);

Detaches all objects from the specified index.

Resolves to null

client.detachFromIndex(indexSelector, objectSelector);

Detaches the specified object from the specified index.

Resolves to null

client.detachObject(parentSelector, linkName);

Returns IterableResultSet

client.listAttachedIndices(selector);

Returns IterableResultSet

client.listIncomingTypedLinks(selector, {
  [facetName]: {
    [attributeName]: 'STRING_VALUE',
  },
});

Returns IterableResultSet

client.listIndex(selector, {
  [facetNameA]: {
    [attributeName]: 'STRING_VALUE',
  },
  [facetNameB]: {
    [attributeName]: 'STRING_VALUE',
  },
});

Returns IterableResultSet

client.listIncomingTypedLinks(selector, facetName?);

Returns IterableResultSet

Returns IterableResultSet

Returns IterableResultSet

Returns IterableResultSet

Returns IterableResultSet

Returns IterableResultSet

Returns IterableResultSet

IterableResultSet is returned by all list* and lookup* methods. It's a convenience wrapper for the paging API provided by AWS Cloud Directory. Instead of having to page through results this class provides a iterable result set.

let users = client.listObjectChildren('/users').iterate();
for(let user of users) {
  console.log(await user);
}

The list* operations return a generator that allows you to scroll through result sets efficiently. The Cloud Directory API implements paging through the NextToken parameters.

let client = new CloudDirectoryClient({ MaxResults: 15 }); // defaults to 10, max. value is 30
let users = client.listObjectChildren('/users');
for(let user of users) {
  console.log(await user);
}

Let's assume we have 100 objects attached to /users that we want to scroll over. With MaxResults set at 15, there will be a total 7 requests made to retrieve all objects. The Cloud Directory API doesn't support skipping object when listing results.