Programming Interface
The damas-core API is available for Python, Javascript and the command line. Read the connect page to setup a client environment.
A demo server is available at https://demo.damas.io.
The implemented methods, parameters and responses follow the specification.
Methods
Generic CRUD Functions
Create, retrieve, update, delete elements (any nodes and edges).
- create - insert new element(s)
- read - retrieve element(s) using identifiers
- update - modify existing element(s)
- upsert - create or modify element(s)
- delete - delete element(s)
User Authentication Functions
Defined in the JWT extension.
- createToken- request an authentication token from the server
- signIn- request a token from the server and use it for further requests
- signOut - revoke a token
- verify - ask the server for the authentication status and user
Search queries
Retrieve elements with more sophisticated methods.
- graph - retrieve connected edges and nodes (recursive) (deprecated)
- graph_backwards - retrieve the connected edges and nodes, in reverse (recursive)
- graph_forwards - retrieve the connected edges and nodes, following the edges direction (recursive)
- search - find elements matching a query string
- search_one - find first element matching a query string
- search_mongo - find elements using a MongoDB query object (if MongoDB is the back-end)
Implementation-specific Notes
Status per Language
| Function | JS | Python | CLI |
|---|---|---|---|
| create | ✓ | ✓ | ✓ |
| read | ✓ | ✓ | ✓ |
| update | ✓ | ✓ | ✓ |
| upsert | ✓ | ✓ | ✓ |
| delete | ✓ | ✓ | ✓ |
| createToken | ✓ | ||
| signIn | ✓ | ✓ | ✓ |
| signOut | ✓ | ✓ | ✓ |
| verify | ✓ | ✓ | ✓ |
| graph * | ✓ | ✓ | ✓ |
| graph_backwards | ✓ | ||
| graph_forwards | ✓ | ||
| search | ✓ | ✓ | ✓ |
| search_one | ✓ | ✓ | ✓ |
| search_mongo | ✓ | ✓ | ✓ |
✓ = implemented
* = deprecated
JSON-Python Object Correspondence Table
The Python module exposes the JSON data using the Python built-in types.
| JSON | Python |
|---|---|
| Object | Dictionary |
| Array | List or Tuple or Set |
| null | None |
| true | True |
| false | False |
Synchronous / Asynchronous calls
The JavaScript module supports both synchronous and asynchronous requests: if an optional callback argument is provided, the request is ran asynchronously and the response is given as argument to the specified callback. If the callback is not provided, the request is made synchronously and the return value holds the response.
The Python API uses synchronous requests only (a bit of work is required to make them async ready).
Objects and Types
The elements are described as key/value pairs using JSON:
{
"_id": "your_custom_id",
"boolean": true,
"number": 1234,
"string":"hello world"
}
The elements are identified using unique identifiers stored in the reserved _id key. If the _id key is not provided at creation, a default unique value for _id is assigned. The ulid extension generates Universally Unique Lexicographically Sortable Identifiers and let you customize the identifiers using patterns.
Types
The elements are loosely typed: it is up to the model from the layer above to decide how and if some elements are typed. For example, the users, defined in the jwt authentication extension, are described as elements wearing some reserved keys: username, password, class plus optional keys.
{
"class": "user",
"email": "usermail@address.com", /* optional or email verification */
"fullname": "Firstname Lastname String", /* optional */
"password": "13d3a2a16c0cd2f7bf115d471999377e", /* md5 or sha1 hashed */
"username": "userlogin"
}
The user elements are defined and used in the jwt authentication extension and a dedicated authentication page gives more details about the mechanism.
Graph Edges
The edges (the directed links between nodes) are objects as nodes, wearing key/values, with the reserved keys src_id and tgt_id referring to the _id of the nodes to link.
{
"_id": "lnk_01G0J7150FYJMCSPK118YGXB56",
"src_id": "<sourcenode_id>",
"tgt_id": "<targetnode_id>"
}
Functions list
A set of generic CRUD functions is provided to create, read, modify and delete elements:
create
Create element(s) in the database. Elements have an _id key being their unique identifier in the database. This key can be specified during creation, but can't be updated afterwards without first deleting the element. The server may add some other arbitrary keys (like author, time at creation) depending on its configuration.
create ( elements [, callback] )
parameters
elements{object | array} : object(s) to insert in the databasecallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns an object or an array of objects (depending on the input) on success
- returns
null(Javascript) orNone(Python) on failure
examples
Python
# create a new element wearing an auto-generated unique identifier
>>> damas.create({"key1":"value1"})
{u'_id': u'55ae0b1ed81e88357d77d0e9', u'key1': u'value1', u'time': 1437469470133, u'author': u'demo'}
# create a new element with a specified identifier
>>> damas.create({"_id":"/project/folder/file", "additional_key":"value"})
{u'_id': u'/project/folder/file', u'additional_key': u'value', u'time': 1480586620449, u'author': u'demo'}
# create two elements
>>> damas.create([{"label":"element1"}, {"label":"element2"}])
[{u'_id': u'583ff5a747e759beb73bde32', u'time': 1480586663024, u'label': u'element1', u'author': u'demo'}, {u'_id': u'583ff5a747e759beb73bde33', u'time': 1480586663024, u'label': u'element2', u'author': u'demo'}]
# create two elements using an array as _id
>>> damas.create({"_id":["identifier1","identifier2"],"key":"keyvalue"})
# create a new graph edge element
>>> damas.create({"src_id":"/project/folder/file1","tgt_id":"/project/folder/file2"})
{u'tgt_id': u'/project/folder/to/file2', u'_id': u'583ff67647e759beb73bde34', u'time': 1480586870826, u'src_id': u'/project/folder/to/file1', u'author': u'demo'}
Javascript
// create a new element
damas.create({key1: "value1"});
▸ Object { author: "demo", time: 1437469470133, key1: "value1", _id: "55ae0b1ed81e88357d77d0e9" }
// create a new element wearing an auto-generated unique identifier (asynchronously)
damas.create({key1: "value2"}, function (element) {
console.log(element.time);
});
// create a new element with a specified identifier
damas.create({"_id":"/project/folder/file", "additional_key":"value"});
▸ Object {_id: "/project/folder/file", additional_key: "value", time: 1480586620449, author: "demo"}
// create two elements
damas.create([{"label":"element1"}, {"label":"element2"}]);
▸ Array [{_id: "583ff5a747e759beb73bde32", time: 1480586663024, label: "element1", author: "demo"}, {_id: "583ff5a747e759beb73bde33", time: 1480586663024, label: "element2", author: "demo"}]
// create two elements with an array as _id
damas.create({"_id":["identifier1","identifier2"],"key":"keyvalue"});
// create a new graph edge element
damas.create({"src_id":"/project/folder/file1","tgt_id":"/project/folder/file2"})
▸ Object {tgt_id: "/project/folder/to/file2", _id: "583ff67647e759beb73bde34", time: 1480586870826, src_id: "/project/folder/to/file1", author: "demo"}
read
Retrieve one or more elements given their identifiers
read ( identifiers [, callback] )
parameters
identifiers{string | array} : identifier(s) string(s) to readcallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns an object or an array of objects (depending on the input) on success
- returns
nullorNoneon failure
For multiple mode, The resulting array is sorted in the same order as the input array of identifiers. If some identifiers are not found, the result array is filled with None / null values for that position.
examples
Python
# read a file
>>> damas.read("/project/folder/file")
{u'additional_key': u'value', u'_id': u'/project/folder/file', u'time': 1480586620449, u'author': u'demo'}
# read 2 elements
>>> damas.read(["583ff5a747e759beb73bde32","583ff5a747e759beb73bde33"])
[{u'_id': u'583ff5a747e759beb73bde32', u'time': 1480586663024, u'label': u'element1', u'author': u'demo'}, {u'_id': u'583ff5a747e759beb73bde33', u'time': 1480586663024, u'label': u'element2', u'author': u'demo'}]
Javascript
// read a file
damas.read("/project/folder/file");
▸ Object {additional_key: "value", _id: "/project/folder/file", time: 1480586620449, author: "demo"}
// read 2 elements
damas.read(["583ff5a747e759beb73bde32", "583ff5a747e759beb73bde33"]);
▸ Array [_id: "583ff5a747e759beb73bde32", time: 1480586663024, label: "element1", author: "demo"}, {_id: "583ff5a747e759beb73bde33", time: 1480586663024, label: "element2", author: "demo"}]
update
Modify and remove keys of the specified element(s)
update ( elements [, callback] )
parameters
elements{object | array} : object(s) to updatecallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns an object or an array of objects (depending on the input) on success
- returns
null(Nonein Python) on failure - returns an array of objects or null on mixed success/failures
The specified keys overwrite the existing keys on the server. Unspecified keys are left untouched on the server. A
nullorNonevalue removes the key.
If multiple nodes are specified, the resulting array is sorted in the same order as the input array of identifiers.
The
_idkey can accept an array of identifiers, which means that the update will be performed on each specified element
examples
Javascript
// update an element
damas.update({_id: "55ae0b1ed81e88357d77d0e9", key1: null, newkey: "value2"});
▸ Object { author: "demo", time: 1437469470133, newkey: "value2", _id: "55ae0b1ed81e88357d77d0e9" }
// update multiple elements
damas.update([{_id: "583ff5a747e759beb73bde32", "label":"elementA"}, {_id: "583ff5a747e759beb73bde33", "label":"elementB"}]);
▸ Array [{_id: "583ff5a747e759beb73bde32", time: 1480586663024, label: "elementA", author: "demo"}, {_id: "583ff5a747e759beb73bde33", time: 1480586663024, label: "elementB", author: "demo"}]
// update multiple elements, condensed
damas.update({_id: ["583ff5a747e759beb73bde32","583ff5a747e759beb73bde33"], "newkey":"value"});
▸ Array [{_id: "583ff5a747e759beb73bde32", time: 1480586663024, label: "elementA", author: "demo", newkey:"value"}, {_id: "583ff5a747e759beb73bde33", time: 1480586663024, label: "elementB", author: "demo", newkey:"value"}]
In Python, the None value is used to remove a key. Python
# update an element
>>> damas.update({'_id': '55ae0b1ed81e88357d77d0e9', 'key1': None, 'newkey': 'value2'})
{u'newkey': u'value2', u'time': 1437469470133, u'_id': u'55ae0b1ed81e88357d77d0e9', u'author': u'demo'}
# update multiple elements
damas.update([{'_id': '583ff5a747e759beb73bde32', 'label':'elementA'}, {'_id': '583ff5a747e759beb73bde33', 'label':'elementB'}])
[{u'_id': u'583ff5a747e759beb73bde32', u'time': 1480586663024, u'label': u'elementA', u'author': u'demo'}, {u'_id': u'583ff5a747e759beb73bde33', u'time': 1480586663024, u'label': u'elementB', u'author': u'demo'}]
# update multiple elements, condensed
damas.update({'_id': ['583ff5a747e759beb73bde32','583ff5a747e759beb73bde33'], 'newkey':'value'})
[{u'newkey': u'value', u'_id': u'583ff5a747e759beb73bde32', u'time': 1480586663024, u'label': u'elementA', u'author': u'demo'}, {u'newkey': u'value', u'_id': u'583ff5a747e759beb73bde33', u'time': 1480586663024, u'label': u'elementB', u'author': u'demo'}]
upsert
Create or update element(s) when identifier(s) are specified and found
upsert ( elements [, callback] )
parameters
elements{object | array} : object(s) to insert and/or update in the databasecallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns an object or an array of objects (depending on the input) on success
- returns
null(Javascript) orNone(Python) on failure
:warning: the returned arrays in case of created and updated elements are not in the same order as the input array but: created elements first, then updated elements.
examples
# Python
# create a new node with a specified id
>>> project.upsert({"_id":"55ae0b1ed81e88357d77d0e9"})
{u'time': 1437469470133, u'_id': u'55ae0b1ed81e88357d77d0e9', u'author': u'demo'}
# update an existing node
>>> project.upsert([{"_id":"55ae0b1ed81e88357d77d0e9", "additional_key":"value"}])
{u'additional_key': u'value', u'time': 1437469470133, u'_id': u'55ae0b1ed81e88357d77d0e9', u'author': u'demo'}
# create a new node without specifying id
>>> project.upsert({"_id":"null"})
{u'_id': u'57ae0b1ed81e88357d77d0b4', u'time': 1480586620449, u'author': u'demo'}
# create and update
>>> project.upsert([{"_id":["55ae0b1ed81e88357d77d0e9", "null"], "additional_key":"hello"}])
[{u'additional_key': u'hello', u'time': 1437469470133, u'_id': u'55ae0b1ed81e88357d77d0e9', u'author': u'demo'}, {u'additional_key': u'hello', u'_id': u'56ae0b1ed81e88357d77d0f9', u'time': 1480586620449, u'author': u'demo'}]
Javascript
// create a new node
damas.upsert({_id: "null"});
>> Object { author: "damas", time: 1480588505449, _id: "583ffcd947e759beb73bde39" }
// update a node
damas.upsert({_id: "583ffcd947e759beb73bde39", a : "test"})
>> Object { a : "test", author: "damas", time: 1480588505449, _id: "583ffcd947e759beb73bde39" }
//create and update
damas.upsert({_id: ["583ffcd947e759beb73bde39", "null"], a : "damas"})
>> Object { a : "damas", author: "damas", time: 1480588505449, _id: "583ffcd947e759beb73bde39" }
>> Object { a : "damas", author: "damas", time: 1480588505449, _id: "583ffcd947e759beb73ple85" }
// create a new node using an asynchronous call
damas.upsert({key1: "value2"}, function (node) {
// asynchronous mode
console.log(node.time);
});
delete
Permanently remove element(s) from the database
delete ( identifiers [, callback] )
parameters
identifiers{string | array} : identifier(s) to delete from the databasecallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns true on success, false otherwise
- returns a boolean or an array of booleans (depending on the input)
the returned array is sorted as the input array
examples
Javascript
damas.delete("55ae0b1ed81e88357d77d0e9");
▸ true
signin
signIn ( username, password [, expiresIn, callback] )
parameters
username{string} : the username or email stringpassword{string} : the user secret password stringexpiresIn{string} (optional) : time before a new connection is required (learn more)callback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns an object containing an authentication token on success, false otherwise
Sign in using the server embedded authentication system
Javascript
// classic authentication
damas.signIn("axel", "password");
>> Object { _id: "55ae0b1ed81e88357d77d0e9", address: "::ffff:127.0.0.1", class: "user", lastActivity: 1561237341643, lastlogin: 1561237340643, username: "axel" }
// signIn using an asynchronous call
// res is the user node (the result of authentication)
let callback = function (res) {
console.log(res);
}
damas.signIn("axel", "password", callback());
>> Object { _id: "55ae0b1ed81e88357d77d0e9", address: "::ffff:127.0.0.1", class: "user", lastActivity: 1561237341643, lastlogin: 1561237340643, username: "axel" }
// you can set token lifespan
damas.signIn("axel", "password", "1d" ,callback());
>> Object { _id: "55ae0b1ed81e88357d77d0e9", address: "::ffff:127.0.0.1", class: "user", lastActivity: 1561237341643, lastlogin: 1561237340643, username: "axel" }
signout
signOut ( [callback] )
parameters
callback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns true on success, false otherwise
verify
Ask the server for the authentication status and user
verify ( [callback] )
parameters
callback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns the authenticated user element on success, false otherwise
search
Find elements wearing the specified key(s) using a query string.
search ( query [, callback] )
parameters
query{string} : search query stringcallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
returns an array of matching identifiers or null if no match was found
format: "keyname1:value keyname2:value"
operators list:
:,<,<=,>,>=
In case of : operator, you can use a regular expression as value.
examples
Python
# list every png file containing "floor" in the file name, case insensitive
>>> damas.search("file:/floor.*png$/i")
# List every file containing the word rabbit and wearing the `type` key = `char`
>>> damas.search('file:/rabbit/ type:char')
Javascript
// list every png file containing "floor" in the file name, case insensitive
damas.search("file:/floor.*png$/i");
// List every file containing the word rabbit and wearing the `type` key = `char`
damas.search('file:/rabbit/ type:char');
search_one
Search nodes, returning the first matching occurrence as a node object (not as index as in search). The search string format is the same as for the search method.
search_one ( query [, callback] )
parameters
query{string}callback(js only, optional) if specified, the request is made asynchronous
return values
- returns the first matching identifier or null if no match was found
search_mongo
We expose the MongoDB find and cursor methods here in order to provide a powerful search with many options. It is only available when the server runs a MongoDB database to store the data.
search_mongo ( query [, sort, limit, skip, callback] )
parameters
query{object} : the query object https://docs.mongodb.org/v3.0/reference/method/db.collection.find/sort(optional) : https://docs.mongodb.org/v3.0/reference/method/cursor.sort/limit(optional) : https://docs.mongodb.org/v3.0/reference/method/cursor.limit/skip(optional) : https://docs.mongodb.org/v3.0/reference/method/cursor.skip/callback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- returns arrays of matching indexes
In order to use regular expressions, and because the JSON format only accept strings and has no type for regular expressions, we use strings with the prefix REGEX_ to indicate to the server that it must convert it to a RegExp object before executing the Mongo query. To add options to regular expressions, prefer the syntax RX_
expression_RXoptions.
For example: the /.*/ regular expression.
is written "REGEX_.*" as string format in the JSON messages
Example with case-insensitive option: /.*/i
is written "RX_.*_RXi" as string format in the JSON messages
Javascript
// Search every file paths starting with /DATABASE/02_ASSETS using a regular expression
damas.search_mongo({_id:"REGEX_/DATABASE/02_ASSETS.*"},{}, 0,0)
Python
# get the 10 most recent files (having the higher `time` key on nodes)
>> damas.search_mongo({"file":{"$exists": True}}, {"time":-1}, 10, 0)
[u'56701f266899505c6d82ffc4', u'56701e2583cfa5c16c1a2f78', u'56701b791da266d26bc11126', u'56701cf1570a32f16be5bb60', u'56701923a26510e96969e277', u'5670305b40c1a51070f3356f', u'567026b69b2d56016f663242', u'56702671a86238e76e08f600', u'56701fb92fdef89f6dcb8c6c', u'55b36829cc6742a30da59b98']
Javascript
// get the 200 last indexed files, sorted by descending time key, and display a table in html format as output
damas.search_mongo({'time': {$exists:true}}, {"time":-1},200,0, function(res){
damas.read(res, function(assets){
var out = document.querySelector('#contents');
var str = '<table><tr><th>author</th><th>file</th><th>time △</th><th>comment</th></tr>';
for(var i=0; i<assets.length; i++)
{
str += '<tr>';
str += '<td>'+assets[i].author+'</td>';
str += '<td>'+assets[i].file+'</td>';
str += '<td>'+new Date(parseInt(assets[i].time))+'</td>';
str += '<td style="white-space:normal">'+assets[i].comment+'</td>';
str += '</tr>';
}
str += '</table>';
out.innerHTML = str;
});
});
graph_backwards
Recursively get all source nodes and edges connected to the specified node
graph_backwards ( identifiers, depth, [, callback] )
parameters
identifiers{string | array} : identifier(s) string(s) to readdepth{number} : number of maximum recursions. 0 for unlimited recursionscallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- @returns {Array} array of element indexes
examples
Javascript
// retrieve the graph of an object users an array containing the elements (nodes and edges)
damas.graph_backwards("usr_marion");
graph_forwards
Recursively get all target nodes and edges connected to the specified node
graph_forwards ( identifiers, depth, [, callback] )
parameters
identifiers{string | array} : identifier(s) string(s) to readdepth{number} : number of maximum recursions. 0 for unlimited recursionscallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- @returns {Array} array of element indexes
examples
Javascript
// retrieve the graph of a user
damas.read(damas.graph_backwards("usr_marion", 0));
// same but asynchronous
damas.graph_backwards("usr_marion", 0, g => {
damas.read(g, n => {
// do something with n
})
})
graph
Recursively get all source nodes and edges connected to the specified node (deprecated, use equivalent graph_backwards instead)
graph ( identifiers, [, callback] )
parameters
identifiers{string | array} : identifier(s) string(s) to readcallback{function} (js only, optional) : if specified, the request is made asynchronous
return values
- @returns {Array} array of elements
examples
Javascript
// retrieve graph as an array containing the elements (nodes and edges)
damas.graph("55687e68e040af7047ee1a53");