1 /*
2 * Copyright (C) 2021 Huawei Device Co., Ltd.
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
16 #include "pbap_pse_obex_server.h"
17 #include <cstring>
18 #include <memory>
19 #include "../obex/obex_mp_server.h"
20 #include "log.h"
21 #include "log_util.h"
22 #include "pbap_pse_header_msg.h"
23
24 namespace OHOS {
25 namespace bluetooth {
PbapPseObexServer(const std::string & serverName,const ObexServerConfig & config,PbapPseService & service)26 PbapPseObexServer::PbapPseObexServer(
27 const std::string &serverName, const ObexServerConfig &config, PbapPseService &service)
28 : obexConfig_(config), pbapPseService_(service)
29 {
30 HILOGI("enter");
31 pseObexObserver_ = std::make_unique<PseObexObserver>(*this);
32 obexServer_ = std::make_unique<ObexMpServer>(serverName, obexConfig_, *pseObexObserver_, *service.GetDispatcher());
33 }
34
StartUp() const35 int PbapPseObexServer::StartUp() const
36 {
37 HILOGI("enter");
38 int ret = obexServer_->Startup();
39 if (ret != BT_SUCCESS) {
40 HILOGE("Obex Startup Error ret = %{public}d", ret);
41 }
42 return ret;
43 }
44
ShutDown() const45 int PbapPseObexServer::ShutDown() const
46 {
47 HILOGI("enter");
48 obexServer_->Shutdown();
49 utility::Message msg(PSE_SHUTDOWN_COMPLETED);
50 pbapPseService_.PostMessage(msg);
51 return 0;
52 }
53
OnTransportDisconnected(const std::string & btAddr)54 void PbapPseObexServer::PseObexObserver::OnTransportDisconnected(const std::string &btAddr)
55 {
56 HILOGI("enter");
57 RawAddress device(btAddr);
58 pseObexServer_.pbapPseService_.ProcessObexRequest(PSE_DEVICE_DISCONNECTED, device);
59 }
60
OnTransportError(const std::string & btAddr,int errCd,const std::string & msg)61 void PbapPseObexServer::PseObexObserver::OnTransportError(const std::string &btAddr, int errCd, const std::string &msg)
62 {
63 HILOGE("%{public}s transport error, errCd=%{public}d, msg=%{public}s",
64 GetEncryptAddr(btAddr).c_str(), errCd, msg.c_str());
65 RawAddress device(btAddr);
66 pseObexServer_.pbapPseService_.ProcessObexRequest(PSE_DEVICE_TRANSPORT_ERROR, device);
67 }
68
OnTransportConnect(ObexIncomingConnect & incomingConnect)69 void PbapPseObexServer::PseObexObserver::OnTransportConnect(ObexIncomingConnect &incomingConnect)
70 {
71 HILOGI("enter");
72 pseObexServer_.pbapPseService_.ProcessObexRequest(
73 PSE_DEVICE_CONNECT_INCOMING, incomingConnect.GetRemoteAddress(), incomingConnect);
74 }
75
OnConnect(ObexServerSession & session,const ObexHeader & req)76 void PbapPseObexServer::PseObexObserver::OnConnect(ObexServerSession &session, const ObexHeader &req)
77 {
78 HILOGI("enter");
79 pseObexServer_.pbapPseService_.ProcessObexRequest(PSE_REQ_OBEX_CONNECT, session.GetRemoteAddr(), session, req);
80 }
81
OnDisconnect(ObexServerSession & session,const ObexHeader & req)82 void PbapPseObexServer::PseObexObserver::OnDisconnect(ObexServerSession &session, const ObexHeader &req)
83 {
84 HILOGI("enter");
85 pseObexServer_.pbapPseService_.ProcessObexRequest(PSE_REQ_OBEX_DISCONNECT, session.GetRemoteAddr(), session, req);
86 }
87
OnPut(ObexServerSession & session,const ObexHeader & req)88 void PbapPseObexServer::PseObexObserver::OnPut(ObexServerSession &session, const ObexHeader &req)
89 {
90 HILOGI("enter");
91 session.SendSimpleResponse(ObexRspCode::BAD_REQUEST);
92 }
93
OnGet(ObexServerSession & session,const ObexHeader & req)94 void PbapPseObexServer::PseObexObserver::OnGet(ObexServerSession &session, const ObexHeader &req)
95 {
96 HILOGI("enter");
97 pseObexServer_.pbapPseService_.ProcessObexRequest(PSE_REQ_OBEX_GET, session.GetRemoteAddr(), session, req);
98 }
99
OnSetPath(ObexServerSession & session,const ObexHeader & req)100 void PbapPseObexServer::PseObexObserver::OnSetPath(ObexServerSession &session, const ObexHeader &req)
101 {
102 HILOGI("enter");
103 pseObexServer_.pbapPseService_.ProcessObexRequest(PSE_REQ_OBEX_SETPATH, session.GetRemoteAddr(), session, req);
104 }
105
OnBusy(ObexServerSession & session,bool isBusy) const106 void PbapPseObexServer::PseObexObserver::OnBusy(ObexServerSession &session, bool isBusy) const
107 {
108 HILOGI("isBusy: %{public}d", isBusy);
109 pseObexServer_.pbapPseService_.ProcessObexBusy(session.GetRemoteAddr(), isBusy);
110 }
111 } // namespace bluetooth
112 } // namespace OHOS
113