lint cleanup
authorJustin Wind <justin.wind+git@gmail.com>
Mon, 3 Jul 2023 18:02:03 +0000 (11:02 -0700)
committerJustin Wind <justin.wind+git@gmail.com>
Mon, 3 Jul 2023 18:02:03 +0000 (11:02 -0700)
test/src/common.js
test/src/communication.js
test/src/db/integration.js
test/src/db/postgres-listener.js
test/src/db/postgres.js
test/src/db/schema-version-helper.js
test/src/db/sqlite.js
test/src/manager.js
test/src/service.js
test/src/template/badge-svg.js

index e46f96abecd497eb549bd170c196e7cfb4059cf3..e20561919b55faa5c4512da96f0d1c20addf610c 100644 (file)
@@ -134,7 +134,7 @@ describe('Common', function () {
     it('covers default', function () {
       const result = common.attemptRetrySeconds(0);
       assert(result >= 60);
-      assert(result <= 60 * 1.618)
+      assert(result <= 60 * 1.618);
     });
   }); // attemptRetrySeconds
 
index 8be92414f6777c923991910d538a806684fe53ae..3e09b3da4d48a32dd9d4e6dbca7eedb931588274 100644 (file)
@@ -709,14 +709,14 @@ describe('Communication', function () {
     it('covers claim', async function () {
       communication.db.topicFetchClaimById.resolves({
         changes: 1,
-      })
+      });
       await communication.topicFetchClaimAndProcessById(dbCtx, topicId, requestId);
       assert(communication.topicFetchProcess.called);
     });
     it('covers no claim', async function () {
       communication.db.topicFetchClaimById.resolves({
         changes: 0,
-      })
+      });
       await communication.topicFetchClaimAndProcessById(dbCtx, topicId, requestId);
       assert(!communication.topicFetchProcess.called);
     });
@@ -733,14 +733,14 @@ describe('Communication', function () {
     it('covers claim', async function () {
       communication.db.verificationClaimById.resolves({
         changes: 1,
-      })
+      });
       await communication.verificationClaimAndProcessById(dbCtx, verificationId, requestId);
       assert(communication.verificationProcess.called);
     });
     it('covers no claim', async function () {
       communication.db.verificationClaimById.resolves({
         changes: 0,
-      })
+      });
       await communication.verificationClaimAndProcessById(dbCtx, verificationId, requestId);
       assert(!communication.verificationProcess.called);
     });
