prehistoric-systems/FilterLists
1
0
Fork 0
mirror of https://github.com/collinbarrett/FilterLists.git synced 2026-03-11 09:04:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

re-initial support for Zip

Browse source
This commit is contained in:
Collin M. Barrett 2019-06-30 20:35:29 -05:00
parent 76a973ecb9
commit 4c436d031e
2 changed files with 55 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/FilterLists.Agent/Features/Archiver/DownloadLists.cs
View file

@ -53,8 +53,8 @@ private static readonly Dictionary<string, Func<ListInfo, IRequest>> CommandsByE
{".p2p", l => new DownloadRawText.Command(l)},
{".php", l => new DownloadRawText.Command(l)},
{".tpl", l => new DownloadRawText.Command(l)},
{".txt", l => new DownloadRawText.Command(l)}
//{".zip", l => new DownloadRawText.Command(l)}
{".txt", l => new DownloadRawText.Command(l)},
{".zip", l => new DownloadZip.Command(l)}
};
private readonly ILogger<Handler> _logger;

53
src/FilterLists.Agent/Features/Archiver/DownloadZip.cs Normal file
View file

@ -0,0 +1,53 @@
using System.IO;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using FilterLists.Agent.Core.Entities;
using FilterLists.Agent.Infrastructure.Clients;
using MediatR;
using SharpCompress.Common;
using SharpCompress.Readers;
namespace FilterLists.Agent.Features.Archiver
{
public static class DownloadZip
{
public class Command : IRequest
{
public Command(ListInfo listInfo)
{
ListInfo = listInfo;
}
public ListInfo ListInfo { get; }
}
public class Handler : AsyncRequestHandler<Command>
{
private const string RepoDirectory = @"archives";
private readonly HttpClient _httpClient;
public Handler(AgentHttpClient httpClient)
{
_httpClient = httpClient.Client;
}
protected override async Task Handle(Command request, CancellationToken cancellationToken)
{
var destinationDirectoryPath = Path.Combine(RepoDirectory, $"{request.ListInfo.Id}");
using (var response = await _httpClient.GetAsync(request.ListInfo.ViewUrl, cancellationToken))
{
if (response.IsSuccessStatusCode)
using (var input = await response.Content.ReadAsStreamAsync())
using (var reader = ReaderFactory.Open(input))
{
while (reader.MoveToNextEntry())
if (!reader.Entry.IsDirectory)
reader.WriteEntryToDirectory(destinationDirectoryPath,
new ExtractionOptions {ExtractFullPath = true, Overwrite = true});
}
}
}
}
}
}