Skip to content

Commit

Permalink
Merge c719505 into a09e4dc
Browse files Browse the repository at this point in the history
  • Loading branch information
@erossignon
erossignon committed Aug 29, 2022
2 parents a09e4dc + c719505 commit 68d7e63
Show file tree
Hide file tree
Showing 149 changed files with 1,491 additions and 1,780 deletions.
4 changes: 2 additions & 2 deletions code_gen/generate_status_code.js
View file
Expand Up @@ -3,11 +3,11 @@
*
*/
const util = require("util");
const xml = require("ersatz-node-expat");
const fs = require("fs");
const path = require("path");
const xml = require("ersatz-node-expat");
const csv = require("csv");
const sprintf = require("sprintf-js").sprintf;
const { sprintf }= require("sprintf-js");


// see OPC-UA Part 6 , A2
Expand Down
271 changes: 126 additions & 145 deletions documentation/sample_client.js
View file
@@ -1,174 +1,155 @@
const { OPCUAClient, makeBrowsePath, AttributeIds, resolveNodeId, TimestampsToReturn} = require("node-opcua");
const async = require("async");
const { hostname } = require("os");
const async = require("async");
const { OPCUAClient, makeBrowsePath, AttributeIds, resolveNodeId, TimestampsToReturn } = require("node-opcua");

// const endpointUrl = "opc.tcp://<hostname>:4334/UA/MyLittleServer";
const endpointUrl = "opc.tcp://" + require("os").hostname() + ":4334/UA/MyLittleServer";
const client = OPCUAClient.create({
endpointMustExist: false
});
client.on("backoff", (retry, delay) =>
console.log(
"still trying to connect to ",
endpointUrl,
": retry =",
retry,
"next attempt in ",
delay / 1000,
"seconds"
)
);
// const endpointUrl = "opc.tcp://<hostname>:4334/UA/MyLittleServer";
const endpointUrl = "opc.tcp://" + hostname() + ":4334/UA/MyLittleServer";
const client = OPCUAClient.create({
endpointMustExist: false
});
client.on("backoff", (retry, delay) =>
console.log("still trying to connect to ", endpointUrl, ": retry =", retry, "next attempt in ", delay / 1000, "seconds")
);


let the_session, the_subscription;

