znetsixe
7fdab73ba0
Encrypts the Grafana bearer token via Node-RED credentials block instead of plain config (F-11). Adds folderUid config field threaded through to the buildUpsertRequest payload (F-8, resolves PRD O-5). Migration path: legacy plain bearerToken still loads, with one-time warn() prompting user to re-save. Composition + URL + headers + per-instance UID were already in place; only the credentials + folderUid + tests are new. - dashboardAPI.html: bearerToken moved to credentials block; folderUid added. - dashboardAPI.js: registerType options pass credentials descriptor. - src/nodeClass.js: read token from node.credentials; legacy fallback warns. - src/specificClass.js: buildUpsertRequest emits folderUid when set. - src/commands/handlers.js: pass folderUid from config to buildUpsertRequest. - test/basic/slice34-credentials-and-folder.basic.test.js: 5 new tests. Diff-based regeneration (F-1) and the explicit flows:started lifecycle hook land in #36 once the S1 spike predicate is wired. Until then, the existing child.register message trigger continues to drive composition on every startup-time child registration. Closes #34
87 lines
2.9 KiB
JavaScript
87 lines
2.9 KiB
JavaScript
'use strict';
|
|
|
|
// dashboardAPI nodeClass — passive HTTP-emitter adapter.
|
|
//
|
|
// Does NOT extend BaseNodeAdapter: dashboardAPI has no generalFunctions
|
|
// config JSON, no Port-0/1 telemetry stream, no parent registration, no
|
|
// tick or status loop. It just listens for `child.register` and emits one
|
|
// Grafana upsert HTTP request per dashboard. See OPEN_QUESTIONS.md
|
|
// (2026-05-10) for the rationale.
|
|
|
|
const { configManager, createRegistry } = require('generalFunctions');
|
|
const DashboardApi = require('./specificClass');
|
|
const commands = require('./commands');
|
|
|
|
class nodeClass {
|
|
constructor(uiConfig, RED, nodeInstance, nameOfNode) {
|
|
this.node = nodeInstance;
|
|
this.RED = RED;
|
|
this.name = nameOfNode;
|
|
|
|
this.config = this._buildConfig(uiConfig);
|
|
this.source = new DashboardApi(this.config);
|
|
this.node.source = this.source;
|
|
|
|
this._commands = createRegistry(commands, { logger: this.source?.logger });
|
|
|
|
this._attachInputHandler();
|
|
this._attachCloseHandler();
|
|
}
|
|
|
|
_buildConfig(uiConfig) {
|
|
const cfgMgr = new configManager();
|
|
// Credentials block (Node-RED encrypts at rest in flow_cred.json). Legacy
|
|
// installs may still carry bearerToken on uiConfig — fall back with a
|
|
// one-time deprecation warning so the user knows to re-save.
|
|
const credentialToken = this.node?.credentials?.bearerToken || '';
|
|
const legacyToken = uiConfig.bearerToken || '';
|
|
if (!credentialToken && legacyToken) {
|
|
this.RED?.log?.warn?.(
|
|
`[${this.name}] bearer token loaded from legacy plain config field. ` +
|
|
`Re-open this node in the editor and click Done to migrate to encrypted credentials.`
|
|
);
|
|
}
|
|
const bearerToken = credentialToken || legacyToken;
|
|
return cfgMgr.buildConfig(this.name, uiConfig, this.node.id, {
|
|
functionality: {
|
|
softwareType: this.name.toLowerCase(),
|
|
role: 'auto ui generator',
|
|
},
|
|
grafanaConnector: {
|
|
protocol: uiConfig.protocol || 'http',
|
|
host: uiConfig.host || 'localhost',
|
|
port: Number(uiConfig.port || 3000),
|
|
bearerToken,
|
|
folderUid: uiConfig.folderUid || '',
|
|
},
|
|
defaultBucket: uiConfig.defaultBucket || process.env.INFLUXDB_BUCKET || '',
|
|
});
|
|
}
|
|
|
|
_attachInputHandler() {
|
|
this.node.on('input', async (msg, send, done) => {
|
|
try {
|
|
await this._commands.dispatch(msg, this.source, {
|
|
node: this.node,
|
|
RED: this.RED,
|
|
send,
|
|
logger: this.source?.logger,
|
|
});
|
|
if (typeof done === 'function') done();
|
|
} catch (error) {
|
|
this.node.status({ fill: 'red', shape: 'ring', text: 'dashboardapi error' });
|
|
this.node.error(error?.message || error, msg);
|
|
if (typeof done === 'function') done(error);
|
|
}
|
|
});
|
|
}
|
|
|
|
_attachCloseHandler() {
|
|
this.node.on('close', (done) => {
|
|
if (typeof done === 'function') done();
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = nodeClass;
|