1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
/**
* @file llareslistener.cpp
* @author Nat Goodspeed
* @date 2009-03-18
* @brief Implementation for llareslistener.
*
* $LicenseInfo:firstyear=2009&license=viewergpl$
* Copyright (c) 2009, Linden Research, Inc.
* $/LicenseInfo$
*/
#if LL_WINDOWS
#pragma warning (disable : 4355) // 'this' used in initializer list: yes, intentionally
#endif
// Precompiled header
#include "linden_common.h"
// associated header
#include "llareslistener.h"
// STL headers
// std headers
// external library headers
// other Linden headers
#include "llares.h"
#include "llerror.h"
#include "llevents.h"
LLAresListener::LLAresListener(const std::string& pumpname, LLAres* llares):
mAres(llares),
mBoundListener(LLEventPumps::instance().
obtain(pumpname).
listen("LLAresListener", boost::bind(&LLAresListener::process, this, _1)))
{
mDispatch["rewriteURI"] = boost::bind(&LLAresListener::rewriteURI, this, _1);
}
bool LLAresListener::process(const LLSD& command)
{
const std::string op(command["op"]);
// Look up the requested operation.
DispatchMap::const_iterator found = mDispatch.find(op);
if (found == mDispatch.end())
{
// There's no feedback other than our own reply. If somebody asks
// for an operation that's not supported (perhaps because of a
// typo?), unless we holler loudly, the request will be silently
// ignored. Throwing a tantrum on such errors will hopefully make
// this product more robust.
LL_ERRS("LLAresListener") << "Unsupported request " << op << LL_ENDL;
return false;
}
// Having found the operation, call it.
found->second(command);
// Conventional LLEventPump listener return
return false;
}
/// This UriRewriteResponder subclass packages returned URIs as an LLSD
/// array to send back to the requester.
class UriRewriteResponder: public LLAres::UriRewriteResponder
{
public:
/// Specify the event pump name on which to send the reply
UriRewriteResponder(const std::string& pumpname):
mPumpName(pumpname)
{}
/// Called by base class with results. This is called in both the
/// success and error cases. On error, the calling logic passes the
/// original URI.
virtual void rewriteResult(const std::vector<std::string>& uris)
{
LLSD result;
for (std::vector<std::string>::const_iterator ui(uris.begin()), uend(uris.end());
ui != uend; ++ui)
{
result.append(*ui);
}
LLEventPumps::instance().obtain(mPumpName).post(result);
}
private:
const std::string mPumpName;
};
void LLAresListener::rewriteURI(const LLSD& data)
{
const std::string uri(data["uri"]);
const std::string reply(data["reply"]);
// Validate that the request is well-formed
if (uri.empty() || reply.empty())
{
LL_ERRS("LLAresListener") << "rewriteURI request missing";
std::string separator;
if (uri.empty())
{
LL_CONT << " 'uri'";
separator = " and";
}
if (reply.empty())
{
LL_CONT << separator << " 'reply'";
}
LL_CONT << LL_ENDL;
}
// Looks as though we have what we need; issue the request
mAres->rewriteURI(uri, new UriRewriteResponder(reply));
}
|
