Managing Datapoint Connections

Connection objects support direct data flow from source datapoints to destination datapoints. IAP supports datapoint connections of one or more data sources to one or more data destinations. See Connections and Connection Types for a description of connections and connection types, including peer-to-peer connections used in the IAP/MQ example.

The following example shows a peer-to-peer connection created between two datapoints identified by the sources and destinations properties. The example includes the following steps:

Specify the connection topic on the request channel. You will need to specify the appropriate SID and Connection Handle.
Specify the source and destination for the create action payload. In this example, the source and destination are two datapoint values.
Publish the connection, which involves publishing the connection topic and the create action payload.
Specify the provision action payload.
Provision the connection, which involves publishing the connection topic with the provision action as the payload.

IAP/MQ Example

Syntax for the Connection topic: glp/0/{SID}/(rq|fb)/con/{Handle}/{object}

function CreateConnection () {

// Specify connection topic
let topic = 'glp/0/' + SID + '/rq/con/' + myConnection + '/do';

// Specify payload sources and destinations
    let payld = '{"action": "create", "args": {
                   "sources“:["glp/0/T6tWyfG/fb/dev/lon/9/if/Switch/0/nvoValue/value"],
                   "destinations": ["glp/0/T6tWyfG/rq/dev/lon/9/if/Lamp/0/nviValue/value“]
                   }}';
mqttClient.publish(topic, payld);

// Provision connection
let payld = '{"action": "provision"}';
mqttClient.publish(topic, payld);
}

/* jshint esversion: 6 */
/* jslint node: true, maxerr: 10000 */

"use strict";

const mqtt = require("mqtt");
const client = mqtt.connect("mqtt://localhost:1883");
const SID = "17q3ak7"; // SID to be used in the topics

function publishAction(
connectionHandle, action, args
) {

// do topic used for publishing action - glp/0/SID/rq/con/H/do where H is the connection handle

let topic = "glp/0/" + SID + "/rq/con/" + connectionHandle + "/do";

     let actionObj = {
          "action": action
     };
     if (args) {
          actionObj.args = args;
     }
     client.publish(topic, JSON.stringify(actionObj));
}

client.on("connect", function () {

// Specify payload sources and destinations

     let createConArgs = {
        "sources": ["glp/0/" + SID + "/fb/dev/lon/9/if/Switch/0/nvoValue/value"],
        "destinations": ["glp/0/" + SID + "/rq/dev/lon/9/if/Lamp/0/nviValue/value"]
    };

// create a connection

    publishAction(
        "test_con", "create", createConArgs
    );

// provision a connection

    publishAction(
        "test_con", "provision"
    );
    client.end();
});