lucretia/embeddingsearch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added Events, Filters, and IncludeSubdirectories to fileupdate call type

Browse Source
This commit is contained in:
LD-Reborn
2025-08-31 01:15:38 +02:00
parent d8e03d1ee0
commit bb6f7c31fb
3 changed files with 24 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/Indexer/Calls.cs
View File

@@ -280,11 +280,22 @@ public class FileUpdateCall : ICall
{ {
throw new IndexerConfigurationException($"Path not set for a Call in Worker \"{Worker.Name}\""); throw new IndexerConfigurationException($"Path not set for a Call in Worker \"{Worker.Name}\"");
} }
List<string> events = callConfig.Events ?? [];
bool allEvents = events.Count == 0;
List<string> filters = callConfig.Filters ?? [];
bool includeSubdirectories = callConfig.IncludeSubdirectories ?? false;
_watcher = new FileSystemWatcher(CallConfig.Path); _watcher = new FileSystemWatcher(CallConfig.Path);
_watcher.Created += OnFileChanged; if (allEvents || events.Contains("Created")) _watcher.Created += OnFileChanged;
_watcher.Changed += OnFileChanged; if (allEvents || events.Contains("Changed")) _watcher.Changed += OnFileChanged;
_watcher.Deleted += OnFileChanged; if (allEvents || events.Contains("Deleted")) _watcher.Deleted += OnFileChanged;
_watcher.Renamed += OnFileChanged; if (allEvents || events.Contains("Renamed")) _watcher.Renamed += OnFileChanged;
foreach (string filter in filters)
{
_watcher.Filters.Add(filter);
}
_watcher.IncludeSubdirectories = includeSubdirectories;
_watcher.EnableRaisingEvents = true; _watcher.EnableRaisingEvents = true;
} }

5
src/Indexer/Models/CallModels.cs
View File

@@ -1,11 +1,16 @@
using Microsoft.Extensions.Diagnostics.HealthChecks; using Microsoft.Extensions.Diagnostics.HealthChecks;
namespace Indexer.Models;
public class CallConfig public class CallConfig
{ {
public required string Type { get; set; } public required string Type { get; set; }
public long? Interval { get; set; } // For Type: Interval public long? Interval { get; set; } // For Type: Interval
public string? Path { get; set; } // For Type: FileSystemWatcher public string? Path { get; set; } // For Type: FileSystemWatcher
public string? Schedule { get; set; } // For Type: Schedule public string? Schedule { get; set; } // For Type: Schedule
public List<string>? Events { get; set; } // For Type: Schedule
public List<string>? Filters { get; set; } // For Type: Schedule
public bool? IncludeSubdirectories { get; set; } // For Type: Schedule
} }
public interface ICall public interface ICall
{ {

5
src/Indexer/appsettings.Development.json
View File

@@ -34,7 +34,10 @@
}, },
{ {
"Type": "fileupdate", "Type": "fileupdate",
"Path": "./Scripts/example_content" "Path": "./Scripts/example_content",
"Events": ["Created", "Changed", "Deleted", "Renamed"],
"Filters": ["*.md", "*.txt"],
"IncludeSubdirectories": true
} }
] ]
} }