Rok4Server.h

Aller à la documentation de ce fichier.

/*
 * Copyright © (2011-2013) Institut national de l'information
 *                    géographique et forestière
 *
 * Géoportail SAV <contact.geoservices@ign.fr>
 *
 * This software is a computer program whose purpose is to publish geographic
 * data using OGC WMS and WMTS protocol.
 *
 * This software is governed by the CeCILL-C license under French law and
 * abiding by the rules of distribution of free software.  You can  use,
 * modify and/ or redistribute the software under the terms of the CeCILL-C
 * license as circulated by CEA, CNRS and INRIA at the following URL
 * "http://www.cecill.info".
 *
 * As a counterpart to the access to the source code and  rights to copy,
 * modify and redistribute granted by the license, users are provided only
 * with a limited warranty  and the software's author,  the holder of the
 * economic rights,  and the successive licensors  have only  limited
 * liability.
 *
 * In this respect, the user's attention is drawn to the risks associated
 * with loading,  using,  modifying and/or developing or reproducing the
 * software by the user in light of its specific status of free software,
 * that may mean  that it is complicated to manipulate,  and  that  also
 * therefore means  that it is reserved for developers  and  experienced
 * professionals having in-depth computer knowledge. Users are therefore
 * encouraged to load and test the software's suitability as regards their
 * requirements in conditions enabling the security of their systems and/or
 * data to be ensured and,  more generally, to use and operate it in the
 * same conditions as regards security.
 *
 * The fact that you are presently reading this means that you have had
 *
 * knowledge of the CeCILL-C license and that you accept its terms.
 */
 
class Rok4Server;
 
#ifndef _ROK4SERVER_
#define _ROK4SERVER_
 
#include "config.h"
#include <rok4/datasource/DataSource.h>
#include "Request.h"
#include <pthread.h>
#include <map>
#include <vector>
#include "Layer.h"
#include <stdio.h>
#include <rok4/utils/TileMatrixSet.h>
#include "fcgiapp.h"
#include <csignal>
#include "ServerConf.h"
#include "ServicesConf.h"
#include "GetFeatureInfoEncoder.h"
#include <rok4/utils/BoundingBox.h>
 
class Rok4Server {
private:
    std::vector<pthread_t> threads;
 
    volatile bool running;
 
    int sock;
 
    int pid;
 
    long time;
 
    ServicesConf* servicesConf;
 
    ServerConf* serverConf;
 
    std::string wmsCapabilities;
 
    std::string wmtsCapabilities;
 
    std::string tmsCapabilities;
 
    std::map<std::string, std::string> ogctilesCapabilities;
 
    static void* thread_loop ( void* arg );
    
 
    void buildWMSCapabilities();
 
    void buildWMTSCapabilities();
 
    void buildTMSCapabilities();
 
    void buildOGCTILESCapabilities();
 
    DataSource* getTileParamWMTS ( Request* request, Layer*& layer, TileMatrixSet*& tms, TileMatrix*& tm, int& tileCol, int& tileRow, std::string& format, Style*& style);
 
    DataSource* getTileParamTMS ( Request* request, Layer*& layer, TileMatrixSet*& tms, TileMatrix*& tm, int& tileCol, int& tileRow, std::string& format, Style*& style);
 
    DataSource* getTileParamOGCTILES ( Request* request, Layer*& layer, TileMatrixSet*& tms, TileMatrix*& tm, int& tileCol, int& tileRow, std::string& format, Style*& style);
 
    DataStream* getMapParamWMS ( Request* request, std::vector<Layer*>& layers, BoundingBox< double >& bbox, int& width, int& height, CRS*& crs, std::string& format, std::vector<Style*>& styles, std::map< std::string, std::string >& format_option,int& dpi);
       
    DataStream* getCapParamWMS ( Request* request, std::string& version );
    
    DataStream* getCapParamWMTS ( Request* request, std::string& version );
    
    DataStream* getLayerParamTMS ( Request* request, Layer*& layer );
 
    DataStream* getFeatureInfoParamWMS (
        Request* request, std::vector<Layer*>& layers, std::vector<Layer*>& query_layers,
        BoundingBox< double >& bbox, int& width, int& height, CRS*& crs, std::string& format,
        std::vector<Style*>& styles, std::string& info_format, int& X, int& Y, int& feature_count,std::map <std::string, std::string >& format_option
    );
 
