Za/data access

.github/workflows/publish.yml

@@ -224,6 +224,7 @@ jobs:
           - acs-admin
           - acs-cluster-manager
           - acs-cmdesc
+          - acs-data-access
           - acs-edge-sync
           - acs-files
           - acs-git

Makefile

@@ -42,6 +42,7 @@ subdirs+= acs-auth
 subdirs+= acs-cluster-manager
 subdirs+= acs-cmdesc
 subdirs+= acs-configdb
+subdirs+= acs-data-access
 subdirs+= acs-directory
 subdirs+= acs-edge
 subdirs+= acs-edge-sync
@@ -67,4 +68,5 @@ subdirs+= historian-sparkplug
 subdirs+= historian-uns
 subdirs+= uns-ingester-sparkplug
 
+
 include ${mk}/acs.subdirs.mk

acs-data-access/.dockerignore

@@ -0,0 +1 @@
+node_modules/

acs-data-access/.gitignore

@@ -0,0 +1,3 @@
+.env
+node_modules/
+tmp/

acs-data-access/Dockerfile

@@ -0,0 +1,32 @@
+ARG base_version
+ARG base_prefix=ghcr.io/amrc-factoryplus/acs-base
+
+FROM ${base_prefix}-js-build:${base_version} AS build
+ARG acs_npm=NO
+
+# Install the node application on the build container where we can
+# compile the native modules.
+RUN install -d -o node -g node /home/node/app \
+    && mkdir /home/node/lib
+COPY --from=lib . /home/node/lib/
+
+WORKDIR /home/node/app
+USER node
+COPY package*.json ./
+RUN <<'SHELL'
+    touch /home/node/.npmrc
+    npm install --save=false --install-links
+SHELL
+COPY --chown=node . .
+RUN <<'SHELL'
+    echo "export const GIT_VERSION=\"$revision\";" > ./lib/git-version.js
+SHELL
+
+FROM ${base_prefix}-js-run:${base_version}
+
+# Copy across from the build container.
+WORKDIR /home/node/app
+COPY --from=build --chown=root:root /home/node/app ./
+
+USER node
+CMD node bin/api.js

acs-data-access/Makefile

@@ -0,0 +1,7 @@
+top=..
+include ${top}/mk/acs.init.mk
+
+repo?=acs-data-access
+k8s.deployment?=data-access
+
+include ${mk}/acs.js.mk

acs-data-access/bin/api.js

@@ -0,0 +1,95 @@
+#!/usr/bin/env node
+
+/*
+* ACS Data Access Service
+* Entry point: api.js
+*/
+
+import {InfluxDB, flux} from '@influxdata/influxdb-client';
+
+import { RxClient, UUIDs } from '@amrc-factoryplus/rx-client';
+import { WebAPI } from '@amrc-factoryplus/service-api';
+import {DataFlow} from '../lib/dataflow.js';
+import { APIv1 } from '../lib/api-v1.js';
+import {DataAccessNotify} from '../lib/notify.js';
+import { InfluxReader } from '../lib/influx-reader.js';
+
+const { env } = process;
+
+const fplus = await new RxClient({
+  env,
+}).init();
+
+const Version = "2.0.0";
+
+const debug = fplus.debug;
+debug.log("app", "Starting acs-data-service revision %s");
+
+const influxClient = new InfluxDB({
+  url: env.INFLUXDB_URL,
+  token: env.INFLUXDB_TOKEN
+});
+
+
+// the dataflow object is full of sequences that does most of the work of this service. Sequence means an RX observable.
+const data = new DataFlow({
+  debug,
+  cdb: fplus.ConfigDB,
+  auth: fplus.Auth,
+});
+
+const influxReader = new InfluxReader({
+  debug,
+  influx_client: influxClient,
+  influx_org: env.INFLUXDB_ORG,
+  influx_bucket: env.INFLUXDB_BUCKET,
+})
+
+const apiv1 = new APIv1({ 
+  data,
+  debug,
+  auth: fplus.Auth,
+  cdb: fplus.ConfigDB,
+  influxReader
+});
+
+const api = await new WebAPI({
+  debug: fplus.debug,
+  ping: {
+    version: Version,
+    service: UUIDs.Service.DataAccess,
+    software: {
+      vendor: 'AMRC',
+      application: 'acs-data-access',
+    },
+  },
+  realm: env.REALM,
+  hostname: env.HOSTNAME,
+  keytab: env.SERVER_KEYTAB,
+  http_port: env.PORT,
+  max_age: env.CACHE_MAX_AGE,
+  routes: app => {
+    app.use("/v1", apiv1.routes);
+  }
+
+}).init();
+
+
+const notify = new DataAccessNotify({
+  api, data, debug,
+  auth: fplus.Auth
+});
+
+debug.log("app", "Running Data Access DataFlow");
+data.run();
+
+debug.log("app", "Running Data Access Notify");
+notify.run();
+
+debug.log("app", "Running Data Access WebAPI")
+api.run();
+
+
+
+
+