Merge claudedo/64fbe15dae7e4d81b8c1045baa7e3c87
This commit is contained in:
@@ -656,7 +656,8 @@
|
|||||||
"worktreesOverview": { "titleAll": "Worktrees", "titleList": "Worktrees — {0}", "listFallback": "Liste", "cleanupFailed": "Aufräumen fehlgeschlagen.", "cleanupFailedDetailed": "Aufräumen fehlgeschlagen: {0}", "removed": "{0} Worktree(s) entfernt.", "discardFailed": "Worktree konnte nicht verworfen werden.", "keepFailed": "Worktree konnte nicht behalten werden.", "cannotForceRunning": "Eine laufende Aufgabe kann nicht zwangsweise entfernt werden.", "forceRemoveFailed": "Zwangsentfernung fehlgeschlagen.", "forceRemoveFailedDetailed": "Zwangsentfernung fehlgeschlagen: {0}", "batchProgress": "Merge {0}/{1}…", "batchDone": "{0} gemergt, {1} zu lösen." },
|
"worktreesOverview": { "titleAll": "Worktrees", "titleList": "Worktrees — {0}", "listFallback": "Liste", "cleanupFailed": "Aufräumen fehlgeschlagen.", "cleanupFailedDetailed": "Aufräumen fehlgeschlagen: {0}", "removed": "{0} Worktree(s) entfernt.", "discardFailed": "Worktree konnte nicht verworfen werden.", "keepFailed": "Worktree konnte nicht behalten werden.", "cannotForceRunning": "Eine laufende Aufgabe kann nicht zwangsweise entfernt werden.", "forceRemoveFailed": "Zwangsentfernung fehlgeschlagen.", "forceRemoveFailedDetailed": "Zwangsentfernung fehlgeschlagen: {0}", "batchProgress": "Merge {0}/{1}…", "batchDone": "{0} gemergt, {1} zu lösen." },
|
||||||
"listSettings": { "untitled": "Unbenannt" },
|
"listSettings": { "untitled": "Unbenannt" },
|
||||||
"detailsIsland": { "verifyFailed": "Merge ist erfolgt, aber das Verifikationskommando der Liste ist fehlgeschlagen — die Aufgabe wurde nicht auf 'Erledigt' gesetzt." },
|
"detailsIsland": { "verifyFailed": "Merge ist erfolgt, aber das Verifikationskommando der Liste ist fehlgeschlagen — die Aufgabe wurde nicht auf 'Erledigt' gesetzt." },
|
||||||
"lists": { "localSuffix": "{0} / lokal", "smartMyDay": "Mein Tag", "smartImportant": "Wichtig", "smartPlanned": "Geplant", "virtualQueue": "Warteschlange", "virtualRunning": "Läuft", "virtualReview": "Prüfung", "newList": "Neue Liste" }
|
"lists": { "localSuffix": "{0} / lokal", "smartMyDay": "Mein Tag", "smartImportant": "Wichtig", "smartPlanned": "Geplant", "virtualQueue": "Warteschlange", "virtualRunning": "Läuft", "virtualReview": "Prüfung", "newList": "Neue Liste" },
|
||||||
|
"repoImport": { "loadFailed": "Gespeicherte Ordner konnten nicht geladen werden: {0}", "saveFailed": "Ordner konnten nicht gespeichert werden: {0}" }
|
||||||
},
|
},
|
||||||
"usage": {
|
"usage": {
|
||||||
"pill": {
|
"pill": {
|
||||||
|
|||||||
@@ -656,7 +656,8 @@
|
|||||||
"worktreesOverview": { "titleAll": "Worktrees", "titleList": "Worktrees — {0}", "listFallback": "list", "cleanupFailed": "Cleanup failed.", "cleanupFailedDetailed": "Cleanup failed: {0}", "removed": "Removed {0} worktree(s).", "discardFailed": "Failed to discard worktree.", "keepFailed": "Failed to keep worktree.", "cannotForceRunning": "Cannot force-remove a running task.", "forceRemoveFailed": "Force remove failed.", "forceRemoveFailedDetailed": "Force remove failed: {0}", "batchProgress": "Merging {0}/{1}…", "batchDone": "Merged {0}, {1} need resolution." },
|
"worktreesOverview": { "titleAll": "Worktrees", "titleList": "Worktrees — {0}", "listFallback": "list", "cleanupFailed": "Cleanup failed.", "cleanupFailedDetailed": "Cleanup failed: {0}", "removed": "Removed {0} worktree(s).", "discardFailed": "Failed to discard worktree.", "keepFailed": "Failed to keep worktree.", "cannotForceRunning": "Cannot force-remove a running task.", "forceRemoveFailed": "Force remove failed.", "forceRemoveFailedDetailed": "Force remove failed: {0}", "batchProgress": "Merging {0}/{1}…", "batchDone": "Merged {0}, {1} need resolution." },
|
||||||
"listSettings": { "untitled": "Untitled" },
|
"listSettings": { "untitled": "Untitled" },
|
||||||
"detailsIsland": { "verifyFailed": "Merge landed, but the list's verify command failed — the task was kept out of Done." },
|
"detailsIsland": { "verifyFailed": "Merge landed, but the list's verify command failed — the task was kept out of Done." },
|
||||||
"lists": { "localSuffix": "{0} / local", "smartMyDay": "My Day", "smartImportant": "Important", "smartPlanned": "Planned", "virtualQueue": "Queue", "virtualRunning": "Running", "virtualReview": "Review", "newList": "New list" }
|
"lists": { "localSuffix": "{0} / local", "smartMyDay": "My Day", "smartImportant": "Important", "smartPlanned": "Planned", "virtualQueue": "Queue", "virtualRunning": "Running", "virtualReview": "Review", "newList": "New list" },
|
||||||
|
"repoImport": { "loadFailed": "Couldn't load remembered folders: {0}", "saveFailed": "Couldn't save folders: {0}" }
|
||||||
},
|
},
|
||||||
"usage": {
|
"usage": {
|
||||||
"pill": {
|
"pill": {
|
||||||
|
|||||||
@@ -59,6 +59,11 @@ public interface IWorkerClient : INotifyPropertyChanged
|
|||||||
Task<SeedResultDto?> RestoreDefaultAgentsAsync();
|
Task<SeedResultDto?> RestoreDefaultAgentsAsync();
|
||||||
Task<ListConfigDto?> GetListConfigAsync(string listId);
|
Task<ListConfigDto?> GetListConfigAsync(string listId);
|
||||||
Task UpdateTaskAgentSettingsAsync(UpdateTaskAgentSettingsDto dto);
|
Task UpdateTaskAgentSettingsAsync(UpdateTaskAgentSettingsDto dto);
|
||||||
|
/// <summary>Repo-import folders remembered for the "Add repos as lists" dialog. Throws on
|
||||||
|
/// a failed hub call — the caller surfaces the failure rather than showing an empty list.</summary>
|
||||||
|
Task<List<string>> GetRepoImportFoldersAsync();
|
||||||
|
/// <summary>Persists the repo-import folder list. Throws on a failed hub call.</summary>
|
||||||
|
Task SetRepoImportFoldersAsync(List<string> folders);
|
||||||
Task<List<SessionSkillDto>> GetSessionSkillsAsync();
|
Task<List<SessionSkillDto>> GetSessionSkillsAsync();
|
||||||
Task<List<string>> InstallSessionSkillAsync(string url);
|
Task<List<string>> InstallSessionSkillAsync(string url);
|
||||||
Task UpdateSessionSkillAsync(string sourceUrl);
|
Task UpdateSessionSkillAsync(string sourceUrl);
|
||||||
|
|||||||
@@ -444,6 +444,12 @@ public partial class WorkerClient : ObservableObject, IAsyncDisposable, IWorkerC
|
|||||||
await _hub.InvokeAsync("UpdateTaskAgentSettings", dto);
|
await _hub.InvokeAsync("UpdateTaskAgentSettings", dto);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async Task<List<string>> GetRepoImportFoldersAsync()
|
||||||
|
=> await _hub.InvokeAsync<List<string>>("GetRepoImportFolders");
|
||||||
|
|
||||||
|
public Task SetRepoImportFoldersAsync(List<string> folders)
|
||||||
|
=> _hub.InvokeAsync("SetRepoImportFolders", folders);
|
||||||
|
|
||||||
public async Task<List<SessionSkillDto>> GetSessionSkillsAsync()
|
public async Task<List<SessionSkillDto>> GetSessionSkillsAsync()
|
||||||
=> await TryInvokeAsync<List<SessionSkillDto>>("GetSessionSkills") ?? [];
|
=> await TryInvokeAsync<List<SessionSkillDto>>("GetSessionSkills") ?? [];
|
||||||
|
|
||||||
|
|||||||
@@ -30,6 +30,9 @@ public sealed partial class ListsIslandViewModel : ViewModelBase, IDisposable
|
|||||||
public event EventHandler? FocusSearchRequested;
|
public event EventHandler? FocusSearchRequested;
|
||||||
public void RequestFocusSearch() => FocusSearchRequested?.Invoke(this, EventArgs.Empty);
|
public void RequestFocusSearch() => FocusSearchRequested?.Invoke(this, EventArgs.Empty);
|
||||||
|
|
||||||
|
// mirrors TasksIslandViewModel.ErrorReported — surfaces modal-owned failures in the footer strip.
|
||||||
|
public event Action<string>? ErrorReported;
|
||||||
|
|
||||||
public IDialogService? Dialogs { get; set; }
|
public IDialogService? Dialogs { get; set; }
|
||||||
|
|
||||||
[RelayCommand]
|
[RelayCommand]
|
||||||
@@ -58,6 +61,7 @@ public sealed partial class ListsIslandViewModel : ViewModelBase, IDisposable
|
|||||||
{
|
{
|
||||||
if (Dialogs is null || _services is null) return;
|
if (Dialogs is null || _services is null) return;
|
||||||
var vm = _services.GetRequiredService<RepoImportModalViewModel>();
|
var vm = _services.GetRequiredService<RepoImportModalViewModel>();
|
||||||
|
vm.ErrorReported += msg => ErrorReported?.Invoke(msg);
|
||||||
await vm.LoadAsync();
|
await vm.LoadAsync();
|
||||||
await Dialogs.ShowRepoImportAsync(vm);
|
await Dialogs.ShowRepoImportAsync(vm);
|
||||||
await LoadAsync();
|
await LoadAsync();
|
||||||
|
|||||||
@@ -237,6 +237,7 @@ public sealed partial class IslandsShellViewModel : ViewModelBase, IDisposable
|
|||||||
Tasks.NotesRequested += () => Details.ShowNotes();
|
Tasks.NotesRequested += () => Details.ShowNotes();
|
||||||
Tasks.PrepRequested += () => Details.ShowPrep();
|
Tasks.PrepRequested += () => Details.ShowPrep();
|
||||||
Tasks.ErrorReported += FlashFooterError;
|
Tasks.ErrorReported += FlashFooterError;
|
||||||
|
Lists.ErrorReported += FlashFooterError;
|
||||||
Tasks.OpenConPtySessionRequested += taskId =>
|
Tasks.OpenConPtySessionRequested += taskId =>
|
||||||
{
|
{
|
||||||
OpenMissionControl();
|
OpenMissionControl();
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ using System.ComponentModel;
|
|||||||
using ClaudeDo.Data;
|
using ClaudeDo.Data;
|
||||||
using ClaudeDo.Data.Models;
|
using ClaudeDo.Data.Models;
|
||||||
using ClaudeDo.Data.Repositories;
|
using ClaudeDo.Data.Repositories;
|
||||||
|
using ClaudeDo.Ui.Localization;
|
||||||
using ClaudeDo.Ui.Services;
|
using ClaudeDo.Ui.Services;
|
||||||
using CommunityToolkit.Mvvm.ComponentModel;
|
using CommunityToolkit.Mvvm.ComponentModel;
|
||||||
using CommunityToolkit.Mvvm.Input;
|
using CommunityToolkit.Mvvm.Input;
|
||||||
@@ -28,12 +29,14 @@ public sealed partial class RepoImportItemViewModel : ViewModelBase
|
|||||||
public sealed partial class RepoImportModalViewModel : ViewModelBase
|
public sealed partial class RepoImportModalViewModel : ViewModelBase
|
||||||
{
|
{
|
||||||
private readonly IDbContextFactory<ClaudeDoDbContext> _dbFactory;
|
private readonly IDbContextFactory<ClaudeDoDbContext> _dbFactory;
|
||||||
|
private readonly IWorkerClient _workerClient;
|
||||||
private readonly HashSet<string> _existingDirs = new(StringComparer.OrdinalIgnoreCase);
|
private readonly HashSet<string> _existingDirs = new(StringComparer.OrdinalIgnoreCase);
|
||||||
private readonly List<string> _folders = new();
|
private readonly List<string> _folders = new();
|
||||||
|
|
||||||
public ObservableCollection<RepoImportItemViewModel> Repos { get; } = new();
|
public ObservableCollection<RepoImportItemViewModel> Repos { get; } = new();
|
||||||
|
|
||||||
public Action? CloseAction { get; set; }
|
public Action? CloseAction { get; set; }
|
||||||
|
public event Action<string>? ErrorReported;
|
||||||
|
|
||||||
[ObservableProperty] private string _searchText = "";
|
[ObservableProperty] private string _searchText = "";
|
||||||
|
|
||||||
@@ -42,9 +45,10 @@ public sealed partial class RepoImportModalViewModel : ViewModelBase
|
|||||||
public string CreateButtonText => $"Create {CreateCount} list(s)";
|
public string CreateButtonText => $"Create {CreateCount} list(s)";
|
||||||
public bool HasFolders => _folders.Count > 0;
|
public bool HasFolders => _folders.Count > 0;
|
||||||
|
|
||||||
public RepoImportModalViewModel(IDbContextFactory<ClaudeDoDbContext> dbFactory)
|
public RepoImportModalViewModel(IDbContextFactory<ClaudeDoDbContext> dbFactory, IWorkerClient workerClient)
|
||||||
{
|
{
|
||||||
_dbFactory = dbFactory;
|
_dbFactory = dbFactory;
|
||||||
|
_workerClient = workerClient;
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task LoadAsync(CancellationToken ct = default)
|
public async Task LoadAsync(CancellationToken ct = default)
|
||||||
@@ -61,9 +65,15 @@ public sealed partial class RepoImportModalViewModel : ViewModelBase
|
|||||||
_existingDirs.Add(l.WorkingDir!);
|
_existingDirs.Add(l.WorkingDir!);
|
||||||
}
|
}
|
||||||
|
|
||||||
var settings = new AppSettingsRepository(ctx);
|
try
|
||||||
foreach (var f in await settings.GetRepoImportFoldersAsync(ct))
|
{
|
||||||
|
foreach (var f in await _workerClient.GetRepoImportFoldersAsync())
|
||||||
AddFolderToSet(f);
|
AddFolderToSet(f);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrorReported?.Invoke(Loc.T("vm.repoImport.loadFailed", ex.Message));
|
||||||
|
}
|
||||||
|
|
||||||
ScanAndAdd(_folders);
|
ScanAndAdd(_folders);
|
||||||
OnPropertyChanged(nameof(HasFolders));
|
OnPropertyChanged(nameof(HasFolders));
|
||||||
@@ -155,8 +165,14 @@ public sealed partial class RepoImportModalViewModel : ViewModelBase
|
|||||||
|
|
||||||
private async Task SaveFoldersAsync()
|
private async Task SaveFoldersAsync()
|
||||||
{
|
{
|
||||||
await using var ctx = await _dbFactory.CreateDbContextAsync();
|
try
|
||||||
await new AppSettingsRepository(ctx).SetRepoImportFoldersAsync(_folders);
|
{
|
||||||
|
await _workerClient.SetRepoImportFoldersAsync(_folders);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrorReported?.Invoke(Loc.T("vm.repoImport.saveFailed", ex.Message));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void ClearRepos()
|
private void ClearRepos()
|
||||||
|
|||||||
@@ -424,6 +424,18 @@ public sealed class WorkerHub : Microsoft.AspNetCore.SignalR.Hub
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async Task<List<string>> GetRepoImportFolders()
|
||||||
|
{
|
||||||
|
using var ctx = _dbFactory.CreateDbContext();
|
||||||
|
return await new AppSettingsRepository(ctx).GetRepoImportFoldersAsync(Context.ConnectionAborted);
|
||||||
|
}
|
||||||
|
|
||||||
|
public async Task SetRepoImportFolders(List<string> folders)
|
||||||
|
{
|
||||||
|
using var ctx = _dbFactory.CreateDbContext();
|
||||||
|
await new AppSettingsRepository(ctx).SetRepoImportFoldersAsync(folders ?? new List<string>(), Context.ConnectionAborted);
|
||||||
|
}
|
||||||
|
|
||||||
public async Task<List<SessionSkillDto>> GetSessionSkills()
|
public async Task<List<SessionSkillDto>> GetSessionSkills()
|
||||||
{
|
{
|
||||||
var rows = await _skillRegistry.ListAsync(Context.ConnectionAborted);
|
var rows = await _skillRegistry.ListAsync(Context.ConnectionAborted);
|
||||||
|
|||||||
@@ -79,6 +79,8 @@ public abstract class StubWorkerClient : IWorkerClient
|
|||||||
public virtual Task RefreshAgentsAsync() => Task.CompletedTask;
|
public virtual Task RefreshAgentsAsync() => Task.CompletedTask;
|
||||||
public virtual Task<SeedResultDto?> RestoreDefaultAgentsAsync() => Task.FromResult<SeedResultDto?>(null);
|
public virtual Task<SeedResultDto?> RestoreDefaultAgentsAsync() => Task.FromResult<SeedResultDto?>(null);
|
||||||
public virtual Task<ListConfigDto?> GetListConfigAsync(string listId) => Task.FromResult<ListConfigDto?>(null);
|
public virtual Task<ListConfigDto?> GetListConfigAsync(string listId) => Task.FromResult<ListConfigDto?>(null);
|
||||||
|
public virtual Task<List<string>> GetRepoImportFoldersAsync() => Task.FromResult(new List<string>());
|
||||||
|
public virtual Task SetRepoImportFoldersAsync(List<string> folders) => Task.CompletedTask;
|
||||||
public virtual Task UpdateTaskAgentSettingsAsync(UpdateTaskAgentSettingsDto dto) => Task.CompletedTask;
|
public virtual Task UpdateTaskAgentSettingsAsync(UpdateTaskAgentSettingsDto dto) => Task.CompletedTask;
|
||||||
public virtual Task<List<SessionSkillDto>> GetSessionSkillsAsync() => Task.FromResult(new List<SessionSkillDto>());
|
public virtual Task<List<SessionSkillDto>> GetSessionSkillsAsync() => Task.FromResult(new List<SessionSkillDto>());
|
||||||
public virtual Task<List<string>> InstallSessionSkillAsync(string url) => Task.FromResult(new List<string>());
|
public virtual Task<List<string>> InstallSessionSkillAsync(string url) => Task.FromResult(new List<string>());
|
||||||
|
|||||||
@@ -0,0 +1,114 @@
|
|||||||
|
using ClaudeDo.Data;
|
||||||
|
using ClaudeDo.Ui.ViewModels.Modals;
|
||||||
|
using Microsoft.EntityFrameworkCore;
|
||||||
|
|
||||||
|
namespace ClaudeDo.Ui.Tests.ViewModels;
|
||||||
|
|
||||||
|
public sealed class RepoImportModalViewModelTests : IDisposable
|
||||||
|
{
|
||||||
|
private readonly string _dbPath;
|
||||||
|
|
||||||
|
public RepoImportModalViewModelTests()
|
||||||
|
{
|
||||||
|
_dbPath = Path.Combine(Path.GetTempPath(), $"claudedo_repoimport_{Guid.NewGuid():N}.db");
|
||||||
|
using var ctx = NewContext();
|
||||||
|
ctx.Database.EnsureCreated();
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Dispose()
|
||||||
|
{
|
||||||
|
try { File.Delete(_dbPath); } catch { }
|
||||||
|
try { File.Delete(_dbPath + "-wal"); } catch { }
|
||||||
|
try { File.Delete(_dbPath + "-shm"); } catch { }
|
||||||
|
}
|
||||||
|
|
||||||
|
private ClaudeDoDbContext NewContext()
|
||||||
|
{
|
||||||
|
var opts = new DbContextOptionsBuilder<ClaudeDoDbContext>()
|
||||||
|
.UseSqlite($"Data Source={_dbPath}")
|
||||||
|
.Options;
|
||||||
|
return new ClaudeDoDbContext(opts);
|
||||||
|
}
|
||||||
|
|
||||||
|
private sealed class TestDbFactory : IDbContextFactory<ClaudeDoDbContext>
|
||||||
|
{
|
||||||
|
private readonly Func<ClaudeDoDbContext> _create;
|
||||||
|
public TestDbFactory(Func<ClaudeDoDbContext> create) => _create = create;
|
||||||
|
public ClaudeDoDbContext CreateDbContext() => _create();
|
||||||
|
}
|
||||||
|
|
||||||
|
private sealed class FakeWorkerClient : StubWorkerClient
|
||||||
|
{
|
||||||
|
public List<string> Folders = new();
|
||||||
|
public Exception? ThrowOnGet;
|
||||||
|
public Exception? ThrowOnSet;
|
||||||
|
public List<string>? LastSaved;
|
||||||
|
|
||||||
|
public override Task<List<string>> GetRepoImportFoldersAsync()
|
||||||
|
=> ThrowOnGet is not null ? throw ThrowOnGet : Task.FromResult(Folders);
|
||||||
|
|
||||||
|
public override Task SetRepoImportFoldersAsync(List<string> folders)
|
||||||
|
{
|
||||||
|
LastSaved = folders;
|
||||||
|
if (ThrowOnSet is not null) throw ThrowOnSet;
|
||||||
|
return Task.CompletedTask;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task LoadAsync_Success_PopulatesFoldersWithoutReportingError()
|
||||||
|
{
|
||||||
|
var worker = new FakeWorkerClient { Folders = new List<string> { @"C:\src" } };
|
||||||
|
var vm = new RepoImportModalViewModel(new TestDbFactory(NewContext), worker);
|
||||||
|
string? reportedError = null;
|
||||||
|
vm.ErrorReported += msg => reportedError = msg;
|
||||||
|
|
||||||
|
await vm.LoadAsync();
|
||||||
|
|
||||||
|
Assert.True(vm.HasFolders);
|
||||||
|
Assert.Null(reportedError);
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task LoadAsync_HubFailure_ReportsErrorInsteadOfSilentEmptyList()
|
||||||
|
{
|
||||||
|
var worker = new FakeWorkerClient { ThrowOnGet = new InvalidOperationException("worker offline") };
|
||||||
|
var vm = new RepoImportModalViewModel(new TestDbFactory(NewContext), worker);
|
||||||
|
string? reportedError = null;
|
||||||
|
vm.ErrorReported += msg => reportedError = msg;
|
||||||
|
|
||||||
|
await vm.LoadAsync();
|
||||||
|
|
||||||
|
Assert.False(vm.HasFolders);
|
||||||
|
Assert.NotNull(reportedError);
|
||||||
|
Assert.Contains("worker offline", reportedError);
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task AddFoldersAsync_SavesThroughWorkerClient()
|
||||||
|
{
|
||||||
|
var worker = new FakeWorkerClient();
|
||||||
|
var vm = new RepoImportModalViewModel(new TestDbFactory(NewContext), worker);
|
||||||
|
await vm.LoadAsync();
|
||||||
|
|
||||||
|
await vm.AddFoldersAsync(new[] { @"C:\src\new-folder" });
|
||||||
|
|
||||||
|
Assert.NotNull(worker.LastSaved);
|
||||||
|
Assert.Contains(@"C:\src\new-folder", worker.LastSaved!);
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task AddFoldersAsync_SaveFailure_ReportsError()
|
||||||
|
{
|
||||||
|
var worker = new FakeWorkerClient { ThrowOnSet = new InvalidOperationException("write failed") };
|
||||||
|
var vm = new RepoImportModalViewModel(new TestDbFactory(NewContext), worker);
|
||||||
|
await vm.LoadAsync();
|
||||||
|
string? reportedError = null;
|
||||||
|
vm.ErrorReported += msg => reportedError = msg;
|
||||||
|
|
||||||
|
await vm.AddFoldersAsync(new[] { @"C:\src\new-folder" });
|
||||||
|
|
||||||
|
Assert.NotNull(reportedError);
|
||||||
|
Assert.Contains("write failed", reportedError);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,73 @@
|
|||||||
|
using ClaudeDo.Data.Models;
|
||||||
|
using ClaudeDo.Data.Repositories;
|
||||||
|
using ClaudeDo.Worker.Hub;
|
||||||
|
using ClaudeDo.Worker.Tests.Infrastructure;
|
||||||
|
using Xunit;
|
||||||
|
|
||||||
|
namespace ClaudeDo.Worker.Tests.Hub;
|
||||||
|
|
||||||
|
public sealed class RepoImportFoldersHubTests : IDisposable
|
||||||
|
{
|
||||||
|
private readonly DbFixture _db = new();
|
||||||
|
|
||||||
|
public void Dispose() => _db.Dispose();
|
||||||
|
|
||||||
|
private WorkerHub CreateHub()
|
||||||
|
{
|
||||||
|
var broadcaster = new HubBroadcaster(new CapturingHubContext());
|
||||||
|
var hub = new WorkerHub(
|
||||||
|
null!, null!, null!, null!, broadcaster, _db.CreateFactory(),
|
||||||
|
null!, null!, null!, null!, null!, null!, null!, null!, null!, null!, null!, null!, null!,
|
||||||
|
null!, new ClaudeDo.Worker.Online.OnlineInboxConfig(), new ClaudeDo.Worker.Online.OnlineTokenStore(),
|
||||||
|
new ClaudeDo.Worker.Runner.PendingQuestionRegistry(), null!);
|
||||||
|
hub.Clients = new FakeHubCallerClients(new RecordingClientProxy());
|
||||||
|
hub.Context = new FakeHubCallerContext();
|
||||||
|
return hub;
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task GetRepoImportFolders_NoRow_ReturnsEmptyList()
|
||||||
|
{
|
||||||
|
var hub = CreateHub();
|
||||||
|
|
||||||
|
var folders = await hub.GetRepoImportFolders();
|
||||||
|
|
||||||
|
Assert.Empty(folders);
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task SetRepoImportFolders_then_GetRepoImportFolders_RoundTrips()
|
||||||
|
{
|
||||||
|
var hub = CreateHub();
|
||||||
|
|
||||||
|
await hub.SetRepoImportFolders(new List<string> { @"C:\src\repo-a", @"C:\src\repo-b" });
|
||||||
|
var folders = await hub.GetRepoImportFolders();
|
||||||
|
|
||||||
|
Assert.Equal(new List<string> { @"C:\src\repo-a", @"C:\src\repo-b" }, folders);
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task SetRepoImportFolders_PersistsSameJsonShapeAsRepository()
|
||||||
|
{
|
||||||
|
var hub = CreateHub();
|
||||||
|
|
||||||
|
await hub.SetRepoImportFolders(new List<string> { @"C:\src\repo-a" });
|
||||||
|
|
||||||
|
using var ctx = _db.CreateContext();
|
||||||
|
var viaRepository = await new AppSettingsRepository(ctx).GetRepoImportFoldersAsync();
|
||||||
|
Assert.Equal(new List<string> { @"C:\src\repo-a" }, viaRepository);
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task SetRepoImportFolders_DoesNotClearOtherAppSettings()
|
||||||
|
{
|
||||||
|
var hub = CreateHub();
|
||||||
|
var before = await hub.GetAppSettings();
|
||||||
|
|
||||||
|
await hub.SetRepoImportFolders(new List<string> { @"C:\src\repo-a" });
|
||||||
|
var after = await hub.GetAppSettings();
|
||||||
|
|
||||||
|
Assert.Equal(before.DefaultModel, after.DefaultModel);
|
||||||
|
Assert.Equal(before.DefaultMaxTurns, after.DefaultMaxTurns);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -51,6 +51,8 @@ sealed class FakeWorkerClient : IWorkerClient
|
|||||||
public Task RefreshAgentsAsync() => Task.CompletedTask;
|
public Task RefreshAgentsAsync() => Task.CompletedTask;
|
||||||
public Task<SeedResultDto?> RestoreDefaultAgentsAsync() => Task.FromResult<SeedResultDto?>(null);
|
public Task<SeedResultDto?> RestoreDefaultAgentsAsync() => Task.FromResult<SeedResultDto?>(null);
|
||||||
public Task<ListConfigDto?> GetListConfigAsync(string listId) => Task.FromResult<ListConfigDto?>(null);
|
public Task<ListConfigDto?> GetListConfigAsync(string listId) => Task.FromResult<ListConfigDto?>(null);
|
||||||
|
public Task<List<string>> GetRepoImportFoldersAsync() => Task.FromResult(new List<string>());
|
||||||
|
public Task SetRepoImportFoldersAsync(List<string> folders) => Task.CompletedTask;
|
||||||
public Task UpdateTaskAgentSettingsAsync(UpdateTaskAgentSettingsDto dto) => Task.CompletedTask;
|
public Task UpdateTaskAgentSettingsAsync(UpdateTaskAgentSettingsDto dto) => Task.CompletedTask;
|
||||||
public Task<List<SessionSkillDto>> GetSessionSkillsAsync() => Task.FromResult(new List<SessionSkillDto>());
|
public Task<List<SessionSkillDto>> GetSessionSkillsAsync() => Task.FromResult(new List<SessionSkillDto>());
|
||||||
public Task<List<string>> InstallSessionSkillAsync(string url) => Task.FromResult(new List<string>());
|
public Task<List<string>> InstallSessionSkillAsync(string url) => Task.FromResult(new List<string>());
|
||||||
|
|||||||
Reference in New Issue
Block a user