Extract hydrate file

.gitignore

@@ -1,4 +1,3 @@
 /.vscode
 /bin
 /build
-/venv

binding.gyp

@@ -26,7 +26,13 @@
         "native-src/sync_root_interface/callbacks/FetchData/FetchData.cpp",
         "native-src/sync_root_interface/callbacks/FetchData/FileCopierWithProgress.cpp",
         "native-src/sync_root_interface/callbacks/FetchData/TransferContext.cpp",
-        "native-src/virtual_drive/Wrappers.cpp"
+        "native-src/virtual_drive/Wrappers.cpp",
+        "native-src/virtual_drive/connect_sync_root.cpp",
+        "native-src/virtual_drive/create_file_placeholder.cpp",
+        "native-src/virtual_drive/create_folder_placeholder.cpp",
+        "native-src/virtual_drive/get_file_identity.cpp",
+        "native-src/virtual_drive/hydrate_file.cpp",
+        "native-src/virtual_drive/register_sync_root.cpp"
       ],
       "include_dirs": [
         "include",

include/virtual_drive/connect_sync_root.h

@@ -0,0 +1,5 @@
+#pragma once
+
+#include <node_api.h>
+
+napi_value connect_sync_root_impl(napi_env env, napi_callback_info args);

include/virtual_drive/create_file_placeholder.h

@@ -0,0 +1,5 @@
+#pragma once
+
+#include <node_api.h>
+
+napi_value create_file_placeholder_impl(napi_env env, napi_callback_info args);

include/virtual_drive/create_folder_placeholder.h

@@ -0,0 +1,5 @@
+#pragma once
+
+#include <node_api.h>
+
+napi_value create_folder_placeholder_impl(napi_env env, napi_callback_info args);

include/virtual_drive/get_file_identity.h

@@ -0,0 +1,5 @@
+#pragma once
+
+#include <node_api.h>
+
+napi_value get_file_identity_impl(napi_env env, napi_callback_info args);

include/virtual_drive/hydrate_file.h

@@ -0,0 +1,5 @@
+#pragma once
+
+#include <node_api.h>
+
+napi_value hydrate_file_impl(napi_env env, napi_callback_info args);

include/virtual_drive/napi_safe_wrap.h

@@ -0,0 +1,21 @@
+#ifndef NAPI_SAFE_WRAP_H
+#define NAPI_SAFE_WRAP_H
+
+#include <node_api.h>
+#include <exception>
+#include <string>
+
+template <typename Fn>
+napi_value napi_safe_wrap(napi_env env, napi_callback_info info, Fn&& fn) {
+    try {
+        return fn(env, info);
+    } catch (const std::exception& e) {
+        napi_throw_error(env, nullptr, e.what());
+    } catch (...) {
+        napi_throw_error(env, nullptr, "Unknown native error");
+    }
+
+    return nullptr;
+}
+
+#endif

include/virtual_drive/register_sync_root.h

@@ -0,0 +1,5 @@
+#pragma once
+
+#include <node_api.h>
+
+napi_value register_sync_root_impl(napi_env env, napi_callback_info args);

native-src/sync_root_interface/SyncRoot.cpp

@@ -68,12 +68,6 @@ void SyncRoot::HydrateFile(const wchar_t *filePath)
                     wprintf(L"Hydration finished %ls\n", filePath);
                 }
             }
-            // }
-            // else
-            // {
-            //     wprintf(L"File is already hydrated: %ls\n", filePath);
-            //     Logger::getInstance().log("File is already hydrated " + Logger::fromWStringToString(filePath), LogLevel::INFO);
-            // }
         }
     }
 }
@@ -173,8 +167,6 @@ HRESULT SyncRoot::RegisterSyncRoot(const wchar_t *syncRootPath, const wchar_t *p
 
         winrt::StorageProviderSyncRootManager::Register(info);
 
-        Sleep(1000);
-
         return S_OK;
     }
     catch (...)

native-src/sync_root_interface/Utilities.cpp

@@ -45,7 +45,6 @@ void Utilities::AddFolderToSearchIndexer(_In_ PCWSTR folder)
 void Utilities::ApplyTransferStateToFile(_In_ PCWSTR fullPath, _In_ CF_CALLBACK_INFO &callbackInfo, UINT64 total, UINT64 completed)
 {
     Logger::getInstance().log("ApplyTransferStateToFile", LogLevel::INFO);
-    printf("ApplyTransferStateToFile\n");
     // Tell the Cloud File API about progress so that toasts can be displayed
 
     HRESULT hr1 = CfReportProviderProgress(

native-src/sync_root_interface/callbacks/FetchData/FileCopierWithProgress.cpp

@@ -48,7 +48,7 @@ HRESULT FileCopierWithProgress::TransferData(
         {
                 wprintf(L"Error in CfExecute(), HRESULT: %lx\n", hr);
         }
-        printf("TransferData : %s\n", SUCCEEDED(hr) ? "Succeeded" : "Failed");
+        printf("TransferData: %s\n", SUCCEEDED(hr) ? "Succeeded" : "Failed");
 
         return hr;
 }