KaneAI - World’s First E2E Software Testing Agent.Book a Demo 
How to use on_message method in ATX
Best Python code snippet using ATX
Assistant.py
Source:Assistant.py 
...27{ASSISTANT_PREFIX[0]}bio [Bio text] 28- Changes Bio of Assistant Account.29"""30flood = {}31@ASS_CLI_1.on_message(32 filters.private33 & filters.incoming34 & ~filters.service35 & ~filters.edited36 & ~filters.me37 & ~filters.bot38 & ~filters.via_bot39 & ~filters.user(SUDOERS)40)41@ASS_CLI_2.on_message(42 filters.private43 & filters.incoming44 & ~filters.service45 & ~filters.edited46 & ~filters.me47 & ~filters.bot48 & ~filters.via_bot49 & ~filters.user(SUDOERS)50)51@ASS_CLI_3.on_message(52 filters.private53 & filters.incoming54 & ~filters.service55 & ~filters.edited56 & ~filters.me57 & ~filters.bot58 & ~filters.via_bot59 & ~filters.user(SUDOERS)60)61@ASS_CLI_4.on_message(62 filters.private63 & filters.incoming64 & ~filters.service65 & ~filters.edited66 & ~filters.me67 & ~filters.bot68 & ~filters.via_bot69 & ~filters.user(SUDOERS)70)71@ASS_CLI_5.on_message(72 filters.private73 & filters.incoming74 & ~filters.service75 & ~filters.edited76 & ~filters.me77 & ~filters.bot78 & ~filters.via_bot79 & ~filters.user(SUDOERS)80)81async def awaiting_message(client, message):82 user_id = message.from_user.id83 if await is_pmpermit_approved(user_id):84 return85 async for m in client.iter_history(user_id, limit=6):86 if m.reply_markup:87 await m.delete()88 if str(user_id) in flood:89 flood[str(user_id)] += 190 else:91 flood[str(user_id)] = 192 if flood[str(user_id)] > 5:93 await message.reply_text("Spam Detected. User Blocked")94 await client.send_message(95 LOG_GROUP_ID,96 f"**Spam Detect Block On Assistant**\n\n- **Blocked User:** {message.from_user.mention}\n- **User ID:** {message.from_user.id}",97 )98 return await client.block_user(user_id)99 await message.reply_text(100 f"Hello, I am {MUSIC_BOT_NAME}'s Assistant.\n\nPlease dont spam here , else you'll get blocked.\nFor more Help start :- @{BOT_USERNAME}"101 )102@ASS_CLI_1.on_message(103 filters.command("approve", prefixes=ASSISTANT_PREFIX)104 & filters.user(SUDOERS)105 & ~filters.via_bot106)107@ASS_CLI_2.on_message(108 filters.command("approve", prefixes=ASSISTANT_PREFIX)109 & filters.user(SUDOERS)110 & ~filters.via_bot111)112@ASS_CLI_3.on_message(113 filters.command("approve", prefixes=ASSISTANT_PREFIX)114 & filters.user(SUDOERS)115 & ~filters.via_bot116)117@ASS_CLI_4.on_message(118 filters.command("approve", prefixes=ASSISTANT_PREFIX)119 & filters.user(SUDOERS)120 & ~filters.via_bot121)122@ASS_CLI_5.on_message(123 filters.command("approve", prefixes=ASSISTANT_PREFIX)124 & filters.user(SUDOERS)125 & ~filters.via_bot126)127async def pm_approve(client, message):128 if not message.reply_to_message:129 return await eor(130 message, text="Reply to a user's message to approve."131 )132 user_id = message.reply_to_message.from_user.id133 if await is_pmpermit_approved(user_id):134 return await eor(message, text="User is already approved to pm")135 await approve_pmpermit(user_id)136 await eor(message, text="User is approved to pm")137@ASS_CLI_1.on_message(138 filters.command("disapprove", prefixes=ASSISTANT_PREFIX)139 & filters.user(SUDOERS)140 & ~filters.via_bot141)142@ASS_CLI_2.on_message(143 filters.command("disapprove", prefixes=ASSISTANT_PREFIX)144 & filters.user(SUDOERS)145 & ~filters.via_bot146)147@ASS_CLI_3.on_message(148 filters.command("disapprove", prefixes=ASSISTANT_PREFIX)149 & filters.user(SUDOERS)150 & ~filters.via_bot151)152@ASS_CLI_4.on_message(153 filters.command("disapprove", prefixes=ASSISTANT_PREFIX)154 & filters.user(SUDOERS)155 & ~filters.via_bot156)157@ASS_CLI_5.on_message(158 filters.command("disapprove", prefixes=ASSISTANT_PREFIX)159 & filters.user(SUDOERS)160 & ~filters.via_bot161)162async def pm_disapprove(client, message):163 if not message.reply_to_message:164 return await eor(165 message, text="Reply to a user's message to disapprove."166 )167 user_id = message.reply_to_message.from_user.id168 if not await is_pmpermit_approved(user_id):169 await eor(message, text="User is already disapproved to pm")170 async for m in client.iter_history(user_id, limit=6):171 if m.reply_markup:172 try:173 await m.delete()174 except Exception:175 pass176 return177 await disapprove_pmpermit(user_id)178 await eor(message, text="User is disapproved to pm")179@ASS_CLI_1.on_message(180 filters.command("block", prefixes=ASSISTANT_PREFIX)181 & filters.user(SUDOERS)182 & ~filters.via_bot183)184@ASS_CLI_2.on_message(185 filters.command("block", prefixes=ASSISTANT_PREFIX)186 & filters.user(SUDOERS)187 & ~filters.via_bot188)189@ASS_CLI_3.on_message(190 filters.command("block", prefixes=ASSISTANT_PREFIX)191 & filters.user(SUDOERS)192 & ~filters.via_bot193)194@ASS_CLI_4.on_message(195 filters.command("block", prefixes=ASSISTANT_PREFIX)196 & filters.user(SUDOERS)197 & ~filters.via_bot198)199@ASS_CLI_5.on_message(200 filters.command("block", prefixes=ASSISTANT_PREFIX)201 & filters.user(SUDOERS)202 & ~filters.via_bot203)204async def block_user_func(client, message):205 if not message.reply_to_message:206 return await eor(message, text="Reply to a user's message to block.")207 user_id = message.reply_to_message.from_user.id208 await eor(message, text="Successfully blocked the user")209 await client.block_user(user_id)210@ASS_CLI_1.on_message(211 filters.command("unblock", prefixes=ASSISTANT_PREFIX)212 & filters.user(SUDOERS)213 & ~filters.via_bot214)215@ASS_CLI_2.on_message(216 filters.command("unblock", prefixes=ASSISTANT_PREFIX)217 & filters.user(SUDOERS)218 & ~filters.via_bot219)220@ASS_CLI_3.on_message(221 filters.command("unblock", prefixes=ASSISTANT_PREFIX)222 & filters.user(SUDOERS)223 & ~filters.via_bot224)225@ASS_CLI_4.on_message(226 filters.command("unblock", prefixes=ASSISTANT_PREFIX)227 & filters.user(SUDOERS)228 & ~filters.via_bot229)230@ASS_CLI_5.on_message(231 filters.command("unblock", prefixes=ASSISTANT_PREFIX)232 & filters.user(SUDOERS)233 & ~filters.via_bot234)235async def unblock_user_func(client, message):236 if not message.reply_to_message:237 return await eor(238 message, text="Reply to a user's message to unblock."239 )240 user_id = message.reply_to_message.from_user.id241 await client.unblock_user(user_id)242 await eor(message, text="Successfully Unblocked the user")243@ASS_CLI_1.on_message(244 filters.command("pfp", prefixes=ASSISTANT_PREFIX)245 & filters.user(SUDOERS)246 & ~filters.via_bot247)248@ASS_CLI_2.on_message(249 filters.command("pfp", prefixes=ASSISTANT_PREFIX)250 & filters.user(SUDOERS)251 & ~filters.via_bot252)253@ASS_CLI_3.on_message(254 filters.command("pfp", prefixes=ASSISTANT_PREFIX)255 & filters.user(SUDOERS)256 & ~filters.via_bot257)258@ASS_CLI_4.on_message(259 filters.command("pfp", prefixes=ASSISTANT_PREFIX)260 & filters.user(SUDOERS)261 & ~filters.via_bot262)263@ASS_CLI_5.on_message(264 filters.command("pfp", prefixes=ASSISTANT_PREFIX)265 & filters.user(SUDOERS)266 & ~filters.via_bot267)268async def set_pfp(client, message):269 if not message.reply_to_message or not message.reply_to_message.photo:270 return await eor(message, text="Reply to a photo.")271 photo = await message.reply_to_message.download()272 try:273 await client.set_profile_photo(photo=photo)274 await eor(message, text="Successfully Changed PFP.")275 except Exception as e:276 await eor(message, text=e)277@ASS_CLI_1.on_message(278 filters.command("bio", prefixes=ASSISTANT_PREFIX)279 & filters.user(SUDOERS)280 & ~filters.via_bot281)282@ASS_CLI_2.on_message(283 filters.command("bio", prefixes=ASSISTANT_PREFIX)284 & filters.user(SUDOERS)285 & ~filters.via_bot286)287@ASS_CLI_3.on_message(288 filters.command("bio", prefixes=ASSISTANT_PREFIX)289 & filters.user(SUDOERS)290 & ~filters.via_bot291)292@ASS_CLI_4.on_message(293 filters.command("bio", prefixes=ASSISTANT_PREFIX)294 & filters.user(SUDOERS)295 & ~filters.via_bot296)297@ASS_CLI_5.on_message(298 filters.command("bio", prefixes=ASSISTANT_PREFIX)299 & filters.user(SUDOERS)300 & ~filters.via_bot301)302async def set_bio(client, message):303 if len(message.command) == 1:304 return await eor(message, text="Give some text to set as bio.")305 elif len(message.command) > 1:306 bio = message.text.split(None, 1)[1]307 try:308 await client.update_profile(bio=bio)309 await eor(message, text="Changed Bio.")310 except Exception as e:311 await eor(message, text=e)...
main.py
Source:main.py
...14 api_hash=API_HASH,15)16REPOLINK = """ Source code: [Github](https://github.com/Moezilla/vc-userbot)17License: [ GPL-3.0 License](https://github.com/moezilla/vc-userbot/blob/master/LICENSE.md)"""18@app.on_message(filters.command("repo", PREFIX))19async def repo(_, message):20 await message.reply_text(REPOLINK)21@app.on_message(filters.command("smug", PREFIX))22def smug(_, message):23 smug = requests.get("https://nekos.life/api/v2/img/smug").json()24 smug = url.get("smug")25 message.reply_video(smug)26@app.on_message(filters.command("solog", PREFIX))27def solog(_, message):28 solog = requests.get("https://nekos.life/api/v2/img/solog").json()29 solog = url.get("solog")30 message.reply_video(solog)31@app.on_message(filters.command("neko", PREFIX))32def neko(_, message):33 neko = requests.get("https://nekos.life/api/v2/img/neko").json()34 neko = url.get("neko")35 message.reply_photo(neko)36@app.on_message(filters.command("feet", PREFIX))37def feet(_, message):38 feet = requests.get("https://nekos.life/api/v2/img/feet").json()39 feet = url.get("feet")40 message.reply_photo(feet)41@app.on_message(filters.command("yuri", PREFIX))42def yuri(_, message):43 yuri = requests.get("https://nekos.life/api/v2/img/yuri").json()44 yuri = url.get("yuri")45 message.reply_photo(yuri)46@app.on_message(filters.command("trap", PREFIX))47def trap(_, message):48 trap = requests.get("https://nekos.life/api/v2/img/trap").json()49 trap = url.get("trap")50 message.reply_photo(trap)51@app.on_message(filters.command("futanari", PREFIX))52def futanari(_, message):53 futanari = requests.get("https://nekos.life/api/v2/img/futanari").json()54 futanari = url.get("futanari")55 message.reply_photo(futanari)56@app.on_message(filters.command("hololewd", PREFIX))57def hololewd(_, message):58 hololewd = requests.get("https://nekos.life/api/v2/img/hololewd").json()59 hololewd = url.get("hololewd")60 message.reply_photo(hololewd)61@app.on_message(filters.command("lewdkemo", PREFIX))62def lewdkemo(_, message):63 lewdkemo = requests.get("https://nekos.life/api/v2/img/lewdkemo").json()64 lewdkemo = url.get("lewdkemo")65 message.reply_photo(lewdkemo)66@app.on_message(filters.command("sologif", PREFIX))67def solog(_, message):68 solog = requests.get("https://nekos.life/api/v2/img/solog").json()69 solog = url.get("solog")70 message.reply_video(solog)71@app.on_message(filters.command("feetgif", PREFIX))72def feetg(_, message):73 feetg = requests.get("https://nekos.life/api/v2/img/feetg").json()74 feetg = url.get("feetg")75 message.reply_video(feetg)76@app.on_message(filters.command("cumgif", PREFIX))77def cum(_, message):78 cum = requests.get("https://nekos.life/api/v2/img/cum").json()79 cum = url.get("cum")80 message.reply_video(cum)81@app.on_message(filters.command("erokemo", PREFIX))82def erokemo(_, message):83 erokemo = requests.get("https://nekos.life/api/v2/img/erokemo").json()84 erokemo = url.get("erokemo")85 message.reply_photo(erokemo)86@app.on_message(filters.command("les", PREFIX))87def les(_, message):88 les = requests.get("https://nekos.life/api/v2/img/les").json()89 les = url.get("les")90 message.reply_video(les)91@app.on_message(filters.command("wallpaper", PREFIX))92def wallpaper(_, message):93 wallpaper = requests.get("https://nekos.life/api/v2/img/wallpaper").json()94 wallpaper = url.get("wallpaper")95 message.reply_photo(wallpaper)96@app.on_message(filters.command("lewdk", PREFIX))97def lewdk(_, message):98 lewdk = requests.get("https://nekos.life/api/v2/img/lewdk").json()99 lewdk = url.get("lewdk")100 message.reply_photo(lewdk)101@app.on_message(filters.command("ngif", PREFIX))102def ngif(_, message):103 ngif = requests.get("https://nekos.life/api/v2/img/ngif").json()104 ngif = url.get("ngif")105 message.reply_video(ngif)106@app.on_message(filters.command("tickle", PREFIX))107def tickle(_, message):108 tickle = requests.get("https://nekos.life/api/v2/img/tickle").json()109 tickle = url.get("tickle")110 message.reply_video(tickle)111@app.on_message(filters.command("lewd", PREFIX))112def lewd(_, message):113 lewd = requests.get("https://nekos.life/api/v2/img/lewd").json()114 lewd = url.get("lewd")115 message.reply_photo(lewd)116@app.on_message(filters.command("feed", PREFIX))117def feed(_, message):118 feed = requests.get("https://nekos.life/api/v2/img/feed").json()119 feed = url.get("feed")120 message.reply_video(feed)121@app.on_message(filters.command("eroyuri", PREFIX))122def eroyuri(_, message):123 eroyuri = requests.get("https://nekos.life/api/v2/img/eroyuri").json()124 eroyuri = url.get("eroyuri")125 message.reply_photo(eroyuri)126@app.on_message(filters.command("eron", PREFIX))127def eron(_, message):128 eron = requests.get("https://nekos.life/api/v2/img/eron").json()129 eron = url.get("eron")130 message.reply_photo(eron)131@app.on_message(filters.command("cum", PREFIX))132def cumjpg(_, message):133 cum_jpg = requests.get("https://nekos.life/api/v2/img/cum_jpg").json()134 cum_jpg = url.get("cum_jpg")135 message.reply_photo(cum_jpg)136@app.on_message(filters.command("bjgif", PREFIX))137def bj(_, message):138 bj = requests.get("https://nekos.life/api/v2/img/bj").json()139 bj = url.get("bj")140 message.reply_video(bj)141@app.on_message(filters.command("blowjob", PREFIX))142def blowjob(_, message):143 blowjob = requests.get("https://nekos.life/api/v2/img/blowjob").json()144 blowjob = url.get("blowjob")145 message.reply_photo(blowjob)146@app.on_message(filters.command("nekogif", PREFIX))147def nekogif(_, message):148 nsfw_neko_gif = requests.get("https://nekos.life/api/v2/img/nsfw_neko_gif").json()149 nsfw_neko_gif = url.get("nsfw_neko_gif")...
dragon_bot.py
Source:dragon_bot.py
...3@client.event4async def on_ready():5 print('we have logged in as {0.user}'.format(client))6@client.event7async def on_message(message):8 if message.author == client.user:9 return10 if message.content.startswith('ping'):11 await message.channel.send('pong')12@client.event13async def on_message(message):14 if message.content.startswith('?thumb')15 channel = message.channel16 await channel.send('send me that ð reaction pls!')17 def check(reaction, user):18 return user == message.author and str(reaction.emoji) == 'ð'19 try:20 reaction, user = await client.wait_for('reaction_add', timeout= 60.0, check=check)21 except asyncio.TimeoutError:22 await channel.send('ð')23 else:24 await channel.send('ð')25@client.event26async def on_message(message):27 if message.content.startswith('?live')28 channel = message.channel29 await channel.send('@everyone come watch me live now at https://www.twitch.tv/talleyho1')30@client.event31async def on_message(message):32 if message.content.startswith('?commands')33 channel = message.channel34 await channel.send('COMMANDS \n ?thumb, for attendance or something \n ?live, for talleyho1s twitch \n ?emojis, shows the servers emojis \n ?help, shows the commands command \n poke, poke')35@client.event36async def on_message(message):37 if message.content.startswith('?emojis')38 channel = message.channel39 await channel.send(List[emojis])40@client.event41async def on_message(message):42 if message.content.startswith('?help')43 channel = message.channel44 await channel.send('type ?commands for a list of commands')45@client.event46async def on_message(message):47 if message.content.startswith('pong')48 channel = message.channel49 await channel.send('ping')50@client.event51async def on_message(message):52 if message.content.startswith('whats ur favorite game')53 channel = message.channel54 await message.send('idk ask master white')55@client.event56async def on_message(message):57 if message.content.startswith('poke')58 channel = message.channel59 await message.send('poke')60@client.event61async def on_message(message):62 if message.content.startswith('humpty dumpty') 63 channel = message.channel64 await message.send('sat on a wall')65@client.event66async def on_message(message):67 if message.content.startswith('?info')68 channel = message.channel69 await message.channel...
Automation Testing Tutorials
Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.
LambdaTest Learning Hubs:
- JUnit Tutorial
- TestNG Tutorial
- Webdriver Tutorial
- WebDriverIO Tutorial
- Protractor Tutorial
- Selenium 4 Tutorial
- Jenkins Tutorial
- NUnit Tutorial
- Jest Tutorial
- Playwright Tutorial
- Cypress Tutorial
- PyTest Tutorial
YouTube
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Run ATX automation tests on LambdaTest cloud grid
Perform automation testing on 3000+ real desktop and mobile devices online.
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
