Merge branch 'notification-service'
[platform/upstream/iotivity.git] / resource / csdk / connectivity / api / cacommon.h
1 /* ****************************************************************
2  *
3  * Copyright 2014 Samsung Electronics All Rights Reserved.
4  *
5  *
6  *
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
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
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.
18  *
19  ******************************************************************/
20
21 /**
22  * @file cacommon.h
23  * This file contains the common data structures between Resource , CA and adapters
24  */
25
26 #ifndef CA_COMMON_H_
27 #define CA_COMMON_H_
28
29 #ifndef WITH_ARDUINO
30 #ifdef TCP_ADAPTER
31 #define HAVE_SYS_POLL_H
32 #endif
33 #endif
34
35 #include <stdint.h>
36 #include <stdlib.h>
37 #include <stdbool.h>
38
39 #ifdef HAVE_SYS_POLL_H
40 #include <sys/poll.h>
41 #endif
42
43 #ifdef HAVE_WINSOCK2_H
44 #include <winsock2.h>
45 #include <mswsock.h>
46 #endif
47
48 #ifdef __cplusplus
49 extern "C"
50 {
51 #endif
52
53 /**
54  * IP address Length.
55  */
56 #define CA_IPADDR_SIZE 16
57
58 /**
59  * Remote Access jabber ID length.
60  */
61 #define CA_RAJABBERID_SIZE 256
62
63 /**
64  * Mac address length for BT port.
65  */
66 #define CA_MACADDR_SIZE 18
67
68 /**
69  * Max header options data length.
70  */
71 #define CA_MAX_HEADER_OPTION_DATA_LENGTH 20
72
73 /**
74 * Max token length.
75 */
76 #define CA_MAX_TOKEN_LEN (8)
77
78 /**
79  * Max URI length.
80  */
81 #ifdef ARDUINO
82 #define CA_MAX_URI_LENGTH 128  /* maximum size of URI for embedded platforms*/
83 #else
84 #define CA_MAX_URI_LENGTH 512 /* maximum size of URI for other platforms*/
85 #endif
86
87 /**
88  * Max PDU length supported.
89  */
90 #ifdef ARDUINO
91 #define COAP_MAX_PDU_SIZE           320  /* maximum size of a CoAP PDU for embedded platforms*/
92 #else
93 #define COAP_MAX_PDU_SIZE           1400 /* maximum size of a CoAP PDU for big platforms*/
94 #endif
95
96 #ifdef WITH_BWT
97 #define CA_DEFAULT_BLOCK_SIZE       CA_BLOCK_SIZE_1024_BYTE
98 #endif
99
100 /**
101  *Maximum length of the remoteEndpoint identity.
102  */
103 #define CA_MAX_ENDPOINT_IDENTITY_LEN   (32)
104
105 /**
106  * option types - the highest option number 63.
107  */
108 #define CA_OPTION_IF_MATCH 1
109 #define CA_OPTION_ETAG 4
110 #define CA_OPTION_IF_NONE_MATCH 5
111 #define CA_OPTION_OBSERVE 6
112 #define CA_OPTION_LOCATION_PATH 8
113 #define CA_OPTION_URI_PATH 11
114 #define CA_OPTION_CONTENT_FORMAT 12
115 #define CA_OPTION_CONTENT_TYPE COAP_OPTION_CONTENT_FORMAT
116 #define CA_OPTION_MAXAGE 14
117 #define CA_OPTION_URI_QUERY 15
118 #define CA_OPTION_ACCEPT 17
119 #define CA_OPTION_LOCATION_QUERY 20
120
121 /**
122  * Payload information from resource model.
123  */
124 typedef uint8_t *CAPayload_t;
125
126 /**
127  * URI for the OIC base.CA considers relative URI as the URI.
128  */
129 typedef char *CAURI_t;
130
131 /**
132  * Token information for mapping the request and responses by resource model.
133  */
134 typedef char *CAToken_t;
135
136 /*
137  * Socket types and error definitions.
138  */
139 #ifdef HAVE_WINSOCK2_H
140 # define OC_SOCKET_ERROR      SOCKET_ERROR
141 # define OC_INVALID_SOCKET    INVALID_SOCKET
142 typedef SOCKET CASocketFd_t;
143 #else // HAVE_WINSOCK2_H
144 # define OC_SOCKET_ERROR      (-1)
145 # define OC_INVALID_SOCKET    (-1)
146 typedef int    CASocketFd_t;
147 #endif
148
149 /*
150  * The following flags are the same as the equivalent OIC values in
151  * octypes.h, allowing direct copying with slight fixup.
152  * The CA layer should used the OC types when build allows that.
153  */
154 #ifdef RA_ADAPTER
155 #define MAX_ADDR_STR_SIZE_CA (256)
156 #else
157 /*
158  * Max Address could be "coaps+tcp://[xxxx:xxxx:xxxx:xxxx:xxxx:xxxx:yyy.yyy.yyy.yyy]:xxxxx"
159  * Which is 65, +1 for null terminator => 66
160  * OCDevAddr (defined in OCTypes.h) must be the same
161  * as CAEndpoint_t (defined here)
162  */
163 #define MAX_ADDR_STR_SIZE_CA (66)
164 #endif
165
166 typedef enum
167 {
168     CA_DEFAULT_ADAPTER = 0,
169
170     // value zero indicates discovery
171     CA_ADAPTER_IP            = (1 << 0),   // IPv4 and IPv6, including 6LoWPAN
172     CA_ADAPTER_GATT_BTLE     = (1 << 1),   // GATT over Bluetooth LE
173     CA_ADAPTER_RFCOMM_BTEDR  = (1 << 2),   // RFCOMM over Bluetooth EDR
174
175 #ifdef RA_ADAPTER
176     CA_ADAPTER_REMOTE_ACCESS = (1 << 3),   // Remote Access over XMPP.
177 #endif
178
179     CA_ADAPTER_TCP           = (1 << 4),   // CoAP over TCP
180     CA_ADAPTER_NFC           = (1 << 5),   // NFC Adapter
181
182     CA_ALL_ADAPTERS          = 0xffffffff
183 } CATransportAdapter_t;
184
185 typedef enum
186 {
187     CA_DEFAULT_FLAGS = 0,
188
189     // Insecure transport is the default (subject to change)
190     CA_SECURE          = (1 << 4),   // secure the transport path
191     // IPv4 & IPv6 autoselection is the default
192     CA_IPV6            = (1 << 5),   // IP adapter only
193     CA_IPV4            = (1 << 6),   // IP adapter only
194     // Indication that a message was received by multicast.
195     CA_MULTICAST       = (1 << 7),
196     // Link-Local multicast is the default multicast scope for IPv6.
197     // These correspond in both value and position to the IPv6 address bits.
198     CA_SCOPE_INTERFACE = 0x1, // IPv6 Interface-Local scope
199     CA_SCOPE_LINK      = 0x2, // IPv6 Link-Local scope (default)
200     CA_SCOPE_REALM     = 0x3, // IPv6 Realm-Local scope
201     CA_SCOPE_ADMIN     = 0x4, // IPv6 Admin-Local scope
202     CA_SCOPE_SITE      = 0x5, // IPv6 Site-Local scope
203     CA_SCOPE_ORG       = 0x8, // IPv6 Organization-Local scope
204     CA_SCOPE_GLOBAL    = 0xE, // IPv6 Global scope
205 } CATransportFlags_t;
206
207 #define CA_IPFAMILY_MASK (CA_IPV6|CA_IPV4)
208 #define CA_SCOPE_MASK 0xf     // mask scope bits above
209
210 /**
211  * Information about the network status.
212  */
213 typedef enum
214 {
215     CA_INTERFACE_DOWN,   /**< Connection is not available */
216     CA_INTERFACE_UP    /**< Connection is Available */
217 } CANetworkStatus_t;
218
219 /*
220  * remoteEndpoint identity.
221  */
222 typedef struct
223 {
224     uint16_t id_length;
225     unsigned char id[CA_MAX_ENDPOINT_IDENTITY_LEN];
226 } CARemoteId_t;
227
228 /**
229  * Message Type for Base source code.
230  */
231 typedef enum
232 {
233     CA_MSG_CONFIRM = 0,  /**< confirmable message (requires ACK/RST) */
234     CA_MSG_NONCONFIRM,   /**< non-confirmable message (one-shot message) */
235     CA_MSG_ACKNOWLEDGE,  /**< used to acknowledge confirmable messages */
236     CA_MSG_RESET         /**< used to indicates not-interested or error (lack of context)in
237                                                   received messages */
238 } CAMessageType_t;
239
240 /**
241  * Allowed method to be used by resource model.
242  */
243 typedef enum
244 {
245     CA_GET = 1, /**< GET Method  */
246     CA_POST,    /**< POST Method */
247     CA_PUT,     /**< PUT Method */
248     CA_DELETE   /**< DELETE Method */
249 } CAMethod_t;
250
251 /**
252  * block size.
253  * it depends on defined size in libCoAP.
254  */
255 typedef enum
256 {
257     CA_BLOCK_SIZE_16_BYTE = 0,    /**< 16byte */
258     CA_BLOCK_SIZE_32_BYTE = 1,    /**< 32byte */
259     CA_BLOCK_SIZE_64_BYTE = 2,    /**< 64byte */
260     CA_BLOCK_SIZE_128_BYTE = 3,   /**< 128byte */
261     CA_BLOCK_SIZE_256_BYTE = 4,   /**< 256byte */
262     CA_BLOCK_SIZE_512_BYTE = 5,   /**< 512byte */
263     CA_BLOCK_SIZE_1024_BYTE = 6     /**< 1Kbyte */
264 } CABlockSize_t;
265
266 /**
267  * Endpoint information for connectivities.
268  * Must be identical to OCDevAddr.
269  */
270 typedef struct
271 {
272     CATransportAdapter_t    adapter;    // adapter type
273     CATransportFlags_t      flags;      // transport modifiers
274     uint16_t                port;       // for IP
275     char                    addr[MAX_ADDR_STR_SIZE_CA]; // address for all
276     uint32_t                ifindex;    // usually zero for default interface
277 #if defined (ROUTING_GATEWAY) || defined (ROUTING_EP)
278     char                    routeData[MAX_ADDR_STR_SIZE_CA]; /**< GatewayId:ClientId of
279                                                                     destination. **/
280 #endif
281 } CAEndpoint_t;
282
283 /**
284  * Endpoint information for secure messages.
285  */
286 typedef struct
287 {
288     CAEndpoint_t endpoint;      /**< endpoint */
289     CARemoteId_t identity;      /**< endpoint identity */
290 } CASecureEndpoint_t;
291
292 /**
293  * Enums for CA return values.
294  */
295 typedef enum
296 {
297     /* Result code - START HERE */
298     CA_STATUS_OK = 0,               /**< Success */
299     CA_STATUS_INVALID_PARAM,        /**< Invalid Parameter */
300     CA_ADAPTER_NOT_ENABLED,         /**< Adapter is not enabled */
301     CA_SERVER_STARTED_ALREADY,      /**< Server is started already */
302     CA_SERVER_NOT_STARTED,          /**< Server is not started */
303     CA_DESTINATION_NOT_REACHABLE,   /**< Destination is not reachable */
304     CA_SOCKET_OPERATION_FAILED,     /**< Socket operation failed */
305     CA_SEND_FAILED,                 /**< Send request failed */
306     CA_RECEIVE_FAILED,              /**< Receive failed */
307     CA_MEMORY_ALLOC_FAILED,         /**< Memory allocation failed */
308     CA_REQUEST_TIMEOUT,             /**< Request is Timeout */
309     CA_DESTINATION_DISCONNECTED,    /**< Destination is disconnected */
310     CA_NOT_SUPPORTED,               /**< Not supported */
311     CA_STATUS_NOT_INITIALIZED,      /**< Not Initialized*/
312     CA_DTLS_AUTHENTICATION_FAILURE, /**< Decryption error in DTLS */
313     CA_STATUS_FAILED =255           /**< Failure */
314     /* Result code - END HERE */
315 } CAResult_t;
316
317 /**
318  * Enums for CA Response values.
319  */
320 typedef enum
321 {
322     /* Response status code - START HERE */
323     CA_EMPTY = 0,                           /**< Empty */
324     CA_CREATED = 201,                       /**< Created */
325     CA_DELETED = 202,                       /**< Deleted */
326     CA_VALID = 203,                         /**< Valid */
327     CA_CHANGED = 204,                       /**< Changed */
328     CA_CONTENT = 205,                       /**< Content */
329     CA_CONTINUE = 231,                      /**< Continue */
330     CA_BAD_REQ = 400,                       /**< Bad Request */
331     CA_UNAUTHORIZED_REQ = 401,              /**< Unauthorized Request */
332     CA_BAD_OPT = 402,                       /**< Bad Option */
333     CA_FORBIDDEN_REQ = 403,                 /**< Forbidden Request */
334     CA_NOT_FOUND = 404,                     /**< Not found */
335     CA_METHOD_NOT_ALLOWED = 405,            /**< Method Not Allowed */
336     CA_NOT_ACCEPTABLE = 406,                /**< Not Acceptable */
337     CA_REQUEST_ENTITY_INCOMPLETE = 408,     /**< Request Entity Incomplete */
338     CA_REQUEST_ENTITY_TOO_LARGE = 413,      /**< Request Entity Too Large */
339     CA_INTERNAL_SERVER_ERROR = 500,         /**< Internal Server Error */
340     CA_RETRANSMIT_TIMEOUT = 504             /**< Retransmit timeout */
341     /* Response status code - END HERE */
342 } CAResponseResult_t;
343
344 /**
345  * Data type whether the data is Request Message or Response Message.
346  * if there is some failure before send data on network.
347  * Type will be set as error type for error callback.
348  */
349 typedef enum
350 {
351     CA_REQUEST_DATA = 1,
352     CA_RESPONSE_DATA,
353     CA_ERROR_DATA,
354     CA_RESPONSE_FOR_RES
355 } CADataType_t;
356
357 /**
358  * Transport Protocol IDs for additional options.
359  */
360 typedef enum
361 {
362     CA_INVALID_ID = (1 << 0),   /**< Invalid ID */
363     CA_COAP_ID = (1 << 1)       /**< COAP ID */
364 } CATransportProtocolID_t;
365
366 /**
367  * Adapter State to indicate the network changed notifications.
368  */
369 typedef enum
370 {
371     CA_ADAPTER_DISABLED,   /**< Adapter is Disabled */
372     CA_ADAPTER_ENABLED     /**< Adapter is Enabled */
373 } CAAdapterState_t;
374
375 /**
376  * Format indicating which encoding has been used on the payload.
377  */
378 typedef enum
379 {
380     CA_FORMAT_UNDEFINED = 0,            /**< Undefined enoding format */
381     CA_FORMAT_TEXT_PLAIN,
382     CA_FORMAT_APPLICATION_LINK_FORMAT,
383     CA_FORMAT_APPLICATION_XML,
384     CA_FORMAT_APPLICATION_OCTET_STREAM,
385     CA_FORMAT_APPLICATION_RDF_XML,
386     CA_FORMAT_APPLICATION_EXI,
387     CA_FORMAT_APPLICATION_JSON,
388     CA_FORMAT_APPLICATION_CBOR,
389     CA_FORMAT_UNSUPPORTED
390 } CAPayloadFormat_t;
391
392 /**
393  * Header options structure to be filled.
394  *
395  * This structure is used to hold header information.
396  */
397 typedef struct
398 {
399     CATransportProtocolID_t protocolID;                     /**< Protocol ID of the Option */
400     uint16_t optionID;                                      /**< The header option ID which will be
401                                                             added to communication packets */
402     uint16_t optionLength;                                  /**< Option Length **/
403     char optionData[CA_MAX_HEADER_OPTION_DATA_LENGTH];      /**< Optional data values**/
404 } CAHeaderOption_t;
405
406 /**
407  * Base Information received.
408  *
409  * This structure is used to hold request & response base information.
410  */
411 typedef struct
412 {
413     CAMessageType_t type;       /**< Qos for the request */
414 #ifdef ROUTING_GATEWAY
415     bool skipRetransmission;    /**< Will not attempt retransmission even if type is CONFIRM.
416                                      Required for packet forwarding */
417 #endif
418     uint16_t messageId;         /**< Message id.
419                                  * if message id is zero, it will generated by CA inside.
420                                  * otherwise, you can use it */
421     CAToken_t token;            /**< Token for CA */
422     uint8_t tokenLength;        /**< token length */
423     CAHeaderOption_t *options;  /** Header Options for the request */
424     uint8_t numOptions;         /**< Number of Header options */
425     CAPayload_t payload;        /**< payload of the request  */
426     size_t payloadSize;         /**< size in bytes of the payload */
427     CAPayloadFormat_t payloadFormat;    /**< encoding format of the request payload */
428     CAPayloadFormat_t acceptFormat;     /**< accept format for the response payload */
429     CAURI_t resourceUri;        /**< Resource URI information **/
430     CARemoteId_t identity;      /**< endpoint identity */
431     CADataType_t dataType;      /**< data type */
432 } CAInfo_t;
433
434 /**
435  * Request Information to be sent.
436  *
437  * This structure is used to hold request information.
438  */
439 typedef struct
440 {
441     CAMethod_t method;  /**< Name of the Method Allowed */
442     CAInfo_t info;      /**< Information of the request. */
443     bool isMulticast;   /**< is multicast request */
444 } CARequestInfo_t;
445
446 /**
447  * Response information received.
448  *
449  * This structure is used to hold response information.
450  */
451 typedef struct
452 {
453     CAResponseResult_t result;  /**< Result for response by resource model */
454     CAInfo_t info;              /**< Information of the response */
455     bool isMulticast;
456 } CAResponseInfo_t;
457
458 /**
459  * Error information from CA
460  *        contains error code and message information.
461  *
462  * This structure holds error information.
463  */
464 typedef struct
465 {
466     CAResult_t result;  /**< CA API request result  */
467     CAInfo_t info;      /**< message information such as token and payload data
468                              helpful to identify the error */
469 } CAErrorInfo_t;
470
471 /**
472  * Hold global variables for CA layer. (also used by RI layer)
473  */
474 typedef struct
475 {
476     CASocketFd_t fd;    /**< socket fd */
477     uint16_t port;      /**< socket port */
478 } CASocket_t;
479
480 #define HISTORYSIZE (4)
481
482 typedef struct
483 {
484     CATransportFlags_t flags;
485     uint16_t messageId;
486     char token[CA_MAX_TOKEN_LEN];
487     uint8_t tokenLength;
488 } CAHistoryItem_t;
489
490 typedef struct
491 {
492     int nextIndex;
493     CAHistoryItem_t items[HISTORYSIZE];
494 } CAHistory_t;
495
496 /**
497  * Hold interface index for keeping track of comings and goings.
498  */
499 typedef struct
500 {
501     int32_t ifIndex; /**< network interface index */
502 } CAIfItem_t;
503
504 /**
505  * Hold the port number assigned from application.
506  * It will be used when creating a socket.
507  */
508 typedef struct
509 {
510     struct udpports
511     {
512         uint16_t u6;    /**< unicast IPv6 socket port */
513         uint16_t u6s;   /**< unicast IPv6 socket secure port */
514         uint16_t u4;    /**< unicast IPv4 socket port */
515         uint16_t u4s;   /**< unicast IPv4 socket secure port */
516     } udp;
517 #ifdef TCP_ADAPTER
518     struct tcpports
519     {
520         uint16_t u4;    /**< unicast IPv4 socket port */
521         uint16_t u6;    /**< unicast IPv6 socket port */
522     } tcp;
523 #endif
524 } CAPorts_t;
525
526 typedef struct
527 {
528     CATransportFlags_t clientFlags; /**< flag for client */
529     CATransportFlags_t serverFlags; /**< flag for server */
530     bool client; /**< client mode */
531     bool server; /**< server mode */
532
533     CAPorts_t ports;
534
535     struct sockets
536     {
537         void *threadpool;           /**< threadpool between Initialize and Start */
538         CASocket_t u6;              /**< unicast   IPv6 */
539         CASocket_t u6s;             /**< unicast   IPv6 secure */
540         CASocket_t u4;              /**< unicast   IPv4 */
541         CASocket_t u4s;             /**< unicast   IPv4 secure */
542         CASocket_t m6;              /**< multicast IPv6 */
543         CASocket_t m6s;             /**< multicast IPv6 secure */
544         CASocket_t m4;              /**< multicast IPv4 */
545         CASocket_t m4s;             /**< multicast IPv4 secure */
546         CASocketFd_t netlinkFd;     /**< netlink */
547 #if defined(_WIN32)
548         WSAEVENT shutdownEvent;     /**< Event used to signal threads to stop */
549 #else
550         int shutdownFds[2];         /**< fds used to signal threads to stop */
551 #endif
552         int selectTimeout;          /**< in seconds */
553         int maxfd;                  /**< highest fd (for select) */
554         bool started;               /**< the IP adapter has started */
555         bool terminate;             /**< the IP adapter needs to stop */
556         bool ipv6enabled;           /**< IPv6 enabled by OCInit flags */
557         bool ipv4enabled;           /**< IPv4 enabled by OCInit flags */
558         bool dualstack;             /**< IPv6 and IPv4 enabled */
559 #if defined (_WIN32)
560         LPFN_WSARECVMSG wsaRecvMsg; /**< Win32 function pointer to WSARecvMsg() */
561 #endif
562
563         struct networkmonitors
564         {
565             CAIfItem_t *ifItems; /**< current network interface index list */
566             size_t sizeIfItems;  /**< size of network interface index array */
567             size_t numIfItems;   /**< number of valid network interfaces */
568         } nm;
569     } ip;
570
571     struct calayer
572     {
573         CAHistory_t requestHistory;  /**< filter IP family in requests */
574     } ca;
575
576 #ifdef TCP_ADAPTER
577     /**
578      * Hold global variables for TCP Adapter.
579      */
580     struct tcpsockets
581     {
582         void *threadpool;       /**< threadpool between Initialize and Start */
583         CASocket_t ipv4;        /**< IPv4 accept socket */
584         CASocket_t ipv6;        /**< IPv6 accept socket */
585         void *svrlist;          /**< unicast IPv4 TCP server information*/
586         int selectTimeout;      /**< in seconds */
587         int listenBacklog;      /**< backlog counts*/
588         int shutdownFds[2];     /**< shutdown pipe */
589         int connectionFds[2];   /**< connection pipe */
590         int maxfd;              /**< highest fd (for select) */
591         bool started;           /**< the TCP adapter has started */
592         bool terminate;         /**< the TCP adapter needs to stop */
593         bool ipv4tcpenabled;    /**< IPv4 TCP enabled by OCInit flags */
594         bool ipv6tcpenabled;    /**< IPv6 TCP enabled by OCInit flags */
595     } tcp;
596 #endif
597 } CAGlobals_t;
598
599 extern CAGlobals_t caglobals;
600
601 /**
602  * Callback function type for request delivery.
603  * @param[out]   object       Endpoint object from which the request is received.
604  *                            It contains endpoint address based on the connectivity type.
605  * @param[out]   requestInfo  Info for resource model to understand about the request.
606  */
607 typedef void (*CARequestCallback)(const CAEndpoint_t *object,
608                                   const CARequestInfo_t *requestInfo);
609
610 /**
611  * Callback function type for response delivery.
612  * @param[out]   object           Endpoint object from which the response is received.
613  * @param[out]   responseInfo     Identifier which needs to be mapped with response.
614  */
615 typedef void (*CAResponseCallback)(const CAEndpoint_t *object,
616                                    const CAResponseInfo_t *responseInfo);
617 /**
618  * Callback function type for error.
619  * @param[out]   object           remote device information.
620  * @param[out]   errorInfo        CA Error information.
621  */
622 typedef void (*CAErrorCallback)(const CAEndpoint_t *object,
623                                 const CAErrorInfo_t *errorInfo);
624
625 /**
626  * Callback function type for network status changes delivery from CA common logic.
627  * @param[out]   info       Endpoint object from which the network status is changed.
628  *                          It contains endpoint address based on the connectivity type.
629  * @param[out]   status     Current network status info.
630  */
631 typedef void (*CANetworkMonitorCallback)(const CAEndpoint_t *info, CANetworkStatus_t status);
632
633 #ifdef __cplusplus
634 } /* extern "C" */
635 #endif
636
637 #endif // CA_COMMON_H_