/*
* Copyright (c) 2023 Proton AG
*
* This file is part of ProtonVPN.
*
* ProtonVPN is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* ProtonVPN is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with ProtonVPN. If not, see .
*/
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using ProtonVPN.Api.Contracts;
using ProtonVPN.Common.Legacy.Threading;
using ProtonVPN.Configurations.Contracts;
namespace ProtonVPN.Api.Handlers;
///
/// Cancels all not finished requests on user logout.
///
public class CancellingHandler : CancellingHandlerBase
{
private readonly IConfiguration _config;
private readonly IUserSession _userSession;
private readonly CancellationHandle _cancellationHandle = new();
public CancellingHandler(IConfiguration config, IUserSession userSession)
{
_config = config;
_userSession = userSession;
}
protected override async Task SendAsync(
HttpRequestMessage request,
CancellationToken cancellationToken)
{
if (IsLogout(request))
{
_cancellationHandle.Cancel();
}
return await base.SendAsync(request, _userSession.IsLoggedIn ? _cancellationHandle.Token : cancellationToken);
}
private bool IsLogout(HttpRequestMessage request)
{
string endpoint = request.RequestUri.AbsoluteUri.Replace(_config.Urls.ApiUrl, "");
return request.Method == HttpMethod.Delete && endpoint == "/auth";
}
}