Git-Mirrors/RetroShare
1
0
Fork 0
mirror of https://github.com/RetroShare/RetroShare.git synced 2025-01-25 23:06:10 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

added transaction items and more modification methods for data service (delete msg/grps)

Browse Source 
git-svn-id: http://svn.code.sf.net/p/retroshare/code/branches/v0.5-new_cache_system@5193 b45a01b8-16f6-495d-af2f-9b41ad6348cc
This commit is contained in:
chrisparker126 2012-06-03 18:09:38 +00:00
parent 768cf49da6
commit 36103b29a1
5 changed files with 194 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

186
libretroshare/src/gxs/rsdataservice.cc
View File

@ -7,9 +7,9 @@
// generic // generic
#define KEY_NXS_FILE std::string("msgFile") #define KEY_NXS_FILE std::string("nxsFile")
#define KEY_NXS_FILE_OFFSET std::string("fileOffset") #define KEY_NXS_FILE_OFFSET std::string("fileOffset")
#define KEY_NXS_LEN std::string("msgLen") #define KEY_NXS_FILE_LEN std::string("nxsFileLen")
#define KEY_NXS_IDENTITY std::string("identity") #define KEY_NXS_IDENTITY std::string("identity")
#define KEY_GRP_ID std::string("grpId") #define KEY_GRP_ID std::string("grpId")
#define KEY_IDENTITY_SIGN std::string("idSign") #define KEY_IDENTITY_SIGN std::string("idSign")
@ -20,7 +20,6 @@
#define KEY_ADMIN_SIGN std::string("adminSign") #define KEY_ADMIN_SIGN std::string("adminSign")
#define KEY_KEY_SET std::string("keySet") #define KEY_KEY_SET std::string("keySet")
#define KEY_GRP_FILE std::string("grpFile")
// msg table columns // msg table columns
@ -29,22 +28,22 @@
// grp col numbers // grp col numbers
#define COL_GRP_ID 1 #define COL_GRP_ID 0
#define COL_ADMIN_SIGN 2 #define COL_ADMIN_SIGN 1
#define COL_KEY_SET 10 #define COL_KEY_SET 9
// msg col numbers // msg col numbers
#define COL_MSG_ID 1 #define COL_PUBLISH_SIGN 1
#define COL_PUBLISH_SIGN 2 #define COL_MSG_ID 9
// generic col numbers // generic col numbers
#define COL_NXS_FILE 3 #define COL_NXS_FILE 2
#define COL_NXS_FILE_OFFSET 4 #define COL_NXS_FILE_OFFSET 3
#define COL_NXS_LEN 5 #define COL_NXS_FILE_LEN 4
#define COL_TIME_STAMP 6 #define COL_TIME_STAMP 5
#define COL_NXS_FLAGS 7 #define COL_NXS_FLAGS 6
#define COL_IDENTITY_SIGN 8 #define COL_IDENTITY_SIGN 7
#define COL_IDENTITY 9 #define COL_IDENTITY 8
RsDataService::RsDataService(const std::string &serviceDir, const std::string &dbName, uint16_t serviceType, RsDataService::RsDataService(const std::string &serviceDir, const std::string &dbName, uint16_t serviceType,
@ -53,32 +52,31 @@ RsDataService::RsDataService(const std::string &serviceDir, const std::string &d
// initialise database // initialise database
remove("RsFileGdp_DataBase");
mDb = new RetroDb(dbName, RetroDb::OPEN_READWRITE_CREATE); mDb = new RetroDb(dbName, RetroDb::OPEN_READWRITE_CREATE);
// create table for msgs // create table for msgs
mDb->execSQL("CREATE TABLE " + MSG_TABLE_NAME + "(" + KEY_MSG_ID mDb->execSQL("CREATE TABLE " + MSG_TABLE_NAME + "(" + KEY_MSG_ID
+ " TEXT PRIMARY KEY ASC," + KEY_GRP_ID + " TEXT," + KEY_NXS_FLAGS + " INT," + " TEXT," + KEY_GRP_ID + " TEXT," + KEY_NXS_FLAGS + " INT,"
+ KEY_TIME_STAMP + " INT," + KEY_PUBLISH_SIGN + " BLOB," + KEY_NXS_IDENTITY + " TEXT," + KEY_TIME_STAMP + " INT," + KEY_PUBLISH_SIGN + " BLOB," + KEY_NXS_IDENTITY + " TEXT,"
+ KEY_IDENTITY_SIGN + " BLOB," + KEY_NXS_FILE + " TEXT,"+ KEY_NXS_FILE_OFFSET + " INT," + KEY_IDENTITY_SIGN + " BLOB," + KEY_NXS_FILE + " TEXT,"+ KEY_NXS_FILE_OFFSET + " INT,"
+ KEY_NXS_LEN+ " INT);"); + KEY_NXS_FILE_LEN+ " INT);");
// create table for grps // create table for grps
mDb->execSQL("CREATE TABLE " + GRP_TABLE_NAME + "(" + KEY_GRP_ID + mDb->execSQL("CREATE TABLE " + GRP_TABLE_NAME + "(" + KEY_GRP_ID +
" TEXT PRIMARY KEY ASC," + KEY_TIME_STAMP + " INT," + " TEXT," + KEY_TIME_STAMP + " INT," +
KEY_ADMIN_SIGN + " BLOB," + " BLOB," + KEY_NXS_FILE + KEY_ADMIN_SIGN + " BLOB," + " BLOB," + KEY_NXS_FILE +
" TEXT," + KEY_NXS_FILE_OFFSET + KEY_KEY_SET + " BLOB," + " INT," + KEY_NXS_LEN + " INT," " TEXT," + KEY_NXS_FILE_OFFSET + " INT," + KEY_KEY_SET + " BLOB," + KEY_NXS_FILE_LEN + " INT,"
+ KEY_NXS_IDENTITY + " TEXT," + KEY_NXS_FLAGS + " INT," + KEY_IDENTITY_SIGN + " BLOB);"); + KEY_NXS_IDENTITY + " TEXT," + KEY_NXS_FLAGS + " INT," + KEY_IDENTITY_SIGN + " BLOB);");
msgColumns.push_back(KEY_GRP_ID); msgColumns.push_back(KEY_PUBLISH_SIGN); msgColumns.push_back(KEY_NXS_FILE);
msgColumns.push_back(KEY_MSG_ID); msgColumns.push_back(KEY_PUBLISH_SIGN); msgColumns.push_back(KEY_NXS_FILE); msgColumns.push_back(KEY_NXS_FILE_OFFSET); msgColumns.push_back(KEY_NXS_FILE_LEN); msgColumns.push_back(KEY_TIME_STAMP);
msgColumns.push_back(KEY_NXS_FILE_OFFSET); msgColumns.push_back(KEY_NXS_LEN); msgColumns.push_back(KEY_TIME_STAMP); msgColumns.push_back(KEY_NXS_FLAGS); msgColumns.push_back(KEY_IDENTITY_SIGN); msgColumns.push_back(KEY_NXS_IDENTITY);
msgColumns.push_back(KEY_NXS_FLAGS); msgColumns.push_back(KEY_NXS_IDENTITY); msgColumns.push_back(KEY_IDENTITY_SIGN); msgColumns.push_back(KEY_MSG_ID);
grpColumns.push_back(KEY_GRP_ID); grpColumns.push_back(KEY_ADMIN_SIGN); grpColumns.push_back(KEY_NXS_FILE); grpColumns.push_back(KEY_GRP_ID); grpColumns.push_back(KEY_ADMIN_SIGN); grpColumns.push_back(KEY_NXS_FILE);
grpColumns.push_back(KEY_NXS_FILE_OFFSET); grpColumns.push_back(KEY_NXS_LEN); grpColumns.push_back(KEY_TIME_STAMP); grpColumns.push_back(KEY_NXS_FILE_OFFSET); grpColumns.push_back(KEY_NXS_FILE_LEN); grpColumns.push_back(KEY_TIME_STAMP);
grpColumns.push_back(KEY_NXS_FLAGS); grpColumns.push_back(KEY_NXS_IDENTITY); grpColumns.push_back(KEY_IDENTITY_SIGN); grpColumns.push_back(KEY_NXS_FLAGS); grpColumns.push_back(KEY_IDENTITY_SIGN);
grpColumns.push_back(KEY_KEY_SET); grpColumns.push_back(KEY_GRP_FILE); grpColumns.push_back(KEY_NXS_IDENTITY); grpColumns.push_back(KEY_KEY_SET);
} }
RsDataService::~RsDataService(){ RsDataService::~RsDataService(){
@ -96,8 +94,8 @@ RsNxsGrp* RsDataService::getGroup(RetroCursor &c){
RsNxsGrp* grp = new RsNxsGrp(mServType); RsNxsGrp* grp = new RsNxsGrp(mServType);
bool ok = true; bool ok = true;
// for manipulating raw data
uint32_t offset = 0; uint32_t offset = 0;
// declare members of nxsgrp
char* data = NULL; char* data = NULL;
uint32_t data_len = 0; uint32_t data_len = 0;
@ -107,42 +105,52 @@ RsNxsGrp* RsDataService::getGroup(RetroCursor &c){
// identity if any // identity if any
c.getString(COL_IDENTITY, grp->identity); c.getString(COL_IDENTITY, grp->identity);
grp->timeStamp = c.getInt64(COL_TIME_STAMP); grp->timeStamp = c.getInt32(COL_TIME_STAMP);
if(!grp->identity.empty() && ok){ if(!( grp->identity.empty() ) && ok){
offset = 0; offset = 0;
data = (char*)c.getData(COL_IDENTITY_SIGN, data_len); data = (char*)c.getData(COL_IDENTITY_SIGN, data_len);
if(data){ if(data){
grp->adminSign.GetTlv(data, data_len, &offset);
grp->idSign.GetTlv(data, data_len, &offset);
} }
} }
grp->grpFlag = c.getInt32(COL_NXS_FLAGS); offset = 0;
data = (char*)c.getData(COL_ADMIN_SIGN, data_len);
if(data){
grp->adminSign.GetTlv(data, data_len, &offset);
}
grp->grpFlag = c.getInt32(COL_NXS_FLAGS);
offset = 0; data = NULL; data_len = 0; offset = 0; data = NULL; data_len = 0;
data = (char*)c.getData(COL_KEY_SET, data_len); data = (char*)c.getData(COL_KEY_SET, data_len);
if(data){ if(data){
ok &= grp->keys.SetTlv(data, data_len, &offset); ok &= grp->keys.GetTlv(data, data_len, &offset);
} }
std::string grpFile; std::string grpFile;
c.getString(COL_NXS_FILE, grpFile); c.getString(COL_NXS_FILE, grpFile);
data_len = c.getInt32(COL_NXS_LEN);
ok &= !grpFile.empty(); ok &= !grpFile.empty();
/* now retrieve grp data from file */ /* now retrieve grp data from file */
if(ok){ if(ok){
data_len = c.getInt32(COL_NXS_FILE_LEN);
offset = c.getInt32(COL_NXS_FILE_OFFSET); offset = c.getInt32(COL_NXS_FILE_OFFSET);
std::ifstream istrm(grpFile.c_str());
istrm.open(grpFile.c_str(), std::ios::binary);
istrm.seekg(offset, std::ios::beg);
char grp_data[data_len]; char grp_data[data_len];
std::ifstream istrm(grpFile.c_str(), std::ios::binary);
istrm.seekg(offset, std::ios::beg);
istrm.read(grp_data, data_len); istrm.read(grp_data, data_len);
istrm.close(); istrm.close();
offset = 0; offset = 0;
ok &= grp->grp.SetTlv(grp_data, data_len, &offset); ok &= grp->grp.GetTlv(grp_data, data_len, &offset);
} }
if(ok) if(ok)
@ -170,8 +178,9 @@ RsNxsMsg* RsDataService::getMessage(RetroCursor &c){
c.getString(COL_IDENTITY, msg->identity); c.getString(COL_IDENTITY, msg->identity);
if(!msg->identity.empty()){ if(!msg->identity.empty()){
offset = 0;
data = (char*)c.getData(COL_IDENTITY_SIGN, data_len); data = (char*)c.getData(COL_IDENTITY_SIGN, data_len);
msg->idSign.SetTlv(data, data_len, &offset); msg->idSign.GetTlv(data, data_len, &offset);
} }
msg->msgFlag = c.getInt32(COL_NXS_FLAGS); msg->msgFlag = c.getInt32(COL_NXS_FLAGS);
@ -182,26 +191,27 @@ RsNxsMsg* RsDataService::getMessage(RetroCursor &c){
data = (char*)c.getData(COL_PUBLISH_SIGN, data_len); data = (char*)c.getData(COL_PUBLISH_SIGN, data_len);
if(data) if(data)
msg->publishSign.SetTlv(data, data_len, &offset); msg->publishSign.GetTlv(data, data_len, &offset);
} }
std::string msgFile; std::string msgFile;
c.getString(COL_NXS_FILE, msgFile); c.getString(COL_NXS_FILE, msgFile);
data_len = c.getInt32(COL_NXS_LEN); offset = c.getInt32(COL_NXS_FILE_OFFSET);
data_len = c.getInt32(COL_NXS_FILE_LEN);
ok &= !msgFile.empty(); ok &= !msgFile.empty();
/* now retrieve grp data from file */ /* now retrieve grp data from file */
if(ok){ if(ok){
offset = c.getInt32(COL_NXS_FILE_OFFSET);
std::ifstream istrm(msgFile.c_str()); char msg_data[data_len];
istrm.open(msgFile.c_str(), std::ios::binary); std::ifstream istrm(msgFile.c_str(), std::ios::binary);
istrm.seekg(offset, std::ios::beg); istrm.seekg(offset, std::ios::beg);
char grp_data[data_len]; istrm.read(msg_data, data_len);
istrm.read(grp_data, data_len);
istrm.close(); istrm.close();
offset = 0; offset = 0;
ok &= msg->msg.SetTlv(grp_data, data_len, &offset); ok &= msg->msg.GetTlv(msg_data, data_len, &offset);
} }
if(ok) if(ok)
@ -229,13 +239,21 @@ int RsDataService::storeMessage(std::set<RsNxsMsg *> &msg){
uint32_t offset = ostrm.tellg(); // get fill offset uint32_t offset = ostrm.tellg(); // get fill offset
ContentValue cv; ContentValue cv;
cv.put(KEY_NXS_FILE_OFFSET, (int32_t)offset);
cv.put(KEY_NXS_FILE, msgFile);
cv.put(KEY_NXS_FILE_LEN, (int32_t)msgPtr->msg.TlvSize());
cv.put(KEY_MSG_ID, msgPtr->msgId); cv.put(KEY_MSG_ID, msgPtr->msgId);
cv.put(KEY_GRP_ID, msgPtr->grpId); cv.put(KEY_GRP_ID, msgPtr->grpId);
char pubSignData[msgPtr->publishSign.TlvSize()]; char pubSignData[msgPtr->publishSign.TlvSize()];
offset = 0;
msgPtr->publishSign.SetTlv(pubSignData, msgPtr->publishSign.TlvSize(), &offset);
cv.put(KEY_PUBLISH_SIGN, msgPtr->publishSign.TlvSize(), pubSignData); cv.put(KEY_PUBLISH_SIGN, msgPtr->publishSign.TlvSize(), pubSignData);
if(! (msgPtr->identity.empty()) ){ if(! (msgPtr->identity.empty()) ){
char idSignData[msgPtr->idSign.TlvSize()]; char idSignData[msgPtr->idSign.TlvSize()];
offset = 0;
msgPtr->idSign.SetTlv(idSignData, msgPtr->idSign.TlvSize(), &offset);
cv.put(KEY_IDENTITY_SIGN, msgPtr->idSign.TlvSize(), idSignData); cv.put(KEY_IDENTITY_SIGN, msgPtr->idSign.TlvSize(), idSignData);
cv.put(KEY_NXS_IDENTITY, msgPtr->identity); cv.put(KEY_NXS_IDENTITY, msgPtr->identity);
} }
@ -243,12 +261,12 @@ int RsDataService::storeMessage(std::set<RsNxsMsg *> &msg){
cv.put(KEY_NXS_FLAGS, (int32_t) msgPtr->msgFlag); cv.put(KEY_NXS_FLAGS, (int32_t) msgPtr->msgFlag);
cv.put(KEY_TIME_STAMP, (int32_t) msgPtr->timeStamp); cv.put(KEY_TIME_STAMP, (int32_t) msgPtr->timeStamp);
offset = 0;
char msgData[msgPtr->msg.TlvSize()]; char msgData[msgPtr->msg.TlvSize()];
msgPtr->msg.SetTlv(msgData, msgPtr->msg.TlvSize(), &offset); msgPtr->msg.SetTlv(msgData, msgPtr->msg.TlvSize(), &offset);
ostrm.write(msgData, msgPtr->msg.TlvSize()); ostrm.write(msgData, msgPtr->msg.TlvSize());
ostrm.close(); ostrm.close();
cv.put(KEY_NXS_FILE_OFFSET, (int32_t)offset);
mDb->sqlInsert(MSG_TABLE_NAME, "", cv); mDb->sqlInsert(MSG_TABLE_NAME, "", cv);
} }
@ -274,6 +292,9 @@ int RsDataService::storeGroup(std::set<RsNxsGrp *> &grp){
uint32_t offset = ostrm.tellg(); // get fill offset uint32_t offset = ostrm.tellg(); // get fill offset
ContentValue cv; ContentValue cv;
cv.put(KEY_NXS_FILE_OFFSET, (int32_t)offset);
cv.put(KEY_NXS_FILE_LEN, (int32_t)grpPtr->grp.TlvSize());
cv.put(KEY_NXS_FILE, grpFile);
cv.put(KEY_GRP_ID, grpPtr->grpId); cv.put(KEY_GRP_ID, grpPtr->grpId);
cv.put(KEY_NXS_FLAGS, (int32_t)grpPtr->grpFlag); cv.put(KEY_NXS_FLAGS, (int32_t)grpPtr->grpFlag);
cv.put(KEY_TIME_STAMP, (int32_t)grpPtr->timeStamp); cv.put(KEY_TIME_STAMP, (int32_t)grpPtr->timeStamp);
@ -282,21 +303,30 @@ int RsDataService::storeGroup(std::set<RsNxsGrp *> &grp){
cv.put(KEY_NXS_IDENTITY, grpPtr->identity); cv.put(KEY_NXS_IDENTITY, grpPtr->identity);
char idSignData[grpPtr->idSign.TlvSize()]; char idSignData[grpPtr->idSign.TlvSize()];
offset = 0;
grpPtr->idSign.SetTlv(idSignData, grpPtr->idSign.TlvSize(), &offset);
cv.put(KEY_IDENTITY_SIGN, grpPtr->idSign.TlvSize(), idSignData); cv.put(KEY_IDENTITY_SIGN, grpPtr->idSign.TlvSize(), idSignData);
std::string wat(idSignData, grpPtr->idSign.TlvSize());
std::cerr << wat << std::endl;
} }
char adminSignData[grpPtr->adminSign.TlvSize()]; char adminSignData[grpPtr->adminSign.TlvSize()];
offset = 0;
grpPtr->adminSign.SetTlv(adminSignData, grpPtr->adminSign.TlvSize(), &offset); grpPtr->adminSign.SetTlv(adminSignData, grpPtr->adminSign.TlvSize(), &offset);
cv.put(KEY_ADMIN_SIGN, grpPtr->adminSign.TlvSize(), adminSignData); cv.put(KEY_ADMIN_SIGN, grpPtr->adminSign.TlvSize(), adminSignData);
offset = 0;
char keySetData[grpPtr->keys.TlvSize()]; char keySetData[grpPtr->keys.TlvSize()];
grpPtr->keys.SetTlv(keySetData, grpPtr->keys.TlvSize(), &offset); grpPtr->keys.SetTlv(keySetData, grpPtr->keys.TlvSize(), &offset);
cv.put(KEY_KEY_SET, grpPtr->keys.TlvSize(), keySetData); cv.put(KEY_KEY_SET, grpPtr->keys.TlvSize(), keySetData);
offset = 0;
char grpData[grpPtr->grp.TlvSize()]; char grpData[grpPtr->grp.TlvSize()];
grpPtr->grp.SetTlv(grpData, grpPtr->grp.TlvSize(), &offset); grpPtr->grp.SetTlv(grpData, grpPtr->grp.TlvSize(), &offset);
ostrm.write(grpData, grpPtr->grp.TlvSize()); ostrm.write(grpData, grpPtr->grp.TlvSize());
ostrm.close(); ostrm.close();
mDb->sqlInsert(GRP_TABLE_NAME, "", cv);
} }
return mDb->execSQL("COMMIT;"); return mDb->execSQL("COMMIT;");
@ -313,21 +343,21 @@ int RsDataService::retrieveGrps(std::map<std::string, RsNxsGrp*> &grp, bool cach
while(valid){ while(valid){
RsNxsGrp* g = getGroup(*c); RsNxsGrp* g = getGroup(*c);
// only add the latest grp info // only add the latest grp info
bool exists = grp.find(g->grpId) != grp.end(); if(g){
if(exists){ bool exists = grp.find(g->grpId) != grp.end();
if(exists){
if(grp[g->grpId]->timeStamp < g->timeStamp){ if(grp[g->grpId]->timeStamp < g->timeStamp){
delete grp[g->grpId]; delete grp[g->grpId];
grp[g->grpId] = g; grp[g->grpId] = g;
}else{
delete g;
}
}else{ }else{
delete g; grp[g->grpId] = g;
} }
}else{
grp[g->grpId] = g;
} }
valid = c->moveToNext(); valid = c->moveToNext();
} }
@ -338,9 +368,9 @@ int RsDataService::retrieveGrps(std::map<std::string, RsNxsGrp*> &grp, bool cach
} }
} }
int RsDataService::retrieveMsgs(const std::string &grpId, std::map<std::string, RsNxsMsg *> msg, bool cache){ int RsDataService::retrieveMsgs(const std::string &grpId, std::map<std::string, RsNxsMsg *>& msg, bool cache){
RetroCursor* c = mDb->sqlQuery(MSG_TABLE_NAME, msgColumns, KEY_GRP_ID+ "=" + grpId, ""); RetroCursor* c = mDb->sqlQuery(MSG_TABLE_NAME, msgColumns, KEY_GRP_ID+ "='" + grpId + "'", "");
if(c){ if(c){
@ -348,20 +378,23 @@ int RsDataService::retrieveMsgs(const std::string &grpId, std::map<std::string,
while(valid){ while(valid){
RsNxsMsg* m = getMessage(*c); RsNxsMsg* m = getMessage(*c);
// only add the latest grp info if(m){
bool exists = msg.find(m->msgId) != msg.end(); // only add the latest grp info
if(exists){ bool exists = msg.find(m->msgId) != msg.end();
if(exists){
if(msg[m->msgId]->timeStamp < m->timeStamp){ if(msg[m->msgId]->timeStamp < m->timeStamp){
delete msg[m->msgId]; delete msg[m->msgId];
msg[m->msgId] = m; msg[m->msgId] = m;
}else{
delete m;
}
}else{ }else{
delete m; msg[m->msgId] = m;
} }
}else{
msg[m->msgId] = m;
}
}
valid = c->moveToNext(); valid = c->moveToNext();
} }
@ -488,6 +521,19 @@ RsNxsMsg* RsDataService::retrieveMsgVersion(const RsGxsMsgId &msgId){
return msg; return msg;
} }
int RsDataService::resetDataStore(){
}
int RsDataService::removeGroups(const std::list<RsGxsGrpId> &grpIds){
return 0;
}
int RsDataService::removeMsgs(const std::list<RsGxsMsgId> &msgIds){
return 0;
}
uint32_t RsDataService::cacheSize() const { uint32_t RsDataService::cacheSize() const {
return 0; return 0;
} }

24
libretroshare/src/gxs/rsdataservice.h
View File

@ -19,7 +19,7 @@ public:
* @param cache whether to store retrieval in memory for faster later retrieval * @param cache whether to store retrieval in memory for faster later retrieval
* @return error code * @return error code
*/ */
int retrieveMsgs(const std::string& grpId, std::map<std::string, RsNxsMsg*> msg, bool cache); int retrieveMsgs(const std::string& grpId, std::map<std::string, RsNxsMsg*>& msg, bool cache);
/*! /*!
* Retrieves latest version of groups for a service * Retrieves latest version of groups for a service
@ -58,6 +58,21 @@ public:
*/ */
RsNxsGrp* retrieveGrpVersion(const RsGxsGrpId& grpId); RsNxsGrp* retrieveGrpVersion(const RsGxsGrpId& grpId);
/*!
* remove msgs in data store listed in msgIds param
* @param msgIds ids of messages to be removed
* @return error code
*/
int removeMsgs(const std::list<RsGxsMsgId>& msgIds);
/*!
* remove groups in data store listed in grpIds param
* @param grpIds ids of groups to be removed
* @return error code
*/
int removeGroups(const std::list<RsGxsGrpId>& grpIds);
/*! /*!
* allows for more complex queries specific to the service * allows for more complex queries specific to the service
* @param search generally stores parameters needed for query * @param search generally stores parameters needed for query
@ -98,6 +113,13 @@ public:
*/ */
int storeGroup(std::set<RsNxsGrp*>& grp); int storeGroup(std::set<RsNxsGrp*>& grp);
/*!
* Completely clear out data stored in
* this data store and returns this to a state
* as it was when first constructed
*/
int resetDataStore();
private: private:

24
libretroshare/src/gxs/rsgds.h
View File

@ -74,7 +74,7 @@ public:
* @param cache whether to store retrieval in memory for faster later retrieval * @param cache whether to store retrieval in memory for faster later retrieval
* @return error code * @return error code
*/ */
virtual int retrieveMsgs(const std::string& grpId, std::map<std::string, RsNxsMsg*> msg, bool cache) = 0; virtual int retrieveMsgs(const std::string& grpId, std::map<std::string, RsNxsMsg*>& msg, bool cache) = 0;
/*! /*!
* Retrieves a group item by grpId * Retrieves a group item by grpId
@ -127,6 +127,20 @@ public:
*/ */
virtual int searchGrps(RsGxsSearch* search, std::list<RsGxsSrchResGrpCtx*>& result) = 0; virtual int searchGrps(RsGxsSearch* search, std::list<RsGxsSrchResGrpCtx*>& result) = 0;
/*!
* remove msgs in data store listed in msgIds param
* @param msgIds ids of messages to be removed
* @return error code
*/
virtual int removeMsgs(const std::list<RsGxsMsgId>& msgIds) = 0;
/*!
* remove groups in data store listed in grpIds param
* @param grpIds ids of groups to be removed
* @return error code
*/
virtual int removeGroups(const std::list<RsGxsGrpId>& grpIds) = 0;
/*! /*!
* @return the cache size set for this RsGeneralDataService in bytes * @return the cache size set for this RsGeneralDataService in bytes
*/ */
@ -151,6 +165,14 @@ public:
*/ */
virtual int storeGroup(std::set<RsNxsGrp*>& grp) = 0; virtual int storeGroup(std::set<RsNxsGrp*>& grp) = 0;
/*!
* Completely clear out data stored in
* and returns this to a state
* as it was when first constructed
*/
virtual int resetDataStore() = 0;
}; };

31
libretroshare/src/serialiser/rsnxsitems.h
View File

@ -82,7 +82,7 @@ class RsSyncGrp : public RsNxsItem {
public: public:
static const uint8_t FLAG_USE_SYNC_HASH; static const uint8_t FLAG_USE_SYNC_HASH;
static const uint8_t FLAG_ONLY_CURRENT; // only send most current sycn list static const uint8_t FLAG_ONLY_CURRENT; // only send most current version of grps / ignores sync hash
RsSyncGrp(uint16_t servtype) : RsNxsItem(servtype, RS_PKT_SUBTYPE_SYNC_GRP) { return;} RsSyncGrp(uint16_t servtype) : RsNxsItem(servtype, RS_PKT_SUBTYPE_SYNC_GRP) { return;}
@ -94,6 +94,35 @@ public:
std::string syncHash; // use to determine if changes that have occured since last hash std::string syncHash; // use to determine if changes that have occured since last hash
};
/*!
* This RsNxsItem is for use in enabling transactions
* in order to guaranttee a collection of item have been
* received
*/
class RsNxsTransac : public RsNxsItem {
public:
/** transaction **/
static const uint16_t FLAG_BEGIN_P1;
static const uint16_t FLAG_BEGIN_P2;
static const uint16_t FLAG_END_P1;
static const uint16_t FLAG_END_P2;
static const uint16_t FLAG_CANCEL;
/** transaction type **/
static const uint16_t FLAG_TYPE_GRP_LIST_RESP;
static const uint16_t FLAG_TYPE_MSG_LIST_RESP;
static const uint16_t FLAG_TYPE_GRP_LIST_REQ;
static const uint16_t FLAG_TYPE_
}; };
/*! /*!

4
libretroshare/src/util/retrodb.cc
View File

@ -29,7 +29,7 @@
#include "retrodb.h" #include "retrodb.h"
//#define RETRODB_DEBUG #define RETRODB_DEBUG
void free_blob(void* dat){ void free_blob(void* dat){
@ -523,7 +523,7 @@ bool RetroCursor::moveToFirst(){
#endif #endif
if(!isOpen()) if(!isOpen())
return -1; return false;
// reset statement // reset statement
int rc = sqlite3_reset(mStmt); int rc = sqlite3_reset(mStmt);