sslrpcclient.hpp

/************************************************************************************
 *    This file is part of the MynahSA streaming and archiving toolkit              *
 *    Copyright (C) 2006 Mynah-Software Ltd. All Rights Reserved.                   *
 *                                                                                  *
 *    This program is free software; you can redistribute it and/or modify          *
 *    it under the terms of the GNU General Public License, version 2               *
 *    as published by the Free Software Foundation.                                 *
 *                                                                                  *
 *    This program is distributed in the hope that it will be useful,               *
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of                *
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                 *
 *    GNU General Public License for more details.                                  *
 *                                                                                  *
 *    You should have received a copy of the GNU General Public License along       *
 *    with this program; if not, write to the Free Software Foundation, Inc.,       *
 *    51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.                   *
 *                                                                                  *
 ************************************************************************************/

#ifndef __ssl_rpc_client_hpp
#define __ssl_rpc_client_hpp


#include "iobase.hpp"





#include <openssl/crypto.h>
#include <openssl/x509.h>
#include <openssl/pem.h>
#include <openssl/ssl.h>
#include <openssl/err.h>

#include "sslarchivestream.hpp"
#include "streamconstructor.hpp"

#include <string>

#include <mynahsa/spimpl.hpp>



namespace MynahSA { 

  class SSLRPCClient {
  public:
    SSLRPCClient(const StreamConstructor& sc,
                unsigned int ipaddress, 
                unsigned int port,
                std::string certificateFile="",
                std::string privateKeyFile="");
    
    SSLRPCClient(const StreamConstructor& sc,
                 std::string machineName, 
                 unsigned int port,
                 std::string certificateFile="",
                 std::string privateKeyFile="");
    
    
    ~SSLRPCClient();
  
    SHARED_PTR<IoBase> rpc(SHARED_PTR<IoBase> req);
  
    bool is_open() const { return _isopen; }
  
    void close();
  
  
  private:
    void init(const StreamConstructor& sc,
              unsigned int ipaddress, 
              unsigned int port,
              std::string certificateFile="",
              std::string privateKeyFile="");
  
    bool _isopen;
    
    SSL_CTX*    _ctx;
    
    SSL*        _ssl;
    
    X509*       _serverCert;
    
    int         _sd;
  
    SHARED_PTR<SSLArchiveStream> _stream;
  
  
  };
};

#endif