using System;
using System.Collections.Generic;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
using BestHTTP.Extensions;
using BestHTTP.Futures;
using BestHTTP.Logger;
using BestHTTP.SignalRCore.Authentication;
using BestHTTP.SignalRCore.Messages;
using Cpp2IlInjected;

namespace BestHTTP.SignalRCore
{
	// Token: 0x020018DF RID: 6367
	[Token(Token = "0x20018DF")]
	public sealed class HubConnection : IHeartbeat
	{
		// Token: 0x170017D8 RID: 6104
		// (get) Token: 0x060095B0 RID: 38320 RVA: 0x001EC77C File Offset: 0x001EA97C
		// (set) Token: 0x060095B1 RID: 38321 RVA: 0x001EC790 File Offset: 0x001EA990
		[Token(Token = "0x170017D8")]
		public Uri Uri
		{
			[Token(Token = "0x60095B0")]
			[Address(RVA = "0x3F6E20", Offset = "0x3F5C20", VA = "0x1803F6E20")]
			get;
			[Token(Token = "0x60095B1")]
			[Address(RVA = "0x3F7200", Offset = "0x3F6000", VA = "0x1803F7200")]
			private set;
		}

		// Token: 0x170017D9 RID: 6105
		// (get) Token: 0x060095B2 RID: 38322 RVA: 0x001EC7A4 File Offset: 0x001EA9A4
		// (set) Token: 0x060095B3 RID: 38323 RVA: 0x001EC7B8 File Offset: 0x001EA9B8
		[Token(Token = "0x170017D9")]
		public ConnectionStates State
		{
			[Token(Token = "0x60095B2")]
			[Address(RVA = "0x40B720", Offset = "0x40A520", VA = "0x18040B720")]
			get;
			[Token(Token = "0x60095B3")]
			[Address(RVA = "0x41F740", Offset = "0x41E540", VA = "0x18041F740")]
			private set;
		}

		// Token: 0x170017DA RID: 6106
		// (get) Token: 0x060095B4 RID: 38324 RVA: 0x001EC7CC File Offset: 0x001EA9CC
		// (set) Token: 0x060095B5 RID: 38325 RVA: 0x001EC7E0 File Offset: 0x001EA9E0
		[Token(Token = "0x170017DA")]
		public ITransport Transport
		{
			[Token(Token = "0x60095B4")]
			[Address(RVA = "0x3F6400", Offset = "0x3F5200", VA = "0x1803F6400")]
			get;
			[Token(Token = "0x60095B5")]
			[Address(RVA = "0x460F90", Offset = "0x45FD90", VA = "0x180460F90")]
			private set;
		}

		// Token: 0x170017DB RID: 6107
		// (get) Token: 0x060095B6 RID: 38326 RVA: 0x001EC7F4 File Offset: 0x001EA9F4
		// (set) Token: 0x060095B7 RID: 38327 RVA: 0x001EC808 File Offset: 0x001EAA08
		[Token(Token = "0x170017DB")]
		public IProtocol Protocol
		{
			[Token(Token = "0x60095B6")]
			[Address(RVA = "0x3F63E0", Offset = "0x3F51E0", VA = "0x1803F63E0")]
			get;
			[Token(Token = "0x60095B7")]
			[Address(RVA = "0x409C60", Offset = "0x408A60", VA = "0x180409C60")]
			private set;
		}

