types: update module types

Author: farnabaz

package.json

@@ -87,6 +87,7 @@
     "@types/micromatch": "^4.0.9",
     "@types/node": "^22.8.4",
     "@types/pako": "^2.0.3",
+    "@types/pg": "^8.11.10",
     "@types/ws": "^8.5.12",
     "csvtojson": "^2.0.10",
     "eslint": "^9.13.0",

pnpm-lock.yaml

@@ -11,6 +11,7 @@ import {
   addComponentsDir,
 } from '@nuxt/kit'
 import type { Nuxt } from '@nuxt/schema'
+import type { ModuleOptions as MDCModuleOptions } from '@nuxtjs/mdc'
 import { hash } from 'ohash'
 import { join, dirname, isAbsolute } from 'pathe'
 import fastGlob from 'fast-glob'
@@ -212,7 +213,7 @@ async function processCollectionItems(nuxt: Nuxt, collections: ResolvedCollectio
   const databaseContents = db.fetchDevelopmentCache()
 
   const configHash = hash({
-    mdcHighlight: nuxt.options.mdc?.highlight,
+    mdcHighlight: (nuxt.options as unknown as { mdc: MDCModuleOptions }).mdc?.highlight,
     contentBuild: options.build?.markdown,
   })
 

src/module.ts

@@ -4,7 +4,7 @@ import { createDatabaseAdapter } from '../internal/database-adapter'
 export type PostgreSqlOptions = { url: string } | pg.ClientConfig
 
 let _client: undefined | pg.Client | Promise<pg.Client>
-export default createDatabaseAdapter<PostgreSqlOptions>((opts = {}) => {
+export default createDatabaseAdapter<PostgreSqlOptions>((opts) => {
   function getClient() {
     if (_client) {
       return _client
@@ -33,7 +33,7 @@ export default createDatabaseAdapter<PostgreSqlOptions>((opts = {}) => {
     async first<T>(sql: string, params?: Array<number | string | boolean>) {
       const db = await getClient()
       const { rows } = params ? await db.query<T[], T>(sql, params as QueryConfigValues<T>) : await db.query<T[], T>(sql)
-      return rows[0]
+      return rows[0] as T
     },
     async exec(sql: string): Promise<void> {
       const db = await getClient()

src/runtime/adapters/postgres.ts

@@ -1,13 +1,14 @@
 import { eventHandler, getRouterParam, readValidatedBody } from 'h3'
 import { z } from 'zod'
+import type { RuntimeConfig } from '@nuxt/content'
 import loadDatabaseAdapter, { checkAndImportDatabaseIntegrity } from '../internal/database.server'
 import { useRuntimeConfig } from '#imports'
 
 export default eventHandler(async (event) => {
   const { sql } = await readValidatedBody(event, z.object({ sql: z.string() }).parse)
   const collection = getRouterParam(event, 'collection')!
 
-  const conf = useRuntimeConfig().content
+  const conf = useRuntimeConfig().content as RuntimeConfig
   await checkAndImportDatabaseIntegrity(event, collection, conf)
 
   return loadDatabaseAdapter(conf).all(sql)

src/runtime/api/query.post.ts

@@ -25,10 +25,10 @@ export async function queryCollectionSearchSections(collection: keyof Collection
 
 async function executeContentQuery<T extends keyof Collections, Result = Collections[T]>(collection: T, sql: string) {
   if (import.meta.client) {
-    return await queryContentSqlClientWasm<T, Result>(collection, sql)
+    return queryContentSqlClientWasm<T, Result>(collection, sql) as Promise<Result[]>
   }
   else {
-    return await fetchQuery(tryUseNuxtApp()?.ssrContext?.event, String(collection), sql)
+    return fetchQuery(tryUseNuxtApp()?.ssrContext?.event, String(collection), sql) as Promise<Result[]>
   }
 }
 

src/runtime/app.ts

@@ -1,7 +1,7 @@
 import type { H3Event } from 'h3'
 import { checksums } from '#content/manifest'
 
-export async function fetchDatabase(event: H3Event | undefined, collection: string) {
+export async function fetchDatabase(event: H3Event | undefined, collection: string): Promise<string> {
   return await $fetch(`/api/content/${collection}/database.sql`, {
     context: event ? { clouflare: event.context.cloudflare } : {},
     responseType: 'text',
@@ -10,7 +10,7 @@ export async function fetchDatabase(event: H3Event | undefined, collection: stri
   })
 }
 
-export async function fetchQuery(event: H3Event | undefined, collection: string, sql: string) {
+export async function fetchQuery<Item>(event: H3Event | undefined, collection: string, sql: string): Promise<Item[]> {
   return await $fetch(`/api/content/${collection}/query`, {
     context: event ? { clouflare: event.context.cloudflare } : {},
     headers: { 'content-type': 'application/json' },

src/runtime/internal/api.ts

@@ -1,7 +1,7 @@
 import type { DatabaseAdapter } from '@nuxt/content'
 import { parseJsonFields } from './collection'
 
-export function createDatabaseAdapter<Options = unknown>(factory: (otps?: Options) => DatabaseAdapter) {
+export function createDatabaseAdapter<Options = unknown>(factory: (otps: Options) => DatabaseAdapter) {
   return (opts: Options) => {
     const adapter = factory(opts)
 

src/runtime/internal/database-adapter.ts

@@ -108,7 +108,7 @@ export async function generateNavigationTree<T extends PageCollectionItemBase>(q
 
         // Create dummy parent if not found
         if (!parent) {
-          const navigationConfig = conf ? pickConfigNavigationFields(conf) : {} as ContentNavigationItem
+          const navigationConfig = (conf ? pickConfigNavigationFields(conf) : {}) as ContentNavigationItem
           parent = {
             ...navigationConfig,
             title: navigationConfig.title || generateTitle(part),

src/runtime/internal/navigation.ts

@@ -7,7 +7,7 @@ import { generateSearchSections } from './internal/search'
 import { fetchQuery } from './internal/api'
 
 export const queryCollectionWithEvent = <T extends keyof Collections>(event: H3Event, collection: T): CollectionQueryBuilder<Collections[T]> => {
-  return collectionQureyBuilder<T>(collection, (collection, sql) => fetchQuery(event, collection, sql))
+  return collectionQureyBuilder<T>(collection, (collection, sql) => fetchQuery<T>(event, collection, sql))
 }
 
 export async function queryCollectionNavigationWithEvent<T extends keyof PageCollections>(event: H3Event, collection: T, fields?: Array<keyof PageCollections[T]>) {