fix: nas config and logConfig

liuzewen99 · liuzewen99 · commit d91d42227420 · 2026-01-20T11:58:23.000+08:00
diff --git a/__tests__/e2e/nodejs/s_oss_config_auto.yaml b/__tests__/e2e/nodejs/s_oss_config_auto.yaml
@@ -38,4 +38,39 @@ resources:
       handler: index.handler
       memorySize: 128
       timeout: 60
-      ossMountConfig: auto|mountDir=/mnt/test-oss-bucket|bucketPath=/|rules=[{"allowedOrigin":"*","allowedMethod":["GET","POST","PUT","DELETE","HEAD"],"allowedHeader":"*","exposeHeader":"Content-Length","maxAgeSeconds":30}]
+      ossMountConfig: auto|mountDir=/mnt/test-oss-bucket|bucketPath=/|rules=[{"allowedOrigin":"*","allowedMethod":["GET","POST","PUT","DELETE","HEAD"],"allowedHeader":"*","exposeHeader":"Content-Length","maxAgeSeconds":30}]
+
+  fcDemo3: # 业务名称/模块名称
+    component: ${env('fc_component_version', path('../../../'))}
+    actions:
+      pre-deploy:
+        - run: npm install
+          path: ./test-auto-code
+    props: # 组件的属性值
+      region: ${vars.region}
+      functionName: fc3-event-${env('fc_component_function_name', 'nodejs18')}-nasConfig
+      role: acs:ram::${config('AccountID')}:role/aliyunaliyunfcdefaultrole
+      runtime: ${env('fc_component_runtime', 'nodejs18')}
+      code: ./test-auto-code
+      handler: index.handler
+      memorySize: 128
+      timeout: 60
+      nasConfig: auto|mountDir=/mnt/fcDir|nasDir=nasDir
+      vpcConfig: auto
+
+  fcDemo4: # 业务名称/模块名称
+    component: ${env('fc_component_version', path('../../../'))}
+    actions:
+      pre-deploy:
+        - run: npm install
+          path: ./test-auto-code
+    props: # 组件的属性值
+      region: ${vars.region}
+      functionName: fc3-event-${env('fc_component_function_name', 'nodejs18')}-logConfig
+      role: acs:ram::${config('AccountID')}:role/aliyunaliyunfcdefaultrole
+      runtime: ${env('fc_component_runtime', 'nodejs18')}
+      code: ./test-auto-code
+      handler: index.handler
+      memorySize: 128
+      timeout: 60
+      logConfig: auto|enableRequestMetrics=false|enableInstanceMetrics=false
diff --git a/src/subCommands/deploy/impl/function.ts b/src/subCommands/deploy/impl/function.ts
@@ -18,7 +18,7 @@ import FC, { GetApiType } from '../../../resources/fc';
 import VPC_NAS from '../../../resources/vpc-nas';
 import Base from './base';
 import { ICredentials } from '@serverless-devs/component-interface';
-import { calculateCRC64, getFileSize } from '../../../utils';
+import { calculateCRC64, getFileSize, parseAutoConfig, checkFcDir } from '../../../utils';
 import OSS from '../../../resources/oss';
 import { setNodeModulesBinPermissions } from '../../../resources/fc/impl/utils';
 
