client-sdk-cpp/src/remote_data_track.cpp at main · Soralsei/client-sdk-cpp · GitHub

History

92 lines (75 loc) · 3.17 KB

Raw

* 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

* http://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 "livekit/remote_data_track.h"

#include <stdexcept>

#include "data_track.pb.h"

#include "ffi.pb.h"

#include "ffi_client.h"

#include "lk_log.h"

namespace livekit {

RemoteDataTrack::RemoteDataTrack(const proto::OwnedRemoteDataTrack& owned)

: handle_(static_cast<uintptr_t>(owned.handle().id())), publisher_identity_(owned.publisher_identity()) {

const auto& pi = owned.info();

info_.name = pi.name();

info_.sid = pi.sid();

info_.uses_e2ee = pi.uses_e2ee();

}

bool RemoteDataTrack::isPublished() const {

if (!handle_.valid()) {

return false;

}

proto::FfiRequest req;

auto* msg = req.mutable_remote_data_track_is_published();

msg->set_track_handle(static_cast<uint64_t>(handle_.get()));

const proto::FfiResponse resp = FfiClient::instance().sendRequest(req);

return resp.remote_data_track_is_published().is_published();

}

void RemoteDataTrack::setPipelineOptions(const DataTrackPipelineOptions& options) {

if (!handle_.valid()) {

return;

}

proto::FfiRequest req;

auto* msg = req.mutable_remote_data_track_set_pipeline_options();

msg->set_track_handle(static_cast<uint64_t>(handle_.get()));

auto* opts = msg->mutable_options();

if (options.max_partial_frames) {

opts->set_max_partial_frames(*options.max_partial_frames);

}

FfiClient::instance().sendRequest(req);

}

Result<std::shared_ptr<DataTrackStream>, SubscribeDataTrackError> RemoteDataTrack::subscribe(

const DataTrackStream::Options& options) {

if (!handle_.valid()) {

LK_LOG_WARN("Subscribe data track failed: code={} message={}",

static_cast<std::uint32_t>(SubscribeDataTrackErrorCode::INVALID_HANDLE),

"RemoteDataTrack::subscribe: invalid FFI handle");

return Result<std::shared_ptr<DataTrackStream>, SubscribeDataTrackError>::failure(

SubscribeDataTrackError{SubscribeDataTrackErrorCode::INVALID_HANDLE,

"RemoteDataTrack::subscribe: invalid FFI "

"handle"});

}

auto result =

FfiClient::instance().subscribeDataTrack(static_cast<std::uint64_t>(handle_.get()), options.buffer_size);

if (!result) {

return Result<std::shared_ptr<DataTrackStream>, SubscribeDataTrackError>::failure(std::move(result).error());

}

const proto::OwnedDataTrackStream owned_sub = result.value();

FfiHandle sub_handle(static_cast<uintptr_t>(owned_sub.handle().id()));

auto stream = std::shared_ptr<DataTrackStream>(new DataTrackStream());

stream->init(std::move(sub_handle));

return Result<std::shared_ptr<DataTrackStream>, SubscribeDataTrackError>::success(std::move(stream));

}

} // namespace livekit

client-sdk-cpp/src/remote_data_track.cpp at main · Soralsei/client-sdk-cpp · GitHub

Expand file tree

Breadcrumbs

remote_data_track.cpp

Latest commit

History

Breadcrumbs

remote_data_track.cpp

File metadata and controls