Telegram-клиент на Golang

Работая разработчиком в одной веб-студии, пришел клиент с довольно интересной работкой, ему нужен был агрегатор постов из чужих телеграм каналов, так как стек в компании был PHP то решили писать на нем, а конкретно на библиотеке MadelineProto о которой уже есть статья от крутого парня (более подробно об этой либе можете почитать в его статье), вот и началось мучительно создание этого сервиса…

Madeline в общей массе свой очень хорошо, полностью асинхронный и имет под капотом кучу методов для работы как с ботами так и с клиентом, но есть у него одна маленькая проблема (а может и не одна ¯\_(ツ)_/¯) , встроенный EventHandler получает не все новые сообщения из постов (и да я понимаю что есть getHistory, но если бы мы брали сообщения через этот метод, все вышло бы очень медленно работающим и высоконагруженным) Долгие часы и даже дни поиска решения этой проблемы не привели к желаемому результату, все так же процент постов которые пропускались именно Madeline был слишком большим.

Ок, было принято волевое решение забить на данную библиотеку и попробовать найти что-то другое на известном нам стеке, взгляд упал на go-tdlib. Развернули либу и поехали пыхтеть в разработку, и о чудо все посты собираются и все стало чудесно, за исключением одного но… Данная библиотека от пользователя Arman92 сильно отстает от офф методов tdlib и имеет внутри несколько логических ошибок, в общем начали у нас сыпаться паники и другие неприятные вещи. Так как пути назад уже не было, перебрали всю либу и обновили методы, а так же исправили ошибки автора.

Цель статьи — в первую очередь привлечь внимание к работе с телеграмм на Golang и рассказать про проблемы Madeline о которых нигде не узнать. Ну и соответственно приведу кусочек кода EventHandler’а для большей ясности.

func restoreSessions(client *tdlib.Client) { log.Println("<<<<<<<<<<<<<<<<<<<<<<<<<<RestoreSessionLog>>>>>>>>>>>>>>>>>>>>>>>>>>>>") rdb := redis.NewClient(&redis.Options{ Addr:     "redis:6379", Password: "", // no password set DB:       0,  // use default DB })  pong, err := rdb.Ping().Result() if err == nil { log.Println("1.Redis connections:" + pong + " - Redis ready") log.Println("1.1 redis connections successful") } log.Println("2. authorization client tdlib ") go func() { log.Println("2.1 timeout 6 sec") time.Sleep(6 * time.Second) currentState, err := client.Authorize() if err != nil { log.Println("2.2 err client authorization ") log.Println(err) } for ; currentState.GetAuthorizationStateEnum() != tdlib.AuthorizationStateReadyType; currentState, _ = client.Authorize() { time.Sleep(300 * time.Millisecond) }  eventFilter := func(msg *tdlib.TdMessage) bool { return true } log.Println("2.2 authorization client successful ") log.Println("2.3 get info session client ") //cid - ID юзера в тг user, err := client.GetMe() if err == nil { log.Println("2.4 get info session client successful") }else { log.Println("2.4 get info session client finished with error:") log.Println(err) } cid := user.ID  /** Выписываю редис лист, если что можно позырить записывает ли он */ log.Println("2.5 redis list for message:") log.Println("2.5 Redis List ---- " + "gotdlibMessage-" + strconv.Itoa(int(cid)) + " ---- Redis List")  receiver := client.AddEventReceiver(&tdlib.UpdateNewMessage{}, eventFilter, 5) log.Println("2.6 handle message") for newMsg := range receiver.Chan { updateMsg := (newMsg).(*tdlib.UpdateNewMessage)  if updateMsg.Message.Content.GetMessageContentEnum() == "messagePhoto" { log.Println("2.7 new message with type: messagePhoto") go messagePhoto(updateMsg, newMsg, rdb, cid,client) }  if updateMsg.Message.Content.GetMessageContentEnum() == "messageText" { log.Println("2.7 new message with type: messageText") go messageText(updateMsg, rdb, cid,client) }  if updateMsg.Message.Content.GetMessageContentEnum() == "messageVideo" { log.Println("2.7 new message with type: messageVideo") go messageVideo(updateMsg, rdb, cid,client) }  if updateMsg.Message.Content.GetMessageContentEnum() == "messageDocument" { log.Println("2.7 new message with type: messageDocument") go messageDocument(updateMsg, rdb, cid,client) } } }() } 

P.S: Доработанную и актуальную либу на 01.08.2021 (Может и дальше буду обновлять) вы можете взять у меня на гите — git