1 files changed, 185 insertions, 0 deletions

diff --git a/linden/indra/newview/lleventpoll.cpp b/linden/indra/newview/lleventpoll.cpp
new file mode 100644
index 0000000..ece0958
--- /dev/null
+++ b/linden/indra/newview/lleventpoll.cpp
@@ -0,0 +1,185 @@
+/** 
+ * @file lleventpoll.cpp
+ * @brief Implementation of the LLEventPoll class.
+ *
+ * Copyright (c) 2006-2007, Linden Research, Inc.
+ * 
+ * The source code in this file ("Source Code") is provided by Linden Lab
+ * to you under the terms of the GNU General Public License, version 2.0
+ * ("GPL"), unless you have obtained a separate licensing agreement
+ * ("Other License"), formally executed by you and Linden Lab.  Terms of
+ * the GPL can be found in doc/GPL-license.txt in this distribution, or
+ * online at http://secondlife.com/developers/opensource/gplv2
+ * 
+ * There are special exceptions to the terms and conditions of the GPL as
+ * it is applied to this Source Code. View the full text of the exception
+ * in the file doc/FLOSS-exception.txt in this software distribution, or
+ * online at http://secondlife.com/developers/opensource/flossexception
+ * 
+ * By copying, modifying or distributing this software, you acknowledge
+ * that you have read and understood your obligations described above,
+ * and agree to abide by those obligations.
+ * 
+ * ALL LINDEN LAB SOURCE CODE IS PROVIDED "AS IS." LINDEN LAB MAKES NO
+ * WARRANTIES, EXPRESS, IMPLIED OR OTHERWISE, REGARDING ITS ACCURACY,
+ * COMPLETENESS OR PERFORMANCE.
+ */
+
+#include "llviewerprecompiledheaders.h"
+
+#include "lleventpoll.h"
+
+#include "llhttpclient.h"
+#include "llhttpnode.h"
+#include "llsdserialize.h"
+
+
+
+class LLEventPoll::Impl : LLHTTPClient::Responder
+{
+public:
+        static Impl& start(
+                const std::string& pollURL, const LLHTTPNode& treeRoot)
+        {
+                Impl* i = new Impl(pollURL, treeRoot);
+                llinfos << "LLEventPoll::Impl::start <" << i->mCount << "> "
+                        << pollURL << llendl;
+                return *i;
+        }
+        
+        void stop()
+        {
+                llinfos << "LLEventPoll::Impl::stop <" << mCount << "> "
+                        << mPollURL << llendl;
+                // there should be a way to stop a LLHTTPClient request in progress
+                mDone = true;
+                mPtr = NULL;
+        }
+        
+private:
+        Impl(const std::string& pollURL, const LLHTTPNode& treeRoot)
+                : mPtr(NULL), mDone(false),
+                  mPollURL(pollURL), mTreeRoot(treeRoot),
+                  mCount(++sCount)
+        {
+                mPtr = this;
+                makeRequest();
+        }
+                
+        ~Impl()
+        {
+                lldebugs << "LLEventPoll::Impl::~Impl <" << mCount << "> "
+                        << mPollURL << llendl;
+        }
+
+
+        void makeRequest()
+        {
+                LLSD request;
+                request["ack"] = mAcknowledge;
+                request["done"] = mDone;
+                
+                lldebugs << "LLEventPoll::Impl::makeRequest <" << mCount << "> ack = "
+                        << LLSDXMLStreamer(mAcknowledge) << llendl;
+                LLHTTPClient::post(mPollURL, request, mPtr);
+        }
+        
+        void handleMessage(const LLSD& content)
+        {
+                std::string message = content["message"];
+                if (message.empty())
+                {
+                        llwarns << "LLEventPoll::Impl::handleMessage <" << mCount
+                                        << "> empty message name" << llendl;
+                        return;
+                }
+                
+                std::string path = "/message/" + message;
+                
+                LLSD context;
+                const LLHTTPNode* handler = mTreeRoot.traverse(path, context);
+                if (!handler)
+                {
+                        llwarns << "LLEventPoll::Impl::handleMessage <" << mCount
+                                        << "> no handler for " << path << llendl;
+                        return;
+                }
+                LLPointer<LLSimpleResponse> responsep = LLSimpleResponse::create();
+                handler->post((LLHTTPNode::ResponsePtr)responsep, context, content["body"]);
+                
+                lldebugs << "LLEventPoll::Impl::handleMessage handled <" << mCount << "> "
+                        << message << ": " << *responsep << llendl;
+        }
+
+        virtual void error(U32 status, const std::string& reason)
+        {
+                lldebugs << "LLEventPoll::Impl::error <" << mCount << "> got "
+                        << status << ": " << reason
+                        << (mDone ? " -- done" : "") << llendl;
+
+                if (mDone) return;
+                
+                if (status == 404)
+                {
+                        // the capability has been revoked
+                        stop();
+                        return;
+                }
+                
+                makeRequest();
+        }
+        
+        
+        virtual void result(const LLSD& content)
+        {
+                lldebugs << "LLEventPoll::Impl::result <" << mCount << ">"
+                        << (mDone ? " -- done" : "") << llendl;
+
+                if (mDone) return;
+
+                mAcknowledge = content["id"];
+                LLSD events = content["events"];
+                
+                lldebugs << "LLEventPoll::Impl::completed <" << mCount << "> ack =  "
+                        << LLSDXMLStreamer(mAcknowledge) << llendl;
+
+                LLSD::array_const_iterator i = events.beginArray();
+                LLSD::array_const_iterator end = events.endArray();
+                for (; i != end; ++i)
+                {
+                        if (i->has("message"))
+                        {
+                                handleMessage(*i);
+                        }
+                }
+                
+                makeRequest();
+        }
+
+private:
+        typedef LLHTTPClient::ResponderPtr Ptr;
+
+        Ptr             mPtr;
+        bool    mDone;
+
+        std::string                     mPollURL;
+        const LLHTTPNode&       mTreeRoot;
+        
+        LLSD    mAcknowledge;
+        
+        // these are only here for debugging so we can see which poller is which
+        static int sCount;
+        int mCount;
+};
+
+int LLEventPoll::Impl::sCount = 0;
+
+
+LLEventPoll::LLEventPoll(const std::string& pollURL, const LLHTTPNode& treeRoot)
+        : impl(Impl::start(pollURL, treeRoot))
+        { }
+
+LLEventPoll::~LLEventPoll()
+{
+        impl.stop();
+}