ScuroNeko/mtg
1
0
Fork 0
mirror of https://github.com/ScuroNeko/mtg.git synced 2026-08-31 12:04:03 +03:00
Code Issues Packages Projects Releases Wiki Activity

Rename full path in order to favor modules

Browse Source
This commit is contained in:
9seconds
2019-11-11 15:09:29 +03:00
parent b491e03504
commit 273aa18367
53 changed files with 120 additions and 122 deletions
Download Patch File Download Diff File Expand all files Collapse all files
antireplay/init.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"math"
"sync"
"github.com/9seconds/mtg/config"
"mtg/config"
"github.com/dgraph-io/ristretto"
)
cli/generate.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"crypto/rand"
"encoding/hex"
"github.com/9seconds/mtg/config"
"mtg/config"
)
func Generate(secretType, hostname string) {
cli/proxy.go
+10 -10
View File
@@ -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
faketls/certificate_server.go
+1 -1
View File
@@ -13,7 +13,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/config"
"mtg/config"
)
type connectionServer struct {
faketls/client_protocol.go
+8 -8
View File
@@ -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 {
faketls/init.go
+1 -1
View File
@@ -6,7 +6,7 @@ import (
"sync"
"time"
"github.com/9seconds/mtg/config"
"mtg/config"
)
var (
go.mod
+2 -4
View File
@@ -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
hub/connection.go
+4 -4
View File
@@ -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 {
hub/connection_list.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"fmt"
"sort"
"github.com/9seconds/mtg/config"
"mtg/config"
)
type connectionList struct {
hub/hub.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"context"
"sync"
"github.com/9seconds/mtg/protocol"
"mtg/protocol"
)
type hub struct {
hub/interface.go
+1 -1
View File
@@ -1,6 +1,6 @@
package hub
import "github.com/9seconds/mtg/protocol"
import "mtg/protocol"
type Interface interface {
Register(*protocol.TelegramRequest) (*ProxyConn, error)
hub/mux.go
+2 -2
View File
@@ -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 {
hub/proxy_conn.go
+3 -3
View File
@@ -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 (
main.go
+3 -3
View File
@@ -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
mtproto/protocol.go
+6 -6
View File
@@ -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) {
mtproto/rpc/proxy_response.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"bytes"
"fmt"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type ProxyResponseType uint8
obfuscated2/client_protocol.go
+7 -7
View File
@@ -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
obfuscated2/telegram_protocol.go
+5 -5
View File
@@ -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) {
protocol/interfaces.go
+1 -1
View File
@@ -1,6 +1,6 @@
package protocol
import "github.com/9seconds/mtg/conntypes"
import "mtg/conntypes"
type ClientProtocol interface {
Handshake(conntypes.StreamReadWriteCloser) (conntypes.StreamReadWriteCloser, error)
protocol/request.go
+1 -1
View File
@@ -5,7 +5,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type TelegramRequest struct {
proxy/direct.go
+3 -3
View File
@@ -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
proxy/middle.go
+3 -3
View File
@@ -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) {
proxy/proxy.go
+6 -6
View File
@@ -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 {
stats/interfaces.go
+1 -1
View File
@@ -3,7 +3,7 @@ package stats
import (
"net"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type IngressTrafficInterface interface {
stats/multi_stats.go
+1 -1
View File
@@ -3,7 +3,7 @@ package stats
import (
"net"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type multiStats []Interface
stats/stats.go
+1 -1
View File
@@ -6,7 +6,7 @@ import (
"net"
"net/http"
"github.com/9seconds/mtg/config"
"mtg/config"
)
var Stats Interface
stats/stats_prometheus.go
+2 -2
View File
@@ -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 {
stats/stats_statsd.go
+2 -2
View File
@@ -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 {
telegram/api/addresses.go
+1 -1
View File
@@ -8,7 +8,7 @@ import (
"strconv"
"strings"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
const (
telegram/base.go
+3 -3
View File
@@ -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 {
telegram/direct.go
+1 -1
View File
@@ -1,6 +1,6 @@
package telegram
import "github.com/9seconds/mtg/conntypes"
import "mtg/conntypes"
const (
directV4DefaultIdx conntypes.DC = 1
telegram/interfaces.go
+1 -1
View File
@@ -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)
telegram/middle.go
+2 -2
View File
@@ -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
tlstypes/client_hello.go
+2 -2
View File
@@ -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 {
tlstypes/handshake.go
+1 -1
View File
@@ -3,7 +3,7 @@ package tlstypes
import (
"bytes"
"github.com/9seconds/mtg/utils"
"mtg/utils"
)
type Handshake struct {
tlstypes/server_hello.go
+1 -1
View File
@@ -9,7 +9,7 @@ import (
"golang.org/x/crypto/curve25519"
"github.com/9seconds/mtg/config"
"mtg/config"
)
type ServerHello struct {
utils/init_tcp.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"fmt"
"net"
"github.com/9seconds/mtg/config"
"mtg/config"
)
func InitTCP(conn net.Conn) error {
wrappers/packet/mtproto_frame.go
+1 -1
View File
@@ -12,7 +12,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
const (
wrappers/packetack/client_abridged.go
+2 -2
View File
@@ -8,8 +8,8 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"github.com/9seconds/mtg/utils"
"mtg/conntypes"
"mtg/utils"
)
const (
wrappers/packetack/client_intermediate.go
+1 -1
View File
@@ -9,7 +9,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
const clientIntermediateQuickAckLength = 0x80000000
wrappers/packetack/client_intermediate_secure.go
+1 -1
View File
@@ -8,7 +8,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type wrapperClientIntermediateSecure struct {
wrappers/packetack/proxy.go
+5 -5
View File
@@ -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 {
wrappers/stream/base.go
+1 -1
View File
@@ -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 {
wrappers/stream/blockcipher.go
+2 -2
View File
@@ -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 {
wrappers/stream/conn.go
+2 -2
View File
@@ -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
wrappers/stream/ctx.go
+1 -1
View File
@@ -8,7 +8,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type wrapperCtx struct {
wrappers/stream/faketls.go
+2 -2
View File
@@ -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 {
wrappers/stream/mtproto_cipher.go
+3 -3
View File
@@ -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
wrappers/stream/obfuscated2.go
+1 -1
View File
@@ -8,7 +8,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type wrapperObfuscated2 struct {
wrappers/stream/rewind.go
+1 -1
View File
@@ -9,7 +9,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
type ReadWriteCloseRewinder interface {
wrappers/stream/stats_telegram.go
+2 -2
View File
@@ -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 {
wrappers/stream/stats_traffic.go
+2 -2
View File
@@ -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 {
wrappers/stream/timeout.go
+1 -1
View File
@@ -6,7 +6,7 @@ import (
"go.uber.org/zap"
"github.com/9seconds/mtg/conntypes"
"mtg/conntypes"
)
const (