chore: update query endpoint

Author: farnabaz

src/module.ts

@@ -196,9 +196,11 @@ export default defineNuxtModule<ModuleOptions>({
       config.alias['#content/local-adapter'] = await resolveDatabaseAdapter(options._localDatabase!.type || 'sqlite', resolveOptions)
 
       config.handlers ||= []
-      config.handlers.push({
-        route: '/__nuxt_content/:collection/query',
-        handler: resolver.resolve('./runtime/api/query.post'),
+      manifest.collections.forEach((collection) => {
+        config.handlers!.push({
+          route: `/__nuxt_content/${collection.name}/query`,
+          handler: resolver.resolve('./runtime/api/query.post'),
+        })
       })
 
       // Handle HMR changes

src/presets/cloudflare.ts

@@ -7,7 +7,7 @@ import { collectionDumpTemplate } from '../utils/templates'
 export default definePreset({
   name: 'cloudflare',
   setup(_options, _nuxt, { resolver, manifest }) {
-    manifest.collections.map(async (collection) => {
+    manifest.collections.map((collection) => {
       addServerHandler({
         route: `/__nuxt_content/${collection.name}/sql_dump.txt`,
         handler: resolver.resolve('./runtime/presets/cloudflare/database-handler'),

src/presets/node.ts

@@ -8,7 +8,7 @@ export default definePreset({
     // Due to prerender enabling in the module, Nuxt create a route for each collection
     // These routes cause issue while enabling cache in Nuxt.
     // So we need to add a server handler for each collection to handle the request.
-    manifest.collections.map(async (collection) => {
+    manifest.collections.map((collection) => {
       addServerHandler({
         route: `/__nuxt_content/${collection.name}/sql_dump.txt`,
         handler: resolver.resolve('./runtime/presets/node/database-handler'),

src/runtime/api/query.post.ts

@@ -6,7 +6,7 @@ import { useRuntimeConfig } from '#imports'
 
 export default eventHandler(async (event) => {
   const { sql } = await readBody(event)
-  const collection = getRouterParam(event, 'collection')!
+  const collection = getRouterParam(event, 'collection')! || event.path?.split('/')?.[2] || ''
 
   assertSafeQuery(sql, collection)