logging

src/api/gitea.ts

@@ -12,6 +12,8 @@ const Base = axios.create({
   },
 })
 
+const l = logger.child({ api: 'gitea' })
+
 export type MirrorOptions = {
   private: boolean
   auth_token: string
@@ -20,7 +22,7 @@ export type MirrorOptions = {
 }
 export async function mirror(options: MirrorOptions) {
   try {
-    logger.debug('Mirroring repository', options)
+    l.debug('mirroring repository', options)
     const response = await Base({
       url: '/repos/migrate',
       method: 'POST',
@@ -41,18 +43,19 @@ export async function mirror(options: MirrorOptions) {
         releases: true,
       },
     })
-    logger.debug('Mirrored repository', { data: response.data })
+    l.debug('mirrored repository', { data: response.data })
     return response.data
   } catch (e) {
     if (e instanceof AxiosError) {
-      logger.error('Error mirroring repository', e.response?.data)
+      l.error('Error mirroring repository', e.response?.data)
     } else {
-      logger.error('Unknown error', e)
+      l.error('Unknown error', e)
     }
   }
 }
 
 export async function listRepositories(page: number, limit: number) {
+  l.debug(`listing repos`, { page, limit })
   const response = await Base<ListRepositoriesResponse>({
     url: '/user/repos',
     method: 'GET',
@@ -65,22 +68,23 @@ export async function listRepositories(page: number, limit: number) {
 }
 
 export async function listAllRepositories() {
-  logger.debug('Listing all repositories in Gitea')
+  l.debug('listing all repositories')
   const limit = 50
   const repos: ListRepositoriesResponse = []
   let page = 1
   while (true) {
+    l.debug('listing page', { page })
     const response = await listRepositories(page, limit)
     repos.push(...response)
     if (response.length < limit) break
     page++
   }
-  logger.debug('Listed all repositories in Gitea', { data: repos })
+  l.debug('listed all repositories', { repos: repos.map((repo) => repo.name) })
   return repos
 }
 
 export async function updateRepository(owner: string, repo: string, body: Partial<Repository>) {
-  logger.debug('Updating repository', { owner, repo, body })
+  l.debug('updating repository', { owner, repo, body })
   await Base({
     url: `/repos/${owner}/${repo}`,
     method: 'PATCH',

src/api/github.ts

@@ -2,6 +2,7 @@ import axios from 'axios'
 
 import { Config } from '../config.js'
 import type { ListRepositoriesResponse } from './github.types.js'
+import { logger } from '../logger.js'
 
 const Base = axios.create({
   baseURL: 'https://api.github.com',
@@ -12,7 +13,10 @@ const Base = axios.create({
   },
 })
 
+const l = logger.child({ api: 'github' })
+
 async function listRepos(page: number, limit: number) {
+  l.debug('listing repos', { page, limit })
   const response = await Base<ListRepositoriesResponse>({
     url: `user/repos`,
     method: 'GET',
@@ -26,14 +30,17 @@ async function listRepos(page: number, limit: number) {
 }
 
 export async function listAllRepositories() {
+  l.debug('listing all repos')
   const limit = 100
   const repos: ListRepositoriesResponse = []
   let page = 1
   while (true) {
+    l.debug('listing page', { page })
     const response = await listRepos(page, limit)
     repos.push(...response)
     if (response.length < limit) break
     page++
   }
+  l.debug('listed all repos')
   return repos
 }

src/config.ts

@@ -1,7 +1,3 @@
-import { config } from 'dotenv'
-
-config()
-
 function getEnv(key: string, fallback: string, parse?: undefined, validator?: (s: string) => boolean): string
 function getEnv<T>(key: string, fallback: T, parse: (value: string) => T, validator?: (T: string) => boolean): T
 function getEnv<T>(
@@ -19,12 +15,6 @@ function getEnv<T>(
   return parsed
 }
 
-function parseBoolean(value: string): boolean {
-  value = value.toLowerCase()
-  const truthy = ['true', 'yes', '1', 'y']
-  return truthy.includes(value)
-}
-
 function isPresent(s: string): boolean {
   return s.length > 0
 }

src/core.ts

@@ -5,30 +5,32 @@ import { logger } from './logger.js'
 
 let running = false
 
+const l = logger.child({ context: 'runner' })
+
 export async function sync() {
   if (running) {
-    logger.info('Already running, skipping')
+    l.info('already running, skipping')
     return
   }
   try {
-    logger.info('Starting sync')
+    l.info('starting sync')
     const syncedRepos = await giteaRepos()
     const toSync = await githubRepos()
-    logger.debug('Loaded repos', { remote: toSync.length, local: syncedRepos.length })
+    l.debug('loaded repos', { remote: toSync.length, local: syncedRepos.length })
 
     for (const repo of toSync) {
+      const lr = l.child({ repo: repo.name })
       const sameName = syncedRepos.find((r) => r.name === repo.name || r.original_url === repo.clone_url)
       if (sameName) {
         if (sameName.original_url === repo.clone_url) {
           if (sameName.private === repo.private) logger.info('Already synced, skipping', { name: repo.name })
           else {
-            logger.info('Visibility changed, updating', { name: repo.name })
+            lr.info('visibility changed, updating')
             const [owner, repository] = sameName.full_name.split('/')
             await updateRepository(owner, repository, { private: repo.private })
           }
         } else {
-          logger.error('Repo with same name but different url', {
+          lr.error('repo with same name but different url', {
-            name: repo.name,
             url: repo.clone_url,
             original_url: sameName.original_url,
           })
@@ -42,14 +44,14 @@ export async function sync() {
         private: repo.private,
         auth_token: Config.github.token,
       }
-      logger.info('Mirroring repository', options)
+      lr.info('mirroring repository', options)
       await mirror(options)
-      logger.info('Mirrored repository', { name: repo.name })
+      lr.info('mirrored repository')
     }
-    logger.info('Finished sync')
+    l.info('Finished sync')
   } catch (error) {
-    logger.debug(error)
+    l.debug(error)
-    logger.error('Failed to sync', { error: error instanceof Error ? error.message : 'Unknown error' })
+    l.error('Failed to sync', { error: error instanceof Error ? error.message : 'Unknown error' })
   } finally {
     running = false
   }