From 171e90079672fe911a852d2ffdfffacd46e7edd9 Mon Sep 17 00:00:00 2001
From: AmarnathCJD <amarnathcharichilil@gmail.com>
Date: Tue, 19 Mar 2024 10:01:43 +0530
Subject: [PATCH] Update log messages in mtproto.go

---
 mtproto.go | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/mtproto.go b/mtproto.go
index 0527be54..2b46b84a 100755
--- a/mtproto.go
+++ b/mtproto.go
@@ -264,7 +264,7 @@ func (m *MTProto) CreateConnection(withLog bool) error {
 	ctx, cancelfunc := context.WithCancel(context.Background())
 	m.stopRoutines = cancelfunc
 	if withLog {
-		m.Logger.Info("Connecting to [" + m.Addr + "] - <TCPInterm> ...")
+		m.Logger.Info("Connecting to [" + m.Addr + "] - <TcpInt> ...")
 	}
 	err := m.connect(ctx)
 	if err != nil {
@@ -273,9 +273,9 @@ func (m *MTProto) CreateConnection(withLog bool) error {
 	m.tcpActive = true
 	if withLog {
 		if m.socksProxy != nil && m.socksProxy.Host != "" {
-			m.Logger.Info("Connection to (" + m.socksProxy.Host + ")[" + m.Addr + "] - <TCPInterm> established")
+			m.Logger.Info("Connection to (" + m.socksProxy.Host + ")[" + m.Addr + "] - <TcpInt> established")
 		} else {
-			m.Logger.Info("Connection to [" + m.Addr + "] - <TCPInterm> established")
+			m.Logger.Info("Connection to [" + m.Addr + "] - <TcpInt> established")
 		}
 	}
 	m.startReadingResponses(ctx)
@@ -318,7 +318,7 @@ func (m *MTProto) makeRequest(data tl.Object, expectedTypes ...reflect.Type) (an
 	resp, err := m.sendPacket(data, expectedTypes...)
 	if err != nil {
 		if strings.Contains(err.Error(), "use of closed network connection") || strings.Contains(err.Error(), "transport is closed") {
-			m.Logger.Info("connection closed due to broken pipe, reconnecting to [" + m.Addr + "]" + " - <TCPInterm> ...")
+			m.Logger.Info("connection closed due to broken pipe, reconnecting to [" + m.Addr + "]" + " - <TcpInt> ...")
 			err = m.Reconnect(false)
 			if err != nil {
 				return nil, errors.Wrap(err, "reconnecting")
@@ -367,7 +367,7 @@ func (m *MTProto) Disconnect() error {
 func (m *MTProto) Terminate() error {
 	m.stopRoutines()
 	m.responseChannels.Close()
-	m.Logger.Info("terminating connection to [" + m.Addr + "] - <TCPInterm> ...")
+	m.Logger.Info("terminating connection to [" + m.Addr + "] - <TcpInt> ...")
 	m.tcpActive = false
 	return nil
 }
@@ -378,12 +378,12 @@ func (m *MTProto) Reconnect(WithLogs bool) error {
 		return errors.Wrap(err, "disconnecting")
 	}
 	if WithLogs {
-		m.Logger.Info("Reconnecting to [" + m.Addr + "] - <TCPInterm> ...")
+		m.Logger.Info("Reconnecting to [" + m.Addr + "] - <TcpInt> ...")
 	}
 
 	err = m.CreateConnection(WithLogs)
 	if err == nil && WithLogs {
-		m.Logger.Info("Reconnected to [" + m.Addr + "] - <TCPInterm> ...")
+		m.Logger.Info("Reconnected to [" + m.Addr + "] - <TcpInt> ...")
 	}
 	m.InvokeRequestWithoutUpdate(&utils.PingParams{
 		PingID: 123456789,
@@ -417,13 +417,13 @@ func (m *MTProto) startReadingResponses(ctx context.Context) {
 
 				if err != nil {
 					if strings.Contains(err.Error(), "unexpected error: unexpected EOF") {
-						m.Logger.Debug("unexpected EOF, reconnecting to [" + m.Addr + "] - <TCPInterm> ...") // TODO: beautify this
+						m.Logger.Debug("unexpected EOF, reconnecting to [" + m.Addr + "] - <TcpInt> ...") // TODO: beautify this
 						err = m.Reconnect(false)
 						if err != nil {
 							m.Logger.Error(errors.Wrap(err, "reconnecting"))
 						}
 					} else if strings.Contains(err.Error(), "required to reconnect!") { // network is not stable
-						m.Logger.Debug("unstable connection, reconnecting to [" + m.Addr + "] - <TCPInterm> ...")
+						m.Logger.Debug("unstable connection, reconnecting to [" + m.Addr + "] - <TcpInt> ...")
 						err = m.Reconnect(false)
 						if err != nil {
 							m.Logger.Error(errors.Wrap(err, "reconnecting"))