Add in-tree Bacnet driver (#344)

.github/workflows/publish.yml

@@ -209,6 +209,7 @@ jobs:
           - acs-edge
           - edge-modbus
           - edge-test
+          - edge-bacnet
     permissions:
       contents: read
       packages: write

edge-bacnet/.gitignore

@@ -0,0 +1,2 @@
+node_modules
+tmp

edge-bacnet/Dockerfile

@@ -0,0 +1,33 @@
+# syntax=docker/dockerfile:1
+
+FROM node:22-alpine AS build
+ARG acs_npm=NO
+ARG revision=unknown
+
+USER root
+RUN <<'SHELL'
+    install -d -o node -g node /home/node/app
+SHELL
+WORKDIR /home/node/app
+USER node
+COPY package*.json ./
+RUN <<'SHELL'
+    touch /home/node/.npmrc
+    if [ "${acs_npm}" != NO ]
+    then
+        npm config set @amrc-factoryplus:registry "${acs_npm}"
+    fi
+
+    npm install --save=false
+SHELL
+COPY --chown=node . .
+RUN <<'SHELL'
+    echo "export const GIT_VERSION=\"$revision\";" > ./lib/git-version.js
+SHELL
+
+FROM node:22-alpine AS run
+# Copy across from the build container.
+WORKDIR /home/node/app
+COPY --from=build --chown=root:root /home/node/app ./
+USER node
+CMD node bin/driver.js

edge-bacnet/Makefile

@@ -0,0 +1,6 @@
+top=..
+include ${top}/mk/acs.init.mk
+
+repo?=edge-bacnet
+
+include ${mk}/acs.js.mk

edge-bacnet/bin/driver.js

@@ -0,0 +1,14 @@
+/* AMRC Connectivity Stack
+ * Modbus Edge Agent driver
+ * Copyright 2024 AMRC
+ */
+
+import { PolledDriver } from "@amrc-factoryplus/edge-driver";
+import { BacnetHandler } from "../lib/bacnet.js";
+
+const drv = new PolledDriver({
+    env:        process.env,
+    handler:    BacnetHandler,
+    serial:     true,
+});
+drv.run();

edge-bacnet/lib/bacnet.js

@@ -0,0 +1,83 @@
+/* AMRC Connectivity Stack
+ * Modbus Edge Agent driver
+ * Copyright 2024 AMRC
+ */
+
+import bacnet from 'node-bacnet';
+import { BufferX } from '@amrc-factoryplus/edge-driver'
+
+export class BacnetHandler {
+  constructor (driver, conf) {
+    this.driver = driver
+    this.conf   = conf
+    this.log = driver.debug.bound('bacnet')
+
+    const {
+            listenInterface,
+            port,
+            broadcastAddress,
+            apduTimeout,
+          } = conf
+
+    this.client = new bacnet({
+      port: port,
+      interface: listenInterface,
+      broadcastAddress: broadcastAddress,
+      apduTimeout: apduTimeout,
+    })
+  }
+
+  static create (driver, conf) {
+    return new BacnetHandler(driver, conf)
+  }
+
+  connect () {
+    // This is a stateless protocol, so we don't need to wait for
+    // the connection to be established
+    return 'UP'
+  }
+
+  parseAddr (spec) {
+
+    const parts = spec.split(',')
+
+    // If there are three parts, then the last one is the propertyID. If
+    // it is missing then the propertyId is 85
+
+    const type = Number.parseInt(parts[0])
+    if (Number.isNaN(type) || type < 0) return
+
+    const instance = Number.parseInt(parts[1])
+    if (Number.isNaN(instance) || instance < 0) return
+
+    const propertyId = Number.parseInt(parts[2] || '85')
+
+    return {
+      type,
+      instance,
+      propertyId,
+    }
+  }
+
+  async poll (addr) {
+    const { client } = this
+
+    return new Promise((resolve, reject) => {
+
+      // XXX - It would be nice to support readPropertyMultiple in the
+      // future when the driver library supports it
+      client.readProperty(this.conf.host, {
+        type: addr.type,
+        instance: addr.instance,
+      }, addr.propertyId, (err, value) => {
+        if (err) {
+          resolve(undefined)
+        }
+        else {
+          const buffer = BufferX.fromJSON(value.values[0])
+          resolve(buffer)
+        }
+      })
+    })
+  }
+}