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 "sms_broadcast_subscriber.h"
17
18#include "common_event_support.h"
19#include "short_message.h"
20#include "sms_cb_data.h"
21#include "string_utils.h"
22
23namespace OHOS {
24namespace Telephony {
25using namespace OHOS::EventFwk;
26SmsBroadcastSubscriber::SmsBroadcastSubscriber(const OHOS::EventFwk::CommonEventSubscribeInfo &subscriberInfo)
27    : CommonEventSubscriber(subscriberInfo)
28{}
29
30void SmsBroadcastSubscriber::OnReceiveEvent(const OHOS::EventFwk::CommonEventData &data)
31{
32    std::cout << "CommonEventPublishOrderedEventTest::Subscriber OnReceiveEvent" << std::endl;
33    OHOS::EventFwk::Want want = data.GetWant();
34    std::string action = data.GetWant().GetAction();
35    if (action == CommonEventSupport::COMMON_EVENT_SMS_RECEIVE_COMPLETED) {
36        int msgcode = GetCode();
37        std::string msgdata = GetData();
38        bool isCdma = want.GetBoolParam("isCdma", false);
39        std::cout << "Sms Receive::OnReceiveEvent msgcode" << msgcode << std::endl;
40        std::cout << "Sms Receive::OnReceiveEvent data = " << msgdata.data() << std::endl;
41        std::cout << "Sms Receive::OnReceiveEvent format Type = " << (isCdma ? "Cdma" : "Gsm") << std::endl;
42        const std::vector<std::string> pdus = want.GetStringArrayParam("pdus");
43        for (unsigned int index = 0; index < pdus.size(); ++index) {
44            std::vector<unsigned char> pdu = StringUtils::HexToByteVector(pdus[index]);
45            auto message = new ShortMessage();
46            std::u16string netType = isCdma ? u"3gpp2" : u"3gpp";
47            ShortMessage::CreateMessage(pdu, netType, *message);
48            if (message != nullptr) {
49                std::string messageBody = StringUtils::ToUtf8(message->GetVisibleMessageBody());
50                std::cout << "receive new sms = " << messageBody.c_str() << std::endl;
51                delete message;
52                message = nullptr;
53            } else {
54                std::cout << "Sms Receive::OnReceiveEvent pdus = " << pdus[index] << std::endl;
55            }
56        }
57    } else if (action == CommonEventSupport::COMMON_EVENT_SMS_EMERGENCY_CB_RECEIVE_COMPLETED ||
58        action == CommonEventSupport::COMMON_EVENT_SMS_CB_RECEIVE_COMPLETED) {
59        CbMessageTest(want);
60    } else if (action == CommonEventSupport::COMMON_EVENT_SMS_WAPPUSH_RECEIVE_COMPLETED) {
61        WapPushMessageTest(want);
62    } else {
63        std::cout << "CommonEventPublishOrderedEventTest::Subscriber OnReceiveEvent do nothing" << std::endl;
64    }
65}
66
67void SmsBroadcastSubscriber::CbMessageTest(const OHOS::EventFwk::Want &want) const
68{
69    std::cout << SmsCbData::SLOT_ID << ":" << want.GetIntParam(SmsCbData::SLOT_ID, DEFAULT_VALUE) << std::endl;
70    std::cout << SmsCbData::CB_MSG_TYPE << ":"
71              << std::to_string(static_cast<uint8_t>(want.GetByteParam(SmsCbData::CB_MSG_TYPE, DEFAULT_VALUE)))
72              << std::endl;
73    std::cout << SmsCbData::LANG_TYPE << ":"
74              << std::to_string(static_cast<uint8_t>(want.GetByteParam(SmsCbData::LANG_TYPE, DEFAULT_VALUE)))
75              << std::endl;
76    std::cout << SmsCbData::DCS << ":"
77              << std::to_string(static_cast<uint8_t>(want.GetByteParam(SmsCbData::DCS, DEFAULT_VALUE)))
78              << std::endl;
79    std::cout << SmsCbData::PRIORITY << ":"
80              << std::to_string(want.GetByteParam(SmsCbData::PRIORITY, DEFAULT_VALUE)) << std::endl;
81    std::cout << SmsCbData::CMAS_CLASS << ":"
82              << std::to_string(want.GetByteParam(SmsCbData::CMAS_CLASS, DEFAULT_VALUE)) << std::endl;
83    std::cout << SmsCbData::CMAS_CATEGORY << ":"
84              << std::to_string(want.GetByteParam(SmsCbData::CMAS_CATEGORY, DEFAULT_VALUE)) << std::endl;
85    std::cout << SmsCbData::CMAS_RESPONSE << ":"
86              << std::to_string(want.GetByteParam(SmsCbData::CMAS_RESPONSE, DEFAULT_VALUE)) << std::endl;
87    std::cout << SmsCbData::SEVERITY << ":"
88              << std::to_string(want.GetByteParam(SmsCbData::SEVERITY, DEFAULT_VALUE)) << std::endl;
89    std::cout << SmsCbData::URGENCY << ":" << std::to_string(want.GetByteParam(SmsCbData::URGENCY, DEFAULT_VALUE))
90              << std::endl;
91    std::cout << SmsCbData::CERTAINTY << ":"
92              << std::to_string(want.GetByteParam(SmsCbData::CERTAINTY, DEFAULT_VALUE)) << std::endl;
93    std::cout << SmsCbData::MSG_BODY << ":" << want.GetStringParam(SmsCbData::MSG_BODY) << std::endl;
94    std::cout << SmsCbData::FORMAT << ":" << std::to_string(want.GetByteParam(SmsCbData::FORMAT, DEFAULT_VALUE))
95              << std::endl;
96    std::cout << SmsCbData::SERIAL_NUM << ":"
97              << want.GetIntParam(SmsCbData::SERIAL_NUM, DEFAULT_VALUE) << std::endl;
98    std::cout << SmsCbData::RECV_TIME << ":" << want.GetStringParam(SmsCbData::RECV_TIME) << std::endl;
99    std::cout << SmsCbData::MSG_ID << ":"
100              << want.GetIntParam(SmsCbData::MSG_ID, DEFAULT_VALUE) << std::endl;
101    std::cout << SmsCbData::SERVICE_CATEGORY << ":"
102              << want.GetIntParam(SmsCbData::SERVICE_CATEGORY, DEFAULT_VALUE) << std::endl;
103    std::cout << SmsCbData::IS_ETWS_PRIMARY << ":" << want.GetBoolParam(SmsCbData::IS_ETWS_PRIMARY, false)
104              << std::endl;
105    std::cout << SmsCbData::IS_CMAS_MESSAGE << ":" << want.GetBoolParam(SmsCbData::IS_CMAS_MESSAGE, false)
106              << std::endl;
107    std::cout << SmsCbData::IS_ETWS_MESSAGE << ":" << want.GetBoolParam(SmsCbData::IS_ETWS_MESSAGE, false)
108              << std::endl;
109    std::cout << SmsCbData::PLMN << ":" << want.GetStringParam(SmsCbData::PLMN) << std::endl;
110    std::cout << SmsCbData::LAC << ":" << want.GetIntParam(SmsCbData::LAC, DEFAULT_VALUE) << std::endl;
111    std::cout << SmsCbData::CID << ":" << want.GetIntParam(SmsCbData::CID, DEFAULT_VALUE) << std::endl;
112    std::cout << SmsCbData::WARNING_TYPE << ":"
113              << want.GetIntParam(SmsCbData::WARNING_TYPE, DEFAULT_VALUE) << std::endl;
114    std::cout << SmsCbData::GEO_SCOPE << ":"
115              << std::to_string(want.GetByteParam(SmsCbData::GEO_SCOPE, DEFAULT_VALUE)) << std::endl;
116}
117
118void SmsBroadcastSubscriber::WapPushMessageTest(const OHOS::EventFwk::Want &want) const
119{
120    std::cout << "wap push slotId:" << want.GetIntParam("slotId", 0) << std::endl;
121    std::cout << "wap push pushType:" << want.GetIntParam("pushType", 0) << std::endl;
122    std::cout << "wap push transactionId:" << want.GetIntParam("transactionId", 0) << std::endl;
123    std::cout << "wap push strAppId:" << want.GetStringParam("strAppId") << std::endl;
124    std::cout << "wap push contentType:" << want.GetStringParam("contentType") << std::endl;
125    std::cout << "wap push header:" << want.GetStringParam("headerData") << std::endl;
126    std::cout << "wap push data:" << want.GetStringParam("rawData") << std::endl;
127}
128} // namespace Telephony
129} // namespace OHOS
130