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
|
// Copyright (c) 2012 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/browser/devtools/devtools_browser_target.h"
#include "base/bind.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/memory/scoped_ptr.h"
#include "base/message_loop_proxy.h"
#include "base/values.h"
#include "net/server/http_server.h"
namespace content {
DevToolsBrowserTarget::DevToolsBrowserTarget(
base::MessageLoopProxy* message_loop_proxy,
net::HttpServer* http_server,
int connection_id)
: message_loop_proxy_(message_loop_proxy),
http_server_(http_server),
connection_id_(connection_id),
handlers_deleter_(&handlers_),
weak_factory_(this) {
}
DevToolsBrowserTarget::~DevToolsBrowserTarget() {
}
void DevToolsBrowserTarget::RegisterDomainHandler(
const std::string& domain,
DevToolsProtocol::Handler* handler) {
DCHECK(handlers_.find(domain) == handlers_.end());
handlers_[domain] = handler;
handler->SetNotifier(base::Bind(&DevToolsBrowserTarget::OnNotification,
weak_factory_.GetWeakPtr()));
}
std::string DevToolsBrowserTarget::HandleMessage(const std::string& data) {
std::string error_response;
scoped_ptr<DevToolsProtocol::Command> command(
DevToolsProtocol::ParseCommand(data, &error_response));
if (!command)
return error_response;
if (handlers_.find(command->domain()) == handlers_.end())
return command->NoSuchMethodErrorResponse()->Serialize();
scoped_ptr<DevToolsProtocol::Response> response(
handlers_[command->domain()]->HandleCommand(command.get()));
if (!response)
return command->NoSuchMethodErrorResponse()->Serialize();
return response->Serialize();
}
void DevToolsBrowserTarget::OnNotification(const std::string& message) {
message_loop_proxy_->PostTask(
FROM_HERE,
base::Bind(&net::HttpServer::SendOverWebSocket,
http_server_,
connection_id_,
message));
}
} // namespace content
|
