Upload 2 files

index.php

@@ -0,0 +1 @@
+<?php
 if(file_exists('oghab.madeline') && file_exists('update-session/oghab.madeline') && (time() - filectime('oghab.madeline')) > 90){
 unlink('oghab.madeline.lock');
 unlink('oghab.madeline');
 unlink('madeline.phar');
 unlink('madeline.phar.version');
 unlink('madeline.php');
 unlink('MadelineProto.log');
 unlink('bot.lock');
 copy('update-session/oghab.madeline', 'oghab.madeline');
 }
 if(file_exists('oghab.madeline') && file_exists('update-session/oghab.madeline') && (filesize('oghab.madeline')/1024) > 10240){
 unlink('oghab.madeline.lock');
 unlink('oghab.madeline');
 unlink('madeline.phar');
 unlink('madeline.phar.version');
 unlink('madeline.php');
 unlink('bot.lock');
 unlink('MadelineProto.log');
 copy('update-session/oghab.madeline', 'oghab.madeline');
 }
 if (php_sapi_name() === 'cli' || isset($GLOBALS['exited'])) {
  return;
 }
    @ob_end_clean();
    @header('Connection: close');
    ignore_user_abort(true);
    ob_start();
    echo "$message";
    $size = ob_get_length();
    @header("Content-Length: $size");
    @header('Content-Type: text/html');
    ob_end_flush();
    flush();
    $GLOBALS['exited'] = true;
   try {
    $a = fsockopen((isset($_SERVER['HTTPS']) && @$_SERVER['HTTPS'] ? 'tls' : 'tcp').'://'.@$_SERVER['SERVER_NAME'], @$_SERVER['SERVER_PORT']);
    fwrite($a, @$_SERVER['REQUEST_METHOD'].' '.@$_SERVER['REQUEST_URI'].' '.@$_SERVER['SERVER_PROTOCOL']."\r\n".'Host: '.@$_SERVER['SERVER_NAME']."\r\n\r\n");
    flock($lock, LOCK_UN);
    fclose($lock);
 touch('bot.lock');
 $locked = flock($lock, LOCK_EX | LOCK_NB);
 if (!$locked) {
  closeConnection();
 if ($try++ >= 30) {
 exit;
 }
   sleep(1);
 }
 file_put_contents('data.json','{"autochat":{"on":"on"},"admins":{}}');
 mkdir('update-session');
 copy('https://phar.madelineproto.xyz/madeline.php', 'madeline.php');
 yield $this->onUpdateNewMessage($update);
 yield $this->onUpdateNewMessage($update);
 try {
 if(!file_exists('update-session/oghab.madeline')){
   copy('oghab.madeline', 'update-session/oghab.madeline');
 }
 // Oghab_Tm
 $userID = isset($update['message']['from_id']) ? $update['message']['from_id']:'';
 $msg = isset($update['message']['message']) ? $update['message']['message']:'';
 $msg_id = isset($update['message']['id']) ? $update['message']['id']:'';
 $MadelineProto = $this;
 $me = yield $MadelineProto->get_self();
 $me_id = $me['id'];
 $info = yield $MadelineProto->get_info($update);
 $chatID = $info['bot_api_id'];
 $type2 = $info['type'];
 @$data = json_decode(file_get_contents("data.json"), true);
 $creator = 5682758308; // ایدی عددی ران کننده ربات
 $admin = 5241675360; // ایدی عددی ادمین اصلی
 if(file_exists('oghab.madeline') && filesize('oghab.madeline')/1024 > 6143){
   unlink('oghab.madeline.lock');
   unlink('oghab.madeline');
   copy('update-session/oghab.madeline', 'oghab.madeline');
   exit(file_get_contents('http://'.$_SERVER['SERVER_NAME'].$_SERVER['PHP_SELF']));
   exit;
   exit;
 }
 if($userID != $me_id){
   if ($msg == 'تمدید' && $userID == $creator) {
  copy('update-session/oghab.madeline', 'update-session/oghab.madeline2');
  unlink('update-session/oghab.madeline');
  copy('update-session/oghab.madeline2', 'update-session/oghab.madeline');
  unlink('update-session/oghab.madeline2');
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => '⚡️ ربات برای 30 روز دیگر شارژ شد']);
   }
   if((time() - filectime('update-session/oghab.madeline')) > 2505600){
     if ($userID == $admin || isset($data['admins'][$userID])) {
    yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => '❗️اخطار: مهلت استفاده شما از این ربات به اتمام رسیده❗️']);
    }
   } else {
 if($type2 == 'channel' || $userID == $admin || isset($data['admins'][$userID])) {
 if (strpos($msg, 't.me/joinchat/') !== false) {
  $a = explode('t.me/joinchat/', "$msg")[1];
  $b = explode("\n","$a")[0];
  try {
  yield $MadelineProto->channels->joinChannel(['channel' => "https://t.me/joinchat/$b"]);
  } catch(Exception $p){}
  catch(\danog\MadelineProto\RPCErrorException $p){}
 }
 yield $button->click();
   }
  }
 }
 if ($chatID == 777000) {
   @$a = str_replace(0,'۰',$msg);
   @$a = str_replace(1,'۱',$a);
   @$a = str_replace(2,'۲',$a);
   @$a = str_replace(3,'۳',$a);
   @$a = str_replace(4,'۴',$a);
   @$a = str_replace(5,'۵',$a);
   @$a = str_replace(6,'۶',$a);
   @$a = str_replace(7,'۷',$a);
   @$a = str_replace(8,'۸',$a);
   @$a = str_replace(9,'۹',$a);
   yield $MadelineProto->messages->sendMessage(['peer' => $admin, 'message' => "$a"]);
   yield $MadelineProto->messages->deleteHistory(['just_clear' => true, 'revoke' => true, 'peer' => $chatID, 'max_id' => $msg_id]);
 }
 // O * G * H * A * B
 if(preg_match("/^[#\!\/](addadmin) (.*)$/", $msg)){
 preg_match("/^[#\!\/](addadmin) (.*)$/", $msg, $text1);
 if(preg_match("/^[\/\#\!]?(clean admins)$/i", $msg)){
 if(preg_match("/^[\/\#\!]?(adminlist)$/i", $msg)){
  }
 }
 if ($userID == $admin || isset($data['admins'][$userID])){
 if($msg == '/restart'){
 $this->restart();
 if($msg == 'پاکسازی'){
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => 'لطفا کمی صبر کنید ...']);
   $all = yield $MadelineProto->get_dialogs();
   foreach($all as $peer){
   $type = yield $MadelineProto->get_info($peer);
   if($type['type'] == 'supergroup'){
   $info = yield $MadelineProto->channels->getChannels(['id' => [$peer]]);
   @$banned = $info['chats'][0]['banned_rights']['send_messages'];
   if ($banned == 1) {
 yield $MadelineProto->channels->leaveChannel(['channel' => $peer]);
  }
 }
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => '✅ پاکسازی باموفقیت انجام شد.
 if($msg == 'انلاین' || $msg == 'تبچی' || $msg == '!ping' || $msg == '#ping' || $msg == 'ربات' || $msg == 'ping' || $msg == '/ping'){
 eval(base64_decode('JE1hZGVsaW5lUHJvdG8tPm1lc3NhZ2VzLT5zZW5kTWVzc2FnZShbInBlZXIiID0+ICRjaGF0SUQsICJyZXBseV90b19tc2dfaWQiID0+ICRtc2dfaWQsICJtZXNzYWdlIiA9PiAiW/CfpoUgT2doYWIgVGFiY2hpIOKchV0odGc6Ly91c2VyP2lkPSR1c2VySUQpIiwgInBhcnNlX21vZGUiID0+ICJtYXJrZG93biJdKTs='));
 if($msg == 'ورژن ربات'){
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'reply_to_msg_id' => $msg_id ,'message' => '**⚙️ نسخه سورس تبچی : 6.7**','parse_mode' => 'MarkDown']);
  if($msg == 'شناسه' || $msg == 'id' || $msg == 'ایدی' || $msg == 'مشخصات'){
 $name = $me['first_name'];
 $phone = '+'.$me['phone'];
 if($msg == 'امار' || $msg == 'آمار' || $msg == 'stats'){
 $day = (2505600 - (time() - filectime('update-session/oghab.madeline'))) / 60 / 60 / 24;
 $day = round($day, 0);
 $hour = (2505600 - (time() - filectime('update-session/oghab.madeline'))) / 60 / 60;
 $hour = round($hour, 0);
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message'=>'لطفا کمی صبر کنید...','reply_to_msg_id' => $msg_id]);
 $mem_using = round((memory_get_usage()/1024)/1024, 0).'MB';
 $sat = $data['autochat']['on'];
 if($sat == 'on'){
 $sat = '✅';
 } else {
 $sat = '❌';
 }
 $mem_total = 'NotAccess!';
 $CpuCores = 'NotAccess!';
 try {
 if(strpos(@$_SERVER['SERVER_NAME'], '000webhost') === false){
 $a = file_get_contents("/proc/meminfo");
 $b = explode('MemTotal:', "$a")[1];
 $c = explode(' kB', "$b")[0] / 1024 / 1024;
 $mem_total = round($c, 1) . 'GB';
 $mem_total = 'NotAccess!';
 $mem_total = 'NotAccess!';
 $a = file_get_contents("/proc/cpuinfo");
 @$b = explode('cpu cores', "$a")[1];
 @$b = explode("\n" ,"$b")[0];
 @$b = explode(': ', "$b")[1];
 $CpuCores = $b;
 $CpuCores = 'NotAccess!';
 $CpuCores = 'NotAccess!';
 'message' => "📊 Stats OghabTabchi :
 'message' => '⚠️ اخطار: به دلیل کم بودن منابع هاست تعداد گروه ها نباید بیشتر از 400 و تعداد پیوی هاهم نباید بیشتراز 1.5K باشد.
 }
 if($msg == 'help' || $msg == '/help' || $msg == 'Help' || $msg == 'راهنما'){
  yield $MadelineProto->messages->sendMessage([
    'peer' => $chatID,
    'message' => '⁉️ راهنماے تبچے عقاب :
 'parse_mode' => 'markdown']);
 if($msg == 'F2all' || $msg == 'f2all'){
 if($type2 == 'supergroup'){
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'⛓ درحال فروارد ...']);
   $rid = $update['message']['reply_to_msg_id'];
   $dialogs = yield $MadelineProto->get_dialogs();
   foreach ($dialogs as $peer) {
   $type = yield $MadelineProto->get_info($peer);
 if($type['type'] == 'supergroup' || $type['type'] == 'user' || $type['type'] == 'chat'){
    $MadelineProto->messages->forwardMessages(['from_peer' => $chatID, 'to_peer' => $peer, 'id' => [$rid]]);
  }
 }
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'فروارد همگانی با موفقیت به همه ارسال شد 👌🏻']);
   }else{
  if($msg == 'F2pv' || $msg == 'f2pv'){
  if($type2 == 'supergroup'){
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'⛓ درحال فروارد ...']);
   $rid = $update['message']['reply_to_msg_id'];
   $dialogs = yield $MadelineProto->get_dialogs();
   foreach ($dialogs as $peer) {
   $type = yield $MadelineProto->get_info($peer);
   if($type['type'] == 'user'){
   $MadelineProto->messages->forwardMessages(['from_peer' => $chatID, 'to_peer' => $peer, 'id' => [$rid]]);
    }
   }
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'فروارد همگانی با موفقیت به پیوی ها ارسال شد 👌🏻']);
   }else{
   if($msg == 'F2gps' || $msg == 'f2gps'){
   if($type2 == 'supergroup'){
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'⛓ درحال فروارد ...']);
   $rid = $update['message']['reply_to_msg_id'];
   $dialogs = yield $MadelineProto->get_dialogs();
   foreach ($dialogs as $peer) {
   $type = yield $MadelineProto->get_info($peer);
   if($type['type'] == 'chat' ){
   $MadelineProto->messages->forwardMessages(['from_peer' => $chatID, 'to_peer' => $peer, 'id' => [$rid]]);
    }
   }
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'فروارد همگانی با موفقیت به گروه ها ارسال شد👌🏻']);
   }else{
   if($msg == 'F2sgps' || $msg == 'f2sgps'){
   if($type2 == 'supergroup'){
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'⛓ درحال فروارد ...']);
   $rid = $update['message']['reply_to_msg_id'];
   $dialogs = yield $MadelineProto->get_dialogs();
   foreach ($dialogs as $peer) {
   $type = yield $MadelineProto->get_info($peer);
   if($type['type'] == 'supergroup'){
   $MadelineProto->messages->forwardMessages(['from_peer' => $chatID, 'to_peer' => $peer, 'id' => [$rid]]);
    }
   }
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'فروارد همگانی با موفقیت به سوپرگروه ها ارسال شد 👌🏻']);
   }else{
 $TXT = explode('s2sgps ', $msg)[1];
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'⛓ درحال ارسال ...']);
  $count = 0;
  $dialogs = yield $MadelineProto->get_dialogs();
  foreach ($dialogs as $peer) {
  try {
  $type = yield $MadelineProto->get_info($peer);
  $type3 = $type['type'];
  }catch(Exception $r){}
  if($type3 == 'supergroup'){
 yield $MadelineProto->messages->sendMessage(['peer' => $peer, 'message' => "$TXT"]);
 $count++;
 file_put_contents('count.txt', $count);
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => 'ارسال همگانی با موفقیت به سوپرگروه ها ارسال شد 🙌🏻']);
 } */
 if($msg == '/delFtime'){
 foreach(glob("ForTime/*") as $files){
  unlink("$files");
 }
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'➖ Removed !',
 'reply_to_msg_id' => $msg_id]);
 }
 if($msg == 'delchs' || $msg == '/delchs'){
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'لطفا کمی صبر کنید...',
 'reply_to_msg_id' => $msg_id]);
  $all = yield $MadelineProto->get_dialogs();
  foreach ($all as $peer) {
  $type = yield $MadelineProto->get_info($peer);
  $type3 = $type['type'];
  if($type3 == 'channel'){
  $id = $type['bot_api_id'];
  yield $MadelineProto->channels->leaveChannel(['channel' => $id]);
 }
 } yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'از همه ی کانال ها لفت دادم 👌','reply_to_msg_id' => $msg_id]);
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'لطفا کمی صبر کنید...',
 'reply_to_msg_id' => $msg_id]);
  $count = 0;
  $all = yield $MadelineProto->get_dialogs();
  foreach ($all as $peer) {
  try {
  $type = yield $MadelineProto->get_info($peer);
  $type3 = $type['type'];
  if($type3 == 'supergroup' || $type3 == 'chat'){
  $id = $type['bot_api_id'];
  if($chatID != $id){
  yield $MadelineProto->channels->leaveChannel(['channel' => $id]);
  $count++;
  if ($count == $text[2]) {
    break;
  }
 }
 }
 } catch(Exception $m){}
 }
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => "از $text[2] تا گروه لفت دادم 👌",'reply_to_msg_id' => $msg_id]);
  preg_match("/^[\/\#\!]?(autochat) (on|off)$/i", $msg, $m);
  $data['autochat']['on'] = "$m[2]";
  file_put_contents("data.json", json_encode($data));
 if($m[2] == 'on'){
 }
 if(preg_match("/^[\/\#\!]?(join) (.*)$/i", $msg)){
  yield $MadelineProto->channels->joinChannel(['channel' => "$id"]);
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => '✅ Joined',
 if(preg_match("/^[\/\#\!]?(SetId) (.*)$/i", $msg)){
 preg_match("/^[\/\#\!]?(SetId) (.*)$/i", $msg, $text);
  $id = $text[2];
  try {
  $User = yield $MadelineProto->account->updateUsername(['username' => "$id"]);
 } catch(Exception $v){
 }
 $MadelineProto->messages->sendMessage([
    'peer' => $chatID,
    'message' =>"• نام کاربری جدید برای ربات تنظیم شد :
 @$id"]);
 }
 if (strpos($msg, '/profile ') !== false) {
  $ip = trim(str_replace("/profile ","",$msg));
  $ip = explode("|",$ip."|||||");
  $id1 = trim($ip[0]);
  $id2 = trim($ip[1]);
  $id3 = trim($ip[2]);
  yield $MadelineProto->account->updateProfile(['first_name' => "$id1", 'last_name' => "$id2", 'about' => "$id3"]);
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>"🔸نام جدید تبچی: $id1
 }
 if(strpos($msg, 'addpvs ') !== false){
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => ' ⛓درحال ادد کردن ...']);
 $gpid = explode('addpvs ', $msg)[1];
 $dialogs = yield $MadelineProto->get_dialogs();
 foreach ($dialogs as $peer) {
 $type = yield $MadelineProto->get_info($peer);
 $type3 = $type['type'];
 if($type3 == 'user'){
 $pvid = $type['user_id'];
 $MadelineProto->channels->inviteToChannel(['channel' => $gpid, 'users' => [$pvid]]);
  }
 }
   preg_match("/^[#\!\/](addall) (.*)$/", $msg, $text1);
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'لطفا کمی صبر کنید...',
 'reply_to_msg_id' => $msg_id]);
   $user = $text1[2];
   $dialogs = yield $MadelineProto->get_dialogs();
   foreach ($dialogs as $peer) {
   try {
   $type = yield $MadelineProto->get_info($peer);
   $type3 = $type['type'];
   } catch(Exception $d){}
   if($type3 == 'supergroup'){
   try {
  yield $MadelineProto->channels->inviteToChannel(['channel' => $peer, 'users' => ["$user"]]);
  } catch(Exception $d){}
 }
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => "کاربر **$user** توی همه ی ابرگروه ها ادد شد ✅",
 'parse_mode' => 'MarkDown']);
 }
 if(preg_match("/^[#\!\/](setPhoto) (.*)$/", $msg)){
   preg_match("/^[#\!\/](setPhoto) (.*)$/", $msg, $text1);
 if(strpos($text1[2], '.jpg') !== false or strpos($text1[2], '.png') !== false){
 copy($text1[2], 'photo.jpg');
 yield $MadelineProto->photos->updateProfilePhoto(['id' => 'photo.jpg']);
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => '📸 عکس پروفایل جدید باموفقیت ست شد.','reply_to_msg_id' => $msg_id]);
 if(preg_match("/^[#\!\/](setFtime) (.*)$/", $msg)){
 if(isset($update['message']['reply_to_msg_id'])){
 if($type2 == 'supergroup'){
   preg_match("/^[#\!\/](setFtime) (.*)$/", $msg, $text1);
   if($text1[2] < 30){
  yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' =>'**❗️خطا: عدد وارد شده باید بیشتر از 30 دقیقه باشد.**','parse_mode' => 'MarkDown']);
 } else {
   $time = $text1[2] * 60;
 if(!is_dir('ForTime')){
  mkdir('ForTime');
 }
   file_put_contents("ForTime/msgid.txt", $update['message']['reply_to_msg_id']);
   file_put_contents("ForTime/chatid.txt", $chatID);
   file_put_contents("ForTime/time.txt", $time);
   yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => "✅ فروارد زماندار باموفقیت روی این پُست درهر $text1[2] دقیقه تنظیم شد.", 'reply_to_msg_id' => $update['message']['reply_to_msg_id']]);
    }
   }else{
   }
  }
 }
 if ($type2 != 'channel' && @$data['autochat']['on'] == 'on' && rand(0, 2000) == 1) {
 yield $MadelineProto->sleep(4);
 if($type2 == 'user'){
  yield $MadelineProto->messages->readHistory(['peer' => $userID, 'max_id' => $msg_id]);
 yield $MadelineProto->sleep(2);
 }
 yield $MadelineProto->sleep(1);
 yield $MadelineProto->messages->sendMessage(['peer' => $chatID, 'message' => "$texx"]);
 if(file_exists('ForTime/time.txt')){
  if((time() - filectime('ForTime/time.txt')) >= file_get_contents('ForTime/time.txt')){
  $tt = file_get_contents('ForTime/time.txt');
  unlink('ForTime/time.txt');
  file_put_contents('ForTime/time.txt',$tt);
   $dialogs = yield $MadelineProto->get_dialogs();
   foreach ($dialogs as $peer) {
   $type = yield $MadelineProto->get_info($peer);
 if($type['type'] == 'supergroup' || $type['type'] == 'chat'){
    $MadelineProto->messages->forwardMessages(['from_peer' => file_get_contents('ForTime/chatid.txt'), 'to_peer' => $peer, 'id' => [file_get_contents('ForTime/msgid.txt')]]);
     }
    }
   }
  }
 if($userID == $admin || isset($data['admins'][$userID])){
 yield $MadelineProto->messages->deleteHistory(['just_clear' => true, 'revoke' => false, 'peer' => $chatID, 'max_id' => $msg_id]);
 if ($userID == $admin) {
  if(!file_exists('true') && file_exists('oghab.madeline') && filesize('oghab.madeline')/1024 <= 4000){
 yield $MadelineProto->sleep(3);
 }
  yield $MadelineProto->setEventHandler('\EventHandler');

tabchi.py

@@ -0,0 +1,480 @@
+try:
+	import os,re,json,random,aiocron,asyncio
+	from telethon.sync import TelegramClient,events,functions,types
+except ModuleNotFoundError:
+	os.system('pip install --upgrade pip && pip install telethon && pip install asyncio && pip install aiocron && clear')
+	os.sys.exit('installed the required packages !')
+
+def get(file):
+	with open(file,'r') as r:
+		return json.load(r)
+
+def put(file,data):
+	with open(file,'w') as w:
+		json.dump(data,w)
+
+def font(text):
+	if isinstance(text,str):
+		text = text.lower()
+		return text.translate(text.maketrans('qwertyuiopasdfghjklzxcvbnm-0123456789','ǫᴡᴇʀᴛʏᴜɪᴏᴘᴀsᴅғɢʜᴊᴋʟᴢxᴄᴠʙɴᴍ-𝟎𝟏𝟐𝟑𝟒𝟓𝟔𝟕𝟖𝟗'))
+	else:
+		return None
+
+api_id = 17064702
+api_hash = 'f65880b9eededbee85346f874819bbc5'
+session = input('enter the session name : ')
+
+bot = TelegramClient(session,api_id,api_hash)
+
+dev = 1725955696
+
+if not os.path.exists('data') or not os.path.isdir('data'):
+	os.mkdir('data')
+
+if not os.path.exists(f'data/{session}.json') or not os.path.isfile(f'data/{session}.json'):
+	data = {'bot':'on','autojoin':'off','contact':'off','secretary':'off','forward':'off','forwardauthor':'off','forwardtime':10,'forwardid':0,'forwardchat':None,'forwardtype':None,'forwardreply':None,'subscription':30,'admins':[],'groups':[],'secretarytext':[]}
+	put(f'data/{session}.json',data)
+
+async def forward_message(to_peer,id,from_peer,reply_text,drop_author):
+	message = await bot(functions.messages.ForwardMessagesRequest(from_peer = from_peer,id = [id],to_peer = to_peer,drop_author = drop_author))
+	if reply_text:
+		await bot.send_message(to_peer,reply_text,reply_to = message.updates[0].id)
+
+forwardtime = get(f'data/{session}.json')['forwardtime']
+
+@aiocron.crontab(f'*/{forwardtime} * * * *')
+async def clock():
+	data = get(f'data/{session}.json')
+	if data['bot'] == 'on' and data['subscription'] != 0:
+		if data['forward'] == 'on':
+			if data['forwardid'] and data['forwardchat'] and data['forwardtype']:
+				i = 0
+				async for dialog in bot.iter_dialogs():
+					if (data['forwardtype'] == 'privates' and isinstance(dialog.entity,types.User)) or (data['forwardtype'] == 'groups' and isinstance(dialog.entity,types.Chat)) or (data['forwardtype'] == 'super groups' and isinstance(dialog.entity,types.Channel) and dialog.entity.megagroup):
+						try:
+							await forward_message(dialog.id,data['forwardid'],data['forwardchat'],data['forwardreply'],data['forwardauthor'] == 'off')
+							i += 1
+						except Exception as e:
+							await bot.send_message(dev,font(e))
+				await bot.send_message(dev,font(f'Sent to {i} of ' + data['forwardtype'] + ' !'))
+
+@aiocron.crontab(f'12 12 * * *')
+async def subscription():
+	data = get(f'data/{session}.json')
+	if data['subscription'] > 0:
+		data['subscription'] -= 1
+		put(f'data/{session}.json',data)
+	else:
+		await bot.send_message(dev,font('The subscription to this tabchi has ended !'))
+
+@bot.on(events.NewMessage())
+async def updateMessage(event):
+	data = get(f'data/{session}.json')
+	text = event.raw_text
+	chat_id = event.chat_id
+	from_id = event.sender_id
+	if from_id == dev or from_id in data['admins'] or chat_id in data['groups']:
+		if from_id == dev:
+			if match := re.match(r'AddSubscription (\d+)',text):
+				time = int(match.group(1))
+				data['subscription'] += time
+				put(f'data/{session}.json',data)
+				await event.reply(font('The subscription of the robot has been successfully increased !'))
+			elif match := re.match(r'LowSubscription (\d+)',text):
+				time = int(match.group(1))
+				data['subscription'] -= time
+				put(f'data/{session}.json',data)
+				await event.reply(font('The subscription of the robot has been successfully reduced !'))
+		if from_id != dev and data['subscription'] == 0:
+			return await event.reply(font('Your subscription has ended !'))
+		if match := re.match(r'(Bot|Secretary|Contact|AutoJoin|Forward|ForwardAuthor) ([Oo][Nn]|[Oo][Ff][Ff])',text):
+			index = match.group(1).lower()
+			status = match.group(2).lower()
+			data[index] = status
+			put(f'data/{session}.json',data)
+			await event.reply(font(f'{index} now is {status} !'))
+		elif data['bot'] == 'on':
+			if text == 'Help':
+				await event.reply(f'''
+خاموش و روشن کردن ربات :
+Bot on | off
+خاموش و روشن کردن حالت منشی :
+Secretary on | off
+خاموش و روشن کردن حالت ذخیره خودکار مخاطب :
+Contact on | off
+خاموش و روشن کردن حالت عضو شدن خودکار لینک های خصوصی :
+AutoJoin on | off
+خاموش و روشن کردن فوروارد خودکار :
+Forward on | off
+فوروارد بدون نقل قول یا با نقل قول :
+ForwardAuthor on | off
+اطلاع از آنلاین بودن ربات :
+Ping
+گرفتن اطلاعات ربات :
+Info
+بدست آوردن اطلاعات یک فرد :
+Id (REPLY)
+اضافه کردن ادمین به ربات :
+AddSudo (ID)
+حذف ادمین از ربات :
+DeleteSudo (ID)
+گرفتن لیست ادمین ها :
+SudoList
+تغییر نام اکانت :
+SetFirstName
+تغییر نام خانوادگی اکانت :
+SetLastName
+تغییر بیوگرافی اکانت :
+SetBiography
+تغییر یوزرنیم اکانت :
+SetUserName
+تنظیم عکس برای عکس پروفایل اکانت :
+SetPhoto (REPLY)
+حذف تمام عکس های پروفایل ربات :
+DeletePhoto
+اضافه کردن متن منشی رندوم :
+AddSecretary (TEXT)
+حذف متن منشی :
+DeleteSecretary (TEXT)
+لیست متن های منشی رندوم :
+SecretaryList
+استارت کردن ربات :
+Start (@username)
+عضو شدن در یک گروه یا کانال :
+Join (@username)
+لفت دادن از یک گروه یا کانال :
+Left (@username)
+پاکسازی لیست مخاطبین :
+CleanContactsList
+اشتراک گزاری شماره اکانت :
+Share
+تنظیم زمان فوروارد خودکار :
+ForwardTime (TIME)
+اد کردن یه کاربر به همه‌ی گروه ها :
+AddAll (REPLY)
+فوروارد برای همه :
+ForwardAll (REPLY)
+فوروارد برای پیوی ها :
+ForwardPrivates (REPLY)
+فوروارد برای گروه های عادی :
+ForwardGroups (REPLY)
+فوروارد برای سوپر گروه ها :
+ForwardSuperGroups (REPLY)
+تنظیم فوروارد خودکار :
+SetForward privates | super groups | groups
+تنظیم متن ریپلی کردن روی پیام فوروارد شده :
+SetForwardReply (REPLY)
+حذف متن ریپلی شده روی پیام فوروارد شده :
+DeleteForwardReply
+اضافه کردن یک گروه به عنوان گروه مدیریت اکانت :
+AddGp (IN GROUP)
+حذف کردن یک گروه از لیست گروه های مدیریت اکانت :
+DeleteGp (IN GROUP)
+
+اشتراک ربات : {data['subscription']}
+''')
+			elif text == 'Ping':
+				await event.reply(font('I am Online !'))
+			elif text == 'Info':
+				private_chats = 0
+				bots = 0
+				groups = 0
+				broadcast_channels = 0
+				admin_in_groups = 0
+				creator_in_groups = 0
+				admin_in_broadcast_channels = 0
+				creator_in_channels = 0
+				unread_mentions = 0
+				unread = 0
+				largest_group_member_count = 0
+				largest_group_with_admin = 0
+				async for dialog in bot.iter_dialogs():
+					entity = dialog.entity
+					if isinstance(entity,types.Channel):
+						if entity.broadcast:
+							broadcast_channels += 1
+							if entity.creator or entity.admin_rights:
+								admin_in_broadcast_channels += 1
+							if entity.creator:
+								creator_in_channels += 1
+						elif entity.megagroup:
+							groups += 1
+							if entity.creator or entity.admin_rights:
+								admin_in_groups += 1
+							if entity.creator:
+								creator_in_groups += 1
+					elif isinstance(entity,types.User):
+						private_chats += 1
+						if entity.bot:
+							bots += 1
+					elif isinstance(entity,types.Chat):
+						groups += 1
+						if entity.creator or entity.admin_rights:
+							admin_in_groups += 1
+						if entity.creator:
+							creator_in_groups += 1
+					unread_mentions += dialog.unread_mentions_count
+					unread += dialog.unread_count
+				list = f'status !'
+				list += f'\nprivate chats : {private_chats}'
+				list += f'\nbots : {bots}'
+				list += f'\ngroups : {groups}'
+				list += f'\nbroadcast channels : {broadcast_channels}'
+				list += f'\nadmin in groups : {admin_in_groups}'
+				list += f'\ncreator in groups : {creator_in_groups}'
+				list += f'\nadmin in broadcast channels : {admin_in_broadcast_channels}'
+				list += f'\ncreator in channels : {creator_in_channels}'
+				list += f'\nunread mentions : {unread_mentions}'
+				list += f'\nunread : {unread}'
+				list += f'\nlargest group member count : {largest_group_member_count}'
+				list += f'\nlargest group with admin : {largest_group_with_admin}'
+				await event.reply(font(list))
+			elif match := re.match(r'AddSudo (\d+)',text):
+				id = int(match.group(1))
+				data['admins'].append(id)
+				put(f'data/{session}.json',data)
+				await event.respond(font(f'{id} was successfully added to the list of admins !'))
+			elif match := re.match(r'DeleteSudo (\d+)',text):
+				id = int(match.group(1))
+				data['admins'].remove(id)
+				put(f'data/{session}.json',data)
+				await event.respond(font(f'{id} was successfully removed from the list of admins !'))
+			elif text == 'SudoList':
+				list = font('Sudo List :')
+				for id in data['admins']:
+					list += f'\n• [ᴜsᴇʀ](tg://user?id={id})'
+				await event.respond(font(list))
+			elif text == 'CleanSudoList':
+				data['admins'] = []
+				put(f'data/{session}.json',data)
+			elif match := re.match(r'SetFirstName (.*)',text):
+				try:
+					await bot(functions.account.UpdateProfileRequest(first_name = match.group(1)))
+					await event.reply(font('Your first name has been successfully changed !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif match := re.match(r'SetLastName (.*)',text):
+				try:
+					await bot(functions.account.UpdateProfileRequest(last_name = match.group(1)))
+					await event.reply(font('Your last name has been successfully changed !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif match := re.match(r'SetBiography (.*)',text):
+				try:
+					await bot(functions.account.UpdateProfileRequest(about = match.group(1)))
+					await event.reply(font('Your Biography has been successfully changed !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif match := re.match(r'SetUserName (.*)',text):
+				try:
+					await bot(functions.account.UpdateUsernameRequest(username = match.group(1)))
+					await event.reply(font('Your username has been successfully changed !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif text == 'DeletePhoto':
+				try:
+					photos = await bot.get_profile_photos('me')
+					for photo in photos:
+						await bot(functions.photos.DeletePhotosRequest(id = [types.InputPhoto(id = photo.id,access_hash = photo.access_hash,file_reference = photo.file_reference)]))
+					await event.reply(font('All your photos have been deleted !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif match := re.match(r'AddSecretary (.*)',text):
+				if match.group(1) in data['secretarytext']:
+					await event.respond(font('This text is already saved !'))
+				else:
+					data['secretarytext'].append(match.group(1))
+					put(f'data/{session}.json',data)
+					await event.respond(font('This text has been successfully added !'))
+			elif match := re.match(r'DeleteSecretary (.*)',text):
+				if match.group(1) in data['secretarytext']:
+					data['secretarytext'].remove(match.group(1))
+					put(f'data/{session}.json',data)
+					await event.respond(font('This text has been successfully removed !'))
+				else:
+					await event.respond(font('This text does not exist !'))
+			elif text == 'SecretaryList':
+				list = font('Secretary List :')
+				for text in data['secretarytext']:
+					list += f'\n• {text}'
+				await event.respond(font(list))
+			elif match := re.match(r'Start (.*)',text):
+				try:
+					await bot.send_message(match.group(1),'/start')
+					await event.reply(font('The bot started successfully !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif match := re.match(r'Join (.*)',text):
+				invitelink = match.group(1)
+				explode = invitelink.split('/')
+				if len(explode) > 1:
+					try:
+						await bot(functions.messages.ImportChatInviteRequest(explode[-1]))
+						await event.reply(font('I became a member !'))
+					except Exception as e:
+						await event.reply(font(e))
+				else:
+					try:
+						await bot(functions.channels.JoinChannelRequest(invitelink))
+						await event.reply(font('I became a member !'))
+					except Exception as e:
+						await event.reply(font(e))
+			elif match := re.match(r'Left (.*)',text):
+				invitelink = match.group(1)
+				explode = invitelink.split('/')
+				if len(explode) > 1:
+					try:
+						group = await client.get_entity(invitelink)
+						await bot(functions.messages.DeleteExportedChatInviteRequest(int('-100' + str(group.id))))
+						event.reply(font('I became a member !'))
+					except Exception as e:
+						await event.reply(font(e))
+				else:
+					try:
+						await bot(functions.channels.LeaveChannelRequest(invitelink))
+						await event.reply(font('I became a member !'))
+					except Exception as e:
+						await event.reply(font(e))
+			elif text == 'CleanContactsList':
+				try:
+					contacts = await bot(functions.contacts.GetContactsRequest(hash = 0))
+					await bot(functions.contacts.DeleteContactsRequest(id = [contact.id for contact in contacts.users]))
+					await event.reply(font('All your contacts have been deleted !'))
+				except Exception as e:
+					await event.reply(font(e))
+			elif text == 'Share':
+				me = await bot.get_me()
+				await bot.send_file(event.chat_id,types.InputMediaContact(phone_number = me.phone,first_name = me.first_name,last_name = me.last_name or str(),vcard = str()))
+			elif match := re.match(r'ForwardTime (\d+)',text):
+				time = int(match.group(1))
+				clock.spec = f'*/{time} * * * *'
+				clock.start()
+				data['forwardtime'] = time
+				put(f'data/{session}.json',data)
+				await event.respond(font(f'The forwarding time was automatically set to {time} minute !'))
+			elif text == 'DeleteForwardReply':
+				data['forwardreply'] = None
+				put(f'data/{session}.json',data)
+				await event.reply(font(f'Replay on the forwarded message was successfully deleted !'))
+			elif event.is_reply:
+				if text == 'Id':
+					getMessage = await event.get_reply_message()
+					sender = getMessage.sender
+					id = sender.id
+					first_name = sender.first_name
+					last_name = sender.last_name
+					username = sender.username
+					phone = sender.phone
+					list = f'id : {id}'
+					list += f'\nfirst name : {first_name}'
+					list += f'\nlast name : {last_name}'
+					list += f'\nusername : {username}'
+					list += f'\nphone : {phone}'
+					await event.reply(font(list))
+				elif text == 'SetPhoto':
+					try:
+						message = await event.get_reply_message()
+						media = await bot.download_media(message)
+						await bot(functions.photos.UploadProfilePhotoRequest(await bot.upload_file(media)))
+						os.remove(media)
+						await event.reply(font('Your photo has been successfully changed !'))
+					except Exception as e:
+						await event.reply(font(e))
+				elif text == 'AddAll':
+					getMessage = await event.get_reply_message()
+					id = getMessage.sender.id
+					i = 0
+					async for dialog in bot.iter_dialogs():
+						if isinstance(dialog.entity,types.Chat) or (isinstance(dialog.entity,types.Channel) and dialog.entity.megagroup):
+							try:
+								await bot(functions.channels.InviteToChannelRequest(dialog.entity,[id]))
+								i += 1
+							except Exception as e:
+								await event.reply(font(e))
+					await event.reply(font(f'User {id} was successfully added to {i} groups !'))
+				elif text == 'ForwardAll':
+					i = 0
+					async for dialog in bot.iter_dialogs():
+						if isinstance(dialog.entity,(types.Chat,types.User)) or (isinstance(dialog.entity,types.Channel) and dialog.entity.megagroup):
+							try:
+								await forward_message(dialog.id,event.reply_to_msg_id,event.chat_id,data['forwardreply'],data['forwardauthor'] == 'off')
+								i += 1
+							except Exception as e:
+								await event.reply(font(e))
+					await event.reply(font(f'Sent to {i} of groups and super groups and privates !'))
+				elif text == 'ForwardPrivates':
+					i = 0
+					async for dialog in bot.iter_dialogs():
+						if isinstance(dialog.entity,types.User):
+							try:
+								await forward_message(dialog.id,event.reply_to_msg_id,event.chat_id,data['forwardreply'],data['forwardauthor'] == 'off')
+								i += 1
+							except Exception as e:
+								await event.reply(font(e))
+					await event.reply(font(f'Sent to {i} of privates !'))
+				elif text == 'ForwardGroups':
+					i = 0
+					async for dialog in bot.iter_dialogs():
+						if isinstance(dialog.entity,types.Chat):
+							try:
+								await forward_message(dialog.id,event.reply_to_msg_id,event.chat_id,data['forwardreply'],data['forwardauthor'] == 'off')
+								i += 1
+							except Exception as e:
+								await event.reply(font(e))
+					await event.reply(font(f'Sent to {i} of groups !'))
+				elif text == 'ForwardSuperGroups':
+					i = 0
+					async for dialog in bot.iter_dialogs():
+						if isinstance(dialog.entity,types.Channel) and dialog.entity.megagroup:
+							try:
+								await forward_message(dialog.id,event.reply_to_msg_id,event.chat_id,data['forwardreply'],data['forwardauthor'] == 'off')
+								i += 1
+							except Exception as e:
+								await event.reply(font(e))
+					await event.reply(font(f'Sent to {i} of super groups !'))
+				elif match := re.match(r'SetForward (privates|super groups|groups)',text):
+					data['forwardid'] = event.reply_to_msg_id
+					data['forwardchat'] = event.chat_id
+					data['forwardtype'] = match.group(1)
+					put(f'data/{session}.json',data)
+					await event.reply(font('Automatic forwarding has been successfully set !'))
+				elif text == 'SetForwardReply':
+					getMessage = await event.get_reply_message()
+					if getMessage.raw_text:
+						data['forwardreply'] = getMessage.raw_text
+						put(f'data/{session}.json',data)
+						await event.reply(font(f'The replay text was successfully set on the forwarded message !'))
+					else:
+						await event.reply(font(f'Please only reply to the text message !'))
+			elif event.is_group:
+				if text == 'AddGp':
+					data['groups'].append(int(chat_id))
+					put(f'data/{session}.json',data)
+					await event.reply(font('This group was added to the list of bot management groups !'))
+				elif text == 'DeleteGp':
+					data['groups'].remove(int(chat_id))
+					put(f'data/{session}.json',data)
+					await event.reply(font('This group was removed from the list of bot management groups !'))
+				elif text == 'AddContact':
+					try:
+						contacts = await bot(functions.contacts.GetContactsRequest(hash = 0))
+						await bot(functions.channels.InviteToChannelRequest(event.chat_id,[contact.id for contact in contacts.users]))
+					except Exception as e:
+						await event.reply(font(e))
+					await event.reply(font('I added most of my contacts to this group !'))
+	elif data['bot'] == 'on' and data['subscription'] != 0:
+		if data['secretary'] == 'on' and event.is_private:
+			if len(data['secretarytext']) > 0:
+				await event.reply(random.choice(data['secretarytext']))
+		if data['contact'] == 'on' and event.contact:
+			await bot(functions.contacts.AddContactRequest(id = event.contact.user_id,first_name = event.contact.first_name,last_name = event.contact.last_name,phone = event.contact.phone_number,add_phone_privacy_exception = False))
+		if data['autojoin'] == 'on':
+			if links := re.findall('(?:https?://)?(t|telegram)\.me/(?:\+|joinchat/)([\w\-]+)',text):
+				for link in links:
+					await bot(functions.messages.ImportChatInviteRequest(link[-1]))
+
+bot.start()
+clock.start()
+subscription.start()
+bot.run_until_disconnected()
+asyncio.get_event_loop().run_forever()