liboh/plugins/js/EmersonHttpManager.hpp

Go to the documentation of this file.

// Copyright (c) 2011 Sirikata Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can
// be found in the LICENSE file.

#ifndef __EMERSON_HTTP_MANAGER_HPP__
#define __EMERSON_HTTP_MANAGER_HPP__

#include <map>
#include <sirikata/core/transfer/HttpManager.hpp>
#include <v8.h>
#include <sirikata/core/util/SelfWeakPtr.hpp>
#include <sirikata/core/network/IOStrandImpl.hpp>
#include "JSCtx.hpp"

namespace Sirikata {

class Context;

namespace JS {

class EmersonHttpManager;
class JSContextStruct;

typedef std::tr1::shared_ptr<EmersonHttpManager> EmersonHttpPtr;
typedef std::tr1::weak_ptr  <EmersonHttpManager> EmersonHttpWPtr;


class EmersonHttpManager : public SelfWeakPtr<EmersonHttpManager>
{
public:
    typedef uint32 EmersonHttpToken;

    EmersonHttpManager(JSCtx* ctx);
    ~EmersonHttpManager();

    typedef std::tr1::shared_ptr<Transfer::HttpManager::HttpResponse> HttpRespPtr;


    /*
      Whenever a context is destroyed, removes its entry from ctxTokeMap.  For
      all allbacks in tokeCBMap that are outstanding for this context, call
      dispose on their outstanding v8 callback functions, and sets their
      jscontext to null instead.
     */
    void deregisterContext(JSContextStruct* toDeregister);


    EmersonHttpToken makeRequest(
        Sirikata::Network::Address addr,Transfer::HttpManager::HTTP_METHOD method,
        std::string req,v8::Persistent<v8::Function> cb, JSContextStruct* jscont);


private:

    typedef std::map<EmersonHttpToken, EmersonHttpToken> TokenMap;
    typedef TokenMap::iterator TokenMapIter;

    typedef std::pair<JSContextStruct* , v8::Persistent<v8::Function> > ContextCBPair;
    typedef std::map<EmersonHttpToken, ContextCBPair> TokenCBMap;
    typedef TokenCBMap::iterator TokenCBMapIter;

    typedef std::map<JSContextStruct*, TokenMap> ContextTokenMap;
    typedef ContextTokenMap::iterator ContextTokenMapIter;

    //to ensure uniqueness, makeRequest should be the only function (outside of
    //constructor that reads or writes to this value).
    EmersonHttpToken currentToken;

    ContextTokenMap ctxTokeMap;

    TokenCBMap tokeCBMap;


    void receiveHttpResponse(EmersonHttpToken respToken,
        HttpRespPtr hrp,
        Transfer::HttpManager::ERR_TYPE error,
        const boost::system::error_code& boost_error
    );
    void postReceiveResp(EmersonHttpToken respToken,HttpRespPtr hrp,Transfer::HttpManager::ERR_TYPE error,const boost::system::error_code& boost_error);


    void debugPrintTokenMap();
    void debugPrintContextMap();




    //If have outstanding requests, this pointer will have a pointer to self.
    //If don't, then it has an empty ptr.  Allows this to garbage collect properly
    EmersonHttpPtr managerLiveness;
    JSCtx* mContext;
};

static EmersonHttpPtr nullEmersonHttpPtr;


} //namespace js
} //namespace sirikata

#endif