7 * This class provides a communication API to the webserver. It also
8 * validates the HMACs on the slots and handles encryption.
9 * @author Brian Demsky <bdemsky@uci.edu>
13 #define CloudComm_SALT_SIZE 8
14 #define CloudComm_TIMEOUT_MILLIS 5000
16 #define CloudComm_IV_SIZE 16
17 /** Sets the size for the HMAC. */
18 #define CloudComm_HMAC_SIZE 32
29 int32_t listeningPort;
30 Thread *localServerThread;
32 TimingSingleton *timer;
35 * Generates Key from password.
37 SecretKeySpec *initKey();
40 * Inits the HMAC generator.
45 * Builds the URL for the given request.
47 URL* buildRequest(bool isput, int64_t sequencenumber, int64_t maxentries);
50 Array<char> *createIV(int64_t machineId, int64_t localSequenceNumber);
51 Array<char> *encryptSlotAndPrependIV(Array<char> *rawData, Array<char> *ivBytes);
52 Array<char> *stripIVAndDecryptSlot(Array<char> *rawData);
53 Array<Slot *> *processSlots(DataInputStream dis);
54 void localServerWorkerFunction();
58 * Empty Constructor needed for child class.
63 * Constructor for actual use. Takes in the url and password.
65 CloudComm(Table *_table, IoTString *_baseurl, IoTString *_password, int _listeningPort);
68 * Inits all the security stuff
73 * API for putting a slot into the queue. Returns NULL on success.
74 * On failure, the server will send slots with newer sequence
77 Array<Slot *> *putSlot(Slot *slot, int max);
80 * Request the server to send all slots with the given
81 * sequencenumber or newer.
83 Array<Slot *> *getSlots(int64_t sequencenumber);
87 * Method that actually handles building Slot objects from the
88 * server response. Shared by both putSlot and getSlots.
91 Array<char> *sendLocalData(Array<char> *sendData, int64_t localSequenceNumber, IoTString *host, int port);