@@ -349,22 +349,30 @@ export default class Service extends Base {
     if (slsAuto) {
       const sls = new Sls(region, credential as ICredentials);
       const { project, logstore } = await sls.deploy();
+      const logAutoConfig = parseAutoConfig(this.local.logConfig as string);
+      const logParams = logAutoConfig?.params || {};
+      const customFields: Record<string, any> = { ...logParams };
+      const getConfigValue = (field: string, defaultValue: any) => {
+        return field in customFields ? customFields[field] : defaultValue;
+      };
       logger.write(
         yellow(`Created log resource succeeded, please replace logConfig: auto in yaml with:
 logConfig:
-  enableInstanceMetrics: true
-  enableRequestMetrics: true
-  logBeginRule: DefaultRegex
+  enableInstanceMetrics: ${getConfigValue('enableInstanceMetrics', true)}
+  enableRequestMetrics: ${getConfigValue('enableRequestMetrics', true)}
+  logBeginRule: ${getConfigValue('logBeginRule', 'DefaultRegex')}
   logstore: ${logstore}
   project: ${project}\n`),
       );
+
       this.createResource.sls = { project, logstore };
       _.set(this.local, 'logConfig', {
-        enableInstanceMetrics: true,
-        enableRequestMetrics: true,
-        logBeginRule: 'DefaultRegex',
+        enableInstanceMetrics: getConfigValue('enableInstanceMetrics', true),
+        enableRequestMetrics: getConfigValue('enableRequestMetrics', true),
+        logBeginRule: getConfigValue('logBeginRule', 'DefaultRegex'),
         logstore,
         project,
+        ...customFields,
       });
     }
 
@@ -443,7 +451,12 @@ vpcConfig:
         _.set(this.local, 'vpcConfig', vpcConfig);
       }
       if (nasAuto) {
-        let serverAddr = `${mountTargetDomain}:/${functionName}`;
+        const { params } = parseAutoConfig(this.local.nasConfig as string);
+        const fcDir = params.mountDir
+          ? checkFcDir(params.mountDir, 'mountDir')
+          : `/mnt/${functionName}`;
+        const nasDir = params.nasDir ? params.nasDir : `${functionName}`;
+        let serverAddr = `${mountTargetDomain}:${nasDir.startsWith('/') ? '' : '/'}${nasDir}`;
         if (serverAddr.length > 128) {
           serverAddr = serverAddr.substring(0, 128);
         }
@@ -454,8 +467,9 @@ nasConfig:
   userId: 0
   mountPoints:
     - serverAddr: ${serverAddr}
-      mountDir: /mnt/${functionName}
-      enableTLS: false\n`),
+      mountDir: ${fcDir}
+      enableTLS: false
+`),
         );
         this.createResource.nas = { mountTargetDomain, fileSystemId };
         _.set(this.local, 'nasConfig', {
@@ -464,7 +478,7 @@ nasConfig:
           mountPoints: [
             {
               serverAddr,
-              mountDir: `/mnt/${functionName}`,
+              mountDir: fcDir,
               enableTLS: false,
             },
           ],
diff --git a/src/subCommands/model/index.ts b/src/subCommands/model/index.ts
@@ -14,6 +14,7 @@ import { OSSMountPoint, VPCConfig } from '@alicloud/fc20230330';
 import { MODEL_DOWNLOAD_TIMEOUT } from './constants';
 import { initClient } from './utils';
 import * as $Dev20230714 from '@alicloud/devs20230714';
+import { parseAutoConfig, checkFcDir } from '../../utils';
 
 const commandsList = Object.keys(commandsHelp.subCommands);
 
@@ -239,7 +240,13 @@ vpcConfig:
     }
 
     if (nasAuto) {
-      let serverAddr = `${mountTargetDomain}:/${functionName}`;
+      const nasAutoConfig = parseAutoConfig(this.local.nasConfig as string);
+      const params = nasAutoConfig?.params || {};
+      const fcDir = params.mountDir
+        ? checkFcDir(params.mountDir, 'mountDir')
+        : `/mnt/${functionName}`;
+      const nasDir = params.nasDir ? params.nasDir : `${functionName}`;
+      let serverAddr = `${mountTargetDomain}:${nasDir.startsWith('/') ? '' : '/'}${nasDir}`;
       if (serverAddr.length > 128) {
         serverAddr = serverAddr.substring(0, 128);
       }
@@ -250,7 +257,7 @@ groupId: 0
 userId: 0
 mountPoints:
   - serverAddr: ${serverAddr}
-    mountDir: /mnt/${functionName}
+    mountDir: ${fcDir}
     enableTLS: false\n`),
       );
       this.createResource.nas = { mountTargetDomain, fileSystemId };
@@ -260,7 +267,7 @@ mountPoints:
         mountPoints: [
           {
             serverAddr,
-            mountDir: `/mnt/${functionName}`,
+            mountDir: fcDir,
             enableTLS: false,
           },
         ],
diff --git a/src/utils/index.ts b/src/utils/index.ts
@@ -49,6 +49,40 @@ export const isAuto = (config: unknown): boolean => {
   return _.toUpper(autoConfig) === 'AUTO';
 };
 
+export const parseAutoConfig = (
+  config: string,
+): { isAuto: boolean; params: Record<string, any> } => {
+  if (!_.isString(config)) {
+    return { isAuto: false, params: {} };
+  }
+
+  const parts = config.split('|');
+  const baseConfig = parts[0];
+  logger.debug(`parseAutoConfig, baseConfig = ${baseConfig}`);
+
+  if (_.toUpper(baseConfig) === 'AUTO') {
+    const params: Record<string, any> = {};
+    for (let i = 1; i < parts.length; i++) {
+      const [key, value] = parts[i].split('=');
+      if (key && value) {
+        const trimmedValue = value.trim();
+        if (typeof trimmedValue === 'string') {
+          try {
+            params[key.trim()] = JSON.parse(trimmedValue);
+          } catch (error) {
+            params[key.trim()] = trimmedValue;
+          }
+        } else {
+          params[key.trim()] = trimmedValue;
+        }
+      }
+    }
+    return { isAuto: true, params };
+  }
+
+  return { isAuto: false, params: {} };
+};
+
 export const isAutoVpcConfig = (config: unknown): boolean => {
   logger.debug(`isAutoVpcConfig, vpcConfig = ${JSON.stringify(config)}`);
   if (_.isString(config)) {
@@ -223,3 +257,80 @@ export function getUserAgent(userAgent: string, command: string) {
   }
   return `${function_ai}Component:fc3;Nodejs:${process.version};OS:${process.platform}-${process.arch}command:${command}`;
 }
+
+/**
+ * 验证并规范化路径
+ */
+export function checkFcDir(path: string, paramName = 'path'): string {
+  if (typeof path !== 'string') {
+    const message = `Invalid ${paramName}, expected string but got ${typeof path}`;
+    throw new Error(message);
+  }
+
+  if (!path) {
+    const message = `Empty ${paramName}, value is required`;
+    throw new Error(message);
+  }
+
+  let normalizedPath = path.trim();
+
+  if (!normalizedPath.startsWith('/')) {
+    normalizedPath = `/${normalizedPath}`;
+    logger.debug(`${paramName} does not start with '/', prepending '/'`);
+  }
+
+  if (normalizedPath.length > 1 && normalizedPath.endsWith('/')) {
+    normalizedPath = normalizedPath.slice(0, -1);
+    logger.debug(`${paramName} ends with '/', removing trailing '/'`);
+  }
+
+  // 检查路径长度
+  if (normalizedPath.length > 128) {
+    const message = `${paramName} is too long (${normalizedPath.length}), maximum length is 128 characters`;
+    throw new Error(message);
+  }
+
+  // 检查不允许的系统目录前缀
+  const forbiddenPrefixes = [
+    '/bin',
+    '/boot',
+    '/dev',
+    '/etc',
+    '/lib',
+    '/lib64',
+    '/media',
+    '/opt',
+    '/proc',
+    '/root',
+    '/run',
+    '/sbin',
+    '/srv',
+    '/sys',
+    '/usr',
+    '/var',
+  ];
+
+  for (const prefix of forbiddenPrefixes) {
+    if (normalizedPath === prefix || normalizedPath.startsWith(`${prefix}/`)) {
+      const message = `Invalid ${paramName}, ${prefix} and its subdirectories are not allowed`;
+      throw new Error(message);
+    }
+  }
+
+  // 检查 /mnt 是否为顶级目录且没有子目录
+  if (normalizedPath === '/mnt' || normalizedPath === '/mnt/') {
+    const message = `Invalid ${paramName}, /mnt without subdirectory is not allowed`;
+    throw new Error(message);
+  }
+
+  // 如果路径是以 /mnt 开头，确保它有子目录
+  if (normalizedPath.startsWith('/mnt/')) {
+    const remainingPath = normalizedPath.substring(4);
+    if (!remainingPath || remainingPath.split('/').every((part) => !part.trim())) {
+      const message = `Invalid ${paramName}, /mnt path must have subdirectories`;
+      throw new Error(message);
+    }
+  }
+
+  return normalizedPath;
+}
