feat: Add new unit tests

Signed-off-by: Pascal Zimmermann <pascal.zimmermann@theiotstudio.com>

Author: ZPascal

influxdb/jest.config.ts

@@ -1,7 +1,22 @@
-import type { Config } from 'jest';
-import sharedConfig from '../jest.shared';
-const config: Config = {
-  ...sharedConfig,
-  displayName: 'influxdb',
+const path = require('path');
+const fs = require('fs');
+
+// Read and parse the shared jest config inline to avoid module resolution issues
+const swcrcPath = path.join(__dirname, '..', '.cjs.swcrc');
+const swcrc = JSON.parse(fs.readFileSync(swcrcPath, 'utf-8'));
+
+module.exports = {
+  testEnvironment: 'jsdom',
+  roots: ['<rootDir>/src'],
+  moduleNameMapper: {
+    '^echarts/(.*)$': 'echarts',
+    '^use-resize-observer$': 'use-resize-observer/polyfilled',
+    '\\.(css|less)$': '<rootDir>/../stylesMock.js',
+  },
+  transformIgnorePatterns: ['node_modules/(?!(lodash-es|yaml))'],
+  transform: {
+    '^.+\\.(ts|tsx|js|jsx)$': ['@swc/jest', { ...swcrc, exclude: [], swcrc: false }],
+  },
+  setupFilesAfterEnv: ['<rootDir>/src/setup-tests.ts'],
 };
-export default config;
+

influxdb/src/setup-tests.ts

@@ -0,0 +1,17 @@
+// Copyright The Perses Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+import '@testing-library/jest-dom';
+
+// Always mock e-charts during tests since we don't have a proper canvas in jsdom
+jest.mock('echarts');

influxdb/src/test/ExposeModules.test.ts

@@ -0,0 +1,45 @@
+// Copyright The Perses Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+import * as InfluxDBDatasourceModule from '../datasource/influxdb/InfluxDBDatasource';
+import * as InfluxDBTimeSeriesQueryModule from '../queries/influxdb-time-series-query/InfluxDBTimeSeriesQuery';
+
+describe('Module Federation Expose Modules', () => {
+  describe('InfluxDBDatasource.ts', () => {
+    it('should export default InfluxDBDatasource', () => {
+      expect(InfluxDBDatasourceModule.default).toBeDefined();
+      expect(InfluxDBDatasourceModule.default).toHaveProperty('createClient');
+    });
+
+    it('should have all required datasource properties', () => {
+      const datasource = InfluxDBDatasourceModule.default;
+      expect(datasource).toHaveProperty('createClient');
+      expect(datasource).toHaveProperty('createInitialOptions');
+      expect(datasource).toHaveProperty('OptionsEditorComponent');
+    });
+  });
+
+  describe('influxdb-time-series-query.ts', () => {
+    it('should export default InfluxDBTimeSeriesQuery', () => {
+      expect(InfluxDBTimeSeriesQueryModule.default).toBeDefined();
+      expect(InfluxDBTimeSeriesQueryModule.default).toHaveProperty('getTimeSeriesData');
+    });
+
+    it('should have all required query properties', () => {
+      const query = InfluxDBTimeSeriesQueryModule.default;
+      expect(query).toHaveProperty('getTimeSeriesData');
+      expect(query).toHaveProperty('createInitialOptions');
+      expect(query).toHaveProperty('OptionsEditorComponent');
+    });
+  });
+});

influxdb/src/test/InfluxDBDatasource.test.ts

@@ -0,0 +1,79 @@
+// Copyright The Perses Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+import { InfluxDBDatasource, InfluxDBSpec } from '../datasource/influxdb/InfluxDBDatasource';
+
+describe('InfluxDBDatasource', () => {
+  it('should have createClient method', () => {
+    expect(InfluxDBDatasource).toHaveProperty('createClient');
+    expect(typeof InfluxDBDatasource.createClient).toBe('function');
+  });
+
+  it('should have OptionsEditorComponent', () => {
+    expect(InfluxDBDatasource).toHaveProperty('OptionsEditorComponent');
+  });
+
+  it('should have createInitialOptions method', () => {
+    expect(InfluxDBDatasource).toHaveProperty('createInitialOptions');
+    expect(typeof InfluxDBDatasource.createInitialOptions).toBe('function');
+  });
+
+  it('should create initial options with version and database', () => {
+    const initialOptions = InfluxDBDatasource.createInitialOptions();
+    expect(initialOptions).toEqual({
+      version: 'v1',
+      database: '',
+    });
+  });
+
+  it('should throw error when no URL is provided', () => {
+    const spec: InfluxDBSpec = {
+      version: 'v1',
+      database: 'testdb',
+    };
+    const options = {
+      proxyUrl: undefined,
+    };
+
+    expect(() => {
+      InfluxDBDatasource.createClient(spec, options);
+    }).toThrow('No URL specified for InfluxDB client');
+  });
+
+  it('should use directUrl when provided', () => {
+    const spec: InfluxDBSpec = {
+      version: 'v1',
+      database: 'testdb',
+      directUrl: 'http://localhost:8086',
+    };
+    const options = {
+      proxyUrl: 'http://proxy:8086',
+    };
+
+    const client = InfluxDBDatasource.createClient(spec, options);
+    expect(client.options.datasourceUrl).toBe('http://localhost:8086');
+  });
+
+  it('should fall back to proxyUrl when directUrl is not provided', () => {
+    const spec: InfluxDBSpec = {
+      version: 'v1',
+      database: 'testdb',
+    };
+    const options = {
+      proxyUrl: 'http://proxy:8086',
+    };
+
+    const client = InfluxDBDatasource.createClient(spec, options);
+    expect(client.options.datasourceUrl).toBe('http://proxy:8086');
+  });
+});

influxdb/src/test/InfluxDBPluginIntegration.test.ts

@@ -0,0 +1,116 @@
+// Copyright The Perses Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+import { getPluginModule } from '../getPluginModule';
+import packageJson from '../../package.json';
+
+interface PluginSpec {
+  kind: string;
+  spec: {
+    name: string;
+    display: {
+      name: string;
+    };
+  };
+}
+
+describe('InfluxDB Plugin Integration', () => {
+  describe('Plugin Module Resource', () => {
+    it('should return valid PluginModuleResource', () => {
+      const pluginModule = getPluginModule();
+      expect(pluginModule.kind).toBe('PluginModule');
+    });
+
+    it('should have correct metadata from package.json', () => {
+      const pluginModule = getPluginModule();
+      expect(pluginModule.metadata.name).toBe(packageJson.name);
+      expect(pluginModule.metadata.version).toBe(packageJson.version);
+    });
+
+    it('should include all plugins from package.json perses config', () => {
+      const pluginModule = getPluginModule();
+      const expectedPlugins = packageJson.perses.plugins;
+      expect(pluginModule.spec.plugins).toEqual(expectedPlugins);
+    });
+
+    it('should have correct plugin kinds', () => {
+      const pluginModule = getPluginModule();
+      const pluginKinds = pluginModule.spec.plugins.map((p: PluginSpec) => p.kind);
+      expect(pluginKinds).toContain('Datasource');
+      expect(pluginKinds).toContain('TimeSeriesQuery');
+    });
+
+    it('should have correct plugin names', () => {
+      const pluginModule = getPluginModule();
+      const pluginNames = pluginModule.spec.plugins.map((p: PluginSpec) => p.spec.name);
+      expect(pluginNames).toContain('InfluxDBDatasource');
+      expect(pluginNames).toContain('InfluxDBTimeSeriesQuery');
+    });
+  });
+
+  describe('Plugin Metadata', () => {
+    it('should have display names for all plugins', () => {
+      const pluginModule = getPluginModule();
+      pluginModule.spec.plugins.forEach((plugin: PluginSpec) => {
+        expect(plugin.spec.display).toBeDefined();
+        expect(plugin.spec.display.name).toBeDefined();
+        expect(plugin.spec.display.name).toBeTruthy();
+      });
+    });
+
+    it('should have valid plugin specifications', () => {
+      const pluginModule = getPluginModule();
+      pluginModule.spec.plugins.forEach((plugin: PluginSpec) => {
+        expect(plugin.kind).toBeTruthy();
+        expect(plugin.spec).toBeDefined();
+        expect(plugin.spec.name).toBeDefined();
+      });
+    });
+  });
+
+  describe('Datasource Plugin Configuration', () => {
+    it('should have InfluxDB Datasource configured', () => {
+      const pluginModule = getPluginModule();
+      const datasourcePlugin = pluginModule.spec.plugins.find(
+        (p: PluginSpec) => p.kind === 'Datasource' && p.spec.name === 'InfluxDBDatasource'
+      );
+      expect(datasourcePlugin).toBeDefined();
+    });
+
+    it('should have correct Datasource display name', () => {
+      const pluginModule = getPluginModule();
+      const datasourcePlugin = pluginModule.spec.plugins.find(
+        (p: PluginSpec) => p.kind === 'Datasource' && p.spec.name === 'InfluxDBDatasource'
+      );
+      expect(datasourcePlugin?.spec.display.name).toBe('InfluxDB Datasource');
+    });
+  });
+
+  describe('TimeSeriesQuery Plugin Configuration', () => {
+    it('should have TimeSeriesQuery plugin configured', () => {
+      const pluginModule = getPluginModule();
+      const queryPlugin = pluginModule.spec.plugins.find(
+        (p: PluginSpec) => p.kind === 'TimeSeriesQuery' && p.spec.name === 'InfluxDBTimeSeriesQuery'
+      );
+      expect(queryPlugin).toBeDefined();
+    });
+
+    it('should have correct TimeSeriesQuery display name', () => {
+      const pluginModule = getPluginModule();
+      const queryPlugin = pluginModule.spec.plugins.find(
+        (p: PluginSpec) => p.kind === 'TimeSeriesQuery' && p.spec.name === 'InfluxDBTimeSeriesQuery'
+      );
+      expect(queryPlugin?.spec.display.name).toBe('InfluxDB Time Series Query');
+    });
+  });
+});

influxdb/src/test/ModuleFederationExports.test.ts

@@ -0,0 +1,86 @@
+// Copyright The Perses Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+import * as InfluxDBDatasourceModule from '../datasource/influxdb/InfluxDBDatasource';
+import * as InfluxDBTimeSeriesQueryModule from '../queries/influxdb-time-series-query/InfluxDBTimeSeriesQuery';
+
+describe('Module Federation Exports', () => {
+  describe('InfluxDBDatasource Module', () => {
+    it('should export default InfluxDBDatasource', () => {
+      expect(InfluxDBDatasourceModule.default).toBeDefined();
+      expect(InfluxDBDatasourceModule.default).toHaveProperty('createClient');
+    });
+
+    it('should export named InfluxDBDatasource', () => {
+      expect(InfluxDBDatasourceModule.InfluxDBDatasource).toBeDefined();
+      expect(InfluxDBDatasourceModule.InfluxDBDatasource).toEqual(InfluxDBDatasourceModule.default);
+    });
+
+    it('should have all required datasource plugin properties', () => {
+      const datasource = InfluxDBDatasourceModule.default;
+      expect(datasource).toHaveProperty('createClient');
+      expect(datasource).toHaveProperty('createInitialOptions');
+      expect(datasource).toHaveProperty('OptionsEditorComponent');
+    });
+  });
+
+  describe('InfluxDBTimeSeriesQuery Module', () => {
+    it('should export default InfluxDBTimeSeriesQuery', () => {
+      expect(InfluxDBTimeSeriesQueryModule.default).toBeDefined();
+      expect(InfluxDBTimeSeriesQueryModule.default).toHaveProperty('getTimeSeriesData');
+    });
+
+    it('should export named InfluxDBTimeSeriesQuery', () => {
+      expect(InfluxDBTimeSeriesQueryModule.InfluxDBTimeSeriesQuery).toBeDefined();
+      expect(InfluxDBTimeSeriesQueryModule.InfluxDBTimeSeriesQuery).toEqual(InfluxDBTimeSeriesQueryModule.default);
+    });
+
+    it('should have all required query plugin properties', () => {
+      const query = InfluxDBTimeSeriesQueryModule.default;
+      expect(query).toHaveProperty('getTimeSeriesData');
+      expect(query).toHaveProperty('createInitialOptions');
+      expect(query).toHaveProperty('OptionsEditorComponent');
+    });
+  });
+
+  describe('Bootstrap Module', () => {
+    it('should export all required modules from bootstrap', async () => {
+      const bootstrap = await import('../bootstrap');
+      expect(bootstrap.getPluginModule).toBeDefined();
+      expect(bootstrap.InfluxDBDatasource).toBeDefined();
+      expect(bootstrap.InfluxDBTimeSeriesQuery).toBeDefined();
+    });
+
+    it('should export correct InfluxDBDatasource from bootstrap', async () => {
+      const bootstrap = await import('../bootstrap');
+      const datasource = bootstrap.InfluxDBDatasource;
+      expect(datasource).toHaveProperty('createClient');
+      expect(datasource).toHaveProperty('createInitialOptions');
+      expect(datasource).toHaveProperty('OptionsEditorComponent');
+    });
+
+    it('should export correct InfluxDBTimeSeriesQuery from bootstrap', async () => {
+      const bootstrap = await import('../bootstrap');
+      expect(bootstrap.InfluxDBTimeSeriesQuery).toEqual(InfluxDBTimeSeriesQueryModule.InfluxDBTimeSeriesQuery);
+    });
+
+    it('should return valid PluginModule metadata', async () => {
+      const bootstrap = await import('../bootstrap');
+      const pluginModule = bootstrap.getPluginModule();
+      expect(pluginModule.kind).toBe('PluginModule');
+      expect(pluginModule.metadata).toHaveProperty('name');
+      expect(pluginModule.metadata).toHaveProperty('version');
+      expect(pluginModule.spec).toHaveProperty('plugins');
+    });
+  });
+});