|
|
@@ -303,72 +303,72 @@ RtcClient::GetTemplateInfoOutcomeCallable RtcClient::getTemplateInfoCallable(con
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DeleteChannelOutcome RtcClient::deleteChannel(const DeleteChannelRequest &request) const
|
|
|
+RtcClient::ModifyAppOutcome RtcClient::modifyApp(const ModifyAppRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DeleteChannelOutcome(endpointOutcome.error());
|
|
|
+ return ModifyAppOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DeleteChannelOutcome(DeleteChannelResult(outcome.result()));
|
|
|
+ return ModifyAppOutcome(ModifyAppResult(outcome.result()));
|
|
|
else
|
|
|
- return DeleteChannelOutcome(outcome.error());
|
|
|
+ return ModifyAppOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::deleteChannelAsync(const DeleteChannelRequest& request, const DeleteChannelAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+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, deleteChannel(request), context);
|
|
|
+ handler(this, request, modifyApp(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DeleteChannelOutcomeCallable RtcClient::deleteChannelCallable(const DeleteChannelRequest &request) const
|
|
|
+RtcClient::ModifyAppOutcomeCallable RtcClient::modifyAppCallable(const ModifyAppRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DeleteChannelOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<ModifyAppOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->deleteChannel(request);
|
|
|
+ return this->modifyApp(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::ModifyAppOutcome RtcClient::modifyApp(const ModifyAppRequest &request) const
|
|
|
+RtcClient::DeleteChannelOutcome RtcClient::deleteChannel(const DeleteChannelRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return ModifyAppOutcome(endpointOutcome.error());
|
|
|
+ return DeleteChannelOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return ModifyAppOutcome(ModifyAppResult(outcome.result()));
|
|
|
+ return DeleteChannelOutcome(DeleteChannelResult(outcome.result()));
|
|
|
else
|
|
|
- return ModifyAppOutcome(outcome.error());
|
|
|
+ return DeleteChannelOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::modifyAppAsync(const ModifyAppRequest& request, const ModifyAppAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+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, modifyApp(request), context);
|
|
|
+ handler(this, request, deleteChannel(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::ModifyAppOutcomeCallable RtcClient::modifyAppCallable(const ModifyAppRequest &request) const
|
|
|
+RtcClient::DeleteChannelOutcomeCallable RtcClient::deleteChannelCallable(const DeleteChannelRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<ModifyAppOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<DeleteChannelOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->modifyApp(request);
|
|
|
+ return this->deleteChannel(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
@@ -627,6 +627,78 @@ RtcClient::UpdateChannelOutcomeCallable RtcClient::updateChannelCallable(const U
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
+RtcClient::StartMPUTaskOutcome RtcClient::startMPUTask(const StartMPUTaskRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return StartMPUTaskOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return StartMPUTaskOutcome(StartMPUTaskResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return StartMPUTaskOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::startMPUTaskAsync(const StartMPUTaskRequest& request, const StartMPUTaskAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, startMPUTask(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::StartMPUTaskOutcomeCallable RtcClient::startMPUTaskCallable(const StartMPUTaskRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<StartMPUTaskOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->startMPUTask(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::StopMPUTaskOutcome RtcClient::stopMPUTask(const StopMPUTaskRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return StopMPUTaskOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return StopMPUTaskOutcome(StopMPUTaskResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return StopMPUTaskOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void RtcClient::stopMPUTaskAsync(const StopMPUTaskRequest& request, const StopMPUTaskAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, stopMPUTask(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+RtcClient::StopMPUTaskOutcomeCallable RtcClient::stopMPUTaskCallable(const StopMPUTaskRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<StopMPUTaskOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->stopMPUTask(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
RtcClient::StartTaskOutcome RtcClient::startTask(const StartTaskRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
@@ -843,72 +915,72 @@ RtcClient::MuteAudioOutcomeCallable RtcClient::muteAudioCallable(const MuteAudio
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::StartAppOutcome RtcClient::startApp(const StartAppRequest &request) const
|
|
|
+RtcClient::CreateConferenceOutcome RtcClient::createConference(const CreateConferenceRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return StartAppOutcome(endpointOutcome.error());
|
|
|
+ return CreateConferenceOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return StartAppOutcome(StartAppResult(outcome.result()));
|
|
|
+ return CreateConferenceOutcome(CreateConferenceResult(outcome.result()));
|
|
|
else
|
|
|
- return StartAppOutcome(outcome.error());
|
|
|
+ return CreateConferenceOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::startAppAsync(const StartAppRequest& request, const StartAppAsyncHandler& 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, startApp(request), context);
|
|
|
+ handler(this, request, createConference(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::StartAppOutcomeCallable RtcClient::startAppCallable(const StartAppRequest &request) const
|
|
|
+RtcClient::CreateConferenceOutcomeCallable RtcClient::createConferenceCallable(const CreateConferenceRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<StartAppOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateConferenceOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->startApp(request);
|
|
|
+ return this->createConference(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::CreateConferenceOutcome RtcClient::createConference(const CreateConferenceRequest &request) const
|
|
|
+RtcClient::GetMPUTaskStatusOutcome RtcClient::getMPUTaskStatus(const GetMPUTaskStatusRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateConferenceOutcome(endpointOutcome.error());
|
|
|
+ return GetMPUTaskStatusOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return CreateConferenceOutcome(CreateConferenceResult(outcome.result()));
|
|
|
+ return GetMPUTaskStatusOutcome(GetMPUTaskStatusResult(outcome.result()));
|
|
|
else
|
|
|
- return CreateConferenceOutcome(outcome.error());
|
|
|
+ return GetMPUTaskStatusOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::createConferenceAsync(const CreateConferenceRequest& request, const CreateConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::getMPUTaskStatusAsync(const GetMPUTaskStatusRequest& request, const GetMPUTaskStatusAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, createConference(request), context);
|
|
|
+ handler(this, request, getMPUTaskStatus(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::CreateConferenceOutcomeCallable RtcClient::createConferenceCallable(const CreateConferenceRequest &request) const
|
|
|
+RtcClient::GetMPUTaskStatusOutcomeCallable RtcClient::getMPUTaskStatusCallable(const GetMPUTaskStatusRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateConferenceOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<GetMPUTaskStatusOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->createConference(request);
|
|
|
+ return this->getMPUTaskStatus(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
@@ -987,108 +1059,108 @@ RtcClient::DescribeRealTimeRecordListOutcomeCallable RtcClient::describeRealTime
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::StopAppOutcome RtcClient::stopApp(const StopAppRequest &request) const
|
|
|
+RtcClient::RemoveTerminalsOutcome RtcClient::removeTerminals(const RemoveTerminalsRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return StopAppOutcome(endpointOutcome.error());
|
|
|
+ return RemoveTerminalsOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return StopAppOutcome(StopAppResult(outcome.result()));
|
|
|
+ return RemoveTerminalsOutcome(RemoveTerminalsResult(outcome.result()));
|
|
|
else
|
|
|
- return StopAppOutcome(outcome.error());
|
|
|
+ return RemoveTerminalsOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::stopAppAsync(const StopAppRequest& request, const StopAppAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::removeTerminalsAsync(const RemoveTerminalsRequest& request, const RemoveTerminalsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, stopApp(request), context);
|
|
|
+ handler(this, request, removeTerminals(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::StopAppOutcomeCallable RtcClient::stopAppCallable(const StopAppRequest &request) const
|
|
|
+RtcClient::RemoveTerminalsOutcomeCallable RtcClient::removeTerminalsCallable(const RemoveTerminalsRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<StopAppOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<RemoveTerminalsOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->stopApp(request);
|
|
|
+ return this->removeTerminals(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::RemoveTerminalsOutcome RtcClient::removeTerminals(const RemoveTerminalsRequest &request) const
|
|
|
+RtcClient::DeleteConferenceOutcome RtcClient::deleteConference(const DeleteConferenceRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return RemoveTerminalsOutcome(endpointOutcome.error());
|
|
|
+ return DeleteConferenceOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return RemoveTerminalsOutcome(RemoveTerminalsResult(outcome.result()));
|
|
|
+ return DeleteConferenceOutcome(DeleteConferenceResult(outcome.result()));
|
|
|
else
|
|
|
- return RemoveTerminalsOutcome(outcome.error());
|
|
|
+ return DeleteConferenceOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::removeTerminalsAsync(const RemoveTerminalsRequest& request, const RemoveTerminalsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::deleteConferenceAsync(const DeleteConferenceRequest& request, const DeleteConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, removeTerminals(request), context);
|
|
|
+ handler(this, request, deleteConference(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::RemoveTerminalsOutcomeCallable RtcClient::removeTerminalsCallable(const RemoveTerminalsRequest &request) const
|
|
|
+RtcClient::DeleteConferenceOutcomeCallable RtcClient::deleteConferenceCallable(const DeleteConferenceRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<RemoveTerminalsOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<DeleteConferenceOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->removeTerminals(request);
|
|
|
+ return this->deleteConference(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-RtcClient::DeleteConferenceOutcome RtcClient::deleteConference(const DeleteConferenceRequest &request) const
|
|
|
+RtcClient::ReceiveNotifyOutcome RtcClient::receiveNotify(const ReceiveNotifyRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DeleteConferenceOutcome(endpointOutcome.error());
|
|
|
+ return ReceiveNotifyOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return DeleteConferenceOutcome(DeleteConferenceResult(outcome.result()));
|
|
|
+ return ReceiveNotifyOutcome(ReceiveNotifyResult(outcome.result()));
|
|
|
else
|
|
|
- return DeleteConferenceOutcome(outcome.error());
|
|
|
+ return ReceiveNotifyOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void RtcClient::deleteConferenceAsync(const DeleteConferenceRequest& request, const DeleteConferenceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void RtcClient::receiveNotifyAsync(const ReceiveNotifyRequest& request, const ReceiveNotifyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, deleteConference(request), context);
|
|
|
+ handler(this, request, receiveNotify(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-RtcClient::DeleteConferenceOutcomeCallable RtcClient::deleteConferenceCallable(const DeleteConferenceRequest &request) const
|
|
|
+RtcClient::ReceiveNotifyOutcomeCallable RtcClient::receiveNotifyCallable(const ReceiveNotifyRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DeleteConferenceOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<ReceiveNotifyOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->deleteConference(request);
|
|
|
+ return this->receiveNotify(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|