		// Token: 0x140000C2 RID: 194
		// (add) Token: 0x060095B8 RID: 38328 RVA: 0x001EC81C File Offset: 0x001EAA1C
		// (remove) Token: 0x060095B9 RID: 38329 RVA: 0x001EC844 File Offset: 0x001EAA44
		[Token(Token = "0x140000C2")]
		public event Action<HubConnection, Uri, Uri> OnRedirected
		{
			[Token(Token = "0x60095B8")]
			[Address(RVA = "0x1C37A10", Offset = "0x1C36810", VA = "0x181C37A10")]
			[CompilerGenerated]
			add
			{
				Action<HubConnection, Uri, Uri> onRedirected;
				Delegate @delegate;
				do
				{
					onRedirected = this.OnRedirected;
					@delegate = Delegate.Combine(onRedirected, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onRedirected)
				{
				}
			}
			[Token(Token = "0x60095B9")]
			[Address(RVA = "0x1C37D30", Offset = "0x1C36B30", VA = "0x181C37D30")]
			[CompilerGenerated]
			remove
			{
				Action<HubConnection, Uri, Uri> onRedirected;
				Delegate @delegate;
				do
				{
					onRedirected = this.OnRedirected;
					@delegate = Delegate.Remove(onRedirected, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onRedirected)
				{
				}
			}
		}

		// Token: 0x140000C3 RID: 195
		// (add) Token: 0x060095BA RID: 38330 RVA: 0x001EC86C File Offset: 0x001EAA6C
		// (remove) Token: 0x060095BB RID: 38331 RVA: 0x001EC894 File Offset: 0x001EAA94
		[Token(Token = "0x140000C3")]
		public event Action<HubConnection> OnConnected
		{
			[Token(Token = "0x60095BA")]
			[Address(RVA = "0x1C37830", Offset = "0x1C36630", VA = "0x181C37830")]
			[CompilerGenerated]
			add
			{
				Action<HubConnection> onConnected;
				Delegate @delegate;
				do
				{
					onConnected = this.OnConnected;
					@delegate = Delegate.Combine(onConnected, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onConnected)
				{
				}
			}
			[Token(Token = "0x60095BB")]
			[Address(RVA = "0x1C37B50", Offset = "0x1C36950", VA = "0x181C37B50")]
			[CompilerGenerated]
			remove
			{
				Action<HubConnection> onConnected;
				Delegate @delegate;
				do
				{
					onConnected = this.OnConnected;
					@delegate = Delegate.Remove(onConnected, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onConnected)
				{
				}
			}
		}

		// Token: 0x140000C4 RID: 196
		// (add) Token: 0x060095BC RID: 38332 RVA: 0x001EC8BC File Offset: 0x001EAABC
		// (remove) Token: 0x060095BD RID: 38333 RVA: 0x001EC8E4 File Offset: 0x001EAAE4
		[Token(Token = "0x140000C4")]
		public event Action<HubConnection, string> OnError
		{
			[Token(Token = "0x60095BC")]
			[Address(RVA = "0x1C378D0", Offset = "0x1C366D0", VA = "0x181C378D0")]
			[CompilerGenerated]
			add
			{
				Action<HubConnection, string> onError;
				Delegate @delegate;
				do
				{
					onError = this.OnError;
					@delegate = Delegate.Combine(onError, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onError)
				{
				}
			}
			[Token(Token = "0x60095BD")]
			[Address(RVA = "0x1C37BF0", Offset = "0x1C369F0", VA = "0x181C37BF0")]
			[CompilerGenerated]
			remove
			{
				Action<HubConnection, string> onError;
				Delegate @delegate;
				do
				{
					onError = this.OnError;
					@delegate = Delegate.Remove(onError, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onError)
				{
				}
			}
		}

		// Token: 0x140000C5 RID: 197
		// (add) Token: 0x060095BE RID: 38334 RVA: 0x001EC90C File Offset: 0x001EAB0C
		// (remove) Token: 0x060095BF RID: 38335 RVA: 0x001EC934 File Offset: 0x001EAB34
		[Token(Token = "0x140000C5")]
		public event Action<HubConnection> OnClosed
		{
			[Token(Token = "0x60095BE")]
			[Address(RVA = "0x1C37790", Offset = "0x1C36590", VA = "0x181C37790")]
			[CompilerGenerated]
			add
			{
				Action<HubConnection> onClosed;
				Delegate @delegate;
				do
				{
					onClosed = this.OnClosed;
					@delegate = Delegate.Combine(onClosed, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onClosed)
				{
				}
			}
			[Token(Token = "0x60095BF")]
			[Address(RVA = "0x1C37AB0", Offset = "0x1C368B0", VA = "0x181C37AB0")]
			[CompilerGenerated]
			remove
			{
				Action<HubConnection> onClosed;
				Delegate @delegate;
				do
				{
					onClosed = this.OnClosed;
					@delegate = Delegate.Remove(onClosed, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onClosed)
				{
				}
			}
		}

		// Token: 0x140000C6 RID: 198
		// (add) Token: 0x060095C0 RID: 38336 RVA: 0x001EC95C File Offset: 0x001EAB5C
		// (remove) Token: 0x060095C1 RID: 38337 RVA: 0x001EC984 File Offset: 0x001EAB84
		[Token(Token = "0x140000C6")]
		public event Func<HubConnection, Message, bool> OnMessage
		{
			[Token(Token = "0x60095C0")]
			[Address(RVA = "0x1C37970", Offset = "0x1C36770", VA = "0x181C37970")]
			[CompilerGenerated]
			add
			{
				Func<HubConnection, Message, bool> onMessage;
				Delegate @delegate;
				do
				{
					onMessage = this.OnMessage;
					@delegate = Delegate.Combine(onMessage, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onMessage)
				{
				}
			}
			[Token(Token = "0x60095C1")]
			[Address(RVA = "0x1C37C90", Offset = "0x1C36A90", VA = "0x181C37C90")]
			[CompilerGenerated]
			remove
			{
				Func<HubConnection, Message, bool> onMessage;
				Delegate @delegate;
				do
				{
					onMessage = this.OnMessage;
					@delegate = Delegate.Remove(onMessage, value);
				}
				while (@delegate != 0 && @delegate == 0);
				while (@delegate != onMessage)
				{
				}
			}
		}

		// Token: 0x170017DC RID: 6108
		// (get) Token: 0x060095C2 RID: 38338 RVA: 0x001EC9AC File Offset: 0x001EABAC
		// (set) Token: 0x060095C3 RID: 38339 RVA: 0x001EC9C0 File Offset: 0x001EABC0
		[Token(Token = "0x170017DC")]
		public IAuthenticationProvider AuthenticationProvider
		{
			[Token(Token = "0x60095C2")]
			[Address(RVA = "0x423D40", Offset = "0x422B40", VA = "0x180423D40")]
			get;
			[Token(Token = "0x60095C3")]
			[Address(RVA = "0x466B90", Offset = "0x465990", VA = "0x180466B90")]
			set;
		}

		// Token: 0x170017DD RID: 6109
		// (get) Token: 0x060095C4 RID: 38340 RVA: 0x001EC9D4 File Offset: 0x001EABD4
		// (set) Token: 0x060095C5 RID: 38341 RVA: 0x001EC9E8 File Offset: 0x001EABE8
		[Token(Token = "0x170017DD")]
		public NegotiationResult NegotiationResult
		{
			[Token(Token = "0x60095C4")]
			[Address(RVA = "0x423DE0", Offset = "0x422BE0", VA = "0x180423DE0")]
			get;
			[Token(Token = "0x60095C5")]
			[Address(RVA = "0x567490", Offset = "0x566290", VA = "0x180567490")]
			private set;
		}

		// Token: 0x170017DE RID: 6110
		// (get) Token: 0x060095C6 RID: 38342 RVA: 0x001EC9FC File Offset: 0x001EABFC
		// (set) Token: 0x060095C7 RID: 38343 RVA: 0x001ECA10 File Offset: 0x001EAC10
		[Token(Token = "0x170017DE")]
		public HubOptions Options
		{
			[Token(Token = "0x60095C6")]
			[Address(RVA = "0x423E10", Offset = "0x422C10", VA = "0x180423E10")]
			get;
			[Token(Token = "0x60095C7")]
			[Address(RVA = "0x687270", Offset = "0x686070", VA = "0x180687270")]
			private set;
		}

		// Token: 0x170017DF RID: 6111
		// (get) Token: 0x060095C8 RID: 38344 RVA: 0x001ECA24 File Offset: 0x001EAC24
		// (set) Token: 0x060095C9 RID: 38345 RVA: 0x001ECA38 File Offset: 0x001EAC38
		[Token(Token = "0x170017DF")]
		public int RedirectCount
		{
			[Token(Token = "0x60095C8")]
			[Address(RVA = "0x5672E0", Offset = "0x5660E0", VA = "0x1805672E0")]
			get;
			[Token(Token = "0x60095C9")]
			[Address(RVA = "0x5674F0", Offset = "0x5662F0", VA = "0x1805674F0")]
			private set;
		}

		// Token: 0x060095CA RID: 38346 RVA: 0x001ECA4C File Offset: 0x001EAC4C
		[Token(Token = "0x60095CA")]
		[Address(RVA = "0x1C374D0", Offset = "0x1C362D0", VA = "0x181C374D0")]
		public HubConnection(Uri hubUri, IProtocol protocol)
		{
			HubOptions hubOptions = new HubOptions();
			hubOptions.<SkipNegotiation>k__BackingField = false;
			hubOptions.<PreferedTransport>k__BackingField = (TransportTypes)((ulong)0L);
			TimeSpan timeSpan;
			hubOptions.<PingInterval>k__BackingField = timeSpan;
			hubOptions.<MaxRedirects>k__BackingField = (int)((ulong)100L);
		}

		// Token: 0x060095CB RID: 38347 RVA: 0x001ECA80 File Offset: 0x001EAC80
		[Token(Token = "0x60095CB")]
		[Address(RVA = "0x1C375B0", Offset = "0x1C363B0", VA = "0x181C375B0")]
		public HubConnection(Uri hubUri, IProtocol protocol, HubOptions options)
		{
			Dictionary<long, Action<Message>> dictionary = new Dictionary();
			this.invocations = dictionary;
			Dictionary<string, Subscription> dictionary2 = new Dictionary(StringComparer._ordinalIgnoreCase);
			this.subscriptions = dictionary2;
			base..ctor();
			int num = 0;
			this.Uri = hubUri;
			this.State = (ConnectionStates)num;
			this.Options = options;
			this.Protocol = protocol;
			num += num;
			num++;
			DefaultAccessTokenAuthenticator defaultAccessTokenAuthenticator;
			defaultAccessTokenAuthenticator.StartAuthentication();
			defaultAccessTokenAuthenticator._connection = this;
			this.AuthenticationProvider = defaultAccessTokenAuthenticator;
		}

		// Token: 0x060095CC RID: 38348 RVA: 0x001ECAFC File Offset: 0x001EACFC
		[Token(Token = "0x60095CC")]
		[Address(RVA = "0x1C36D50", Offset = "0x1C35B50", VA = "0x181C36D50")]
		public void StartConnect()
		{
			ConnectionStates connectionStates = this.<State>k__BackingField;
			if (connectionStates != ConnectionStates.Initial && connectionStates != ConnectionStates.Redirected)
			{
				ILogger logger = HTTPManager.Logger;
				ConnectionStates connectionStates2 = this.<State>k__BackingField;
				return;
			}
			ILogger logger2 = HTTPManager.Logger;
			if (this.<AuthenticationProvider>k__BackingField != 0 && logger2 != 0)
			{
				ILogger logger3 = HTTPManager.Logger;
				int num = 0;
				this.SetState(ConnectionStates.Authenticating, num);
				IAuthenticationProvider authenticationProvider = this.<AuthenticationProvider>k__BackingField;
				OnAuthenticationSuccededDelegate onAuthenticationSuccededDelegate;
				onAuthenticationSuccededDelegate.method_ptr = ldftn(OnAuthenticationSucceded);
				onAuthenticationSuccededDelegate.method = ldftn(OnAuthenticationSucceded);
				onAuthenticationSuccededDelegate.m_target = this;
				IAuthenticationProvider authenticationProvider2 = this.<AuthenticationProvider>k__BackingField;
				OnAuthenticationFailedDelegate onAuthenticationFailedDelegate;
				onAuthenticationFailedDelegate.method_ptr = ldftn(OnAuthenticationFailed);
				onAuthenticationFailedDelegate.method = ldftn(OnAuthenticationFailed);
				onAuthenticationFailedDelegate.m_target = this;
				IAuthenticationProvider authenticationProvider3 = this.<AuthenticationProvider>k__BackingField;
				return;
			}
			this.StartNegotiation();
		}

		// Token: 0x060095CD RID: 38349 RVA: 0x001ECBC4 File Offset: 0x001EADC4
		[Token(Token = "0x60095CD")]
		[Address(RVA = "0x1C35190", Offset = "0x1C33F90", VA = "0x181C35190")]
		private void OnAuthenticationSucceded(IAuthenticationProvider provider)
		{
			ILogger logger = HTTPManager.Logger;
			IAuthenticationProvider authenticationProvider = this.<AuthenticationProvider>k__BackingField;
			OnAuthenticationSuccededDelegate onAuthenticationSuccededDelegate;
			onAuthenticationSuccededDelegate.method_ptr = ldftn(OnAuthenticationSucceded);
			onAuthenticationSuccededDelegate.method = ldftn(OnAuthenticationSucceded);
			onAuthenticationSuccededDelegate.m_target = this;
			IAuthenticationProvider authenticationProvider2 = this.<AuthenticationProvider>k__BackingField;
			OnAuthenticationFailedDelegate onAuthenticationFailedDelegate;
			onAuthenticationFailedDelegate.method_ptr = ldftn(OnAuthenticationFailed);
			onAuthenticationFailedDelegate.method = ldftn(OnAuthenticationFailed);
			onAuthenticationFailedDelegate.m_target = this;
			this.StartNegotiation();
		}

		// Token: 0x060095CE RID: 38350 RVA: 0x001ECC38 File Offset: 0x001EAE38
		[Token(Token = "0x60095CE")]
		[Address(RVA = "0x1C35050", Offset = "0x1C33E50", VA = "0x181C35050")]
		private void OnAuthenticationFailed(IAuthenticationProvider provider, string reason)
		{
			ILogger logger = HTTPManager.Logger;
			string text = "OnAuthenticationFailed: " + reason;
			IAuthenticationProvider authenticationProvider = this.<AuthenticationProvider>k__BackingField;
			OnAuthenticationSuccededDelegate onAuthenticationSuccededDelegate;
			onAuthenticationSuccededDelegate.method_ptr = ldftn(OnAuthenticationSucceded);
			onAuthenticationSuccededDelegate.method = ldftn(OnAuthenticationSucceded);
			onAuthenticationSuccededDelegate.m_target = this;
			IAuthenticationProvider authenticationProvider2 = this.<AuthenticationProvider>k__BackingField;
			OnAuthenticationFailedDelegate onAuthenticationFailedDelegate;
			onAuthenticationFailedDelegate.method_ptr = ldftn(OnAuthenticationFailed);
			onAuthenticationFailedDelegate.method = ldftn(OnAuthenticationFailed);
			onAuthenticationFailedDelegate.m_target = this;
			this.SetState(ConnectionStates.Closed, reason);
		}

		// Token: 0x060095CF RID: 38351 RVA: 0x001ECCBC File Offset: 0x001EAEBC
		[Token(Token = "0x60095CF")]
		[Address(RVA = "0x1C37010", Offset = "0x1C35E10", VA = "0x181C37010")]
		private void StartNegotiation()
		{
			ILogger logger = HTTPManager.Logger;
			if (this.<State>k__BackingField != ConnectionStates.CloseInitiated)
			{
				if (!this.<Options>k__BackingField.<SkipNegotiation>k__BackingField)
				{
					int num = 0;
					this.SetState(ConnectionStates.Negotiating, num);
					UriBuilder uriBuilder = new UriBuilder(this.<Uri>k__BackingField);
					if (!uriBuilder._path.EndsWith("/"))
					{
						string text = uriBuilder._path + "/";
						uriBuilder.Path = text;
					}
					string text2 = uriBuilder._path + "negotiate";
					uriBuilder.Path = text2;
					Uri uri = uriBuilder.Uri;
					Action<NEBIGEDJGPP, HOOILIHKMEG> action = new Action(this.OnNegotiationRequestFinished);
					int num2 = 0;
					if (this.<AuthenticationProvider>k__BackingField != 0 && num2 < uri)
					{
						num2 += num2;
						num2++;
					}
					NEBIGEDJGPP nebigedjgpp;
					nebigedjgpp.GDOIHJPIPBM();
					return;
				}
				ILogger logger2 = HTTPManager.Logger;
				this.ConnectImpl();
			}
			int num3 = 0;
			this.SetState(ConnectionStates.Closed, num3);
			throw new NullReferenceException();
		}

		// Token: 0x060095D0 RID: 38352 RVA: 0x0000220F File Offset: 0x0000040F
		[Token(Token = "0x60095D0")]
		[Address(RVA = "0x1C34AB0", Offset = "0x1C338B0", VA = "0x181C34AB0")]
		private void ConnectImpl()
		{
			throw new AnalysisFailedException("CPP2IL failed to recover any usable IL for this method.");
		}

		// Token: 0x060095D1 RID: 38353 RVA: 0x0000220F File Offset: 0x0000040F
		[Token(Token = "0x60095D1")]
		[Address(RVA = "0x1C34F60", Offset = "0x1C33D60", VA = "0x181C34F60")]
		private bool IsTransportSupported(string transportName)
		{
			throw new AnalysisFailedException("CPP2IL failed to recover any usable IL for this method.");
		}

		// Token: 0x060095D2 RID: 38354 RVA: 0x001ECDC4 File Offset: 0x001EAFC4
		[Token(Token = "0x60095D2")]
		[Address(RVA = "0x1C359B0", Offset = "0x1C347B0", VA = "0x181C359B0")]
		private void OnNegotiationRequestFinished(NEBIGEDJGPP req, HOOILIHKMEG resp)
		{
			while (this.<State>k__BackingField != ConnectionStates.CloseInitiated)
			{
				string text = req.GLGCGFDLEJE();
				if (text == 0)
				{
					if (!resp.HIOBKPKOMLL)
					{
						int num = resp.LLODNIOIDKE;
						string text2 = resp.DFPPNHINEFO;
						string text3 = resp.DKPCLPHKFDI;
						int num2;
						string text4 = string.Format("Negotiation Request Finished Successfully, but the server sent an error. Status Code: {0}-{1} Message: {2}", num2, text2, text3);
					}
					ILogger logger = HTTPManager.Logger;
					string text5 = resp.DKPCLPHKFDI;
					string text6 = "Negotiation Request Finished Successfully! Response: " + text5;
					int num3 = 0;
					NegotiationResult negotiationResult = NegotiationResult.Parse(resp.DKPCLPHKFDI, num3, this);
					this.<NegotiationResult>k__BackingField = negotiationResult;
					if (negotiationResult == 0)
					{
						continue;
					}
					Uri <Url>k__BackingField = this.<NegotiationResult>k__BackingField.<Url>k__BackingField;
					int num4 = 0;
					if (!(<Url>k__BackingField != num4))
					{
						this.ConnectImpl();
					}
					int num5 = 0;
					this.SetState(ConnectionStates.Redirected, num5);
					int num6 = this.<RedirectCount>k__BackingField;
					num6++;
					this.<RedirectCount>k__BackingField = num6;
					HubOptions hubOptions = this.<Options>k__BackingField;
					int <MaxRedirects>k__BackingField = hubOptions.<MaxRedirects>k__BackingField;
					if (num6 < <MaxRedirects>k__BackingField)
					{
						Uri uri = this.<Uri>k__BackingField;
						NegotiationResult negotiationResult2 = this.<NegotiationResult>k__BackingField;
						Uri <Url>k__BackingField2 = negotiationResult2.<Url>k__BackingField;
						this.<Uri>k__BackingField = <Url>k__BackingField2;
						if (!string.IsNullOrEmpty(negotiationResult2.<AccessToken>k__BackingField))
						{
							string <AccessToken>k__BackingField = this.<NegotiationResult>k__BackingField.<AccessToken>k__BackingField;
							BearerTokenAuthProvider bearerTokenAuthProvider;
							bearerTokenAuthProvider.StartAuthentication();
							bearerTokenAuthProvider.accessToken = <AccessToken>k__BackingField;
							this.<AuthenticationProvider>k__BackingField = bearerTokenAuthProvider;
						}
						if (this.OnRedirected != (ulong)0L)
						{
							Action<HubConnection, Uri, Uri> onRedirected = this.OnRedirected;
							Uri uri2 = this.<Uri>k__BackingField;
							onRedirected(this, uri, uri2);
							ILogger logger2 = HTTPManager.Logger;
						}
						this.StartConnect();
					}
					string text7 = string.Format("MaxRedirects ({0:N0}) reached!", hubOptions);
				}
				if ("Negotiation Request: " + text != 0)
				{
					break;
				}
				return;
			}
			int num7 = 0;
			this.SetState(ConnectionStates.Closed, num7);
		}

		// Token: 0x060095D3 RID: 38355 RVA: 0x001ECF7C File Offset: 0x001EB17C
		[Token(Token = "0x60095D3")]
		[Address(RVA = "0x1C36C90", Offset = "0x1C35A90", VA = "0x181C36C90")]
		public void StartClose()
		{
			ILogger logger = HTTPManager.Logger;
			int num = 0;
			this.SetState(ConnectionStates.CloseInitiated, num);
			if (this.<Transport>k__BackingField != 0)
			{
			}
		}

		// Token: 0x060095D4 RID: 38356 RVA: 0x001ECFAC File Offset: 0x001EB1AC
		[Token(Token = "0x60095D4")]
		[Address(RVA = "0x1779D80", Offset = "0x1778B80", VA = "0x181779D80")]
		public IFuture<StreamItemContainer<TResult>> Stream<TResult>(string target, params object[] args)
		{
			Action<Message> action;
			ulong num2;
			long num = this.InvokeImp(target, args, action, num2 != 0UL);
			throw new NullReferenceException();
		}

		// Token: 0x060095D5 RID: 38357 RVA: 0x001ECFCC File Offset: 0x001EB1CC
		[Token(Token = "0x60095D5")]
		[Address(RVA = "0x1B557B0", Offset = "0x1B545B0", VA = "0x181B557B0")]
		public void CancelStream<T>(StreamItemContainer<T> container)
		{
			container.IsCanceled = true;
		}

		// Token: 0x060095D6 RID: 38358 RVA: 0x001ECFEC File Offset: 0x001EB1EC
		[Token(Token = "0x60095D6")]
		[Address(RVA = "0x1779C50", Offset = "0x1778A50", VA = "0x181779C50")]
		public IFuture<TResult> Invoke<TResult>(string target, params object[] args)
		{
			Action<Message> action;
			ulong num2;
			long num = this.InvokeImp(target, args, action, num2 != 0UL);
			throw new NullReferenceException();
		}

		// Token: 0x060095D7 RID: 38359 RVA: 0x001ED00C File Offset: 0x001EB20C
		[Token(Token = "0x60095D7")]
		[Address(RVA = "0x1C36180", Offset = "0x1C34F80", VA = "0x181C36180")]
		public IFuture<bool> Send(string target, params object[] args)
		{
			Future<bool> future4 = new Future();
			Future<bool> future = future4;
			Action<Message> action = delegate(Message message)
			{
				int num2 = 0;
				Future<bool> future3 = future;
				Exception ex = new Exception(num2);
				future3.Fail(ex);
			};
			if (this.<State>k__BackingField == ConnectionStates.Connected && action != 0)
			{
				long num;
				this.invocations.Add(num, action);
			}
			Future<bool> future2 = future;
			throw new NullReferenceException();
		}

		// Token: 0x060095D8 RID: 38360 RVA: 0x001ED068 File Offset: 0x001EB268
		[Token(Token = "0x60095D8")]
		[Address(RVA = "0x1C34E00", Offset = "0x1C33C00", VA = "0x181C34E00")]
		private long InvokeImp(string target, object[] args, Action<Message> callback, bool isStreamingInvocation = false)
		{
			if (this.<State>k__BackingField == ConnectionStates.Connected && callback != 0)
			{
				long num;
				this.invocations.Add(num, callback);
			}
			throw new NullReferenceException();
		}

		// Token: 0x060095D9 RID: 38361 RVA: 0x001ED098 File Offset: 0x001EB298
		[Token(Token = "0x60095D9")]
		[Address(RVA = "0x1C36040", Offset = "0x1C34E40", VA = "0x181C36040")]
		private void SendMessage(Message message)
		{
			IProtocol protocol = this.<Protocol>k__BackingField;
			int num = 0;
			num += num;
			num++;
			bool nonblocking = message.nonblocking;
			object[] arguments = message.arguments;
			object result = message.result;
			ITransport transport = this.<Transport>k__BackingField;
			DateTime utcNow = DateTime.UtcNow;
			this.lastMessageSent = utcNow;
		}

		// Token: 0x060095DA RID: 38362 RVA: 0x001ED0EC File Offset: 0x001EB2EC
		[Token(Token = "0x60095DA")]
		[Address(RVA = "0x1C35D80", Offset = "0x1C34B80", VA = "0x181C35D80")]
		public void On(string methodName, Action callback)
		{
			Action<object[]> action = delegate(object[] args)
			{
				callback();
			};
			Dictionary<string, Subscription> dictionary = this.subscriptions;
			bool flag;
			if (!flag)
			{
				Dictionary<string, Subscription> dictionary2 = this.subscriptions;
				List<CallbackDescriptor> list = new List(1);
				Subscription subscription;
				subscription.callbacks = list;
				dictionary2.Add(methodName, subscription);
			}
		}

		// Token: 0x060095DB RID: 38363 RVA: 0x001ED148 File Offset: 0x001EB348
		[Token(Token = "0x60095DB")]
		[Address(RVA = "0x1B55F30", Offset = "0x1B54D30", VA = "0x181B55F30")]
		public void On<T1>(string methodName, Action<T1> callback)
		{
			Type[] array = new Type[1];
			Type typeFromHandle = typeof(Type);
			if (typeFromHandle != 0)
			{
			}
			array[0] = typeFromHandle;
			Action<object[]> action;
			this.On(methodName, array, action);
		}

		// Token: 0x060095DC RID: 38364 RVA: 0x001ED184 File Offset: 0x001EB384
		[Token(Token = "0x60095DC")]
		[Address(RVA = "0x1B55D50", Offset = "0x1B54B50", VA = "0x181B55D50")]
		public void On<T1, T2>(string methodName, Action<T1, T2> callback)
		{
			Type[] array = new Type[2];
			Type typeFromHandle = typeof(Type);
			if (typeFromHandle != 0)
			{
			}
			array[0] = typeFromHandle;
			Type type;
			if (type != 0)
			{
			}
			array[1] = type;
			Action<object[]> action;
			this.On(methodName, array, action);
		}

		// Token: 0x060095DD RID: 38365 RVA: 0x001ED1CC File Offset: 0x001EB3CC
		[Token(Token = "0x60095DD")]
		[Address(RVA = "0x1B55B10", Offset = "0x1B54910", VA = "0x181B55B10")]
		public void On<T1, T2, T3>(string methodName, Action<T1, T2, T3> callback)
		{
			Type[] array = new Type[3];
			Type typeFromHandle = typeof(Type);
			if (typeFromHandle != 0)
			{
			}
			array[0] = typeFromHandle;
			Type type;
			if (type != 0)
			{
			}
			array[1] = type;
			Type type2;
			if (type2 != 0)
			{
			}
			array[2] = type2;
			Action<object[]> action;
			this.On(methodName, array, action);
		}

		// Token: 0x060095DE RID: 38366 RVA: 0x001ED220 File Offset: 0x001EB420
		[Token(Token = "0x60095DE")]
		[Address(RVA = "0x1B55870", Offset = "0x1B54670", VA = "0x181B55870")]
		public void On<T1, T2, T3, T4>(string methodName, Action<T1, T2, T3, T4> callback)
		{
			Type[] array = new Type[4];
			Type typeFromHandle = typeof(Type);
			if (typeFromHandle != 0)
			{
			}
			array[0] = typeFromHandle;
			Type type;
			if (type != 0)
			{
			}
			array[1] = type;
			Type type2;
			if (type2 != 0)
			{
			}
			array[2] = type2;
			Type type3;
			if (type3 != 0)
			{
			}
			array[3] = type3;
			Action<object[]> action;
			this.On(methodName, array, action);
		}

		// Token: 0x060095DF RID: 38367 RVA: 0x001ED284 File Offset: 0x001EB484
		[Token(Token = "0x60095DF")]
		[Address(RVA = "0x1C35F10", Offset = "0x1C34D10", VA = "0x181C35F10")]
		public void On(string methodName, Type[] paramTypes, Action<object[]> callback)
		{
			Dictionary<string, Subscription> dictionary = this.subscriptions;
			bool flag;
			if (!flag)
			{
				Dictionary<string, Subscription> dictionary2 = this.subscriptions;
				List<CallbackDescriptor> list = new List(1);
				Subscription subscription;
				subscription.callbacks = list;
				dictionary2.Add(methodName, subscription);
			}
		}

		// Token: 0x060095E0 RID: 38368 RVA: 0x001ED2C4 File Offset: 0x001EB4C4
		[Token(Token = "0x60095E0")]
		[Address(RVA = "0x1C352B0", Offset = "0x1C340B0", VA = "0x181C352B0")]
		internal void OnMessages(List<Message> messages)
		{
			ThrowHelper.ThrowArgumentOutOfRangeException();
			bool flag;
			if (this.OnMessage == 0 || !flag)
			{
			}
			ILogger logger = HTTPManager.Logger;
			int num = 0;
			if (logger <= (ulong)6L)
			{
				Dictionary<string, Subscription> dictionary = this.subscriptions;
				bool flag2;
				if (flag2 && num < (flag2 ? 1 : 0))
				{
					ThrowHelper.ThrowArgumentOutOfRangeException();
					num += 2;
					num += num;
					IProtocol protocol = this.<Protocol>k__BackingField;
					ILogger logger2 = HTTPManager.Logger;
					ILogger logger3 = HTTPManager.Logger;
					num++;
					bool flag3;
					if (flag3)
					{
						Dictionary<long, Action<Message>> dictionary2 = this.invocations;
						bool flag4;
						if (flag4)
						{
							ILogger logger4 = HTTPManager.Logger;
							bool flag5;
							if (flag5)
							{
								Dictionary<long, Action<Message>> dictionary3 = this.invocations;
								bool flag6;
								if (flag6)
								{
									ILogger logger5 = HTTPManager.Logger;
								}
								Dictionary<long, Action<Message>> dictionary4 = this.invocations;
							}
						}
					}
				}
			}
		}

		// Token: 0x060095E1 RID: 38369 RVA: 0x001ED39C File Offset: 0x001EB59C
		[Token(Token = "0x60095E1")]
		[Address(RVA = "0x1C372E0", Offset = "0x1C360E0", VA = "0x181C372E0")]
		private void Transport_OnStateChanged(TransportStates oldState, TransportStates newState)
		{
			ILogger logger = HTTPManager.Logger;
			ILogger logger2 = logger;
			if (logger != 0)
			{
				if (logger != 0)
				{
					if (logger == 0)
					{
						ITransport transport = this.<Transport>k__BackingField;
						goto IL_2B;
					}
					if (logger2 == (ulong)1L)
					{
					}
				}
				return;
			}
			IL_2B:
			throw new NullReferenceException();
		}

		// Token: 0x060095E2 RID: 38370 RVA: 0x001ED3DC File Offset: 0x001EB5DC
		[Token(Token = "0x60095E2")]
		[Address(RVA = "0x1C36350", Offset = "0x1C35150", VA = "0x181C36350")]
		private void SetState(ConnectionStates state, [Optional] string errorReason)
		{
			ILogger logger = HTTPManager.Logger;
			string[] array = new string[7];
			if ("SetState - from State: '" != 0)
			{
			}
			array[0] = "SetState - from State: '";
			ConnectionStates connectionStates;
			int num = connectionStates.GetHashCode();
			if (num != 0)
			{
			}
			array[1] = num;
			if ("' to State: '" != 0)
			{
			}
			array[2] = "' to State: '";
			int num2;
			num = num2;
			if (num != 0)
			{
			}
			array[3] = num;
			if ("' errorReason: '" != 0)
			{
			}
			array[4] = "' errorReason: '";
			if (errorReason != 0)
			{
			}
			array[5] = errorReason;
			if ("'" != 0)
			{
			}
			array[6] = "'";
			string text = string.Concat(array);
			ILogger logger2 = HTTPManager.Logger;
			string[] array2 = new string[5];
			if ("SetState - from State: '" != 0)
			{
			}
			array2[0] = "SetState - from State: '";
			ConnectionStates connectionStates2;
			int num3 = connectionStates2.GetHashCode();
			if (num3 != 0)
			{
			}
			array2[1] = num3;
			if ("' to State: '" != 0)
			{
			}
			array2[2] = "' to State: '";
			int num4;
			num3 = num4;
			if (num3 != 0)
			{
			}
			array2[3] = num3;
			if ("'" != 0)
			{
			}
			array2[4] = "'";
			string text2 = string.Concat(array2);
			if (this.<State>k__BackingField != text2)
			{
				this.<State>k__BackingField = text2;
				if (text2 <= (ulong)6L)
				{
					Action<HubConnection> onConnected = this.OnConnected;
					if (onConnected != 0)
					{
						onConnected(this);
					}
					ILogger logger3 = HTTPManager.Logger;
					HTTPManager.Heartbeats.Subscribe(this);
					DateTime utcNow = DateTime.UtcNow;
					this.lastMessageSent = utcNow;
				}
			}
		}

		// Token: 0x060095E3 RID: 38371 RVA: 0x001ED5C0 File Offset: 0x001EB7C0
		[Token(Token = "0x60095E3")]
		[Address(RVA = "0x1C34900", Offset = "0x1C33700", VA = "0x181C34900", Slot = "4")]
		void IHeartbeat.OnHeartbeatUpdate(TimeSpan dif)
		{
			if (this.<State>k__BackingField == ConnectionStates.Connected)
			{
				TimeSpan <PingInterval>k__BackingField = this.<Options>k__BackingField.<PingInterval>k__BackingField;
				TimeSpan zero = TimeSpan.Zero;
				if (<PingInterval>k__BackingField != zero)
				{
					DateTime utcNow = DateTime.UtcNow;
					DateTime dateTime = this.lastMessageSent;
					TimeSpan timeSpan = utcNow - dateTime;
					TimeSpan <PingInterval>k__BackingField2 = this.<Options>k__BackingField.<PingInterval>k__BackingField;
					if (timeSpan >= <PingInterval>k__BackingField2)
					{
					}
				}
			}
		}

		// Token: 0x0400662A RID: 26154
		[Token(Token = "0x400662A")]
		public static readonly object[] EmptyArgs = new object[0];

		// Token: 0x04006638 RID: 26168
		[global::Cpp2IlInjected.FieldOffset(Offset = "0x78")]
		[Token(Token = "0x4006638")]
		private long lastInvocationId;

		// Token: 0x04006639 RID: 26169
		[global::Cpp2IlInjected.FieldOffset(Offset = "0x80")]
		[Token(Token = "0x4006639")]
		private Dictionary<long, Action<Message>> invocations;

		// Token: 0x0400663A RID: 26170
		[global::Cpp2IlInjected.FieldOffset(Offset = "0x88")]
		[Token(Token = "0x400663A")]
		private Dictionary<string, Subscription> subscriptions;

		// Token: 0x0400663B RID: 26171
		[global::Cpp2IlInjected.FieldOffset(Offset = "0x90")]
		[Token(Token = "0x400663B")]
		private DateTime lastMessageSent;
	}
}