diff --git a/antireplay/init.go b/antireplay/init.go index 5659ab7..9fab0d8 100644 --- a/antireplay/init.go +++ b/antireplay/init.go @@ -4,7 +4,7 @@ import ( "math" "sync" - "github.com/9seconds/mtg/config" + "mtg/config" "github.com/dgraph-io/ristretto" ) diff --git a/cli/generate.go b/cli/generate.go index 5811798..2d92321 100644 --- a/cli/generate.go +++ b/cli/generate.go @@ -4,7 +4,7 @@ import ( "crypto/rand" "encoding/hex" - "github.com/9seconds/mtg/config" + "mtg/config" ) func Generate(secretType, hostname string) { diff --git a/cli/proxy.go b/cli/proxy.go index 188dc68..1cda1a3 100644 --- a/cli/proxy.go +++ b/cli/proxy.go @@ -8,16 +8,16 @@ import ( "go.uber.org/zap" "go.uber.org/zap/zapcore" - "github.com/9seconds/mtg/antireplay" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/faketls" - "github.com/9seconds/mtg/hub" - "github.com/9seconds/mtg/ntp" - "github.com/9seconds/mtg/obfuscated2" - "github.com/9seconds/mtg/proxy" - "github.com/9seconds/mtg/stats" - "github.com/9seconds/mtg/telegram" - "github.com/9seconds/mtg/utils" + "mtg/antireplay" + "mtg/config" + "mtg/faketls" + "mtg/hub" + "mtg/ntp" + "mtg/obfuscated2" + "mtg/proxy" + "mtg/stats" + "mtg/telegram" + "mtg/utils" ) func Proxy() error { // nolint: funlen diff --git a/faketls/certificate_server.go b/faketls/certificate_server.go index e11e105..af0f100 100644 --- a/faketls/certificate_server.go +++ b/faketls/certificate_server.go @@ -13,7 +13,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/config" + "mtg/config" ) type connectionServer struct { diff --git a/faketls/client_protocol.go b/faketls/client_protocol.go index a0cb209..718350b 100644 --- a/faketls/client_protocol.go +++ b/faketls/client_protocol.go @@ -11,14 +11,14 @@ import ( "sync" "time" - "github.com/9seconds/mtg/antireplay" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/obfuscated2" - "github.com/9seconds/mtg/protocol" - "github.com/9seconds/mtg/stats" - "github.com/9seconds/mtg/tlstypes" - "github.com/9seconds/mtg/wrappers/stream" + "mtg/antireplay" + "mtg/config" + "mtg/conntypes" + "mtg/obfuscated2" + "mtg/protocol" + "mtg/stats" + "mtg/tlstypes" + "mtg/wrappers/stream" ) type ClientProtocol struct { diff --git a/faketls/init.go b/faketls/init.go index b3b6500..d2c8369 100644 --- a/faketls/init.go +++ b/faketls/init.go @@ -6,7 +6,7 @@ import ( "sync" "time" - "github.com/9seconds/mtg/config" + "mtg/config" ) var ( diff --git a/go.mod b/go.mod index cf4c180..a2f6aad 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ -module github.com/9seconds/mtg +module mtg -replace github.com/golang/lint => github.com/golang/lint v0.0.0-20190227174305-8f45f776aaf1 +go 1.13 require ( github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d @@ -16,5 +16,3 @@ require ( gopkg.in/alecthomas/kingpin.v2 v2.2.6 gopkg.in/alexcesaro/statsd.v2 v2.0.0 ) - -go 1.13 diff --git a/hub/connection.go b/hub/connection.go index 60ee738..1bb67c7 100644 --- a/hub/connection.go +++ b/hub/connection.go @@ -7,10 +7,10 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/mtproto" - "github.com/9seconds/mtg/mtproto/rpc" - "github.com/9seconds/mtg/protocol" + "mtg/conntypes" + "mtg/mtproto" + "mtg/mtproto/rpc" + "mtg/protocol" ) type connection struct { diff --git a/hub/connection_list.go b/hub/connection_list.go index 4a335bf..7acdde1 100644 --- a/hub/connection_list.go +++ b/hub/connection_list.go @@ -4,7 +4,7 @@ import ( "fmt" "sort" - "github.com/9seconds/mtg/config" + "mtg/config" ) type connectionList struct { diff --git a/hub/hub.go b/hub/hub.go index edfc442..fd291ec 100644 --- a/hub/hub.go +++ b/hub/hub.go @@ -4,7 +4,7 @@ import ( "context" "sync" - "github.com/9seconds/mtg/protocol" + "mtg/protocol" ) type hub struct { diff --git a/hub/interface.go b/hub/interface.go index a1efcdc..883c91e 100644 --- a/hub/interface.go +++ b/hub/interface.go @@ -1,6 +1,6 @@ package hub -import "github.com/9seconds/mtg/protocol" +import "mtg/protocol" type Interface interface { Register(*protocol.TelegramRequest) (*ProxyConn, error) diff --git a/hub/mux.go b/hub/mux.go index 0b60154..7263826 100644 --- a/hub/mux.go +++ b/hub/mux.go @@ -3,8 +3,8 @@ package hub import ( "context" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/protocol" + "mtg/conntypes" + "mtg/protocol" ) type muxNewRequest struct { diff --git a/hub/proxy_conn.go b/hub/proxy_conn.go index a3e4686..bbfa428 100644 --- a/hub/proxy_conn.go +++ b/hub/proxy_conn.go @@ -4,9 +4,9 @@ import ( "sync" "time" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/mtproto/rpc" - "github.com/9seconds/mtg/protocol" + "mtg/conntypes" + "mtg/mtproto/rpc" + "mtg/protocol" ) const ( diff --git a/main.go b/main.go index 400c110..6864153 100644 --- a/main.go +++ b/main.go @@ -7,9 +7,9 @@ import ( kingpin "gopkg.in/alecthomas/kingpin.v2" - "github.com/9seconds/mtg/cli" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/utils" + "mtg/cli" + "mtg/config" + "mtg/utils" ) var version = "dev" // this has to be set by build ld flags diff --git a/mtproto/protocol.go b/mtproto/protocol.go index b7dae2e..3dfdda4 100644 --- a/mtproto/protocol.go +++ b/mtproto/protocol.go @@ -3,12 +3,12 @@ package mtproto import ( "fmt" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/mtproto/rpc" - "github.com/9seconds/mtg/protocol" - "github.com/9seconds/mtg/telegram" - "github.com/9seconds/mtg/wrappers/packet" - "github.com/9seconds/mtg/wrappers/stream" + "mtg/conntypes" + "mtg/mtproto/rpc" + "mtg/protocol" + "mtg/telegram" + "mtg/wrappers/packet" + "mtg/wrappers/stream" ) func TelegramProtocol(req *protocol.TelegramRequest) (conntypes.PacketReadWriteCloser, error) { diff --git a/mtproto/rpc/proxy_response.go b/mtproto/rpc/proxy_response.go index 5366f34..8132d67 100644 --- a/mtproto/rpc/proxy_response.go +++ b/mtproto/rpc/proxy_response.go @@ -4,7 +4,7 @@ import ( "bytes" "fmt" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type ProxyResponseType uint8 diff --git a/obfuscated2/client_protocol.go b/obfuscated2/client_protocol.go index d85387c..3d8b6f9 100644 --- a/obfuscated2/client_protocol.go +++ b/obfuscated2/client_protocol.go @@ -9,13 +9,13 @@ import ( "io" "time" - "github.com/9seconds/mtg/antireplay" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/protocol" - "github.com/9seconds/mtg/stats" - "github.com/9seconds/mtg/utils" - "github.com/9seconds/mtg/wrappers/stream" + "mtg/antireplay" + "mtg/config" + "mtg/conntypes" + "mtg/protocol" + "mtg/stats" + "mtg/utils" + "mtg/wrappers/stream" ) const clientProtocolHandshakeTimeout = 10 * time.Second diff --git a/obfuscated2/telegram_protocol.go b/obfuscated2/telegram_protocol.go index cf17099..34ec469 100644 --- a/obfuscated2/telegram_protocol.go +++ b/obfuscated2/telegram_protocol.go @@ -4,11 +4,11 @@ import ( "crypto/rand" "fmt" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/protocol" - "github.com/9seconds/mtg/telegram" - "github.com/9seconds/mtg/utils" - "github.com/9seconds/mtg/wrappers/stream" + "mtg/conntypes" + "mtg/protocol" + "mtg/telegram" + "mtg/utils" + "mtg/wrappers/stream" ) func TelegramProtocol(req *protocol.TelegramRequest) (conntypes.StreamReadWriteCloser, error) { diff --git a/protocol/interfaces.go b/protocol/interfaces.go index 2e27fc3..bd44ce8 100644 --- a/protocol/interfaces.go +++ b/protocol/interfaces.go @@ -1,6 +1,6 @@ package protocol -import "github.com/9seconds/mtg/conntypes" +import "mtg/conntypes" type ClientProtocol interface { Handshake(conntypes.StreamReadWriteCloser) (conntypes.StreamReadWriteCloser, error) diff --git a/protocol/request.go b/protocol/request.go index 00a33f8..8db368a 100644 --- a/protocol/request.go +++ b/protocol/request.go @@ -5,7 +5,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type TelegramRequest struct { diff --git a/proxy/direct.go b/proxy/direct.go index 7067cbb..e4b5683 100644 --- a/proxy/direct.go +++ b/proxy/direct.go @@ -6,9 +6,9 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/obfuscated2" - "github.com/9seconds/mtg/protocol" + "mtg/conntypes" + "mtg/obfuscated2" + "mtg/protocol" ) const directPipeBufferSize = 1024 * 1024 diff --git a/proxy/middle.go b/proxy/middle.go index c0995dc..97262ec 100644 --- a/proxy/middle.go +++ b/proxy/middle.go @@ -5,9 +5,9 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/protocol" - "github.com/9seconds/mtg/wrappers/packetack" + "mtg/conntypes" + "mtg/protocol" + "mtg/wrappers/packetack" ) func middleConnection(request *protocol.TelegramRequest) { diff --git a/proxy/proxy.go b/proxy/proxy.go index 809482e..4c800dd 100644 --- a/proxy/proxy.go +++ b/proxy/proxy.go @@ -6,12 +6,12 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/protocol" - "github.com/9seconds/mtg/stats" - "github.com/9seconds/mtg/utils" - "github.com/9seconds/mtg/wrappers/stream" + "mtg/config" + "mtg/conntypes" + "mtg/protocol" + "mtg/stats" + "mtg/utils" + "mtg/wrappers/stream" ) type Proxy struct { diff --git a/stats/interfaces.go b/stats/interfaces.go index 0672982..345bdaa 100644 --- a/stats/interfaces.go +++ b/stats/interfaces.go @@ -3,7 +3,7 @@ package stats import ( "net" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type IngressTrafficInterface interface { diff --git a/stats/multi_stats.go b/stats/multi_stats.go index f87ee75..e7728d3 100644 --- a/stats/multi_stats.go +++ b/stats/multi_stats.go @@ -3,7 +3,7 @@ package stats import ( "net" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type multiStats []Interface diff --git a/stats/stats.go b/stats/stats.go index 044e704..b4ccad7 100644 --- a/stats/stats.go +++ b/stats/stats.go @@ -6,7 +6,7 @@ import ( "net" "net/http" - "github.com/9seconds/mtg/config" + "mtg/config" ) var Stats Interface diff --git a/stats/stats_prometheus.go b/stats/stats_prometheus.go index e2cefb2..509f864 100644 --- a/stats/stats_prometheus.go +++ b/stats/stats_prometheus.go @@ -9,8 +9,8 @@ import ( "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" + "mtg/config" + "mtg/conntypes" ) type statsPrometheus struct { diff --git a/stats/stats_statsd.go b/stats/stats_statsd.go index e6baa5d..0261f0b 100644 --- a/stats/stats_statsd.go +++ b/stats/stats_statsd.go @@ -8,8 +8,8 @@ import ( "gopkg.in/alexcesaro/statsd.v2" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" + "mtg/config" + "mtg/conntypes" ) type statsStatsd struct { diff --git a/telegram/api/addresses.go b/telegram/api/addresses.go index c7573e4..bbb2116 100644 --- a/telegram/api/addresses.go +++ b/telegram/api/addresses.go @@ -8,7 +8,7 @@ import ( "strconv" "strings" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) const ( diff --git a/telegram/base.go b/telegram/base.go index 51cfd42..f4cf3ff 100644 --- a/telegram/base.go +++ b/telegram/base.go @@ -5,9 +5,9 @@ import ( "math/rand" "net" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/utils" - "github.com/9seconds/mtg/wrappers/stream" + "mtg/conntypes" + "mtg/utils" + "mtg/wrappers/stream" ) type baseTelegram struct { diff --git a/telegram/direct.go b/telegram/direct.go index 3810c9a..8fc0b48 100644 --- a/telegram/direct.go +++ b/telegram/direct.go @@ -1,6 +1,6 @@ package telegram -import "github.com/9seconds/mtg/conntypes" +import "mtg/conntypes" const ( directV4DefaultIdx conntypes.DC = 1 diff --git a/telegram/interfaces.go b/telegram/interfaces.go index e419b8b..f6008c2 100644 --- a/telegram/interfaces.go +++ b/telegram/interfaces.go @@ -1,6 +1,6 @@ package telegram -import "github.com/9seconds/mtg/conntypes" +import "mtg/conntypes" type Telegram interface { Dial(conntypes.DC, conntypes.ConnectionProtocol) (conntypes.StreamReadWriteCloser, error) diff --git a/telegram/middle.go b/telegram/middle.go index 519332e..3464489 100644 --- a/telegram/middle.go +++ b/telegram/middle.go @@ -7,8 +7,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/telegram/api" + "mtg/conntypes" + "mtg/telegram/api" ) const middleTelegramBackgroundUpdateEvery = time.Hour diff --git a/tlstypes/client_hello.go b/tlstypes/client_hello.go index dbdcde4..deef64a 100644 --- a/tlstypes/client_hello.go +++ b/tlstypes/client_hello.go @@ -6,8 +6,8 @@ import ( "crypto/sha256" "fmt" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/utils" + "mtg/config" + "mtg/utils" ) type ClientHello struct { diff --git a/tlstypes/handshake.go b/tlstypes/handshake.go index ec0accf..6afe0ba 100644 --- a/tlstypes/handshake.go +++ b/tlstypes/handshake.go @@ -3,7 +3,7 @@ package tlstypes import ( "bytes" - "github.com/9seconds/mtg/utils" + "mtg/utils" ) type Handshake struct { diff --git a/tlstypes/server_hello.go b/tlstypes/server_hello.go index b233d29..e2dd739 100644 --- a/tlstypes/server_hello.go +++ b/tlstypes/server_hello.go @@ -9,7 +9,7 @@ import ( "golang.org/x/crypto/curve25519" - "github.com/9seconds/mtg/config" + "mtg/config" ) type ServerHello struct { diff --git a/utils/init_tcp.go b/utils/init_tcp.go index 3bf90ca..d59b281 100644 --- a/utils/init_tcp.go +++ b/utils/init_tcp.go @@ -4,7 +4,7 @@ import ( "fmt" "net" - "github.com/9seconds/mtg/config" + "mtg/config" ) func InitTCP(conn net.Conn) error { diff --git a/wrappers/packet/mtproto_frame.go b/wrappers/packet/mtproto_frame.go index 6a1cd1a..34553d3 100644 --- a/wrappers/packet/mtproto_frame.go +++ b/wrappers/packet/mtproto_frame.go @@ -12,7 +12,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) const ( diff --git a/wrappers/packetack/client_abridged.go b/wrappers/packetack/client_abridged.go index 1b8aa9a..1c7a94c 100644 --- a/wrappers/packetack/client_abridged.go +++ b/wrappers/packetack/client_abridged.go @@ -8,8 +8,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/utils" + "mtg/conntypes" + "mtg/utils" ) const ( diff --git a/wrappers/packetack/client_intermediate.go b/wrappers/packetack/client_intermediate.go index 71ca5f5..d454147 100644 --- a/wrappers/packetack/client_intermediate.go +++ b/wrappers/packetack/client_intermediate.go @@ -9,7 +9,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) const clientIntermediateQuickAckLength = 0x80000000 diff --git a/wrappers/packetack/client_intermediate_secure.go b/wrappers/packetack/client_intermediate_secure.go index 153e779..85a9888 100644 --- a/wrappers/packetack/client_intermediate_secure.go +++ b/wrappers/packetack/client_intermediate_secure.go @@ -8,7 +8,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type wrapperClientIntermediateSecure struct { diff --git a/wrappers/packetack/proxy.go b/wrappers/packetack/proxy.go index 62ac7d2..6129615 100644 --- a/wrappers/packetack/proxy.go +++ b/wrappers/packetack/proxy.go @@ -6,11 +6,11 @@ import ( "fmt" "net" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/hub" - "github.com/9seconds/mtg/mtproto/rpc" - "github.com/9seconds/mtg/protocol" + "mtg/config" + "mtg/conntypes" + "mtg/hub" + "mtg/mtproto/rpc" + "mtg/protocol" ) type wrapperProxy struct { diff --git a/wrappers/stream/base.go b/wrappers/stream/base.go index 0fd50ca..3780ebd 100644 --- a/wrappers/stream/base.go +++ b/wrappers/stream/base.go @@ -3,7 +3,7 @@ package stream import ( "net" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) func NewClientConn(parent net.Conn, connID conntypes.ConnID) conntypes.StreamReadWriteCloser { diff --git a/wrappers/stream/blockcipher.go b/wrappers/stream/blockcipher.go index 3fc7a40..a5463b9 100644 --- a/wrappers/stream/blockcipher.go +++ b/wrappers/stream/blockcipher.go @@ -9,8 +9,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/utils" + "mtg/conntypes" + "mtg/utils" ) type wrapperBlockCipher struct { diff --git a/wrappers/stream/conn.go b/wrappers/stream/conn.go index 8b0bf80..fc85e3f 100644 --- a/wrappers/stream/conn.go +++ b/wrappers/stream/conn.go @@ -7,8 +7,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/config" - "github.com/9seconds/mtg/conntypes" + "mtg/config" + "mtg/conntypes" ) type connPurpose uint8 diff --git a/wrappers/stream/ctx.go b/wrappers/stream/ctx.go index c744062..3a89677 100644 --- a/wrappers/stream/ctx.go +++ b/wrappers/stream/ctx.go @@ -8,7 +8,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type wrapperCtx struct { diff --git a/wrappers/stream/faketls.go b/wrappers/stream/faketls.go index 3db845b..10ef688 100644 --- a/wrappers/stream/faketls.go +++ b/wrappers/stream/faketls.go @@ -8,8 +8,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/tlstypes" + "mtg/conntypes" + "mtg/tlstypes" ) type wrapperFakeTLS struct { diff --git a/wrappers/stream/mtproto_cipher.go b/wrappers/stream/mtproto_cipher.go index a46b528..350dbbb 100644 --- a/wrappers/stream/mtproto_cipher.go +++ b/wrappers/stream/mtproto_cipher.go @@ -9,9 +9,9 @@ import ( "encoding/binary" "net" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/mtproto/rpc" - "github.com/9seconds/mtg/utils" + "mtg/conntypes" + "mtg/mtproto/rpc" + "mtg/utils" ) type mtprotoCipherPurpose uint8 diff --git a/wrappers/stream/obfuscated2.go b/wrappers/stream/obfuscated2.go index d94b245..0368a2b 100644 --- a/wrappers/stream/obfuscated2.go +++ b/wrappers/stream/obfuscated2.go @@ -8,7 +8,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type wrapperObfuscated2 struct { diff --git a/wrappers/stream/rewind.go b/wrappers/stream/rewind.go index 1170d9d..1472012 100644 --- a/wrappers/stream/rewind.go +++ b/wrappers/stream/rewind.go @@ -9,7 +9,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) type ReadWriteCloseRewinder interface { diff --git a/wrappers/stream/stats_telegram.go b/wrappers/stream/stats_telegram.go index 064790c..3eceafa 100644 --- a/wrappers/stream/stats_telegram.go +++ b/wrappers/stream/stats_telegram.go @@ -7,8 +7,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/stats" + "mtg/conntypes" + "mtg/stats" ) type wrapperTelegramStats struct { diff --git a/wrappers/stream/stats_traffic.go b/wrappers/stream/stats_traffic.go index 911daa2..90ed926 100644 --- a/wrappers/stream/stats_traffic.go +++ b/wrappers/stream/stats_traffic.go @@ -6,8 +6,8 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" - "github.com/9seconds/mtg/stats" + "mtg/conntypes" + "mtg/stats" ) type wrapperTrafficStats struct { diff --git a/wrappers/stream/timeout.go b/wrappers/stream/timeout.go index 6dee072..ce35675 100644 --- a/wrappers/stream/timeout.go +++ b/wrappers/stream/timeout.go @@ -6,7 +6,7 @@ import ( "go.uber.org/zap" - "github.com/9seconds/mtg/conntypes" + "mtg/conntypes" ) const (