replace istanbul ignores with c8

packages/server/src/cli/args.ts

@@ -1,4 +1,3 @@
-/* istanbul ignore file */
 import { InvalidArgumentError, Option } from 'commander'
 
 import { FastifyCorsOptions } from '@fastify/cors'

packages/server/src/environment.ts

@@ -1,4 +1,4 @@
-/* istanbul ignore next */
+/* c8 ignore next */
 export const environment = process.env.NODE_ENV || 'development'
 
 const NON_PROD = ['test', 'development']

packages/server/src/errors.ts

@@ -1,4 +1,3 @@
-/* istanbul ignore file */
 import { FastifyReply } from 'fastify'
 import { ZodError } from 'zod'
 

packages/server/src/main.ts

@@ -42,7 +42,7 @@ async function startServer(this: Command) {
       },
     )
 
-    /* istanbul ignore next */
+    /* c8 ignore next */
     closeWithGrace(
       {
         delay: opts.grace,

packages/server/src/server.ts

@@ -73,7 +73,7 @@ export async function createServer(opts: ServerOptions) {
     logger,
   })
 
-  /* istanbul ignore next */
+  /* c8 ignore next */
   process.once('SIGUSR2', async function () {
     await server.close()
     // Controlled shutdown for Nodemon

packages/server/src/services/agents/steward/queries/index.ts

@@ -36,6 +36,7 @@ export class Queries {
       return await this.#locationHandler.queryAssetByLocation(args.criteria)
     }
 
+    /* c8 ignore next */
     throw new ValidationError('Unknown query type')
   }
 

packages/server/src/services/agents/xcm/agent.ts

@@ -325,12 +325,12 @@ export class XcmAgent implements Agent, Subscribable {
         })
       }
     } catch (error) {
-      /* istanbul ignore next */
+      /* c8 ignore next */
       // Clean up subscriptions.
       subs.forEach(({ sub }) => {
         sub.unsubscribe()
       })
-      /* istanbul ignore next */
+      /* c8 ignore next */
       throw error
     }
 

packages/server/src/services/config.ts

@@ -119,13 +119,13 @@ const configPlugin: FastifyPluginAsync<ConfigServerOptions> = async (fastify, op
     const config = $ServiceConfiguration.parse(toml.parse(fs.readFileSync(configPath, 'utf-8')))
     fastify.decorate('localConfig', config)
   } catch (err) {
-    /* istanbul ignore next */
+    /* c8 ignore next */
     if (err instanceof z.ZodError) {
       fastify.log.error(err.issues)
     } else {
       fastify.log.error(err)
     }
-    /* istanbul ignore next */
+    /* c8 ignore next */
     throw new Error('Error while loading configuration.')
   }
 }

packages/server/src/services/ingress/producer/index.ts

@@ -1,4 +1,3 @@
-/* istanbul ignore file */
 import EventEmitter from 'node:events'
 
 import { Subscription as RxSubscription } from 'rxjs'

packages/server/src/services/ingress/server/main.ts

@@ -31,7 +31,7 @@ async function startServer(this: Command) {
       },
     )
 
-    /* istanbul ignore next */
+    /* c8 ignore next */
     closeWithGrace(
       {
         delay: opts.grace,

packages/server/src/services/ingress/server/server.ts

@@ -43,7 +43,7 @@ export async function createIngressServer(opts: ServerOptions) {
 
   server.setErrorHandler(errorHandler)
 
-  /* istanbul ignore next */
+  /* c8 ignore next */
   process.once('SIGUSR2', function () {
     server.close().then(() => {
       // Controlled shutdown for Nodemon

packages/server/src/services/ingress/watcher/fetchers.ts

@@ -1,4 +1,3 @@
-/* istanbul ignore file */
 import { HexString, NetworkURN } from '@/lib.js'
 import { ApiClient } from '@/services/networking/client/index.js'
 

packages/server/src/services/networking/plugin.ts

@@ -10,7 +10,7 @@ declare module 'fastify' {
 }
 
 const connectorPlugin: FastifyPluginAsync = async (fastify) => {
-  /* istanbul ignore next */
+  /* c8 ignore next */
   if (fastify.localConfig === undefined) {
     return
   }

packages/server/src/services/persistence/kysely/plugin.ts

@@ -21,7 +21,7 @@ declare module 'fastify' {
 type KyselyOptions = DatabaseOptions & KyselyServerOptions
 
 const kyselyPlugin: FastifyPluginAsync<KyselyOptions> = async (fastify, { data }) => {
-  /* istanbul ignore next */
+  /* c8 ignore next */
   const filename = data && data.length > 0 ? path.join(data, '/db.sqlite') : ':memory:'
 
   fastify.log.info('[kysely] open sqlite database at %s', filename)

packages/server/src/services/subscriptions/api/ws/protocol.ts

@@ -147,7 +147,7 @@ export default class WebsocketProtocol extends (EventEmitter as new () => Teleme
         socket.on('message', (data: Buffer) => {
           setImmediate(async () => {
             if (resolvedId) {
-              /* istanbul ignore next */
+              /* c8 ignore next */
               this.#safeWrite(socket, resolvedId)
             } else {
               const parsed = $EphemeralSubscription.safeParse(data.toString())

packages/server/src/services/subscriptions/api/ws/routes.ts

@@ -39,7 +39,7 @@ export async function SubscriptionWebSocketsApi(fastify: FastifyInstance) {
     },
   )
 
-  /* istanbul ignore next */
+  /* c8 ignore next */
   fastify.get<{
     Querystring: NodQuerystring
     Params: SubscriptionPathParams
@@ -56,7 +56,7 @@ export async function SubscriptionWebSocketsApi(fastify: FastifyInstance) {
     },
   )
 
-  /* istanbul ignore next */
+  /* c8 ignore next */
   fastify.get<{
     Querystring: NodQuerystring
   }>(

packages/server/src/services/telemetry/plugin.ts

@@ -78,7 +78,7 @@ const telemetryPlugin: FastifyPluginAsync<TelemetryOptions> = async (fastify, op
 
     fastify.addHook('onResponse', createReplyHook())
 
-    /* istanbul ignore next */
+    /* c8 ignore next */
     fastify.get(
       '/metrics',
       {