index bd28e92a9124c7ba1d7cb2c0a7bc9d256e10c983..84d1d26b027f0bfa060f0ed4ba83a83fc133aa95 100644 (file)
@@ -285,7 +285,7 @@ describe('Database Integration', function () {
           const data = {
             ...testData.subscriptionUpsert,
             topicId,
-          }
+          };
           await db.context(async (dbCtx) => {
             const result = await db.subscriptionUpsert(dbCtx, data);
             assert(result.lastInsertRowid);
@@ -364,7 +364,7 @@ describe('Database Integration', function () {
             ...testData.subscriptionUpsert,
             secret: 'newSecret',
             topicId,
-          }
+          };
           await db.context(async (dbCtx) => {
             const result = await db.subscriptionUpsert(dbCtx, data);
             assert(result.lastInsertRowid);
@@ -416,7 +416,7 @@ describe('Database Integration', function () {
         });
         step('delete expired subscriptions', async function() {
           await db.context(async (dbCtx) => {
-            await db.subscriptionDeleteExpired(dbCtx, topicId)
+            await db.subscriptionDeleteExpired(dbCtx, topicId);
             const subscription = await db.subscriptionGet(dbCtx, testData.subscriptionUpsert.callback, topicId);
             assert(!subscription);
           });
index ecd2fe2ce4c06aabb47635c6edae4fcb5df80bfd..eaa3a1c24c5daf333d6ffe3f55fcac80ad46a878 100644 (file)
@@ -2,7 +2,7 @@
 'use strict';
 
 const assert = require('assert');
-const sinon = require('sinon');
+const sinon = require('sinon'); // eslint-disable-line node/no-unpublished-require
 const stubLogger = require('../../stub-logger');
 const Listener = require('../../../src/db/postgres/listener');
 
index d6bf6746524e88275078233d041195b356d4f966..c7621354de979ce9a78039813cfb20bf78b76570 100644 (file)
@@ -65,7 +65,7 @@ describe('DatabasePostgres', function () {
     httpRemoteAddr = '127.0.0.1';
     httpFrom = 'user@example.com';
     wanted = 5;
-});
+  });
   afterEach(function () {
     sinon.restore();
   });
@@ -631,7 +631,7 @@ describe('DatabasePostgres', function () {
       const expected = new Error();
       sinon.stub(db.db, 'manyOrNone').throws(expected);
       try {
-        await db.subscriptionDeliveryClaim(dbCtx, wanted, claimTimeoutSeconds, claimant );
+        await db.subscriptionDeliveryClaim(dbCtx, wanted, claimTimeoutSeconds, claimant);
         assert.fail(noExpectedException);
       } catch (e) {
         assert.deepStrictEqual(e, expected);
@@ -650,7 +650,7 @@ describe('DatabasePostgres', function () {
         changes: 1,
         lastInsertRowid: 'c2e254c5-aa6e-4a8f-b1a1-e474b07392bb',
         duration: 11,
-      }
+      };
       sinon.stub(db.db, 'result').resolves(dbResult);
       const result = await db.subscriptionDeliveryClaimById(dbCtx, subscriptionId, claimTimeoutSeconds, claimant);
       assert.deepStrictEqual(result, expected);
@@ -1026,7 +1026,7 @@ describe('DatabasePostgres', function () {
         rowCount: 1,
         rows: [],
         duration: 10,
-      }
+      };
       const expected = {
         changes: 1,
         lastInsertRowid: undefined,
@@ -1048,7 +1048,7 @@ describe('DatabasePostgres', function () {
         rowCount: 1,
         rows: [],
         duration: 10,
-      }
+      };
       const expected = {
         changes: 1,
         lastInsertRowid: undefined,
@@ -1070,7 +1070,7 @@ describe('DatabasePostgres', function () {
         rowCount: 0,
         rows: [],
         duration: 10,
-      }
+      };
       sinon.stub(db.db, 'one').resolves(dbOne);
       sinon.stub(db.db, 'result').onCall(0).resolves(dbResult0).onCall(1).resolves(dbResult1);
       try {
@@ -1091,7 +1091,7 @@ describe('DatabasePostgres', function () {
         rowCount: 0,
         rows: [],
         duration: 10,
-      }
+      };
       sinon.stub(db.db, 'one').resolves(dbOne);
       sinon.stub(db.db, 'result').onCall(0).resolves(dbResult0).onCall(1).resolves(dbResult1);
       try {
@@ -1764,7 +1764,7 @@ describe('DatabasePostgres', function () {
         rowCount: 0,
         rows: [],
         duration: 10,
-      }
+      };
       sinon.stub(db.db, 'result').resolves(dbResult);
       try {
         await db.verificationUpdate(dbCtx, verificationId, data);
@@ -1790,7 +1790,7 @@ describe('DatabasePostgres', function () {
         rowCount: 1,
         rows: [],
         duration: 10,
-      }
+      };
       sinon.stub(db.db, 'result').resolves(dbResult);
       await db.verificationValidated(dbCtx, verificationId);
     });
@@ -1799,7 +1799,7 @@ describe('DatabasePostgres', function () {
         rowCount: 0,
         rows: [],
         duration: 10,
-      }
+      };
       sinon.stub(db.db, 'result').resolves(dbResult);
       try {
         await db.verificationValidated(dbCtx, verificationId);
index b69735e3400a758b9d569bc8e9f4cfadd3ef0ef8..4a95202c85ec90d7c4594148440b2606df9ad9e5 100644 (file)
@@ -121,6 +121,7 @@ describe('SchemaVersionHelper', function () {
         .onCall(i++).returns(notDir) // 'init.sql'
         .onCall(i++).returns(isDir).onCall(i++).returns(isMig) // '1.0.1'
         .onCall(i++).returns(isDir).onCall(i++).returns(isMig) // '1.0.0'
+      ;
       const result = svh.allSchemaVersions('path');
       assert.deepStrictEqual(result, expected);
     });
@@ -137,7 +138,7 @@ describe('SchemaVersionHelper', function () {
         max: { major: 1, minor: 1, patch: 1 },
       };
       current = { major: 1, minor: 0, patch: 1 };
-      });
+    });
     it('covers', function () {
       const expected = ['1.1.0', '1.1.1'];
       fs.readdirSync.returns(['1.1.2', 'file.txt', '1.1.0', '1.1.1', 'init.sql', '1.0.1', '1.0.0']);
@@ -151,6 +152,7 @@ describe('SchemaVersionHelper', function () {
         .onCall(i++).returns(notDir) // 'init.sql'
         .onCall(i++).returns(isDir).onCall(i++).returns(isMig) // '1.0.1'
         .onCall(i++).returns(isDir).onCall(i++).returns(isMig) // '1.0.0'
+      ;
       const result = svh.unappliedSchemaVersions('path', current, supported);
       assert.deepStrictEqual(result, expected);
     });
index deb0ee244fbbb0811f0f6b62b66bebe41aac8ff6..e466930f197d533ab6a39ccc166683c3fcd0a3d6 100644 (file)
@@ -237,7 +237,7 @@ describe('DatabaseSQLite', function () {
         contentFetchNextAttempt: now,
         contentUpdated: now,
         url: topic.url,
-      }
+      };
       const result = DB._topicDataToNative(topic);
       assert.deepStrictEqual(result, expected);
     });
@@ -881,7 +881,7 @@ describe('DatabaseSQLite', function () {
       const dbResult1 = {
         changes: 1,
         lastInsertRowid: undefined,
-      }
+      };
       const expected = {
         changes: 1,
         lastInsertRowid: undefined,
@@ -901,7 +901,7 @@ describe('DatabaseSQLite', function () {
       const dbResult1 = {
         changes: 1,
         lastInsertRowid: undefined,
-      }
+      };
       const expected = {
         changes: 1,
         lastInsertRowid: undefined,
@@ -921,7 +921,7 @@ describe('DatabaseSQLite', function () {
       const dbResult1 = {
         changes: 0,
         lastInsertRowid: undefined,
-      }
+      };
       sinon.stub(db.statement.topicAttempts, 'get').returns(dbGet);
       sinon.stub(db.statement.topicAttemptsIncrement, 'run').returns(dbResult0);
       sinon.stub(db.statement.topicContentFetchDone, 'run').returns(dbResult1);
@@ -941,7 +941,7 @@ describe('DatabaseSQLite', function () {
       const dbResult1 = {
         changes: 0,
         lastInsertRowid: undefined,
-      }
+      };
       sinon.stub(db.statement.topicAttempts, 'get').returns(dbGet);
       sinon.stub(db.statement.topicAttemptsIncrement, 'run').returns(dbResult0);
       sinon.stub(db.statement.topicContentFetchDone, 'run').returns(dbResult1);
@@ -1534,7 +1534,7 @@ describe('DatabaseSQLite', function () {
       DB._verificationDataToEngine(data);
       assert.strictEqual(data.isPublisherValidated, 0);
     });
-  }) // _verificationDataToEngine
+  }); // _verificationDataToEngine
 
   describe('verificationInsert', function () {
     let verification;
@@ -1625,7 +1625,7 @@ describe('DatabaseSQLite', function () {
       const dbResult = {
         changes: 0,
         lastInsertRowid: undefined,
-      }
+      };
       sinon.stub(db.statement.verificationUpdate, 'run').returns(dbResult);
       try {
         await db.verificationUpdate(dbCtx, verificationId, data);
@@ -1650,7 +1650,7 @@ describe('DatabaseSQLite', function () {
       const dbResult = {
         changes: 1,
         lastInsertRowid: undefined,
-      }
+      };
       sinon.stub(db.statement.verificationValidate, 'run').returns(dbResult);
       await db.verificationValidated(dbCtx, verificationId);
     });
@@ -1658,7 +1658,7 @@ describe('DatabaseSQLite', function () {
       const dbResult = {
         changes: 0,
         lastInsertRowid: undefined,
-      }
+      };
       sinon.stub(db.statement.verificationValidate, 'run').returns(dbResult);
       try {
         await db.verificationValidated(dbCtx, verificationId);
index 9d8c380ff3b300b25d2841de4dffea19b6b05cf5..d3ddfb7b5517f0d94f5d5488fc76ff90ac29836b 100644 (file)
@@ -398,7 +398,7 @@ describe('Manager', function () {
   describe('_getRootData', function () {
     it('extracts expected values', function () {
       req.getHeader.returns('user@example.com');
-      ctx = Object.assign({}, testData.validSubscribeCtx)
+      ctx = Object.assign({}, testData.validSubscribeCtx);
       const result = Manager._getRootData(req, ctx);
       assert.deepStrictEqual(result, testData.validRootData);
     });
@@ -791,7 +791,7 @@ describe('Manager', function () {
       assert(manager.db.topicFetchRequested.called);
       assert.strictEqual(res.statusCode, 202);
       assert(res.end.called);
-      assert(manager.communication.topicFetchClaimAndProcessById.called)
+      assert(manager.communication.topicFetchClaimAndProcessById.called);
     });
     it('covers no immediate processing', async function() {
       manager.options.manager.processImmediately = false;
@@ -803,7 +803,7 @@ describe('Manager', function () {
       assert(manager.db.topicFetchRequested.called);
       assert.strictEqual(res.statusCode, 202);
       assert(res.end.called);
-      assert(!manager.communication.topicFetchClaimAndProcessById.called)
+      assert(!manager.communication.topicFetchClaimAndProcessById.called);
     });
   }); // _publishRequest
 
index 2de3b52c4595772834636f38be58b10fb54f9f6a..576859f834156b09759c2b64f7b29cee31de0e53 100644 (file)
@@ -21,6 +21,7 @@ describe('Service', function () {
     asyncLocalStorage = new AsyncLocalStorage();
     options = new Config('test');
     service = new Service(stubLogger, stubDb, options, asyncLocalStorage);
+    stubLogger._reset();
     sinon.stub(service.manager);
     sinon.stub(service.sessionManager);
     sinon.stub(service.authenticator);
@@ -49,7 +50,7 @@ describe('Service', function () {
   });
 
   describe('preHandler', function () {
-    it('logs requestId', async () => {
+    it('logs requestId', async function () {
       sinon.stub(service.__proto__.__proto__, 'preHandler').resolves();
       await service.asyncLocalStorage.run({}, async () => {
         await service.preHandler(req, res, ctx);
@@ -57,6 +58,12 @@ describe('Service', function () {
         assert('requestId' in logObject);
       });
     });
+    it('covers weird async context failure', async function () {
+      sinon.stub(service.__proto__.__proto__, 'preHandler').resolves();
+      sinon.stub(service.asyncLocalStorage, 'getStore').returns();
+      await service.preHandler(req, res, ctx);
+      assert(service.logger.debug.called);
+    });
   }); // preHandler
 
   describe('maybeIngestBody', function () {
@@ -197,7 +204,7 @@ describe('Service', function () {
       await service.handlerGetAdminLogout(req, res, ctx);
       assert(service.sessionManager.getAdminLogout.called);
     });
-}); // handlerGetAdminLogout
+  }); // handlerGetAdminLogout
 
   describe('handlerGetAdminIA', function () {
     it('covers', async function () {
index 1f4e0260a025048ac0676869ad2ffbbf67c629cd..8d7b66b14e9287c417be81b7369ea8575564d79c 100644 (file)
@@ -3,7 +3,6 @@
 
 const assert = require('assert');
 const template = require('../../../src/template/badge-svg');
-const Config = require('../../../config');
 
 describe('Badge SVG Template', function () {
   let ctx, label, message, accessibleText;