diff --git a/LANCommander.Server.Services/Abstractions/IMediaGrabberService.cs b/LANCommander.Server.Services/Abstractions/IMediaGrabberService.cs index 7bc992a8..83a098f3 100644 --- a/LANCommander.Server.Services/Abstractions/IMediaGrabberService.cs +++ b/LANCommander.Server.Services/Abstractions/IMediaGrabberService.cs @@ -14,11 +14,18 @@ namespace LANCommander.Server.Services.Abstractions Task DownloadAsync(MediaGrabberResult result, IProgress? progress) => DownloadAsync(result); + IEnumerable GetGrabberNames() => [Name]; + async IAsyncEnumerable> SearchStreamAsync( MediaType type, string keywords, [EnumeratorCancellation] CancellationToken cancellationToken = default) { yield return await SearchAsync(type, keywords); } + + IAsyncEnumerable> SearchStreamAsync( + MediaType type, string keywords, string? grabberName, + [EnumeratorCancellation] CancellationToken cancellationToken = default) + => SearchStreamAsync(type, keywords, cancellationToken); } } diff --git a/LANCommander.Server.Services/MediaGrabbers/CompositeMediaGrabberService.cs b/LANCommander.Server.Services/MediaGrabbers/CompositeMediaGrabberService.cs index e45ac7c7..6245e0b5 100644 --- a/LANCommander.Server.Services/MediaGrabbers/CompositeMediaGrabberService.cs +++ b/LANCommander.Server.Services/MediaGrabbers/CompositeMediaGrabberService.cs @@ -32,12 +32,25 @@ namespace LANCommander.Server.Services.MediaGrabbers return results; } + public IEnumerable GetGrabberNames() => _grabbers.Select(g => g.Name); + public async IAsyncEnumerable> SearchStreamAsync( MediaType type, string keywords, [EnumeratorCancellation] CancellationToken cancellationToken = default) + { + await foreach (var batch in SearchStreamAsync(type, keywords, null, cancellationToken)) + yield return batch; + } + + public async IAsyncEnumerable> SearchStreamAsync( + MediaType type, string keywords, string? grabberName, + [EnumeratorCancellation] CancellationToken cancellationToken = default) { var applicable = _grabbers.Where(g => g.SupportedMediaTypes.Contains(type)).ToList(); + if (!string.IsNullOrEmpty(grabberName)) + applicable = applicable.Where(g => g.Name == grabberName).ToList(); + if (applicable.Count == 0) yield break; diff --git a/LANCommander.Server.Services/MetadataService.cs b/LANCommander.Server.Services/MetadataService.cs index e8d961ca..7ea09c19 100644 --- a/LANCommander.Server.Services/MetadataService.cs +++ b/LANCommander.Server.Services/MetadataService.cs @@ -9,7 +9,7 @@ public class MetadataService(IServiceProvider serviceProvider) { var providers = serviceProvider.GetServices(); - return providers.Select(p => p.ProviderName); + return providers.Where(p => p.IsAvailable).Select(p => p.ProviderName); } public IMetadataProvider? GetProvider(string providerName) diff --git a/LANCommander.Server.Services/Providers/Metadata/HqMetadataProvider.cs b/LANCommander.Server.Services/Providers/Metadata/HqMetadataProvider.cs index b5551f26..87f28de8 100644 --- a/LANCommander.Server.Services/Providers/Metadata/HqMetadataProvider.cs +++ b/LANCommander.Server.Services/Providers/Metadata/HqMetadataProvider.cs @@ -14,6 +14,7 @@ public class HqMetadataProvider( private IReadOnlyList? _cachedProviders; public string ProviderName => "LANCommander HQ"; + public bool IsAvailable => settingsProvider.CurrentValue.Server.HQ.IsAuthenticated; public async Task?> GetSubProvidersAsync() { diff --git a/LANCommander.Server.Services/Providers/Metadata/IMetadataProvider.cs b/LANCommander.Server.Services/Providers/Metadata/IMetadataProvider.cs index 63870d4a..2dfd56d7 100644 --- a/LANCommander.Server.Services/Providers/Metadata/IMetadataProvider.cs +++ b/LANCommander.Server.Services/Providers/Metadata/IMetadataProvider.cs @@ -5,6 +5,7 @@ namespace LANCommander.Server.Services.Providers.Metadata; public interface IMetadataProvider { public string ProviderName { get; } + bool IsAvailable => true; public Task?> SearchGamesAsync(string input, int limit = 10, int offset = 0); public Task GetGameAsync(string gameId); diff --git a/LANCommander.Server.Services/Providers/Metadata/IgdbMetadataProvider.cs b/LANCommander.Server.Services/Providers/Metadata/IgdbMetadataProvider.cs index dccd2363..5b182a71 100644 --- a/LANCommander.Server.Services/Providers/Metadata/IgdbMetadataProvider.cs +++ b/LANCommander.Server.Services/Providers/Metadata/IgdbMetadataProvider.cs @@ -25,6 +25,8 @@ public class IgdbMetadataProvider( } public string ProviderName => "IGDB"; + public bool IsAvailable => !string.IsNullOrWhiteSpace(settingsProvider.CurrentValue.Server.IGDB.ClientId) + && !string.IsNullOrWhiteSpace(settingsProvider.CurrentValue.Server.IGDB.ClientSecret); public async Task?> SearchGamesAsync(string input, int limit = 10, int offset = 0) { diff --git a/LANCommander.Server.Settings/Models/MediaSettings.cs b/LANCommander.Server.Settings/Models/MediaSettings.cs index 636f1c4b..4b12bcf1 100644 --- a/LANCommander.Server.Settings/Models/MediaSettings.cs +++ b/LANCommander.Server.Settings/Models/MediaSettings.cs @@ -6,6 +6,7 @@ namespace LANCommander.Server.Settings.Models; public class MediaSettings { public string SteamGridDbApiKey { get; set; } = String.Empty; + public bool AutoDownloadMedia { get; set; } = false; public IEnumerable MediaTypes { get; set; } = [ diff --git a/LANCommander.Server/Models/AddGameDialogOptions.cs b/LANCommander.Server/Models/AddGameDialogOptions.cs new file mode 100644 index 00000000..c290b046 --- /dev/null +++ b/LANCommander.Server/Models/AddGameDialogOptions.cs @@ -0,0 +1,4 @@ +namespace LANCommander.Server.Models +{ + public class AddGameDialogOptions { } +} diff --git a/LANCommander.Server/UI/Pages/Games/Components/AddGameDialog.razor b/LANCommander.Server/UI/Pages/Games/Components/AddGameDialog.razor new file mode 100644 index 00000000..6a1cdb6f --- /dev/null +++ b/LANCommander.Server/UI/Pages/Games/Components/AddGameDialog.razor @@ -0,0 +1,102 @@ +@using LANCommander.Server.Services.Abstractions +@using LANCommander.Server.Services.Models +@using LANCommander.Server.Settings +@inherits FeedbackComponent +@inject IMediaGrabberService MediaGrabberService +@inject MediaService MediaService +@inject GameService GameService +@inject SettingsProvider SettingsProvider +@inject NavigationManager NavigationManager +@inject ILogger Logger + + + Automatically download art + + +@code { + MetadataLookupPanel _panel; + bool _autoDownloadMedia; + + static readonly MediaType[] AutoDownloadTypes = + [ + MediaType.Icon, + MediaType.Cover, + MediaType.Background, + MediaType.Logo, + MediaType.Grid + ]; + + protected override void OnInitialized() + { + _autoDownloadMedia = SettingsProvider.CurrentValue.Server.Media.AutoDownloadMedia; + } + + private void OnAutoDownloadMediaChanged(bool value) + { + _autoDownloadMedia = value; + SettingsProvider.Update(s => s.Server.Media.AutoDownloadMedia = value); + } + + private async Task OnGameImported(Guid gameId) + { + if (_autoDownloadMedia) + { + await DownloadMediaForGame(gameId); + } + + await CloseFeedbackAsync(); + NavigationManager.NavigateTo($"/Games/{gameId}"); + } + + private async Task DownloadMediaForGame(Guid gameId) + { + try + { + var game = await GameService.GetAsync(gameId); + + if (game == null) + return; + + foreach (var mediaType in AutoDownloadTypes) + { + try + { + await _panel.UpdateStatusAsync($"Downloading {mediaType}..."); + + var results = await MediaGrabberService.SearchAsync(mediaType, game.Title); + var result = results.FirstOrDefault(); + + if (result == null) + continue; + + using var download = await MediaGrabberService.DownloadAsync(result); + + var media = new Media + { + GameId = gameId, + Type = mediaType, + SourceUrl = result.SourceUrl, + MimeType = download.MimeType, + StorageLocation = await MediaService.GetDefaultStorageLocationAsync(), + Crc32 = string.Empty + }; + + await MediaService.WriteToFileAsync(media, download.Stream); + } + catch (Exception ex) + { + Logger.LogError(ex, "Failed to auto-download {MediaType} for game {GameId}", mediaType, gameId); + } + } + } + catch (Exception ex) + { + Logger.LogError(ex, "Failed to auto-download media for game {GameId}", gameId); + } + } +} diff --git a/LANCommander.Server/UI/Pages/Games/Components/GameMetadataLookup.razor b/LANCommander.Server/UI/Pages/Games/Components/GameMetadataLookup.razor index d75fb8b7..201ea7b7 100644 --- a/LANCommander.Server/UI/Pages/Games/Components/GameMetadataLookup.razor +++ b/LANCommander.Server/UI/Pages/Games/Components/GameMetadataLookup.razor @@ -1,488 +1,54 @@ -@using AntDesign.TableModels -@using LANCommander.Server.ImportExport.Factories -@using LANCommander.Server.Services.Providers.Metadata @inject MetadataService MetadataService -@inject GameService GameService -@inject ImportContextFactory ImportContextFactory -@inject IMessageService MessageService -@inject ILogger Logger -@{ - RenderFragment SearchFooter = - @; - - RenderFragment MergeFooter = - @; -} - - - @if (_stage == ModalStage.Search) - { - @if (_errorMessage != null) - { - - - - - - } - else - { - - - - - - - @string.Join(", ", context.Data.Developers?.Select(d => d.Name) ?? []) - -
- - @if (_results?.More ?? false) - { - - } - } - } - else if (_stage == ModalStage.Merge) - { - @if (_errorMessage != null) - { - - - - - - } - else - { -
-
-
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
ImportFieldValue
Title@_fetchedManifest?.Title
Description@_fetchedManifest?.Description
Released On@(_fetchedManifest?.ReleasedOn.ToString("MM/dd/yyyy"))
Singleplayer@(_fetchedManifest?.Singleplayer == true ? "Yes" : "No")
Engine@(_fetchedManifest?.Engine?.Name ?? "—")
Developers - @foreach (var item in _fetchedManifest?.Developers ?? []) - { - @item.Name - } -
Publishers - @foreach (var item in _fetchedManifest?.Publishers ?? []) - { - @item.Name - } -
Genres - @foreach (var item in _fetchedManifest?.Genres ?? []) - { - @item.Name - } -
Tags - @foreach (var item in _fetchedManifest?.Tags ?? []) - { - @item.Name - } -
Multiplayer Modes@(_fetchedManifest?.MultiplayerModes?.Count ?? 0) mode(s)
Save Paths@(_fetchedManifest?.SavePaths?.Count ?? 0) path(s)
External IDs - @foreach (var item in _fetchedManifest?.ExternalIds ?? []) - { - @item.Provider: @item.ExternalId - } -
-
-
-
- } - } + + - + @code { - private enum ModalStage { Search, Merge } - [Parameter] public Guid GameId { get; set; } [Parameter] public EventCallback OnImported { get; set; } - [Parameter] public string ButtonText { get; set; } + [Parameter] public string ButtonText { get; set; } = "Lookup"; [Parameter] public bool AutoFocus { get; set; } [Parameter] public string Value { get; set; } [Parameter] public EventCallback ValueChanged { get; set; } - ITable? ResultsTable; + bool _modalVisible; + bool _hasProviders; - MetadataSearchResultsCollection? _results; - - IEnumerable> SelectedResults { get; set; } - bool _modalVisible { get; set; } = false; - bool _loading = false; - int _limit = 10; - int _offset = 0; - - string _selectedProvider = string.Empty; - IEnumerable _availableProviders = []; - - string? _selectedSubProvider; - IEnumerable<(string Slug, string Name)>? _availableSubProviders; - - ModalStage _stage = ModalStage.Search; - string? _errorMessage = null; - LANCommander.SDK.Models.Manifest.Game? _fetchedManifest = null; - - // Scalar field merge options - bool _importTitle = true; - bool _importDescription = true; - bool _importReleasedOn = true; - bool _importSingleplayer = true; - bool _importEngine = true; - - // Collection merge options - bool _importDevelopers = true; - bool _importPublishers = true; - bool _importGenres = true; - bool _importTags = true; - bool _importMultiplayerModes = true; - bool _importSavePaths = true; - bool _importExternalIds = true; - - protected override async Task OnInitializedAsync() + protected override void OnInitialized() { - _availableProviders = MetadataService.GetProviderNames(); - _selectedProvider = _availableProviders.FirstOrDefault() ?? string.Empty; - await UpdateSubProvidersAsync(); - } - - private async Task OnProviderChanged(string provider) - { - _selectedProvider = provider; - _errorMessage = null; - await UpdateSubProvidersAsync(); - - if (!string.IsNullOrWhiteSpace(Value)) - await SearchForGame(Value); - } - - private async Task OnSubProviderChanged(string subProvider) - { - _selectedSubProvider = subProvider; - _errorMessage = null; - - if (!string.IsNullOrWhiteSpace(Value)) - await SearchForGame(Value); - } - - private async Task UpdateSubProvidersAsync() - { - var provider = MetadataService.GetProvider(_selectedProvider); - - if (provider is not null) - { - _availableSubProviders = await provider.GetSubProvidersAsync(); - _selectedSubProvider = _availableSubProviders?.FirstOrDefault().Slug; - } - else - { - _availableSubProviders = null; - _selectedSubProvider = null; - } - } - - private void OnRowClicked(RowData> row) - { - ResultsTable?.SetSelection([row.Data.Id]); + _hasProviders = MetadataService.GetProviderNames().Any(); } private async Task SearchFieldOnKeyDown(KeyboardEventArgs e) { if ((e.Code == "Enter" || e.Code == "NumpadEnter") && !String.IsNullOrWhiteSpace(Value)) - await SearchForGame(Value); + OpenLookup(); } - private async Task SearchForGame(string title, bool newSearch = true) + private void OpenLookup() { - var provider = MetadataService.GetProvider(_selectedProvider); - - if (provider is null) - { - MessageService.Error($"Provider \"{_selectedProvider}\" is not available"); - return; - } - - try - { - _loading = true; - _modalVisible = true; - _errorMessage = null; - - if (newSearch) - { - _results = null; - _offset = 0; - } - - _results = _availableSubProviders?.Any() == true - ? await provider.SearchGamesAsync(title, _selectedSubProvider, _limit, _offset) - : await provider.SearchGamesAsync(title, _limit, _offset); - - _loading = false; - } - catch (Exception ex) - { - Logger.LogError(ex, "An error occurred searching {Provider}", _selectedProvider); - - _loading = false; - _errorMessage = ex.Message; - } - } - - private async Task BeginMerge() - { - var provider = MetadataService.GetProvider(_selectedProvider); - - if (provider is null) - return; - - _loading = true; - _errorMessage = null; - - try - { - var selected = SelectedResults.First(); - - var manifest = await provider.GetGameAsync(selected.Id); - - if (manifest is null) - { - _errorMessage = "Could not retrieve game metadata from the provider."; - _loading = false; - return; - } - - _fetchedManifest = manifest; - - // Default collection toggles to false if the manifest has no data for them - _importTitle = true; - _importDescription = !string.IsNullOrWhiteSpace(manifest.Description); - _importReleasedOn = manifest.ReleasedOn != default; - _importSingleplayer = true; - _importEngine = manifest.Engine != null; - _importDevelopers = manifest.Developers?.Any() == true; - _importPublishers = manifest.Publishers?.Any() == true; - _importGenres = manifest.Genres?.Any() == true; - _importTags = manifest.Tags?.Any() == true; - _importMultiplayerModes = manifest.MultiplayerModes?.Any() == true; - _importSavePaths = manifest.SavePaths?.Any() == true; - _importExternalIds = manifest.ExternalIds?.Any() == true; - - _stage = ModalStage.Merge; - } - catch (Exception ex) - { - Logger.LogError(ex, "An error occurred fetching metadata from {Provider}", _selectedProvider); - _errorMessage = ex.Message; - } - finally - { - _loading = false; - } - } - - private async Task ImportWithMerge() - { - if (_fetchedManifest is null) - return; - - _loading = true; - _errorMessage = null; - - try - { - // Load existing game data so we can restore unchecked scalar fields - LANCommander.Server.Data.Models.Game? existing = null; - - if (GameId != Guid.Empty) - existing = await GameService.GetAsync(GameId); - - var manifest = _fetchedManifest; - manifest.Id = GameId == Guid.Empty ? Guid.NewGuid() : GameId; - - // Restore scalar fields the user opted out of - if (!_importTitle && existing != null) - manifest.Title = existing.Title; - - if (!_importDescription && existing != null) - manifest.Description = existing.Description; - - if (!_importReleasedOn && existing != null) - manifest.ReleasedOn = existing.ReleasedOn ?? default; - - if (!_importSingleplayer && existing != null) - manifest.Singleplayer = existing.Singleplayer; - - if (!_importEngine) - manifest.Engine = null; - - // Clear collections the user opted out of so importers skip them - if (!_importDevelopers) - manifest.Developers = new List(); - - if (!_importPublishers) - manifest.Publishers = new List(); - - if (!_importGenres) - manifest.Genres = new List(); - - if (!_importTags) - manifest.Tags = new List(); - - if (!_importMultiplayerModes) - manifest.MultiplayerModes = new List(); - - if (!_importSavePaths) - manifest.SavePaths = new List(); - - if (!_importExternalIds) - manifest.ExternalIds = new List(); - - using var context = ImportContextFactory.Create(); - await context.InitializeMetadataUpdateAsync(manifest); - await context.ImportQueueAsync(); - - Close(); - - await OnImported.InvokeAsync(manifest.Id); - } - catch (Exception ex) - { - Logger.LogError(ex, "An error occurred importing metadata from {Provider}", _selectedProvider); - _errorMessage = ex.Message; - _loading = false; - } - } - - private void BackToSearch() - { - _stage = ModalStage.Search; - _errorMessage = null; - _fetchedManifest = null; - SelectedResults = []; - } - - private void DismissError() - { - _errorMessage = null; + _modalVisible = true; } private void Close() { - _results = null; - _limit = 10; - _offset = 0; _modalVisible = false; - _stage = ModalStage.Search; - _errorMessage = null; - _fetchedManifest = null; } - private async Task ShowMore() + private async Task OnPanelImported(Guid gameId) { - _offset += _results?.Limit ?? _limit; - - await SearchForGame(Value, false); + _modalVisible = false; + await OnImported.InvokeAsync(gameId); } } diff --git a/LANCommander.Server/UI/Pages/Games/Components/MetadataLookupPanel.razor b/LANCommander.Server/UI/Pages/Games/Components/MetadataLookupPanel.razor new file mode 100644 index 00000000..340108eb --- /dev/null +++ b/LANCommander.Server/UI/Pages/Games/Components/MetadataLookupPanel.razor @@ -0,0 +1,508 @@ +@using AntDesign.TableModels +@using LANCommander.Server.ImportExport.Factories +@using LANCommander.Server.Services.Providers.Metadata +@inject MetadataService MetadataService +@inject GameService GameService +@inject ImportContextFactory ImportContextFactory +@inject IMessageService MessageService +@inject ILogger Logger + + + + + + + + +@if (_stage == ModalStage.Search) +{ + @if (_errorMessage != null) + { + + + + + + } + else if (_hasSearched) + { + + + + + + + @string.Join(", ", context.Data.Developers?.Select(d => d.Name) ?? []) + +
+ + @if (_results?.More ?? false) + { + + } + } + + + + @foreach (var sp in _availableSubProviders) + { + + } + + } + @if (ShowCancel) + { + + } + + + @ChildContent +} +else if (_stage == ModalStage.Merge) +{ + @if (_errorMessage != null) + { + + + + + + } + else + { +
+
+
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
ImportFieldValue
Title@_fetchedManifest?.Title
Description@_fetchedManifest?.Description
Released On@(_fetchedManifest?.ReleasedOn.ToString("MM/dd/yyyy"))
Singleplayer@(_fetchedManifest?.Singleplayer == true ? "Yes" : "No")
Engine@(_fetchedManifest?.Engine?.Name ?? "—")
Developers + @foreach (var item in _fetchedManifest?.Developers ?? []) + { + @item.Name + } +
Publishers + @foreach (var item in _fetchedManifest?.Publishers ?? []) + { + @item.Name + } +
Genres + @foreach (var item in _fetchedManifest?.Genres ?? []) + { + @item.Name + } +
Tags + @foreach (var item in _fetchedManifest?.Tags ?? []) + { + @item.Name + } +
Multiplayer Modes@(_fetchedManifest?.MultiplayerModes?.Count ?? 0) mode(s)
Save Paths@(_fetchedManifest?.SavePaths?.Count ?? 0) path(s)
External IDs + @foreach (var item in _fetchedManifest?.ExternalIds ?? []) + { + @item.Provider: @item.ExternalId + } +
+
+
+
+ } + + + + + @if (ShowCancel) + { + + } + +} + + + +@code { + private enum ModalStage { Search, Merge } + + [Parameter] public Guid GameId { get; set; } + [Parameter] public EventCallback OnImported { get; set; } + [Parameter] public EventCallback OnCancel { get; set; } + [Parameter] public bool AutoFocus { get; set; } + [Parameter] public bool ShowCancel { get; set; } = true; + [Parameter] public string Search { get; set; } = string.Empty; + [Parameter] public EventCallback SearchChanged { get; set; } + [Parameter] public RenderFragment ChildContent { get; set; } + + ITable? ResultsTable; + + MetadataSearchResultsCollection? _results; + + IEnumerable> SelectedResults { get; set; } + bool _loading = false; + bool _hasSearched = false; + int _limit = 10; + int _offset = 0; + + string _selectedProvider = string.Empty; + IEnumerable _availableProviders = []; + + string? _selectedSubProvider; + IEnumerable<(string Slug, string Name)>? _availableSubProviders; + + ModalStage _stage = ModalStage.Search; + string? _errorMessage = null; + LANCommander.SDK.Models.Manifest.Game? _fetchedManifest = null; + + bool _importing = false; + string _importStatus = "Importing..."; + + bool _importTitle = true; + bool _importDescription = true; + bool _importReleasedOn = true; + bool _importSingleplayer = true; + bool _importEngine = true; + bool _importDevelopers = true; + bool _importPublishers = true; + bool _importGenres = true; + bool _importTags = true; + bool _importMultiplayerModes = true; + bool _importSavePaths = true; + bool _importExternalIds = true; + + protected override async Task OnInitializedAsync() + { + _availableProviders = MetadataService.GetProviderNames(); + _selectedProvider = _availableProviders.FirstOrDefault() ?? string.Empty; + await UpdateSubProvidersAsync(); + } + + private async Task OnProviderChanged(string provider) + { + _selectedProvider = provider; + _errorMessage = null; + await UpdateSubProvidersAsync(); + + if (!string.IsNullOrWhiteSpace(Search)) + await SearchForGame(Search); + } + + private async Task OnSubProviderChanged(string subProvider) + { + _selectedSubProvider = subProvider; + _errorMessage = null; + + if (!string.IsNullOrWhiteSpace(Search)) + await SearchForGame(Search); + } + + private async Task UpdateSubProvidersAsync() + { + var provider = MetadataService.GetProvider(_selectedProvider); + + if (provider is not null) + { + _availableSubProviders = await provider.GetSubProvidersAsync(); + _selectedSubProvider = _availableSubProviders?.FirstOrDefault().Slug; + } + else + { + _availableSubProviders = null; + _selectedSubProvider = null; + } + } + + private async Task OnRowClicked(RowData> row) + { + ResultsTable?.SetSelection([row.Data.Id]); + await BeginMerge(); + } + + private async Task SearchFieldOnKeyDown(KeyboardEventArgs e) + { + if ((e.Code == "Enter" || e.Code == "NumpadEnter") && !String.IsNullOrWhiteSpace(Search)) + await SearchForGame(Search); + } + + private async Task SearchForGame(string title, bool newSearch = true) + { + var provider = MetadataService.GetProvider(_selectedProvider); + + if (provider is null) + { + MessageService.Error($"Provider \"{_selectedProvider}\" is not available"); + return; + } + + try + { + _loading = true; + _hasSearched = true; + _errorMessage = null; + + if (newSearch) + { + _results = null; + _offset = 0; + } + + _results = _availableSubProviders?.Any() == true + ? await provider.SearchGamesAsync(title, _selectedSubProvider, _limit, _offset) + : await provider.SearchGamesAsync(title, _limit, _offset); + + _loading = false; + } + catch (Exception ex) + { + Logger.LogError(ex, "An error occurred searching {Provider}", _selectedProvider); + + _loading = false; + _errorMessage = ex.Message; + } + } + + private async Task BeginMerge() + { + var provider = MetadataService.GetProvider(_selectedProvider); + + if (provider is null) + return; + + _loading = true; + _errorMessage = null; + + try + { + var selected = SelectedResults.First(); + + var manifest = await provider.GetGameAsync(selected.Id); + + if (manifest is null) + { + _errorMessage = "Could not retrieve game metadata from the provider."; + _loading = false; + return; + } + + _fetchedManifest = manifest; + + _importTitle = true; + _importDescription = !string.IsNullOrWhiteSpace(manifest.Description); + _importReleasedOn = manifest.ReleasedOn != default; + _importSingleplayer = true; + _importEngine = manifest.Engine != null; + _importDevelopers = manifest.Developers?.Any() == true; + _importPublishers = manifest.Publishers?.Any() == true; + _importGenres = manifest.Genres?.Any() == true; + _importTags = manifest.Tags?.Any() == true; + _importMultiplayerModes = manifest.MultiplayerModes?.Any() == true; + _importSavePaths = manifest.SavePaths?.Any() == true; + _importExternalIds = manifest.ExternalIds?.Any() == true; + + _stage = ModalStage.Merge; + } + catch (Exception ex) + { + Logger.LogError(ex, "An error occurred fetching metadata from {Provider}", _selectedProvider); + _errorMessage = ex.Message; + } + finally + { + _loading = false; + } + } + + private async Task ImportWithMerge() + { + if (_fetchedManifest is null) + return; + + _loading = true; + _importing = true; + _importStatus = "Importing..."; + _errorMessage = null; + + try + { + LANCommander.Server.Data.Models.Game? existing = null; + + if (GameId != Guid.Empty) + existing = await GameService.GetAsync(GameId); + + var manifest = _fetchedManifest; + manifest.Id = GameId == Guid.Empty ? Guid.NewGuid() : GameId; + + if (!_importTitle && existing != null) + manifest.Title = existing.Title; + + if (!_importDescription && existing != null) + manifest.Description = existing.Description; + + if (!_importReleasedOn && existing != null) + manifest.ReleasedOn = existing.ReleasedOn ?? default; + + if (!_importSingleplayer && existing != null) + manifest.Singleplayer = existing.Singleplayer; + + if (!_importEngine) + manifest.Engine = null; + + if (!_importDevelopers) + manifest.Developers = new List(); + + if (!_importPublishers) + manifest.Publishers = new List(); + + if (!_importGenres) + manifest.Genres = new List(); + + if (!_importTags) + manifest.Tags = new List(); + + if (!_importMultiplayerModes) + manifest.MultiplayerModes = new List(); + + if (!_importSavePaths) + manifest.SavePaths = new List(); + + if (!_importExternalIds) + manifest.ExternalIds = new List(); + + using var context = ImportContextFactory.Create(); + await context.InitializeMetadataUpdateAsync(manifest); + await context.ImportQueueAsync(); + + _loading = false; + + await OnImported.InvokeAsync(manifest.Id); + + _importing = false; + Reset(); + } + catch (Exception ex) + { + Logger.LogError(ex, "An error occurred importing metadata from {Provider}", _selectedProvider); + _errorMessage = ex.Message; + _loading = false; + _importing = false; + } + } + + public async Task UpdateStatusAsync(string status) + { + _importStatus = status; + await InvokeAsync(StateHasChanged); + } + + private void BackToSearch() + { + _stage = ModalStage.Search; + _errorMessage = null; + _fetchedManifest = null; + SelectedResults = []; + } + + private void DismissError() + { + _errorMessage = null; + } + + private void Reset() + { + _results = null; + _limit = 10; + _offset = 0; + _hasSearched = false; + _stage = ModalStage.Search; + _errorMessage = null; + _fetchedManifest = null; + } + + private async Task HandleCancel() + { + Reset(); + await OnCancel.InvokeAsync(); + } + + private async Task ShowMore() + { + _offset += _results?.Limit ?? _limit; + + await SearchForGame(Search, false); + } +} diff --git a/LANCommander.Server/UI/Pages/Games/Index.razor b/LANCommander.Server/UI/Pages/Games/Index.razor index b937e94c..a9169b55 100644 --- a/LANCommander.Server/UI/Pages/Games/Index.razor +++ b/LANCommander.Server/UI/Pages/Games/Index.razor @@ -3,6 +3,7 @@ @using AntDesign.TableModels @attribute [Authorize] @inject GameService GameService +@inject MetadataService MetadataService @inject NavigationManager NavigationManager @inject ModalService ModalService @inject IMessageService MessageService @@ -154,9 +155,33 @@ return "/favicon.ico"; } - void Add() + bool _hasMetadataProviders; + + protected override void OnInitialized() { - NavigationManager.NavigateTo("/Games/Add"); + _hasMetadataProviders = MetadataService.GetProviderNames().Any(); + } + + async Task Add() + { + if (_hasMetadataProviders) + { + var modalOptions = new ModalOptions + { + Title = "Add Game", + Maximizable = false, + DefaultMaximized = false, + Closable = true, + Footer = null, + }; + + var modalRef = ModalService.CreateModal(modalOptions, new AddGameDialogOptions()); + modalRef.OnClose = Reload; + } + else + { + NavigationManager.NavigateTo("/Games/Add"); + } } async Task Delete(Game game)