    DataStream* getFeatureInfoParamWMTS ( Request* request, Layer*& layer, TileMatrixSet*& tms, TileMatrix*& tm, int &tileCol, int &tileRow, std::string  &format, Style* &style, std::string& info_format, int& X, int& Y);
 
    Image *styleImage(Image *curImage, Rok4Format::eformat_data pyrType, Style *style, std::string format, int size, Pyramid *pyr);
    
    Image *mergeImages(std::vector<Image*> images, Rok4Format::eformat_data &pyrType, Style *style, CRS* crs, BoundingBox<double> bbox);
    
    DataStream *formatImage(Image *image, std::string format, Rok4Format::eformat_data pyrType, std::map<std::string, std::string> format_option, int size, Style *style);
 
    DataStream* WMSGetCapabilities ( Request* request );
    
    DataStream* WMTSGetCapabilities ( Request* request );
    
    DataStream* TMSGetCapabilities ( Request* request );
    
    DataStream* OGCTILESGetCapabilities ( Request* request );
 
    DataStream* GlobalGetServices ( Request* request );
    
    DataStream* TMSGetLayer ( Request* request );
    
    DataStream* TMSGetLayerMetadata ( Request* request );
    
    DataStream* TMSGetLayerGDAL ( Request* request );
 
    DataStream* AdminCreateLayer ( Request* request );
 
    DataStream* AdminBuildCapabilities ( Request* request );
 
    DataStream* AdminDeleteLayer ( Request* request );
 
    DataStream* AdminUpdateLayer ( Request* request );
 
    DataStream* getMap ( Request* request );
 
    DataSource* getTile ( Request* request );
 
    DataStream* WMSGetFeatureInfo ( Request* request );
    
    DataStream* WMTSGetFeatureInfo ( Request* request );
 
    DataStream* OGCTILESGetFeatureInfo ( Request* request );
 
    DataStream* CommonGetFeatureInfo ( std::string service, Layer* layer, BoundingBox<double> bbox, int width, int height, CRS* crs, std::string info_format , int X, int Y, std::string format, int feature_count);
 
    void processWMS ( Request *request, FCGX_Request&  fcgxRequest );
    void processWMTS ( Request *request, FCGX_Request&  fcgxRequest );
    void processTMS ( Request *request, FCGX_Request&  fcgxRequest );
    void processOGCTILES ( Request *request, FCGX_Request&  fcgxRequest );
    void processAdmin ( Request *request, FCGX_Request&  fcgxRequest );
    void processHealthCheck ( Request *request, FCGX_Request&  fcgxRequest );
    void processGlobal ( Request *request, FCGX_Request&  fcgxRequest );
    void processRequest ( Request *request, FCGX_Request&  fcgxRequest );
 
    static std::vector<std::string> split ( const std::string &s, char delim ) {
        std::vector<std::string> elems;
        std::stringstream ss ( s );
        std::string item;
        while ( std::getline ( ss, item, delim ) ) {
            elems.push_back ( item );
        }
        return elems;
    }
 
    static std::string numToStr ( long int i ) {
        std::ostringstream strstr;
        strstr << i;
        return strstr.str();
    }
 
    static std::string doubleToStr ( long double d ) {
        std::ostringstream strstr;
        strstr.setf ( std::ios::fixed,std::ios::floatfield );
        strstr.precision ( 16 );
        strstr << d;
        return strstr.str();
    }
 
    static std::string getParam ( std::map<std::string, std::string>& option, std::string paramName ) {
        std::map<std::string, std::string>::iterator it = option.find ( paramName );
        if ( it == option.end() ) {
            return "";
        }
        return it->second;
    }
public:
    ServicesConf* getServicesConf() ;
    ServerConf* getServerConf() ;
 
    std::map<std::string, Layer*>& getLayerList() ;
 
    void run(sig_atomic_t signal_pending = 0);
    void initFCGI();
    int getFCGISocket() ;
 
    void setFCGISocket ( int sockFCGI ) ;
    
    void setPID ( int processID );
 
    int getPID();
 
    void setTime ( long processTime );
 
    long getTime();
 
    void terminate();
 
    bool isRunning() ;
 
    Rok4Server ( ServerConf* svr, ServicesConf* svc);
    virtual ~Rok4Server ();
 
};
 
#endif