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.