Bridges.h

Go to the documentation of this file.

#ifndef BRIDGES_H
#define BRIDGES_H
 
#include <iostream>
#include <algorithm>
using namespace std;
 
#include "DataStructure.h" //string, using std
#include "ServerComm.h" //vector
 
//#include "DataSource.h"
 
#include <JSONutil.h>
#include <alltypes.h>
#include <chrono>
#include <USMap.h>
#include <WorldMap.h>
#include <rapidjson/document.h>
#include <rapidjson/stringbuffer.h>
#include <rapidjson/writer.h>
 
namespace bridges {
    using namespace bridges::datastructure;
    using namespace rapidjson;
 
    namespace game {
        class SocketConnection;
    }
    class Bridges {
        private:
            static bool profile() {
                return false;
            }
 
            static string getDefaultServerURL() {
                return "http://assignments.bridgesuncc.org";
            }
 
            bool jsonFlag = false;                  // if JSON is to be printed
 
            // this flag will turn on all labels in the visualization
            bool element_labelFlag = false, link_labelFlag = false;
 
            bool post_visualization_link = true;    // post flag of visualization url
 
            string user_name = string(),
                   api_key = string();              // user credentials
 
            string map;                             // for map overlays
            bool map_as_json = false;
 
            string description = string();          // visualization description
 
            string title = string();                            // title of visualization
 
            unsigned int assn_num = 0;              // assignment id
 
            DataStructure* ds_handle = nullptr;     // data structure handle
 
            string server_url = "http://assignments.bridgesuncc.org";
 
            string BASE_URL = server_url + "/assignments/";
 
            // map overlay options
            string map_overlay_options[3] = {"cartesian", "albersusa", "equirectangular"};
            bool map_overlay = false;
            string coord_system_type = "cartesian";
 
            // world coordinate window
            vector<double> wc_window;
 
            unsigned int lastAssignNum = 0, subAssignNum = 0;
 
            // JSON object - contains the data structure representationa
            rapidjson::Writer<rapidjson::StringBuffer> json_obj;
 
        public:
 
            Bridges() {
                Bridges (0, "", "");
            }
            Bridges (const string& name, const string& key) {
                Bridges (0, name, key);
            }
            Bridges (unsigned int num, const string& name, const string& key) {
                setAssignment(num);
                setUserName(name);
                setApiKey(key);
                setServer("live");
            }
 
            void setElementLabelFlag(bool flag) {
                element_labelFlag = flag;
            }
            void setLinkLabelFlag(bool flag) {
                link_labelFlag = flag;
            }
 
            bool getElementLabelFlag() const {
                return element_labelFlag;
            }
            bool getLinkLabelFlag() const {
                return link_labelFlag;
            }
 
            bool getJSONFlag() const {
                return jsonFlag;
            }
 
            void  postVisualizationLink(bool link_url) {
                post_visualization_link = link_url;
            }
 
            void setJSONFlag(bool flag) {
                jsonFlag = flag;
            }
 
            const string& getUserName() const {
                return user_name;
            }
            void setUserName(string name) {
                char* force = getenv("FORCE_BRIDGES_USERNAME");
                if (force != nullptr) {
                    name = force;
                }
 
                user_name = name;
            }
            const string& getApiKey()  const {
                return api_key;
            }
            void setApiKey(string key) {
                char* force = getenv("FORCE_BRIDGES_APIKEY");
                if (force != nullptr) {
                    key = force;
                }
                api_key = key;
            }
            unsigned int getAssignment() const {
                return assn_num;
            }
            void setAssignment(unsigned int num) {
                char* force = getenv("FORCE_BRIDGES_ASSIGNMENT");
                if (force != nullptr) {
                    num = std::atoi(force);
                }
 
                assn_num =  num;
 
                if (assn_num != lastAssignNum) {        // reset if a new assignment
                    lastAssignNum = assn_num;
                    subAssignNum = 0;
                }
            }
            const string& getTitle() const {
                return title;
            }
 
            void setTitle(const string& t) {
                title = t;
            }
            const string& getDescription() const {
                return description;
            }
            void setDescription(const string& descr) {
                description = descr;
            }
 
            void setDataStructure(DataStructure *ds) {
                ds_handle = ds;
            }
 
            void setDataStructure(DataStructure &ds) {
                setDataStructure(&ds);
            }
 
            DataStructure* getDataStructure() {
                return ds_handle;
            }
 
