Работая разработчиком в одной веб-студии, пришел клиент с довольно интересной работкой, ему нужен был агрегатор постов из чужих телеграм каналов, так как стек в компании был 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