#ifndef __INGEST_HPP__
#define __INGEST_HPP__

struct ClientList {
    uint32_t num;
    uint32_t start;
    uint32_t end;
    sgx_aes_gcm_128bit_key_t *keys;
};

class Ingestion{
private:

    ClientList clients;
    MsgBuffer buffer;
    uint32_t max_buffer_size;

public:

    Ingestion() {
    }

    void generateClientKeys(sgx_aes_gcm_128bit_key_t &ESK);

    void initialize(uint32_t cnum, uint32_t cstart, sgx_aes_gcm_128bit_key_t &ESK);

    uint32_t getClientNum() {
        return (clients.num);
    }

    uint32_t getClientStart() {
        return (clients.start);
    }

    sgx_aes_gcm_128bit_key_t* getClientKeys() {
        return (clients.keys);
    }

    bool processMsgBundle(clientid_t cid, unsigned char *msgbundle,
        uint32_t num_msgs);
};


extern Ingestion g_ing;

#endif