|
@@ -458,6 +458,10 @@ export class TelegramClient extends TelegramBaseClient {
|
|
sender.dcId = dcId;
|
|
sender.dcId = dcId;
|
|
return sender;
|
|
return sender;
|
|
} catch (e) {
|
|
} catch (e) {
|
|
|
|
+ // we can't create sender for our own main DC
|
|
|
|
+ if (e.message=="DC_ID_INVALID"){
|
|
|
|
+ throw e;
|
|
|
|
+ }
|
|
await sender.disconnect();
|
|
await sender.disconnect();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -467,6 +471,7 @@ export class TelegramClient extends TelegramBaseClient {
|
|
async getDC(
|
|
async getDC(
|
|
dcId: number
|
|
dcId: number
|
|
): Promise<{ id: number; ipAddress: string; port: number }> {
|
|
): Promise<{ id: number; ipAddress: string; port: number }> {
|
|
|
|
+ this._log.debug(`Getting DC ${dcId}`);
|
|
if (!IS_NODE) {
|
|
if (!IS_NODE) {
|
|
switch (dcId) {
|
|
switch (dcId) {
|
|
case 1:
|
|
case 1:
|
|
@@ -525,6 +530,7 @@ export class TelegramClient extends TelegramBaseClient {
|
|
}
|
|
}
|
|
|
|
|
|
async _borrowExportedSender(dcId: number, retries = this._requestRetries) {
|
|
async _borrowExportedSender(dcId: number, retries = this._requestRetries) {
|
|
|
|
+ this._log.debug(`Borrowing client for DC ${dcId}`)
|
|
let senderPromise = this._borrowedSenderPromises[dcId];
|
|
let senderPromise = this._borrowedSenderPromises[dcId];
|
|
if (!senderPromise) {
|
|
if (!senderPromise) {
|
|
senderPromise = this._createExportedSender(dcId, retries);
|
|
senderPromise = this._createExportedSender(dcId, retries);
|