//
//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+#include "iotivity_config.h"
#include "OCResource.h"
#include "OCUtilities.h"
#include <boost/lexical_cast.hpp>
#include <sstream>
+#ifdef HAVE_ARPA_INET_H
+#include <arpa/inet.h>
+#endif
+#ifdef HAVE_WS2TCPIP_H
+#include <ws2tcpip.h>
+#endif
+#ifdef HAVE_IN6ADDR_H
+#include <in6addr.h>
+#endif
+#include "ocstack.h"
namespace OC {
static const char COAP[] = "coap://";
static const char COAPS[] = "coaps://";
static const char COAP_TCP[] = "coap+tcp://";
+static const char COAPS_TCP[] = "coaps+tcp://";
+static const char COAP_GATT[] = "coap+gatt://";
+static const char COAP_RFCOMM[] = "coap+rfcomm://";
using OC::nil_guard;
using OC::result_guard;
OCResource::OCResource(std::weak_ptr<IClientWrapper> clientWrapper,
const OCDevAddr& devAddr, const std::string& uri,
- const std::string& serverId, bool observable,
+ const std::string& serverId, uint8_t property,
const std::vector<std::string>& resourceTypes,
- const std::vector<std::string>& interfaces)
+ const std::vector<std::string>& interfaces,
+ const std::string& deviceName)
: m_clientWrapper(clientWrapper), m_uri(uri),
m_resourceId(serverId, m_uri), m_devAddr(devAddr),
- m_isObservable(observable), m_isCollection(false),
+ m_isCollection(false), m_property(property),
m_resourceTypes(resourceTypes), m_interfaces(interfaces),
- m_observeHandle(nullptr)
+ m_observeHandle(nullptr), m_deviceName(deviceName)
{
m_isCollection = std::find(m_interfaces.begin(), m_interfaces.end(), LINK_INTERFACE)
!= m_interfaces.end();
interfaces.empty()||
m_clientWrapper.expired())
{
- throw ResourceInitException(m_uri.empty(), resourceTypes.empty(),
- interfaces.empty(), m_clientWrapper.expired(), false, false);
+ throw ResourceInitException(m_uri.empty(), false, resourceTypes.empty(),
+ interfaces.empty(), m_clientWrapper.expired(), false, false, false);
}
}
OCResource::OCResource(std::weak_ptr<IClientWrapper> clientWrapper,
const std::string& host, const std::string& uri,
const std::string& serverId,
- OCConnectivityType connectivityType, bool observable,
+ OCConnectivityType connectivityType, uint8_t property,
const std::vector<std::string>& resourceTypes,
- const std::vector<std::string>& interfaces)
+ const std::vector<std::string>& interfaces,
+ const std::string& deviceName)
: m_clientWrapper(clientWrapper), m_uri(uri),
m_resourceId(serverId, m_uri),
- m_devAddr{ OC_DEFAULT_ADAPTER, OC_DEFAULT_FLAGS, 0, {0}, 0
-#if defined (ROUTING_GATEWAY) || defined (ROUTING_EP)
- , {0}
-#endif
- },
- m_isObservable(observable), m_isCollection(false),
+ m_isCollection(false), m_property(property),
m_resourceTypes(resourceTypes), m_interfaces(interfaces),
- m_observeHandle(nullptr)
+ m_observeHandle(nullptr), m_deviceName(deviceName)
{
+ m_devAddr = OCDevAddr{OC_DEFAULT_ADAPTER, OC_DEFAULT_FLAGS, 0, {0}, 0,
+#if defined (ROUTING_GATEWAY) || defined (ROUTING_EP)
+ {0},
+#endif
+ {0}};
m_isCollection = std::find(m_interfaces.begin(), m_interfaces.end(), LINK_INTERFACE)
!= m_interfaces.end();
interfaces.empty()||
m_clientWrapper.expired())
{
- throw ResourceInitException(m_uri.empty(), resourceTypes.empty(),
- interfaces.empty(), m_clientWrapper.expired(), false, false);
+ throw ResourceInitException(m_uri.empty(), false, resourceTypes.empty(),
+ interfaces.empty(), m_clientWrapper.expired(), false, false, false);
}
if (uri.length() == 1 && uri[0] == '/')
{
- throw ResourceInitException(m_uri.empty(), resourceTypes.empty(),
- interfaces.empty(), m_clientWrapper.expired(), false, false);
+ throw ResourceInitException(m_uri.empty(), true, resourceTypes.empty(),
+ interfaces.empty(), m_clientWrapper.expired(), false, false, false);
}
if (uri[0] != '/')
{
- throw ResourceInitException(m_uri.empty(), resourceTypes.empty(),
- interfaces.empty(), m_clientWrapper.expired(), false, false);
+ throw ResourceInitException(m_uri.empty(), true, resourceTypes.empty(),
+ interfaces.empty(), m_clientWrapper.expired(), false, false, false);
}
// construct the devAddr from the pieces we have
{
size_t prefix_len;
- if(host.compare(0, sizeof(COAP) - 1, COAP) == 0)
+ if (host.compare(0, sizeof(COAP) - 1, COAP) == 0)
{
prefix_len = sizeof(COAP) - 1;
}
- else if(host.compare(0, sizeof(COAPS) - 1, COAPS) == 0)
+ else if (host.compare(0, sizeof(COAPS) - 1, COAPS) == 0)
{
prefix_len = sizeof(COAPS) - 1;
- m_devAddr.flags = static_cast<OCTransportFlags>(m_devAddr.flags & OC_SECURE);
+ m_devAddr.flags = static_cast<OCTransportFlags>(m_devAddr.flags | OC_SECURE);
}
else if (host.compare(0, sizeof(COAP_TCP) - 1, COAP_TCP) == 0)
{
prefix_len = sizeof(COAP_TCP) - 1;
- m_devAddr.adapter = static_cast<OCTransportAdapter>(m_devAddr.adapter & OC_ADAPTER_TCP);
+ }
+ else if (host.compare(0, sizeof(COAPS_TCP) - 1, COAPS_TCP) == 0)
+ {
+ prefix_len = sizeof(COAPS_TCP) - 1;
+ m_devAddr.flags = static_cast<OCTransportFlags>(m_devAddr.flags | OC_SECURE);
+ }
+ else if (host.compare(0, sizeof(COAP_GATT) - 1, COAP_GATT) == 0)
+ {
+ prefix_len = sizeof(COAP_GATT) - 1;
+ }
+ else if (host.compare(0, sizeof(COAP_RFCOMM) - 1, COAP_RFCOMM) == 0)
+ {
+ prefix_len = sizeof(COAP_RFCOMM) - 1;
}
else
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false, false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, false, true);
}
- // removed 'coap://' or 'coaps://' or 'coap+tcp://'
+ // remove 'coap://' or 'coaps://' or 'coap+tcp://' or 'coap+gatt://' or 'coap+rfcomm://'
std::string host_token = host.substr(prefix_len);
- if (host_token[0] == '[') // ipv6 address
+ if (host_token[0] == '[') // IPv6
{
- m_devAddr.flags = static_cast< OCTransportFlags >(m_devAddr.flags & OC_IP_USE_V6);
-
- size_t found = host_token.find(']');
+ size_t bracket = host_token.find(']');
- if (found == std::string::npos || found == 0)
+ if (std::string::npos == bracket || 0 == bracket)
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
}
// extract the ipv6 address
- std::string ip6Addr = host_token.substr(1, found - 1);
-
- size_t addrLength = ip6Addr.length();
-
- if (MAX_ADDR_STR_SIZE <= addrLength)
- {
- throw std::length_error("host address is too long.");
- }
+ std::string ip6Addr = host_token.substr(1, bracket - 1);
// address validity check
- size_t colon = ip6Addr.find(':');
-
- if (std::string::npos == colon)
+ std::string ip6AddrToValidityCheck(ip6Addr);
+ size_t percent = ip6AddrToValidityCheck.find('%');
+ if (std::string::npos != percent)
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ ip6AddrToValidityCheck.resize(percent);
}
-
- size_t colonCnt = 1;
- int omittedColon = -2;
-
- while (std::string::npos != colon)
+ struct in6_addr buf;
+ const char *cAddr = ip6AddrToValidityCheck.c_str();
+ if (0 == inet_pton(AF_INET6, cAddr, &buf))
{
- size_t nextColon = ip6Addr.find(':', colon + 1);
-
- if (nextColon == colon + 1)
- {
- if (0 < omittedColon)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
- }
- omittedColon = colon;
- }
-
- colon = nextColon;
-
- if (7 < colonCnt++)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
- }
- }
-
- if (7 >= colonCnt && 0 > omittedColon)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), true, false, false);
}
- size_t startPoint = 0;
-
- if (0 == omittedColon)
- {
- startPoint = 2;
- }
+ //skip ']' and ':' characters in host string
+ host_token = host_token.substr(bracket + 2);
+ int port = std::stoi(host_token);
- while (1)
+ if (0 > port || UINT16_MAX < port)
{
- std::string block;
- colon = ip6Addr.find(':', startPoint);
-
- if (std::string::npos != colon)
- {
- block = ip6Addr.substr(startPoint, colon - startPoint);
-
- if (4 < block.length() ||
- std::string::npos != block.find_first_not_of("0123456789ABCDEFabcdef") ||
- 0 == block.length())
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
- }
-
- startPoint = colon + 1;
- }
- else
- {
- block = ip6Addr.substr(startPoint);
-
- if (4 < block.length() ||
- std::string::npos != block.find_first_not_of("0123456789ABCDEFabcdef") ||
- 0 == block.length())
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
- }
-
- break;
- }
-
- if ((int)colon == omittedColon)
- {
- if (colon == addrLength - 2)
- {
- break;
- }
- startPoint = colon + 2;
- continue;
- }
-
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), true, false, false);
}
- // end of address validity check
- ip6Addr.copy(m_devAddr.addr, sizeof(m_devAddr.addr));
- m_devAddr.addr[ip6Addr.length()] = '\0';
- //skip ']' and ':' characters in host string
- host_token = host_token.substr(found + 2);
-
- int port = std::stoi(host_token);
+ OCStackResult result = OCDecodeAddressForRFC6874(m_devAddr.addr,
+ sizeof(m_devAddr.addr), ip6Addr.c_str(), nullptr);
- if (0 > port || UINT16_MAX < port)
+ if (OC_STACK_OK != result)
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
}
- m_devAddr.port = static_cast< uint16_t >(port);
+ m_devAddr.port = static_cast<uint16_t>(port);
+ m_devAddr.flags = static_cast<OCTransportFlags>(m_devAddr.flags | OC_IP_USE_V6);
}
else if (host_token[0] == ':')
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, false, true);
}
else
{
size_t dot = host_token.find('.');
- if (dot == std::string::npos) // MAC address
+ if (std::string::npos == dot) // MAC
{
std::string macAddr = host_token;
// address validity check
if (MAC_ADDR_STR_SIZE != macAddr.length())
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
}
- for (size_t blockCnt = 0; blockCnt < 6; blockCnt++)
+ for (size_t blockCnt = 0; blockCnt < MAC_ADDR_BLOCKS; blockCnt++)
{
std::string block = macAddr.substr(blockCnt * 3, 2);
if (std::string::npos != block.find_first_not_of("0123456789ABCDEFabcdef"))
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
}
- if (5 > blockCnt)
+ if (MAC_ADDR_BLOCKS - 1 > blockCnt)
{
char delimiter = macAddr[blockCnt * 3 + 2];
- if (':' != delimiter || '-' != delimiter)
+ if (':' != delimiter)
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(),
- false, false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
}
}
}
- // end of address validity check
macAddr.copy(m_devAddr.addr, sizeof(m_devAddr.addr));
- m_devAddr.addr[macAddr.length()] = '\0';
+ m_devAddr.addr[MAC_ADDR_STR_SIZE] = '\0';
}
- else // ipv4 address
+ else // IPv4
{
size_t colon = host_token.find(':');
- if (colon == std::string::npos)
+ if (colon == std::string::npos || colon == 0)
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
}
+ // extract the ipv4 address
std::string ip4Addr = host_token.substr(0, colon);
- size_t addrLength = ip4Addr.length();
-
- if (MAX_ADDR_STR_SIZE <= addrLength)
- {
- throw std::length_error("host address is too long.");
- }
// address validity check
- size_t startPoint = 0;
-
- for (size_t blockCnt = 1; blockCnt <= 4; blockCnt++)
+ struct in_addr buf;
+ const char *cAddr = ip4Addr.c_str();
+ if (0 == inet_pton(AF_INET, cAddr, &buf))
{
- size_t dot = ip4Addr.find('.', startPoint);
- std::string addrBlock;
-
- if (4 > blockCnt)
- {
- if (std::string::npos == dot || dot <= startPoint)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(),
- false, false);
- }
- addrBlock = ip4Addr.substr(startPoint, dot - startPoint);
- }
- else
- {
- if (std::string::npos != dot)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(),
- false, false);
- }
- addrBlock = ip4Addr.substr(startPoint, colon - startPoint);
- }
-
- int i_addrBlock = std::stoi(addrBlock);
-
- if (std::string::npos != addrBlock.find_first_not_of("0123456789") ||
- 0 > i_addrBlock || 255 < i_addrBlock)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
- }
- startPoint = dot + 1;
-
- if (addrLength <= startPoint)
- {
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
- }
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), true, false, false);
}
- // end of address validity check
- ip4Addr.copy(m_devAddr.addr, sizeof(m_devAddr.addr));
- m_devAddr.addr[ip4Addr.length()] = '\0';
- //skip ':' character in host string
+ //skip ':' characters in host string
host_token = host_token.substr(colon + 1);
-
int port = std::stoi(host_token);
if (0 > port || UINT16_MAX < port)
{
- throw ResourceInitException(m_uri.empty(), m_resourceTypes.empty(),
- m_interfaces.empty(), m_clientWrapper.expired(), false,
- false);
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), true, false, false);
}
- m_devAddr.port = static_cast< uint16_t >(port);
+ ip4Addr.copy(m_devAddr.addr, sizeof(m_devAddr.addr));
+ m_devAddr.addr[ip4Addr.length()] = '\0';
+ m_devAddr.port = static_cast<uint16_t>(port);
}
}
}
return checked_guard(m_clientWrapper.lock(),
&IClientWrapper::GetResourceRepresentation,
m_devAddr, m_uri,
- queryParametersMap, m_headerOptions,
+ queryParametersMap, m_headerOptions, CT_DEFAULT,
attributeHandler, QoS);
}
{
QueryParamsMap mapCpy(queryParametersMap);
- if(!resourceType.empty())
+ if (!resourceType.empty())
{
mapCpy[OC::Key::RESOURCETYPESKEY]=resourceType;
}
- if(!resourceInterface.empty())
+ if (!resourceInterface.empty())
{
mapCpy[OC::Key::INTERFACESKEY]= resourceInterface;
}
{
QueryParamsMap mapCpy(queryParametersMap);
- if(!resourceType.empty())
+ if (!resourceType.empty())
{
mapCpy[OC::Key::RESOURCETYPESKEY]=resourceType;
}
- if(!resourceInterface.empty())
+ if (!resourceInterface.empty())
{
mapCpy[OC::Key::INTERFACESKEY]=resourceInterface;
}
{
return checked_guard(m_clientWrapper.lock(), &IClientWrapper::PostResourceRepresentation,
m_devAddr, m_uri, rep, queryParametersMap,
- m_headerOptions, attributeHandler, QoS);
+ m_headerOptions, CT_DEFAULT, attributeHandler, QoS);
}
OCStackResult OCResource::post(const OCRepresentation& rep,
{
QueryParamsMap mapCpy(queryParametersMap);
- if(!resourceType.empty())
+ if (!resourceType.empty())
{
mapCpy[OC::Key::RESOURCETYPESKEY]=resourceType;
}
- if(!resourceInterface.empty())
+ if (!resourceInterface.empty())
{
mapCpy[OC::Key::INTERFACESKEY]=resourceInterface;
}
OCStackResult OCResource::deleteResource(DeleteCallback deleteHandler, QualityOfService QoS)
{
return checked_guard(m_clientWrapper.lock(), &IClientWrapper::DeleteResource,
- m_devAddr, m_uri, m_headerOptions, deleteHandler, QoS);
+ m_devAddr, m_uri, m_headerOptions, CT_DEFAULT, deleteHandler, QoS);
}
OCStackResult OCResource::deleteResource(DeleteCallback deleteHandler)
const QueryParamsMap& queryParametersMap, ObserveCallback observeHandler,
QualityOfService QoS)
{
- if(m_observeHandle != nullptr)
- {
- return result_guard(OC_STACK_INVALID_PARAM);
- }
-
return checked_guard(m_clientWrapper.lock(), &IClientWrapper::ObserveResource,
observeType, &m_observeHandle, m_devAddr,
m_uri, queryParametersMap, m_headerOptions,
OCStackResult OCResource::cancelObserve(QualityOfService QoS)
{
- if(m_observeHandle == nullptr)
+ if (m_observeHandle == nullptr)
{
return result_guard(OC_STACK_INVALID_PARAM);
}
OCStackResult result = checked_guard(m_clientWrapper.lock(),
&IClientWrapper::CancelObserveResource,
- m_observeHandle, "", m_uri, m_headerOptions, QoS);
+ m_observeHandle, (const char*)"", m_uri, m_headerOptions, QoS);
- if(result == OC_STACK_OK)
+ if (result == OC_STACK_OK)
{
m_observeHandle = nullptr;
}
std::string OCResource::host() const
{
std::ostringstream ss;
- if (m_devAddr.flags & OC_SECURE)
+
+ if (m_devAddr.adapter & OC_ADAPTER_TCP)
{
- ss << COAPS;
+ if (m_devAddr.flags & OC_SECURE)
+ {
+ ss << COAPS_TCP;
+ }
+ else
+ {
+ ss << COAP_TCP;
+ }
+ }
+ else if (m_devAddr.adapter & OC_ADAPTER_GATT_BTLE)
+ {
+ ss << COAP_GATT;
}
- else if (m_devAddr.adapter & OC_ADAPTER_TCP)
+ else if (m_devAddr.adapter & OC_ADAPTER_RFCOMM_BTEDR)
{
- ss << COAP_TCP;
+ ss << COAP_RFCOMM;
}
else
{
- ss << COAP;
+ if (m_devAddr.flags & OC_SECURE)
+ {
+ ss << COAPS;
+ }
+ else
+ {
+ ss << COAP;
+ }
}
+
if (m_devAddr.flags & OC_IP_USE_V6)
{
- ss << '[' << m_devAddr.addr << ']';
+ char addressEncoded[128] = {0};
+
+ OCStackResult result = OCEncodeAddressForRFC6874(addressEncoded,
+ sizeof(addressEncoded),
+ m_devAddr.addr);
+ if (OC_STACK_OK != result)
+ {
+ throw ResourceInitException(m_uri.empty(), false, m_resourceTypes.empty(),
+ m_interfaces.empty(), m_clientWrapper.expired(), false, true, false);
+ }
+ ss << '[' << addressEncoded << ']';
}
else
{
bool OCResource::isObservable() const
{
- return m_isObservable;
+ return (m_property & OC_OBSERVABLE) == OC_OBSERVABLE;
}
+#ifdef WITH_MQ
+bool OCResource::isPublish() const
+{
+ return (m_property & OC_MQ_PUBLISHER) == OC_MQ_PUBLISHER;
+}
+#endif
+
std::vector<std::string> OCResource::getResourceTypes() const
{
return m_resourceTypes;
return this->uniqueIdentifier().m_representation;
}
+std::string OCResource::deviceName() const
+{
+ return m_deviceName;
+}
+
+OCDevAddr OCResource::getDevAddr() const
+{
+ return m_devAddr;
+}
+
+#ifdef WITH_MQ
+OCStackResult OCResource::discoveryMQTopics(const QueryParamsMap& queryParametersMap,
+ MQTopicCallback attributeHandler,
+ QualityOfService qos)
+{
+ return checked_guard(m_clientWrapper.lock(),
+ &IClientWrapper::ListenForMQTopic,
+ m_devAddr, m_uri,
+ queryParametersMap, m_headerOptions,
+ attributeHandler, qos);
+}
+
+OCStackResult OCResource::createMQTopic(const OCRepresentation& rep,
+ const std::string& topicUri,
+ const QueryParamsMap& queryParametersMap,
+ MQTopicCallback attributeHandler,
+ QualityOfService qos)
+{
+ return checked_guard(m_clientWrapper.lock(), &IClientWrapper::PutMQTopicRepresentation,
+ m_devAddr, topicUri, rep, queryParametersMap,
+ m_headerOptions, attributeHandler, qos);
+}
+#endif
+#ifdef MQ_SUBSCRIBER
+OCStackResult OCResource::subscribeMQTopic(ObserveType observeType,
+ const QueryParamsMap& queryParametersMap,
+ ObserveCallback observeHandler,
+ QualityOfService qos)
+{
+ return result_guard(observe(observeType, queryParametersMap, observeHandler, qos));
+}
+
+OCStackResult OCResource::unsubscribeMQTopic(QualityOfService qos)
+{
+ return result_guard(cancelObserve(qos));
+}
+
+OCStackResult OCResource::requestMQPublish(const QueryParamsMap& queryParametersMap,
+ PostCallback attributeHandler,
+ QualityOfService qos)
+{
+ OCRepresentation rep;
+ rep.setValue(std::string("req_pub"), std::string("true"));
+ return result_guard(post(rep, queryParametersMap, attributeHandler, qos));
+}
+#endif
+#ifdef MQ_PUBLISHER
+OCStackResult OCResource::publishMQTopic(const OCRepresentation& rep,
+ const QueryParamsMap& queryParametersMap,
+ PostCallback attributeHandler,
+ QualityOfService qos)
+{
+ return result_guard(post(rep, queryParametersMap, attributeHandler, qos));
+}
+#endif
+
bool OCResource::operator==(const OCResource &other) const
{
return m_resourceId == other.m_resourceId;
projects / platform / upstream / iotivity.git / blobdiff