LANCommander/LANCommander.Launcher.Services/Import/Importers/DeveloperImporter.cs
Pat Hartl 18bf0f251c Refactor launcher import (again)
Implements a queue-based importer based on the implementation server-side.
2025-12-05 21:04:01 -06:00

58 lines
No EOL
1.9 KiB
C#

using LANCommander.Launcher.Services.Exceptions;
using LANCommander.SDK.Models.Manifest;
using Microsoft.Extensions.Logging;
namespace LANCommander.Launcher.Services.Import.Importers;
public class DeveloperImporter(
CompanyService companyService,
ILogger<DeveloperImporter> logger) : BaseImporter<Company>
{
public override async Task<ImportItemInfo<Company>> GetImportInfoAsync(Company record, BaseManifest manifest) =>
new()
{
Key = GetKey(record),
Name = record.Name,
Type = "Developer",
Record = record,
};
public override string GetKey(Company record) => $"{nameof(Company)}/{record.Name}";
public override async Task<bool> CanImportAsync(Company record)
{
var existing = await companyService.FirstOrDefaultAsync(c => c.Name == record.Name);
if (existing == null)
return true;
return record.UpdatedOn > existing.ImportedOn;
}
public override async Task<bool> AddAsync(ImportItemInfo<Company> importItemInfo)
{
var company = new Data.Models.Company
{
Name = importItemInfo.Record.Name,
CreatedOn = importItemInfo.Record.CreatedOn,
UpdatedOn = importItemInfo.Record.UpdatedOn,
ImportedOn = DateTime.UtcNow,
};
try
{
await companyService.AddAsync(company);
return true;
}
catch (Exception ex)
{
logger.LogError(ex, "Could not add developer | {Key}", GetKey(importItemInfo.Record));
return false;
}
}
public override async Task<bool> UpdateAsync(ImportItemInfo<Company> importItemInfo) => true;
public override async Task<bool> ExistsAsync(ImportItemInfo<Company> importItemInfo)
=> await companyService.ExistsAsync(c => c.Name == importItemInfo.Record.Name);
}