chore: added test

Author: kirrg001

packages/collector/test/apps/agentStub.js

@@ -46,6 +46,7 @@ const ignoreEndpoints = process.env.IGNORE_ENDPOINTS && JSON.parse(process.env.I
 const disable = process.env.AGENT_DISABLE_TRACING && JSON.parse(process.env.AGENT_DISABLE_TRACING);
 
 const uuids = {};
+const agentLogs = [];
 let discoveries = {};
 let rejectAnnounceAttempts = 0;
 let requests = {};
@@ -136,6 +137,16 @@ app.head(
   })
 );
 
+app.post('/com.instana.agent.logger', (req, res) => {
+  logger.info('Received log message from agent: %j', req.body);
+  agentLogs.push(req.body);
+  res.sendStatus(200);
+});
+
+app.get('/agent/logs', (req, res) => {
+  res.json(agentLogs);
+});
+
 app.post(
   '/com.instana.plugin.nodejs.:pid',
   checkExistenceOfKnownPid(function handleEntityData(req, res) {

packages/collector/test/apps/agentStubControls.js

@@ -175,6 +175,15 @@ class AgentStubControls {
     });
   }
 
+  getAgentLogs() {
+    return fetch(`http://127.0.0.1:${this.agentPort}/agent/logs`, {
+      method: 'GET',
+      headers: {
+        'Content-Type': 'application/json'
+      }
+    }).then(response => response.json());
+  }
+
   async reset() {
     // eslint-disable-next-line no-console
     console.log(`[AgentStubControls] reset ${this.agentPort}`);

packages/collector/test/tracing/misc/agent-logs/app.js

@@ -0,0 +1,44 @@
+/*
+ * (c) Copyright IBM Corp. 20215
+ */
+
+'use strict';
+
+// NOTE: c8 bug https://github.com/bcoe/c8/issues/166
+process.on('SIGTERM', () => {
+  process.disconnect();
+  process.exit(0);
+});
+
+const agentPort = process.env.INSTANA_AGENT_PORT;
+
+require('../../../..')({
+  // NOTE: The test env mutes all logs by default. No logs, no agent logs.
+  level: 'info'
+});
+
+const express = require('express');
+const port = require('../../../test_util/app-port')();
+const app = express();
+
+const logPrefix = `Agent Logs App (${process.pid}):\t`;
+
+app.get('/', (req, res) => {
+  res.send();
+});
+
+app.get('/trace', async (req, res) => {
+  await fetch(`http://127.0.0.1:${agentPort}`);
+  res.send();
+});
+
+app.listen(port, () => {
+  log(`Listening on port: ${port}`);
+});
+
+function log() {
+  /* eslint-disable no-console */
+  const args = Array.prototype.slice.call(arguments);
+  args[0] = logPrefix + args[0];
+  console.log.apply(console, args);
+}

packages/collector/test/tracing/misc/agent-logs/test.js

@@ -0,0 +1,55 @@
+/*
+ * (c) Copyright IBM Corp. 2025
+ */
+
+'use strict';
+
+const { expect } = require('chai');
+const supportedVersion = require('@instana/core').tracing.supportedVersion;
+const config = require('../../../../../core/test/config');
+const testUtils = require('../../../../../core/test/test_util');
+const ProcessControls = require('../../../test_util/ProcessControls');
+const globalAgent = require('../../../globalAgent');
+const agentControls = globalAgent.instance;
+
+const mochaSuiteFn = supportedVersion(process.versions.node) ? describe : describe.skip;
+
+mochaSuiteFn('tracing/agent logs', function () {
+  this.timeout(config.getTestTimeout());
+  globalAgent.setUpCleanUpHooks();
+
+  describe('Ensure agent logs are transmitted', function () {
+    let controls;
+
+    before(async () => {
+      controls = new ProcessControls({
+        dirname: __dirname,
+        useGlobalAgent: true
+      });
+
+      await controls.startAndWaitForAgentConnection();
+    });
+
+    beforeEach(async () => {
+      await agentControls.clearReceivedTraceData();
+    });
+
+    after(async () => {
+      await controls.stop();
+    });
+
+    it('expect agent logs data', async () => {
+      await controls.sendRequest({
+        path: '/trace'
+      });
+
+      await testUtils.retry(async () => {
+        const spans = await agentControls.getSpans();
+        const agentLogs = await agentControls.getAgentLogs();
+
+        expect(spans.length).to.equal(2);
+        expect(agentLogs.length).to.equal(9);
+      });
+    });
+  });
+});