async.series([

let the_session, the_subscription;

async.series(
[
// step 1 : connect to
function(callback) {
client.connect(endpointUrl, function(err) {
if (err) {
console.log(" cannot connect to endpoint :", endpointUrl);
} else {
console.log("connected !");
}
callback(err);
function (callback) {
client.connect(endpointUrl, function (err) {
if (err) {
console.log(" cannot connect to endpoint :", endpointUrl);
} else {
console.log("connected !");
}
callback(err);
});
},

// step 2 : createSession
function(callback) {
client.createSession(function(err, session) {
if (err) {
return callback(err);
}
the_session = session;
callback();
function (callback) {
client.createSession(function (err, session) {
if (err) {
return callback(err);
}
the_session = session;
callback();
});
},

// step 3 : browse
function(callback) {
the_session.browse("RootFolder", function(err, browseResult) {
if (!err) {
console.log("Browsing rootfolder: ");
for (let reference of browseResult.references) {
console.log(reference.browseName.toString(), reference.nodeId.toString());
}
}
callback(err);
});
function (callback) {
the_session.browse("RootFolder", function (err, browseResult) {
if (!err) {
console.log("Browsing rootfolder: ");
for (let reference of browseResult.references) {
console.log(reference.browseName.toString(), reference.nodeId.toString());
}
}
callback(err);
});
},

// step 4 : read a variable with readVariableValue
function(callback) {
the_session.read({nodeId: "ns=1;s=free_memory", attributeId: AttributeIds.Value}, (err, dataValue) => {
if (!err) {
console.log(" free mem % = ", dataValue.toString());
}
callback(err);
});
function (callback) {
the_session.read({ nodeId: "ns=1;s=free_memory", attributeId: AttributeIds.Value }, (err, dataValue) => {
if (!err) {
console.log(" free mem % = ", dataValue.toString());
}
callback(err);
});
},

// step 4' : read a variable with read
function(callback) {
const maxAge = 0;
const nodeToRead = {
nodeId: "ns=1;s=free_memory",
attributeId: AttributeIds.Value
};
the_session.read(nodeToRead, maxAge, function(err, dataValue) {
if (!err) {
console.log(" free mem % = ", dataValue.toString());
}
callback(err);
});
function (callback) {
const maxAge = 0;
const nodeToRead = {
nodeId: "ns=1;s=free_memory",
attributeId: AttributeIds.Value
};

the_session.read(nodeToRead, maxAge, function (err, dataValue) {
if (!err) {
console.log(" free mem % = ", dataValue.toString());
}
callback(err);
});
},

// step 5: install a subscription and install a monitored item for 10 seconds
function(callback) {
const subscriptionOptions = {
maxNotificationsPerPublish: 1000,
publishingEnabled: true,
requestedLifetimeCount: 100,
requestedMaxKeepAliveCount: 10,
requestedPublishingInterval: 1000
};
the_session.createSubscription2(subscriptionOptions, (err, subscription) => {
if (err) {
return callback(err);
}

the_subscription = subscription;

the_subscription
.on("started", () => {
console.log(
"subscription started for 2 seconds - subscriptionId=",
the_subscription.subscriptionId
);
})
.on("keepalive", function() {
console.log("subscription keepalive");
})
.on("terminated", function() {
console.log("terminated");
});
callback();
});
function (callback) {
const subscriptionOptions = {
maxNotificationsPerPublish: 1000,
publishingEnabled: true,
requestedLifetimeCount: 100,
requestedMaxKeepAliveCount: 10,
requestedPublishingInterval: 1000
};
the_session.createSubscription2(subscriptionOptions, (err, subscription) => {
if (err) {
return callback(err);
}

the_subscription = subscription;

the_subscription
.on("started", () => {
console.log("subscription started for 2 seconds - subscriptionId=", the_subscription.subscriptionId);
})
.on("keepalive", function () {
console.log("subscription keepalive");
})
.on("terminated", function () {
console.log("terminated");
});
callback();
});
},
function(callback) {
// install monitored item
const itemToMonitor = {
nodeId: resolveNodeId("ns=1;s=free_memory"),
attributeId: AttributeIds.Value
};
const monitoringParamaters = {
samplingInterval: 100,
discardOldest: true,
queueSize: 10
};

the_subscription.monitor(
itemToMonitor,
monitoringParamaters,
TimestampsToReturn.Both,
(err, monitoredItem) => {
monitoredItem.on("changed", function(dataValue) {
console.log(
"monitored item changed: % free mem = ",
dataValue.value.value
);
});
callback();
}
);
console.log("-------------------------------------");
function (callback) {
// install monitored item
const itemToMonitor = {
nodeId: resolveNodeId("ns=1;s=free_memory"),
attributeId: AttributeIds.Value
};
const monitoringParamaters = {
samplingInterval: 100,
discardOldest: true,
queueSize: 10
};

the_subscription.monitor(itemToMonitor, monitoringParamaters, TimestampsToReturn.Both, (err, monitoredItem) => {
monitoredItem.on("changed", function (dataValue) {
console.log("monitored item changed: % free mem = ", dataValue.value.value);
});
callback();
});
console.log("-------------------------------------");
},
function(callback) {
function (callback) {
// wait a little bit : 10 seconds
setTimeout(()=>callback(), 10*1000);
setTimeout(() => callback(), 10 * 1000);
},
// terminate session
function(callback) {
the_subscription.terminate(callback);;
function (callback) {
the_subscription.terminate(callback);
},
// close session
function(callback) {
the_session.close(function(err) {
if (err) {
console.log("closing session failed ?");
}
callback();
function (callback) {
the_session.close(function (err) {
if (err) {
console.log("closing session failed ?");
}
callback();
});
}

],
function(err) {
function (err) {
if (err) {
console.log(" failure ",err);
console.log(" failure ", err);
} else {
console.log("done!");
}
client.disconnect(function(){});
}) ;
client.disconnect(function () {});
}
);

0 comments on commit 68d7e63

Please sign in to comment.