mirror of
https://github.com/kidfromjupiter/nearby.git
synced 2026-09-16 15:36:12 -04:00
105 lines
3.6 KiB
C++
105 lines
3.6 KiB
C++
// Copyright 2022 Google LLC
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// https://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
#include "sharing/nearby_connections_service.h"
|
|
|
|
#include <algorithm>
|
|
#include <cstdint>
|
|
#include <filesystem> // NOLINT(build/c++17)
|
|
#include <functional>
|
|
#include <string>
|
|
#include <utility>
|
|
#include <vector>
|
|
|
|
#include "internal/platform/file.h"
|
|
#include "sharing/common/compatible_u8_string.h"
|
|
#include "sharing/internal/public/logging.h"
|
|
#include "sharing/nearby_connections_types.h"
|
|
|
|
namespace nearby {
|
|
namespace sharing {
|
|
|
|
Status ConvertToStatus(NcStatus status) {
|
|
return static_cast<Status>(status.value);
|
|
}
|
|
|
|
Payload ConvertToPayload(NcPayload payload) {
|
|
switch (payload.GetType()) {
|
|
case NcPayloadType::kBytes: {
|
|
NcByteArray bytes = payload.AsBytes();
|
|
std::string data = std::string(bytes);
|
|
return Payload(payload.GetId(),
|
|
std::vector<uint8_t>(data.begin(), data.end()));
|
|
}
|
|
case NcPayloadType::kFile: {
|
|
std::filesystem::path file_path =
|
|
std::filesystem::u8path(payload.AsFile()->GetFilePath());
|
|
std::string parent_folder = payload.GetParentFolder();
|
|
NL_VLOG(1) << __func__ << ": Payload file_path=" << file_path
|
|
<< ", parent_folder = " << parent_folder;
|
|
return Payload(payload.GetId(), InputFile(file_path), parent_folder);
|
|
}
|
|
default:
|
|
return Payload();
|
|
}
|
|
}
|
|
|
|
NcPayload ConvertToServicePayload(Payload payload) {
|
|
switch (payload.content.type) {
|
|
case PayloadContent::Type::kFile: {
|
|
int64_t file_size = payload.content.file_payload.size;
|
|
std::string file_path = GetCompatibleU8String(
|
|
payload.content.file_payload.file.path.u8string());
|
|
std::string file_name = GetCompatibleU8String(
|
|
payload.content.file_payload.file.path.filename().u8string());
|
|
std::string parent_folder = payload.content.file_payload.parent_folder;
|
|
std::replace(parent_folder.begin(), parent_folder.end(), '\\', '/');
|
|
NL_VLOG(1) << __func__ << ": NC Payload file_path=" << file_path
|
|
<< ", parent_folder = " << parent_folder;
|
|
nearby::InputFile input_file(file_path, file_size);
|
|
NcPayload nc_payload(payload.id, parent_folder, file_name,
|
|
std::move(input_file));
|
|
return nc_payload;
|
|
}
|
|
case PayloadContent::Type::kBytes: {
|
|
std::vector<uint8_t> bytes = payload.content.bytes_payload.bytes;
|
|
return NcPayload(payload.id,
|
|
NcByteArray(std::string(bytes.begin(), bytes.end())));
|
|
}
|
|
default:
|
|
return NcPayload();
|
|
}
|
|
}
|
|
|
|
NcResultCallback BuildResultCallback(
|
|
std::function<void(Status status)> callback) {
|
|
return NcResultCallback{[&, callback = std::move(callback)](NcStatus status) {
|
|
callback(ConvertToStatus(status));
|
|
}};
|
|
}
|
|
|
|
NcStrategy ConvertToServiceStrategy(Strategy strategy) {
|
|
switch (strategy) {
|
|
case Strategy::kP2pCluster:
|
|
return NcStrategy::kP2pCluster;
|
|
case Strategy::kP2pPointToPoint:
|
|
return NcStrategy::kP2pPointToPoint;
|
|
case Strategy::kP2pStar:
|
|
return NcStrategy::kP2pStar;
|
|
}
|
|
}
|
|
|
|
} // namespace sharing
|
|
} // namespace nearby
|