Telegram-Leecher.ipynb

{
  "cells": [
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "RU83_DRgK3Si"
      },
      "source": [
        "# 🦀[Telegram-Leecher](https://github.com/XronTrix10/Telegram-Leecher)🦀\n",
        "\n",
        "1. ⬆️ Upload Your Custom THUMBNAIL ( name = thmb.jpg )\n",
        "\n",
        "2. ⬆️ Upload Your token.pickle File\n",
        "\n",
        "### ⚠️ NOTE: File names should be exactly same as mentioned\n",
        "\n",
        "## 👇 It should look like 👇\n",
        "![2023-03-20 11_46_08-Try.ipynb - Colaboratory - Brave.png](data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAASQAAAEhCAIAAABZVkoIAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAAASdEVYdFNvZnR3YXJlAEdyZWVuc2hvdF5VCAUAABocSURBVHhe7Z1PbBvHvcd7fqd3ead3eqd36emdaDSJu0laRnbjiE+2rFZwEdWx1BAvNRyYbc3ApZvIgFVDsiq6jlyndK2klmvQQiDApRHQMAMkRAoQARGBhxbw+b3rO/T83nfmN1wul/+WFHe4JL8fLOyZ2Znd4XI+O7NDcfitGCHECpSNEEtQNkIsQdkIsQRlI8QSlI0QS1A2QixB2QixBGUjxBKUjRBLUDZCLEHZCLEEZSPEEpSNEEtQNkIsQdnI2DM7O3urHzKZDIqYwhahbGTsef78+T/6BEVM4c5ASGTroiV27e3tBfeWspHxBm0d8kijb4vY1Qp2mUN0QBzu5BsSv/zyS2TAvyapF5SNjDeiEwaHJt7MYWRDhk6+ISqmYZdJCgBlI+ON6BSGbAB5Wn1DYADTAGUj443o1EU2NSXSjKjiytMdZPP6BgYzDURCtuXL2eyWb1tLzcViTmr708L+7ZSDTHOpNaRfXpYihAho/V1kawsyB5cNIKfr28CmgR6yyW0AJ1tZWVH3hM5kMhlTpn82ntRaqOy+G4ttFnS4sIFM7+5WEHyigoS4WJANuL6BwUwDPWSTE4hpcqZO7O3tmTL9o2Urbp9dWmpsiwl0Z04y+7CQ30qqno2ykXZYk036NAAp+irr0kM2aAZMJDS0bLr78hOfh3gLcRVskS2+kFpVA86NzDmdoUF8/ueraiy6nknOKk/JBGNBNtc0aCbdz2C+ReKZrbNsG2ocKYI1ybaYeVhGzKWyv7aod+Axb+cLk6ipFjbNHjKRhC2b1zSJDuxbb9n6PeIAaNnKeTM1ojczEdJetuW7JQQrj7OpWceZTa4+UuKV7qoijn7MqzxMYxQaP7ea/6JSerSxpMqTyQTtMzzZkKd1RgSJg/nWQzY5E46YyWQQ7kJfr9ZHmwkS04O1lS2dR6iST+scmkz+61rt85ySal3L9mh1eUZ2kQkHjTMk2ZABDdtnmoBdA/gWaIIEh+sp26FnI5snSOQ5ra1sTraIQBv0QNRJ5Z5VJV79qlS4t7rEp7aJBo0TTbTLn2u1ElA2HLOtaQKKix1o/CapF9EZRgZ+ZhPZnm43zDTbfH2exElcXN2+v1+Ux7ryznmTTiYQtE80dzT6fjHlOyNHNpF2SIbgM4jjOEFyfvcrNfGxMaezKBYzNzfOy7hxZnn1dlZ/Cg6ctccooz+yI5MLGj0GVuivgmNK2qWHbHgZI536bz9BsrhZUCPFSiG3nkldzub1uLF8XymWfqhyVT/PZy8nU1d3impPMdvQkpCR0UM26XChHG4GEu7EoT/U7mvq30luFSoHiBvKDzP1qf9k9rHKaDio7F/j1D+JBD1kg2NiEfo31ft2xkIH6MdJLOqntfmWiUdndrH5KY6Q0ROJZzZCpgHKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWKJ8ZNtZWWlywq4t0a0/iYhPRk/2WSB9S7QNxJNxk82McpEmpFdIDzf0K+2td2+4dGpSVtkLW1UJpPJIICo2THFTKZsIKQ2F50RbDTH0l0Wz8atYYQViwITKxsI4601h+4TtDPc3c0hhoQ5dJ+EUROXTpp5mWblJlk2MPT31Ry3f9DIzCGGhDluZ3BG9H4AAZOkGXpNBF9Pi6hYjb5OftzP7NAc5pchxpcJlw2YfUNisGMOVqo7cswuuI9JCJikOpI+RIK45Ov3UMTsmBomSjYfwXMGZ7BjDlaqO3LMTqBle1s8wmaHxqQOCd/BXYvELu+4ccr7N8rWH4Mdc7BS3ZFjtkUGijINKJl9nZskDoXWblN+8NnXj4lXqI+Ja1DP8B4gI8iEyCY/PGkiddrmPCRhHHMwpCZtcR+WvF0HLpHZPdT6+zorIMPXtg+KrWZO1WByEmRzm5HPN0k0kSER/JioDNo6kDs9WtVwG5bUpBXvWXBqOTtAQ8cuySMpQ8E9pktb2YDkN5E6w70mEac/2eQ6jhZ5k0yk+YYNvL5JiokMiSDHdAdLaHDS5iRgRzbveyTnNRFPxUx8GLR2VtKv+oaR8r743izAYaQfXFDcoeXqSKMZoXVSDQn73jzUDf+6vkmihIdFkGPqFm6eRnCh3EpakM17r3HPi8rg1IKkmBxDwucVzoJEvHCky6Vwa+VWQECjkvQpobds7u0QlwZXTazDFRzVPUkqI2F5m90ayrvrvoWSKOFh0fOY0sTdm5HUUJBWOCzMQZvx3gTbNmW5ViYyJMQrqYCAqNnnQVqOy3CvxljQWza5G3nVwsXVN6xQPhvtibxVJqIrg3/dRG893cQh0vOYaFLeZoTqoUqC14TDIzXx4QqGQNvTybtpIsMD5/L5huaB+w7SAV67nNdlCk0DPWST+zT+NfE6uHxIx78mbhH9ZvmbS/DEQ9LzmD7ZwkNq4gNNXBp3275F3jVg4kMF5/X51hbUsG3dpoEessnlw3U08TpIQfpIrpp+y0Ymm+8O7QOtWW5PvtuQtPLWe9Zh6FQTNeTwPKR5kQwImEOEQBflplkzIZBsJtIM0t1Bi030GxdIoeA5gwNt3FbbCnahtUlzd+9QbopEh0X3mnQC1fDdCEICrxonwv0FTcjOGaNPD9lwmfAOtV6sTsNLC6C56GYTiKE38SCIXXJ2N8AGR3rI1nqfBiHdqgMCw3FqrVIPcOMfVRPHJUI9UQF0/lM+diIuPWQDaDdouGjf0m6ANOVO812EkLb0lg1AKu/jgffJhKMjQgISSDYXb1fm9nj0jZAg9CebD/pGSHAOJRtwffN2eoSQVg4rG4Bm7NkI6ckQZCOEBIGyEWIJykaIJSgbIZYYvWxLhIwzph0HgD0bIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZYYe9lW9I9I7HlA1OwjJEqMvWxqIcsW6BuJIOMtm/zkQECee34nkRD7TJpsMMqEOsCFwMiomCjZZF1099cI2oIipjAhdpkc2WCaJHb3jbKRUTEhsrmmCV18o2xkVEyCbLL4OTCp9UWa9/b2RDAvlI2MiskZRkI5k9r110k7yLaYvrm9lnRU0Emu3c6mF3UyIcODsgmr+9Va+V5SBc/mSrVa4bpOJmR4UDZCLDFRsrmYpHZQNjIqxlu2Wf3rcH3hnUchxCZDkG20zRc9lf7z40Dwz0fICOkhG1rnlxoTb4dk4PCMkO70kA3jLjwCmUhnIBtymgghpB3dZJMnIoy+TFwjnxdLGAEZQyIPH4cI6U4fsiEqc30AUenNZK/8bRRlI6QLffds4hVMQ7prF2UjpCe9ZYNIJq7B0FFkM3GNfN5F2QjpQkfZYA6MwojRp5AY6JMNicjp7esIIT46yoYeDPK0yiaPavLY5uIaSNkI6US3YaSMGL0foCEFRskTmtgodrkpko0Q0krQZzbp5aRDEwm9dnGCpJX5+flsNvunP/3pk08+2djY+N73vmd2kGklqGwII+DqhO7O2+ONULYf/vCH6XT6Nx4QNftGx5EjR9bX12/fvv2Tn/xkYWHh7NmzZgeZYoLK1p0Ryva0HSP37dixYzDt6tWrJk5Id9kAxo2+ice2IBtkM5GB+MEPfmBC/ZBMJo1eAcjn8+j3TMmuLC0t/f73v79///7HH3/8wQcfvPzyy0jEreTGjRsYE8qw8PXXX0cixoofffTRlStXcrkc8kMw9GNIvHv3LqIAgTfffNMVDz3er3/9axwWB9nc3Lxz5w6FnB56yIYuq6dv2IsnOu+ocgB++9vfHj9+3EQC05dsAoadpnAHYMsf/vAHOADHzp07B1suXbqEMB7Abt68eVKzvb2NKBLFK7h05syZ06dPI4DRIw7i7dm84QsXLuzs7PziF7/AzQVXDMpRtumhh2yChfEhZPvzn//cr28DyIYipnAH3nvvPXQ47ktOpVKXL1/+6U9/CqncRy8EEEUiZEOf9s4770g6zIGHr732WlvZ0K2hNwMIeNN1UTL5BJLNApANJvTrWxiyofVvbW2JDy4XL170Gjg3N4feD4kyjIR1ko6y8AcWeUVyw95Eb7pEycQTLdlAX76NSrZTp06hZ6NspC8omx/fMPKtt956++23uwwjg8uGMMaQeKjjMHI64TBS8fLLL6Ob+vGPf4xwlwkS9HiJROLkyZO/+93v3AmSvmS7cOHCvXv3cC5OkEwhEZJthBMkUAi92fvvvy9Rd+r/j3/8469+9asXX3wRiejrIJua+P/kkxs3bkjX169s6NM49T+1REi2fk0Dw5LNGpBN1AXQFbKhl5MomXiiIpuFD7WF0coGtba3t8+cOYMhKPq0XC73ox/9yOwjk05UZBuMmZkZ41BgUMQUHgVw7IMPPtjZ2cEYFU+Gb7/9ttlBpoDxlg2gp5K/Pw5Czz8fISQ8xl42QsYFykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiiYZs/3Phn2QzcRIKG4VarbBpIoOwWah9tXveRMg4Mfayrays3Lp1a89DkLX3Rkf4sr27W6lVdt81MRIdxl62f7Qjwr5RtuklKrLNzc2ZUD9k9E9VBeS5/p0dU7IF52KuWKkpDirFe+m4SU1mH5erByq5Wt5fW9SJqjUXd+8WKzq98jSXenNtv6zCtYPy/jXJBKkq+Xv7ZZ2n9kU+I8lNsjmp20WTAQd/05HUNizWj18p7j4qubKhdoVyVaUfVMufqtqdvy+vQVG5r3O1fQlkFERFtkKhcPLkSRMJTF+yCR1+/WN1v1orP0gnHCfx3m65Vt2/ppr+6qdI3U3POjFnKfukWnuaTSBVyVYrP1pNzsYTF3dKaMUH5fzV5fjMfOaBKrqqDqikqj7dTi3E4+dW81BFynpkW9wqVquF7Ll4bGZ59VGlc3+1nPtcHwqnS+pDmZxunWPOm9lCtVa8qc/Q3LO1fwlkFERItr/97W/9+jaAbChiCjcBB6r5K9K3JFLXs2sX0SadxJmlRTRTAeO3WmEDAd2zZU2yk/2sVvusHms0dNWz7da/hO1cgxelbdV5u7Kd3/2qVvqw3vLntku18s5/mVgT6pjlnfotwtkqGtmcxOLZRZgmbDyp1R6r2jXL1uElkFEQIdlgQr++DU+2hOpb0F893d+9mVl2v186c94dg2lc2RpNVrXyJ/WYTzb3wcnJFhvpIpsKNOPJ7wWGmN5S43lmi/+sPowUpBpNsnV4CWQUREs20Jdvw5NNET+X2bibL2KcVi3lVGNNbGDcVd7NLOgnuKaerU/ZVMfVKlt1P8hiP51km9vA0LH8IDOvbw2NajTJ1uElkFFA2TTnMtmtzLKJLO98IbMLaqRXn8zQ47eBZbucbxlGpvPI+tD9tR3HqY/1/KhjthtGNlVDj2bbyNbhJZBRwGGkZiVXqlWLt8/j/h8/t12EGXeWYrElNTPxLJdamJ//+Xbx6/oYLKhsMqvhOLNpNeXyZMM3QbJ8t4Rxa/79JScWX76aL1f2V0+o9Ba8EyQb+xjtimxnVZ1Ld1LzC/Op26hyvRpqyFotXE8kZvFqOrwEMgo4QWJYvLLrTv2XHtZnyL1z7vcwatO9U1DZKoUHBZnZrz7bbTf1H0/fM58fqONf6Twr32Hqf/Ga+Wih8nR353G19mxb+2yeP818SduXQEZBhGTr1zQwRNmGjZKtMYwMiHLVR/8HIVElKrJZ+FBbiLRsZKLpIduJo/+RPvHv3s3siAaz+oeI+8L9xYyQoWzETw/Z3ER3u7/4r2ZfNEBPJX9/HIQOfz5CiA26yYZ+zE30bt8k/7l49l98242T/2aKEULa0Vs2qBVkQ863vv9tU5IQ0kJv2fDYZuKdQR7kjNoTHSGRYvSy/d+3vsWNm7uZZjGJUDZu0dpeffXVl156yTSOySIqsp04cSJBphtpCQgcP37c/cnISSIqsuES/yeZbqQlzM/PIxyPx1944QXTRCaFaMn2xhtvoIsj04m0hIWFBfiG6CuvvPKd73zHtJKJIFqy4RJjCPHaQPyyhZWVFbOPjAOubKdPn0ZjQMrRo0ePHDliGsr401s2/PvW97/dfXNzmpL94JMNlxi3NKcfINV/d2Bzc9Nk6od3cp//dW/NRPokQNkzv7y29sszJkJcpCWcOnVKRpLHjh1D4iR1bt1kk/4q+BakD2ylVTZcYozXcZUDcvPmzf9t4e9//7uk41+Tryvrf/nmm7+sS/j8J391w/3Su+zZj55+883j35gYcZGWgGYwNzeHB4qZmZkpkg3AH/RXQTZToH/aytbXJd7b2zN/Zezh+fPn2HXr1i2Egywj6f1amloQzv2KWp8cpuyUc/iWEHF6yGaBUGUDQXwrmC+PAfWtUCXMZ7m1T/WXLg8qxbspWbIAQlYe7XiWiFxKeVeP1Jl02d3cU/3FNE9ZD43vj/oyFz5M1jMvNs5+P19qfN90kqFsoRO2bCCIb/6eTa2SkErMJJIfqkUScmdVuspTLW7/fD4+s6zWJziAY7JagVq2sXR3yV/2JpIr+UuqrIdm2Wrl/NUkMuulDUxmtWJCtbRzeT4xm1x9pKyjbBPAxMoGYJdL9+WQgV82s8QA0G6s6xB6tgcpnRiLXdQrINRXhnSL686qvoxkLLH9rGlpLI2vZ3Mzq4WGqo8ySN79qr6esaKRf7KhbKETnmw++pOt8dzVaOtKNteBxnIjiibZGmVjqQetj3DNsrXJ7LOLsk0IlM0QBdkyj6o6StkoWzhMoGx9DSMbJ9KZ1TAyuVOule/Vl7GkbJMCZTOoLuiLneRsIuEcWrZ2EyROcm37ZlqvVtcsm5ogWY7H4ss6sxxQT5ComRhOkFC2YRIR2WLv5kpqDVP16xaHla3dbP7SnVLtoLCmgs2yPcvvupm3OPVP2cIkKrLZo1m2htVecA1MyPM7ARMOZQudqZINLy3+MzyRmc8MOsmWvFeWpctjM8vqR9XqSyBPNpQtdKZKtuTHanBYebwhS4137Nl8Pxfa5UdJJwjKFjpTJRvpAmULncNf4oCLkHOF1ogzRbKNiqFcYogE5bpga9VxMjiULXQm/hKTgFC20KFsRKBsoUPZiEDZQoeyEYGyhQ5lIwJlCx3KRgTKFjrDusRmjt8DP1gbLyhb6Bz+EkMq87l1C7cCrKsVnM5/NzxEFtPrG/JVnPaobxuoVYmaafxx8/hC2ULn8JcYRhm3PDx//lzSA/rmfkemC1ZkWysc1Ep31NpB7aFsY8skyNb2byMPs25kJ6zI1gvKNrZMuGwgiG9oqXWkHTtL1/Ml/ZXOWqWUv2ZGdR7ZFjeeVGvl3fSMjlxzMxd3LsVVklKimLu+X25eVdKL+iqqZxXK/BU5i1cbJ7lVkCPgyLuSwSPb4mZBVUKdsalU6nbRlBqrbwxQttAJWzYQxDdvz+Zczldqlf31xmoF+cuqydZlc1L3y7VqQb4n46g17cq77yUcJ5G6U6oifU6UqOnvpMUTyW219KReVdKLOmN9FUq99kExi4IebRLr2iUcORY/r1aV1BnqsuG8qhKbfkUXt4qoQ/ZcPKYOWxmj78JRttAJSTYAu1z6WTfSQbi6v1bvEZy1fbXoFaIim+lPLsp+nVmt0iNk8l/rRSaVEqVtJY9CHfyxMdkFiY1VKPVJSh8mPNq46/8IyxsPC7lLddkWN1Ql7rv9pVtKrTmpj6NR3/JWCz2MBZQtdMKTzUdg2Zrbayy2dLck/YOS7VmphDHdw3S9lavMPlSj9wz2gOfgDZRs7oomMSf7mUSbtClu1c/jojUuPUMl8m4lPKVUoJmxWVKBsoVO9GVTX692ZcMo8VKudOD2bDpzyxCxf9lUPxZYNowe07nP2/ZsCFT3r0rimEHZQid6svUYRiLpPPQr7+qWnsg+rdWeZl01UXn1X9+yqfFn12HkYno9mznnOfK7O+WG826ptHrcfJjWicBUZyygbKETEdm860bqCZL6co7r+2i9zRMkaMMpdDt44kKqcxUuVou3z8djTuLidvHrci7ZUTbP6pE6sVrcvqhmVtIP9IxLPxMkqhKo81fifKOUWnMSlX9/CaWWr+bLlf3VEyo9+lC20ImIbN51I9GOl67vl6vyyFPKX0fDVTRkQw49Y6kl9GQ+KJu1HzvI5lk9Uvdsj3cLMvX/dcnM7Hu0UW66U//l4nbjQ4X6kZ2MqsSjjNNUKp6+Z37IqvGBwThA2UInKrJZp3kYSShb+FA2IlC20KFsRKBsoTO1shEflC10Dn+JM1w3ciKgbKEzlEvMdSMnAMoWOhN/iUlAKFvoUDYiULbQoWxEoGyhI5eYGzfZKFuI+K41tynfKFu4vPrqq7jE8/PzC5pTp07hciOFTCF46ylbiLz00kvHjx/HJYZvp0+fxr9zc3Ny0ckUAuUoW4i8+OKL8Xgcl1gu9xtvvIEwmVpef/11yhYiL7zwwiuvvIJLfOzYsZmZGQTINIObL2ULEVzZo0eP4hITAr773e9SthA5cuQIri8hAtqDaRnjT+RkI2RSoWyEWIKyEWIJykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZagbIRYgrIRYgnKRoglKBshlqBshFiCshFiCcpGiCUoGyGWoGyEWIKyEWIJykaIJSgbIZagbIRYgrIRYoVY7P8BlC4WUdxmN9sAAAAASUVORK5CYII=)"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "cellView": "form",
        "id": "q7HC3z2JwqCz"
      },
      "outputs": [],
      "source": [
        "#@title ⚙️ Set-up Modules and Environments [ MUST ]\n",
        "\n",
        "!git clone https://github.com/XronTrix10/Telegram-Leecher &>/dev/null && bash /content/Telegram-Leecher/setup.sh &>/dev/null\n",
        "\n",
        "import shutil, os\n",
        "if os.path.exists(\"/content/sample_data\"):\n",
        "    shutil.rmtree(\"/content/sample_data\")\n",
        "\n",
        "print('Files and modules setup Successfull')"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "id": "D2atQB36K9ig"
      },
      "outputs": [],
      "source": [
        "#@title ✒️ Edit the Variables with your data and Run this cell\n",
        "API_ID    = \"\"           # <== YOUR TELEGRAM API ID HERE\n",
        "API_HASH  = \"\"           # <== YOUR TELEGRAM API HASH HERE ( Place Inside Quotes )\n",
        "BOT_TOKEN = \"\"           # <== YOUR TELEGRAM BOT TOKEN HERE ( Place Inside Quotes )\n",
        "CHAT_ID   = \"\"           # <== YOUR CHAT ID WHERE ALL STATUS AND LOGS WILL BE SHOWN\n",
        "DUMP_ID   = \"\"           # <== CHAT ID WHERE ALL FILES WILL BE UPLOADED ( MUST BE A CHANNEL OR SUPERGROUP ) [ ID STARTS WITH -100 ]\n",
        "LEECH_DOCUMENT = False   # Change it to True to leech as Document\n",
        "\n",
        "# ⚠️ 👇🏻 Edit The Below Variables Only If you are on Mobile 📱\n",
        "\n",
        "'''\n",
        "'L' => Leech\n",
        "'Z' => ZipLeech\n",
        "'U' => UnzipLeech\n",
        "\n",
        "'''\n",
        "LEECH_MODE  = \"\"           # <== Leech Mode\n",
        "D_LINK      = \"\"           # <== YOUR Download Link\n",
        "C_NAME      = \"\"           # <== Custom Name [ Leave Empty For Default ]\n",
        "\n",
        "# NOTE: Currently only one link is supported for Mobile users\n",
        "\n",
        "print('BOT Variables Initialized ! 💖')"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "5cQBmcILyrid"
      },
      "source": [
        "# 🏃 RUN THE BELOW CELL TO START LEECHING 🦀\n",
        "\n",
        "#### 📣 Join our Channel For Latest Updates and Features: [Colab Leecher](https://t.me/Colab_Leecher)\n",
        "\n",
        "#### 💬 For any issues or suggestions, Ask in : [Discussion Group](https://t.me/+2n9HLR2F1uJhZGY1)"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "cellView": "form",
        "id": "NOdAOzwaQfwi"
      },
      "outputs": [],
      "source": [
        "# @title 🖥️ Main Colab Leech Code [ Click on RUN for Magic ✨ ]\n",
        "import os, io, re, sys, time, math, pytz, psutil, shutil, pickle, uvloop, pathlib, datetime, subprocess\n",
        "from PIL import Image\n",
        "from pyrogram import Client\n",
        "from natsort import natsorted\n",
        "from urllib.parse import urlparse\n",
        "from re import search as re_search\n",
        "from os import makedirs, path as ospath\n",
        "from IPython.display import clear_output\n",
        "from urllib.parse import parse_qs, urlparse\n",
        "from googleapiclient.discovery import build\n",
        "from googleapiclient.errors import HttpError\n",
        "from googleapiclient.http import MediaIoBaseDownload\n",
        "from moviepy.video.io.VideoFileClip import VideoFileClip\n",
        "from pyrogram.types import (\n",
        "    ReplyKeyboardMarkup,\n",
        "    InlineKeyboardMarkup,\n",
        "    InlineKeyboardButton,\n",
        ")\n",
        "\n",
        "uvloop.install()\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    Local OS Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "def convert_seconds(seconds):\n",
        "    seconds = int(seconds)\n",
        "    days = seconds // (24 * 3600)\n",
        "    seconds = seconds % (24 * 3600)\n",
        "    hours = seconds // 3600\n",
        "    seconds %= 3600\n",
        "    minutes = seconds // 60\n",
        "    seconds %= 60\n",
        "\n",
        "    if days > 0:\n",
        "        return f\"{days}d {hours}h {minutes}m {seconds}s\"\n",
        "    elif hours > 0:\n",
        "        return f\"{hours}h {minutes}m {seconds}s\"\n",
        "    elif minutes > 0:\n",
        "        return f\"{minutes}m {seconds}s\"\n",
        "    else:\n",
        "        return f\"{seconds}s\"\n",
        "\n",
        "\n",
        "def size_measure(size):\n",
        "    if size > 1024 * 1024 * 1024 * 1024 * 1024:\n",
        "        siz = f\"{size/(1024**5):.2f} PiB\"\n",
        "    elif size > 1024 * 1024 * 1024 * 1024:\n",
        "        siz = f\"{size/(1024**4):.2f} TiB\"\n",
        "    elif size > 1024 * 1024 * 1024:\n",
        "        siz = f\"{size/(1024**3):.2f} GiB\"\n",
        "    elif size > 1024 * 1024:\n",
        "        siz = f\"{size/(1024**2):.2f} MiB\"\n",
        "    elif size > 1024:\n",
        "        siz = f\"{size/1024:.2f} KiB\"\n",
        "    else:\n",
        "        siz = f\"{size} B\"\n",
        "    return siz\n",
        "\n",
        "\n",
        "def get_file_type(file_path):\n",
        "    extensions_dict = {\n",
        "        \".mp4\": \"video\",\n",
        "        \".avi\": \"video\",\n",
        "        \".mkv\": \"video\",\n",
        "        \".mov\": \"video\",\n",
        "        \".webm\": \"video\",\n",
        "        \".vob\": \"video\",\n",
        "        \".m4v\": \"video\",\n",
        "        \".mp3\": \"audio\",\n",
        "        \".wav\": \"audio\",\n",
        "        \".flac\": \"audio\",\n",
        "        \".aac\": \"audio\",\n",
        "        \".ogg\": \"audio\",\n",
        "        \".jpg\": \"photo\",\n",
        "        \".jpeg\": \"photo\",\n",
        "        \".png\": \"photo\",\n",
        "        \".gif\": \"photo\",\n",
        "    }\n",
        "    _, extension = os.path.splitext(file_path)\n",
        "\n",
        "    if extension.lower() in extensions_dict:\n",
        "        if extensions_dict[extension] == \"video\":\n",
        "            new_path = video_extension_fixer(file_path)\n",
        "        else:\n",
        "            new_path = file_path\n",
        "        return extensions_dict[extension], new_path\n",
        "    else:\n",
        "        return \"document\", file_path\n",
        "\n",
        "\n",
        "def shorterFileName(path):\n",
        "    if os.path.isfile(path):\n",
        "        dir_path, filename = os.path.split(path)\n",
        "        if len(filename) > 60:\n",
        "            basename, ext = os.path.splitext(filename)\n",
        "            basename = basename[: 60 - len(ext)]\n",
        "            filename = basename + ext\n",
        "            path = os.path.join(dir_path, filename)\n",
        "        return path\n",
        "    elif os.path.isdir(path):\n",
        "        dir_path, dirname = os.path.split(path)\n",
        "        if len(dirname) > 60:\n",
        "            dirname = dirname[:60]\n",
        "            path = os.path.join(dir_path, dirname)\n",
        "        return path\n",
        "    else:\n",
        "        if len(path) > 60:\n",
        "            path = path[:60]\n",
        "        return path\n",
        "\n",
        "\n",
        "def get_folder_size(folder_path):\n",
        "    if os.path.isfile(folder_path):\n",
        "        return os.path.getsize(folder_path)\n",
        "    else:\n",
        "        total_size = 0\n",
        "        for dirpath, _, filenames in os.walk(folder_path):\n",
        "            for f in filenames:\n",
        "                fp = os.path.join(dirpath, f)\n",
        "                total_size += os.path.getsize(fp)\n",
        "        return total_size\n",
        "\n",
        "\n",
        "def get_file_count(folder_path):\n",
        "    count = 0\n",
        "    for _, __, filenames in os.walk(folder_path):\n",
        "        for f_ in filenames:\n",
        "            count += 1\n",
        "    return count\n",
        "\n",
        "\n",
        "def video_extension_fixer(file_path):\n",
        "    _, f_name = os.path.split(file_path)\n",
        "    if f_name.endswith(\".mp4\") or f_name.endswith(\".mkv\"):\n",
        "        return file_path\n",
        "    else:\n",
        "        os.rename(file_path, os.path.join(file_path + \".mp4\"))\n",
        "        return os.path.join(file_path + \".mp4\")\n",
        "\n",
        "\n",
        "def Thumbnail_Maintainer(file_path):\n",
        "    thmb = f\"{d_path}/video_frame.jpg\"\n",
        "    if os.path.exists(thmb):\n",
        "        os.remove(thmb)\n",
        "    try:\n",
        "        with VideoFileClip(file_path) as video:\n",
        "            if os.path.exists(custom_thumb):\n",
        "                return custom_thumb, video.duration\n",
        "            else:\n",
        "                video.save_frame(thmb, t=math.floor(video.duration / 2))\n",
        "                return thmb, video.duration\n",
        "    except Exception as e:\n",
        "        print(f\"Thmb Gen ERROR: {e}\")\n",
        "        return thumb_path, 0\n",
        "\n",
        "\n",
        "def Thumbnail_Checker(dir_path):\n",
        "    for filename in os.listdir(dir_path):\n",
        "        if filename.endswith(\".jpg\"):\n",
        "            os.rename(os.path.join(dir_path, filename), custom_thumb)\n",
        "            return True\n",
        "    # No jpg file was found\n",
        "    return False\n",
        "\n",
        "\n",
        "def system_info():\n",
        "    ram_usage = psutil.Process(os.getpid()).memory_info().rss\n",
        "    disk_usage = psutil.disk_usage(\"/\")\n",
        "    cpu_usage_percent = psutil.cpu_percent()\n",
        "\n",
        "    string = \"\\n\\n⍟───── [Colab Usage](https://colab.research.google.com/drive/12hdEqaidRZ8krqj7rpnyDzg1dkKmvdvp) ─────⍟\\n\"\n",
        "    string += f\"\\n╭🖥️ **CPU Usage »**  __{cpu_usage_percent}%__\"\n",
        "    string += f\"\\n├💽 **RAM Usage »**  __{size_measure(ram_usage)}__\"\n",
        "    string += f\"\\n╰💾 **DISK Free »**  __{size_measure(disk_usage.free)}__\"\n",
        "    string += f\"\\n\\n<i>💖 When I'm Doin This, Do Something Else ! **Because, Time Is Precious ✨**</i>\"\n",
        "\n",
        "    return string\n",
        "\n",
        "\n",
        "async def zip_folder(path):\n",
        "    dir_p, p_name = os.path.split(path)\n",
        "    r = \"-r\" if os.path.isdir(path) else \"\"\n",
        "    if len(custom_name) != 0:\n",
        "        name = custom_name\n",
        "    elif os.path.isfile(path):\n",
        "        name = os.path.basename(path)\n",
        "    else:\n",
        "        name = d_name\n",
        "    zip_msg = f\"<b>🔐 ZIPPING » </b>\\n\\n<code>{name}</code>\\n\"\n",
        "    starting_time = datetime.datetime.now()\n",
        "    cmd = f'cd \"{dir_p}\" && zip {r} -s 2000m -0 \"{temp_zpath}/{name}.zip\" \"{p_name}\"'\n",
        "    proc = subprocess.Popen(cmd, shell=True)\n",
        "    total = size_measure(get_folder_size(path))\n",
        "    while proc.poll() is None:\n",
        "        speed_string, eta, percentage = speed_eta(\n",
        "            starting_time, get_folder_size(temp_zpath), get_folder_size(path)\n",
        "        )\n",
        "        await status_bar(\n",
        "            zip_msg,\n",
        "            speed_string,\n",
        "            percentage,\n",
        "            convert_seconds(eta),\n",
        "            size_measure(get_folder_size(temp_zpath)),\n",
        "            total,\n",
        "            \"Xr-Zipp 🔒\",\n",
        "        )\n",
        "        time.sleep(1)\n",
        "    if os.path.isfile(path):\n",
        "        os.remove(path)\n",
        "    else:\n",
        "        shutil.rmtree(path)\n",
        "\n",
        "\n",
        "async def extract_zip(zip_filepath):\n",
        "    starting_time = datetime.datetime.now()\n",
        "    dirname, filename = os.path.split(zip_filepath)\n",
        "    unzip_msg = f\"<b>📂 EXTRACTING »</b>\\n\\n<code>{filename}</code>\\n\"\n",
        "    file_pattern = \"\"\n",
        "    name, ext = os.path.splitext(filename)\n",
        "    if ext == \".rar\":\n",
        "        if \"part\" in name:\n",
        "            cmd = f\"unrar x -kb -idq '{zip_filepath}' {temp_unzip_path}\"\n",
        "            file_pattern = \"rar\"\n",
        "        else:\n",
        "            cmd = f\"unrar x '{zip_filepath}' {temp_unzip_path}\"\n",
        "\n",
        "    elif ext == \".tar\":\n",
        "        cmd = f\"tar -xvf '{zip_filepath}' -C {temp_unzip_path}\"\n",
        "    elif ext == \".gz\":\n",
        "        cmd = f\"tar -zxvf '{zip_filepath}' -C {temp_unzip_path}\"\n",
        "    else:\n",
        "        cmd = f\"7z x '{zip_filepath}' -o{temp_unzip_path}\"\n",
        "        if ext == \".001\":\n",
        "            file_pattern = \"7z\"\n",
        "        elif ext == \".z01\":\n",
        "            file_pattern = \"zip\"\n",
        "\n",
        "    proc = subprocess.Popen(cmd, shell=True)\n",
        "    total = size_measure(get_folder_size(zip_filepath))\n",
        "    while proc.poll() is None:\n",
        "        speed_string, eta, percentage = speed_eta(\n",
        "            starting_time,\n",
        "            get_folder_size(temp_unzip_path),\n",
        "            get_folder_size(zip_filepath),\n",
        "        )\n",
        "        await status_bar(\n",
        "            unzip_msg,\n",
        "            speed_string,\n",
        "            percentage,\n",
        "            convert_seconds(eta),\n",
        "            size_measure(get_folder_size(temp_unzip_path)),\n",
        "            total,\n",
        "            \"Xr-Unzip 🔓\",\n",
        "        )\n",
        "        time.sleep(1)\n",
        "\n",
        "    # Deletes all remaining Multi Part Volumes\n",
        "    c = 1\n",
        "    if file_pattern == \"rar\":\n",
        "        name_, _ = os.path.splitext(name)\n",
        "        na_p = name_ + \".part\" + str(c) + \".rar\"\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        while os.path.exists(p_ap):\n",
        "            print(\"\\nDeleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "            c += 1\n",
        "            na_p = name_ + \".part\" + str(c) + \".rar\"\n",
        "            p_ap = os.path.join(dirname, na_p)\n",
        "\n",
        "    elif file_pattern == \"7z\":\n",
        "        na_p = name + \".\" + str(c).zfill(3)\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        while os.path.exists(p_ap):\n",
        "            print(\"\\nDeleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "            c += 1\n",
        "            na_p = name + \".\" + str(c).zfill(3)\n",
        "            p_ap = os.path.join(dirname, na_p)\n",
        "\n",
        "    elif file_pattern == \"zip\":\n",
        "        na_p = name + \".zip\"\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        if os.path.exists(p_ap):\n",
        "            print(\"\\nDeleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "        na_p = name + \".z\" + str(c).zfill(2)\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        while os.path.exists(p_ap):\n",
        "            print(\"Deleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "            c += 1\n",
        "            na_p = name + \".z\" + str(c).zfill(2)\n",
        "            p_ap = os.path.join(dirname, na_p)\n",
        "\n",
        "    if os.path.exists(zip_filepath):\n",
        "        os.remove(zip_filepath)\n",
        "\n",
        "\n",
        "async def size_checker(file_path):\n",
        "    max_size = 2097152000  # 2 GB\n",
        "    file_size = os.stat(file_path).st_size\n",
        "\n",
        "    if file_size > max_size:\n",
        "        if not ospath.exists(temp_lpath):\n",
        "            makedirs(temp_lpath)\n",
        "        _, filename = os.path.split(file_path)\n",
        "        filename = filename.lower()\n",
        "        if (\n",
        "            filename.endswith(\".zip\")\n",
        "            or filename.endswith(\".rar\")\n",
        "            or filename.endswith(\".7z\")\n",
        "            or filename.endswith(\".tar\")\n",
        "            or filename.endswith(\".gz\")\n",
        "        ):\n",
        "            await split_zipFile(file_path, max_size)\n",
        "        else:\n",
        "            await zip_folder(file_path)\n",
        "            time.sleep(2)\n",
        "        return True\n",
        "    else:\n",
        "        return False\n",
        "\n",
        "\n",
        "async def split_zipFile(file_path, max_size):\n",
        "    starting_time = datetime.datetime.now()\n",
        "    _, filename = os.path.split(file_path)\n",
        "    new_path = f\"{temp_lpath}/{filename}\"\n",
        "    down_msg = f\"<b>✂️ SPLITTING » </b>\\n\\n<code>{filename}</code>\\n\"\n",
        "    # Get the total size of the file\n",
        "    total_size = os.path.getsize(file_path)\n",
        "    with open(file_path, \"rb\") as f:\n",
        "        chunk = f.read(max_size)\n",
        "        i = 1\n",
        "        bytes_written = 0\n",
        "        while chunk:\n",
        "            # Generate filename for this chunk\n",
        "            ext = str(i).zfill(3)\n",
        "            output_filename = \"{}.{}\".format(new_path, ext)\n",
        "\n",
        "            # Write chunk to file\n",
        "            with open(output_filename, \"wb\") as out:\n",
        "                out.write(chunk)\n",
        "\n",
        "            bytes_written += len(chunk)\n",
        "            speed_string, eta, percentage = speed_eta(\n",
        "                starting_time, bytes_written, total_size\n",
        "            )\n",
        "            await status_bar(\n",
        "                down_msg,\n",
        "                speed_string,\n",
        "                percentage,\n",
        "                convert_seconds(eta),\n",
        "                size_measure(bytes_written),\n",
        "                size_measure(total_size),\n",
        "                \"Xr-Split ✂️\",\n",
        "            )\n",
        "            # Get next chunk\n",
        "            chunk = f.read(max_size)\n",
        "            i += 1  # Increment chunk counter\n",
        "\n",
        "\n",
        "def is_time_over(current_time):\n",
        "    ten_sec_passed = time.time() - current_time[0] >= 3\n",
        "    if ten_sec_passed:\n",
        "        current_time[0] = time.time()\n",
        "    return ten_sec_passed\n",
        "\n",
        "\n",
        "def speed_eta(start, done, total):\n",
        "    percentage = (done / total) * 100\n",
        "    elapsed_time = (datetime.datetime.now() - start).seconds\n",
        "    if done > 0 and elapsed_time != 0:\n",
        "        raw_speed = done / elapsed_time\n",
        "        speed = f\"{size_measure(raw_speed)}/s\"\n",
        "        eta = (total - done) / raw_speed\n",
        "    else:\n",
        "        speed, eta = \"N/A\", 0\n",
        "    return speed, eta, percentage\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    Direct Link Handler Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "async def on_output(output: str):\n",
        "    # print(\"=\" * 60 + f\"\\n\\n{output}\\n\\n\" + \"*\" * 60)\n",
        "    global link_info\n",
        "    total_size = \"0B\"\n",
        "    progress_percentage = \"0B\"\n",
        "    downloaded_bytes = \"0B\"\n",
        "    eta = \"0S\"\n",
        "    try:\n",
        "        if \"ETA:\" in output:\n",
        "            parts = output.split()\n",
        "            total_size = parts[1].split(\"/\")[1]\n",
        "            total_size = total_size.split(\"(\")[0]\n",
        "            progress_percentage = parts[1][parts[1].find(\"(\") + 1 : parts[1].find(\")\")]\n",
        "            downloaded_bytes = parts[1].split(\"/\")[0]\n",
        "            eta = parts[4].split(\":\")[1][:-1]\n",
        "    except Exception as do:\n",
        "        print(f\"Could't Get Info Due to: {do}\")\n",
        "\n",
        "    percentage = re.findall(\"\\d+\\.\\d+|\\d+\", progress_percentage)[0]\n",
        "    down = re.findall(\"\\d+\\.\\d+|\\d+\", downloaded_bytes)[0]\n",
        "    down_unit = re.findall(\"[a-zA-Z]+\", downloaded_bytes)[0]\n",
        "    if \"G\" in down_unit:\n",
        "        spd = 3\n",
        "    elif \"M\" in down_unit:\n",
        "        spd = 2\n",
        "    elif \"K\" in down_unit:\n",
        "        spd = 1\n",
        "    else:\n",
        "        spd = 0\n",
        "\n",
        "    elapsed_time_seconds = (datetime.datetime.now() - start_time).seconds\n",
        "\n",
        "    if elapsed_time_seconds >= 270 and not link_info:\n",
        "        raise Exception(\"Failed to get download information ! Probably dead link 💀\")\n",
        "    # Only Do this if got Information\n",
        "    if total_size != \"0B\":\n",
        "        # Calculate download speed\n",
        "        link_info = True\n",
        "        current_speed = (float(down) * 1024**spd) / elapsed_time_seconds\n",
        "        speed_string = f\"{size_measure(current_speed)}/s\"\n",
        "\n",
        "        await status_bar(\n",
        "            down_msg,\n",
        "            speed_string,\n",
        "            int(percentage),\n",
        "            eta,\n",
        "            downloaded_bytes,\n",
        "            total_size,\n",
        "            \"Aria2c 🧨\",\n",
        "        )\n",
        "\n",
        "\n",
        "async def aria2_Download(link, num):\n",
        "    global start_time, down_msg\n",
        "    name_d = get_Aria2c_Name(link)\n",
        "    start_time = datetime.datetime.now()\n",
        "    down_msg = f\"<b>📥 DOWNLOADING FROM » </b><i>🔗Link {str(num).zfill(2)}</i>\\n\\n<b>🏷️ Name » </b><code>{name_d}</code>\\n\"\n",
        "\n",
        "    # Create a command to run aria2p with the link\n",
        "    command = [\n",
        "        \"aria2c\",\n",
        "        \"-x16\",\n",
        "        \"--seed-time=0\",\n",
        "        \"--summary-interval=1\",\n",
        "        \"--console-log-level=notice\",\n",
        "        \"-d\",\n",
        "        d_fol_path,\n",
        "        link,\n",
        "    ]\n",
        "\n",
        "    # Run the command using subprocess.Popen\n",
        "    proc = subprocess.Popen(\n",
        "        command, bufsize=0, stdout=subprocess.PIPE, stderr=subprocess.PIPE\n",
        "    )\n",
        "\n",
        "    # Read and print output in real-time\n",
        "    while True:\n",
        "        output = proc.stdout.readline()\n",
        "        if output == b\"\" and proc.poll() is not None:\n",
        "            break\n",
        "        if output:\n",
        "            # sys.stdout.write(output.decode(\"utf-8\"))\n",
        "            # sys.stdout.flush()\n",
        "            await on_output(output.decode(\"utf-8\"))\n",
        "\n",
        "    # Retrieve exit code and any error output\n",
        "    exit_code = proc.wait()\n",
        "    error_output = proc.stderr.read()\n",
        "    if exit_code != 0:\n",
        "        raise Exception(\n",
        "            f\"aria2c download failed with return code {exit_code}. Error: {error_output}\"\n",
        "        )\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    Telegram Downloader\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "async def media_Identifier(link):\n",
        "    parts = link.split(\"/\")\n",
        "    message_id = parts[-1]\n",
        "    msg_chat_id = \"-100\" + parts[4]\n",
        "    message_id, msg_chat_id = int(message_id), int(msg_chat_id)\n",
        "    message = await bot.get_messages(msg_chat_id, message_id)\n",
        "\n",
        "    media = (\n",
        "        message.document\n",
        "        or message.photo\n",
        "        or message.video\n",
        "        or message.audio\n",
        "        or message.voice\n",
        "        or message.video_note\n",
        "        or message.sticker\n",
        "        or message.animation\n",
        "        or None\n",
        "    )\n",
        "    if media is None:\n",
        "        raise Exception(\"Couldn't Download Telegram Message\")\n",
        "    return media, message\n",
        "\n",
        "\n",
        "async def download_progress(current, total):\n",
        "    speed_string, eta, percentage = speed_eta(start_time, current, total)\n",
        "\n",
        "    await status_bar(\n",
        "        down_msg=down_msg,\n",
        "        speed=speed_string,\n",
        "        percentage=percentage,\n",
        "        eta=convert_seconds(eta),\n",
        "        done=size_measure(sum(down_bytes) + current),\n",
        "        left=size_measure(folder_info[0]),\n",
        "        engine=\"Pyrogram 💥\",\n",
        "    )\n",
        "\n",
        "\n",
        "async def TelegramDownload(link, num):\n",
        "    global start_time, down_msg\n",
        "    media, message = await media_Identifier(link)\n",
        "    if media is not None:\n",
        "        name = media.file_name if hasattr(media, \"file_name\") else \"None\"\n",
        "    else:\n",
        "        raise Exception(\"Couldn't Download Telegram Message\")\n",
        "\n",
        "    down_msg = f\"<b>📥 DOWNLOADING FROM » </b><i>🔗Link {str(num).zfill(2)}</i>\\n\\n<code>{name}</code>\\n\"\n",
        "    start_time = datetime.datetime.now()\n",
        "    file_path = os.path.join(d_fol_path, name)\n",
        "    await message.download(\n",
        "        progress=download_progress, in_memory=False, file_name=file_path\n",
        "    )\n",
        "    down_bytes.append(media.file_size)\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    Initiator Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "async def calG_DownSize(links):\n",
        "    for link in natsorted(links):\n",
        "        if \"drive.google.com\" in link:\n",
        "            id = getIDFromURL(link)\n",
        "            try:\n",
        "                meta = getFileMetadata(id)\n",
        "            except Exception as e:\n",
        "                if \"File not found\" in str(e):\n",
        "                    raise Exception(\n",
        "                        \"The file link you gave either doesn't exist or You don't have access to it!\"\n",
        "                    )\n",
        "                elif \"Failed to retrieve\" in str(e):\n",
        "                    clear_output()\n",
        "                    raise Exception(\n",
        "                        \"Authorization Error with Google ! Make Sure you uploaded token.pickle !\"\n",
        "                    )\n",
        "                else:\n",
        "                    raise Exception(f\"Error in G-API: {e}\")\n",
        "            if meta.get(\"mimeType\") == \"application/vnd.google-apps.folder\":\n",
        "                folder_info[0] += get_Gfolder_size(id)\n",
        "            else:\n",
        "                folder_info[0] += int(meta[\"size\"])\n",
        "        elif \"t.me\" in link:\n",
        "            media, _ = await media_Identifier(link)\n",
        "            if media is not None:\n",
        "                size = media.file_size\n",
        "                folder_info[0] += size\n",
        "            else:\n",
        "                raise Exception(\"Couldn't Download Telegram Message\")\n",
        "        else:\n",
        "            pass\n",
        "\n",
        "\n",
        "def get_Aria2c_Name(link):\n",
        "    cmd = f'aria2c -x10 --dry-run --file-allocation=none \"{link}\"'\n",
        "    result = subprocess.run(cmd, stdout=subprocess.PIPE, shell=True)\n",
        "    stdout_str = result.stdout.decode(\"utf-8\")\n",
        "    filename = stdout_str.split(\"complete: \")[-1].split(\"\\n\")[0]\n",
        "    name = filename.split(\"/\")[-1]\n",
        "    if len(name) == 0:\n",
        "        name = \"UNKNOWN DOWNLOAD NAME\"\n",
        "    return name\n",
        "\n",
        "\n",
        "async def get_d_name(link):\n",
        "    global d_name\n",
        "    if custom_name:\n",
        "        d_name = custom_name\n",
        "        return\n",
        "    if \"drive.google.com\" in link:\n",
        "        id = getIDFromURL(link)\n",
        "        meta = getFileMetadata(id)\n",
        "        d_name = meta[\"name\"]\n",
        "    elif \"t.me\" in link:\n",
        "        media, _ = await media_Identifier(link)\n",
        "        d_name = media.file_name if hasattr(media, \"file_name\") else \"None\"\n",
        "    else:\n",
        "        d_name = get_Aria2c_Name(link)\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    G Drive Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "def build_service():\n",
        "    # create credentials object from token.pickle file\n",
        "    creds = None\n",
        "    if os.path.exists(\"/content/token.pickle\"):\n",
        "        with open(\"/content/token.pickle\", \"rb\") as token:\n",
        "            creds = pickle.load(token)\n",
        "    else:\n",
        "        exit(1)\n",
        "\n",
        "    # create drive API client\n",
        "    service = build(\"drive\", \"v3\", credentials=creds)\n",
        "\n",
        "    return service\n",
        "\n",
        "\n",
        "async def g_DownLoad(link, num):\n",
        "    global start_time, down_msg\n",
        "    down_msg = f\"<b>📥 DOWNLOADING FROM » </b><i>🔗Link {str(num).zfill(2)}</i>\\n\\n<b>🏷️ Name » </b><code>{d_name}</code>\\n\"\n",
        "    file_id = getIDFromURL(link)\n",
        "    meta = getFileMetadata(file_id)\n",
        "\n",
        "    if meta.get(\"mimeType\") == \"application/vnd.google-apps.folder\":\n",
        "        await gDownloadFolder(file_id, d_fol_path)\n",
        "    else:\n",
        "        await gDownloadFile(file_id, d_fol_path)\n",
        "        clear_output()\n",
        "\n",
        "\n",
        "def getIDFromURL(link: str):\n",
        "    if \"folders\" in link or \"file\" in link:\n",
        "        regex = r\"https:\\/\\/drive\\.google\\.com\\/(?:drive(.*?)\\/folders\\/|file(.*?)?\\/d\\/)([-\\w]+)\"\n",
        "        res = re_search(regex, link)\n",
        "        if res is None:\n",
        "            raise IndexError(\"G-Drive ID not found.\")\n",
        "        return res.group(3)\n",
        "    parsed = urlparse(link)\n",
        "    return parse_qs(parsed.query)[\"id\"][0]\n",
        "\n",
        "\n",
        "def getFilesByFolderID(folder_id):\n",
        "    page_token = None\n",
        "    files = []\n",
        "    while True:\n",
        "        response = (\n",
        "            service.files()\n",
        "            .list(\n",
        "                supportsAllDrives=True,\n",
        "                includeItemsFromAllDrives=True,\n",
        "                q=f\"'{folder_id}' in parents and trashed = false\",\n",
        "                spaces=\"drive\",\n",
        "                pageSize=200,\n",
        "                fields=\"nextPageToken, files(id, name, mimeType, size, shortcutDetails)\",\n",
        "                orderBy=\"folder, name\",\n",
        "                pageToken=page_token,\n",
        "            )\n",
        "            .execute()\n",
        "        )\n",
        "        files.extend(response.get(\"files\", []))\n",
        "        page_token = response.get(\"nextPageToken\")\n",
        "        if page_token is None:\n",
        "            break\n",
        "    return files\n",
        "\n",
        "\n",
        "def getFileMetadata(file_id):\n",
        "    return (\n",
        "        service.files()\n",
        "        .get(fileId=file_id, supportsAllDrives=True, fields=\"name, id, mimeType, size\")\n",
        "        .execute()\n",
        "    )\n",
        "\n",
        "\n",
        "def get_Gfolder_size(folder_id):\n",
        "    try:\n",
        "        query = \"trashed = false and '{0}' in parents\".format(folder_id)\n",
        "        results = (\n",
        "            service.files()\n",
        "            .list(\n",
        "                supportsAllDrives=True,\n",
        "                includeItemsFromAllDrives=True,\n",
        "                q=query,\n",
        "                fields=\"files(id, mimeType, size)\",\n",
        "            )\n",
        "            .execute()\n",
        "        )\n",
        "\n",
        "        total_size = 0\n",
        "        items = results.get(\"files\", [])\n",
        "\n",
        "        folders_without_size = (\n",
        "            item[\"id\"]\n",
        "            for item in items\n",
        "            if item.get(\"size\") is None\n",
        "            and item[\"mimeType\"] == \"application/vnd.google-apps.folder\"\n",
        "        )\n",
        "\n",
        "        for item in items:\n",
        "            # If the item has a size attribute\n",
        "            if \"size\" in item:\n",
        "                total_size += int(item[\"size\"])\n",
        "\n",
        "        # Recursively call the function for folders whose size is not found\n",
        "        for folder_id in folders_without_size:\n",
        "            total_size += get_Gfolder_size(folder_id)\n",
        "\n",
        "        return total_size\n",
        "\n",
        "    except HttpError as error:\n",
        "        print(f\"Error while checking size: {error}\")\n",
        "        return -1\n",
        "\n",
        "\n",
        "async def gDownloadFile(file_id, path):\n",
        "    # Check if the specified file or folder exists and is downloadable.\n",
        "    try:\n",
        "        file = getFileMetadata(file_id)\n",
        "    except HttpError as error:\n",
        "        print(\"An error occurred: {0}\".format(error))\n",
        "        file = None\n",
        "    if file is None:\n",
        "        print(\n",
        "            \"Sorry, the specified file or folder does not exist or is not accessible.\"\n",
        "        )\n",
        "    else:\n",
        "        if file[\"mimeType\"].startswith(\"application/vnd.google-apps\"):\n",
        "            print(\n",
        "                \"Sorry, the specified ID is for a Google Docs, Sheets, Slides, or Forms document. You can only download these types of files in specific formats.\"\n",
        "            )\n",
        "        else:\n",
        "            try:\n",
        "                file_name = file.get(\"name\", f\"untitleddrivefile_{file_id}\")\n",
        "                file_name = os.path.join(path, file_name)\n",
        "                # Create a BytesIO stream to hold the downloaded file data.\n",
        "                file_contents = io.BytesIO()\n",
        "\n",
        "                # Download the file or folder contents to the BytesIO stream.\n",
        "                request = service.files().get_media(\n",
        "                    fileId=file_id, supportsAllDrives=True\n",
        "                )\n",
        "                file_downloader = MediaIoBaseDownload(\n",
        "                    file_contents, request, chunksize=70 * 1024 * 1024\n",
        "                )\n",
        "                done = False\n",
        "                while done is False:\n",
        "                    status, done = file_downloader.next_chunk()\n",
        "                    # Get current value from file_contents.\n",
        "                    file_contents.seek(0)\n",
        "                    with open(file_name, \"ab\") as f:\n",
        "                        f.write(file_contents.getvalue())\n",
        "                    # Reset the buffer for the next chunk.\n",
        "                    file_contents.seek(0)\n",
        "                    file_contents.truncate()\n",
        "                    # The saved bytes till now\n",
        "                    file_d_size = int(status.progress() * int(file[\"size\"]))\n",
        "                    down_done = sum(down_bytes) + file_d_size\n",
        "                    speed_string, eta, percentage = speed_eta(\n",
        "                        start_time, down_done, folder_info[0]\n",
        "                    )\n",
        "                    await status_bar(\n",
        "                        down_msg=down_msg,\n",
        "                        speed=speed_string,\n",
        "                        percentage=percentage,\n",
        "                        eta=convert_seconds(eta),\n",
        "                        done=size_measure(down_done),\n",
        "                        left=size_measure(folder_info[0]),\n",
        "                        engine=\"G-API ♻️\",\n",
        "                    )\n",
        "                down_bytes.append(int(file[\"size\"]))\n",
        "                down_count[0] += 1\n",
        "\n",
        "            except Exception as e:\n",
        "                print(\"Error downloading: {0}\".format(e))\n",
        "\n",
        "\n",
        "async def gDownloadFolder(folder_id, path):\n",
        "    folder_meta = getFileMetadata(folder_id)\n",
        "    folder_name = folder_meta[\"name\"]\n",
        "    if not ospath.exists(f\"{path}/{folder_name}\"):\n",
        "        makedirs(f\"{path}/{folder_name}\")\n",
        "    path += f\"/{folder_name}\"\n",
        "    result = getFilesByFolderID(folder_id)\n",
        "    if len(result) == 0:\n",
        "        return\n",
        "    result = natsorted(result, key=lambda k: k[\"name\"])\n",
        "    for item in result:\n",
        "        file_id = item[\"id\"]\n",
        "        shortcut_details = item.get(\"shortcutDetails\")\n",
        "        if shortcut_details is not None:\n",
        "            file_id = shortcut_details[\"targetId\"]\n",
        "            mime_type = shortcut_details[\"targetMimeType\"]\n",
        "        else:\n",
        "            mime_type = item.get(\"mimeType\")\n",
        "        if mime_type == \"application/vnd.google-apps.folder\":\n",
        "            await gDownloadFolder(file_id, path)\n",
        "        else:\n",
        "            await gDownloadFile(file_id, path)\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    Telegram Upload Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "def keyboard():\n",
        "    return InlineKeyboardMarkup(\n",
        "        [\n",
        "            [  # First row\n",
        "                InlineKeyboardButton(  # Opens a web URL\n",
        "                    \"Git Repo 🪲\",\n",
        "                    url=\"https://github.com/XronTrix10/Telegram-Leecher\",\n",
        "                ),\n",
        "            ],\n",
        "            [\n",
        "                InlineKeyboardButton(  # Opens a web URL\n",
        "                    \"Channel 📣\",\n",
        "                    url=\"https://t.me/Colab_Leecher\",\n",
        "                ),\n",
        "                InlineKeyboardButton(  # Opens a web URL\n",
        "                    \"Group 💬\",\n",
        "                    url=\"https://t.me/Colab_Leecher_Discuss\",\n",
        "                ),\n",
        "            ],\n",
        "        ]\n",
        "    )\n",
        "\n",
        "\n",
        "async def status_bar(down_msg, speed, percentage, eta, done, left, engine):\n",
        "    bar_length = 12\n",
        "    filled_length = int(percentage / 100 * bar_length)\n",
        "    # bar = \"⬢\" * filled_length + \"⬡\" * (bar_length - filled_length)\n",
        "    bar = \"█\" * filled_length + \"░\" * (bar_length - filled_length)\n",
        "    message = (\n",
        "        f\"\\n╭|{bar}| » __{percentage:.2f}%__\\n├⚡️ **Speed »** __{speed}__\\n├⚙️ **Engine »** __{engine}__\"\n",
        "        + f\"\\n├⏳ **Time Left »** __{eta}__\"\n",
        "        + f\"\\n├🍃 **Time Spent »** __{convert_seconds((datetime.datetime.now() - task_start).seconds)}__\"\n",
        "        + f\"\\n├✅ **Processed »** __{done}__\\n╰📦 **Total Size »** __{left}__\"\n",
        "    )\n",
        "    sys_text = system_info()\n",
        "    try:\n",
        "        print(f\"\\r{engine} ║ {bar} ║ {percentage:.2f}% ║ {speed} ║ ⏳ {eta}\", end=\"\")\n",
        "        # Edit the message with updated progress information.\n",
        "        if is_time_over(current_time):\n",
        "            await bot.edit_message_text(\n",
        "                chat_id=chat_id,\n",
        "                message_id=msg.id,\n",
        "                text=task_msg + down_msg + message + sys_text,\n",
        "                reply_markup=keyboard(),\n",
        "            )\n",
        "\n",
        "    except Exception as e:\n",
        "        # Catch any exceptions that might occur while editing the message.\n",
        "        print(f\"Error Updating Status bar: {str(e)}\")\n",
        "\n",
        "\n",
        "async def progress_bar(current, total):\n",
        "    upload_speed = 0\n",
        "    if current > 0:\n",
        "        elapsed_time_seconds = (datetime.datetime.now() - start_time).seconds\n",
        "        upload_speed = current / elapsed_time_seconds\n",
        "    eta = (total_down_size - current - sum(up_bytes)) / upload_speed\n",
        "    percentage = (current + sum(up_bytes)) / total_down_size * 100\n",
        "    await status_bar(\n",
        "        down_msg=text_msg,\n",
        "        speed=f\"{size_measure(upload_speed)}/s\",\n",
        "        percentage=percentage,\n",
        "        eta=convert_seconds(eta),\n",
        "        done=size_measure(current + sum(up_bytes)),\n",
        "        left=size_measure(total_down_size),\n",
        "        engine=\"Pyrogram 💥\",\n",
        "    )\n",
        "\n",
        "\n",
        "async def upload_file(file_path, real_name):\n",
        "    global sent\n",
        "\n",
        "    caption = f\"<code>{real_name}</code>\"\n",
        "    type_, file_path = get_file_type(file_path)\n",
        "    f_type = \"document\" if LEECH_DOCUMENT else type_\n",
        "\n",
        "    # Upload the file\n",
        "    try:\n",
        "        if f_type == \"video\":\n",
        "            thmb_path, seconds = Thumbnail_Maintainer(file_path)\n",
        "            with Image.open(thmb_path) as img:\n",
        "                width, height = img.size\n",
        "\n",
        "            sent = await sent.reply_video(\n",
        "                video=file_path,\n",
        "                supports_streaming=True,\n",
        "                width=width,\n",
        "                height=height,\n",
        "                caption=caption,\n",
        "                thumb=thmb_path,\n",
        "                duration=int(seconds),\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        elif f_type == \"audio\":\n",
        "            thmb_path = None if not os.path.exists(custom_thumb) else custom_thumb\n",
        "            sent = await sent.reply_audio(\n",
        "                audio=file_path,\n",
        "                caption=caption,\n",
        "                thumb=thmb_path,\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        elif f_type == \"document\":\n",
        "            if os.path.exists(custom_thumb):\n",
        "                thmb_path = custom_thumb\n",
        "            elif type_ == \"video\":\n",
        "                thmb_path, _ = Thumbnail_Maintainer(file_path)\n",
        "            else:\n",
        "                thmb_path = None\n",
        "\n",
        "            sent = await sent.reply_document(\n",
        "                document=file_path,\n",
        "                caption=caption,\n",
        "                thumb=thmb_path,\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        elif f_type == \"photo\":\n",
        "            sent = await sent.reply_photo(\n",
        "                photo=file_path,\n",
        "                caption=caption,\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        clear_output()\n",
        "\n",
        "        sent_file.append(sent)\n",
        "        sent_fileName.append(real_name)\n",
        "\n",
        "    except Exception as e:\n",
        "        print(f\"Error When Uploading : {e}\")\n",
        "\n",
        "\n",
        "async def Leecher(file_path):\n",
        "    global text_msg, start_time, msg, sent\n",
        "\n",
        "    leech = await size_checker(file_path)\n",
        "\n",
        "    if leech:  # File was splitted\n",
        "        if ospath.exists(file_path):\n",
        "            os.remove(file_path)  # Delete original Big Zip file\n",
        "\n",
        "        dir_list = natsorted(os.listdir(temp_lpath))\n",
        "\n",
        "        count = 1\n",
        "\n",
        "        for dir_path in dir_list:\n",
        "            short_path = os.path.join(temp_lpath, dir_path)\n",
        "            file_name = os.path.basename(short_path)\n",
        "            new_path = shorterFileName(short_path)\n",
        "            os.rename(short_path, new_path)\n",
        "            start_time = datetime.datetime.now()\n",
        "            current_time[0] = time.time()\n",
        "            text_msg = f\"<b>📤 UPLOADING SPLIT » {count} OF {len(dir_list)} Files</b>\\n\\n<code>{file_name}</code>\\n\"\n",
        "            msg = await bot.edit_message_text(\n",
        "                chat_id=chat_id,\n",
        "                message_id=msg.id,\n",
        "                text=task_msg + text_msg + \"\\n⏳ __Starting.....__\" + system_info(),\n",
        "                reply_markup=keyboard(),\n",
        "            )\n",
        "            await upload_file(new_path, file_name)\n",
        "            up_bytes.append(os.stat(new_path).st_size)\n",
        "\n",
        "            count += 1\n",
        "\n",
        "        shutil.rmtree(temp_lpath)\n",
        "\n",
        "    else:\n",
        "        file_name = os.path.basename(file_path)\n",
        "        new_path = shorterFileName(file_path)  # Trimming filename upto 50 chars\n",
        "        os.rename(file_path, new_path)\n",
        "        start_time = datetime.datetime.now()\n",
        "        current_time[0] = time.time()\n",
        "        text_msg = f\"<b>📤 UPLOADING » </b>\\n\\n<code>{file_name}</code>\\n\"\n",
        "        msg = await bot.edit_message_text(\n",
        "            chat_id=chat_id,\n",
        "            message_id=msg.id,\n",
        "            text=task_msg + text_msg + \"\\n⏳ __Starting.....__\" + system_info(),\n",
        "            reply_markup=keyboard(),\n",
        "        )\n",
        "        await upload_file(new_path, file_name)\n",
        "        up_bytes.append(os.stat(new_path).st_size)\n",
        "\n",
        "        os.remove(new_path)\n",
        "\n",
        "\n",
        "async def Leech(folder_path):\n",
        "    files = [str(p) for p in pathlib.Path(folder_path).glob(\"**/*\") if p.is_file()]\n",
        "    for f in natsorted(files):\n",
        "        file_path = os.path.join(folder_path, f)\n",
        "        await Leecher(file_path)\n",
        "\n",
        "    shutil.rmtree(folder_path)\n",
        "\n",
        "\n",
        "async def ZipLeech(d_fol_path):\n",
        "    global msg, down_msg, start_time, total_down_size\n",
        "\n",
        "    down_msg = f\"<b>🔐 ZIPPING » </b>\\n\\n<code>{d_name}</code>\\n\"\n",
        "\n",
        "    try:\n",
        "        msg = await bot.edit_message_text(\n",
        "            chat_id=chat_id,\n",
        "            message_id=msg.id,\n",
        "            text=task_msg + down_msg + system_info(),\n",
        "        )\n",
        "    except Exception as e2:\n",
        "        print(f\"Problem in ZipLeech !{e2}\")\n",
        "\n",
        "    print(\"\\nNow ZIPPING the folder...\")\n",
        "    current_time[0] = time.time()\n",
        "    start_time = datetime.datetime.now()\n",
        "    if not os.path.exists(temp_zpath):\n",
        "        makedirs(temp_zpath)\n",
        "    await zip_folder(d_fol_path)\n",
        "    clear_output()\n",
        "    time.sleep(2)\n",
        "\n",
        "    total_down_size = get_folder_size(temp_zpath)\n",
        "\n",
        "    if os.path.exists(d_fol_path):\n",
        "        shutil.rmtree(d_fol_path)\n",
        "    await Leech(temp_zpath)\n",
        "\n",
        "\n",
        "async def UnzipLeech(d_fol_path):\n",
        "    global msg\n",
        "\n",
        "    down_msg = f\"\\n<b>📂 EXTRACTING » </b>\\n\\n<code>{d_name}</code>\\n\"\n",
        "\n",
        "    msg = await bot.edit_message_text(\n",
        "        chat_id=chat_id,\n",
        "        message_id=msg.id,\n",
        "        text=task_msg + down_msg + \"\\n⏳ __Starting.....__\" + system_info(),\n",
        "    )\n",
        "    cant_files = []\n",
        "    filenames = [str(p) for p in pathlib.Path(d_fol_path).glob(\"**/*\") if p.is_file()]\n",
        "    for f in natsorted(filenames):\n",
        "        short_path = os.path.join(d_fol_path, f)\n",
        "        if not os.path.exists(temp_unzip_path):\n",
        "            makedirs(temp_unzip_path)\n",
        "        filename = os.path.basename(f).lower()\n",
        "        _, ext = os.path.splitext(filename)\n",
        "        try:\n",
        "            if os.path.exists(short_path):\n",
        "                if ext in [\".7z\", \".gz\", \".zip\", \".rar\", \".001\", \".tar\", \".z01\"]:\n",
        "                    await extract_zip(short_path)\n",
        "                    await Leech(temp_unzip_path)\n",
        "                else:\n",
        "                    cant_files.append(short_path)\n",
        "                    print(\n",
        "                        f\"Unable to Extract {os.path.basename(f)} ! Will be Leeching later !\"\n",
        "                    )\n",
        "        except Exception as e5:\n",
        "            print(f\"UZLeech Launcher Exception: {e5}\")\n",
        "\n",
        "    try:\n",
        "        for path in cant_files:\n",
        "            if os.path.exists(path):\n",
        "                await Leecher(path)\n",
        "    except Exception as e5:\n",
        "        print(f\"UZLeech Launcher Exception: {e5}\")\n",
        "\n",
        "    shutil.rmtree(d_fol_path)\n",
        "\n",
        "\n",
        "async def FinalStep(msg):\n",
        "    final_text = (\n",
        "        f\"<b>📂 Total Files:</b>  <code>{len(sent_file)}</code>\\n\\n<b>📜 LOG:</b>\\n\"\n",
        "    )\n",
        "    l_ink = \"⍟───── [Colab Leech](https://colab.research.google.com/drive/12hdEqaidRZ8krqj7rpnyDzg1dkKmvdvp) ─────⍟\"\n",
        "    last_text = (\n",
        "        f\"\\n\\n<b>{(task).upper()} COMPLETE 🔥</b>\\n\\n\"\n",
        "        + f\"╭<b>📛 Name » </b>  <code>{d_name}</code>\\n\"\n",
        "        + f\"├<b>📦 Size » </b><code>{size_measure(sum(up_bytes))}</code>\\n\"\n",
        "        + f\"╰<b>🍃 Saved Time »</b> <code>{convert_seconds((datetime.datetime.now() - task_start).seconds)}</code>\"\n",
        "    )\n",
        "    src = f\"**SOURCE »** __[Links]({src_link})__\"\n",
        "    await bot.send_message(\n",
        "        chat_id=dump_id,\n",
        "        text=src + last_text,\n",
        "        reply_to_message_id=sent.id,\n",
        "    )\n",
        "\n",
        "    await bot.edit_message_text(\n",
        "        chat_id=chat_id,\n",
        "        message_id=msg.id,\n",
        "        text=task_msg + l_ink + last_text,\n",
        "        reply_markup=keyboard(),\n",
        "    )\n",
        "\n",
        "    try:\n",
        "        final_texts = []\n",
        "\n",
        "        for i in range(len(sent_file)):\n",
        "            file_link = f\"https://t.me/c/{link_p}/{sent_file[i].id}\"\n",
        "            fileName = sent_fileName[i]\n",
        "            fileText = f\"\\n({str(i+1).zfill(2)}) <a href={file_link}>{fileName}</a>\"\n",
        "            if len(final_text + fileText) >= 4096:\n",
        "                final_texts.append(final_text)\n",
        "                final_text = fileText\n",
        "            else:\n",
        "                final_text += fileText\n",
        "        final_texts.append(final_text)\n",
        "\n",
        "        for fn_txt in final_texts:\n",
        "            msg = await bot.send_message(\n",
        "                chat_id=chat_id, reply_to_message_id=msg.id, text=fn_txt\n",
        "            )\n",
        "    except Exception as e:\n",
        "        Err = f\"<b>Error Sending logs » </b><i>{e}</i>\"\n",
        "        Err += f\"\\n\\n<i>⚠️ If You are Unknown with this **ERROR**, Then Forward This Message in [Colab Leecher Discussion](https://t.me/Colab_Leecher_Discuss) Where [Xron Trix](https://t.me/XronTrix) may fix it</i>\"\n",
        "        await bot.send_message(chat_id=chat_id, reply_to_message_id=msg.id, text=Err)\n",
        "\n",
        "\n",
        "# ****************************************************************\n",
        "#    Main Functions, function calls and variable declarations\n",
        "# ****************************************************************\n",
        "api_id, chat_id, dump_id = int(API_ID), int(CHAT_ID), int(DUMP_ID)\n",
        "link_p = str(dump_id)[4:]\n",
        "custom_thumb = \"/content/thmb.jpg\"\n",
        "d_path = \"/content/bot_Folder\"\n",
        "d_name = \"\"\n",
        "link_info = False\n",
        "d_fol_path = f\"{d_path}/Downloads\"\n",
        "temp_lpath = f\"{d_path}/Leeched_Files\"\n",
        "temp_unzip_path = f\"{d_path}/Unzipped_Files/\"\n",
        "temp_zpath = temp_lpath\n",
        "sent_file = []\n",
        "sent_fileName = []\n",
        "down_bytes = []\n",
        "down_bytes.append(0)\n",
        "up_bytes = []\n",
        "up_bytes.append(0)\n",
        "current_time = []\n",
        "current_time.append(time.time())\n",
        "folder_info = [0, 1]\n",
        "down_count = []\n",
        "down_count.append(1)\n",
        "start_time = datetime.datetime.now()\n",
        "text_msg = \"\"\n",
        "link = \"something\"\n",
        "choice = \"x\"\n",
        "links = []\n",
        "\n",
        "service = build_service()\n",
        "\n",
        "if not Thumbnail_Checker(\"/content\"):\n",
        "    thumb_path = \"/content/Telegram-Leecher/custom_thmb.jpg\"\n",
        "    print(\"Didn't find thumbnail, So switching to default thumbnail\")\n",
        "else:\n",
        "    thumb_path = custom_thumb\n",
        "\n",
        "if ospath.exists(d_path):\n",
        "    shutil.rmtree(d_path)\n",
        "    makedirs(d_path)\n",
        "else:\n",
        "    makedirs(d_path)\n",
        "\n",
        "if len(LEECH_MODE) == 0:\n",
        "    while choice not in [\"1\", \"2\", \"3\", \"l\", \"z\", \"u\"]:\n",
        "        choice = input(\n",
        "            \"Choose the Operation:\\n\\n\\t[1 / L] Leech\\n\\t[2 / Z] Zipleech\\n\\t[3 / U] Unzipleech\\n\\nEnter: \"\n",
        "        ).lower()\n",
        "        clear_output()\n",
        "        if choice not in [\"1\", \"2\", \"3\", \"l\", \"z\", \"u\"]:\n",
        "            print(f\"No Such Leech Mode '{choice}' ! Enter Option Correctly 🦥\\n\")\n",
        "else:\n",
        "    choice = LEECH_MODE.lower()\n",
        "\n",
        "if choice == \"1\" or choice == \"l\":\n",
        "    task = \"Leech\"\n",
        "elif choice == \"2\" or choice == \"z\":\n",
        "    task = \"Zipleech\"\n",
        "else:\n",
        "    task = \"Unzipleech\"\n",
        "leech_type = \"Document\" if LEECH_DOCUMENT else \"Media\"\n",
        "\n",
        "time.sleep(1)\n",
        "print(f\"TASK MODE: {task} as {leech_type}\")\n",
        "\n",
        "if len(D_LINK) == 0:\n",
        "    # Getting Download Links\n",
        "    while link.lower() != \"c\":\n",
        "        link = input(f\"Download link [ Enter 'C' to Terminate]: \")\n",
        "        if link.lower() != \"c\":\n",
        "            links.append(link)\n",
        "else:\n",
        "    links.append(D_LINK)\n",
        "\n",
        "d_name, custom_name = \"\", \"\"\n",
        "\n",
        "if len(LEECH_MODE) + len(D_LINK) + len(C_NAME) == 0:  # Making Sure, he is in Desktop\n",
        "    if choice in [\"2\", \"z\"] or (len(links) == 1 and choice in [\"1\", \"l\"]):\n",
        "        custom_name = input(\"Enter Custom File name [ 'D' to set Default ]: \")\n",
        "    else:\n",
        "        print(\"Custom Name Not Applicable\")\n",
        "else:\n",
        "    custom_name = C_NAME\n",
        "\n",
        "if custom_name.lower() == \"d\":\n",
        "    custom_name = \"\"\n",
        "\n",
        "\n",
        "task_start = datetime.datetime.now()\n",
        "down_msg = f\"<b>📥 DOWNLOADING » </b>\\n\"\n",
        "task_msg = f\"<b>🦞 TASK MODE » </b><i>{task} as {leech_type}</i>\\n\\n\"\n",
        "\n",
        "dump_task = task_msg + \"<b>🖇️ SOURCES » </b>\"\n",
        "\n",
        "for link in links:\n",
        "    if \"t.me\" in link:\n",
        "        ida = \"💬\"\n",
        "    elif \"drive.google.com\" in link:\n",
        "        ida = \"♻️\"\n",
        "    elif \"magnet\" in link or \"torrent\" in link:\n",
        "        ida = \"🧲\"\n",
        "    else:\n",
        "        ida = \"🔗\"\n",
        "    dump_task += f\"\\n\\n{ida} <code>{link}</code>\"\n",
        "\n",
        "# Get the current date and time in the specified time zone\n",
        "cdt = datetime.datetime.now(pytz.timezone(\"Asia/Kolkata\"))\n",
        "# Format the date and time as a string\n",
        "dt = cdt.strftime(\" %d/%m/%Y\")\n",
        "\n",
        "dump_task += f\"\\n\\n<b>📆 Task Date » </b><i>{dt}</i>\"\n",
        "\n",
        "if not ospath.exists(d_fol_path):\n",
        "    makedirs(d_fol_path)\n",
        "\n",
        "async with Client(\n",
        "    \"my_bot\", api_id=api_id, api_hash=API_HASH, bot_token=BOT_TOKEN\n",
        ") as bot:\n",
        "    try:\n",
        "        sent = await bot.send_message(chat_id=dump_id, text=dump_task)\n",
        "\n",
        "        src_link = f\"https://t.me/c/{link_p}/{sent.id}\"\n",
        "        task_msg += \"<b>🖇️ SOURCE » </b>\" + f\"__[Links]({src_link})__\\n\\n\"\n",
        "\n",
        "        msg = await bot.send_photo(\n",
        "            chat_id=chat_id,\n",
        "            photo=thumb_path,\n",
        "            caption=task_msg\n",
        "            + down_msg\n",
        "            + f\"\\n📝 __Starting DOWNLOAD...__\"\n",
        "            + system_info(),\n",
        "            reply_markup=keyboard(),\n",
        "        )\n",
        "        clear_output()\n",
        "        await calG_DownSize(links)\n",
        "        await get_d_name(links[0])\n",
        "\n",
        "        if choice in [\"2\", \"z\"]:\n",
        "            d_fol_path = os.path.join(d_fol_path, d_name)\n",
        "            if os.path.exists(d_fol_path):\n",
        "                makedirs(d_fol_path)\n",
        "\n",
        "        links = natsorted(links)\n",
        "\n",
        "        current_time[0] = time.time()\n",
        "        start_time = datetime.datetime.now()\n",
        "\n",
        "        for c in range(len(links)):\n",
        "            if \"drive.google.com\" in links[c]:\n",
        "                await g_DownLoad(links[c], c + 1)\n",
        "            elif \"t.me\" in links[c]:\n",
        "                await TelegramDownload(links[c], c + 1)\n",
        "            else:\n",
        "                aria2_dn = f\"<b>PLEASE WAIT ⌛</b>\\n\\n__Getting Download Info For__\\n\\n<code>{links[c]}</code>\"\n",
        "                try:\n",
        "                    await bot.edit_message_text(\n",
        "                        chat_id=chat_id,\n",
        "                        message_id=msg.id,\n",
        "                        text=aria2_dn + system_info(),\n",
        "                        reply_markup=keyboard(),\n",
        "                    )\n",
        "                except Exception as e1:\n",
        "                    print(f\"Couldn't Update text ! Because: {e1}\")\n",
        "                link_info = False\n",
        "                await aria2_Download(links[c], c + 1)\n",
        "\n",
        "        total_down_size = get_folder_size(d_fol_path)\n",
        "\n",
        "        if choice in [\"1\", \"l\"] and len(custom_name) != 0:\n",
        "            files = os.listdir(d_fol_path)\n",
        "            for file_ in files:\n",
        "                current_name = os.path.join(d_fol_path, file_)\n",
        "                new_name = os.path.join(d_fol_path, custom_name)\n",
        "                os.rename(current_name, new_name)\n",
        "\n",
        "        clear_output()\n",
        "\n",
        "        if choice == \"1\" or choice == \"l\":\n",
        "            await Leech(d_fol_path)\n",
        "\n",
        "        elif choice == \"2\" or choice == \"z\":\n",
        "            await ZipLeech(d_fol_path)\n",
        "\n",
        "        else:\n",
        "            await UnzipLeech(d_fol_path)\n",
        "\n",
        "        await FinalStep(msg)\n",
        "\n",
        "    except Exception as e:\n",
        "        clear_output()\n",
        "        if ospath.exists(d_path):\n",
        "            shutil.rmtree(d_path)\n",
        "            print(\"Download Folder was DELETED 💀!\")\n",
        "\n",
        "        Error_Text = (\n",
        "            \"⍟───── [Colab Leech](https://colab.research.google.com/drive/12hdEqaidRZ8krqj7rpnyDzg1dkKmvdvp) ─────⍟\\n\"\n",
        "            + f\"\\n<b>TASK FAILED TO COMPLETE 💔</b>\\n\\n╭<b>📛 Name » </b> <code>{d_name}</code>\\n├<b>🍃 Wasted Time » </b>\"\n",
        "            + f\"__{convert_seconds((datetime.datetime.now() - task_start).seconds)}__\\n\"\n",
        "            + f\"<b>╰🤔 Reason » </b>__{e}__\"\n",
        "            + f\"\\n\\n<i>⚠️ If You are Unknown with this **ERROR**, Then Forward This Message in [Colab Leecher Discussion](https://t.me/Colab_Leecher_Discuss) Where [Xron Trix](https://t.me/XronTrix) may fix it</i>\"\n",
        "        )\n",
        "        try:\n",
        "            await bot.delete_messages(chat_id=chat_id, message_ids=msg.id)\n",
        "            await bot.send_photo(\n",
        "                chat_id=chat_id,\n",
        "                photo=thumb_path,\n",
        "                caption=task_msg + Error_Text,\n",
        "                reply_markup=InlineKeyboardMarkup(\n",
        "                    [\n",
        "                        [\n",
        "                            InlineKeyboardButton(  # Opens a web URL\n",
        "                                \"Report Issue 🥺\",\n",
        "                                url=\"https://github.com/XronTrix10/Telegram-Leecher/issues\",\n",
        "                            ),\n",
        "                            InlineKeyboardButton(  # Opens a web URL\n",
        "                                \"Group Discuss 🤔\",\n",
        "                                url=\"https://t.me/Colab_Leecher_Discuss\",\n",
        "                            ),\n",
        "                        ],\n",
        "                    ]\n",
        "                ),\n",
        "            )\n",
        "        except Exception as d:\n",
        "            print(f\"Another Error Occured: {d}\")\n",
        "        print(f\"Error Occured: {e}\")\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "m1f3umhJoVfU"
      },
      "source": [
        "# 🦄 Some Special Purpose Cells Collapsed Here"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "DborMDN8-WoR"
      },
      "source": [
        "## 💥 Leech Directly From Exsisting Folder"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "id": "6g6vihS4-beX"
      },
      "outputs": [],
      "source": [
        "#@title 🖊️ Edit This Cell And Run It\n",
        "\n",
        "'''\n",
        "'L' or '1' => Leech\n",
        "'Z' or '2' => ZipLeech\n",
        "'U' or '3' => UnzipLeech\n",
        "\n",
        "'''\n",
        "\n",
        "LEECH_MODE  = \"\"           # <== Leech Mode\n",
        "PATH        = \"\"           # <== Path To Your Colab File/Folder\n",
        "C_NAME      = \"\"           # <== Custom Name [ Leave Empty For Default ]\n",
        "\n",
        "# NOTE: Currently only one link is supported for Mobile users\n",
        "\n",
        "print('Task Information Acquired ! 💖')"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "cellView": "form",
        "id": "jdNrPC5nJ_rq"
      },
      "outputs": [],
      "source": [
        "# @title 🍅 Local Colab Leecher\n",
        "import os, io, re, sys, time, math, pytz, psutil, shutil, pickle, uvloop, pathlib, datetime, subprocess\n",
        "from PIL import Image\n",
        "from pyrogram import Client\n",
        "from natsort import natsorted\n",
        "from urllib.parse import urlparse\n",
        "from re import search as re_search\n",
        "from os import makedirs, path as ospath\n",
        "from IPython.display import clear_output\n",
        "from urllib.parse import parse_qs, urlparse\n",
        "from googleapiclient.discovery import build\n",
        "from googleapiclient.errors import HttpError\n",
        "from googleapiclient.http import MediaIoBaseDownload\n",
        "from moviepy.video.io.VideoFileClip import VideoFileClip\n",
        "from pyrogram.types import (\n",
        "    ReplyKeyboardMarkup,\n",
        "    InlineKeyboardMarkup,\n",
        "    InlineKeyboardButton,\n",
        ")\n",
        "\n",
        "uvloop.install()\n",
        "\n",
        "\n",
        "# =================================================================\n",
        "#    Local OS Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "def convert_seconds(seconds):\n",
        "    seconds = int(seconds)\n",
        "    days = seconds // (24 * 3600)\n",
        "    seconds = seconds % (24 * 3600)\n",
        "    hours = seconds // 3600\n",
        "    seconds %= 3600\n",
        "    minutes = seconds // 60\n",
        "    seconds %= 60\n",
        "\n",
        "    if days > 0:\n",
        "        return f\"{days}d {hours}h {minutes}m {seconds}s\"\n",
        "    elif hours > 0:\n",
        "        return f\"{hours}h {minutes}m {seconds}s\"\n",
        "    elif minutes > 0:\n",
        "        return f\"{minutes}m {seconds}s\"\n",
        "    else:\n",
        "        return f\"{seconds}s\"\n",
        "\n",
        "\n",
        "def size_measure(size):\n",
        "    if size > 1024 * 1024 * 1024 * 1024 * 1024:\n",
        "        siz = f\"{size/(1024**5):.2f} PiB\"\n",
        "    elif size > 1024 * 1024 * 1024 * 1024:\n",
        "        siz = f\"{size/(1024**4):.2f} TiB\"\n",
        "    elif size > 1024 * 1024 * 1024:\n",
        "        siz = f\"{size/(1024**3):.2f} GiB\"\n",
        "    elif size > 1024 * 1024:\n",
        "        siz = f\"{size/(1024**2):.2f} MiB\"\n",
        "    elif size > 1024:\n",
        "        siz = f\"{size/1024:.2f} KiB\"\n",
        "    else:\n",
        "        siz = f\"{size} B\"\n",
        "    return siz\n",
        "\n",
        "\n",
        "def get_file_type(file_path):\n",
        "    extensions_dict = {\n",
        "        \".mp4\": \"video\",\n",
        "        \".avi\": \"video\",\n",
        "        \".mkv\": \"video\",\n",
        "        \".mov\": \"video\",\n",
        "        \".webm\": \"video\",\n",
        "        \".vob\": \"video\",\n",
        "        \".m4v\": \"video\",\n",
        "        \".mp3\": \"audio\",\n",
        "        \".wav\": \"audio\",\n",
        "        \".flac\": \"audio\",\n",
        "        \".aac\": \"audio\",\n",
        "        \".ogg\": \"audio\",\n",
        "        \".jpg\": \"photo\",\n",
        "        \".jpeg\": \"photo\",\n",
        "        \".png\": \"photo\",\n",
        "        \".gif\": \"photo\",\n",
        "    }\n",
        "    _, extension = os.path.splitext(file_path)\n",
        "\n",
        "    if extension.lower() in extensions_dict:\n",
        "        if extensions_dict[extension] == \"video\":\n",
        "            new_path = video_extension_fixer(file_path)\n",
        "        else:\n",
        "            new_path = file_path\n",
        "        return extensions_dict[extension], new_path\n",
        "    else:\n",
        "        return \"document\", file_path\n",
        "\n",
        "\n",
        "def shorterFileName(path):\n",
        "    if os.path.isfile(path):\n",
        "        dir_path, filename = os.path.split(path)\n",
        "        if len(filename) > 60:\n",
        "            basename, ext = os.path.splitext(filename)\n",
        "            basename = basename[: 60 - len(ext)]\n",
        "            filename = basename + ext\n",
        "            path = os.path.join(dir_path, filename)\n",
        "        return path\n",
        "    elif os.path.isdir(path):\n",
        "        dir_path, dirname = os.path.split(path)\n",
        "        if len(dirname) > 60:\n",
        "            dirname = dirname[:60]\n",
        "            path = os.path.join(dir_path, dirname)\n",
        "        return path\n",
        "    else:\n",
        "        if len(path) > 60:\n",
        "            path = path[:60]\n",
        "        return path\n",
        "\n",
        "\n",
        "def get_folder_size(folder_path):\n",
        "    if os.path.isfile(folder_path):\n",
        "        return os.path.getsize(folder_path)\n",
        "    else:\n",
        "        total_size = 0\n",
        "        for dirpath, _, filenames in os.walk(folder_path):\n",
        "            for f in filenames:\n",
        "                fp = os.path.join(dirpath, f)\n",
        "                total_size += os.path.getsize(fp)\n",
        "        return total_size\n",
        "\n",
        "\n",
        "def get_file_count(folder_path):\n",
        "    count = 0\n",
        "    for _, __, filenames in os.walk(folder_path):\n",
        "        for f_ in filenames:\n",
        "            count += 1\n",
        "    return count\n",
        "\n",
        "\n",
        "def video_extension_fixer(file_path):\n",
        "    _, f_name = os.path.split(file_path)\n",
        "    if f_name.endswith(\".mp4\") or f_name.endswith(\".mkv\"):\n",
        "        return file_path\n",
        "    else:\n",
        "        os.rename(file_path, os.path.join(file_path + \".mp4\"))\n",
        "        return os.path.join(file_path + \".mp4\")\n",
        "\n",
        "\n",
        "def Thumbnail_Maintainer(file_path):\n",
        "    thmb = f\"{d_path}/video_frame.jpg\"\n",
        "    if os.path.exists(thmb):\n",
        "        os.remove(thmb)\n",
        "    try:\n",
        "        with VideoFileClip(file_path) as video:\n",
        "            if os.path.exists(custom_thumb):\n",
        "                return custom_thumb, video.duration\n",
        "            else:\n",
        "                video.save_frame(thmb, t=math.floor(video.duration / 2))\n",
        "                return thmb, video.duration\n",
        "    except Exception as e:\n",
        "        print(f\"Thmb Gen ERROR: {e}\")\n",
        "        return thumb_path, 0\n",
        "\n",
        "\n",
        "def Thumbnail_Checker(dir_path):\n",
        "    for filename in os.listdir(dir_path):\n",
        "        if filename.endswith(\".jpg\"):\n",
        "            os.rename(os.path.join(dir_path, filename), custom_thumb)\n",
        "            return True\n",
        "    # No jpg file was found\n",
        "    return False\n",
        "\n",
        "\n",
        "def system_info():\n",
        "    ram_usage = psutil.Process(os.getpid()).memory_info().rss\n",
        "    disk_usage = psutil.disk_usage(\"/\")\n",
        "    cpu_usage_percent = psutil.cpu_percent()\n",
        "\n",
        "    string = \"\\n\\n⍟───── [Colab Usage](https://colab.research.google.com/drive/12hdEqaidRZ8krqj7rpnyDzg1dkKmvdvp) ─────⍟\\n\"\n",
        "    string += f\"\\n╭🖥️ **CPU Usage »**  __{cpu_usage_percent}%__\"\n",
        "    string += f\"\\n├💽 **RAM Usage »**  __{size_measure(ram_usage)}__\"\n",
        "    string += f\"\\n╰💾 **DISK Free »**  __{size_measure(disk_usage.free)}__\"\n",
        "    string += f\"\\n\\n<i>💖 When I'm Doin This, Do Something Else ! **Because, Time Is Precious ✨**</i>\"\n",
        "\n",
        "    return string\n",
        "\n",
        "\n",
        "async def zip_folder(path):\n",
        "    dir_p, p_name = os.path.split(path)\n",
        "    r = \"-r\" if os.path.isdir(path) else \"\"\n",
        "    if len(custom_name) != 0:\n",
        "        name = custom_name\n",
        "    elif os.path.isfile(path):\n",
        "        name = os.path.basename(path)\n",
        "    else:\n",
        "        name = d_name\n",
        "    zip_msg = f\"<b>🔐 ZIPPING » </b>\\n\\n<code>{name}</code>\\n\"\n",
        "    starting_time = datetime.datetime.now()\n",
        "    cmd = f'cd \"{dir_p}\" && zip {r} -s 2000m -0 \"{temp_zpath}/{name}.zip\" \"{p_name}\"'\n",
        "    proc = subprocess.Popen(cmd, shell=True)\n",
        "    total = size_measure(get_folder_size(path))\n",
        "    while proc.poll() is None:\n",
        "        speed_string, eta, percentage = speed_eta(\n",
        "            starting_time, get_folder_size(temp_zpath), get_folder_size(path)\n",
        "        )\n",
        "        await status_bar(\n",
        "            zip_msg,\n",
        "            speed_string,\n",
        "            percentage,\n",
        "            convert_seconds(eta),\n",
        "            size_measure(get_folder_size(temp_zpath)),\n",
        "            total,\n",
        "            \"Xr-Zipp 🔒\",\n",
        "        )\n",
        "        time.sleep(1)\n",
        "    if os.path.isfile(path):\n",
        "        os.remove(path)\n",
        "    else:\n",
        "        shutil.rmtree(path)\n",
        "\n",
        "\n",
        "async def extract_zip(zip_filepath):\n",
        "    starting_time = datetime.datetime.now()\n",
        "    dirname, filename = os.path.split(zip_filepath)\n",
        "    unzip_msg = f\"<b>📂 EXTRACTING »</b>\\n\\n<code>{filename}</code>\\n\"\n",
        "    file_pattern = \"\"\n",
        "    name, ext = os.path.splitext(filename)\n",
        "    if ext == \".rar\":\n",
        "        if \"part\" in name:\n",
        "            cmd = f\"unrar x -kb -idq '{zip_filepath}' {temp_unzip_path}\"\n",
        "            file_pattern = \"rar\"\n",
        "        else:\n",
        "            cmd = f\"unrar x '{zip_filepath}' {temp_unzip_path}\"\n",
        "\n",
        "    elif ext == \".tar\":\n",
        "        cmd = f\"tar -xvf '{zip_filepath}' -C {temp_unzip_path}\"\n",
        "    elif ext == \".gz\":\n",
        "        cmd = f\"tar -zxvf '{zip_filepath}' -C {temp_unzip_path}\"\n",
        "    else:\n",
        "        cmd = f\"7z x '{zip_filepath}' -o{temp_unzip_path}\"\n",
        "        if ext == \".001\":\n",
        "            file_pattern = \"7z\"\n",
        "        elif ext == \".z01\":\n",
        "            file_pattern = \"zip\"\n",
        "\n",
        "    proc = subprocess.Popen(cmd, shell=True)\n",
        "    total = size_measure(get_folder_size(zip_filepath))\n",
        "    while proc.poll() is None:\n",
        "        speed_string, eta, percentage = speed_eta(\n",
        "            starting_time,\n",
        "            get_folder_size(temp_unzip_path),\n",
        "            get_folder_size(zip_filepath),\n",
        "        )\n",
        "        await status_bar(\n",
        "            unzip_msg,\n",
        "            speed_string,\n",
        "            percentage,\n",
        "            convert_seconds(eta),\n",
        "            size_measure(get_folder_size(temp_unzip_path)),\n",
        "            total,\n",
        "            \"Xr-Unzip 🔓\",\n",
        "        )\n",
        "        time.sleep(1)\n",
        "\n",
        "    # Deletes all remaining Multi Part Volumes\n",
        "    c = 1\n",
        "    if file_pattern == \"rar\":\n",
        "        name_, _ = os.path.splitext(name)\n",
        "        na_p = name_ + \".part\" + str(c) + \".rar\"\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        while os.path.exists(p_ap):\n",
        "            print(\"\\nDeleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "            c += 1\n",
        "            na_p = name_ + \".part\" + str(c) + \".rar\"\n",
        "            p_ap = os.path.join(dirname, na_p)\n",
        "\n",
        "    elif file_pattern == \"7z\":\n",
        "        na_p = name + \".\" + str(c).zfill(3)\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        while os.path.exists(p_ap):\n",
        "            print(\"\\nDeleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "            c += 1\n",
        "            na_p = name + \".\" + str(c).zfill(3)\n",
        "            p_ap = os.path.join(dirname, na_p)\n",
        "\n",
        "    elif file_pattern == \"zip\":\n",
        "        na_p = name + \".zip\"\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        if os.path.exists(p_ap):\n",
        "            print(\"\\nDeleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "        na_p = name + \".z\" + str(c).zfill(2)\n",
        "        p_ap = os.path.join(dirname, na_p)\n",
        "        while os.path.exists(p_ap):\n",
        "            print(\"Deleted: \", p_ap)\n",
        "            os.remove(p_ap)\n",
        "            c += 1\n",
        "            na_p = name + \".z\" + str(c).zfill(2)\n",
        "            p_ap = os.path.join(dirname, na_p)\n",
        "\n",
        "    if os.path.exists(zip_filepath):\n",
        "        os.remove(zip_filepath)\n",
        "\n",
        "\n",
        "async def size_checker(file_path):\n",
        "    max_size = 2097152000  # 2 GB\n",
        "    file_size = os.stat(file_path).st_size\n",
        "\n",
        "    if file_size > max_size:\n",
        "        if not ospath.exists(temp_lpath):\n",
        "            makedirs(temp_lpath)\n",
        "        _, filename = os.path.split(file_path)\n",
        "        filename = filename.lower()\n",
        "        if (\n",
        "            filename.endswith(\".zip\")\n",
        "            or filename.endswith(\".rar\")\n",
        "            or filename.endswith(\".7z\")\n",
        "            or filename.endswith(\".tar\")\n",
        "            or filename.endswith(\".gz\")\n",
        "        ):\n",
        "            await split_zipFile(file_path, max_size)\n",
        "        else:\n",
        "            await zip_folder(file_path)\n",
        "            time.sleep(2)\n",
        "        return True\n",
        "    else:\n",
        "        return False\n",
        "\n",
        "\n",
        "async def split_zipFile(file_path, max_size):\n",
        "    starting_time = datetime.datetime.now()\n",
        "    _, filename = os.path.split(file_path)\n",
        "    new_path = f\"{temp_lpath}/{filename}\"\n",
        "    down_msg = f\"<b>✂️ SPLITTING » </b>\\n\\n<code>{filename}</code>\\n\"\n",
        "    # Get the total size of the file\n",
        "    total_size = os.path.getsize(file_path)\n",
        "    with open(file_path, \"rb\") as f:\n",
        "        chunk = f.read(max_size)\n",
        "        i = 1\n",
        "        bytes_written = 0\n",
        "        while chunk:\n",
        "            # Generate filename for this chunk\n",
        "            ext = str(i).zfill(3)\n",
        "            output_filename = \"{}.{}\".format(new_path, ext)\n",
        "\n",
        "            # Write chunk to file\n",
        "            with open(output_filename, \"wb\") as out:\n",
        "                out.write(chunk)\n",
        "\n",
        "            bytes_written += len(chunk)\n",
        "            speed_string, eta, percentage = speed_eta(\n",
        "                starting_time, bytes_written, total_size\n",
        "            )\n",
        "            await status_bar(\n",
        "                down_msg,\n",
        "                speed_string,\n",
        "                percentage,\n",
        "                convert_seconds(eta),\n",
        "                size_measure(bytes_written),\n",
        "                size_measure(total_size),\n",
        "                \"Xr-Split ✂️\",\n",
        "            )\n",
        "            # Get next chunk\n",
        "            chunk = f.read(max_size)\n",
        "            i += 1  # Increment chunk counter\n",
        "\n",
        "\n",
        "def is_time_over(current_time):\n",
        "    ten_sec_passed = time.time() - current_time[0] >= 3\n",
        "    if ten_sec_passed:\n",
        "        current_time[0] = time.time()\n",
        "    return ten_sec_passed\n",
        "\n",
        "\n",
        "def speed_eta(start, done, total):\n",
        "    percentage = (done / total) * 100\n",
        "    elapsed_time = (datetime.datetime.now() - start).seconds\n",
        "    if done > 0 and elapsed_time != 0:\n",
        "        raw_speed = done / elapsed_time\n",
        "        speed = f\"{size_measure(raw_speed)}/s\"\n",
        "        eta = (total - done) / raw_speed\n",
        "    else:\n",
        "        speed, eta = \"N/A\", 0\n",
        "    return speed, eta, percentage\n",
        "\n",
        "# =================================================================\n",
        "#    Telegram Upload Functions\n",
        "# =================================================================\n",
        "\n",
        "\n",
        "def keyboard():\n",
        "    return InlineKeyboardMarkup(\n",
        "        [\n",
        "            [  # First row\n",
        "                InlineKeyboardButton(  # Opens a web URL\n",
        "                    \"Git Repo 🪲\",\n",
        "                    url=\"https://github.com/XronTrix10/Telegram-Leecher\",\n",
        "                ),\n",
        "            ],\n",
        "            [\n",
        "                InlineKeyboardButton(  # Opens a web URL\n",
        "                    \"Channel 📣\",\n",
        "                    url=\"https://t.me/Colab_Leecher\",\n",
        "                ),\n",
        "                InlineKeyboardButton(  # Opens a web URL\n",
        "                    \"Group 💬\",\n",
        "                    url=\"https://t.me/Colab_Leecher_Discuss\",\n",
        "                ),\n",
        "            ],\n",
        "        ]\n",
        "    )\n",
        "\n",
        "\n",
        "async def status_bar(down_msg, speed, percentage, eta, done, left, engine):\n",
        "    bar_length = 12\n",
        "    filled_length = int(percentage / 100 * bar_length)\n",
        "    # bar = \"⬢\" * filled_length + \"⬡\" * (bar_length - filled_length)\n",
        "    bar = \"█\" * filled_length + \"░\" * (bar_length - filled_length)\n",
        "    message = (\n",
        "        f\"\\n╭|{bar}| » __{percentage:.2f}%__\\n├⚡️ **Speed »** __{speed}__\\n├⚙️ **Engine »** __{engine}__\"\n",
        "        + f\"\\n├⏳ **Time Left »** __{eta}__\"\n",
        "        + f\"\\n├🍃 **Time Spent »** __{convert_seconds((datetime.datetime.now() - task_start).seconds)}__\"\n",
        "        + f\"\\n├✅ **Processed »** __{done}__\\n╰📦 **Total Size »** __{left}__\"\n",
        "    )\n",
        "    sys_text = system_info()\n",
        "    try:\n",
        "        print(f\"\\r{engine} ║ {bar} ║ {percentage:.2f}% ║ {speed} ║ ⏳ {eta}\", end=\"\")\n",
        "        # Edit the message with updated progress information.\n",
        "        if is_time_over(current_time):\n",
        "            await bot.edit_message_text(\n",
        "                chat_id=chat_id,\n",
        "                message_id=msg.id,\n",
        "                text=task_msg + down_msg + message + sys_text,\n",
        "                reply_markup=keyboard(),\n",
        "            )\n",
        "\n",
        "    except Exception as e:\n",
        "        # Catch any exceptions that might occur while editing the message.\n",
        "        print(f\"Error Updating Status bar: {str(e)}\")\n",
        "\n",
        "\n",
        "async def progress_bar(current, total):\n",
        "    upload_speed = 0\n",
        "    if current > 0:\n",
        "        elapsed_time_seconds = (datetime.datetime.now() - start_time).seconds\n",
        "        upload_speed = current / elapsed_time_seconds\n",
        "    eta = (total_down_size - current - sum(up_bytes)) / upload_speed\n",
        "    percentage = (current + sum(up_bytes)) / total_down_size * 100\n",
        "    await status_bar(\n",
        "        down_msg=text_msg,\n",
        "        speed=f\"{size_measure(upload_speed)}/s\",\n",
        "        percentage=percentage,\n",
        "        eta=convert_seconds(eta),\n",
        "        done=size_measure(current + sum(up_bytes)),\n",
        "        left=size_measure(total_down_size),\n",
        "        engine=\"Pyrogram 💥\",\n",
        "    )\n",
        "\n",
        "\n",
        "async def upload_file(file_path, real_name):\n",
        "    global sent\n",
        "\n",
        "    caption = f\"<code>{real_name}</code>\"\n",
        "    type_, file_path = get_file_type(file_path)\n",
        "    f_type = \"document\" if LEECH_DOCUMENT else type_\n",
        "\n",
        "    # Upload the file\n",
        "    try:\n",
        "        if f_type == \"video\":\n",
        "            thmb_path, seconds = Thumbnail_Maintainer(file_path)\n",
        "            with Image.open(thmb_path) as img:\n",
        "                width, height = img.size\n",
        "\n",
        "            sent = await sent.reply_video(\n",
        "                video=file_path,\n",
        "                supports_streaming=True,\n",
        "                width=width,\n",
        "                height=height,\n",
        "                caption=caption,\n",
        "                thumb=thmb_path,\n",
        "                duration=int(seconds),\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        elif f_type == \"audio\":\n",
        "            thmb_path = None if not os.path.exists(custom_thumb) else custom_thumb\n",
        "            sent = await sent.reply_audio(\n",
        "                audio=file_path,\n",
        "                caption=caption,\n",
        "                thumb=thmb_path,\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        elif f_type == \"document\":\n",
        "            if os.path.exists(custom_thumb):\n",
        "                thmb_path = custom_thumb\n",
        "            elif type_ == \"video\":\n",
        "                thmb_path, _ = Thumbnail_Maintainer(file_path)\n",
        "            else:\n",
        "                thmb_path = None\n",
        "\n",
        "            sent = await sent.reply_document(\n",
        "                document=file_path,\n",
        "                caption=caption,\n",
        "                thumb=thmb_path,\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        elif f_type == \"photo\":\n",
        "            sent = await sent.reply_photo(\n",
        "                photo=file_path,\n",
        "                caption=caption,\n",
        "                progress=progress_bar,\n",
        "                reply_to_message_id=sent.id,\n",
        "            )\n",
        "\n",
        "        clear_output()\n",
        "\n",
        "        sent_file.append(sent)\n",
        "        sent_fileName.append(real_name)\n",
        "\n",
        "    except Exception as e:\n",
        "        print(f\"Error When Uploading : {e}\")\n",
        "\n",
        "\n",
        "async def Leecher(file_path):\n",
        "    global text_msg, start_time, msg, sent\n",
        "\n",
        "    leech = await size_checker(file_path)\n",
        "\n",
        "    if leech:  # File was splitted\n",
        "        if ospath.exists(file_path):\n",
        "            os.remove(file_path)  # Delete original Big Zip file\n",
        "\n",
        "        dir_list = natsorted(os.listdir(temp_lpath))\n",
        "\n",
        "        count = 1\n",
        "\n",
        "        for dir_path in dir_list:\n",
        "            short_path = os.path.join(temp_lpath, dir_path)\n",
        "            file_name = os.path.basename(short_path)\n",
        "            new_path = shorterFileName(short_path)\n",
        "            os.rename(short_path, new_path)\n",
        "            start_time = datetime.datetime.now()\n",
        "            current_time[0] = time.time()\n",
        "            text_msg = f\"<b>📤 UPLOADING SPLIT » {count} OF {len(dir_list)} Files</b>\\n\\n<code>{file_name}</code>\\n\"\n",
        "            msg = await bot.edit_message_text(\n",
        "                chat_id=chat_id,\n",
        "                message_id=msg.id,\n",
        "                text=task_msg + text_msg + \"\\n⏳ __Starting.....__\" + system_info(),\n",
        "                reply_markup=keyboard(),\n",
        "            )\n",
        "            await upload_file(new_path, file_name)\n",
        "            up_bytes.append(os.stat(new_path).st_size)\n",
        "\n",
        "            count += 1\n",
        "\n",
        "        shutil.rmtree(temp_lpath)\n",
        "\n",
        "    else:\n",
        "        file_name = os.path.basename(file_path)\n",
        "        new_path = shorterFileName(file_path)  # Trimming filename upto 50 chars\n",
        "        os.rename(file_path, new_path)\n",
        "        start_time = datetime.datetime.now()\n",
        "        current_time[0] = time.time()\n",
        "        text_msg = f\"<b>📤 UPLOADING » </b>\\n\\n<code>{file_name}</code>\\n\"\n",
        "        msg = await bot.edit_message_text(\n",
        "            chat_id=chat_id,\n",
        "            message_id=msg.id,\n",
        "            text=task_msg + text_msg + \"\\n⏳ __Starting.....__\" + system_info(),\n",
        "            reply_markup=keyboard(),\n",
        "        )\n",
        "        await upload_file(new_path, file_name)\n",
        "        up_bytes.append(os.stat(new_path).st_size)\n",
        "\n",
        "        os.remove(new_path)\n",
        "\n",
        "\n",
        "async def Leech(folder_path):\n",
        "    files = [str(p) for p in pathlib.Path(folder_path).glob(\"**/*\") if p.is_file()]\n",
        "    for f in natsorted(files):\n",
        "        file_path = os.path.join(folder_path, f)\n",
        "        await Leecher(file_path)\n",
        "\n",
        "    shutil.rmtree(folder_path)\n",
        "\n",
        "\n",
        "async def ZipLeech(d_fol_path):\n",
        "    global msg, down_msg, start_time, total_down_size\n",
        "\n",
        "    down_msg = f\"<b>🔐 ZIPPING » </b>\\n\\n<code>{d_name}</code>\\n\"\n",
        "\n",
        "    try:\n",
        "        msg = await bot.edit_message_text(\n",
        "            chat_id=chat_id,\n",
        "            message_id=msg.id,\n",
        "            text=task_msg + down_msg + system_info(),\n",
        "        )\n",
        "    except Exception as e2:\n",
        "        print(f\"Problem in ZipLeech !{e2}\")\n",
        "\n",
        "    print(\"\\nNow ZIPPING the folder...\")\n",
        "    current_time[0] = time.time()\n",
        "    start_time = datetime.datetime.now()\n",
        "    if not os.path.exists(temp_zpath):\n",
        "        makedirs(temp_zpath)\n",
        "    await zip_folder(d_fol_path)\n",
        "    clear_output()\n",
        "    time.sleep(2)\n",
        "\n",
        "    total_down_size = get_folder_size(temp_zpath)\n",
        "\n",
        "    if os.path.exists(d_fol_path):\n",
        "        shutil.rmtree(d_fol_path)\n",
        "    await Leech(temp_zpath)\n",
        "\n",
        "\n",
        "async def UnzipLeech(d_fol_path):\n",
        "    global msg\n",
        "\n",
        "    down_msg = f\"\\n<b>📂 EXTRACTING » </b>\\n\\n<code>{d_name}</code>\\n\"\n",
        "\n",
        "    msg = await bot.edit_message_text(\n",
        "        chat_id=chat_id,\n",
        "        message_id=msg.id,\n",
        "        text=task_msg + down_msg + \"\\n⏳ __Starting.....__\" + system_info(),\n",
        "    )\n",
        "    cant_files = []\n",
        "    filenames = [str(p) for p in pathlib.Path(d_fol_path).glob(\"**/*\") if p.is_file()]\n",
        "    for f in natsorted(filenames):\n",
        "        short_path = os.path.join(d_fol_path, f)\n",
        "        if not os.path.exists(temp_unzip_path):\n",
        "            makedirs(temp_unzip_path)\n",
        "        filename = os.path.basename(f).lower()\n",
        "        _, ext = os.path.splitext(filename)\n",
        "        try:\n",
        "            if os.path.exists(short_path):\n",
        "                if ext in [\".7z\", \".gz\", \".zip\", \".rar\", \".001\", \".tar\", \".z01\"]:\n",
        "                    await extract_zip(short_path)\n",
        "                    await Leech(temp_unzip_path)\n",
        "                else:\n",
        "                    cant_files.append(short_path)\n",
        "                    print(\n",
        "                        f\"Unable to Extract {os.path.basename(f)} ! Will be Leeching later !\"\n",
        "                    )\n",
        "        except Exception as e5:\n",
        "            print(f\"UZLeech Launcher Exception: {e5}\")\n",
        "\n",
        "    try:\n",
        "        for path in cant_files:\n",
        "            if os.path.exists(path):\n",
        "                await Leecher(path)\n",
        "    except Exception as e5:\n",
        "        print(f\"UZLeech Launcher Exception: {e5}\")\n",
        "\n",
        "    shutil.rmtree(d_fol_path)\n",
        "\n",
        "\n",
        "async def FinalStep(msg):\n",
        "    final_text = (\n",
        "        f\"<b>📂 Total Files:</b>  <code>{len(sent_file)}</code>\\n\\n<b>📜 LOG:</b>\\n\"\n",
        "    )\n",
        "    l_ink = \"⍟───── [Colab Leech](https://colab.research.google.com/drive/12hdEqaidRZ8krqj7rpnyDzg1dkKmvdvp) ─────⍟\"\n",
        "    last_text = (\n",
        "        f\"\\n\\n<b>{(task).upper()} COMPLETE 🔥</b>\\n\\n\"\n",
        "        + f\"╭<b>📛 Name » </b>  <code>{d_name}</code>\\n\"\n",
        "        + f\"├<b>📦 Size » </b><code>{size_measure(sum(up_bytes))}</code>\\n\"\n",
        "        + f\"╰<b>🍃 Saved Time »</b> <code>{convert_seconds((datetime.datetime.now() - task_start).seconds)}</code>\"\n",
        "    )\n",
        "    src = f\"**SOURCE »** __[Links]({src_link})__\"\n",
        "    await bot.send_message(\n",
        "        chat_id=dump_id,\n",
        "        text=src + last_text,\n",
        "        reply_to_message_id=sent.id,\n",
        "    )\n",
        "\n",
        "    await bot.edit_message_text(\n",
        "        chat_id=chat_id,\n",
        "        message_id=msg.id,\n",
        "        text=task_msg + l_ink + last_text,\n",
        "        reply_markup=keyboard(),\n",
        "    )\n",
        "\n",
        "    try:\n",
        "        final_texts = []\n",
        "\n",
        "        for i in range(len(sent_file)):\n",
        "            file_link = f\"https://t.me/c/{link_p}/{sent_file[i].id}\"\n",
        "            fileName = sent_fileName[i]\n",
        "            fileText = f\"\\n({str(i+1).zfill(2)}) <a href={file_link}>{fileName}</a>\"\n",
        "            if len(final_text + fileText) >= 4096:\n",
        "                final_texts.append(final_text)\n",
        "                final_text = fileText\n",
        "            else:\n",
        "                final_text += fileText\n",
        "        final_texts.append(final_text)\n",
        "\n",
        "        for fn_txt in final_texts:\n",
        "            msg = await bot.send_message(\n",
        "                chat_id=chat_id, reply_to_message_id=msg.id, text=fn_txt\n",
        "            )\n",
        "    except Exception as e:\n",
        "        Err = f\"<b>Error Sending logs » </b><i>{e}</i>\"\n",
        "        Err += f\"\\n\\n<i>⚠️ If You are Unknown with this **ERROR**, Then Forward This Message in [Colab Leecher Discussion](https://t.me/Colab_Leecher_Discuss) Where [Xron Trix](https://t.me/XronTrix) may fix it</i>\"\n",
        "        await bot.send_message(chat_id=chat_id, reply_to_message_id=msg.id, text=Err)\n",
        "\n",
        "\n",
        "\n",
        "# ****************************************************************\n",
        "#    Main Functions, function calls and variable declarations\n",
        "# ****************************************************************\n",
        "api_id, chat_id, dump_id = int(API_ID), int(CHAT_ID), int(DUMP_ID)\n",
        "link_p = str(dump_id)[4:]\n",
        "custom_thumb = \"/content/thmb.jpg\"\n",
        "d_path = \"/content/bot_Folder\"\n",
        "d_name = \"\"\n",
        "d_fol_path = PATH\n",
        "temp_lpath = f\"{d_path}/Leeched_Files\"\n",
        "temp_unzip_path = f\"{d_path}/Unzipped_Files/\"\n",
        "temp_zpath = temp_lpath\n",
        "sent_file = []\n",
        "sent_fileName = []\n",
        "up_bytes = []\n",
        "up_bytes.append(0)\n",
        "current_time = []\n",
        "current_time.append(time.time())\n",
        "start_time = datetime.datetime.now()\n",
        "text_msg = \"\"\n",
        "choice = \"x\"\n",
        "\n",
        "if not Thumbnail_Checker(\"/content\"):\n",
        "    thumb_path = \"/content/Telegram-Leecher/custom_thmb.jpg\"\n",
        "    print(\"Didn't find thumbnail, So switching to default thumbnail\")\n",
        "else:\n",
        "    thumb_path = custom_thumb\n",
        "\n",
        "if ospath.exists(d_path):\n",
        "    shutil.rmtree(d_path)\n",
        "    makedirs(d_path)\n",
        "else:\n",
        "    makedirs(d_path)\n",
        "\n",
        "if len(LEECH_MODE) == 0:\n",
        "    while choice not in [\"1\", \"2\", \"3\", \"l\", \"z\", \"u\"]:\n",
        "        choice = input(\n",
        "            \"Choose the Operation:\\n\\n\\t[1 / L] Leech\\n\\t[2 / Z] Zipleech\\n\\t[3 / U] Unzipleech\\n\\nEnter: \"\n",
        "        ).lower()\n",
        "        clear_output()\n",
        "        if choice not in [\"1\", \"2\", \"3\", \"l\", \"z\", \"u\"]:\n",
        "            print(f\"No Such Leech Mode '{choice}' ! Enter Option Correctly 🦥\\n\")\n",
        "else:\n",
        "    choice = LEECH_MODE.lower()\n",
        "\n",
        "if choice == \"1\" or choice == \"l\":\n",
        "    task = \"Leech\"\n",
        "elif choice == \"2\" or choice == \"z\":\n",
        "    task = \"Zipleech\"\n",
        "else:\n",
        "    task = \"Unzipleech\"\n",
        "leech_type = \"Document\" if LEECH_DOCUMENT else \"Media\"\n",
        "\n",
        "time.sleep(1)\n",
        "clear_output()\n",
        "print(f\"TASK MODE: {task} as {leech_type}\")\n",
        "\n",
        "custom_name = C_NAME\n",
        "d_name = os.path.basename(PATH)\n",
        "\n",
        "task_start = datetime.datetime.now()\n",
        "down_msg = f\"<b>📤 UPLOADING » </b>\\n\"\n",
        "task_msg = f\"<b>🦞 TASK MODE » </b><i>{task} as {leech_type}</i>\\n\\n\"\n",
        "\n",
        "dump_task = task_msg + \"<b>🖇️ SOURCES » </b>\"\n",
        "dump_task += f\"\\n\\n{PATH}\"\n",
        "cdt = datetime.datetime.now(pytz.timezone(\"Asia/Kolkata\"))\n",
        "dt = cdt.strftime(\" %d/%m/%Y\")\n",
        "dump_task += f\"\\n\\n<b>📆 Task Date » </b><i>{dt}</i>\"\n",
        "\n",
        "if not ospath.exists(d_fol_path):\n",
        "    raise Exception(f\"Provided PATH does not exist ! {d_fol_path}\")\n",
        "\n",
        "async with Client(\n",
        "    \"my_bot\", api_id=api_id, api_hash=API_HASH, bot_token=BOT_TOKEN\n",
        ") as bot:\n",
        "    try:\n",
        "        sent = await bot.send_message(chat_id=dump_id, text=dump_task)\n",
        "\n",
        "        src_link = f\"https://t.me/c/{link_p}/{sent.id}\"\n",
        "        task_msg += \"<b>🖇️ SOURCE » </b>\" + f\"__[Links]({src_link})__\\n\\n\"\n",
        "\n",
        "        msg = await bot.send_photo(\n",
        "            chat_id=chat_id,\n",
        "            photo=thumb_path,\n",
        "            caption=task_msg\n",
        "            + down_msg\n",
        "            + f\"\\n📝 __Preparing To UPLOAD...__\"\n",
        "            + system_info(),\n",
        "            reply_markup=keyboard(),\n",
        "        )\n",
        "        clear_output()\n",
        "        total_down_size = get_folder_size(d_fol_path)\n",
        "\n",
        "        if choice in [\"1\", \"l\"] and len(custom_name) != 0:\n",
        "            files = os.listdir(d_fol_path)\n",
        "            for file_ in files:\n",
        "                current_name = os.path.join(d_fol_path, file_)\n",
        "                new_name = os.path.join(d_fol_path, custom_name)\n",
        "                os.rename(current_name, new_name)\n",
        "\n",
        "        clear_output()\n",
        "\n",
        "        if choice == \"1\" or choice == \"l\":\n",
        "            await Leech(d_fol_path)\n",
        "\n",
        "        elif choice == \"2\" or choice == \"z\":\n",
        "            await ZipLeech(d_fol_path)\n",
        "\n",
        "        else:\n",
        "            await UnzipLeech(d_fol_path)\n",
        "\n",
        "        await FinalStep(msg)\n",
        "\n",
        "    except Exception as e:\n",
        "        clear_output()\n",
        "\n",
        "        Error_Text = (\n",
        "            \"⍟───── [Colab Leech](https://colab.research.google.com/drive/12hdEqaidRZ8krqj7rpnyDzg1dkKmvdvp) ─────⍟\\n\"\n",
        "            + f\"\\n<b>TASK FAILED TO COMPLETE 💔</b>\\n\\n╭<b>📛 Name » </b> <code>{d_name}</code>\\n├<b>🍃 Wasted Time » </b>\"\n",
        "            + f\"__{convert_seconds((datetime.datetime.now() - task_start).seconds)}__\\n\"\n",
        "            + f\"<b>╰🤔 Reason » </b>__{e}__\"\n",
        "            + f\"\\n\\n<i>⚠️ If You are Unknown with this **ERROR**, Then Forward This Message in [Colab Leecher Discussion](https://t.me/Colab_Leecher_Discuss) Where [Xron Trix](https://t.me/XronTrix) may fix it</i>\"\n",
        "        )\n",
        "        try:\n",
        "            await bot.delete_messages(chat_id=chat_id, message_ids=msg.id)\n",
        "            await bot.send_photo(\n",
        "                chat_id=chat_id,\n",
        "                photo=thumb_path,\n",
        "                caption=task_msg + Error_Text,\n",
        "                reply_markup=InlineKeyboardMarkup(\n",
        "                    [\n",
        "                        [\n",
        "                            InlineKeyboardButton(  # Opens a web URL\n",
        "                                \"Report Issue 🥺\",\n",
        "                                url=\"https://github.com/XronTrix10/Telegram-Leecher/issues\",\n",
        "                            ),\n",
        "                            InlineKeyboardButton(  # Opens a web URL\n",
        "                                \"Group Discuss 🤔\",\n",
        "                                url=\"https://t.me/Colab_Leecher_Discuss\",\n",
        "                            ),\n",
        "                        ],\n",
        "                    ]\n",
        "                ),\n",
        "            )\n",
        "        except Exception as d:\n",
        "            print(f\"Another Error Occured: {d}\")\n",
        "        print(f\"Error Occured: {e}\")\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "DDxF4Ggv-C6Y"
      },
      "source": [
        "## 🪞 Mirror to Google Drive [ Coming Soon ]\n",
        "\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "AuDEk2B7JXux"
      },
      "source": [
        "### Told You Coming Soon"
      ]
    }
  ],
  "metadata": {
    "colab": {
      "collapsed_sections": [
        "m1f3umhJoVfU",
        "DDxF4Ggv-C6Y"
      ],
      "private_outputs": true,
      "provenance": []
    },
    "gpuClass": "standard",
    "kernelspec": {
      "display_name": "Python 3",
      "name": "python3"
    },
    "language_info": {
      "name": "python",
      "version": "3.11.2"
    }
  },
  "nbformat": 4,
  "nbformat_minor": 0
}