Eslint plugin style fixes

e2e/test/cases/cluster/api-spec.ts

@@ -175,7 +175,7 @@ describe('cluster api', () => {
             jobId = job.id();
             const { ex_id: exId } = await job.execution();
             ex = terasliceHarness.teraslice.executions.wrap(exId);
-        })
+        });
 
         it('will not delete a running job', async () => {
             await terasliceHarness.waitForExStatus(ex, 'running', 100, 1000);
@@ -192,28 +192,27 @@ describe('cluster api', () => {
 
         it('will not list a deleted job by default', async () => {
             const list = await terasliceHarness.teraslice.jobs.list();
-            const jobIds = list.map((job) => job.job_id);
+            const jobIds = list.map((jobConfig) => jobConfig.job_id);
             expect(jobIds).toEqual(expect.arrayContaining([expect.not.stringMatching(jobId)]));
         });
 
         it('will list a deleted job when passed "{ deleted: true }"', async () => {
             const list = await terasliceHarness.teraslice.jobs.list({ deleted: true });
-            expect(list).toEqual(expect.arrayContaining([expect.objectContaining({ ...jobSpec, job_id: jobId })]));
+            expect(list).toEqual(
+                expect.arrayContaining([expect.objectContaining({ ...jobSpec, job_id: jobId })])
+            );
         });
 
         it('will not start a deleted job', async () => {
             await expect(terasliceHarness.teraslice.jobs.post(`/jobs/${jobId}/_start`)).rejects.toThrow(`Job ${jobId} has been deleted and cannot be started.`);
-
         });
 
         it('will not update a deleted job', async () => {
             await expect(terasliceHarness.teraslice.jobs.put(`/jobs/${jobId}`, { workers: 1 })).rejects.toThrow(`Job ${jobId} has been deleted and cannot be updated.`);
-
         });
 
         it('will not recover a deleted job', async () => {
             await expect(terasliceHarness.teraslice.jobs.post(`/jobs/${jobId}/_recover`)).rejects.toThrow(`Job ${jobId} has been deleted and cannot be recovered.`);
-
         });
     });
 });

e2e/test/cases/cluster/job-state-spec.ts

@@ -42,5 +42,8 @@ describe('job state', () => {
             ex1.stop({ blocking: true }),
             ex2.stop({ blocking: true }),
         ]);
+
+        // we are testing to see if errors come from transitions, not any end results
+        expect(true).toBe(true);
     });
 });

e2e/test/cases/cluster/state-spec.ts

@@ -1,3 +1,4 @@
+/* eslint-disable jest/expect-expect */
 import { pDelay, flatten } from '@terascope/utils';
 import signale from '../../signale.js';
 import { TerasliceHarness } from '../../teraslice-harness.js';
