Untitled

@bot.on_message(filters.command("upload", prefixes=["/", ".", "?", "-"])& filters.reply)
async def go(bot, message):
    picid = message.reply_to_message.photo.file_id
    picBy = message.reply_to_message.from_user.username
    admin = message.from_user.id
    alw = shiro.find_one({"user": admin})
    if alw:
        hPic = {"Husbando_Pic": picid, "uploaded_By": picBy, "findv": 33}
        uploder.insert_one(hPic)
        await message.reply_text("done")


@bot.on_message(filters.command("download", prefixes=["/", ".", "?", "-"]))
async def get(bot, message):
    getp = pika.shiro.aggregate({ $sample: { size: 1} })
    await message.reply_photo(photo=f"{getp}")