fix: download recursive (#1838)

* fix: download recursive

* fix: handle model not loaded

* fix: set permission for all venv folder

* format code

Author: nguyenhoangthuan99

engine/extensions/python-engine/python_engine.cc

@@ -531,6 +531,18 @@ void PythonEngine::HandleInference(
   std::string model = (*json_body)["model"].asString();
   Json::Value body = (*json_body)["body"];
 
+  if (models_.find(model) == models_.end()) {
+    Json::Value error;
+    error["error"] = "Model '" + model + "' is not loaded!";
+    Json::Value status;
+    status["is_done"] = true;
+    status["has_error"] = true;
+    status["is_stream"] = false;
+    status["status_code"] = k400BadRequest;
+    callback(std::move(status), std::move(error));
+    return;
+  }
+
   // Transform Request
   std::string transformed_request;
   if (!transform_request.empty()) {
@@ -699,6 +711,18 @@ void PythonEngine::HandleRouteRequest(
   std::string model = (*json_body)["model"].asString();
   Json::Value body = (*json_body)["body"];
 
+  if (models_.find(model) == models_.end()) {
+    Json::Value error;
+    error["error"] = "Model '" + model + "' is not loaded!";
+    Json::Value status;
+    status["is_done"] = true;
+    status["has_error"] = true;
+    status["is_stream"] = false;
+    status["status_code"] = k400BadRequest;
+    callback(std::move(status), std::move(error));
+    return;
+  }
+
   // Transform Request
   std::string transformed_request;
   if (!transform_request.empty()) {

engine/services/model_service.cc

@@ -582,13 +582,8 @@ ModelService::DownloadModelFromCortexsoAsync(
           pyvenv_cfg.close();
           // Add executable permission to python
 
-#ifdef _WIN32
-          set_permission_utils::SetExecutePermissionsRecursive(
-              venv_path / std::filesystem::path("Scripts"));
-#else
           set_permission_utils::SetExecutePermissionsRecursive(
-              venv_path / std::filesystem::path("bin"));
-#endif
+              venv_path );
 
         } else {
           CTL_ERR("Failed to extract venv.zip");

engine/utils/curl_utils.cc

@@ -271,8 +271,12 @@ cpp::result<Json::Value, std::string> SimpleGetJsonRecursive(
   if (root.isArray()) {
     for (const auto& value : root) {
       if (value["type"].asString() == "directory") {
-        auto temp = SimpleGetJsonRecursive(url + "/" + value["path"].asString(),
-                                           timeout);
+        auto temp = SimpleGetJsonRecursive(
+            url + "/" +
+                std::filesystem::path(value["path"].asString())
+                    .filename()
+                    .string(),
+            timeout);
         if (!temp.has_error()) {
           if (temp.value().isArray()) {
             for (const auto& item : temp.value()) {