            void setServer(string server_type) {
                char* force = getenv("FORCE_BRIDGES_APISERVER");
                if (force != nullptr) {
                    server_type = force;
                }
 
                if (server_type == "live")
                    server_url = "http://assignments.bridgesuncc.org";
                else if (server_type == "clone")
                    server_url = "http://assignments-clone.bridgesuncc.org";
                else if (server_type == "games")
                    server_url = "http://games.bridgesuncc.org";
                else if (server_type == "games-clone")
                    server_url = "http://games-clone.bridgesuncc.org";
                else if (server_type == "local")
                    server_url = "http://127.0.0.1:3000";
 
                BASE_URL = server_url + "/assignments/";
            }
 
            void setMapOverlay (bool overlay_flag) {
                map_overlay = overlay_flag;
            }
 
            void setMap(string map_str) {
                map = map_str;
                setMapAsJSON(false);
            }
 
            /*
             * @brief this function is used when US maps are drawn as
             *  an overlay behind a data structure view or when data
             *  attributes are assignment to states or counties
             *
             *  See tutorial at  https://bridgesuncc.github.io/tutorials/Map.html
             *
             */
            void setMap(const Map* map) {
                string map_str = map->getMapRepresentation();
                setMapOverlay(map->getOverlay());
                setCoordSystemType(map->getProjection());
 
                // get the string rep of the map json
                this->map = map_str;
                setMapAsJSON(true);
            }
 
            // sets the map object
            void setMap(const Map& map) {
                setMap(&map);
            }
 
            // specifies the map object being send as a JSON or not
            void setMapAsJSON(bool b) {
                map_as_json = b;
            }
 
            //TODO: What is this get map? This is clearly not how to access map data. What were we trying to do here? [KRS: Probably obsolete?]
            string getMap(vector<string> states) {
                string json_str;
 
                // form the url and get the state county data
                string url = "http://static-data.bridgesuncc.org/api/us_map?state=";
                url += states[0];
                //              to do muultiple states -- later
                //              for (auto st : states)
                //                  url += st + ",";
                //              url = url.substr(0, url.size()-1);
 
                return json_str;
            }
 
            void setCoordSystemType (string coord) {
                std::transform(coord.begin(), coord.end(), coord.begin(), ::tolower);
                if (coord == "cartesian" || coord == "albersusa" || coord == "equirectangular"
                    || coord == "window")
                    coord_system_type = coord;
                else  {
                    cout << "Unrecognized coordinate system \'" + coord + "\', defaulting to "
                        << "cartesian. Options:";
                    for (auto proj : map_overlay_options)
                        cout <<  + "\t" ;
                    coord_system_type = "cartesian";
                }
            }
            const string&  getCoordSystemType () {
                return coord_system_type;
            }
 
            void setWindow (int xmin, int xmax, int ymin, int ymax) {
                setWindow(double(xmin), double(xmax), double(ymin), double(ymax));
            }
 
            void setWindow (double xmin, double xmax, double ymin, double ymax) {
                wc_window.clear();
                wc_window.push_back(xmin);
                wc_window.push_back(xmax);
                wc_window.push_back(ymin);
                wc_window.push_back(ymax);
            }
 
            string getVisualizeURL() const {
                return BASE_URL + to_string(getAssignment()) + "/" + getUserName();
            }
 
