1 //******************************************************************
3 // Copyright 2014 Intel Mobile Communications GmbH All Rights Reserved.
5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
7 // Licensed under the Apache License, Version 2.0 (the "License");
8 // you may not use this file except in compliance with the License.
9 // You may obtain a copy of the License at
11 // http://www.apache.org/licenses/LICENSE-2.0
13 // Unless required by applicable law or agreed to in writing, software
14 // distributed under the License is distributed on an "AS IS" BASIS,
15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 // See the License for the specific language governing permissions and
17 // limitations under the License.
19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
21 #include <cereal/cereal.hpp>
22 #include <cereal/types/memory.hpp>
23 #include <cereal/types/vector.hpp>
24 #include <cereal/archives/json.hpp>
26 #include <StringConstants.h>
30 class ListenOCContainer
33 enum class OCSecureType
39 class ListenResourceContainer
41 class ListenResourcePropertiesContainer
43 friend class cereal::access;
44 friend class ListenResourceContainer;
46 template<class Archive>
47 void serialize(Archive& ar)
53 ar(cereal::make_nvp(OC::Key::OBSERVABLEKEY, obsTemp));
54 m_observable = obsTemp != 0;
56 catch(cereal::Exception&)
58 // we swallow this exception, since it means the key
59 // doesn't exist, allowing these to be optional
60 ar.setNextName(nullptr);
67 ar(cereal::make_nvp(OC::Key::SECUREKEY, secureTemp));
68 m_secure = secureTemp != 0;
71 ar(cereal::make_nvp(OC::Key::PORTKEY, m_port));
73 catch(cereal::Exception&)
75 ar.setNextName(nullptr);
80 ar(cereal::make_nvp(OC::Key::RESOURCETYPESKEY,m_resourceTypes));
82 catch(cereal::Exception&)
84 ar.setNextName(nullptr);
88 ar(cereal::make_nvp(OC::Key::INTERFACESKEY, m_interfaces));
90 catch(cereal::Exception&)
92 ar.setNextName(nullptr);
97 std::vector<std::string> m_resourceTypes;
98 std::vector<std::string> m_interfaces;
104 ListenResourceContainer() : m_loaded(false)
108 friend class cereal::access;
109 friend class ListenOCContainer;
111 template <class Archive>
112 void serialize(Archive& ar)
116 ar(cereal::make_nvp(OC::Key::URIKEY, m_uri));
119 catch(cereal::Exception&)
121 ar.setNextName(nullptr);
125 ar(cereal::make_nvp(OC::Key::PROPERTYKEY, m_props));
128 catch(cereal::Exception&)
130 ar.setNextName(nullptr);
137 ListenResourcePropertiesContainer m_props;
144 bool observable() const
146 return m_props.m_observable;
149 OCSecureType secureType() const
151 return m_props.m_secure?OCSecureType::IPv4Secure :OCSecureType::IPv4;
156 return m_props.m_port;
159 std::vector<std::string> resourceTypes() const
161 return m_props.m_resourceTypes;
164 std::vector<std::string> interfaces() const
166 return m_props.m_interfaces;
171 friend class cereal::access;
172 template <class Archive>
173 void serialize(Archive& ar)
175 std::vector<ListenResourceContainer> resources;
179 ListenOCContainer(std::weak_ptr<IClientWrapper> cw, const OCDevAddr& address,
180 std::stringstream& json):
181 m_clientWrapper(cw), m_address(address)
186 const std::vector<std::shared_ptr<OCResource>>& Resources() const
192 std::string ConvertOCAddrToString(OCSecureType sec, int secureport)
202 if(sec== OCSecureType::IPv4)
206 else if(sec == OCSecureType::IPv4Secure)
212 oclog() << "ConvertOCAddrToString(): invalid SecureType"<<std::flush;
213 throw ResourceInitException(false, false, false, false, false, true);
216 if(0== OCDevAddrToIPv4Addr(&m_address, &addr1, &addr2, &addr3, &addr4))
218 // nothing to do, successful case.
222 oclog() << "ConvertOCAddrToString(): Invalid Ip"
224 throw ResourceInitException(false, false, false, false, false, true);
227 os<<static_cast<int>(addr1)<<'.'
228 <<static_cast<int>(addr2)<<'.'
229 <<static_cast<int>(addr3)<<'.'
230 <<static_cast<int>(addr4);
232 if(sec == OCSecureType::IPv4Secure && secureport>0 && secureport<=65535)
234 port = static_cast<uint16_t>(secureport);
236 else if(sec == OCSecureType::IPv4 && 0==OCDevAddrToPort(&m_address, &port))
238 // nothing to do, this is a successful case
242 oclog() << "ConvertOCAddrToString() : Invalid Port"
244 throw ResourceInitException(false, false, false, false, true, false);
247 os <<":"<< static_cast<int>(port);
252 void LoadFromJson(std::stringstream& json)
254 cereal::JSONInputArchive archive(json);
256 std::vector<ListenResourceContainer> resources;
257 archive(cereal::make_nvp(OC::Key::OCKEY, resources));
261 for(const auto& res : resources)
267 m_resources.push_back(std::shared_ptr<OCResource>(
268 new OCResource(m_clientWrapper,
269 ConvertOCAddrToString(res.secureType(),res.port()),
270 res.m_uri, res.observable(), res.resourceTypes(),
275 catch(ResourceInitException& e)
277 oclog() << "listenCallback(): failed to create resource: " << e.what()
282 std::vector<std::shared_ptr<OC::OCResource>> m_resources;
283 std::weak_ptr<IClientWrapper> m_clientWrapper;