Документация

https://flowly.guru/api/v1

Auth: YOUR_BOT_API_KEY

{"tg_user_id": 12344566, "lang": "ru", "is_premium": false, "offers_limit": 3}

{
  "status": "not_ok",
  "offers": [{
    "offer_id": 7,
    "name": "Название канала",
    "price": "0.80",
    "link": "https://t.me/example",
    "type": "channel",
    "channel_id": "-1001234567890",
    "subscribed": false
  }],
  "description": "Subscription required"
}

{"tg_user_id": 12344566, "offer_id": 7}

{"status": "subscribed"}

{"tg_user_id": 12344566}

{"balance": "120.00", "earned_by_bot": "48.00", "currency": "RUB"}

{"date": "2026-10-05", "subs_count": 12, "income": "9.60", "currency": "RUB"}

{
  "event_id": "уникальный-id-события",
  "tg_user_id": 12344566,
  "link": "https://t.me/example",
  "status": "subscribed",
  "reason": "subscribed",
  "occurred_at": "2026-10-05T12:00:00+03:00"
}

import hashlib
import hmac
import os

body = await request.read()
secret = os.environ["FLOWLY_WEBHOOK_SECRET"].encode()
expected = "sha256=" + hmac.new(secret, body, hashlib.sha256).hexdigest()
received = request.headers.get("X-Flowly-Signature", "")
if not hmac.compare_digest(received, expected):
    raise PermissionError("Неверная подпись")

pip install aiogram aiohttp

import asyncio
import os
import aiohttp
from aiogram import Bot, Dispatcher, F
from aiogram.filters import CommandStart
from aiogram.types import InlineKeyboardButton, InlineKeyboardMarkup

dp = Dispatcher()

async def offers(user):
    async with http.post(
        "https://flowly.guru/api/v1/offers",
        headers={"Auth": os.environ["FLOWLY_API_KEY"]},
        json={"tg_user_id": user.id,
              "lang": user.language_code or "ru",
              "is_premium": bool(user.is_premium)},
    ) as response:
        if response.status != 200:
            raise RuntimeError("Проверка временно недоступна")
        return await response.json()

def buttons(result):
    rows = [[InlineKeyboardButton(text=item["name"], url=item["link"])]
            for item in result.get("offers", [])
            if not item.get("subscribed")]
    rows.append([InlineKeyboardButton(text="Проверить выполнение", callback_data="check")])
    return InlineKeyboardMarkup(inline_keyboard=rows)

@dp.message(CommandStart())
async def start(message):
    try:
        result = await offers(message.from_user)
    except (RuntimeError, aiohttp.ClientError, asyncio.TimeoutError):
        await message.answer("Не получилось получить задания. Попробуйте чуть позже.")
        return
    if result["status"] == "ok":
        await message.answer("Задания уже выполнены!")
    elif result["status"] == "no_offers":
        await message.answer("Сейчас заданий нет. Загляните позже.")
    else:
        await message.answer("Выполните задания ниже, затем нажмите «Проверить выполнение».",
                             reply_markup=buttons(result))

@dp.callback_query(F.data == "check")
async def check(callback):
    await callback.answer()
    try:
        result = await offers(callback.from_user)
    except (RuntimeError, aiohttp.ClientError, asyncio.TimeoutError):
        await callback.message.answer("Не удалось проверить. Попробуйте ещё раз позже.")
        return
    if result["status"] == "ok":
        # Здесь начислите награду в своей БД только один раз.
        await callback.message.edit_text("Готово! Здесь пользователь получит свою награду 🎉")
    elif result["status"] == "no_offers":
        await callback.message.edit_text("Сейчас подходящих заданий нет.")
    else:
        await callback.message.answer("Остались невыполненные задания.", reply_markup=buttons(result))

async def main():
    global http
    async with aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=15)) as http:
        async with Bot(os.environ["BOT_TOKEN"]) as bot:
            await dp.start_polling(bot)

if __name__ == "__main__":
    asyncio.run(main())