Highly-opinionated (ex-bullshit-free) MTPROTO proxy for Telegram. If you use v1.0 or upgrade broke you proxy, please read the chapter Version 2
您最多选择25个主题 主题必须以字母或数字开头,可以包含连字符 (-),并且长度不得超过35个字符

server_side.go 3.6KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. package fake
  2. import (
  3. "bytes"
  4. "crypto/hmac"
  5. "crypto/rand"
  6. "crypto/sha256"
  7. "encoding/binary"
  8. "io"
  9. "math"
  10. rnd "math/rand/v2"
  11. "github.com/9seconds/mtg/v2/mtglib/internal/doppel"
  12. "github.com/9seconds/mtg/v2/mtglib/internal/tls"
  13. "golang.org/x/crypto/curve25519"
  14. )
  15. const (
  16. TypeHandshakeServer = 0x02
  17. ChangeCipherValue = 0x01
  18. EllipticCurveLen = 32
  19. )
  20. var serverHelloSuffix = []byte{
  21. 0x00, // no compression
  22. 0x00, 0x2e, // 46 bytes of data
  23. 0x00, 0x2b, // Extension - Supported Versions
  24. 0x00, 0x02, // 2 bytes are following
  25. 0x03, 0x04, // TLS 1.3
  26. 0x00, 0x33, // Extension - Key Share
  27. 0x00, 0x24, // 36 bytes
  28. 0x00, 0x1d, // x25519 curve
  29. 0x00, 0x20, // 32 bytes of key
  30. }
  31. func SendServerHello(w io.Writer, secret []byte, clientHello *ClientHello) error {
  32. buf := &bytes.Buffer{}
  33. buf.Grow(tls.MaxRecordSize)
  34. generateServerHello(buf, clientHello)
  35. generateChangeCipherValue(buf)
  36. generateNoise(buf)
  37. packet := buf.Bytes()
  38. digest := hmac.New(sha256.New, secret)
  39. digest.Write(clientHello.Random[:])
  40. digest.Write(packet)
  41. copy(packet[RandomOffset:], digest.Sum(nil))
  42. _, err := w.Write(packet)
  43. return err
  44. }
  45. func generateServerHello(buf *bytes.Buffer, hello *ClientHello) {
  46. payload := acquireBuffer()
  47. defer releaseBuffer(payload)
  48. generateServerHelloPayload(payload, hello)
  49. // 16 - type is 0x16 (handshake record)
  50. // 03 03 - legacy protocol version of "3,3" (TLS 1.2)
  51. // 00 7a - 0x7A (122) bytes of handshake message follows
  52. // 16 - type is 0x16 (handshake record)
  53. buf.WriteByte(tls.TypeHandshake)
  54. // 03 03 - legacy protocol version of "3,3" (TLS 1.2)
  55. buf.Write(tls.TLSVersion[:])
  56. // 00 7a - 0x7A (122) bytes of handshake message follows
  57. binary.Write(buf, binary.BigEndian, uint16(payload.Len())) //nolint: errcheck
  58. payload.WriteTo(buf) //nolint: errcheck
  59. }
  60. func generateServerHelloPayload(buf *bytes.Buffer, hello *ClientHello) {
  61. data := [4]byte{}
  62. payload := acquireBuffer()
  63. defer releaseBuffer(payload)
  64. generateServerHelloHandshakePayload(payload, hello)
  65. // 02 - handshake message type 0x02 (server hello)
  66. // 00 00 76 - 0x76 (118) bytes of server hello data follows
  67. buf.WriteByte(TypeHandshakeServer)
  68. // 00 00 76 - 0x76 (118) bytes of server hello data follows
  69. binary.BigEndian.PutUint32(data[:], uint32(payload.Len()))
  70. buf.Write(data[1:])
  71. payload.WriteTo(buf) //nolint: errcheck
  72. }
  73. func generateServerHelloHandshakePayload(buf *bytes.Buffer, hello *ClientHello) {
  74. // The unusual version number ("3,3" representing TLS 1.2) is due to
  75. // TLS 1.0 being a minor revision of the SSL 3.0 protocol. Therefore
  76. // TLS 1.0 is represented by "3,1", TLS 1.1 is "3,2", and so on.
  77. buf.Write(tls.TLSVersion[:])
  78. buf.Write(emptyRandom[:])
  79. // 20 - 0x20 (32) bytes of session ID follow
  80. // e0 e1 ... fe ff - session ID copied from Client Hello
  81. buf.WriteByte(byte(len(hello.SessionID)))
  82. buf.Write(hello.SessionID)
  83. binary.Write(buf, binary.BigEndian, hello.CipherSuite) //nolint: errcheck
  84. buf.Write(serverHelloSuffix)
  85. scalar := [EllipticCurveLen]byte{}
  86. if _, err := rand.Read(scalar[:]); err != nil {
  87. panic(err)
  88. }
  89. curve, _ := curve25519.X25519(scalar[:], curve25519.Basepoint)
  90. buf.Write(curve)
  91. }
  92. func generateChangeCipherValue(buf *bytes.Buffer) {
  93. buf.WriteByte(tls.TypeChangeCipherSpec)
  94. buf.Write(tls.TLSVersion[:])
  95. binary.Write(buf, binary.BigEndian, uint16(1)) //nolint: errcheck
  96. buf.WriteByte(ChangeCipherValue)
  97. }
  98. func generateNoise(buf *bytes.Buffer) {
  99. minSize := int(math.Round(0.75 * float64(doppel.TLSRecordSizeMax)))
  100. data := make([]byte, minSize+rnd.IntN(doppel.TLSRecordSizeMax-minSize))
  101. if _, err := rand.Read(data[:]); err != nil {
  102. panic(err)
  103. }
  104. tls.WriteRecord(buf, data[:]) //nolint: errcheck
  105. }