EmbeddedArtists AB / PubNub

Modified PubNub library to better utilize low bandwidth connections like a GSM modem. Instead of 10 socket connections sending 3 bytes only one is made and it sends all 30 bytes at the same time.

Fork of PubNub by PubNub

PubNub.h@1:29cc485dcdb1, 2014-03-02 (annotated)

Committer:
pasky
Date:
Sun Mar 02 01:41:18 2014 +0000
Revision:
1:29cc485dcdb1
Parent:
0:9858347c382d
Child:
2:d78239c9ebb8
Move the class description to an outer comment.; ; This might fix docgen.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
pasky 0:9858347c382d 1 /* PubNub.h */
pasky 0:9858347c382d 2 /* Copyright (c) 2013 PubNub Inc.
pasky 0:9858347c382d 3 * http://www.pubnub.com/
pasky 0:9858347c382d 4 * http://www.pubnub.com/terms
pasky 0:9858347c382d 5 *
pasky 0:9858347c382d 6 * Permission is hereby granted, free of charge, to any person obtaining a copy
pasky 0:9858347c382d 7 * of this software and associated documentation files (the "Software"), to deal
pasky 0:9858347c382d 8 * in the Software without restriction, including without limitation the rights
pasky 0:9858347c382d 9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
pasky 0:9858347c382d 10 * copies of the Software, and to permit persons to whom the Software is
pasky 0:9858347c382d 11 * furnished to do so, subject to the following conditions:
pasky 0:9858347c382d 12 *
pasky 0:9858347c382d 13 * The above copyright notice and this permission notice shall be included in
pasky 0:9858347c382d 14 * all copies or substantial portions of the Software.
pasky 0:9858347c382d 15 *
pasky 0:9858347c382d 16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
pasky 0:9858347c382d 17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
pasky 0:9858347c382d 18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
pasky 0:9858347c382d 19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
pasky 0:9858347c382d 20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
pasky 0:9858347c382d 21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
pasky 0:9858347c382d 22 * THE SOFTWARE.
pasky 0:9858347c382d 23 */
pasky 0:9858347c382d 24
pasky 0:9858347c382d 25 /** \file
pasky 0:9858347c382d 26 PubNub Client header file
pasky 0:9858347c382d 27 */
pasky 0:9858347c382d 28
pasky 0:9858347c382d 29 #ifndef PubNub_h
pasky 0:9858347c382d 30 #define PubNub_h
pasky 0:9858347c382d 31
pasky 0:9858347c382d 32 #include "TCPSocketConnection.h"
pasky 0:9858347c382d 33
pasky 0:9858347c382d 34
pasky 0:9858347c382d 35 /* TODO: UUID */
pasky 0:9858347c382d 36 /* TODO: secret_key */
pasky 0:9858347c382d 37 /* TODO: cipher_key */
pasky 0:9858347c382d 38 /* TODO: timeout support */
pasky 0:9858347c382d 39
pasky 0:9858347c382d 40 /* Maximum length of the HTTP reply. This buffer is dynamically allocated
pasky 0:9858347c382d 41 * only when loading the reply from the network. */
pasky 0:9858347c382d 42 /* XXX: Replies of API calls longer than this will be discarded and instead,
pasky 0:9858347c382d 43 * PNR_FORMAT_ERROR will be reported. Specifically, this may cause lost
pasky 0:9858347c382d 44 * messages returned by subscribe if too many too large messages got queued. */
pasky 0:9858347c382d 45 #ifndef PUBNUB_REPLY_MAXLEN
pasky 0:9858347c382d 46 #define PUBNUB_REPLY_MAXLEN (2048-8-1)
pasky 0:9858347c382d 47 #endif
pasky 0:9858347c382d 48
pasky 0:9858347c382d 49
pasky 0:9858347c382d 50 /* Result codes for PubNub methods. */
pasky 0:9858347c382d 51 enum PubNubRes {
pasky 0:9858347c382d 52 /* Success. */
pasky 0:9858347c382d 53 PNR_OK,
pasky 0:9858347c382d 54 /* Time out before the request has completed. */
pasky 0:9858347c382d 55 PNR_TIMEOUT,
pasky 0:9858347c382d 56 /* Communication error (network or HTTP response format). */
pasky 0:9858347c382d 57 PNR_IO_ERROR,
pasky 0:9858347c382d 58 /* HTTP error. */
pasky 0:9858347c382d 59 PNR_HTTP_ERROR,
pasky 0:9858347c382d 60 /* Unexpected input in received JSON. */
pasky 0:9858347c382d 61 PNR_FORMAT_ERROR,
pasky 0:9858347c382d 62 /* PubNub JSON reply indicates failure. */
pasky 0:9858347c382d 63 PNR_PUBNUB_ERROR,
pasky 0:9858347c382d 64 };
pasky 0:9858347c382d 65
pasky 0:9858347c382d 66
pasky 1:29cc485dcdb1 67 /** A PubNub Client context. Declare it as a local or global variable,
pasky 1:29cc485dcdb1 68 * then you may start calling the API immediately.
pasky 1:29cc485dcdb1 69 *
pasky 1:29cc485dcdb1 70 * All methods are blocking; if you need to communicate with
pasky 1:29cc485dcdb1 71 * PubNub asynchronously, run PubNub in a dedicated thread.
pasky 1:29cc485dcdb1 72 * Always use the PubNub context only in a single thread at once.
pasky 1:29cc485dcdb1 73 *
pasky 1:29cc485dcdb1 74 * Message are passed as strings instead of JSON structures due
pasky 1:29cc485dcdb1 75 * to much higher RAM efficiency. Often, ad hoc composing and
pasky 1:29cc485dcdb1 76 * parsing JSON messages will work fine in practice. Otherwise,
pasky 1:29cc485dcdb1 77 * take a look at e.g. the picojson library. */
pasky 0:9858347c382d 78 class PubNub {
pasky 0:9858347c382d 79 public:
pasky 0:9858347c382d 80 /** Init a Pubnub Client context
pasky 0:9858347c382d 81 *
pasky 0:9858347c382d 82 * Note that the string parameters are not copied; do not
pasky 0:9858347c382d 83 * overwrite or free the memory where you stored the keys!
pasky 0:9858347c382d 84 * (If you are passing string literals, don't worry about it.)
pasky 0:9858347c382d 85 *
pasky 0:9858347c382d 86 * @param string publish_key required key to send messages.
pasky 0:9858347c382d 87 * @param string subscribe_key required key to receive messages.
pasky 0:9858347c382d 88 * @param string origin optional setting for cloud origin.
pasky 0:9858347c382d 89 * @return boolean whether begin() was successful. */
pasky 0:9858347c382d 90 PubNub(const char *publish_key, const char *subscribe_key, const char *origin = "http://pubsub.pubnub.com");
pasky 0:9858347c382d 91
pasky 0:9858347c382d 92 ~PubNub();
pasky 0:9858347c382d 93
pasky 0:9858347c382d 94 /** Publish
pasky 0:9858347c382d 95 *
pasky 0:9858347c382d 96 * Send a message (assumed to be well-formed JSON) to a given channel.
pasky 0:9858347c382d 97 *
pasky 0:9858347c382d 98 * Examples:
pasky 0:9858347c382d 99 p.publish("demo", "\"lala\"");
pasky 0:9858347c382d 100 * or
pasky 0:9858347c382d 101 if (p.publish("demo", "{\"lala\":1}") != PNR_OK) {
pasky 0:9858347c382d 102 blink_error();
pasky 0:9858347c382d 103 }
pasky 0:9858347c382d 104 *
pasky 0:9858347c382d 105 * @param channel required channel name.
pasky 0:9858347c382d 106 * @param message required JSON message object.
pasky 0:9858347c382d 107 * @param reply optional pointer for passing the returned reply (free() after use).
pasky 0:9858347c382d 108 * @return PNR_OK on success. */
pasky 0:9858347c382d 109 PubNubRes publish(const char *channel, const char *message, char **reply = NULL);
pasky 0:9858347c382d 110
pasky 0:9858347c382d 111 /** Subscribe
pasky 0:9858347c382d 112 *
pasky 0:9858347c382d 113 * Listen for a message on a given channel. The function will block
pasky 0:9858347c382d 114 * and return when a message arrives. Typically, you will run this
pasky 0:9858347c382d 115 * function in a loop to keep listening for messages indefinitely.
pasky 0:9858347c382d 116 *
pasky 0:9858347c382d 117 * As a reply, you will get a JSON message. If you are used to
pasky 0:9858347c382d 118 * PubNub API in other environments, you would expect an array
pasky 0:9858347c382d 119 * of messages; here, even if the device received multiple messages
pasky 0:9858347c382d 120 * batched, they are spread over subsequent PubNub.subscribe() calls
pasky 0:9858347c382d 121 * and each returns only a single message. However, *reply can be
pasky 0:9858347c382d 122 * set NULL - in that case, simply retry the call, this indicates
pasky 0:9858347c382d 123 * an empty reply from the server (what happens e.g. after waiting
pasky 0:9858347c382d 124 * for certain interval, or immediately after subscribing).
pasky 0:9858347c382d 125 *
pasky 0:9858347c382d 126 * Contrary to publish(), you should NOT free() the reply yourself!
pasky 0:9858347c382d 127 * Instead, you are expected to call another subscribe() just after
pasky 0:9858347c382d 128 * processing the reply; subscribe() will release any memory it can
pasky 0:9858347c382d 129 * before waiting for new data from the server.
pasky 0:9858347c382d 130 *
pasky 0:9858347c382d 131 * Examples:
pasky 0:9858347c382d 132 while (1) {
pasky 0:9858347c382d 133 char *reply;
pasky 0:9858347c382d 134 if (p.subscribe("demo", &reply) != PNR_OK) continue;
pasky 0:9858347c382d 135 if (!reply) continue;
pasky 0:9858347c382d 136 int code = -1;
pasky 0:9858347c382d 137 if (sscanf(reply, "{\"code\":%d}", &code) == 1)
pasky 0:9858347c382d 138 printf("received JSON msg with code %d\n", code);
pasky 0:9858347c382d 139 }
pasky 0:9858347c382d 140 *
pasky 0:9858347c382d 141 * @param channel required channel name.
pasky 0:9858347c382d 142 * @param reply required pointer for passing the returned reply (do not free()).
pasky 0:9858347c382d 143 * @return PNR_OK on success. */
pasky 0:9858347c382d 144 PubNubRes subscribe(const char *channel, char **reply);
pasky 0:9858347c382d 145
pasky 0:9858347c382d 146 /* TODO: subscribe_multi */
pasky 0:9858347c382d 147
pasky 0:9858347c382d 148 /** History
pasky 0:9858347c382d 149 *
pasky 0:9858347c382d 150 * Receive list of the last N messages on the given channel.
pasky 0:9858347c382d 151 *
pasky 0:9858347c382d 152 * The messages are returned in the reply buffer, with each message
pasky 0:9858347c382d 153 * terminated by a NUL byte, i.e. being a standalone C string; to
pasky 0:9858347c382d 154 * iterate over all the messages, you can use the replysize. reply
pasky 0:9858347c382d 155 * can be NULL if there is no history for this channel.
pasky 0:9858347c382d 156 *
pasky 0:9858347c382d 157 * Example:
pasky 0:9858347c382d 158 char *reply;
pasky 0:9858347c382d 159 int replysize;
pasky 0:9858347c382d 160 if (p.history("demo", &reply, &replysize) != PNR_OK) return;
pasky 0:9858347c382d 161 if (!reply) return;
pasky 0:9858347c382d 162 for (char *msg = reply; msg < reply + replysize; msg += strlen(msg)+1)
pasky 0:9858347c382d 163 printf("historic message: %s", msg);
pasky 0:9858347c382d 164 free(reply);
pasky 0:9858347c382d 165 *
pasky 0:9858347c382d 166 * @param channel required channel name.
pasky 0:9858347c382d 167 * @param reply required pointer for passing the returned reply (free() after use).
pasky 0:9858347c382d 168 * @param replysize required pointer for returning the total reply size.
pasky 0:9858347c382d 169 * @param int limit optional number of messages to retrieve.
pasky 0:9858347c382d 170 * @return PNR_OK on success. */
pasky 0:9858347c382d 171 PubNubRes history(const char *channel, char **reply, int *replysize, int limit = 10);
pasky 0:9858347c382d 172
pasky 0:9858347c382d 173 /** Time
pasky 0:9858347c382d 174 *
pasky 0:9858347c382d 175 * Receive the current server timestamp and store it in the
pasky 0:9858347c382d 176 * provided string buffer (a char[32] or larger).
pasky 0:9858347c382d 177 *
pasky 0:9858347c382d 178 * @param ts required pointer to the string buffer.
pasky 0:9858347c382d 179 * @return PNR_OK on success. */
pasky 0:9858347c382d 180 PubNubRes time(char *ts);
pasky 0:9858347c382d 181
pasky 0:9858347c382d 182 /* TODO: here_now */
pasky 0:9858347c382d 183
pasky 0:9858347c382d 184 protected:
pasky 0:9858347c382d 185 const char *m_publish_key, *m_subscribe_key;
pasky 0:9858347c382d 186
pasky 0:9858347c382d 187 const char *m_origin;
pasky 0:9858347c382d 188 const char *origin_hostname();
pasky 0:9858347c382d 189
pasky 0:9858347c382d 190 char m_timetoken[32];
pasky 0:9858347c382d 191 char *m_replybuf;
pasky 0:9858347c382d 192 int m_replylen;
pasky 0:9858347c382d 193
pasky 0:9858347c382d 194 /* Back-end post-processing of subscribe(). free()s *reply
pasky 0:9858347c382d 195 * in the process. */
pasky 0:9858347c382d 196 PubNubRes subscribe_processjson(char *reply, int replylen);
pasky 0:9858347c382d 197 };
pasky 0:9858347c382d 198
pasky 0:9858347c382d 199 #endif