Message.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.
 */
 
#ifndef _MESSAGE_
#define _MESSAGE_
 
#include <rok4/datastream/DataStream.h>
#include <rok4/datasource/DataSource.h>
#include <string.h> // Pour memcpy
#include "ServiceException.h"
#include <vector>
 
class MessageDataSource : public DataSource {
private:
    std::string type;
protected:
    std::string message;
public:
    MessageDataSource ( std::string message, std::string type ) : message ( message ), type ( type ) {}
    const uint8_t* getData ( size_t& size ) {
        size=message.length();
        return ( const uint8_t* ) message.data();
    }
    int getHttpStatus() {
        return 200;
    }
    std::string getType() {
        return type.c_str();
    }
    std::string getEncoding() {
        return "";
    }
    bool releaseData() {return true;}
    
    unsigned int getLength(){
            return message.length();
    }
};
 
class SERDataSource : public MessageDataSource {
private:
    int httpStatus ;
public:
    SERDataSource ( ServiceException *sex ) ;
    std::string getMessage() {
        return this->message;
    } ;
    int getHttpStatus() {
        return this->httpStatus;
    }
};
 
 
class EmptyResponseDataStream : public DataStream {
private:
    std::string type;
    
    uint32_t pos;
protected:
    std::string message;
 
public:
    EmptyResponseDataStream() {}
 
    size_t read ( uint8_t *buffer, size_t size ) {
        return 0;
    }
    bool eof() {
        return true;
    }
    std::string getType() {
        return "";
    }
    std::string getEncoding() {
        return "";
    }
    int getHttpStatus() {
        return 204;
    }
    unsigned int getLength(){
        return 0;
    }
};
 
class MessageDataStream : public DataStream {
private:
    std::string type;
    
    uint32_t pos;
protected:
    std::string message;
 
public:
    MessageDataStream ( std::string message, std::string type ) : message ( message ), type ( type ), pos ( 0 ) {}
 
    size_t read ( uint8_t *buffer, size_t size ) {
        if ( size > message.length() - pos ) size = message.length() - pos;
        memcpy ( buffer, ( uint8_t* ) ( message.data() +pos ),size );
        pos+=size;
        return size;
    }
    bool eof() {
        return ( pos==message.length() );
    }
    std::string getType() {
        return type.c_str();
    }
    std::string getEncoding() {
        return "";
    }
    int getHttpStatus() {
        return 200;
    }
    unsigned int getLength(){
        return message.length();
    }
};
 
class SERDataStream : public MessageDataStream {
private:
    int httpStatus ;
public:
    SERDataStream ( ServiceException *sex ) ;
    std::string getMessage() {
        return this->message;
    } ;
    int getHttpStatus() {
        return this->httpStatus;
    }
};
 
#endif