1 // Copyright 2012 Google Inc. All Rights Reserved.
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License");
4 // you may not use this file except in compliance with the License.
5 // You may obtain a copy of the License at
6 //
7 // http://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS,
11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 // See the License for the specific language governing permissions and
13 // limitations under the License.
14
15 #include "polo/pairing/serverpairingsession.h"
16
17 #include <glog/logging.h>
18 #include "polo/pairing/polochallengeresponse.h"
19 #include "polo/util/poloutil.h"
20
21 namespace polo {
22 namespace pairing {
23
ServerPairingSession(wire::PoloWireAdapter * wire,PairingContext * context,PoloChallengeResponse * challenge,const std::string & server_name)24 ServerPairingSession::ServerPairingSession(wire::PoloWireAdapter *wire,
25 PairingContext *context,
26 PoloChallengeResponse* challenge,
27 const std::string& server_name)
28 : PairingSession(wire, context, challenge),
29 server_name_(server_name) {
30 }
31
~ServerPairingSession()32 ServerPairingSession::~ServerPairingSession() {
33 }
34
DoInitializationPhase()35 void ServerPairingSession::DoInitializationPhase() {
36 LOG(INFO) << "Waiting for PairingRequest...";
37 wire()->GetNextMessage();
38 }
39
DoConfigurationPhase()40 void ServerPairingSession::DoConfigurationPhase() {
41 LOG(INFO) << "Waiting for Configuration...";
42 wire()->GetNextMessage();
43 }
44
OnPairingRequestMessage(const message::PairingRequestMessage & message)45 void ServerPairingSession::OnPairingRequestMessage(
46 const message::PairingRequestMessage& message) {
47 set_service_name(message.service_name());
48
49 if (message.has_client_name()) {
50 set_peer_name(message.client_name());
51 }
52
53 message::PairingRequestAckMessage ack(service_name());
54 wire()->SendPairingRequestAckMessage(ack);
55
56 LOG(INFO) << "Waiting for Options...";
57 wire()->GetNextMessage();
58 }
59
OnOptionsMessage(const message::OptionsMessage & message)60 void ServerPairingSession::OnOptionsMessage(
61 const message::OptionsMessage& message) {
62 // The client is responsible for negotiating a valid configuration, so just
63 // send the server options.
64 wire()->SendOptionsMessage(local_options());
65
66 DoConfigurationPhase();
67 }
68
OnConfigurationMessage(const message::ConfigurationMessage & message)69 void ServerPairingSession::OnConfigurationMessage(
70 const message::ConfigurationMessage& message) {
71 if (!SetConfiguration(message)) {
72 wire()->SendErrorMessage(kErrorBadConfiguration);
73 listener()->OnError(kErrorBadConfiguration);
74 return;
75 }
76
77 const encoding::EncodingOption& encoding = message.encoding();
78
79 if (GetLocalRole() == message::OptionsMessage::kDisplayDevice) {
80 if (!local_options().SupportsOutputEncoding(encoding)) {
81 LOG(ERROR) << "Unsupported output encoding requested: "
82 << encoding.encoding_type();
83 wire()->SendErrorMessage(kErrorBadConfiguration);
84 listener()->OnError(kErrorBadConfiguration);
85 return;
86 }
87 } else {
88 if (!local_options().SupportsInputEncoding(encoding)) {
89 LOG(ERROR) << "Unsupported input encoding requested: "
90 << encoding.encoding_type();
91 wire()->SendErrorMessage(kErrorBadConfiguration);
92 listener()->OnError(kErrorBadConfiguration);
93 return;
94 }
95 }
96
97 message::ConfigurationAckMessage ack;
98 wire()->SendConfigurationAckMessage(ack);
99
100 DoPairingPhase();
101 }
102
OnConfigurationAckMessage(const message::ConfigurationAckMessage & message)103 void ServerPairingSession::OnConfigurationAckMessage(
104 const message::ConfigurationAckMessage& message) {
105 LOG(ERROR) << "Received unexpected ConfigurationAckMessage";
106 wire()->SendErrorMessage(kErrorProtocol);
107 listener()->OnError(kErrorProtocol);
108 }
109
OnPairingRequestAckMessage(const message::PairingRequestAckMessage & message)110 void ServerPairingSession::OnPairingRequestAckMessage(
111 const message::PairingRequestAckMessage& message) {
112 LOG(ERROR) << "Received unexpected PairingRequestAckMessage";
113 wire()->SendErrorMessage(kErrorProtocol);
114 listener()->OnError(kErrorProtocol);
115 }
116
117 } // namespace pairing
118 } // namespace polo
119