            void visualize() {
                std::chrono::time_point<std::chrono::system_clock> start;
                std::chrono::time_point<std::chrono::system_clock> end;
                std::chrono::time_point<std::chrono::system_clock> jsonbuild_start;
                std::chrono::time_point<std::chrono::system_clock> jsonbuild_end;
                std::chrono::time_point<std::chrono::system_clock> httprequest_start;
                std::chrono::time_point<std::chrono::system_clock> httprequest_end;
 
                if (profile())
                    start = std::chrono::system_clock::now();
 
                if (getAssignment() != lastAssignNum) {         // reset if a new assignment
                    lastAssignNum = getAssignment();
                    subAssignNum = 0;
                }
                if (subAssignNum == 99) {
                    cout << "#sub-assignments limit(99) exceeded, visualization not generated .."
                        << endl;
                    return;
                }
                if (!ds_handle) {
                    cerr << "Error: Data Structure handle null! Visualization not generated.";
                    return;
                }
 
                //
                // get the JSON of the data structure
                // each data structure is responsible for generating its own JSON
                //
                if (profile())
                    jsonbuild_start = std::chrono::system_clock::now();
 
                string ds_json;
                // We are transitioning to using rapidjson to
                // generate the JSON of the data structure reprsentation
                Document doc;
                StringBuffer sb;
                Writer<StringBuffer> json_writer(sb);   // for conversion to string
                doc.SetObject();
                if (ds_handle->getDStype() == "Scene") {
                    string ds_part_json = ds_handle->getDataStructureRepresentation();
                    // erase open curly brace
                    ds_part_json.erase(0, 1);
                    ds_json = getJSONHeader() + ds_part_json;
                }
                else if (ds_handle->getDStype() == "us_map") {
                    setMap((USMap*) ds_handle);
                    //                  string tmp = ds_handle->getDataStructureRepresentation();
                    // Document d;
                    // d.SetObject();
                    // Value key, value;
                    // key.SetString("mapdummy");
                    // value.SetBool(true);
                    // d.AddMember(key, value, d.GetAllocator());
                    //                  ds_json = getJSONHeader(d);
                    ds_json = getJSONHeader() + ds_handle->getDataStructureRepresentation();
                    //                  ds_json = getJSONHeader();
                }
                else if (ds_handle->getDStype() == "world_map") {
                    setMap((WorldMap*) ds_handle);
                    ds_json = getJSONHeader() + ds_handle->getDataStructureRepresentation();
                    //exit(0);
                }
                /*
                                else if (ds_handle->getDStype() == "LineChart"){
 
                                    // get the header information
                                    string s = getJSONHeader(doc);
 
                                    // get the data structure representation
                                    ds_handle->getDataStructureRepresentation(doc);
                                    doc.Accept(json_writer);
                                    ds_json = sb.GetString();
                                }
                */
                /*
                                else if (ds_handle->getDStype() == "SinglyLinkedList"){
                                    ds_json = getJSONHeader() + ds_handle->getDataStructureRepresentation();
                                //  getJSONHeader(doc);
 
                                //  doc.Accept(json_writer);
                                    ds_handle->getDataStructureRepresentation(doc);
                                    doc.Accept(json_writer);
                                    ds_json = sb.GetString();
                cout << "DS Rep(in visualize():\n" << sb.GetString() << endl;;
 
                                }
                */
                else {
                    ds_json = getJSONHeader() + ds_handle->getDataStructureRepresentation();
                }
                if (profile())
                    jsonbuild_end = std::chrono::system_clock::now();
 
                //
                // print JSON if flag is on
                //
                if (getJSONFlag()) {
                    cout << "JSON[" + ds_handle->getDStype() + "]:\t" << ds_json << endl;
                }
 
                if (profile())
                    httprequest_start = std::chrono::system_clock::now();
 
                try {                       // send the JSON of assignment to the server
                    ServerComm::makeRequest(BASE_URL + to_string(getAssignment()) + "." +
                        (subAssignNum > 9 ? "" : "0") + to_string(subAssignNum) + "?apikey=" + getApiKey() +
                        "&username=" + getUserName(), {"Content-Type: text/plain"}, ds_json);
 
                    if (post_visualization_link) {
                        cout << "Success: Assignment posted to the server. " << endl
                            << "Check out your visualization at:" << endl << endl
                            << getVisualizeURL() << endl << endl;
                    }
                    subAssignNum++;
                }
                catch (const string& error_str) {
                    cerr << "\nPosting assignment to the server failed!" << endl
                        << error_str << endl << endl;
                    cerr << "Provided Bridges Credentials:" << endl <<
                        "\t User Name: " << getUserName() << endl <<
                        "\t API Key: " << getApiKey() << endl <<
                        "\t Assignment Number: " << getAssignment() << endl;
                    throw bridges::RuntimeException();
                }
                catch (const HTTPException& he) {
                    cerr << "\nPosting assignment to the server failed!" << endl;
                    if (he.httpcode == 401) {
                        cerr << "Provided Bridges Credentials are incorrect:" << endl <<
                            "\t ServerURL: " << getServerURL() << endl <<
                            "\t User Name: " << getUserName() << endl <<
                            "\t API Key: " << getApiKey() << endl <<
                            "\t Assignment Number: " << getAssignment() << endl;
                    }
                    else if (he.httpcode == 413) {
                        cerr << "Assignment is too large." << endl;
                        cerr << "In general the assignment should be smaller than 16MB once serialized to JSON." << endl;
                    }
                    else {
                        std::cerr << he.what() << endl;
                    }
                    throw;
                }
                if (profile())
                    httprequest_end = std::chrono::system_clock::now();
 
                if (profile()) {
                    end = std::chrono::system_clock::now();
 
                    std::chrono::duration<double> totaltime = end - start;
                    std::chrono::duration<double> jsonbuildtime = jsonbuild_end - jsonbuild_start;
                    std::chrono::duration<double> httptime = httprequest_end - httprequest_start;
                    std::cerr << "total visualize() time:" << totaltime.count() << " seconds"
                        << " (including JSON build time: " << jsonbuildtime.count() << " seconds"
                        << " and HTTP request time: " << httptime.count() << " seconds)."
                        << std::endl;
                }
            }
 
