ResourceServer.cpp File Reference

#include "express/legacy/in/WebApp.h"
#include "express/middleware/JsonMiddleware.h"
#include "log/Logger.h"
#include "web/http/legacy/in/Client.h"
#include <nlohmann/json.hpp>
#include <string>

Include dependency graph for ResourceServer.cpp:

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 53 of file ResourceServer.cpp.

                                 {
    express::WebApp::init(argc, argv);
 
    const express::legacy::in::WebApp app("OAuth2ResourceServer");
 
    const std::string authorizationServerUri{"http://localhost:8082"};
 
    app.use(express::middleware::JsonMiddleware());
 
    app.get("/access", [authorizationServerUri] APPLICATION(req, res) {
        res->set("Access-Control-Allow-Origin", "*");
        const std::string queryAccessToken{req->query("access_token")};
        const std::string queryClientId{req->query("client_id")};
        if (queryAccessToken.empty() || queryClientId.empty()) {
            VLOG(1) << "Missing access_token or client_id in body";
            res->sendStatus(401);
            return;
        }
 
        const web::http::legacy::in::Client legacyClient(
            [](web::http::legacy::in::Client::SocketConnection* socketConnection) {
                VLOG(1) << "OnConnect";
 
                VLOG(1) << "\tServer: " + socketConnection->getRemoteAddress().toString();
                VLOG(1) << "\tClient: " + socketConnection->getLocalAddress().toString();
            },
            []([[maybe_unused]] web::http::legacy::in::Client::SocketConnection* socketConnection) {
                VLOG(1) << "OnConnected";
            },
            [](web::http::legacy::in::Client::SocketConnection* socketConnection) {
                VLOG(1) << "OnDisconnect";
 
                VLOG(1) << "\tServer: " + socketConnection->getRemoteAddress().toString();
                VLOG(1) << "\tClient: " + socketConnection->getLocalAddress().toString();
            },
            [queryAccessToken, queryClientId, res](const std::shared_ptr<web::http::client::MasterRequest>& request) {
                VLOG(1) << "OnRequestBegin";
                request->url = "/oauth2/token/validate?client_id=" + queryClientId;
                request->method = "POST";
                VLOG(1) << "ClientId: " << queryClientId;
                VLOG(1) << "AccessToken: " << queryAccessToken;
                const nlohmann::json requestJson = {{"access_token", queryAccessToken}, {"client_id", queryClientId}};
                const std::string requestJsonString{requestJson.dump(4)};
                request->send(
                    requestJsonString,
                    [res]([[maybe_unused]] const std::shared_ptr<web::http::client::Request>& request,
                          const std::shared_ptr<web::http::client::Response>& response) {
                        VLOG(1) << "OnResponse";
                        VLOG(1) << "Response: " << std::string(response->body.begin(), response->body.end());
                        if (std::stoi(response->statusCode) != 200) {
                            const nlohmann::json errorJson = {{"error", "Invalid access token"}};
                            res->status(401).send(errorJson.dump(4));
                        } else {
                            const nlohmann::json successJson = {{"content", "🦆"}};
                            res->status(200).send(successJson.dump(4));
                        }
                    },
                    [](const std::shared_ptr<web::http::client::Request>&, const std::string& message) {
                        VLOG(1) << "OAuth2ResourceServer: Request parse error: " << message;
                    });
            },
            []([[maybe_unused]] const std::shared_ptr<web::http::client::Request>& req) {
                LOG(INFO) << " -- OnRequestEnd";
            });
 
        legacyClient.connect(
            "localhost", 8082, [](const web::http::legacy::in::Client::SocketAddress& socketAddress, const core::socket::State& state) {
                switch (state) {
                    case core::socket::State::OK:
                        VLOG(1) << "OAuth2ResourceServer: connected to '" << socketAddress.toString() << "'";
                        break;
                    case core::socket::State::DISABLED:
                        VLOG(1) << "OAuth2ResourceServer: disabled";
                        break;
                    case core::socket::State::ERROR:
                        VLOG(1) << "OAuth2ResourceServer: error occurred";
                        break;
                    case core::socket::State::FATAL:
                        VLOG(1) << "OAuth2ResourceServer: fatal error occurred";
                        break;
                }
            });
    });
 
    app.listen(8083, [](const express::legacy::in::WebApp::SocketAddress& socketAddress, const core::socket::State& state) {
        switch (state) {
            case core::socket::State::OK:
                VLOG(1) << "app: listening on '" << socketAddress.toString() << "'";
                break;
            case core::socket::State::DISABLED:
                VLOG(1) << "app: disabled";
                break;
            case core::socket::State::ERROR:
                VLOG(1) << "app: error occurred";
                break;
            case core::socket::State::FATAL:
                VLOG(1) << "app: fatal error occurred";
                break;
        }
    });
    return express::WebApp::start();
}

References web::http::client::Response::body, web::http::client::Client< SocketClientT >::Client(), net::in::stream::SocketClient< SocketConnectorT, ConfigSocketClientT, SocketContextFactoryT, Args >::connect(), core::socket::State::DISABLED, core::socket::State::ERROR, core::socket::State::FATAL, core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::getLocalAddress(), core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::getRemoteAddress(), express::WebApp::init(), net::in::stream::SocketServer< SocketAcceptorT, ConfigSocketServerT, SocketContextFactoryT, Args >::listen(), web::http::client::Request::method, core::socket::State::OK, express::Request::query(), express::Response::send(), web::http::client::MasterRequest::send(), express::Response::sendStatus(), express::Response::set(), express::WebApp::start(), express::Response::status(), web::http::client::Response::statusCode, net::in::SocketAddress::toString(), web::http::client::Request::url, and express::WebAppT< ServerT >::WebAppT().

Here is the call graph for this function: