|
|
@@ -87,504 +87,864 @@ RtcClient::DescribeAppsOutcomeCallable RtcClient::describeAppsCallable(const Des
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::ModifyConferenceOutcome RtcClient::modifyConference(const ModifyConferenceRequest &request) const
|
|
|
+RtcClient::GetTaskStatusOutcome RtcClient::getTaskStatus(const GetTaskStatusRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return ModifyConferenceOutcome(endpointOutcome.error());
|
|
|
+ return GetTaskStatusOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return ModifyConferenceOutcome(ModifyConferenceResult(outcome.result()));
|
|
|
+ return GetTaskStatusOutcome(GetTaskStatusResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return GetTaskStatusOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::getTaskStatusAsync(const GetTaskStatusRequest& request, const GetTaskStatusAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, getTaskStatus(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::GetTaskStatusOutcomeCallable RtcClient::getTaskStatusCallable(const GetTaskStatusRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<GetTaskStatusOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->getTaskStatus(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::MuteAudioAllOutcome RtcClient::muteAudioAll(const MuteAudioAllRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return MuteAudioAllOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return MuteAudioAllOutcome(MuteAudioAllResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return MuteAudioAllOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::muteAudioAllAsync(const MuteAudioAllRequest& request, const MuteAudioAllAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, muteAudioAll(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::MuteAudioAllOutcomeCallable RtcClient::muteAudioAllCallable(const MuteAudioAllRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<MuteAudioAllOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->muteAudioAll(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::UpdateTaskParamOutcome RtcClient::updateTaskParam(const UpdateTaskParamRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return UpdateTaskParamOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return UpdateTaskParamOutcome(UpdateTaskParamResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return UpdateTaskParamOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::updateTaskParamAsync(const UpdateTaskParamRequest& request, const UpdateTaskParamAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, updateTaskParam(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::UpdateTaskParamOutcomeCallable RtcClient::updateTaskParamCallable(const UpdateTaskParamRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<UpdateTaskParamOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->updateTaskParam(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::DeleteTemplateOutcome RtcClient::deleteTemplate(const DeleteTemplateRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DeleteTemplateOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DeleteTemplateOutcome(DeleteTemplateResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DeleteTemplateOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::deleteTemplateAsync(const DeleteTemplateRequest& request, const DeleteTemplateAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, deleteTemplate(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::DeleteTemplateOutcomeCallable RtcClient::deleteTemplateCallable(const DeleteTemplateRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DeleteTemplateOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->deleteTemplate(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::CreateTemplateOutcome RtcClient::createTemplate(const CreateTemplateRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return CreateTemplateOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return CreateTemplateOutcome(CreateTemplateResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return CreateTemplateOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::createTemplateAsync(const CreateTemplateRequest& request, const CreateTemplateAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, createTemplate(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::CreateTemplateOutcomeCallable RtcClient::createTemplateCallable(const CreateTemplateRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateTemplateOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->createTemplate(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::GetTemplateInfoOutcome RtcClient::getTemplateInfo(const GetTemplateInfoRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return GetTemplateInfoOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return GetTemplateInfoOutcome(GetTemplateInfoResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return GetTemplateInfoOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::getTemplateInfoAsync(const GetTemplateInfoRequest& request, const GetTemplateInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, getTemplateInfo(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::GetTemplateInfoOutcomeCallable RtcClient::getTemplateInfoCallable(const GetTemplateInfoRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<GetTemplateInfoOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->getTemplateInfo(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::DeleteChannelOutcome RtcClient::deleteChannel(const DeleteChannelRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DeleteChannelOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DeleteChannelOutcome(DeleteChannelResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DeleteChannelOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::deleteChannelAsync(const DeleteChannelRequest& request, const DeleteChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, deleteChannel(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::DeleteChannelOutcomeCallable RtcClient::deleteChannelCallable(const DeleteChannelRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DeleteChannelOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->deleteChannel(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::ModifyAppOutcome RtcClient::modifyApp(const ModifyAppRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return ModifyAppOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return ModifyAppOutcome(ModifyAppResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return ModifyAppOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::modifyAppAsync(const ModifyAppRequest& request, const ModifyAppAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, modifyApp(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::ModifyAppOutcomeCallable RtcClient::modifyAppCallable(const ModifyAppRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<ModifyAppOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->modifyApp(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::RemoveParticipantsOutcome RtcClient::removeParticipants(const RemoveParticipantsRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return RemoveParticipantsOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return RemoveParticipantsOutcome(RemoveParticipantsResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return RemoveParticipantsOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::removeParticipantsAsync(const RemoveParticipantsRequest& request, const RemoveParticipantsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, removeParticipants(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::RemoveParticipantsOutcomeCallable RtcClient::removeParticipantsCallable(const RemoveParticipantsRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<RemoveParticipantsOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->removeParticipants(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::GetAllTemplateOutcome RtcClient::getAllTemplate(const GetAllTemplateRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return GetAllTemplateOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return GetAllTemplateOutcome(GetAllTemplateResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return GetAllTemplateOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::getAllTemplateAsync(const GetAllTemplateRequest& request, const GetAllTemplateAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, getAllTemplate(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::GetAllTemplateOutcomeCallable RtcClient::getAllTemplateCallable(const GetAllTemplateRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<GetAllTemplateOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->getAllTemplate(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::DescribeStatisOutcome RtcClient::describeStatis(const DescribeStatisRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DescribeStatisOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DescribeStatisOutcome(DescribeStatisResult(outcome.result()));
|
|
|
else
|
|
|
- return ModifyConferenceOutcome(outcome.error());
|
|
|
+ return DescribeStatisOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::modifyConferenceAsync(const ModifyConferenceRequest& request, const ModifyConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::describeStatisAsync(const DescribeStatisRequest& request, const DescribeStatisAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, modifyConference(request), context);
|
|
|
+ handler(this, request, describeStatis(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::ModifyConferenceOutcomeCallable RtcClient::modifyConferenceCallable(const ModifyConferenceRequest &request) const
|
|
|
+RtcClient::DescribeStatisOutcomeCallable RtcClient::describeStatisCallable(const DescribeStatisRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<ModifyConferenceOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeStatisOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->modifyConference(request);
|
|
|
+ return this->describeStatis(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeConferenceAuthInfoOutcome RtcClient::describeConferenceAuthInfo(const DescribeConferenceAuthInfoRequest &request) const
|
|
|
+RtcClient::CreateChannelOutcome RtcClient::createChannel(const CreateChannelRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeConferenceAuthInfoOutcome(endpointOutcome.error());
|
|
|
+ return CreateChannelOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeConferenceAuthInfoOutcome(DescribeConferenceAuthInfoResult(outcome.result()));
|
|
|
+ return CreateChannelOutcome(CreateChannelResult(outcome.result()));
|
|
|
else
|
|
|
- return DescribeConferenceAuthInfoOutcome(outcome.error());
|
|
|
+ return CreateChannelOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::describeConferenceAuthInfoAsync(const DescribeConferenceAuthInfoRequest& request, const DescribeConferenceAuthInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::createChannelAsync(const CreateChannelRequest& request, const CreateChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, describeConferenceAuthInfo(request), context);
|
|
|
+ handler(this, request, createChannel(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeConferenceAuthInfoOutcomeCallable RtcClient::describeConferenceAuthInfoCallable(const DescribeConferenceAuthInfoRequest &request) const
|
|
|
+RtcClient::CreateChannelOutcomeCallable RtcClient::createChannelCallable(const CreateChannelRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeConferenceAuthInfoOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateChannelOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->describeConferenceAuthInfo(request);
|
|
|
+ return this->createChannel(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeRecordListOutcome RtcClient::describeRecordList(const DescribeRecordListRequest &request) const
|
|
|
+RtcClient::StopTaskOutcome RtcClient::stopTask(const StopTaskRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeRecordListOutcome(endpointOutcome.error());
|
|
|
+ return StopTaskOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeRecordListOutcome(DescribeRecordListResult(outcome.result()));
|
|
|
+ return StopTaskOutcome(StopTaskResult(outcome.result()));
|
|
|
else
|
|
|
- return DescribeRecordListOutcome(outcome.error());
|
|
|
+ return StopTaskOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::describeRecordListAsync(const DescribeRecordListRequest& request, const DescribeRecordListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::stopTaskAsync(const StopTaskRequest& request, const StopTaskAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, describeRecordList(request), context);
|
|
|
+ handler(this, request, stopTask(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeRecordListOutcomeCallable RtcClient::describeRecordListCallable(const DescribeRecordListRequest &request) const
|
|
|
+RtcClient::StopTaskOutcomeCallable RtcClient::stopTaskCallable(const StopTaskRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeRecordListOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<StopTaskOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->describeRecordList(request);
|
|
|
+ return this->stopTask(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::MuteAudioAllOutcome RtcClient::muteAudioAll(const MuteAudioAllRequest &request) const
|
|
|
+RtcClient::GetTaskParamOutcome RtcClient::getTaskParam(const GetTaskParamRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return MuteAudioAllOutcome(endpointOutcome.error());
|
|
|
+ return GetTaskParamOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return MuteAudioAllOutcome(MuteAudioAllResult(outcome.result()));
|
|
|
+ return GetTaskParamOutcome(GetTaskParamResult(outcome.result()));
|
|
|
else
|
|
|
- return MuteAudioAllOutcome(outcome.error());
|
|
|
+ return GetTaskParamOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::muteAudioAllAsync(const MuteAudioAllRequest& request, const MuteAudioAllAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::getTaskParamAsync(const GetTaskParamRequest& request, const GetTaskParamAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, muteAudioAll(request), context);
|
|
|
+ handler(this, request, getTaskParam(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::MuteAudioAllOutcomeCallable RtcClient::muteAudioAllCallable(const MuteAudioAllRequest &request) const
|
|
|
+RtcClient::GetTaskParamOutcomeCallable RtcClient::getTaskParamCallable(const GetTaskParamRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<MuteAudioAllOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<GetTaskParamOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->muteAudioAll(request);
|
|
|
+ return this->getTaskParam(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::UnmuteAudioOutcome RtcClient::unmuteAudio(const UnmuteAudioRequest &request) const
|
|
|
+RtcClient::UpdateChannelOutcome RtcClient::updateChannel(const UpdateChannelRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return UnmuteAudioOutcome(endpointOutcome.error());
|
|
|
+ return UpdateChannelOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return UnmuteAudioOutcome(UnmuteAudioResult(outcome.result()));
|
|
|
+ return UpdateChannelOutcome(UpdateChannelResult(outcome.result()));
|
|
|
else
|
|
|
- return UnmuteAudioOutcome(outcome.error());
|
|
|
+ return UpdateChannelOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::unmuteAudioAsync(const UnmuteAudioRequest& request, const UnmuteAudioAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::updateChannelAsync(const UpdateChannelRequest& request, const UpdateChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, unmuteAudio(request), context);
|
|
|
+ handler(this, request, updateChannel(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::UnmuteAudioOutcomeCallable RtcClient::unmuteAudioCallable(const UnmuteAudioRequest &request) const
|
|
|
+RtcClient::UpdateChannelOutcomeCallable RtcClient::updateChannelCallable(const UpdateChannelRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<UnmuteAudioOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<UpdateChannelOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->unmuteAudio(request);
|
|
|
+ return this->updateChannel(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::MuteAudioOutcome RtcClient::muteAudio(const MuteAudioRequest &request) const
|
|
|
+RtcClient::StartTaskOutcome RtcClient::startTask(const StartTaskRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return MuteAudioOutcome(endpointOutcome.error());
|
|
|
+ return StartTaskOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return MuteAudioOutcome(MuteAudioResult(outcome.result()));
|
|
|
+ return StartTaskOutcome(StartTaskResult(outcome.result()));
|
|
|
else
|
|
|
- return MuteAudioOutcome(outcome.error());
|
|
|
+ return StartTaskOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::muteAudioAsync(const MuteAudioRequest& request, const MuteAudioAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::startTaskAsync(const StartTaskRequest& request, const StartTaskAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, muteAudio(request), context);
|
|
|
+ handler(this, request, startTask(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::MuteAudioOutcomeCallable RtcClient::muteAudioCallable(const MuteAudioRequest &request) const
|
|
|
+RtcClient::StartTaskOutcomeCallable RtcClient::startTaskCallable(const StartTaskRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<MuteAudioOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<StartTaskOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->muteAudio(request);
|
|
|
+ return this->startTask(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::StartAppOutcome RtcClient::startApp(const StartAppRequest &request) const
|
|
|
+RtcClient::ModifyConferenceOutcome RtcClient::modifyConference(const ModifyConferenceRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return StartAppOutcome(endpointOutcome.error());
|
|
|
+ return ModifyConferenceOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return StartAppOutcome(StartAppResult(outcome.result()));
|
|
|
+ return ModifyConferenceOutcome(ModifyConferenceResult(outcome.result()));
|
|
|
else
|
|
|
- return StartAppOutcome(outcome.error());
|
|
|
+ return ModifyConferenceOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::startAppAsync(const StartAppRequest& request, const StartAppAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::modifyConferenceAsync(const ModifyConferenceRequest& request, const ModifyConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, startApp(request), context);
|
|
|
+ handler(this, request, modifyConference(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::StartAppOutcomeCallable RtcClient::startAppCallable(const StartAppRequest &request) const
|
|
|
+RtcClient::ModifyConferenceOutcomeCallable RtcClient::modifyConferenceCallable(const ModifyConferenceRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<StartAppOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<ModifyConferenceOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->startApp(request);
|
|
|
+ return this->modifyConference(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::CreateConferenceOutcome RtcClient::createConference(const CreateConferenceRequest &request) const
|
|
|
+RtcClient::DescribeConferenceAuthInfoOutcome RtcClient::describeConferenceAuthInfo(const DescribeConferenceAuthInfoRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateConferenceOutcome(endpointOutcome.error());
|
|
|
+ return DescribeConferenceAuthInfoOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return CreateConferenceOutcome(CreateConferenceResult(outcome.result()));
|
|
|
+ return DescribeConferenceAuthInfoOutcome(DescribeConferenceAuthInfoResult(outcome.result()));
|
|
|
else
|
|
|
- return CreateConferenceOutcome(outcome.error());
|
|
|
+ return DescribeConferenceAuthInfoOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::createConferenceAsync(const CreateConferenceRequest& request, const CreateConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::describeConferenceAuthInfoAsync(const DescribeConferenceAuthInfoRequest& request, const DescribeConferenceAuthInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, createConference(request), context);
|
|
|
+ handler(this, request, describeConferenceAuthInfo(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::CreateConferenceOutcomeCallable RtcClient::createConferenceCallable(const CreateConferenceRequest &request) const
|
|
|
+RtcClient::DescribeConferenceAuthInfoOutcomeCallable RtcClient::describeConferenceAuthInfoCallable(const DescribeConferenceAuthInfoRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateConferenceOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeConferenceAuthInfoOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->createConference(request);
|
|
|
+ return this->describeConferenceAuthInfo(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DeleteChannelOutcome RtcClient::deleteChannel(const DeleteChannelRequest &request) const
|
|
|
+RtcClient::DescribeRecordListOutcome RtcClient::describeRecordList(const DescribeRecordListRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DeleteChannelOutcome(endpointOutcome.error());
|
|
|
+ return DescribeRecordListOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DeleteChannelOutcome(DeleteChannelResult(outcome.result()));
|
|
|
+ return DescribeRecordListOutcome(DescribeRecordListResult(outcome.result()));
|
|
|
else
|
|
|
- return DeleteChannelOutcome(outcome.error());
|
|
|
+ return DescribeRecordListOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::deleteChannelAsync(const DeleteChannelRequest& request, const DeleteChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::describeRecordListAsync(const DescribeRecordListRequest& request, const DescribeRecordListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, deleteChannel(request), context);
|
|
|
+ handler(this, request, describeRecordList(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DeleteChannelOutcomeCallable RtcClient::deleteChannelCallable(const DeleteChannelRequest &request) const
|
|
|
+RtcClient::DescribeRecordListOutcomeCallable RtcClient::describeRecordListCallable(const DescribeRecordListRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DeleteChannelOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeRecordListOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->deleteChannel(request);
|
|
|
+ return this->describeRecordList(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::ModifyAppOutcome RtcClient::modifyApp(const ModifyAppRequest &request) const
|
|
|
+RtcClient::UnmuteAudioOutcome RtcClient::unmuteAudio(const UnmuteAudioRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return ModifyAppOutcome(endpointOutcome.error());
|
|
|
+ return UnmuteAudioOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return ModifyAppOutcome(ModifyAppResult(outcome.result()));
|
|
|
+ return UnmuteAudioOutcome(UnmuteAudioResult(outcome.result()));
|
|
|
else
|
|
|
- return ModifyAppOutcome(outcome.error());
|
|
|
+ return UnmuteAudioOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::modifyAppAsync(const ModifyAppRequest& request, const ModifyAppAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::unmuteAudioAsync(const UnmuteAudioRequest& request, const UnmuteAudioAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, modifyApp(request), context);
|
|
|
+ handler(this, request, unmuteAudio(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::ModifyAppOutcomeCallable RtcClient::modifyAppCallable(const ModifyAppRequest &request) const
|
|
|
+RtcClient::UnmuteAudioOutcomeCallable RtcClient::unmuteAudioCallable(const UnmuteAudioRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<ModifyAppOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<UnmuteAudioOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->modifyApp(request);
|
|
|
+ return this->unmuteAudio(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeRealTimeRecordDetailOutcome RtcClient::describeRealTimeRecordDetail(const DescribeRealTimeRecordDetailRequest &request) const
|
|
|
+RtcClient::MuteAudioOutcome RtcClient::muteAudio(const MuteAudioRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeRealTimeRecordDetailOutcome(endpointOutcome.error());
|
|
|
+ return MuteAudioOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeRealTimeRecordDetailOutcome(DescribeRealTimeRecordDetailResult(outcome.result()));
|
|
|
+ return MuteAudioOutcome(MuteAudioResult(outcome.result()));
|
|
|
else
|
|
|
- return DescribeRealTimeRecordDetailOutcome(outcome.error());
|
|
|
+ return MuteAudioOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::describeRealTimeRecordDetailAsync(const DescribeRealTimeRecordDetailRequest& request, const DescribeRealTimeRecordDetailAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::muteAudioAsync(const MuteAudioRequest& request, const MuteAudioAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, describeRealTimeRecordDetail(request), context);
|
|
|
+ handler(this, request, muteAudio(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeRealTimeRecordDetailOutcomeCallable RtcClient::describeRealTimeRecordDetailCallable(const DescribeRealTimeRecordDetailRequest &request) const
|
|
|
+RtcClient::MuteAudioOutcomeCallable RtcClient::muteAudioCallable(const MuteAudioRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeRealTimeRecordDetailOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<MuteAudioOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->describeRealTimeRecordDetail(request);
|
|
|
+ return this->muteAudio(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::RemoveParticipantsOutcome RtcClient::removeParticipants(const RemoveParticipantsRequest &request) const
|
|
|
+RtcClient::StartAppOutcome RtcClient::startApp(const StartAppRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return RemoveParticipantsOutcome(endpointOutcome.error());
|
|
|
+ return StartAppOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return RemoveParticipantsOutcome(RemoveParticipantsResult(outcome.result()));
|
|
|
+ return StartAppOutcome(StartAppResult(outcome.result()));
|
|
|
else
|
|
|
- return RemoveParticipantsOutcome(outcome.error());
|
|
|
+ return StartAppOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::removeParticipantsAsync(const RemoveParticipantsRequest& request, const RemoveParticipantsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::startAppAsync(const StartAppRequest& request, const StartAppAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, removeParticipants(request), context);
|
|
|
+ handler(this, request, startApp(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::RemoveParticipantsOutcomeCallable RtcClient::removeParticipantsCallable(const RemoveParticipantsRequest &request) const
|
|
|
+RtcClient::StartAppOutcomeCallable RtcClient::startAppCallable(const StartAppRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<RemoveParticipantsOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<StartAppOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->removeParticipants(request);
|
|
|
+ return this->startApp(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeStatisOutcome RtcClient::describeStatis(const DescribeStatisRequest &request) const
|
|
|
+RtcClient::CreateConferenceOutcome RtcClient::createConference(const CreateConferenceRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeStatisOutcome(endpointOutcome.error());
|
|
|
+ return CreateConferenceOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeStatisOutcome(DescribeStatisResult(outcome.result()));
|
|
|
+ return CreateConferenceOutcome(CreateConferenceResult(outcome.result()));
|
|
|
else
|
|
|
- return DescribeStatisOutcome(outcome.error());
|
|
|
+ return CreateConferenceOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::describeStatisAsync(const DescribeStatisRequest& request, const DescribeStatisAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::createConferenceAsync(const CreateConferenceRequest& request, const CreateConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, describeStatis(request), context);
|
|
|
+ handler(this, request, createConference(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DescribeStatisOutcomeCallable RtcClient::describeStatisCallable(const DescribeStatisRequest &request) const
|
|
|
+RtcClient::CreateConferenceOutcomeCallable RtcClient::createConferenceCallable(const CreateConferenceRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeStatisOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateConferenceOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->describeStatis(request);
|
|
|
+ return this->createConference(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::CreateChannelOutcome RtcClient::createChannel(const CreateChannelRequest &request) const
|
|
|
+RtcClient::DescribeRealTimeRecordDetailOutcome RtcClient::describeRealTimeRecordDetail(const DescribeRealTimeRecordDetailRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateChannelOutcome(endpointOutcome.error());
|
|
|
+ return DescribeRealTimeRecordDetailOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return CreateChannelOutcome(CreateChannelResult(outcome.result()));
|
|
|
+ return DescribeRealTimeRecordDetailOutcome(DescribeRealTimeRecordDetailResult(outcome.result()));
|
|
|
else
|
|
|
- return CreateChannelOutcome(outcome.error());
|
|
|
+ return DescribeRealTimeRecordDetailOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::createChannelAsync(const CreateChannelRequest& request, const CreateChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::describeRealTimeRecordDetailAsync(const DescribeRealTimeRecordDetailRequest& request, const DescribeRealTimeRecordDetailAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, createChannel(request), context);
|
|
|
+ handler(this, request, describeRealTimeRecordDetail(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::CreateChannelOutcomeCallable RtcClient::createChannelCallable(const CreateChannelRequest &request) const
|
|
|
+RtcClient::DescribeRealTimeRecordDetailOutcomeCallable RtcClient::describeRealTimeRecordDetailCallable(const DescribeRealTimeRecordDetailRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateChannelOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeRealTimeRecordDetailOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->createChannel(request);
|
|
|
+ return this->describeRealTimeRecordDetail(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
@@ -735,42 +1095,6 @@ RtcClient::DeleteConferenceOutcomeCallable RtcClient::deleteConferenceCallable(c
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::UpdateChannelOutcome RtcClient::updateChannel(const UpdateChannelRequest &request) const
|
|
|
-{
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
- return UpdateChannelOutcome(endpointOutcome.error());
|
|
|
-
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
-
|
|
|
- if (outcome.isSuccess())
|
|
|
- return UpdateChannelOutcome(UpdateChannelResult(outcome.result()));
|
|
|
- else
|
|
|
- return UpdateChannelOutcome(outcome.error());
|
|
|
-}
|
|
|
-
|
|
|
-void RtcClient::updateChannelAsync(const UpdateChannelRequest& request, const UpdateChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
-{
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
- {
|
|
|
- handler(this, request, updateChannel(request), context);
|
|
|
- };
|
|
|
-
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
-}
|
|
|
-
|
|
|
-RtcClient::UpdateChannelOutcomeCallable RtcClient::updateChannelCallable(const UpdateChannelRequest &request) const
|
|
|
-{
|
|
|
- auto task = std::make_shared<std::packaged_task<UpdateChannelOutcome()>>(
|
|
|
- [this, request]()
|
|
|
- {
|
|
|
- return this->updateChannel(request);
|
|
|
- });
|
|
|
-
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
- return task->get_future();
|
|
|
-}
|
|
|
-
|
|
|
RtcClient::UnmuteAudioAllOutcome RtcClient::unmuteAudioAll(const UnmuteAudioAllRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|