NatTypeTester/NatTypeTester.ViewModels/RFC5780ViewModel.cs

using Dns.Net.Abstractions;
using JetBrains.Annotations;
using Microsoft;
using NatTypeTester.Models;
using ReactiveUI;
using Socks5.Models;
using STUN;
using STUN.Client;
using STUN.Proxy;
using STUN.StunResult;
using System.Net;
using System.Net.Sockets;
using System.Reactive;
using System.Reactive.Linq;

namespace NatTypeTester.ViewModels;

[UsedImplicitly]
public class RFC5780ViewModel : ViewModelBase, IRoutableViewModel
{
	public string UrlPathSegment => @"RFC5780";
	public IScreen HostScreen => LazyServiceProvider.LazyGetRequiredService<IScreen>();

	private Config Config => LazyServiceProvider.LazyGetRequiredService<Config>();

	private IDnsClient DnsClient => LazyServiceProvider.LazyGetRequiredService<IDnsClient>();

	public StunResult5389 Result5389 { get; set; }

	public ReactiveCommand<Unit, Unit> DiscoveryNatType { get; }

	private static readonly IPEndPoint DefaultLocalEndpoint = new(IPAddress.Any, 0);

	public RFC5780ViewModel()
	{
		Result5389 = new StunResult5389 { LocalEndPoint = new IPEndPoint(IPAddress.Any, 0) };
		DiscoveryNatType = ReactiveCommand.CreateFromTask(DiscoveryNatTypeAsync);
	}

	private async Task DiscoveryNatTypeAsync(CancellationToken token)
	{
		Verify.Operation(StunServer.TryParse(Config.StunServer, out var server), @"Wrong STUN Server!");

		if (!HostnameEndpoint.TryParse(Config.ProxyServer, out var proxyIpe))
		{
			throw new NotSupportedException(@"Unknown proxy address");
		}

		var socks5Option = new Socks5CreateOption
		{
			Address = await DnsClient.QueryAsync(proxyIpe.Hostname, token),
			Port = proxyIpe.Port,
			UsernamePassword = new UsernamePassword
			{
				UserName = Config.ProxyUser,
				Password = Config.ProxyPassword
			}
		};

		Result5389.LocalEndPoint ??= DefaultLocalEndpoint;
		using var proxy = ProxyFactory.CreateProxy(Config.ProxyType, Result5389.LocalEndPoint, socks5Option);

		var ip = await DnsClient.QueryAsync(server.Hostname, token);
		using var client = new StunClient5389UDP(new IPEndPoint(ip, server.Port), Result5389.LocalEndPoint, proxy);

		Result5389 = client.State;
		using (Observable.Interval(TimeSpan.FromSeconds(0.1))
				   .ObserveOn(RxApp.MainThreadScheduler)
				   .Subscribe(_ => this.RaisePropertyChanged(nameof(Result5389))))
		{
			await client.ConnectProxyAsync(token);
			try
			{
				await client.QueryAsync(token);
				Result5389.LocalEndPoint = new IPEndPoint(client.LocalEndPoint.AddressFamily is AddressFamily.InterNetwork ? IPAddress.Any : IPAddress.IPv6Any, client.LocalEndPoint.Port);
			}
			finally
			{
				await client.CloseProxyAsync(token);
			}
		}

		Result5389 = new StunResult5389();
		Result5389.Clone(client.State);

		this.RaisePropertyChanged(nameof(Result5389));
	}
}