liboh/include/sirikata/oh/ObjectQueryProcessor.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 _SIRIKATA_OH_OBJECT_QUERY_PROCESSOR_HPP_
#define _SIRIKATA_OH_OBJECT_QUERY_PROCESSOR_HPP_

#include <sirikata/oh/Platform.hpp>
#include <sirikata/oh/HostedObject.hpp>
#include <sirikata/core/service/Service.hpp>
#include <sirikata/core/util/Factory.hpp>

#include <sirikata/pintoloc/BaseProxCommandable.hpp>

namespace Sirikata {

namespace Protocol {
namespace Prox {
class ProximityResults;
}
namespace Loc {
class BulkLocationUpdate;
}
}

namespace OH {

class SIRIKATA_OH_EXPORT ObjectQueryProcessor :
        public Service,
        public Pinto::BaseProxCommandable
{
  public:
    typedef HostedObject::SSTStreamPtr SSTStreamPtr;
    typedef HostedObject::SSTConnectionPtr SSTConnectionPtr;

    ObjectQueryProcessor(Context* ctx);
    virtual ~ObjectQueryProcessor();

    // Connection/disconnection to track unrequested

    virtual void presenceConnected(HostedObjectPtr ho, const SpaceObjectReference& sporef);
    virtual void presenceConnectedStream(HostedObjectPtr ho, const SpaceObjectReference& sporef, SSTStreamPtr strm);
    virtual void presenceDisconnected(HostedObjectPtr ho, const SpaceObjectReference& sporef);


    virtual String connectRequest(HostedObjectPtr ho, const SpaceObjectReference& sporef, const String& query);

    virtual void updateQuery(HostedObjectPtr ho, const SpaceObjectReference& sporef, const String& new_query) = 0;

  protected:
    void deliverProximityUpdate(HostedObjectPtr ho, const SpaceObjectReference& sporef, const Sirikata::Protocol::Prox::ProximityUpdate& update);

    void deliverLocationUpdate(HostedObjectPtr ho, const SpaceObjectReference& sporef, const LocUpdate& lu);
};


class SIRIKATA_OH_EXPORT ObjectQueryProcessorFactory
    : public AutoSingleton<ObjectQueryProcessorFactory>,
      public Factory2<ObjectQueryProcessor*, ObjectHostContext*, const String&>
{
public:
    static ObjectQueryProcessorFactory& getSingleton();
    static void destroy();
};

} // namespace OH
} // namespace Sirikata

#endif //_SIRIKATA_OH_OBJECT_QUERY_PROCESSOR_HPP_