anth64/stk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Enhance file watching to return event types

Browse Source 
- `platform_directory_watch_check` now returns event types along side
  file names/counts
This commit is contained in:
anth64
2025-11-03 23:16:32 +01:00
parent ec2aa09596
commit da4dcee490
1 changed files with 54 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/platform.c
+54 -17
View File
@@ -95,8 +95,11 @@ void platform_directory_watch_stop(void *handle)
#endif #endif
} }
char **platform_directory_watch_check(void *handle, size_t *out_count) stk_file_event_t *platform_directory_watch_check(void *handle,
char ***file_list,
size_t *out_count)
{ {
stk_file_event_t *events = NULL;
#ifdef __linux__ #ifdef __linux__
int fd; int fd;
char buffer[EVENT_BUFFER_SIZE]; char buffer[EVENT_BUFFER_SIZE];
@@ -104,7 +107,6 @@ char **platform_directory_watch_check(void *handle, size_t *out_count)
struct inotify_event *event; struct inotify_event *event;
char *event_ptr; char *event_ptr;
size_t file_count, index; size_t file_count, index;
char **file_list;
fd = (int)(long)handle; fd = (int)(long)handle;
bytes_read = read(fd, buffer, sizeof(buffer)); bytes_read = read(fd, buffer, sizeof(buffer));
@@ -128,8 +130,11 @@ char **platform_directory_watch_check(void *handle, size_t *out_count)
return NULL; return NULL;
} }
file_list = malloc(file_count * sizeof(char *)); events = malloc(file_count * sizeof(stk_file_event_t));
if (!file_list) { *file_list = malloc(file_count * sizeof(char *));
if (!events || !*file_list) {
free(events);
free(*file_list);
*out_count = 0; *out_count = 0;
return NULL; return NULL;
} }
@@ -139,9 +144,22 @@ char **platform_directory_watch_check(void *handle, size_t *out_count)
while (event_ptr < buffer + bytes_read) { while (event_ptr < buffer + bytes_read) {
event = (struct inotify_event *)event_ptr; event = (struct inotify_event *)event_ptr;
if (event->len > 0) { if (event->len > 0) {
file_list[index] = malloc(strlen(event->name) + 1); switch (event->mask) {
if (file_list[index]) { case IN_CREATE:
strcpy(file_list[index], event->name); case IN_MOVED_TO:
events[index] = STK_FILE_CREATED;
break;
case IN_MODIFY:
events[index] = STK_FILE_MODIFIED;
break;
case IN_DELETE:
case IN_MOVED_FROM:
events[index] = STK_FILE_DELETED;
break;
}
(*file_list)[index] = malloc(strlen(event->name) + 1);
if ((*file_list)[index]) {
strcpy((*file_list)[index], event->name);
index++; index++;
} }
} }
@@ -150,7 +168,7 @@ char **platform_directory_watch_check(void *handle, size_t *out_count)
} }
*out_count = index; *out_count = index;
return file_list; return events;
#elif defined(_WIN32) #elif defined(_WIN32)
HANDLE h; HANDLE h;
BYTE buffer[EVENT_BUFFER_SIZE]; BYTE buffer[EVENT_BUFFER_SIZE];
@@ -190,8 +208,11 @@ char **platform_directory_watch_check(void *handle, size_t *out_count)
return NULL; return NULL;
} }
file_list = malloc(file_count * sizeof(char *)); events = malloc(file_count * sizeof(stk_file_event_t));
if (!file_list) { *file_list = malloc(file_count * sizeof(char *));
if (!events || !*file_list) {
free(events);
free(*file_list);
*out_count = 0; *out_count = 0;
return NULL; return NULL;
} }
@@ -201,18 +222,34 @@ char **platform_directory_watch_check(void *handle, size_t *out_count)
while (1) { while (1) {
info = (FILE_NOTIFY_INFORMATION *)event_ptr; info = (FILE_NOTIFY_INFORMATION *)event_ptr;
switch (info->Action) {
case FILE_ACTION_ADDED:
events[index] = STK_FILE_CREATED;
break;
case FILE_ACTION_MODIFIED:
events[index] = STK_FILE_MODIFIED;
break;
case FILE_ACTION_REMOVED:
events[index] = STK_FILE_DELETED;
break;
case FILE_ACTION_RENAMED:
events[index] = STK_FILE_RENAMED;
break;
}
char_count = WideCharToMultiByte( char_count = WideCharToMultiByte(
CP_UTF8, 0, info->FileName, CP_UTF8, 0, info->FileName,
info->FileNameLength / sizeof(WCHAR), NULL, 0, NULL, NULL); info->FileNameLength / sizeof(WCHAR), NULL, 0, NULL, NULL);
if (char_count > 0) { if (char_count > 0) {
file_list[index] = malloc(char_count + 1); (file_list *)[index] = malloc(char_count + 1);
if (file_list[index]) { if ((*file_list)[index]) {
WideCharToMultiByte( WideCharToMultiByte(CP_UTF8, 0, info->FileName,
CP_UTF8, 0, info->FileName, info->FileNameLength /
info->FileNameLength / sizeof(WCHAR), sizeof(WCHAR),
file_list[index], char_count, NULL, NULL); (file_list *)[index],
file_list[index][char_count] = '\0'; char_count, NULL, NULL);
(file_list *)[index][char_count] = '\0';
index++; index++;
} }
} }