slon-project/slon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Slon/Modules/Db: Show progress when loading profiles and statues

Browse source
This commit is contained in:
Alec Murphy 2025-03-12 13:41:05 -04:00
parent de213e35fe
commit 6e9f86b4ae
1 changed files with 22 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

22
Slon/Modules/Db.HC
View file

@ -9,19 +9,30 @@ JsonObject* db = Json.CreateObject(slon_db_mem_task);
U0 @slon_db_load_accounts_from_disk() U0 @slon_db_load_accounts_from_disk()
{ {
progress1 = 0;
progress1_max = 0;
JsonArray* accounts = Json.CreateArray(slon_db_mem_task); JsonArray* accounts = Json.CreateArray(slon_db_mem_task);
U8 scratch_buffer[256]; U8 scratch_buffer[256];
StrPrint(scratch_buffer, "%s/accounts/*.json", SLON_DB_PATH); StrPrint(scratch_buffer, "%s/accounts/*.json", SLON_DB_PATH);
CDirEntry* files = FilesFind(scratch_buffer); CDirEntry* files = FilesFind(scratch_buffer);
CDirEntry* de = files; CDirEntry* de = files;
while (de) {
++progress1_max;
de = de->next;
}
JsonObject* account = NULL; JsonObject* account = NULL;
de = files;
while (de) { while (de) {
account = Json.ParseFile(de->full_name, slon_db_mem_task); account = Json.ParseFile(de->full_name, slon_db_mem_task);
if (account) { if (account) {
accounts->append(account); accounts->append(account);
} }
++progress1;
StrPrint(progress1_desc, "Loading profile for account [%d/%d]", progress1 + 1, progress1_max);
de = de->next; de = de->next;
} }
progress1 = 0;
progress1_max = 0;
DirTreeDel(files); DirTreeDel(files);
db->set("accounts", accounts, JSON_ARRAY); db->set("accounts", accounts, JSON_ARRAY);
} }
@ -130,11 +141,18 @@ U0 @slon_db_load_settings_from_disk()
U0 @slon_db_load_statuses_from_disk() U0 @slon_db_load_statuses_from_disk()
{ {
progress1 = 0;
progress1_max = 0;
JsonObject* statuses = Json.CreateObject(slon_db_mem_task); JsonObject* statuses = Json.CreateObject(slon_db_mem_task);
U8 scratch_buffer[256]; U8 scratch_buffer[256];
StrPrint(scratch_buffer, "%s/statuses/*.json", SLON_DB_PATH); StrPrint(scratch_buffer, "%s/statuses/*.json", SLON_DB_PATH);
CDirEntry* files = FilesFind(scratch_buffer); CDirEntry* files = FilesFind(scratch_buffer);
CDirEntry* de = files; CDirEntry* de = files;
while (de) {
++progress1_max;
de = de->next;
}
de = files;
JsonArray* status_array = NULL; JsonArray* status_array = NULL;
while (de) { while (de) {
status_array = Json.ParseFile(de->full_name, slon_db_mem_task); status_array = Json.ParseFile(de->full_name, slon_db_mem_task);
@ -142,8 +160,12 @@ U0 @slon_db_load_statuses_from_disk()
StrFind(".json", de->name)[0] = NULL; StrFind(".json", de->name)[0] = NULL;
statuses->set(de->name, status_array, JSON_ARRAY); statuses->set(de->name, status_array, JSON_ARRAY);
} }
++progress1;
StrPrint(progress1_desc, "Loading statuses for account [%d/%d]", progress1 + 1, progress1_max);
de = de->next; de = de->next;
} }
progress1 = 0;
progress1_max = 0;
DirTreeDel(files); DirTreeDel(files);
db->set("statuses", statuses, JSON_OBJECT); db->set("statuses", statuses, JSON_OBJECT);
} }