如何從Telegram API獲取最新/新消息

Question

我試圖從Telegram API（而不是bot API）獲取最新消息。我目前正在使用messages.getHistory，但它從頭開始返回所有消息。如果我收到新消息（自登錄以來）也可以。

到目前爲止，我最好的選擇是讀取所有消息，然後跟蹤偏移量，以免再次讀取相同的消息，但這太慢且資源昂貴。

Answer 1

從Telegram API獲取實時更新有一個更簡單的方法。

如果您將TCP連接設置爲非輪詢，那麼只要您的電報帳戶有更新，就會將消息推送給您。

這消除了你提到的成本，你根本沒有得到任何重複。

對於我的電報的客戶我已經通過簡單地在啓動時運行此成功做到了這一點：

TL.invokewithlayer(layer, TL.initconnection(app_id, device_model, system_version, app_version, lang_code, TL.help_getconfig)) 

然後，我只是從連接的TCP套接字處理傳入的數據，因爲它到達。

Answer 2

查爾斯的回答指出了我的正確方向。對於那些有興趣在Node.js的版本，我設法得到它的工作通過電報-Link模塊和設置connectionType到TCP：

var telegramLink = require('telegram.link')(); 

// set the environment 
var app = { 
    // NOTE: if you FORK the project you MUST use your APP ID. 
    // Otherwise YOUR APPLICATION WILL BE BLOCKED BY TELEGRAM 
    // You can obtain your own APP ID for your application here: https://my.telegram.org 
    id: 12345, 
    hash: 'somehashcode', 
    version: require('../package.json').version, 
    lang: 'en', 
    deviceModel: os.type().replace('Darwin', 'OS_X'), 
    systemVersion: os.platform() + '/' + os.release(), 
    connectionType: 'TCP' 
}; 

//var primaryDC = telegramLink.TEST_PRIMARY_DC; 
var primaryDC = telegramLink.PROD_PRIMARY_DC; 

... 

telegramLink.createClient(app, dataCenter, function() { 
... 

簡單點就是，將其更改爲TCP會給你想要的效果，你會得到消息的registerOnUpdates推到你：

clientProxy.getClient().account.updateStatus(false).then(function() { 
    clientProxy.getClient().registerOnUpdates(function(update) { 
     console.log('update', update.toPrintable()); 

     clientProxy.getClient().messages.receivedMessages(update.id, function(err) { console.log(err); }); 
    }); 
... 

注重receivedMessages - 如果你不叫這個做，那麼報文將無法收到任何新的更新。如果receivedMessages未在您的報文鏈接中定義，請將以下代碼添加到lib/api/messages.js中：

// *** 
// messages.**receivedMessages(max_id, [callback])** 

// Return a Promise to Confirms receipt of messages by a client, cancels PUSH-notification sending. 

// [Click here for more details](https://core.telegram.org/method/messages.receivedMessages) 
Messages.prototype.receivedMessages = function(max_id, callback) { 
    return utility.callService(api.service.messages.receivedMessages, this.client, this.client._channel, callback, arguments); 
};