Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion binding.gyp
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@
],
"include_dirs": [
"include",
"include/napi_helpers",
"include/helpers",
"include/placeholders_interface",
"include/sync_root_interface",
"include/sync_root_interface/callbacks",
Expand Down
Binary file modified dist/addon.node
Binary file not shown.
20 changes: 20 additions & 0 deletions include/helpers/check_hresult.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
#ifndef WINRT_CHECK_HRESULT_WRAPPER_H
#define WINRT_CHECK_HRESULT_WRAPPER_H

#include <winrt/base.h>
#include <string>

inline void check_hresult(const char *key, HRESULT hr)
{
try
{
winrt::check_hresult(hr);
}
catch (const winrt::hresult_error &e)
{
std::string msg = std::string("[") + key + "] " + winrt::to_string(e.message());
throw winrt::hresult_error(e.code(), winrt::to_hstring(msg));
}
}

#endif
Original file line number Diff line number Diff line change
Expand Up @@ -4,47 +4,52 @@
#include <string>
#include <tuple>

template<typename T>
template <typename T>
T napi_extract_value(napi_env env, napi_value value);

template<>
inline std::wstring napi_extract_value<std::wstring>(napi_env env, napi_value value) {
template <>
inline std::wstring napi_extract_value<std::wstring>(napi_env env, napi_value value)
{
size_t length;
napi_get_value_string_utf16(env, value, nullptr, 0, &length);

std::wstring result(length + 1, L'\0');
size_t actualLength;
napi_get_value_string_utf16(env, value, reinterpret_cast<char16_t*>(result.data()), length + 1, &actualLength);
napi_get_value_string_utf16(env, value, reinterpret_cast<char16_t *>(result.data()), length + 1, &actualLength);
result.resize(actualLength);

return result;
}

template<>
inline int64_t napi_extract_value<int64_t>(napi_env env, napi_value value) {
template <>
inline int64_t napi_extract_value<int64_t>(napi_env env, napi_value value)
{
int64_t result;
napi_get_value_int64(env, value, &result);
return result;
}

template<>
inline bool napi_extract_value<bool>(napi_env env, napi_value value) {
template <>
inline bool napi_extract_value<bool>(napi_env env, napi_value value)
{
bool result;
napi_get_value_bool(env, value, &result);
return result;
}

template<typename... Types, std::size_t... Is>
inline std::tuple<Types...> napi_extract_args_impl(napi_env env, napi_value* argv, std::index_sequence<Is...>) {
template <typename... Types, std::size_t... Is>
inline std::tuple<Types...> napi_extract_args_impl(napi_env env, napi_value *argv, std::index_sequence<Is...>)
{
return std::make_tuple(napi_extract_value<Types>(env, argv[Is])...);
}

template<typename... Types>
inline std::tuple<Types...> napi_extract_args(napi_env env, napi_callback_info info) {
template <typename... Types>
inline std::tuple<Types...> napi_extract_args(napi_env env, napi_callback_info info)
{
constexpr size_t N = sizeof...(Types);
size_t argc = N;
napi_value argv[N];
napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr);

return napi_extract_args_impl<Types...>(env, argv, std::make_index_sequence<N>{});
}
Original file line number Diff line number Diff line change
Expand Up @@ -6,19 +6,27 @@
#include <string>

template <typename Fn>
napi_value napi_safe_wrap(napi_env env, napi_callback_info info, Fn&& fn, const char* function_name) {
napi_value napi_safe_wrap(napi_env env, napi_callback_info info, Fn &&fn, const char *function_name)
{
std::ostringstream oss;

try {
try
{
return fn(env, info);
} catch (const winrt::hresult_error& e) {
}
catch (const winrt::hresult_error &e)
{
oss << "[" << function_name << "] WinRT error: " << winrt::to_string(e.message()) << " (HRESULT: 0x" << std::hex << e.code() << ")";
} catch (const std::exception& e) {
}
catch (const std::exception &e)
{
oss << "[" << function_name << "] " << e.what();
} catch (...) {
}
catch (...)
{
oss << "[" << function_name << "] Unknown native error";
}

napi_throw_error(env, nullptr, oss.str().c_str());
return nullptr;
}
Expand Down
49 changes: 28 additions & 21 deletions native-src/placeholders_interface/Planceholders.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@
#include <windows.h>
#include <shlobj.h>
#include "convert_to_placeholder.h"
#include <check_hresult.h>

#pragma comment(lib, "shlwapi.lib")

Expand Down Expand Up @@ -50,11 +51,13 @@ void Placeholders::UpdateSyncStatus(const std::wstring &path)
{
auto fileHandle = Placeholders::OpenFileHandle(path, FILE_WRITE_ATTRIBUTES, true);

winrt::check_hresult(CfSetInSyncState(
fileHandle.get(),
CF_IN_SYNC_STATE_IN_SYNC,
CF_SET_IN_SYNC_FLAG_NONE,
nullptr));
check_hresult(
"CfSetInSyncState",
CfSetInSyncState(
fileHandle.get(),
CF_IN_SYNC_STATE_IN_SYNC,
CF_SET_IN_SYNC_FLAG_NONE,
nullptr));

SHChangeNotify(SHCNE_UPDATEITEM, SHCNF_PATH, path.c_str(), nullptr);
}
Expand All @@ -63,16 +66,18 @@ void Placeholders::UpdateFileIdentity(const std::wstring &path, const std::wstri
{
auto fileHandle = OpenFileHandle(path, FILE_WRITE_ATTRIBUTES, true);

winrt::check_hresult(CfUpdatePlaceholder(
fileHandle.get(),
nullptr,
placeholderId.c_str(),
static_cast<DWORD>(placeholderId.size() * sizeof(wchar_t)),
nullptr,
0,
CF_UPDATE_FLAG_NONE,
nullptr,
nullptr));
check_hresult(
"CfUpdatePlaceholder",
CfUpdatePlaceholder(
fileHandle.get(),
nullptr,
placeholderId.c_str(),
static_cast<DWORD>(placeholderId.size() * sizeof(wchar_t)),
nullptr,
0,
CF_UPDATE_FLAG_NONE,
nullptr,
nullptr));
}

FileState Placeholders::GetPlaceholderInfo(const std::wstring &path)
Expand All @@ -85,12 +90,14 @@ FileState Placeholders::GetPlaceholderInfo(const std::wstring &path)
std::vector<char> buffer(infoSize);
auto *info = reinterpret_cast<CF_PLACEHOLDER_BASIC_INFO *>(buffer.data());

winrt::check_hresult(CfGetPlaceholderInfo(
fileHandle.get(),
CF_PLACEHOLDER_INFO_BASIC,
info,
infoSize,
nullptr));
check_hresult(
"CfGetPlaceholderInfo",
CfGetPlaceholderInfo(
fileHandle.get(),
CF_PLACEHOLDER_INFO_BASIC,
info,
infoSize,
nullptr));

std::string placeholderId(reinterpret_cast<const char *>(info->FileIdentity), info->FileIdentityLength);

Expand Down
21 changes: 10 additions & 11 deletions native-src/sync_root_interface/SyncRoot.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
#include <filesystem>
#include <iostream>
#include <vector>
#include <check_hresult.h>

std::map<std::wstring, CF_CONNECTION_KEY> connectionMap;

Expand All @@ -19,14 +20,14 @@ void SyncRoot::ConnectSyncRoot(const wchar_t *syncRootPath, InputSyncCallbacks s

CF_CONNECTION_KEY connectionKey;

HRESULT hr = CfConnectSyncRoot(
syncRootPath,
callbackTable,
nullptr,
CF_CONNECT_FLAG_REQUIRE_PROCESS_INFO | CF_CONNECT_FLAG_REQUIRE_FULL_FILE_PATH,
&connectionKey);

winrt::check_hresult(hr);
check_hresult(
"CfConnectSyncRoot",
CfConnectSyncRoot(
syncRootPath,
callbackTable,
nullptr,
CF_CONNECT_FLAG_REQUIRE_PROCESS_INFO | CF_CONNECT_FLAG_REQUIRE_FULL_FILE_PATH,
&connectionKey));

connectionMap[syncRootPath] = connectionKey;
}
Expand All @@ -36,9 +37,7 @@ void SyncRoot::DisconnectSyncRoot(const wchar_t *syncRootPath)
auto it = connectionMap.find(syncRootPath);
if (it != connectionMap.end())
{
HRESULT hr = CfDisconnectSyncRoot(it->second);

winrt::check_hresult(hr);
check_hresult("CfDisconnectSyncRoot", CfDisconnectSyncRoot(it->second));

connectionMap.erase(it);
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
#include <Callbacks.h>
#include <cfapi.h>
#include <check_hresult.h>
#include <chrono>
#include <codecvt>
#include <condition_variable>
Expand Down Expand Up @@ -76,7 +77,7 @@ napi_value response_callback_fn_fetch_data(napi_env env, napi_callback_info info
if (FAILED(hr))
{
transfer_data(ctx->connectionKey, ctx->transferKey, nullptr, ctx->requiredOffset, ctx->requiredLength, STATUS_UNSUCCESSFUL);
winrt::throw_hresult(hr);
check_hresult("transfer_data", hr);
}

size_t completed = offset + length;
Expand All @@ -90,9 +91,12 @@ napi_value response_callback_fn_fetch_data(napi_env env, napi_callback_info info
winrt::com_ptr<IShellItem2> shellItem;
winrt::com_ptr<IPropertyStore> propStoreVolatile;

winrt::check_hresult(SHCreateItemFromParsingName(ctx->path.c_str(), nullptr, __uuidof(shellItem), shellItem.put_void()));
check_hresult(
"SHCreateItemFromParsingName",
SHCreateItemFromParsingName(ctx->path.c_str(), nullptr, __uuidof(shellItem), shellItem.put_void()));

winrt::check_hresult(
check_hresult(
"shellItem->GetPropertyStore",
shellItem->GetPropertyStore(
GETPROPERTYSTOREFLAGS::GPS_READWRITE | GETPROPERTYSTOREFLAGS::GPS_VOLATILEPROPERTIESONLY,
__uuidof(propStoreVolatile),
Expand Down
3 changes: 2 additions & 1 deletion native-src/virtual_drive/convert_to_placeholder.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
#include "stdafx.h"
#include "napi_extract_args.h"
#include "Placeholders.h"
#include <check_hresult.h>

void convert_to_placeholder(const std::wstring &path, const std::wstring &placeholderId)
{
Expand All @@ -19,7 +20,7 @@ void convert_to_placeholder(const std::wstring &path, const std::wstring &placeh

if (hr != 0x8007017C) // Already a placeholder
{
winrt::check_hresult(hr);
check_hresult("CfConvertToPlaceholder", hr);
}
}

Expand Down
5 changes: 4 additions & 1 deletion native-src/virtual_drive/create_file_placeholder.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
#include "Placeholders.h"
#include "convert_to_placeholder.h"
#include "napi_extract_args.h"
#include <check_hresult.h>

napi_value create_file_placeholder_impl(napi_env env, napi_callback_info info)
{
Expand Down Expand Up @@ -33,7 +34,9 @@ napi_value create_file_placeholder_impl(napi_env env, napi_callback_info info)
cloudEntry.FsMetadata.BasicInfo.LastAccessTime = lastAccessTime;
cloudEntry.FsMetadata.BasicInfo.ChangeTime = lastWriteTime;

winrt::check_hresult(CfCreatePlaceholders(parentPath.c_str(), &cloudEntry, 1, CF_CREATE_FLAG_NONE, NULL));
check_hresult(
"CfCreatePlaceholders",
CfCreatePlaceholders(parentPath.c_str(), &cloudEntry, 1, CF_CREATE_FLAG_NONE, NULL));

return nullptr;
}
6 changes: 5 additions & 1 deletion native-src/virtual_drive/create_folder_placeholder.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
#include "Placeholders.h"
#include "convert_to_placeholder.h"
#include "napi_extract_args.h"
#include <check_hresult.h>

napi_value create_folder_placeholder_impl(napi_env env, napi_callback_info info)
{
Expand Down Expand Up @@ -31,7 +32,10 @@ napi_value create_folder_placeholder_impl(napi_env env, napi_callback_info info)
cloudEntry.FsMetadata.BasicInfo.LastWriteTime = lastWriteTime;
cloudEntry.FsMetadata.BasicInfo.LastAccessTime = lastAccessTime;

winrt::check_hresult(CfCreatePlaceholders(parentPath.c_str(), &cloudEntry, 1, CF_CREATE_FLAG_NONE, NULL));
check_hresult(
"CfCreatePlaceholders",
CfCreatePlaceholders(parentPath.c_str(), &cloudEntry, 1, CF_CREATE_FLAG_NONE, NULL));

Placeholders::UpdateSyncStatus(path);

return nullptr;
Expand Down
15 changes: 9 additions & 6 deletions native-src/virtual_drive/dehydrate_file.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
#include "napi_extract_args.h"
#include "stdafx.h"
#include "Placeholders.h"
#include <check_hresult.h>

napi_value dehydrate_file(napi_env env, napi_callback_info info)
{
Expand All @@ -21,12 +22,14 @@ napi_value dehydrate_file(napi_env env, napi_callback_info info)
LARGE_INTEGER length;
GetFileSizeEx(fileHandle.get(), &length);

winrt::check_hresult(CfDehydratePlaceholder(
fileHandle.get(),
offset,
length,
CF_DEHYDRATE_FLAG_NONE,
nullptr));
check_hresult(
"CfDehydratePlaceholder",
CfDehydratePlaceholder(
fileHandle.get(),
offset,
length,
CF_DEHYDRATE_FLAG_NONE,
nullptr));

return nullptr;
}
15 changes: 9 additions & 6 deletions native-src/virtual_drive/hydrate_file.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
#include <Windows.h>
#include <Placeholders.h>
#include <napi_extract_args.h>
#include <check_hresult.h>

struct AsyncWork
{
Expand All @@ -29,12 +30,14 @@ void hydrate_file(const std::wstring &path)
LARGE_INTEGER length;
GetFileSizeEx(fileHandle.get(), &length);

winrt::check_hresult(CfHydratePlaceholder(
fileHandle.get(),
offset,
length,
CF_HYDRATE_FLAG_NONE,
nullptr));
check_hresult(
"CfHydratePlaceholder",
CfHydratePlaceholder(
fileHandle.get(),
offset,
length,
CF_HYDRATE_FLAG_NONE,
nullptr));
}

void execute_work(napi_env env, void *data)
Expand Down
Loading