restAPI.cpp

#include <spdlog/spdlog.h>

#include "libs/graphStore/NodeManager.h"
#include "libs/restAPI/GraphEndpoint.cpp"

using namespace std;

int main(int argc, char* argv[]) {
    Port port(9080);
    spdlog::set_level(spdlog::level::debug);
    GraphConfig gc;
    gc.graphID = 1;
    gc.partitionID = 0;
    gc.maxLabelSize = 43;
    gc.openMode = "app";
    NodeManager* nm = new NodeManager(gc);

    spdlog::info("Starting streaming graph store REST API . . ");
    int thr = 2;

    if (argc >= 2) {
        port = static_cast<uint16_t>(std::stol(argv[1]));

        if (argc == 3) thr = std::stoi(argv[2]);
    }

    Address addr(Ipv4::any(), port);
    spdlog::info("Available hardware CPU cores = {}", hardware_concurrency());
    spdlog::info("Number of threads in use for REST API = {}", thr);

    GraphEndpoint gEP(addr, nm);
    spdlog::info("Graph info:");
    spdlog::info("\t Graph ID: {}", gc.graphID);
    spdlog::info("\t Graph partition ID: {}", gc.partitionID);
    spdlog::info("\t Graph max label size: {}", gc.maxLabelSize);

    spdlog::info("Graph REST API Started in port = {}", port);
    gEP.logPaths();
    gEP.init(thr);
    gEP.start();
}