Skip to content

Commit

Permalink
remove unsupport services
Browse files Browse the repository at this point in the history
  • Loading branch information
@wubenqi
wubenqi committed Apr 7, 2022
1 parent d1b0b0b commit aa7b37f
Show file tree
Hide file tree
Showing 214 changed files with 311 additions and 8,453 deletions.
2 changes: 2 additions & 0 deletions .gitignore
View file
Original file line number Diff line number Diff line change
Expand Up @@ -62,3 +62,5 @@ Thumbs.db
/teamgramd/logs/status/
/teamgramd/bin/GeoLite2-City.mmdb
/teamgramd/bin/GeoLite2-Country.mmdb
/teamgramd/logs/dfs/
/teamgramd/logs/sync/
10 changes: 7 additions & 3 deletions app/bff/bff/client/bff_proxy_client.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -68,8 +68,8 @@ func (c *BFFProxyClient) GetRpcClientByRequest(t interface{}) (zrpc.Client, erro
if c2, ok := c.BFFClients[rt.Name()]; ok {
return c2, nil
} else {
logx.Errorf("not found method: %s", rt.Name())
logx.Errorf("%s blocked, License key from https://teamgram.net required to unlock enterprise features.", rt.Name())
// logx.Errorf("not found method: %s", rt.Name())
// logx.Errorf("%s blocked, License key from https://teamgram.net required to unlock enterprise features.", rt.Name())
}

// TODO(@benqi):
Expand All @@ -81,7 +81,11 @@ func (c *BFFProxyClient) GetRpcClientByRequest(t interface{}) (zrpc.Client, erro
func (c *BFFProxyClient) Invoke(rpcMetaData *metadata.RpcMetadata, object mtproto.TLObject) (mtproto.TLObject, error) {
conn, err := c.GetRpcClientByRequest(object)
if err != nil {
return nil, err
r, err2 := c.TryReturnFakeRpcResult(object)
if err2 != nil {
return nil, mtproto.NewRpcError(status.Convert(err2))
}
return r, nil
}

t := mtproto.FindRPCContextTuple(object)
Expand Down
215 changes: 215 additions & 0 deletions app/bff/bff/client/fake_rpc_result.go
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,215 @@
// Copyright 2022 Teamgram Authors
// All rights reserved.
//
// Author: Benqi ([email protected])
//

package bff_proxy_client

import (
"github.com/teamgram/proto/mtproto"
"github.com/teamgram/proto/mtproto/crypto"
"github.com/zeromicro/go-zero/core/logx"
"reflect"
"time"
)

var (
gNewAlgoSalt1 = []byte{0xEC, 0xF8, 0x73, 0x76, 0x65, 0xBC, 0x77, 0x5A}
gNewAlgoSalt2 = []byte{0xBE, 0xDE, 0x48, 0x88, 0x8C, 0x0F, 0x42, 0xAC, 0x34, 0xFF, 0xD1, 0xD4, 0x93, 0x5D, 0x8B, 0x21}

gNewAlgoP = []byte{
0xc7, 0x1c, 0xae, 0xb9, 0xc6, 0xb1, 0xc9, 0x04, 0x8e, 0x6c, 0x52, 0x2f,
0x70, 0xf1, 0x3f, 0x73, 0x98, 0x0d, 0x40, 0x23, 0x8e, 0x3e, 0x21, 0xc1,
0x49, 0x34, 0xd0, 0x37, 0x56, 0x3d, 0x93, 0x0f, 0x48, 0x19, 0x8a, 0x0a,
0xa7, 0xc1, 0x40, 0x58, 0x22, 0x94, 0x93, 0xd2, 0x25, 0x30, 0xf4, 0xdb,
0xfa, 0x33, 0x6f, 0x6e, 0x0a, 0xc9, 0x25, 0x13, 0x95, 0x43, 0xae, 0xd4,
0x4c, 0xce, 0x7c, 0x37, 0x20, 0xfd, 0x51, 0xf6, 0x94, 0x58, 0x70, 0x5a,
0xc6, 0x8c, 0xd4, 0xfe, 0x6b, 0x6b, 0x13, 0xab, 0xdc, 0x97, 0x46, 0x51,
0x29, 0x69, 0x32, 0x84, 0x54, 0xf1, 0x8f, 0xaf, 0x8c, 0x59, 0x5f, 0x64,
0x24, 0x77, 0xfe, 0x96, 0xbb, 0x2a, 0x94, 0x1d, 0x5b, 0xcd, 0x1d, 0x4a,
0xc8, 0xcc, 0x49, 0x88, 0x07, 0x08, 0xfa, 0x9b, 0x37, 0x8e, 0x3c, 0x4f,
0x3a, 0x90, 0x60, 0xbe, 0xe6, 0x7c, 0xf9, 0xa4, 0xa4, 0xa6, 0x95, 0x81,
0x10, 0x51, 0x90, 0x7e, 0x16, 0x27, 0x53, 0xb5, 0x6b, 0x0f, 0x6b, 0x41,
0x0d, 0xba, 0x74, 0xd8, 0xa8, 0x4b, 0x2a, 0x14, 0xb3, 0x14, 0x4e, 0x0e,
0xf1, 0x28, 0x47, 0x54, 0xfd, 0x17, 0xed, 0x95, 0x0d, 0x59, 0x65, 0xb4,
0xb9, 0xdd, 0x46, 0x58, 0x2d, 0xb1, 0x17, 0x8d, 0x16, 0x9c, 0x6b, 0xc4,
0x65, 0xb0, 0xd6, 0xff, 0x9c, 0xa3, 0x92, 0x8f, 0xef, 0x5b, 0x9a, 0xe4,
0xe4, 0x18, 0xfc, 0x15, 0xe8, 0x3e, 0xbe, 0xa0, 0xf8, 0x7f, 0xa9, 0xff,
0x5e, 0xed, 0x70, 0x05, 0x0d, 0xed, 0x28, 0x49, 0xf4, 0x7b, 0xf9, 0x59,
0xd9, 0x56, 0x85, 0x0c, 0xe9, 0x29, 0x85, 0x1f, 0x0d, 0x81, 0x15, 0xf6,
0x35, 0xb1, 0x05, 0xee, 0x2e, 0x4e, 0x15, 0xd0, 0x4b, 0x24, 0x54, 0xbf,
0x6f, 0x4f, 0xad, 0xf0, 0x34, 0xb1, 0x04, 0x03, 0x11, 0x9c, 0xd8, 0xe3,
0xb9, 0x2f, 0xcc, 0x5b,
}

gNewAlgoG = int32(3)

// salt: 7D 04 B3 4B 94 82 8C 3D [8 BYTES],
gNewSecureAlgoSalt = []byte{0x7D, 0x04, 0xB3, 0x4B, 0x94, 0x82, 0x8C, 0x3D}
)

var (
gNewAlgo *mtproto.PasswordKdfAlgo
gNewSecureAlgo *mtproto.SecurePasswordKdfAlgo
)

func init() {
gNewAlgo = mtproto.MakeTLPasswordKdfAlgoModPow(&mtproto.PasswordKdfAlgo{
Salt1: gNewAlgoSalt1,
Salt2: gNewAlgoSalt2,
G: gNewAlgoG,
P: gNewAlgoP,
}).To_PasswordKdfAlgo()

gNewSecureAlgo = mtproto.MakeTLSecurePasswordKdfAlgoPBKDF2(&mtproto.SecurePasswordKdfAlgo{
Salt: gNewSecureAlgoSalt,
}).To_SecurePasswordKdfAlgo()
}

func (c *BFFProxyClient) TryReturnFakeRpcResult(object mtproto.TLObject) (mtproto.TLObject, error) {
rt := reflect.TypeOf(object)
if rt.Kind() == reflect.Ptr {
rt = rt.Elem()
}

switch rt.Name() {
// langpack
case "TLLangpackGetDifference":
in := object.(*mtproto.TLLangpackGetDifference)
return mtproto.MakeTLLangPackDifference(&mtproto.LangPackDifference{
LangCode: in.GetLangCode(),
FromVersion: in.GetFromVersion(),
Version: in.GetFromVersion(),
Strings: []*mtproto.LangPackString{},
}).To_LangPackDifference(), nil
case "TLLangpackGetLangPack":
in := object.(*mtproto.TLLangpackGetLangPack)
return mtproto.MakeTLLangPackDifference(&mtproto.LangPackDifference{
LangCode: in.GetLangCode(),
FromVersion: 0,
Version: 0,
Strings: []*mtproto.LangPackString{},
}).To_LangPackDifference(), nil
case "TLLangpackGetLanguages":
return &mtproto.Vector_LangPackLanguage{
Datas: []*mtproto.LangPackLanguage{},
}, nil
case "TLLangpackGetStrings":
return &mtproto.Vector_LangPackString{
Datas: []*mtproto.LangPackString{},
}, nil

// webpage
case "TLMessagesGetWebPage":
return mtproto.MakeTLWebPageEmpty(&mtproto.WebPage{
Id: 0,
}).To_WebPage(), nil
case "TLMessagesGetWebPageView":
return mtproto.MakeTLMessageMediaEmpty(&mtproto.MessageMedia{
//
}).To_MessageMedia(), nil

// wallpaper
case "TLAccountGetWallPapers":
return mtproto.MakeTLAccountWallPapers(&mtproto.Account_WallPapers{
Hash: 0,
Wallpapers: []*mtproto.WallPaper{},
}).To_Account_WallPapers(), nil

// twofa
case "TLAccountGetPassword":
return mtproto.MakeTLAccountPassword(&mtproto.Account_Password{
HasRecovery: false,
HasSecureValues: false,
HasPassword: false,
CurrentAlgo: nil,
Srp_B: nil,
SrpId: nil,
Hint: nil,
EmailUnconfirmedPattern: nil,
NewAlgo: gNewAlgo,
NewSecureAlgo: gNewSecureAlgo,
SecureRandom: crypto.RandomBytes(256),
}).To_Account_Password(), nil

// tos
case "TLHelpAcceptTermsOfService":
return mtproto.BoolTrue, nil
case "TLHelpGetTermsOfServiceUpdate":
return mtproto.MakeTLHelpTermsOfServiceUpdateEmpty(&mtproto.Help_TermsOfServiceUpdate{
Expires: int32(time.Now().Unix() + 3600),
}).To_Help_TermsOfServiceUpdate(), nil

// themes
case "TLAccountGetThemes":
return mtproto.MakeTLAccountThemes(&mtproto.Account_Themes{
Hash: 0,
Themes: []*mtproto.Theme{},
}).To_Account_Themes(), nil

// stickers
case "TLMessagesGetAllStickers":
return mtproto.MakeTLMessagesAllStickers(&mtproto.Messages_AllStickers{
Hash: 0,
Sets: []*mtproto.StickerSet{},
}).To_Messages_AllStickers(), nil
case "TLMessagesGetArchivedStickers":
return mtproto.MakeTLMessagesArchivedStickers(&mtproto.Messages_ArchivedStickers{
Count: 0,
Sets: []*mtproto.StickerSetCovered{},
}).To_Messages_ArchivedStickers(), nil
case "TLMessagesGetFavedStickers":
return mtproto.MakeTLMessagesFavedStickers(&mtproto.Messages_FavedStickers{
Hash: 0,
Packs: []*mtproto.StickerPack{},
Stickers: []*mtproto.Document{},
}).To_Messages_FavedStickers(), nil
case "TLMessagesGetMaskStickers":
return mtproto.MakeTLMessagesAllStickers(&mtproto.Messages_AllStickers{
Hash: 0,
Sets: []*mtproto.StickerSet{},
}).To_Messages_AllStickers(), nil
case "TLMessagesGetOldFeaturedStickers":
return mtproto.MakeTLMessagesFeaturedStickers(&mtproto.Messages_FeaturedStickers{
Count: 0,
Hash: 0,
Sets: []*mtproto.StickerSetCovered{},
Unread: []int64{},
}).To_Messages_FeaturedStickers(), nil
case "TLMessagesGetRecentStickers":
return mtproto.MakeTLMessagesRecentStickers(&mtproto.Messages_RecentStickers{
Hash: 0,
Packs: []*mtproto.StickerPack{},
Stickers: []*mtproto.Document{},
Dates: []int32{},
}).To_Messages_RecentStickers(), nil
case "TLMessagesGetStickers":
return mtproto.MakeTLMessagesStickers(&mtproto.Messages_Stickers{
Hash: 0,
Stickers: []*mtproto.Document{},
}).To_Messages_Stickers(), nil

// scheduledmessages
case "TLMessagesGetScheduledMessages":
return mtproto.MakeTLMessagesMessages(&mtproto.Messages_Messages{
Messages: []*mtproto.Message{},
Chats: []*mtproto.Chat{},
Users: []*mtproto.User{},
}).To_Messages_Messages(), nil

case "TLMessagesGetAvailableReactions":
return mtproto.MakeTLMessagesAvailableReactions(&mtproto.Messages_AvailableReactions{
Hash: 0,
Reactions: []*mtproto.AvailableReaction{},
}).To_Messages_AvailableReactions(), nil

case "TLMessagesGetDialogFilters":
return &mtproto.Vector_DialogFilter{
Datas: []*mtproto.DialogFilter{},
}, nil
}

logx.Errorf("%s blocked, License key from https://teamgram.net required to unlock enterprise features.", rt.Name())
return nil, mtproto.ErrEnterpriseIsBlocked
}
Loading

0 comments on commit aa7b37f

Please sign in to comment.