chore: lint fixes in packages_worker

Signed-off-by: anilb <epipav@gmail.com>

Author: epipav

services/apps/packages_worker/src/config.ts

@@ -20,7 +20,10 @@ export function getPackagesDbConfig() {
 
 export function getEnricherConfig() {
   const rawTokens = process.env.ENRICHER_GITHUB_TOKENS ?? ''
-  const tokens = rawTokens.split(',').map((t) => t.trim()).filter(Boolean)
+  const tokens = rawTokens
+    .split(',')
+    .map((t) => t.trim())
+    .filter(Boolean)
 
   return {
     tokens,

services/apps/packages_worker/src/db.ts

@@ -1,5 +1,5 @@
-import { getDbConnection } from '@crowd/database'
 import { pgpQx } from '@crowd/data-access-layer/src/queryExecutor'
+import { getDbConnection } from '@crowd/database'
 
 import { getPackagesDbConfig } from './config'
 

services/apps/packages_worker/src/enricher/fetchLightRepo.ts

@@ -67,7 +67,8 @@ export async function fetchLightRepo(url: string, token: string): Promise<LightR
 
   if (json.errors?.length) {
     const err = json.errors[0]
-    if (err.type === 'RATE_LIMITED') throw new FetchError('RATE_LIMIT', `RATE_LIMITED for ${url}`, resetMs)
+    if (err.type === 'RATE_LIMITED')
+      throw new FetchError('RATE_LIMIT', `RATE_LIMITED for ${url}`, resetMs)
     if (err.type === 'NOT_FOUND') throw new FetchError('NOT_FOUND', `NOT_FOUND for ${url}`)
     throw new FetchError('TRANSIENT', `GraphQL error for ${url}: ${err.message ?? err.type}`)
   }
@@ -82,7 +83,9 @@ export async function fetchLightRepo(url: string, token: string): Promise<LightR
     name,
     description: repo.description ?? null,
     primaryLanguage: repo.primaryLanguage?.name ?? null,
-    topics: (repo.repositoryTopics?.nodes ?? []).map((n: { topic: { name: string } }) => n.topic.name),
+    topics: (repo.repositoryTopics?.nodes ?? []).map(
+      (n: { topic: { name: string } }) => n.topic.name,
+    ),
     stars: repo.stargazerCount ?? 0,
     forks: repo.forkCount ?? 0,
     watchers: repo.watchers?.totalCount ?? 0,

services/apps/packages_worker/src/enricher/runEnrichmentLoop.ts

@@ -1,7 +1,8 @@
-import { getServiceChildLogger } from '@crowd/logging'
 import { QueryExecutor } from '@crowd/data-access-layer/src/queryExecutor'
+import { getServiceChildLogger } from '@crowd/logging'
 
 import { getEnricherConfig } from '../config'
+
 import { fetchLightRepo, parseGithubUrl } from './fetchLightRepo'
 import { FetchError, LightRepoResult } from './types'
 import { updateEnrichedRepos } from './updateEnrichedRepos'
@@ -10,10 +11,7 @@ const log = getServiceChildLogger('github-repos-enricher')
 
 const MAX_RETRIES = 3
 
-async function fetchWithRetries(
-  url: string,
-  token: string,
-): Promise<LightRepoResult | null> {
+async function fetchWithRetries(url: string, token: string): Promise<LightRepoResult | null> {
   for (let attempt = 0; attempt <= MAX_RETRIES; attempt++) {
     try {
       return await fetchLightRepo(url, token)
@@ -171,7 +169,13 @@ export async function runEnrichmentLoop(
       continue
     }
 
-    const { fetched, failed, flushed } = await processPage(urls, config.tokens, parkedUntil, config, qx)
+    const { fetched, failed, flushed } = await processPage(
+      urls,
+      config.tokens,
+      parkedUntil,
+      config,
+      qx,
+    )
 
     log.info(
       `Page ${pageNum}: read=${urls.length} fetched=${fetched} failed=${failed} flushed=${flushed}`,

services/apps/packages_worker/src/enricher/updateEnrichedRepos.ts

@@ -1,11 +1,14 @@
-import { getServiceChildLogger } from '@crowd/logging'
 import { QueryExecutor } from '@crowd/data-access-layer/src/queryExecutor'
+import { getServiceChildLogger } from '@crowd/logging'
 
 import { LightRepoResult } from './types'
 
 const log = getServiceChildLogger('github-repos-enricher:update')
 
-export async function updateEnrichedRepos(qx: QueryExecutor, rows: LightRepoResult[]): Promise<void> {
+export async function updateEnrichedRepos(
+  qx: QueryExecutor,
+  rows: LightRepoResult[],
+): Promise<void> {
   if (rows.length === 0) return
 
   for (const r of rows) {

services/apps/packages_worker/src/npm/activities.ts

@@ -3,6 +3,6 @@ import { getServiceChildLogger } from '@crowd/logging'
 const log = getServiceChildLogger('npm')
 
 export async function sayHiNpm(): Promise<string> {
-  log.info('👋 hi from npm activity')
+  log.info('hi from npm activity')
   return 'hi from npm'
 }