fix: 修正GraphQL无法正常读取的问题

- 将graphql查询文件移至server/assets，他们在构建后会以二进制形式写入server的存储中
- 在server端通过storage读取数据

server/api/cms/companyProfile.ts

@@ -1,12 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(
-    path.resolve('graphql/companyProfile.graphql'),
-    'utf-8'
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/companyProfile.graphql'
   );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ company_profile: CompanyProfile }>(

server/api/cms/contactInfo.ts

@@ -1,12 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(
-    path.resolve('graphql/contactInfo.graphql'),
-    'utf-8'
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/contactInfo.graphql'
   );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ contact_info: ContactInfo }>(query, {

server/api/cms/documentList.ts

@@ -1,12 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(
-    path.resolve('graphql/documentList.graphql'),
-    'utf-8'
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/documentList.graphql'
   );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ product_documents: ProductDocument[] }>(

server/api/cms/homepage.ts

@@ -1,9 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(path.resolve('graphql/homepage.graphql'), 'utf-8');
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/homepage.graphql'
+  );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ homepage: Homepage }>(query, {

server/api/cms/product/[id].ts

@@ -1,6 +1,5 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
   const id = getRouterParam(event, 'id');
@@ -10,7 +9,13 @@ export default defineEventHandler(async (event) => {
       statusMessage: 'Product ID is required',
     });
 
-  const query = readFileSync(path.resolve('graphql/product.graphql'), 'utf-8');
+  const query = await loadAssetAsString(
+    'assets/server',
+    'graphql/product.graphql'
+  );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ products_by_id: Product }>(query, {

server/api/cms/productList.ts

@@ -1,12 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(
-    path.resolve('graphql/productList.graphql'),
-    'utf-8'
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/productList.graphql'
   );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ products: Product[] }>(query, {

server/api/cms/questionList.ts

@@ -1,12 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(
-    path.resolve('graphql/questionList.graphql'),
-    'utf-8'
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/questionList.graphql'
   );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ questions: Question[] }>(query, {

server/api/cms/solution/[id].ts

@@ -1,6 +1,5 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
   const id = getRouterParam(event, 'id');
@@ -10,7 +9,13 @@ export default defineEventHandler(async (event) => {
       statusMessage: 'Solution ID is required',
     });
 
-  const query = readFileSync(path.resolve('graphql/solution.graphql'), 'utf-8');
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/solution.graphql'
+  );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ solutions_by_id: Solution }>(query, {

server/api/cms/solutionList.ts

@@ -1,12 +1,14 @@
 import { directus } from '~~/server/utils/directus';
-import { readFileSync } from 'node:fs';
-import path from 'node:path';
+import { loadAssetAsString } from '~~/server/utils/serverAssets';
 
 export default defineEventHandler(async (event) => {
-  const query = readFileSync(
-    path.resolve('graphql/solutionList.graphql'),
-    'utf-8'
+  const query = await loadAssetAsString(
+    'assets:server',
+    'graphql/solutionList.graphql'
   );
+  if (!query)
+    throw createError({ statusCode: 500, message: 'GraphQL query not found' });
+
   const locale = getHeader(event, 'x-locale') || 'zh-CN';
 
   const data = await directus.query<{ solutions: Solution[] }>(query, {

server/utils/serverAssets.ts

@@ -0,0 +1,24 @@
+/**
+ * 将存储中的资源作为字符串加载
+ *
+ * @param storage - 存储名称
+ * @param path - 资源路径
+ *
+ * ---
+ *  @example
+ *  const content = await loadAssetAsString('myStorage', 'path/to/asset.txt');
+ *  // typeof content === 'string'
+ */
+export async function loadAssetAsString(
+  storage: string,
+  path: string
+): Promise<string> {
+  const data = await useStorage(storage).getItem(path);
+  if (data instanceof Uint8Array) {
+    return Buffer.from(data).toString('utf-8');
+  }
+  if (typeof data === 'string') {
+    return data;
+  }
+  throw new Error(`Invalid asset type for ${path}`);
+}