Browse Source

Run eslint --fix

Andrew Lane 4 years ago
parent
commit
792a6f4cf5

+ 28 - 28
examples/betterLogging.js

@@ -1,38 +1,38 @@
 rewireLoggingToElement(
-  () => document.getElementById("log"),
-  () => document.getElementById("log-container"),
-  true
-);
+    () => document.getElementById('log'),
+    () => document.getElementById('log-container'),
+    true,
+)
 
 function rewireLoggingToElement(eleLocator, eleOverflowLocator, autoScroll) {
-  fixLoggingFunc("log");
+    fixLoggingFunc('log')
 
-  function fixLoggingFunc(name) {
-      console.old = console.log
-    console.log = function(...arg) {
-      const output = produceOutput(name, arg);
-      const eleLog = eleLocator();
+    function fixLoggingFunc(name) {
+        console.old = console.log
+        console.log = function(...arg) {
+            const output = produceOutput(name, arg)
+            const eleLog = eleLocator()
 
-      if (autoScroll) {
-        const eleContainerLog = eleOverflowLocator();
-        const isScrolledToBottom =
+            if (autoScroll) {
+                const eleContainerLog = eleOverflowLocator()
+                const isScrolledToBottom =
           eleContainerLog.scrollHeight - eleContainerLog.clientHeight <=
-          eleContainerLog.scrollTop + 1;
-        eleLog.innerHTML += output + "<br>";
-        if (isScrolledToBottom) {
-          eleContainerLog.scrollTop =
-            eleContainerLog.scrollHeight - eleContainerLog.clientHeight;
-        }
-      } else {
-        eleLog.innerHTML += output + "<br>";
-      }
+          eleContainerLog.scrollTop + 1
+                eleLog.innerHTML += output + '<br>'
+                if (isScrolledToBottom) {
+                    eleContainerLog.scrollTop =
+            eleContainerLog.scrollHeight - eleContainerLog.clientHeight
+                }
+            } else {
+                eleLog.innerHTML += output + '<br>'
+            }
 
-    };
-  }
+        }
+    }
 
-  function produceOutput(name, args) {
-      arg =  args[0].replace("%c","")
-    return '<span style="'+ args[1]+'">'+arg+"</span>&nbsp;"
+    function produceOutput(name, args) {
+        arg =  args[0].replace('%c','')
+        return '<span style="'+ args[1]+'">'+arg+'</span>&nbsp;'
     
-  }
+    }
 }

+ 7 - 7
gramjs/Helpers.js

@@ -1,4 +1,4 @@
-const { isBrowser, isNode } = require("browser-or-node" );
+const { isBrowser, isNode } = require('browser-or-node' )
 
 const BigInt = require('big-integer')
 const IS_NODE = isNode
@@ -176,23 +176,23 @@ async function generateKeyDataFromNonce(serverNonce, newNonce) {
     const [hash1, hash2, hash3] = await Promise.all([
         sha1(Buffer.concat([newNonce, serverNonce])),
         sha1(Buffer.concat([serverNonce, newNonce])),
-        sha1(Buffer.concat([newNonce, newNonce]))
+        sha1(Buffer.concat([newNonce, newNonce])),
     ])
     const keyBuffer = Buffer.concat([hash1, hash2.slice(0, 12)])
     const ivBuffer = Buffer.concat([hash2.slice(12, 20), hash3, newNonce.slice(0, 4)])
     return {
         key: keyBuffer,
-        iv: ivBuffer
+        iv: ivBuffer,
     }
 }
 
 function convertToLittle(buf) {
-    const correct = Buffer.alloc(buf.length * 4);
+    const correct = Buffer.alloc(buf.length * 4)
 
     for (let i = 0; i < buf.length; i++) {
         correct.writeUInt32BE(buf[i], i * 4)
     }
-    return correct;
+    return correct
 }
 
 /**
@@ -272,7 +272,7 @@ function getRandomInt(min, max) {
  * @param ms time in milliseconds
  * @returns {Promise}
  */
