martin/aqhomecontrol
Public Access
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

aqhome: started parsing messages and extract info for node db.

Browse Source
This commit is contained in:
Martin Preuss
2023-03-24 21:16:25 +01:00
parent 58e5816c56
commit 0aaa5969ab
6 changed files with 410 additions and 119 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
aqhome/nodes/nodedb.c
View File

@@ -39,6 +39,27 @@ void AQH_NodeDb_free(AQH_NODE_DB *ndb)
void AQH_NodeDb_SetModified(AQH_NODE_DB *ndb)
{
ndb->modified=1;
}
void AQH_NodeDb_ClearModified(AQH_NODE_DB *ndb)
{
ndb->modified=0;
}
int AQH_NodeDb_IsModified(const AQH_NODE_DB *ndb)
{
return ndb->modified;
}
AQH_NODE_INFO_LIST *AQH_NodeDb_GetAllNodeInfos(AQH_NODE_DB *ndb)
{
return ndb->nodeList;
@@ -62,6 +83,7 @@ int AQH_NodeDb_AddNodeInfo(AQH_NODE_DB *ndb, AQH_NODE_INFO *ni)
}
busAddr=AQH_NodeInfo_GetBusAddress(ni);
#if 0
if (busAddr==0) {
DBG_ERROR(AQH_LOGDOMAIN, "Not adding node without BUSADDR");
return GWEN_ERROR_INVALID;
@@ -70,9 +92,11 @@ int AQH_NodeDb_AddNodeInfo(AQH_NODE_DB *ndb, AQH_NODE_INFO *ni)
DBG_ERROR(AQH_LOGDOMAIN, "A node with the given BUSADDR \"%02x\" already exists", busAddr);
return GWEN_ERROR_INVALID;
}
#endif
DBG_INFO(AQH_LOGDOMAIN, "Adding node UID=%08x BUSADDR=%02x", (unsigned int) uid, busAddr);
AQH_NodeInfo_List_Add(ni, ndb->nodeList);
AQH_NodeDb_SetModified(ndb);
return 0;
}
@@ -92,7 +116,7 @@ AQH_NODE_INFO *AQH_NodeDb_GetNodeInfoByUid(AQH_NODE_DB *ndb, uint32_t uid)
AQH_NODE_INFO_LIST *AQH_NodeDb_GetNodeInfosByNodeType(AQH_NODE_DB *ndb, int t)
AQH_NODE_INFO_LIST *AQH_NodeDb_GetNodeInfosByFirmwareType(AQH_NODE_DB *ndb, int t)
{
AQH_NODE_INFO_LIST *resultList;
AQH_NODE_INFO *ni;
@@ -100,7 +124,7 @@ AQH_NODE_INFO_LIST *AQH_NodeDb_GetNodeInfosByNodeType(AQH_NODE_DB *ndb, int t)
resultList=AQH_NodeInfo_List_new();
ni=AQH_NodeInfo_List_First(ndb->nodeList);
while(ni) {
if (t==0 || t==AQH_NodeInfo_GetNodeType(ni))
if (t==0 || t==AQH_NodeInfo_GetFirmwareType(ni))
AQH_NodeInfo_List_Add(AQH_NodeInfo_dup(ni), resultList);
ni=AQH_NodeInfo_List_Next(ni);
}
@@ -115,5 +139,43 @@ AQH_NODE_INFO_LIST *AQH_NodeDb_GetNodeInfosByNodeType(AQH_NODE_DB *ndb, int t)
void AQH_NodeDb_toDb(AQH_NODE_DB *ndb, GWEN_DB_NODE *dbDatabase)
{
if (ndb->nodeList) {
AQH_NODE_INFO *ni;
ni=AQH_NodeInfo_List_First(ndb->nodeList);
while(ni) {
GWEN_DB_NODE *dbNodeInfo;
dbNodeInfo=GWEN_DB_Group_new("nodeInfo");
AQH_NodeInfo_toDb(ni, dbNodeInfo);
GWEN_DB_AddGroup(dbDatabase, dbNodeInfo);
ni=AQH_NodeInfo_List_Next(ni);
}
}
}
void AQH_NodeDb_fromDb(AQH_NODE_DB *ndb, GWEN_DB_NODE *dbDatabase)
{
GWEN_DB_NODE *dbNodeInfo;
AQH_NodeInfo_List_Clear(ndb->nodeList);
dbNodeInfo=GWEN_DB_FindFirstGroup(dbDatabase, "nodeinfo");
while(dbNodeInfo) {
AQH_NODE_INFO *ni;
ni=AQH_NodeInfo_fromDb(dbNodeInfo);
if (ni)
AQH_NodeInfo_List_Add(ni, ndb->nodeList);
dbNodeInfo=GWEN_DB_FindNextGroup(dbNodeInfo, "nodeinfo");
}
AQH_NodeDb_ClearModified(ndb);
}