Method execute

backend/app/executors/advanced_share.py:16–75

(self, config: dict, context: ExecutionContext)

        return "share_folder"

    async def execute(self, config: dict, context: ExecutionContext) -> ModuleResult:
        from app.services.file_share import start_file_share, get_local_ip
        
        folder_path = context.resolve_value(config.get("folderPath", ""))
        port = to_int(config.get("port", 8080), 8080, context)
        share_name = context.resolve_value(config.get("shareName", "")) or "共享文件夹"
        result_variable = config.get("resultVariable", "share_url")
        allow_write = config.get("allowWrite", True)  # 默认允许写操作
        
        if not folder_path:
            return ModuleResult(success=False, error="文件夹路径不能为空")
        
        folder = Path(folder_path)
        if not folder.exists():
            return ModuleResult(success=False, error=f"文件夹不存在: {folder_path}")
        
        if not folder.is_dir():
            return ModuleResult(success=False, error=f"路径不是文件夹: {folder_path}")
        
        try:
            result = start_file_share(
                path=str(folder.resolve()),
                port=port,
                share_type='folder',
                name=share_name,
                allow_write=allow_write
            )
            
            if not result['success']:
                return ModuleResult(success=False, error=result.get('error', '启动共享服务失败'))
            
            share_url = result['url']
            local_ip = result['ip']
            
            if result_variable:
                context.set_variable(result_variable, share_url)
            
            write_mode = "可上传/删除" if allow_write else "仅下载"
            message = f"📂 文件夹共享已启动！\n" \
                      f"共享名称: {share_name}\n" \
                      f"共享路径: {folder_path}\n" \
                      f"访问地址: {share_url}\n" \
                      f"权限模式: {write_mode}\n" \
                      f"💡 同局域网的设备可以使用浏览器访问上述地址来浏览和下载文件"
            
            return ModuleResult(
                success=True,
                message=message,
                data={
                    'url': share_url,
                    'ip': local_ip,
                    'port': port,
                    'path': str(folder.resolve()),
                    'name': share_name,
                    'allowWrite': allow_write
                }
            )