-const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms))
+const sleep = ms => new Promise(resolve => setTimeout(resolve, ms))
 
 /**
  * Checks if the obj is an array
@@ -347,5 +347,5 @@ module.exports = {
     //isArrayLike,
     toSignedLittleBuffer,
     convertToLittle,
-    IS_NODE
+    IS_NODE,
 }

+ 2 - 2
gramjs/Password.js

@@ -86,7 +86,7 @@ function checkPrimeAndGood(primeBytes, g) {
             return // It's good
         }
     }
-    throw new Error("Changing passwords unsupported")
+    throw new Error('Changing passwords unsupported')
     //checkPrimeAndGoodCheck(readBigIntFromBuffer(primeBytes, false), g)
 }
 
@@ -248,7 +248,7 @@ async function computeCheck(request, password) {
         sha256(pForHash),
         sha256(gForHash),
         sha256(algo.salt1),
-        sha256(algo.salt2)
+        sha256(algo.salt2),
     ])
     const M1 = await sha256(Buffer.concat([
         xor(pSha,gSha),

+ 15 - 15
gramjs/Utils.js

@@ -1,4 +1,4 @@
-const {IS_NODE} = require("./Helpers");
+const {IS_NODE} = require('./Helpers')
 const { constructors } = require('./tl')
 const { requests } = require('./tl')
 
@@ -70,7 +70,7 @@ function getInputPeer(entity, allowSelf = true, checkHash = true) {
         if ((entity.accessHash !== undefined && !entity.min) || !checkHash) {
             return new constructors.InputPeerChannel({
                 channelId: entity.id,
-                accessHash: entity.accessHash
+                accessHash: entity.accessHash,
             })
         } else {
             throw new TypeError('Channel without accessHash or min info cannot be input')
@@ -81,20 +81,20 @@ function getInputPeer(entity, allowSelf = true, checkHash = true) {
         // also not optional, we assume that this truly is the case.
         return new constructors.InputPeerChannel({
             channelId: entity.id,
-            accessHash: entity.accessHash
+            accessHash: entity.accessHash,
         })
     }
 
     if (entity instanceof constructors.InputUser) {
         return new constructors.InputPeerUser({
             userId: entity.userId,
-            accessHash: entity.accessHash
+            accessHash: entity.accessHash,
         })
     }
     if (entity instanceof constructors.InputChannel) {
         return new constructors.InputPeerChannel({
             channelId: entity.channelId,
-            accessHash: entity.accessHash
+            accessHash: entity.accessHash,
         })
     }
     if (entity instanceof constructors.UserEmpty) {
@@ -616,46 +616,46 @@ function isListLike(item) {
 */
 async function getDC(dcId,client, cdn = false) {
     if (!IS_NODE){
-    switch (dcId) {
+        switch (dcId) {
         case 1:
             return {
                 id: 1,
                 ipAddress: IS_NODE?'':'pluto.web.telegram.org',
-                port: 443
+                port: 443,
             }
         case 2:
             return {
                 id: 2,
                 ipAddress: 'venus.web.telegram.org',
-                port: 443
+                port: 443,
             }
         case 3:
             return {
                 id: 3,
                 ipAddress: 'aurora.web.telegram.org',
-                port: 443
+                port: 443,
             }
         case 4:
             return {
                 id: 4,
                 ipAddress: 'vesta.web.telegram.org',
-                port: 443
+                port: 443,
             }
         case 5:
             return {
                 id: 5,
                 ipAddress: 'flora.web.telegram.org',
-                port: 443
+                port: 443,
             }
         default:
             throw new Error(`Cannot find the DC with the ID of ${dcId}`)
-    }
+        }
     }
     if (!client._config) {
         client._config = await client.invoke(new requests.help.GetConfig())
     }
     if (cdn) {
-        throw new Error(`CDNs are Not supported`)
+        throw new Error('CDNs are Not supported')
     }
 
     for (const DC of client._config.dcOptions) {
@@ -663,7 +663,7 @@ async function getDC(dcId,client, cdn = false) {
             return {
                 id:DC.id,
                 ipAddress:DC.ipAddress,
-                port:443
+                port:443,
             }
         }
     }
@@ -687,5 +687,5 @@ module.exports = {
     getAppropriatedPartSize,
     //getInputLocation,
     strippedPhotoToJpg,
-    getDC
+    getDC,
 }

+ 16 - 16
gramjs/client/TelegramClient.js

@@ -10,7 +10,7 @@ const os = require('os')
 const { LAYER } = require('../tl/AllTLObjects')
 const { constructors, requests } = require('../tl')
 const MTProtoSender = require('../network/MTProtoSender')
-const { UpdateConnectionState } = require("../network")
+const { UpdateConnectionState } = require('../network')
 const { ConnectionTCPObfuscated } = require('../network/connection/TCPObfuscated')
 const { ConnectionTCPFull } = require('../network/connection/TCPFull')
 const { authFlow, checkAuthorization } = require('./auth')
@@ -98,7 +98,7 @@ class TelegramClient {
 
         this._floodWaitedRequests = {}
 
-        this._initWith = (x) => {
+        this._initWith = x => {
             return new requests.InvokeWithLayer({
                 layer: LAYER,
                 query: new requests.InitConnection({
@@ -217,10 +217,10 @@ class TelegramClient {
         await Promise.all([
             this.disconnect(),
             this.session.delete(),
-            ...Object.values(this._borrowedSenderPromises).map((promise) => {
+            ...Object.values(this._borrowedSenderPromises).map(promise => {
                 return promise
-                    .then((sender) => sender.disconnect())
-            })
+                    .then(sender => sender.disconnect())
+            }),
         ])
 
         this._eventBuilders = []
@@ -255,11 +255,11 @@ class TelegramClient {
             senderPromise = this._createExportedSender(dcId, retries)
             this._borrowedSenderPromises[dcId] = senderPromise
 
-            senderPromise.then((sender) => {
+            senderPromise.then(sender => {
                 if (!sender) {
-                    delete this._borrowedSenderPromises[dcId];
+                    delete this._borrowedSenderPromises[dcId]
                 }
-            });
+            })
         }
         return senderPromise
     }
@@ -290,9 +290,9 @@ class TelegramClient {
                     this._log.info(`Exporting authorization for data center ${dc.ipAddress}`)
                     const auth = await this.invoke(new requests.auth.ExportAuthorization({ dcId: dcId }))
                     const req = this._initWith(new requests.auth.ImportAuthorization({
-                            id: auth.id,
-                            bytes: auth.bytes,
-                        },
+                        id: auth.id,
+                        bytes: auth.bytes,
+                    },
                     ))
                     await sender.send(req)
                 }
@@ -404,7 +404,7 @@ class TelegramClient {
             })
         } catch (e) {
             // TODO this should never raise
-            throw e;
+            throw e
             /*if (e.message === 'LOCATION_INVALID') {
                 const ie = await this.getInputEntity(entity)
                 if (ie instanceof constructors.InputPeerChannel) {
@@ -432,12 +432,12 @@ class TelegramClient {
             new constructors.InputStickerSetThumb({
                 stickerset: new constructors.InputStickerSetID({
                     id: stickerSet.id,
-                    accessHash: stickerSet.accessHash
+                    accessHash: stickerSet.accessHash,
                 }),
                 localId: location.localId,
                 volumeId: location.volumeId,
             }),
-            { dcId: stickerSet.thumbDcId }
+            { dcId: stickerSet.thumbDcId },
         )
     }
 
@@ -448,7 +448,7 @@ class TelegramClient {
         const indexOfSize = sizeTypes.indexOf(sizeType)
         let size
         for (let i = indexOfSize; i < sizeTypes.length; i++) {
-            size = sizes.find((s) => s.type === sizeTypes[i])
+            size = sizes.find(s => s.type === sizeTypes[i])
             if (size) {
                 return size
             }
@@ -614,7 +614,7 @@ class TelegramClient {
 
         const apiCredentials = {
             apiId: this.apiId,
-            apiHash: this.apiHash
+            apiHash: this.apiHash,
         }
 
         await authFlow(this, apiCredentials, authParams)

+ 2 - 2
gramjs/crypto/Factorizator.js

@@ -10,7 +10,7 @@ class Factorizator {
      */
     static gcd(a, b) {
         while (b.neq(BigInt.zero)) {
-            let temp = b
+            const temp = b
             b = a.remainder(b)
             a = temp
         }
@@ -47,7 +47,7 @@ class Factorizator {
             while (k.lesser(r) && g.eq(BigInt.one)) {
 
                 ys = y
-                let condition = BigInt.min(m, r.minus(k))
+                const condition = BigInt.min(m, r.minus(k))
                 for (let i = 0; BigInt(i).lesser(condition); i++) {
                     y = (modExp(y, BigInt(2), pq)).add(c).remainder(pq)
                     q = q.multiply(x.minus(y).abs()).remainder(pq)

+ 5 - 5
gramjs/crypto/IGE.js

@@ -1,10 +1,10 @@
-const Helpers = require("../Helpers");
+const Helpers = require('../Helpers')
 
-const {IGE:aes_ige} = require('@cryptography/aes');
+const {IGE:aes_ige} = require('@cryptography/aes')
 
 class IGENEW {
     constructor(key, iv) {
-        this.ige = new aes_ige(key,iv);
+        this.ige = new aes_ige(key,iv)
     }
 
     /**
@@ -13,7 +13,7 @@ class IGENEW {
      * @returns {Buffer}
      */
     decryptIge(cipherText) {
-        return Helpers.convertToLittle(this.ige.decrypt(cipherText));
+        return Helpers.convertToLittle(this.ige.decrypt(cipherText))
     }
 
     /**
@@ -27,7 +27,7 @@ class IGENEW {
             plainText = Buffer.concat([plainText, Helpers.generateRandomBytes(16 - padding)])
         }
 
-        return Helpers.convertToLittle(this.ige.encrypt(plainText));
+        return Helpers.convertToLittle(this.ige.encrypt(plainText))
 
 
     }

+ 4 - 4
gramjs/crypto/RSA.js

@@ -4,19 +4,19 @@ const { readBigIntFromBuffer, readBufferFromBigInt, getByteArray, sha1, generate
 const PUBLIC_KEYS = [{
     'fingerprint': [40, 85, 94, 156, 117, 240, 61, 22, 65, 244, 169, 2, 33, 107, 232, 108, 2, 43, 180, 195],
     'n': BigInt('24403446649145068056824081744112065346446136066297307473868293895086332508101251964919587745984311372853053253457835208829824428441874946556659953519213382748319518214765985662663680818277989736779506318868003755216402538945900388706898101286548187286716959100102939636333452457308619454821845196109544157601096359148241435922125602449263164512290854366930013825808102403072317738266383237191313714482187326643144603633877219028262697593882410403273959074350849923041765639673335775605842311578109726403165298875058941765362622936097839775380070572921007586266115476975819175319995527916042178582540628652481530373407'),
-    'e': 65537
+    'e': 65537,
 }, {
     'fingerprint': [140, 171, 9, 34, 146, 246, 166, 50, 10, 170, 229, 247, 155, 114, 28, 177, 29, 106, 153, 154],
     'n': BigInt('25081407810410225030931722734886059247598515157516470397242545867550116598436968553551465554653745201634977779380884774534457386795922003815072071558370597290368737862981871277312823942822144802509055492512145589734772907225259038113414940384446493111736999668652848440655603157665903721517224934142301456312994547591626081517162758808439979745328030376796953660042629868902013177751703385501412640560275067171555763725421377065095231095517201241069856888933358280729674273422117201596511978645878544308102076746465468955910659145532699238576978901011112475698963666091510778777356966351191806495199073754705289253783'),
-    'e': 65537
+    'e': 65537,
 }, {
     'fingerprint': [243, 218, 109, 239, 16, 202, 176, 78, 167, 8, 255, 209, 120, 234, 205, 112, 111, 42, 91, 176],
     'n': BigInt('22347337644621997830323797217583448833849627595286505527328214795712874535417149457567295215523199212899872122674023936713124024124676488204889357563104452250187725437815819680799441376434162907889288526863223004380906766451781702435861040049293189979755757428366240570457372226323943522935844086838355728767565415115131238950994049041950699006558441163206523696546297006014416576123345545601004508537089192869558480948139679182328810531942418921113328804749485349441503927570568778905918696883174575510385552845625481490900659718413892216221539684717773483326240872061786759868040623935592404144262688161923519030977'),
-    'e': 65537
+    'e': 65537,
 }, {
     'fingerprint': [128, 80, 214, 72, 77, 244, 98, 7, 201, 250, 37, 244, 227, 51, 96, 199, 182, 37, 224, 113],
     'n': BigInt('24573455207957565047870011785254215390918912369814947541785386299516827003508659346069416840622922416779652050319196701077275060353178142796963682024347858398319926119639265555410256455471016400261630917813337515247954638555325280392998950756512879748873422896798579889820248358636937659872379948616822902110696986481638776226860777480684653756042166610633513404129518040549077551227082262066602286208338952016035637334787564972991208252928951876463555456715923743181359826124083963758009484867346318483872552977652588089928761806897223231500970500186019991032176060579816348322451864584743414550721639495547636008351'),
-    'e': 65537
+    'e': 65537,
 }]
 
 const _serverKeys = {}

+ 8 - 8
gramjs/crypto/crypto.js

@@ -1,6 +1,6 @@
-const AES = require('@cryptography/aes').default;
-const { i2ab, ab2i } = require('./converters');
-const { getWords } = require('./words');
+const AES = require('@cryptography/aes').default
+const { i2ab, ab2i } = require('./converters')
+const { getWords } = require('./words')
 class Counter {
     constructor(initialValue) {
         this.setBytes(initialValue)
@@ -61,7 +61,7 @@ class CTR {
 // endregion
 function createDecipheriv(algorithm, key, iv) {
     if (algorithm.includes('ECB')) {
-        throw new Error('Not supported');
+        throw new Error('Not supported')
     } else {
         return new CTR(key, iv)
     }
@@ -69,7 +69,7 @@ function createDecipheriv(algorithm, key, iv) {
 
 function createCipheriv(algorithm, key, iv) {
     if (algorithm.includes('ECB')) {
-        throw new Error('Not supported');
+        throw new Error('Not supported')
     } else {
         return new CTR(key, iv)
     }
@@ -106,8 +106,8 @@ async function pbkdf2(password, salt, iterations) {
         {name: 'PBKDF2'}, false, ['deriveBits'])
     return Buffer.from(await crypto.subtle.deriveBits({
         name: 'PBKDF2',
-        hash: 'SHA-512', salt, iterations
-    }, passwordKey, 512));
+        hash: 'SHA-512', salt, iterations,
+    }, passwordKey, 512))
 }
 
 function createHash(algorithm) {
@@ -119,5 +119,5 @@ module.exports = {
     createDecipheriv,
     randomBytes,
     createHash,
-    pbkdf2
+    pbkdf2,
 }

+ 1 - 1
gramjs/errors/RPCBaseErrors.js

@@ -7,7 +7,7 @@ class RPCError extends Error {
             'RPCError {0}: {1}{2}'
                 .replace('{0}', code)
                 .replace('{1}', message)
-                .replace('{2}', RPCError._fmtRequest(request))
+                .replace('{2}', RPCError._fmtRequest(request)),
         )
         this.code = code
         this.message = message

+ 1 - 1
gramjs/errors/index.js

@@ -4,7 +4,7 @@
  * @param request the request that caused this error
  * @constructor the RPCError as a Python exception that represents this error
  */
-const { RPCError } = require("./RPCBaseErrors")
+const { RPCError } = require('./RPCBaseErrors')
 const { rpcErrorRe } = require('./RPCErrorList')
 
 function RPCMessageToError(rpcError, request) {

+ 3 - 3
gramjs/extensions/AsyncQueue.js

@@ -1,7 +1,7 @@
 class AsyncQueue {
     constructor() {
         this._queue = []
-        this.canGet = new Promise((resolve) => {
+        this.canGet = new Promise(resolve => {
             this.resolveGet = resolve
         })
         this.canPush = true
@@ -11,7 +11,7 @@ class AsyncQueue {
         await this.canPush
         this._queue.push(value)
         this.resolveGet(true)
-        this.canPush = new Promise((resolve) => {
+        this.canPush = new Promise(resolve => {
             this.resolvePush = resolve
         })
     }
@@ -20,7 +20,7 @@ class AsyncQueue {
         await this.canGet
         const returned = this._queue.pop()
         this.resolvePush(true)
-        this.canGet = new Promise((resolve) => {
+        this.canGet = new Promise(resolve => {
             this.resolveGet = resolve
         })
         return returned

+ 1 - 1
gramjs/extensions/Logger.js

@@ -78,7 +78,7 @@ class Logger {
     }
 
     static setLevel(level) {
-        _level = level;
+        _level = level
     }
 
     /**

+ 2 - 2
gramjs/extensions/MessagePacker.js

@@ -6,7 +6,7 @@ class MessagePacker {
     constructor(state, logger) {
         this._state = state
         this._queue = []
-        this._ready = new Promise(((resolve) => {
+        this._ready = new Promise((resolve => {
             this.setReady = resolve
         }))
         this._log = logger
@@ -31,7 +31,7 @@ class MessagePacker {
     async get() {
 
         if (!this._queue.length) {
-            this._ready = new Promise(((resolve) => {
+            this._ready = new Promise((resolve => {
                 this.setReady = resolve
             }))
             await this._ready

+ 4 - 4
gramjs/extensions/PromisedNetSockets.js

@@ -33,7 +33,7 @@ class PromisedNetSockets {
         const toReturn = this.stream.slice(0, number)
         this.stream = this.stream.slice(number)
         if (this.stream.length === 0) {
-            this.canRead = new Promise((resolve) => {
+            this.canRead = new Promise(resolve => {
                 this.resolveRead = resolve
             })
         }
@@ -47,7 +47,7 @@ class PromisedNetSockets {
         }
         const toReturn = this.stream
         this.stream = Buffer.alloc(0)
-        this.canRead = new Promise((resolve) => {
+        this.canRead = new Promise(resolve => {
             this.resolveRead = resolve
         })
         return toReturn
@@ -63,7 +63,7 @@ class PromisedNetSockets {
         this.stream = Buffer.alloc(0)
 
         this.client = new Socket()
-        this.canRead = new Promise((resolve) => {
+        this.canRead = new Promise(resolve => {
             this.resolveRead = resolve
         })
         this.closed = false
@@ -98,7 +98,7 @@ class PromisedNetSockets {
     }
 
     async receive() {
-        this.client.on('data', async (message) => {
+        this.client.on('data', async message => {
 
             const release = await mutex.acquire()
             try {

+ 9 - 9
gramjs/extensions/PromisedWebSockets.js

@@ -41,7 +41,7 @@ class PromisedWebSockets {
         const toReturn = this.stream.slice(0, number)
         this.stream = this.stream.slice(number)
         if (this.stream.length === 0) {
-            this.canRead = new Promise((resolve) => {
+            this.canRead = new Promise(resolve => {
                 this.resolveRead = resolve
             })
         }
@@ -55,7 +55,7 @@ class PromisedWebSockets {
         }
         const toReturn = this.stream
         this.stream = Buffer.alloc(0)
-        this.canRead = new Promise((resolve) => {
+        this.canRead = new Promise(resolve => {
             this.resolveRead = resolve
         })
         return toReturn
@@ -71,7 +71,7 @@ class PromisedWebSockets {
 
     async connect(port, ip) {
         this.stream = Buffer.alloc(0)
-        this.canRead = new Promise((resolve) => {
+        this.canRead = new Promise(resolve => {
             this.resolveRead = resolve
         })
         this.closed = false
@@ -82,19 +82,19 @@ class PromisedWebSockets {
                 this.receive()
                 resolve(this)
             }
-            this.client.onerror = (error) => {
+            this.client.onerror = error => {
                 reject(error)
             }
             this.client.onclose = () => {
-                    this.resolveRead(false)
-                    this.closed = true
+                this.resolveRead(false)
+                this.closed = true
             }
             //CONTEST
             if (typeof window !== 'undefined'){
                 window.addEventListener('offline', async () => {
                     await this.close()
                     this.resolveRead(false)
-                });
+                })
             }
         })
     }
@@ -112,12 +112,12 @@ class PromisedWebSockets {
     }
 
     async receive() {
-        this.client.onmessage = async (message) => {
+        this.client.onmessage = async message => {
             const release = await mutex.acquire()
             try {
                 let data
                 //CONTEST BROWSER
-                    data = Buffer.from(await new Response(message.data).arrayBuffer())
+                data = Buffer.from(await new Response(message.data).arrayBuffer())
                 this.stream = Buffer.concat([this.stream, data])
                 this.resolveRead(true)
             } finally {

+ 3 - 3
gramjs/network/Authenticator.js

@@ -6,7 +6,7 @@ const RSA = require('../crypto/RSA')
 const Helpers = require('../Helpers')
 const { constructors, requests } = require('../tl')
 const BinaryReader = require('../extensions/BinaryReader')
-const { SecurityError } = require("../errors/Common")
+const { SecurityError } = require('../errors/Common')
 
 /**
  * Executes the authentication process with the Telegram servers.
@@ -35,8 +35,8 @@ async function doAuthentication(sender, log) {
     let { p, q } = Factorizator.factorize(pq)
 
     // TODO Bring back after `Factorizator` fix.
-     p = Helpers.getByteArray(p)
-     q = Helpers.getByteArray(q)
+    p = Helpers.getByteArray(p)
+    q = Helpers.getByteArray(q)
 
     bytes = Helpers.generateRandomBytes(32)
     const newNonce = Helpers.readBigIntFromBuffer(bytes, true, true)

+ 1 - 1
gramjs/network/MTProtoPlainSender.js

@@ -7,7 +7,7 @@ const MTProtoState = require('./MTProtoState')
 const BinaryReader = require('../extensions/BinaryReader')
 const { InvalidBufferError } = require('../errors/Common')
 const BigInt = require('big-integer')
-const { toSignedLittleBuffer } = require("../Helpers")
+const { toSignedLittleBuffer } = require('../Helpers')
 
 /**
  * MTProto Mobile Protocol plain sender (https://core.telegram.org/mtproto/description#unencrypted-messages)

+ 8 - 8
gramjs/network/MTProtoSender.js

@@ -10,8 +10,8 @@ const RequestState = require('./RequestState')
 const { MsgsAck, upload, MsgsStateInfo, Pong } = require('../tl').constructors
 const MessagePacker = require('../extensions/MessagePacker')
 const BinaryReader = require('../extensions/BinaryReader')
-const { UpdateConnectionState } = require("./index");
-const { BadMessageError } = require("../errors/Common")
+const { UpdateConnectionState } = require('./index')
+const { BadMessageError } = require('../errors/Common')
 const {
     BadServerSalt,
     BadMsgNotification,
@@ -73,8 +73,8 @@ class MTProtoSender {
         this._authKeyCallback = args.authKeyCallback
         this._updateCallback = args.updateCallback
         this._autoReconnectCallback = args.autoReconnectCallback
-        this._isMainSender = args.isMainSender;
-        this._senderCallback = args.senderCallback;
+        this._isMainSender = args.isMainSender
+        this._senderCallback = args.senderCallback
 
         /**
          * Whether the user has explicitly connected or disconnected.
@@ -170,9 +170,9 @@ class MTProtoSender {
                 if (attempt===0 && eventDispatch!==null){
                     eventDispatch({ update: new UpdateConnectionState(-1) })
                 }
-                console.dir(e);
+                console.dir(e)
 
-                this._log.error("WebSocket connection failed attempt : "+(attempt+1))
+                this._log.error('WebSocket connection failed attempt : '+(attempt+1))
                 await Helpers.sleep(this._delay)
             }
         }
@@ -771,7 +771,7 @@ class MTProtoSender {
             this._reconnecting = true
             // TODO Should we set this?
             // this._user_connected = false
-            this._log.info("Started reconnecting")
+            this._log.info('Started reconnecting')
             this._reconnect()
         }
     }
@@ -804,7 +804,7 @@ class MTProtoSender {
 
                 break
             } catch (e) {
-                this._log.error("WebSocket connection failed attempt : "+(attempt+1))
+                this._log.error('WebSocket connection failed attempt : '+(attempt+1))
                 console.log(e)
                 await Helpers.sleep(this._delay)
             }

+ 3 - 3
gramjs/network/MTProtoState.js

@@ -6,8 +6,8 @@ const { TLMessage } = require('../tl/core')
 const { SecurityError, InvalidBufferError } = require('../errors/Common')
 const { InvokeAfterMsg } = require('../tl').requests
 const BigInt = require('big-integer')
-const { toSignedLittleBuffer,readBufferFromBigInt } = require("../Helpers")
-const { readBigIntFromBuffer } = require("../Helpers")
+const { toSignedLittleBuffer,readBufferFromBigInt } = require('../Helpers')
+const { readBigIntFromBuffer } = require('../Helpers')
 
 class MTProtoState {
     /**
@@ -75,7 +75,7 @@ class MTProtoState {
         const x = client === true ? 0 : 8
         const [sha256a , sha256b] = await Promise.all([
             Helpers.sha256(Buffer.concat([msgKey, authKey.slice(x, x + 36)])),
-            Helpers.sha256(Buffer.concat([authKey.slice(x + 40, x + 76), msgKey]))
+            Helpers.sha256(Buffer.concat([authKey.slice(x + 40, x + 76), msgKey])),
         ])
         const key = Buffer.concat([sha256a.slice(0, 8), sha256b.slice(8, 24), sha256a.slice(24, 32)])
         const iv = Buffer.concat([sha256b.slice(0, 8), sha256a.slice(8, 24), sha256b.slice(24, 32)])

+ 2 - 2
gramjs/network/connection/Connection.js

@@ -1,7 +1,7 @@
 const PromisedWebSockets = require('../../extensions/PromisedWebSockets')
 const PromisedNetSockets = require('../../extensions/PromisedNetSockets')
 const AsyncQueue = require('../../extensions/AsyncQueue')
-const {IS_NODE} = require("../../Helpers");
+const {IS_NODE} = require('../../Helpers')
 
 /**
  * The `Connection` class is a wrapper around ``asyncio.open_connection``.
@@ -100,7 +100,7 @@ class Connection {
             try {
                 data = await this._recv()
                 if (!data) {
-                    throw new Error("no data received")
+                    throw new Error('no data received')
                 }
             } catch (e) {
                 this._log.info('connection closed')

+ 40 - 40
gramjs/network/connection/TCPFull.js

@@ -1,56 +1,56 @@
 const { Connection, PacketCodec } = require('./Connection')
- const { crc32 } = require('../../Helpers')
- const { InvalidChecksumError } = require('../../errors/Common')
+const { crc32 } = require('../../Helpers')
+const { InvalidChecksumError } = require('../../errors/Common')
 
- class FullPacketCodec extends PacketCodec {
-     constructor(connection) {
-         super(connection)
-         this._sendCounter = 0 // Telegram will ignore us otherwise
-     }
+class FullPacketCodec extends PacketCodec {
+    constructor(connection) {
+        super(connection)
+        this._sendCounter = 0 // Telegram will ignore us otherwise
+    }
 
-     encodePacket(data) {
-         // https://core.telegram.org/mtproto#tcp-transport
-         // total length, sequence number, packet and checksum (CRC32)
-         const length = data.length + 12
-         const e = Buffer.alloc(8)
-         e.writeInt32LE(length,0)
-         e.writeInt32LE(this._sendCounter,4)
-         data = Buffer.concat([e, data])
-         const crc =  Buffer.alloc(4)
-         crc.writeUInt32LE(crc32(data),0)
-         this._sendCounter += 1
-         return Buffer.concat([data, crc])
-     }
+    encodePacket(data) {
+        // https://core.telegram.org/mtproto#tcp-transport
+        // total length, sequence number, packet and checksum (CRC32)
+        const length = data.length + 12
+        const e = Buffer.alloc(8)
+        e.writeInt32LE(length,0)
+        e.writeInt32LE(this._sendCounter,4)
+        data = Buffer.concat([e, data])
+        const crc =  Buffer.alloc(4)
+        crc.writeUInt32LE(crc32(data),0)
+        this._sendCounter += 1
+        return Buffer.concat([data, crc])
+    }
 
-     /**
+    /**
       *
       * @param reader {PromisedWebSockets}
       * @returns {Promise<*>}
       */
-     async readPacket(reader) {
-         const packetLenSeq = await reader.read(8) // 4 and 4
-         // process.exit(0);
-         if (packetLenSeq === undefined) {
-             return false
-         }
-         const packetLen = packetLenSeq.readInt32LE(0)
-         let body = await reader.read(packetLen - 8)
-         const checksum = body.slice(-4).readUInt32LE(0)
-         body = body.slice(0, -4)
+    async readPacket(reader) {
+        const packetLenSeq = await reader.read(8) // 4 and 4
+        // process.exit(0);
+        if (packetLenSeq === undefined) {
+            return false
+        }
+        const packetLen = packetLenSeq.readInt32LE(0)
+        let body = await reader.read(packetLen - 8)
+        const checksum = body.slice(-4).readUInt32LE(0)
+        body = body.slice(0, -4)
 
-         const validChecksum = crc32(Buffer.concat([packetLenSeq, body]))
-         if (!(validChecksum === checksum)) {
-             throw new InvalidChecksumError(checksum, validChecksum)
-         }
-         return body
-     }
- }
+        const validChecksum = crc32(Buffer.concat([packetLenSeq, body]))
+        if (!(validChecksum === checksum)) {
+            throw new InvalidChecksumError(checksum, validChecksum)
+        }
+        return body
+    }
+}
 
 class ConnectionTCPFull extends Connection {
      PacketCodecClass = FullPacketCodec;
 }
 
 module.exports = {
-     FullPacketCodec,
-     ConnectionTCPFull,
+    FullPacketCodec,
+    ConnectionTCPFull,
 }

+ 4 - 4
gramjs/sessions/CacheApiSession.js

@@ -24,11 +24,11 @@ class CacheApi extends MemorySession {
 
             this.setDC(mainDcId, ipAddress, port, true)
 
-            Object.keys(keys).forEach((dcId) => {
+            Object.keys(keys).forEach(dcId => {
                 if (keys[dcId] && hashes[dcId]){
                     this._authKeys[dcId] = new AuthKey(
                         Buffer.from(keys[dcId].data),
-                        Buffer.from(hashes[dcId].data)
+                        Buffer.from(hashes[dcId].data),
                     )
                 }
             })
@@ -85,10 +85,10 @@ class CacheApi extends MemorySession {
         const sessionData = {
             mainDcId: this._dcId,
             keys: {},
-            hashes: {}
+            hashes: {},
         }
 
-        Object.keys(this._authKeys).map((dcId) => {
+        Object.keys(this._authKeys).map(dcId => {
             const authKey = this._authKeys[dcId]
             sessionData.keys[dcId] = authKey._key
             sessionData.hashes[dcId] = authKey._hash

+ 1 - 1
gramjs/sessions/index.js

@@ -5,5 +5,5 @@ const CacheApiSession = require('./CacheApiSession')
 module.exports = {
     Memory,
     StringSession,
-    CacheApiSession
+    CacheApiSession,
 }

+ 72 - 72
gramjs/tl/api.js

@@ -1,18 +1,18 @@
 const {
     parseTl,
     serializeBytes,
-    serializeDate
+    serializeDate,
 } = require('./generationHelpers')
 const { IS_NODE,toSignedLittleBuffer } = require('../Helpers')
-let tlContent,schemeContent;
+let tlContent,schemeContent
 if (IS_NODE){
-    const fs = require("fs");
+    const fs = require('fs')
 
-    tlContent = fs.readFileSync(__dirname+'/static/api.tl',"utf-8");
-    schemeContent = fs.readFileSync(__dirname+'/static/schema.tl',"utf-8");
+    tlContent = fs.readFileSync(__dirname+'/static/api.tl','utf-8')
+    schemeContent = fs.readFileSync(__dirname+'/static/schema.tl','utf-8')
 }else{
-     tlContent = require('./static/api.tl').default;
-     schemeContent = require('./static/schema.tl').default;
+    tlContent = require('./static/api.tl').default
+    schemeContent = require('./static/schema.tl').default
 
 }
 
@@ -42,7 +42,7 @@ const CACHING_SUPPORTED = typeof self !== 'undefined' && self.localStorage !== u
 const CACHE_KEY = 'GramJs:apiCache'
 
 function buildApiFromTlSchema() {
-    let definitions;
+    let definitions
     const fromCache = CACHING_SUPPORTED && loadFromCache()
 
     if (fromCache) {
@@ -56,8 +56,8 @@ function buildApiFromTlSchema() {
     }
 
     return mergeWithNamespaces(
-      createClasses('constructor', definitions.constructors),
-      createClasses('request', definitions.requests)
+        createClasses('constructor', definitions.constructors),
+        createClasses('request', definitions.requests),
     )
 }
 
@@ -78,7 +78,7 @@ function loadFromTlSchemas() {
 function mergeWithNamespaces(obj1, obj2) {
     const result = { ...obj1 }
 
-    Object.keys(obj2).forEach((key) => {
+    Object.keys(obj2).forEach(key => {
         if (typeof obj2[key] === 'function' || !result[key]) {
             result[key] = obj2[key]
         } else {
@@ -101,32 +101,32 @@ function extractParams(fileContent) {
 
 function argToBytes(x, type) {
     switch (type) {
-        case 'int':
-            const i = Buffer.alloc(4)
-            i.writeInt32LE(x, 0)
-            return i
-        case 'long':
-            return toSignedLittleBuffer(x, 8)
-        case 'int128':
-            return toSignedLittleBuffer(x, 16)
-        case 'int256':
-            return toSignedLittleBuffer(x, 32)
-        case 'double':
-            const d = Buffer.alloc(8)
-            d.writeDoubleLE(x, 0)
-            return d
-        case 'string':
-            return serializeBytes(x)
-        case 'Bool':
-            return x ? Buffer.from('b5757299', 'hex') : Buffer.from('379779bc', 'hex')
-        case 'true':
-            return Buffer.alloc(0)
-        case 'bytes':
-            return serializeBytes(x)
-        case 'date':
-            return serializeDate(x)
-        default:
-            return x.getBytes()
+    case 'int':
+        const i = Buffer.alloc(4)
+        i.writeInt32LE(x, 0)
+        return i
+    case 'long':
+        return toSignedLittleBuffer(x, 8)
+    case 'int128':
+        return toSignedLittleBuffer(x, 16)
+    case 'int256':
+        return toSignedLittleBuffer(x, 32)
+    case 'double':
+        const d = Buffer.alloc(8)
+        d.writeDoubleLE(x, 0)
+        return d
+    case 'string':
+        return serializeBytes(x)
+    case 'Bool':
+        return x ? Buffer.from('b5757299', 'hex') : Buffer.from('379779bc', 'hex')
+    case 'true':
+        return Buffer.alloc(0)
+    case 'bytes':
+        return serializeBytes(x)
+    case 'date':
+        return serializeDate(x)
+    default:
+        return x.getBytes()
     }
 }
 /*
@@ -177,32 +177,32 @@ function getArgFromReader(reader, arg) {
         return reader.readInt()
     } else {
         switch (arg.type) {
-            case 'int':
-                return reader.readInt()
-            case 'long':
-                return reader.readLong()
-            case 'int128':
-                return reader.readLargeInt(128)
-            case 'int256':
-                return reader.readLargeInt(256)
-            case 'double':
-                return reader.readDouble()
-            case 'string':
-                return reader.tgReadString()
-            case 'Bool':
-                return reader.tgReadBool()
-            case 'true':
-                return true
-            case 'bytes':
-                return reader.tgReadBytes()
-            case 'date':
-                return reader.tgReadDate()
-            default:
-                if (!arg.skipConstructorId) {
-                    return reader.tgReadObject()
-                } else {
-                    return api.constructors[arg.type].fromReader(reader)
-                }
+        case 'int':
+            return reader.readInt()
+        case 'long':
+            return reader.readLong()
+        case 'int128':
+            return reader.readLargeInt(128)
+        case 'int256':
+            return reader.readLargeInt(256)
+        case 'double':
+            return reader.readDouble()
+        case 'string':
+            return reader.tgReadString()
+        case 'Bool':
+            return reader.tgReadBool()
+        case 'true':
+            return true
+        case 'bytes':
+            return reader.tgReadBytes()
+        case 'date':
+            return reader.tgReadDate()
+        default:
+            if (!arg.skipConstructorId) {
+                return reader.tgReadObject()
+            } else {
+                return api.constructors[arg.type].fromReader(reader)
+            }
         }
     }
 }
@@ -227,9 +227,9 @@ function createClasses(classesType, params) {
             constructor(args) {
                 args = args || {}
                 Object.keys(args)
-                  .forEach((argName) => {
-                      this[argName] = args[argName]
-                  })
+                    .forEach(argName => {
+                        this[argName] = args[argName]
+                    })
             }
 
             static fromReader(reader) {
@@ -269,9 +269,9 @@ function createClasses(classesType, params) {
                 for (const arg in argsConfig) {
                     if (argsConfig.hasOwnProperty(arg)) {
                         if (argsConfig[arg].isFlag) {
-                          if (this[arg]===false || this[arg]===null || this[arg]===undefined || argsConfig[arg].type==='true'){
-                              continue
-                          }
+                            if (this[arg]===false || this[arg]===null || this[arg]===undefined || argsConfig[arg].type==='true'){
+                                continue
+                            }
                         }
                         if (argsConfig[arg].isVector) {
                             if (argsConfig[arg].useVectorId) {
@@ -282,7 +282,7 @@ function createClasses(classesType, params) {
                             buffers.push(l, Buffer.concat(this[arg].map(x => argToBytes(x, argsConfig[arg].type))))
                         } else if (argsConfig[arg].flagIndicator) {
                             if (!Object.values(argsConfig)
-                              .some((f) => f.isFlag)) {
+                                .some(f => f.isFlag)) {
                                 buffers.push(Buffer.alloc(4))
                             } else {
                                 let flagCalculate = 0
@@ -324,8 +324,8 @@ function createClasses(classesType, params) {
                 const m = result.match(/Vector<(int|long)>/)
                 if (m) {
                     reader.readInt()
-                    let temp = []
-                    let len = reader.readInt()
+                    const temp = []
+                    const len = reader.readInt()
                     if (m[1] === 'int') {
                         for (let i = 0; i < len; i++) {
                             temp.push(reader.readInt())

+ 2 - 2
gramjs/tl/core/MessageContainer.js

@@ -2,7 +2,7 @@ const TLMessage = require('./TLMessage')
 
 class MessageContainer {
     static CONSTRUCTOR_ID = 0x73f1f8dc;
-    static classType = "constructor"
+    static classType = 'constructor'
     // Maximum size in bytes for the inner payload of the container.
     // Telegram will close the connection if the payload is bigger.
     // The overhead of the container itself is subtracted.
@@ -22,7 +22,7 @@ class MessageContainer {
 
         this.CONSTRUCTOR_ID = 0x73f1f8dc
         this.messages = messages
-        this.classType = "constructor"
+        this.classType = 'constructor'
     }
 
     static async fromReader(reader) {

+ 2 - 2
gramjs/tl/core/RPCResult.js

@@ -3,14 +3,14 @@ const GZIPPacked = require('./GZIPPacked')
 
 class RPCResult {
     static CONSTRUCTOR_ID = 0xf35c6d01;
-    static classType = "constructor"
+    static classType = 'constructor'
 
     constructor(reqMsgId, body, error) {
         this.CONSTRUCTOR_ID = 0xf35c6d01
         this.reqMsgId = reqMsgId
         this.body = body
         this.error = error
-        this.classType = "constructor"
+        this.classType = 'constructor'
     }
 
     static async fromReader(reader) {

+ 2 - 2
gramjs/tl/core/TLMessage.js

@@ -1,13 +1,13 @@
 
 class TLMessage {
     static SIZE_OVERHEAD = 12;
-    static classType = "constructor"
+    static classType = 'constructor'
 
     constructor(msgId, seqNo, obj) {
         this.msgId = msgId
         this.seqNo = seqNo
         this.obj = obj
-        this.classType = "constructor"
+        this.classType = 'constructor'
     }
 }
 

+ 15 - 15
gramjs/tl/generationHelpers.js

@@ -1,13 +1,13 @@
 const { crc32 } = require('../Helpers')
-const snakeToCamelCase = (name) => {
+const snakeToCamelCase = name => {
     const result = name.replace(/(?:^|_)([a-z])/g, (_, g) => g.toUpperCase())
     return result.replace(/_/g, '')
 }
-const variableSnakeToCamelCase = (str) => str.replace(
+const variableSnakeToCamelCase = str => str.replace(
     /([-_][a-z])/g,
-    (group) => group.toUpperCase()
+    group => group.toUpperCase()
         .replace('-', '')
-        .replace('_', '')
+        .replace('_', ''),
 )
 
 const CORE_TYPES = new Set([
@@ -15,7 +15,7 @@ const CORE_TYPES = new Set([
     0x997275b5, // boolTrue#997275b5 = Bool;
     0x3fedd339, // true#3fedd339 = True;
     0xc4b9f9bb, // error#c4b9f9bb code:int text:string = Error;
-    0x56730bcc // null#56730bcc = Null;
+    0x56730bcc, // null#56730bcc = Null;
 ])
 const AUTH_KEY_TYPES = new Set([
     0x05162463, // resPQ,
@@ -28,7 +28,7 @@ const AUTH_KEY_TYPES = new Set([
     0x6643b654, // client_DH_inner_data
     0xd712e4be, // req_DH_params
     0xf5045f1f, // set_client_DH_params
-    0x3072cfa1 // gzip_packed
+    0x3072cfa1, // gzip_packed
 ])
 
 
@@ -47,15 +47,15 @@ const fromLine = (line, isFunction) => {
         subclassOfId: crc32(match[3]),
         result: match[3],
         isFunction: isFunction,
-        namespace: null
+        namespace: null,
     }
     if (!currentConfig.constructorId) {
 
-        let hexId = ''
+        const hexId = ''
         let args
 
         if (Object.values(currentConfig.argsConfig).length) {
-            args = ` ${Object.keys(currentConfig.argsConfig).map((arg) => arg.toString()).join(' ')}`
+            args = ` ${Object.keys(currentConfig.argsConfig).map(arg => arg.toString()).join(' ')}`
         } else {
             args = ''
         }
@@ -104,14 +104,14 @@ function buildArgConfig(name, argType) {
         flagIndex: -1,
         flagIndicator: true,
         type: null,
-        useVectorId: null
+        useVectorId: null,
     }
 
     // Special case: some types can be inferred, which makes it
     // less annoying to type. Currently the only type that can
     // be inferred is if the name is 'random_id', to which a
     // random ID will be assigned if left as None (the default)
-    let canBeInferred = name === 'random_id'
+    const canBeInferred = name === 'random_id'
 
     // The type can be an indicator that other arguments will be flags
     if (argType !== '#') {
@@ -154,7 +154,7 @@ function buildArgConfig(name, argType) {
         // @ts-ignore
         if (/^[a-z]$/.test(currentConfig.type.split('.')
             .pop()
-            .charAt(0)
+            .charAt(0),
         )
         ) {
             currentConfig.skipConstructorId = true
@@ -251,8 +251,8 @@ const parseTl = function* (content, layer, methods = [], ignoreIds = CORE_TYPES)
 }
 
 const findAll = (regex, str, matches = []) => {
-    if (!regex.flags.includes(`g`)) {
-        regex = new RegExp(regex.source, `g`)
+    if (!regex.flags.includes('g')) {
+        regex = new RegExp(regex.source, 'g')
     }
 
     const res = regex.exec(str)
@@ -322,5 +322,5 @@ module.exports = {
     serializeDate,
     serializeBytes,
     snakeToCamelCase,
-    variableSnakeToCamelCase
+    variableSnakeToCamelCase,
 }

+ 1 - 1
gramjs/tl/index.js

@@ -8,5 +8,5 @@ module.exports = {
     requests: api,
     patched,
     serializeBytes,
-    serializeDate
+    serializeDate,
 }

+ 3 - 3
gramjs/tl/types-generator/generate.js

@@ -33,12 +33,12 @@ function extractParams(fileContent) {
             functions.push(def)
         } else {
             if (!types[def.result]) {
-                let [namespace, name] = def.result.includes('.') ? def.result.split('.') : [undefined, def.result]
+                const [namespace, name] = def.result.includes('.') ? def.result.split('.') : [undefined, def.result]
 
                 types[def.result] = {
                     namespace,
                     name,
-                    constructors: []
+                    constructors: [],
                 }
             }
 
@@ -50,7 +50,7 @@ function extractParams(fileContent) {
     return {
         types: Object.values(types),
         constructors,
-        functions
+        functions,
     }
 }
 

+ 17 - 17
gramjs/tl/types-generator/template.js

@@ -18,8 +18,8 @@ module.exports = ({ types, constructors, functions }) => {
 
     function renderTypes(types, indent) {
         return types.map(({ name, constructors }) => `
-      ${!constructors.length ? '// ' : ''}export type Type${upperFirst(name)} = ${constructors.map((name) => name)
-            .join(' | ')};
+      ${!constructors.length ? '// ' : ''}export type Type${upperFirst(name)} = ${constructors.map(name => name)
+    .join(' | ')};
     `.trim())
             .join(`\n${indent}`)
     }
@@ -32,24 +32,24 @@ module.exports = ({ types, constructors, functions }) => {
                 return `export class ${upperFirst(name)} extends VirtualClass<void> {};`
             }
 
-            let hasRequiredArgs = argKeys.some((argName) => argName !== 'flags' && !argsConfig[argName].isFlag)
+            const hasRequiredArgs = argKeys.some(argName => argName !== 'flags' && !argsConfig[argName].isFlag)
 
             return `
       export class ${upperFirst(name)} extends VirtualClass<{
 ${indent}  ${Object.keys(argsConfig)
-            .map((argName) => `
+    .map(argName => `
         ${renderArg(argName, argsConfig[argName])};
       `.trim())
-            .join(`\n${indent}  `)}
-${indent}}${!hasRequiredArgs ? ` | void` : ''}> {
+    .join(`\n${indent}  `)}
+${indent}}${!hasRequiredArgs ? ' | void' : ''}> {
 ${indent}  ${Object.keys(argsConfig)
-            .map((argName) => `
+    .map(argName => `
         ${renderArg(argName, argsConfig[argName])};
       `.trim())
-            .join(`\n${indent}  `)}
+    .join(`\n${indent}  `)}
 ${indent}};`.trim()
         })
-        .join(`\n${indent}`)
+            .join(`\n${indent}`)
     }
 
     function renderRequests(requests, indent) {
@@ -60,22 +60,22 @@ ${indent}};`.trim()
                 return `export class ${upperFirst(name)} extends Request<void, ${renderResult(result)}> {};`
             }
 
-            let hasRequiredArgs = argKeys.some((argName) => argName !== 'flags' && !argsConfig[argName].isFlag)
+            const hasRequiredArgs = argKeys.some(argName => argName !== 'flags' && !argsConfig[argName].isFlag)
 
             return `
       export class ${upperFirst(name)} extends Request<Partial<{
-${indent}  ${argKeys.map((argName) => `
+${indent}  ${argKeys.map(argName => `
         ${renderArg(argName, argsConfig[argName])};
       `.trim())
-            .join(`\n${indent}  `)}
-${indent}}${!hasRequiredArgs ? ` | void` : ''}>, ${renderResult(result)}> {
-${indent}  ${argKeys.map((argName) => `
+    .join(`\n${indent}  `)}
+${indent}}${!hasRequiredArgs ? ' | void' : ''}>, ${renderResult(result)}> {
+${indent}  ${argKeys.map(argName => `
         ${renderArg(argName, argsConfig[argName])};
       `.trim())
-            .join(`\n${indent}  `)}
+    .join(`\n${indent}  `)}
 ${indent}};`.trim()
         })
-        .join(`\n${indent}`)
+            .join(`\n${indent}`)
     }
 
     function renderResult(result) {
@@ -89,7 +89,7 @@ ${indent}};`.trim()
 
     function renderArg(argName, argConfig) {
         const {
-            isVector, isFlag, skipConstructorId, type
+            isVector, isFlag, skipConstructorId, type,
         } = argConfig
 
         const valueType = renderValueType(type, isVector, !skipConstructorId)

+ 1 - 1
webpack.config.js

@@ -14,7 +14,7 @@ module.exports = {
                 use: 'ts-loader',
                 exclude: [
                     /node_modules/,
-                ]
+                ],
             },
             {
                 test: /\.js$/,