debian/libwvstreams-dev/usr/include/wvstreams/wvsslstream.h

/* -*- Mode: C++ -*-
 * Worldvisions Weaver Software:
 *   Copyright (C) 1997-2002 Net Integration Technologies, Inc.
 *
 * SSL (Socket Security Layer) communications via WvStreams.
 */ 
#ifndef __WVSSLSTREAM_H
#define __WVSSLSTREAM_H
 
#include "wvfdstream.h"
#include "wvlog.h"
#include "wvstreamclone.h"
#include "wvtr1.h"
 
struct ssl_st;
struct ssl_ctx_st;
struct ssl_method_st;
 
typedef struct ssl_ctx_st SSL_CTX;
typedef struct ssl_st SSL;
typedef struct ssl_method_st SSL_METHOD;
 
class WvX509;
class WvX509Mgr;
class WvSSLStream;
 
typedef wv::function<bool(WvX509*)> WvSSLValidateCallback;
typedef wv::function<bool(WvX509*, WvSSLStream *)> WvSSLGlobalValidateCallback;

class WvSSLStream : public WvStreamClone
{
public:
    /* This ValidateCallback is purely more convenient to set (not passed in
     * via constructor) than its local cousin.  It is used when you want an
     * easy way to assign a validation function to any WvSSLStream you might
     * be using.  NOTE:  It should be assigned before you instantiate a stream,
     * and should never be changed while WvSSLStreams still linger.
     *
     * NOTE:  Using wv::bind can effectively bind an object with a particular
     * function for this callback, so you can do all sorts of interesting stuff
     * with it.
     */
    static WvSSLGlobalValidateCallback global_vcb;
    WvSSLStream(IWvStream *_slave, WvX509Mgr *_x509 = NULL, 
                WvSSLValidateCallback _vcb = 0, bool _is_server = false);
    
    virtual ~WvSSLStream();
    
    virtual void pre_select(SelectInfo &si);
    virtual bool post_select(SelectInfo &si);
    
    virtual void close();
    virtual bool isok() const;
    virtual void noread();
    virtual void nowrite();
    
protected:
    WvX509Mgr *x509;
    
    SSL_CTX *ctx;
    
    SSL *ssl;
    
    virtual size_t uwrite(const void *buf, size_t len);
    virtual size_t uread(void *buf, size_t len);
    
private:
    bool sslconnected;
    SelectRequest connect_wants;

    void setconnected(bool conn);
    
    bool is_server;
    
    bool ssl_stop_read, ssl_stop_write;
    
    WvSSLValidateCallback vcb;
    
    WvLog debug;

    WvInPlaceBuf write_bouncebuf;
    size_t write_eat;

    WvInPlaceBuf read_bouncebuf;
    bool read_pending;

    WvDynBuf unconnected_buf;

    void printerr(WvStringParm func);
 
public:
    const char *wstype() const { return "WvSSLStream"; }
};
 
#endif // __WVSSLSTREAM_H