mirror of
https://github.com/RetroShare/RetroShare.git
synced 2024-10-01 02:35:48 -04:00
81 lines
3.1 KiB
Cheetah
81 lines
3.1 KiB
Cheetah
/*******************************************************************************
|
|
* RetroShare JSON API *
|
|
* *
|
|
* Copyright (C) 2018-2019 Gioacchino Mazzurco <gio@eigenlab.org> *
|
|
* *
|
|
* This program is free software: you can redistribute it and/or modify *
|
|
* it under the terms of the GNU Affero General Public License version 3 as *
|
|
* published by the Free Software Foundation. *
|
|
* *
|
|
* This program is distributed in the hope that it will be useful, *
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
* GNU Affero General Public License for more details. *
|
|
* *
|
|
* You should have received a copy of the GNU Affero General Public License *
|
|
* along with this program. If not, see <https://www.gnu.org/licenses/>. *
|
|
* *
|
|
*******************************************************************************/
|
|
|
|
registerHandler( "$%apiPath%$",
|
|
[this](const std::shared_ptr<rb::Session> session)
|
|
{
|
|
const std::multimap<std::string, std::string> headers
|
|
{
|
|
{ "Connection", "keep-alive" },
|
|
{ "Content-Type", "text/event-stream" }
|
|
};
|
|
session->yield(rb::OK, headers);
|
|
|
|
size_t reqSize = session->get_request()->get_header("Content-Length", 0);
|
|
session->fetch( reqSize, [this](
|
|
const std::shared_ptr<rb::Session> session,
|
|
const rb::Bytes& body )
|
|
{
|
|
INITIALIZE_API_CALL_JSON_CONTEXT;
|
|
|
|
if( !checkRsServicePtrReady(
|
|
$%instanceName%$, "$%instanceName%$", cAns, session ) )
|
|
return;
|
|
|
|
$%paramsDeclaration%$
|
|
|
|
$%inputParamsDeserialization%$
|
|
|
|
const std::weak_ptr<rb::Service> weakService(mService);
|
|
const std::weak_ptr<rb::Session> weakSession(session);
|
|
$%callbackName%$ = [this, weakService, weakSession]($%callbackParams%$)
|
|
{
|
|
auto session = weakSession.lock();
|
|
if(!session || session->is_closed()) return;
|
|
|
|
auto lService = weakService.lock();
|
|
if(!lService || lService->is_down()) return;
|
|
|
|
$%callbackParamsSerialization%$
|
|
|
|
std::stringstream sStream;
|
|
sStream << "data: " << compactJSON << ctx.mJson << "\n\n";
|
|
const std::string message = sStream.str();
|
|
|
|
lService->schedule( [weakSession, message]()
|
|
{
|
|
auto session = weakSession.lock();
|
|
if(!session || session->is_closed()) return;
|
|
session->yield(message);
|
|
$%sessionEarlyClose%$
|
|
} );
|
|
};
|
|
|
|
$%functionCall%$
|
|
|
|
$%outputParamsSerialization%$
|
|
|
|
// return them to the API caller
|
|
std::stringstream message;
|
|
message << "data: " << compactJSON << cAns.mJson << "\n\n";
|
|
session->yield(message.str());
|
|
$%sessionDelayedClose%$
|
|
} );
|
|
}, $%requiresAuth%$ );
|