chore: lint fix

Author: e11sy

convertors/move-timestamp-out-of-payload.js

@@ -1,6 +1,10 @@
 require('dotenv').config();
 const { MongoClient } = require('mongodb');
 
+/**
+ * @param db - mongo db instance
+ * @param collectionName - name of the collection to be updated
+ */
 async function movePayloadTimestampToEventLevel(db, collectionName) {
   const collection = db.collection(collectionName);
   const cursor = collection.find({ 'payload.timestamp': { $exists: true } }).batchSize(500);
@@ -11,7 +15,10 @@ async function movePayloadTimestampToEventLevel(db, collectionName) {
 
   for await (const doc of cursor) {
     const timestamp = Number(doc.payload?.timestamp);
-    if (isNaN(timestamp)) continue;
+
+    if (isNaN(timestamp)) {
+      continue;
+    }
 
     bulkOps.push({
       updateOne: {
@@ -25,6 +32,7 @@ async function movePayloadTimestampToEventLevel(db, collectionName) {
 
     if (bulkOps.length === 1000) {
       const result = await collection.bulkWrite(bulkOps);
+
       updated += result.modifiedCount;
       processed += bulkOps.length;
       console.log(`  Flushed 1000 updates (${processed} processed, ${updated} updated)`);
@@ -34,6 +42,7 @@ async function movePayloadTimestampToEventLevel(db, collectionName) {
 
   if (bulkOps.length > 0) {
     const result = await collection.bulkWrite(bulkOps);
+
     updated += result.modifiedCount;
     processed += bulkOps.length;
     console.log(`  Flushed final ${bulkOps.length} updates (${processed} processed, ${updated} updated)`);
@@ -42,6 +51,11 @@ async function movePayloadTimestampToEventLevel(db, collectionName) {
   console.log(`  Done with ${collectionName}: ${updated} documents updated`);
 }
 
+/**
+ * @param db - mongo db instance
+ * @param repetitionCollectionName - repetitions collection to be updated
+ * @param projectId - project id of current repetitions collection
+ */
 async function backfillTimestampsFromEvents(db, repetitionCollectionName, projectId) {
   const collection = db.collection(repetitionCollectionName);
 
@@ -64,7 +78,12 @@ async function backfillTimestampsFromEvents(db, repetitionCollectionName, projec
         as: 'eventData',
       },
     },
-    { $unwind: { path: '$eventData', preserveNullAndEmptyArrays: true } },
+    {
+      $unwind: {
+        path: '$eventData',
+        preserveNullAndEmptyArrays: true,
+      },
+    },
     { $match: { 'eventData.timestamp': { $exists: true } } },
     {
       $project: {
@@ -78,7 +97,6 @@ async function backfillTimestampsFromEvents(db, repetitionCollectionName, projec
 
   let bulkOps = [];
   let processed = 0;
-  let flushed = 0;
 
   for await (const doc of cursor) {
     bulkOps.push({
@@ -90,27 +108,30 @@ async function backfillTimestampsFromEvents(db, repetitionCollectionName, projec
 
     if (bulkOps.length === 1000) {
       const res = await collection.bulkWrite(bulkOps);
+
       processed += res.modifiedCount;
-      flushed++;
       bulkOps = [];
     }
   }
 
   if (bulkOps.length > 0) {
     const res = await collection.bulkWrite(bulkOps);
+
     processed += res.modifiedCount;
-    flushed++;
   }
 
   console.log(`  Done backfilling ${repetitionCollectionName}: ${processed} updated`);
 }
 
+/**
+ * Method that runs convertor script
+ */
 async function run() {
   const fullUri = process.env.MONGO_EVENTS_DATABASE_URI;
 
   // Parse the Mongo URL manually
   const mongoUrl = new URL(fullUri);
-  const databaseName = "hawk_events"
+  const databaseName = 'hawk_events';
 
   // Extract query parameters
   const queryParams = Object.fromEntries(mongoUrl.searchParams.entries());
@@ -136,9 +157,9 @@ async function run() {
 
   const client = new MongoClient(cleanUri, options);
 
-
   await client.connect();
   const db = client.db(databaseName);
+
   console.log(`Connected to database: ${databaseName}`);
 
   const collections = await db.listCollections({}, {
@@ -154,6 +175,7 @@ async function run() {
 
   // Convert events
   let i = 1;
+
   for (const collectionName of eventCollections) {
     console.log(`[${i}/${eventCollections.length}] Processing ${collectionName}`);
     await movePayloadTimestampToEventLevel(db, collectionName);

workers/release/src/index.ts

@@ -234,7 +234,7 @@ export default class ReleaseWorker extends Worker {
         }, { session });
       });
     } catch (error) {
-      this.logger.error(`Can\'t extract release info:\n${JSON.stringify(error)}`);
+      this.logger.error(`Can't extract release info:\n${JSON.stringify(error)}`);
 
       throw new NonCriticalError('Can\'t parse source-map file');
     } finally {