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::SERVERIDKEY, m_serverId));
128 catch(cereal::Exception&)
130 ar.setNextName(nullptr);
134 ar(cereal::make_nvp(OC::Key::PROPERTYKEY, m_props));
137 catch(cereal::Exception&)
139 ar.setNextName(nullptr);
145 std::string m_serverId;
147 ListenResourcePropertiesContainer m_props;
154 bool observable() const
156 return m_props.m_observable;
159 OCSecureType secureType() const
161 return m_props.m_secure?OCSecureType::IPv4Secure :OCSecureType::IPv4;
166 return m_props.m_port;
169 std::vector<std::string> resourceTypes() const
171 return m_props.m_resourceTypes;
174 std::vector<std::string> interfaces() const
176 return m_props.m_interfaces;
181 friend class cereal::access;
182 template <class Archive>
183 void serialize(Archive& ar)
185 std::vector<ListenResourceContainer> resources;
189 ListenOCContainer(std::weak_ptr<IClientWrapper> cw, const OCDevAddr& address,
190 std::stringstream& json):
191 m_clientWrapper(cw), m_address(address)
196 const std::vector<std::shared_ptr<OCResource>>& Resources() const
202 std::string ConvertOCAddrToString(OCSecureType sec, int secureport)
204 char stringAddress[DEV_ADDR_SIZE_MAX];
209 if(sec== OCSecureType::IPv4)
213 else if(sec == OCSecureType::IPv4Secure)
219 oclog() << "ConvertOCAddrToString(): invalid SecureType"<<std::flush;
220 throw ResourceInitException(false, false, false, false, false, true);
223 if(0== OCDevAddrToString(&m_address, stringAddress))
225 // nothing to do, successful case.
229 oclog() << "ConvertOCAddrToString(): Invalid Ip"
231 throw ResourceInitException(false, false, false, false, false, true);
236 if(sec == OCSecureType::IPv4Secure && secureport>0 && secureport<=65535)
238 port = static_cast<uint16_t>(secureport);
240 else if(sec == OCSecureType::IPv4 && 0==OCDevAddrToPort(&m_address, &port))
242 // nothing to do, this is a successful case
246 oclog() << "ConvertOCAddrToString() : Invalid Port"
248 throw ResourceInitException(false, false, false, false, true, false);
251 os <<":"<< static_cast<int>(port);
256 void LoadFromJson(std::stringstream& json)
258 cereal::JSONInputArchive archive(json);
260 std::vector<ListenResourceContainer> resources;
261 archive(cereal::make_nvp(OC::Key::OCKEY, resources));
265 for(const auto& res : resources)
272 //CA_TODO: To get the connectivity type correctly.
273 uint8_t connectivityType;
274 m_resources.push_back(std::shared_ptr<OCResource>(
275 new OCResource(m_clientWrapper,
276 ConvertOCAddrToString(res.secureType(),res.port()),
277 res.m_uri, res.m_serverId, connectivityType, res.observable(),
278 res.resourceTypes(), res.interfaces())));
280 m_resources.push_back(std::shared_ptr<OCResource>(
281 new OCResource(m_clientWrapper,
282 ConvertOCAddrToString(res.secureType(),res.port()),
283 res.m_uri, res.m_serverId, res.observable(),
284 res.resourceTypes(), res.interfaces())));
289 catch(ResourceInitException& e)
291 oclog() << "listenCallback(): failed to create resource: " << e.what()
296 std::vector<std::shared_ptr<OC::OCResource>> m_resources;
297 std::weak_ptr<IClientWrapper> m_clientWrapper;