diff --git a/src/Sphagnum.Client/ClientDefault.cs b/src/Sphagnum.Client/ClientDefault.cs index 4a5fe8e..b5044de 100644 --- a/src/Sphagnum.Client/ClientDefault.cs +++ b/src/Sphagnum.Client/ClientDefault.cs @@ -1,4 +1,5 @@ using Sphagnum.Common.Infrastructure.Contracts; +using Sphagnum.Common.Infrastructure.Services; using Sphagnum.Common.Messaging.Contracts; using Sphagnum.Common.Messaging.Contracts.Messages; using Sphagnum.Common.Messaging.Utils; @@ -14,7 +15,7 @@ namespace Sphagnum.Client private readonly IConnection _connection; private readonly Channel _commonMessagesChannel = Channel.CreateUnbounded(); private readonly CancellationTokenSource _cts = new CancellationTokenSource(); - public ClientDefault(IConnectionFactory factory) + public ClientDefault(ConnectionFactory factory) { _connection = factory.CreateConnection().Result; } diff --git a/src/Sphagnum.Common/Infrastructure/Contracts/IConnectionFactory.cs b/src/Sphagnum.Common/Infrastructure/Contracts/IConnectionFactory.cs deleted file mode 100644 index 0ff2b08..0000000 --- a/src/Sphagnum.Common/Infrastructure/Contracts/IConnectionFactory.cs +++ /dev/null @@ -1,15 +0,0 @@ -using Sphagnum.Common.Old.Contracts.Login; -using System.Threading.Tasks; - -namespace Sphagnum.Common.Infrastructure.Contracts -{ - public interface IConnectionFactory - { - public int Port { get; } - public string Hostname { get; } - public string Login { get; } - public string Password { get; } - public UserRights UserRights { get; set; } - internal Task CreateConnection(bool connected = true); - } -} diff --git a/src/Sphagnum.Common/Infrastructure/Services/ConnectionFactory.cs b/src/Sphagnum.Common/Infrastructure/Services/ConnectionFactory.cs index b4f6ec1..7a327da 100644 --- a/src/Sphagnum.Common/Infrastructure/Services/ConnectionFactory.cs +++ b/src/Sphagnum.Common/Infrastructure/Services/ConnectionFactory.cs @@ -5,14 +5,14 @@ using System.Threading.Tasks; namespace Sphagnum.Common.Infrastructure.Services { - public class ConnectionFactory : IConnectionFactory + public class ConnectionFactory { public int Port { get; set; } public string Hostname { get; set; } = string.Empty; public string Login { get; set; } = string.Empty; public string Password { get; set; } = string.Empty; public UserRights UserRights { get; set; } - async Task IConnectionFactory.CreateConnection(bool connected = true) + internal virtual async Task CreateConnection(bool connected = true) { var conn = new SocketConnection(new Socket(SocketType.Stream, ProtocolType.Tcp)); if (connected)