refactor: move all sources to src/ (#42)

.github/workflows/check.yml

@@ -23,4 +23,4 @@ jobs:
         run: deno lint
 
       - name: Check
-        run: deno check mod.ts
+        run: deno check src/mod.ts

src/classes.ts

@@ -1,4 +1,4 @@
-import { Buffer } from "../deps.ts";
+import { Buffer } from "./deps.ts";
 
 export class CustomFile {
   name: string;

src/client/2fa.ts

@@ -2,7 +2,7 @@ import { Api } from "../tl/api.js";
 import { generateRandomBytes } from "../helpers.ts";
 import { computeCheck, computeDigest } from "../password.ts";
 import { EmailUnconfirmedError } from "../errors/mod.ts";
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 import { AbstractTelegramClient } from "./abstract_telegram_client.ts";
 import { TwoFaParams } from "./types.ts";
 

src/client/abstract_telegram_client.ts

@@ -6,7 +6,7 @@ import { Session } from "../sessions/mod.ts";
 import { LogLevel } from "../extensions/logger.ts";
 import { TotalList } from "../helpers.ts";
 import { TelegramBaseClient, TelegramClientParams } from "./base_client.ts";
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 
 export abstract class AbstractTelegramClient extends TelegramBaseClient {
   constructor(

src/client/base_client.ts

@@ -22,7 +22,7 @@ import {
   ConnectionTCPMTProxyAbridged,
 } from "../network/connection/tcpmt_proxy.ts";
 import { ProxyInterface } from "../network/connection/types.ts";
-import { Semaphore } from "../../deps.ts";
+import { Semaphore } from "../deps.ts";
 
 const EXPORTED_SENDER_RECONNECT_TIMEOUT = 1000; // 1 sec
 const EXPORTED_SENDER_RELEASE_TIMEOUT = 30000; // 30 sec

src/client/chats.ts

@@ -4,7 +4,7 @@ import { EntityType_, entityType_ } from "../tl/helpers.ts";
 import { getDisplayName } from "../utils.ts";
 import { RequestIter } from "../request_iter.ts";
 import { Api } from "../tl/api.js";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { IterParticipantsParams } from "./types.ts";
 
 const MAX_PARTICIPANTS_CHUNK_SIZE = 200;

src/client/dialogs.ts

@@ -4,7 +4,7 @@ import { AbstractTelegramClient } from "./abstract_telegram_client.ts";
 import { Dialog } from "../tl/custom/dialog.ts";
 import { TotalList } from "../helpers.ts";
 import { LogLevel } from "../extensions/logger.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { getPeerId } from "../utils.ts";
 import { CustomMessage } from "../tl/custom/message.ts";
 import { IterDialogsParams } from "./types.ts";

src/client/downloads.ts

@@ -21,7 +21,7 @@ import {
   join,
   resolve,
   WriteStream,
-} from "../../deps.ts";
+} from "../deps.ts";
 import {
   DirectDownloadIterInterface,
   DownloadFileParamsV2,

src/client/message_parse.ts

@@ -3,7 +3,7 @@ import { getPeerId, sanitizeParseMode } from "../utils.ts";
 import { AbstractTelegramClient } from "./abstract_telegram_client.ts";
 import { isArrayLike } from "../helpers.ts";
 import { EntityType_, entityType_ } from "../tl/helpers.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { CustomMessage } from "../tl/custom/message.ts";
 import { ParseInterface } from "./types.ts";
 

src/client/messages.ts

@@ -12,7 +12,7 @@ import {
   getPeerId,
   parseID,
 } from "../utils.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { _getPeer } from "./users.ts";
 import { _parseMessageText } from "./message_parse.ts";
 import { _fileToMedia } from "./utils.ts";

src/client/telegram_client.ts

@@ -32,7 +32,7 @@ import { LogLevel } from "../extensions/logger.ts";
 import { AbstractTelegramClient } from "./abstract_telegram_client.ts";
 import { TotalList } from "../helpers.ts";
 import * as types from "./types.ts";
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 
 export class TelegramClient extends TelegramBaseClient
   implements AbstractTelegramClient {

src/client/types.ts

@@ -1,7 +1,7 @@
 import { Api } from "../tl/api.js";
 import { DateLike, OutFile, ProgressCallback } from "../define.d.ts";
 import { CustomFile } from "../classes.ts";
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 
 export interface ParseInterface {
   parse: (message: string) => [string, Api.TypeMessageEntity[]];

src/client/updates.ts

@@ -1,5 +1,5 @@
 import { Api } from "../tl/api.js";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { UpdateConnectionState } from "../network/mod.ts";
 import { getPeerId } from "../utils.ts";
 import { getRandomInt, returnBigInt, sleep } from "../helpers.ts";

src/client/uploads.ts

@@ -14,7 +14,7 @@ import {
   sleep,
 } from "../helpers.ts";
 import { FloodWaitError } from "../errors/mod.ts";
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 import { SendFileInterface, UploadFileParams } from "./types.ts";
 import { CustomFile } from "../classes.ts";
 import { _fileToMedia } from "./utils.ts";

src/client/users.ts

@@ -12,7 +12,7 @@ import * as utils from "../utils.ts";
 import { isArrayLike, returnBigInt, sleep } from "../helpers.ts";
 import { EntityType_, entityType_ } from "../tl/helpers.ts";
 import { AbstractTelegramClient } from "./abstract_telegram_client.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { LogLevel } from "../extensions/logger.ts";
 import { MTProtoSender } from "../network/mtproto_sender.ts";
 import {

src/client/utils.ts

@@ -2,7 +2,7 @@ import { Api } from "../tl/api.js";
 import { getAttributes, getInputMedia, isImage } from "../utils.ts";
 import { AbstractTelegramClient } from "./abstract_telegram_client.ts";
 import { _parseMessageText } from "./message_parse.ts";
-import { basename, Buffer } from "../../deps.ts";
+import { basename, Buffer } from "../deps.ts";
 import { CustomFile } from "../classes.ts";
 import { FileToMediaInterface } from "./types.ts";
 

src/crypto/authkey.ts

@@ -6,7 +6,7 @@ import {
   toSignedLittleBuffer,
 } from "../helpers.ts";
 import { BinaryReader } from "../extensions/binary_reader.ts";
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 export class AuthKey {
   private _key?: Buffer;

src/crypto/crypto.ts

@@ -1,5 +1,5 @@
 import { ab2i, i2ab } from "./converters.ts";
-import { AES, Buffer, getWords } from "../../deps.ts";
+import { AES, Buffer, getWords } from "../deps.ts";
 
 export class Counter {
   _counter: Buffer;

src/crypto/ctr.ts

@@ -1,5 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 import { createCipheriv } from "../crypto/mod.ts";
 
 export class CTR {

src/crypto/factorizator.ts

@@ -1,5 +1,5 @@
 import { modExp } from "../helpers.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 
 export class Factorizator {
   static gcd(a: bigInt.BigInteger, b: bigInt.BigInteger) {

src/crypto/ige.ts

@@ -1,5 +1,5 @@
 import { convertToLittle, generateRandomBytes } from "../helpers.ts";
-import { Buffer, IGE as IGE_ } from "../../deps.ts";
+import { Buffer, IGE as IGE_ } from "../deps.ts";
 
 export class IGE {
   // deno-lint-ignore no-explicit-any

src/crypto/rsa.ts

@@ -5,7 +5,7 @@ import {
   readBufferFromBigInt,
   sha1,
 } from "../helpers.ts";
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 const PUBLIC_KEYS = [
   {

src/define.d.ts

@@ -1,4 +1,4 @@
-import { bigInt, Buffer, WriteStream } from "../deps.ts";
+import { bigInt, Buffer, WriteStream } from "./deps.ts";
 
 type ValueOf<T> = T[keyof T];
 type Phone = string;

src/entity_cache.ts

@@ -2,7 +2,7 @@
 import { Api } from "./tl/api.js";
 import { getInputPeer, getPeerId } from "./utils.ts";
 import { isArrayLike, returnBigInt } from "./helpers.ts";
-import { bigInt } from "../deps.ts";
+import { bigInt } from "./deps.ts";
 
 export function getEntityPair_(
   entityId: string,

src/errors/common.ts

@@ -1,4 +1,4 @@
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 
 export class ReadCancelledError extends Error {
   constructor() {

src/events/common.ts

@@ -4,7 +4,7 @@ import { AbstractTelegramClient } from "../client/abstract_telegram_client.ts";
 import { isArrayLike, returnBigInt } from "../helpers.ts";
 import { getPeerId, parseID } from "../utils.ts";
 import { SenderGetter } from "../tl/custom/sender_getter.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 
 export async function _intoIdSet(
   client: AbstractTelegramClient,

src/events/deleted_message.ts

@@ -1,6 +1,6 @@
 import { Api } from "../tl/api.js";
 import { DefaultEventInterface, EventBuilder, EventCommon } from "./common.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 
 export class DeletedMessage extends EventBuilder {
   constructor(eventParams: DefaultEventInterface) {

src/events/edited_message.ts

@@ -4,7 +4,7 @@ import {
   NewMessageEvent,
   NewMessageInterface,
 } from "./new_message.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 
 export interface EditedMessageInterface extends NewMessageInterface {
   func?: { (event: EditedMessageEvent): boolean };

src/events/new_message.ts

@@ -7,7 +7,7 @@ import {
 import { AbstractTelegramClient } from "../client/abstract_telegram_client.ts";
 import { Api } from "../tl/api.js";
 import { LogLevel } from "../extensions/logger.ts";
-import { bigInt } from "../../deps.ts";
+import { bigInt } from "../deps.ts";
 import { CustomMessage } from "../tl/custom/message.ts";
 
 export interface NewMessageInterface extends DefaultEventInterface {

src/extensions/binary_reader.ts

@@ -2,7 +2,7 @@ import { TypeNotFoundError } from "../errors/common.ts";
 import { coreObjects } from "../tl/core/core_objects.ts";
 import { tlObjects } from "../tl/all_tl_objects.ts";
 import { readBigIntFromBuffer } from "../helpers.ts";
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 import { BinaryReader as IBinaryReader } from "./interfaces.ts";
 
 export class BinaryReader implements IBinaryReader {

src/extensions/binary_writer.ts

@@ -1,4 +1,4 @@
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 
 export class BinaryWriter {
   private _stream: Buffer;

src/extensions/html.ts

@@ -1,5 +1,5 @@
 import { Api } from "../tl/api.js";
-import { Handler, Parser } from "../../deps.ts";
+import { Handler, Parser } from "../deps.ts";
 
 function stripText(text: string, entities: Api.TypeMessageEntity[]) {
   if (!entities || !entities.length) {

src/extensions/interfaces.ts

@@ -1,4 +1,4 @@
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 export interface BinaryReader {
   offset: number;

src/extensions/message_packer.ts

@@ -1,5 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import { Buffer } from "../../deps.ts";
+import { Buffer } from "../deps.ts";
 import { MessageContainer, TLMessage } from "../tl/core/mod.ts";
 import { BinaryWriter } from "./binary_writer.ts";
 import type { MTProtoState } from "../network/mtproto_state.ts";

src/extensions/promised_net_sockets.ts

@@ -1,5 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import { Buffer, Mutex, Socket, SocksClient } from "../../deps.ts";
+import { Buffer, Mutex, Socket, SocksClient } from "../deps.ts";
 import { ProxyInterface } from "../network/connection/types.ts";
 
 const mutex = new Mutex();

src/extensions/promised_web_sockets.ts

@@ -1,5 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import { Buffer, Mutex } from "../../deps.ts";
+import { Buffer, Mutex } from "../deps.ts";
 
 const mutex = new Mutex();
 const closeError = new Error("WebSocket was closed");

src/helpers.ts

@@ -1,4 +1,4 @@
-import { bigInt, Buffer } from "../deps.ts";
+import { bigInt, Buffer } from "./deps.ts";
 import { createHash, randomBytes } from "./crypto/crypto.ts";
 
 export function readBigIntFromBuffer(

src/network/authenticator.ts

@@ -19,7 +19,7 @@ import { serverKeys } from "../crypto/rsa.ts";
 import { BinaryReader } from "../extensions/binary_reader.ts";
 import { AuthKey } from "../crypto/authkey.ts";
 import { IGE } from "../crypto/ige.ts";
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 const RETRIES = 20;
 

src/network/connection/connection.ts

@@ -8,7 +8,7 @@ import {
   CancellablePromise,
   Cancellation,
   pseudoCancellable,
-} from "../../../deps.ts";
+} from "../../deps.ts";
 import { ProxyInterface } from "./types.ts";
 
 export interface ConnectionInterfaceParams {

src/network/connection/tcp_full.ts

@@ -3,7 +3,7 @@ import { crc32 } from "../../helpers.ts";
 import { InvalidChecksumError } from "../../errors/mod.ts";
 import type { PromisedNetSockets } from "../../extensions/promised_net_sockets.ts";
 import type { PromisedWebSockets } from "../../extensions/promised_web_sockets.ts";
-import { Buffer } from "../../../deps.ts";
+import { Buffer } from "../../deps.ts";
 
 export class FullPacketCodec extends PacketCodec {
   private _sendCounter: number;

src/network/connection/tcp_obfuscated.ts

@@ -4,7 +4,7 @@ import { AbridgedPacketCodec } from "./tcpa_bridged.ts";
 import { CTR } from "../../crypto/ctr.ts";
 import type { PromisedNetSockets } from "../../extensions/promised_net_sockets.ts";
 import type { PromisedWebSockets } from "../../extensions/promised_web_sockets.ts";
-import { Buffer } from "../../../deps.ts";
+import { Buffer } from "../../deps.ts";
 
 class ObfuscatedIO {
   header?: Buffer = undefined;

src/network/connection/tcpa_bridged.ts

@@ -2,7 +2,7 @@ import { Connection, PacketCodec } from "./connection.ts";
 import { readBufferFromBigInt } from "../../helpers.ts";
 import type { PromisedNetSockets } from "../../extensions/promised_net_sockets.ts";
 import type { PromisedWebSockets } from "../../extensions/promised_web_sockets.ts";
-import { bigInt, Buffer } from "../../../deps.ts";
+import { bigInt, Buffer } from "../../deps.ts";
 
 export class AbridgedPacketCodec extends PacketCodec implements PacketCodec {
   static tag = Buffer.from("ef", "hex");

src/network/connection/tcpmt_proxy.ts

@@ -5,7 +5,7 @@ import { CTR } from "../../crypto/ctr.ts";
 import type { Logger } from "../../extensions/logger.ts";
 import type { PromisedNetSockets } from "../../extensions/promised_net_sockets.ts";
 import type { PromisedWebSockets } from "../../extensions/promised_web_sockets.ts";
-import { Buffer } from "../../../deps.ts";
+import { Buffer } from "../../deps.ts";
 import { ProxyInterface } from "./types.ts";
 
 export class MTProxyIO {

src/network/mtproto_plain_sender.ts

@@ -4,7 +4,7 @@ import { toSignedLittleBuffer } from "../helpers.ts";
 import { InvalidBufferError } from "../errors/mod.ts";
 import { BinaryReader } from "../extensions/binary_reader.ts";
 import type { Connection } from "./connection/connection.ts";
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 export class MTProtoPlainSender {
   private _state: MTProtoState;

src/network/mtproto_sender.ts

@@ -29,7 +29,7 @@ import {
   Cancellation,
   Mutex,
   pseudoCancellable,
-} from "../../deps.ts";
+} from "../deps.ts";
 
 export class UpdateConnectionState {
   static disconnected = -1;

src/network/mtproto_state.ts

@@ -16,7 +16,7 @@ import {
 import { BinaryReader } from "../extensions/binary_reader.ts";
 import type { BinaryWriter } from "../extensions/binary_writer.ts";
 import { InvalidBufferError, SecurityError } from "../errors/mod.ts";
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 export class MTProtoState {
   private readonly authKey?: AuthKey;

src/network/request_state.ts

@@ -1,5 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import { bigInt, Buffer } from "../../deps.ts";
+import { bigInt, Buffer } from "../deps.ts";
 
 export class RequestState {
   public containerId?: bigInt.BigInteger;

src/password.ts

@@ -7,7 +7,7 @@ import {
   readBufferFromBigInt,
   sha256,
 } from "./helpers.ts";
-import { bigInt, Buffer } from "../deps.ts";
+import { bigInt, Buffer } from "./deps.ts";
 import { pbkdf2Sync } from "./crypto/crypto.ts";
 
 const SIZE_FOR_HASH = 256;