diff --git a/engine/cli/commands/server_start_cmd.cc b/engine/cli/commands/server_start_cmd.cc index 4268f6362..37ca87fb6 100644 --- a/engine/cli/commands/server_start_cmd.cc +++ b/engine/cli/commands/server_start_cmd.cc @@ -65,16 +65,16 @@ bool ServerStartCmd::Exec(const std::string& host, int port, si.cb = sizeof(si); ZeroMemory(&pi, sizeof(pi)); std::wstring params = L"--start-server"; - params += L" --config_file_path " + - file_manager_utils::GetConfigurationPath().wstring(); - params += L" --data_folder_path " + - file_manager_utils::GetCortexDataPath().wstring(); + params += L" --config_file_path \"" + + file_manager_utils::GetConfigurationPath().wstring() + L"\""; + params += L" --data_folder_path \"" + + file_manager_utils::GetCortexDataPath().wstring() + L"\""; params += L" --loglevel " + cortex::wc::Utf8ToWstring(log_level_); std::wstring exe_w = cortex::wc::Utf8ToWstring(exe); std::wstring current_path_w = file_manager_utils::GetExecutableFolderContainerPath().wstring(); - std::wstring wcmds = current_path_w + L"/" + exe_w + L" " + params; - CTL_DBG("wcmds: " << wcmds); + std::wstring wcmds = current_path_w + L"\\" + exe_w + L" " + params; + CTL_INF("wcmds: " << wcmds); std::vector mutable_cmds(wcmds.begin(), wcmds.end()); mutable_cmds.push_back(L'\0'); // Create child process diff --git a/engine/extensions/remote-engine/remote_engine.cc b/engine/extensions/remote-engine/remote_engine.cc index b843a3d58..659525bef 100644 --- a/engine/extensions/remote-engine/remote_engine.cc +++ b/engine/extensions/remote-engine/remote_engine.cc @@ -31,6 +31,7 @@ size_t StreamWriteCallback(char* ptr, size_t size, size_t nmemb, Json::Reader reader; if (reader.parse(chunk, check_error)) { CTL_WRN(chunk); + CTL_INF("Request: " << context->last_request); Json::Value status; status["is_done"] = true; status["has_error"] = true; @@ -143,7 +144,9 @@ CurlResponse RemoteEngine::MakeStreamingChatCompletionRequest( "", config.model, renderer_, - stream_template}; + stream_template, + true, + body}; curl_easy_setopt(curl, CURLOPT_URL, full_url.c_str()); curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers); diff --git a/engine/extensions/remote-engine/remote_engine.h b/engine/extensions/remote-engine/remote_engine.h index 46222467a..4043a8800 100644 --- a/engine/extensions/remote-engine/remote_engine.h +++ b/engine/extensions/remote-engine/remote_engine.h @@ -25,6 +25,7 @@ struct StreamContext { extensions::TemplateRenderer& renderer; std::string stream_template; bool need_stop = true; + std::string last_request; }; struct CurlResponse { std::string body; diff --git a/engine/services/hardware_service.cc b/engine/services/hardware_service.cc index 5403d707a..7db302a7d 100644 --- a/engine/services/hardware_service.cc +++ b/engine/services/hardware_service.cc @@ -143,16 +143,16 @@ bool HardwareService::Restart(const std::string& host, int port) { ZeroMemory(&pi, sizeof(pi)); // TODO (sang) write a common function for this and server_start_cmd std::wstring params = L"--ignore_cout"; - params += L" --config_file_path " + - file_manager_utils::GetConfigurationPath().wstring(); - params += L" --data_folder_path " + - file_manager_utils::GetCortexDataPath().wstring(); + params += L" --config_file_path \"" + + file_manager_utils::GetConfigurationPath().wstring() + L"\""; + params += L" --data_folder_path \"" + + file_manager_utils::GetCortexDataPath().wstring() + L"\""; params += L" --loglevel " + cortex::wc::Utf8ToWstring(luh::LogLevelStr(luh::global_log_level)); std::wstring exe_w = exe.wstring(); std::wstring current_path_w = file_manager_utils::GetExecutableFolderContainerPath().wstring(); - std::wstring wcmds = current_path_w + L"/" + exe_w + L" " + params; + std::wstring wcmds = current_path_w + L"\\" + exe_w + L" " + params; CTL_DBG("wcmds: " << wcmds); std::vector mutable_cmds(wcmds.begin(), wcmds.end()); mutable_cmds.push_back(L'\0');