        private:
            string getServerURL() const {
                return server_url;
            }
 
            string  getJSONHeader(Document& d) {
                Value key, value;
 
                key.SetString("visual", d.GetAllocator());
                value.SetString(ds_handle->getDStype().c_str(), d.GetAllocator());
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("title", d.GetAllocator());
                value.SetString(getTitle().c_str(), d.GetAllocator());
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("description", d.GetAllocator());
                value.SetString(getDescription().c_str(), d.GetAllocator());
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("map", d.GetAllocator());
                value.SetString(map.c_str(), d.GetAllocator());
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("map_overlay", d.GetAllocator());
                value.SetBool((map_overlay) ? true : false);
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("element_label_flag", d.GetAllocator());
                value.SetBool(element_labelFlag);
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("link_label_flag", d.GetAllocator());
                value.SetBool(link_labelFlag);
                d.AddMember(key, value, d.GetAllocator());
 
                key.SetString("coord_system_type", d.GetAllocator());
                value.SetString(getCoordSystemType().c_str(), d.GetAllocator());
                d.AddMember(key, value, d.GetAllocator());
 
                if (wc_window.size() == 4) {// world coord window has been specified
                    Value v;
                    d.SetArray();
                    Value w_array(kArrayType);
                    w_array.PushBack(v.SetDouble(wc_window[0]), d.GetAllocator());
                    w_array.PushBack(v.SetDouble(wc_window[1]), d.GetAllocator());
                    w_array.PushBack(v.SetDouble(wc_window[2]), d.GetAllocator());
                    w_array.PushBack(v.SetDouble(wc_window[3]), d.GetAllocator());
 
                    d.AddMember("window", w_array, d.GetAllocator());
                }
                // conver JSON to a string
                StringBuffer s;
                Writer<StringBuffer> writer(s);
                d.Accept(writer);
 
                return s.GetString();
            }
 
            string getJSONHeader () {
                using bridges::JSONUtil::JSONencode;
 
                string json_header = OPEN_CURLY +
                    QUOTE + "visual" + QUOTE + COLON + JSONencode(ds_handle->getDStype()) + COMMA +
                    QUOTE + "title" + QUOTE + COLON + JSONencode(getTitle()) + COMMA +
                    QUOTE + "description" + QUOTE + COLON + JSONencode( getDescription()) + COMMA +
                    QUOTE + "map_overlay" + QUOTE + COLON +
                    ((map_overlay) ? "true" : "false") + COMMA;
                if (map_as_json)
                    json_header += QUOTE + "map" + QUOTE + COLON + map + COMMA;
                else
                    json_header += QUOTE + "map" + QUOTE + COLON + QUOTE + map + QUOTE + COMMA;
 
                json_header += QUOTE + "element_label_flag" + QUOTE + COLON + ((element_labelFlag) ? "true" : "false") + COMMA +
                    QUOTE + "link_label_flag" + QUOTE + COLON + ((link_labelFlag) ? "true" : "false") + COMMA +
                    QUOTE + "coord_system_type" + QUOTE + COLON + JSONencode(getCoordSystemType()) +
                    COMMA;
 
                if (wc_window.size() == 4) {        // world coord window has been specified
                    json_header += QUOTE + string("window") + QUOTE + COLON + OPEN_BOX;
                    json_header += std::to_string(wc_window[0]) + COMMA +
                        std::to_string(wc_window[1]) + COMMA +
                        std::to_string(wc_window[2]) + COMMA + std::to_string(wc_window[3]);
                    json_header += CLOSE_BOX + COMMA;
 
                }
 
                return json_header;
            }
 
            friend DataSource;
            friend bridges::game::SocketConnection;
    };  //end of class Bridges
 
}   // end of bridges namespace
#endif