@@ -33,7 +34,7 @@ describe('cluster state', () => {
 
     function verifyClusterMaster(state: any) {
         // verify that the cluster master worker exists within the state
-        const nodes = Object.values(state).filter((node:any) => {
+        const nodes = Object.values(state).filter((node: any) => {
             const cms = findWorkers(node.active, 'cluster_master');
             return cms.length > 0;
         }) as any;
@@ -91,8 +92,7 @@ describe('cluster state', () => {
         verifyClusterState(await terasliceHarness.scaleWorkersAndWait());
     });
 
-    // eslint-disable-next-line jest/no-focused-tests
-    fit('should be correct for running job with 1 worker', async () => {
+    it('should be correct for running job with 1 worker', async () => {
         const jobSpec = terasliceHarness.newJob('reindex');
         const specIndex = terasliceHarness.newSpecIndex('state');
         // Set resource constraints on workers within CI

e2e/test/cases/cluster/worker-allocation-spec.ts

@@ -1,3 +1,4 @@
+/* eslint-disable jest/expect-expect */
 import { TerasliceHarness } from '../../teraslice-harness.js';
 import { TEST_PLATFORM } from '../../config.js';
 

e2e/test/cases/data/id-reader-spec.ts

@@ -9,7 +9,7 @@ import { TEST_PLATFORM } from '../../config.js';
  *  - https://github.com/terascope/elasticsearch-assets/issues/12
  */
 // eslint-disable-next-line jest/no-disabled-tests
-xdescribe('id reader', () => {
+describe.skip('id reader', () => {
     let terasliceHarness: TerasliceHarness;
 
     beforeAll(async () => {

e2e/test/docker-helpers.ts

@@ -43,7 +43,7 @@ export async function dockerUp() {
             throw new Error('Node version check failed to return a result.');
         }
         return version;
-    })
+    });
 
     const scriptsNodeVersion = semver.coerce(NODE_VERSION);
     const parsedVersion = semver.parse(e2eNodeVersion);

e2e/test/download-assets.ts

@@ -15,7 +15,7 @@ type AssetInfo = {
     bundle: boolean;
     fileName: string;
     assetNodeVersion: string;
-}
+};
 
 /**
  * This will get the correct teraslice node version so
@@ -51,7 +51,6 @@ export const defaultAssetBundles = [
 ];
 
 function assetFileInfo(assetName: string): AssetInfo {
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
     const [name, version, _, assetNodeVersion] = assetName.split('-');
     return {
         name,
@@ -207,7 +206,7 @@ function getMSUntilRetry(err: HTTPError): number {
  * @param {any} err The response error
  * @returns {number|undefined} Delay in milliseconds or undefined
  */
-function calculateDelay(err: any): number|undefined {
+function calculateDelay(err: any): number | undefined {
     const MAX_WAIT_MS = 180_000;
 
     if (err instanceof HTTPError) {

e2e/test/setup-config.ts

@@ -14,7 +14,7 @@ const baseConfig = {
         environment: 'development',
         log_level: [
             { console: 'warn' },
-            { file: process.env.DEBUG_LOG_LEVEL || 'info', }
+            { file: process.env.DEBUG_LOG_LEVEL || 'info' }
         ],
         logging: [
             'console',

e2e/test/teraslice-harness.ts

@@ -78,6 +78,7 @@ export class TerasliceHarness {
         const errors = await ex.errors();
         this.warn(`waitForStatus: ${exId} errors`, errors);
     }
+
     // TODO: look at types here
     warn(msg: string, obj: any) {
         if (isEmpty(obj)) return;

eslint.config.js

@@ -1,3 +1,3 @@
 import eslintConfig from '@terascope/eslint-config';
 
-export default eslintConfig
+export default eslintConfig;

jest.config.base.js

@@ -62,31 +62,32 @@ export default (projectDir) => {
         watchPlugins: ['jest-watch-typeahead/filename', 'jest-watch-typeahead/testname'],
         workerIdleMemoryLimit: '200MB',
         testTimeout: 60 * 1000,
-        globals:  {
-            availableExtensions: ['.js', '.ts', '.mjs', 'cjs']
+        globals: {
+            availableExtensions: ['.js', '.ts', '.mjs', 'cjs'],
         },
         transform: {
-            ['^.+\\.(t|j)sx?$']: ['@swc/jest', {
-                jsc: {
-                    loose: true,
-                    parser: {
-                        syntax: 'typescript',
-                        tsx: false,
-                        decorators: true
+            ['^.+\\.(t|j)sx?$']: ['@swc/jest',
+                {
+                    jsc: {
+                        loose: true,
+                        parser: {
+                            syntax: 'typescript',
+                            tsx: false,
+                            decorators: true
+                        },
+                        transform: {
+                            legacyDecorator: true,
+                            decoratorMetadata: true
+                        },
+                        target: 'esnext'
                     },
-                    transform: {
-                        legacyDecorator: true,
-                        decoratorMetadata: true
-                    },
-                    target: 'esnext'
-                },
-                module: {
-                    type: 'es6',
-                    strictMode: false,
-                    noInterop: false,
-                    ignoreDynamic: true
-                }
-            }]
+                    module: {
+                        type: 'es6',
+                        strictMode: false,
+                        noInterop: false,
+                        ignoreDynamic: true
+                    }
+                }]
         },
         roots: [`${packageRoot}/test`]
     };

jest.config.js

@@ -37,7 +37,7 @@ export default {
     verbose: true,
     projects,
     globals: {
-        availableExtensions: ['.js', '.ts', '.mjs', '.cjs']
+        availableExtensions: ['.js', '.ts', '.mjs', '.cjs'],
     },
     testMatch: [
         '<rootDir>/packages/*/test/**/*-spec.{ts,js}',
@@ -73,26 +73,27 @@ export default {
     },
     extensionsToTreatAsEsm: ['.ts'],
     transform: {
-        ['^.+\\.(t|j)sx?$']: ['@swc/jest', {
-            jsc: {
-                loose: true,
-                parser: {
-                    syntax: 'typescript',
-                    tsx: false,
-                    decorators: true
+        ['^.+\\.(t|j)sx?$']: ['@swc/jest',
+            {
+                jsc: {
+                    loose: true,
+                    parser: {
+                        syntax: 'typescript',
+                        tsx: false,
+                        decorators: true
+                    },
+                    transform: {
+                        legacyDecorator: true,
+                        decoratorMetadata: true
+                    },
+                    target: 'esnext'
                 },
-                transform: {
-                    legacyDecorator: true,
-                    decoratorMetadata: true
-                },
-                target: 'esnext'
-            },
-            module: {
-                type: 'es6',
-                strictMode: false,
-                noInterop: false,
-                ignoreDynamic: true
-            }
-        }]
-    }
+                module: {
+                    type: 'es6',
+                    strictMode: false,
+                    noInterop: false,
+                    ignoreDynamic: true
+                }
+            }]
+    },
 };

package.json

@@ -32,7 +32,7 @@
         "k8s:rebuild": "ts-scripts k8s-env --rebuild",
         "k8s:restart": "ts-scripts k8s-env --rebuild --skip-build",
         "k8sV2": "TEST_ELASTICSEARCH=true ELASTICSEARCH_PORT=9200 CLUSTERING_TYPE='kubernetesV2' ts-scripts k8s-env",
-        "lint": "eslint",
+        "lint": "DEBUG=typescript-eslint:* eslint --debug",
         "lint:fix": "yarn lint --fix && yarn sync",
         "setup": "yarn $YARN_SETUP_ARGS && yarn run build --force",
         "start": "node service.js",
@@ -48,7 +48,7 @@
         "nan": "^2.19.0"
     },
     "devDependencies": {
-        "@eslint/js": "^9.9.1",
+        "@eslint/js": "^9.10.0",
         "@swc/core": "1.4.0",
         "@swc/jest": "^0.2.36",
         "@types/bluebird": "^3.5.42",
@@ -59,7 +59,7 @@
         "@types/lodash": "^4.17.7",
         "@types/node": "^18.14.2",
         "@types/uuid": "^9.0.8",
-        "eslint": "^9.9.1",
+        "eslint": "^9.10.0",
         "jest": "^29.7.0",
         "jest-extended": "^3.2.4",
         "jest-watch-typeahead": "^2.2.2",

packages/data-mate/bench/build-column-perf-test.js

@@ -1,3 +1,4 @@
+/* eslint-disable no-console */
 import { config, data } from './fixtures/data.json';
 import { Column } from '../dist/src/index.js';
 
@@ -6,16 +7,15 @@ const fieldConfig = config.fields[name];
 const values = data.map((row) => row[name]);
 
 const startRSS = process.memoryUsage().rss;
-// eslint-disable-next-line no-console
-console.log(`Building ${values.length} rows`,);
+console.log(`Building ${values.length} rows`);
 
 console.time(`Built ${values.length} rows`);
 
 const column = Column.fromJSON(name, fieldConfig, values);
 console.timeEnd(`Built ${values.length} rows`);
 
 const endRSS = process.memoryUsage().rss;
-// eslint-disable-next-line no-console
+
 console.log('DONE', endRSS - startRSS);
 
 setTimeout(() => console.error('exiting...'), 5000);

packages/data-mate/bench/generate-data.js

@@ -1,3 +1,4 @@
+/* eslint-disable no-console */
 import { times, random } from '@terascope/utils';
 import { FieldType } from '@terascope/types';
 import fs from 'node:fs';
@@ -97,10 +98,12 @@ let records = times(numRecords, () => {
         return {
             type: age > 20 ? 'parent' : 'child',
             number_of_friends: random(1, 2000),
-            requests: random(0, 20) ? {
-                total: random(10, maxInt),
-                last: chance.date().toISOString()
-            } : null,
+            requests: random(0, 20)
+                ? {
+                    total: random(10, maxInt),
+                    last: chance.date().toISOString()
+                }
+                : null,
         };
     }
     return {
@@ -133,14 +136,14 @@ function randNull(fn, arg) {
     return fn.call(chance, arg);
 }
 
-// eslint-disable-next-line no-console
 console.dir({
     dataTypeConfig,
     records,
 }, {
     maxArrayLength: 1,
     depth: 5
 });
+
 (async function writeRow() {
     console.time('write row');
     await new Promise((resolve, reject) => {

packages/data-mate/bench/index.js

@@ -19,7 +19,7 @@ function start(name, dir) {
 
     async function run() {
         const list = await pMap(benchmarks, async (file) => {
-            return import(path.join(dir, file))
+            return import(path.join(dir, file));
         });
 
         for (const initSuite of list) {

packages/data-mate/bench/serialize-perf-test.js

@@ -96,16 +96,22 @@ async function deserializeStream(iterator) {
 async function runTest(times) {
     let start;
     return Promise.resolve()
-        .then(() => { start = Date.now(); })
+        .then(() => {
+            start = Date.now();
+        })
         .then(readFile('data.json'))
         .then(fromJSON)
         .then(() => times.set('row', Date.now() - start))
         .then(() => pDelay(100))
-        .then(() => { start = Date.now(); })
+        .then(() => {
+            start = Date.now();
+        })
         .then(readFile('data.dfjson'))
         .then(deserialize)
         .then(() => times.set('column', Date.now() - start))
-        .then(() => { start = Date.now(); })
+        .then(() => {
+            start = Date.now();
+        })
         .then(readFileStream('data.dfjson'))
         .then(deserializeStream)
         .then(() => times.set('column stream', Date.now() - start));