SubGram API

// --- Файл: subgramApi.js ---
const axios = require('axios');

const API_KEY = 'ВАШ_API_КЛЮЧ_БОТА';
const URL = 'https://api.subgram.org/get-sponsors';
const BLOCKING_SUBGRAM_STATUSES = ["warning", "gender", "age", "register"];

async function getSubgramSponsors(userId, chatId, options = {}) {
  const headers = { 
      'Auth': API_KEY,
      'Content-Type': 'application/json'
  };
  const payload = { user_id: userId, chat_id: chatId, ...options };
  
  try {
    const response = await axios.post(URL, payload, { headers, timeout: 10000 });
    return response.data;
  } catch (error) {
    console.error('Ошибка запроса к SubGram API:', error.response?.data || error.message);
    return null;
  }
}
module.exports = { getSubgramSponsors, BLOCKING_SUBGRAM_STATUSES };


// --- Файл: bot.js (пример с node-telegram-bot-api) ---
// const TelegramBot = require('node-telegram-bot-api');
// const token = 'ВАШ_ТЕЛЕГРАМ_ТОКЕН';
// const bot = new TelegramBot(token, { polling: true });
// const { getSubgramSponsors, BLOCKING_SUBGRAM_STATUSES } = require('./subgramApi');

bot.onText(/\/start/, async (msg) => {
    // Вызываем функцию для проверки подписки
    const response = await getSubgramSponsors(
        msg.from.id,
        msg.chat.id
    );

    if (!response) {
        console.error("Ошибка запроса к SubGram API: Не удалось осуществить запрос");
        // Если API недоступен, выдаем доступ, чтобы не терять пользователя
        await bot.sendMessage(msg.chat.id, "✅ Доступ предоставлен.");
        return;
    }

    const status = response.status;

    if (status && BLOCKING_SUBGRAM_STATUSES.includes(status)) {
        //Если бот добавлен по токену и "Получать ссылки в API" - Выкл, SubGram самостоятельно отправит сообщение
        //Вам как владельцу бота делать ничего не нужно
    } else {
        if (status && status === "error") {
            console.warn(`Ошибка SubGram API: ${response.message}. Предоставляем доступ.`);
        }
        await bot.sendMessage(msg.chat.id, "✅ Доступ предоставлен!");
        // ... ваш код для выдачи контента ...
    }
});

bot.on('callback_query', async (callbackQuery) => {
    if (!callbackQuery.data.startsWith('subgram')) {
        return;
    }

    const userId = callbackQuery.from.id;
    const chatId = callbackQuery.message.chat.id;
    const callbackData = callbackQuery.data;

    const api_kwargs = {};
    
    if (callbackData === "subgram-op") {
        await bot.answerCallbackQuery(callbackQuery.id, { text: "⏳ Проверяем подписки..." });
    } else if (callbackData.startsWith("subgram_")) {
        // Универсальная обработка для пола и возраста
        const parts = callbackData.split("_");
        const param_type = parts[1]; // 'gender' или 'age'
        const param_value = parts[2]; // 'male', 'c1', и т.д.
        api_kwargs[param_type] = param_value;
    }

    // Отправляем повторный запрос в SubGram API с новыми данными
    const response = await getSubgramSponsors(userId, chatId, api_kwargs);

    // Логика доступа АНАЛОГИЧНА основной
    if (!response) {
        console.error("Ошибка запроса к SubGram API: Не удалось осуществить запрос");
        await bot.sendMessage(chatId, "✅ Доступ предоставлен.");
        return;
    }
    
    const status = response.status;

    if (status && BLOCKING_SUBGRAM_STATUSES.includes(status)) {
        //Если бот добавлен по токену и "Получать ссылки в API" - Выкл, SubGram самостоятельно отправит сообщение, Вам как владельцу бота делать ничего не нужно
    } else {
        if (status && status === "error") {
             console.warn(`Ошибка SubGram API: ${response.message}. Предоставляем доступ.`);
        }
        await bot.sendMessage(chatId, "✅ Доступ предоставлен!");
        // ... ваш код для выдачи контента ...
    }
});
                        

<?php
// --- Файл: subgram_api.php ---
const API_KEY = "ВАШ_API_КЛЮЧ_БОТА";
const URL = "https://api.subgram.org/get-sponsors";
const BLOCKING_SUBGRAM_STATUSES = ["warning", "gender", "age", "register"];

function getSubgramSponsors($userId, $chatId, $options = []) {
    $payload = ['user_id' => $userId, 'chat_id' => $chatId];
    $payload = array_merge($payload, $options);
    
    $headers = [
        'Auth: ' . API_KEY,
        'Content-Type: application/json'
    ];
    
    $ch = curl_init(URL);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($ch, CURLOPT_TIMEOUT, 10);
    
    $response_body = curl_exec($ch);
    $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    if ($response_body === false) {
        error_log("Ошибка запроса к SubGram API: cURL error");
        return null;
    }
    
    return json_decode($response_body, true);
}

// --- Файл: bot.php (пример обработчика вебхука) ---
// require_once 'subgram_api.php';
// ... (здесь должны быть ваши функции для отправки запросов к Telegram API, например, sendMessage, answerCallbackQuery) ...

$update = json_decode(file_get_contents('php://input'), true);

if (isset($update['message'])) {
    $userId = $update['message']['from']['id'];
    $chatId = $update['message']['chat']['id'];

    // Вызываем функцию для проверки подписки
    $response = getSubgramSponsors($userId, $chatId);

    if ($response === null) {
        error_log("Ошибка запроса к SubGram API: Не удалось осуществить запрос");
        // Если API недоступен, выдаем доступ, чтобы не терять пользователя
        sendMessage($chatId, "✅ Доступ предоставлен.");
        exit();
    }
    
    $status = $response['status'] ?? null;
    
    if ($status && in_array($status, BLOCKING_SUBGRAM_STATUSES)) {
        //Если бот добавлен по токену и "Получать ссылки в API" - Выкл, SubGram самостоятельно отправит сообщение
        //Вам как владельцу бота делать ничего не нужно
    } else {
        if ($status && $status === "error") {
            error_log("Ошибка SubGram API: " . $response['message'] . ". Предоставляем доступ.");
        }
        sendMessage($chatId, "✅ Доступ предоставлен!");
        // ... ваш код для выдачи контента ...
    }

} elseif (isset($update['callback_query'])) {
    $callback = $update['callback_query'];
    $data = $callback['data'];

    if (strpos($data, 'subgram') === 0) {
        $userId = $callback['from']['id'];
        $chatId = $callback['message']['chat']['id'];
        
        $api_kwargs = [];

        if ($data === "subgram-op") {
            answerCallbackQuery($callback['id'], ['text' => '⏳ Проверяем подписки...']);
        } elseif (strpos($data, 'subgram_') === 0) {
            // Универсальная обработка для пола и возраста
            $parts = explode('_', $data);
            $param_type = $parts[1]; // 'gender' или 'age'
            $param_value = $parts[2]; // 'male', 'c1', и т.д.
            $api_kwargs[$param_type] = $param_value;
        }

        // Отправляем повторный запрос в SubGram API с новыми данными
        $response = getSubgramSponsors($userId, $chatId, $api_kwargs);
        
        // Логика доступа АНАЛОГИЧНА основной
        if ($response === null) {
             error_log("Ошибка запроса к SubGram API: Не удалось осуществить запрос");
             sendMessage($chatId, "✅ Доступ предоставлен.");
             exit();
        }

        $status = $response['status'] ?? null;

        if ($status && in_array($status, BLOCKING_SUBGRAM_STATUSES)) {
            //Если бот добавлен по токену и "Получать ссылки в API" - Выкл, SubGram самостоятельно отправит сообщение, Вам как владельцу бота делать ничего не нужно
        } else {
            if ($status && $status === "error") {
                 error_log("Ошибка SubGram API: " . $response['message'] . ". Предоставляем доступ.");
            }
            sendMessage($chatId, "✅ Доступ предоставлен!");
            // ... ваш код для выдачи контента ...
        }
    }
}
?>
                        

// --- Файл: subgramApi.js ---
const axios = require('axios');

const API_KEY = 'ВАШ_API_КЛЮЧ_БОТА';
const URL = 'https://api.subgram.org/get-sponsors';

async function getSubgramSponsors(userId, chatId, options = {}) {
  const headers = { 
      'Auth': API_KEY,
      'Content-Type': 'application/json'
  };
  const payload = { user_id: userId, chat_id: chatId, ...options };
  
  try {
    const response = await axios.post(URL, payload, { headers, timeout: 10000 });
    return response.data;
  } catch (error) {
    console.error('Ошибка запроса к SubGram API:', error.response?.data || error.message);
    return null;
  }
}
module.exports = { getSubgramSponsors };


// --- Файл: bot.js (пример с node-telegram-bot-api) ---
// const TelegramBot = require('node-telegram-bot-api');
// const token = 'ВАШ_ТЕЛЕГРАМ_ТОКЕН';
// const bot = new TelegramBot(token, { polling: true });
// const { getSubgramSponsors } = require('./subgramApi');

/**
 * Основная функция для обработки всех статусов от SubGram.
 * @returns {Promise} Возвращает true, если нужно дать доступ, иначе false.
 */
async function processSubgramCheck(user, chatId, apiOptions = {}) {
    // 1. Передаем больше данных о пользователе, если не передавали токен.
    const userData = {
        "first_name": user.first_name,
        "username": user.username,
        "language_code": user.language_code,
        "is_premium": !!user.is_premium
    };
    Object.assign(userData, apiOptions);

    const response = await getSubgramSponsors(user.id, chatId, userData);

    if (!response) {
        return true; // Дать доступ при ошибке API
    }

    const status = response.status;
    let text = "";
    const inline_keyboard = [];

    if (status === "warning") {
        text = "Пожалуйста, выполните задания ниже:";
        const sponsors = response.additional?.sponsors || [];
        // 2. Показываем только тех, на кого надо подписаться
        sponsors.forEach(sponsor => {
            if (sponsor.available_now && sponsor.status === "unsubscribed") {
                inline_keyboard.push([{ text: sponsor.button_text || "Подписаться", url: sponsor.link }]);
            }
        });
        inline_keyboard.push([{ text: "✅ Я выполнил", callback_data: "subgram-op" }]);

    } else if (status === "gender") {
        // 3. Обработка вопроса о поле
        text = "Укажите ваш пол:";
        inline_keyboard.push([
            { text: "Мужской", callback_data: "subgram_gender_male" },
            { text: "Женский", callback_data: "subgram_gender_female" }
        ]);

    } else if (status === "age") {
        // 3. Обработка вопроса о возрасте
        text = "Укажите ваш возраст:";
        const age_categories = {"c1": "Младше 10", "c2": "11-13", "c3": "14-15", "c4": "16-17", "c5": "18-24", "c6": "25 и старше"};
        // Группируем по 2 кнопки в ряд
        const rows = [];
        const keys = Object.keys(age_categories);
        for (let i = 0; i < keys.length; i += 2) {
            const row = [];
            row.push({ text: age_categories[keys[i]], callback_data: `subgram_age_${keys[i]}`});
            if (keys[i+1]) {
                row.push({ text: age_categories[keys[i+1]], callback_data: `subgram_age_${keys[i+1]}`});
            }
            rows.push(row);
        }
        inline_keyboard.push(...rows);

    } else if (status === "register") {
        // 4. Обработка анкеты
        text = "Для продолжения, пожалуйста, пройдите быструю регистрацию.";
        const reg_url = response.additional?.registration_url;
        if (reg_url) {
            inline_keyboard.push([{ text: "✅ Пройти регистрацию", web_app: { url: reg_url } }]);
            inline_keyboard.push([{ text: "Продолжить", callback_data: "subgram-op" }]);
        } else {
            return true; // Дать доступ, если URL не пришел
        }
    
    } else { // error или неизвестный статус
        return true; // Дать доступ
    }

    await bot.sendMessage(chatId, text, { reply_markup: { inline_keyboard } });
    return false; // Не давать доступ, т.к. отправили сообщение с заданием
}


bot.onText(/\/start/, async (msg) => {
    const shouldGrantAccess = await processSubgramCheck(msg.from, msg.chat.id);
    if (shouldGrantAccess) {
        // Даем доступ
        await bot.sendMessage(msg.chat.id, "✅ Доступ предоставлен!");
        // ... ваш основной код ...
    }
});

bot.on('callback_query', async (callbackQuery) => {
    if (!callbackQuery.data.startsWith("subgram")) {
        return;
    }

    // 5. Удаляем старое сообщение
    bot.deleteMessage(callbackQuery.message.chat.id, callbackQuery.message.message_id)
        .catch(err => console.log("Не удалось удалить сообщение (возможно, уже удалено)"));

    const api_kwargs = {};
    const data = callbackQuery.data;

    // 6. Парсим callback_data
    if (data.startsWith("subgram_gender_")) {
        api_kwargs["gender"] = data.split("_")[2];
    } else if (data.startsWith("subgram_age_")) {
        api_kwargs["age"] = data.split("_")[2];
    }
    // Для subgram-op (Я выполнил/Продолжить) api_kwargs остается пустым

    await bot.answerCallbackQuery(callbackQuery.id);
    const shouldGrantAccess = await processSubgramCheck(callbackQuery.from, callbackQuery.message.chat.id, api_kwargs);

    if (shouldGrantAccess) {
        // Даем доступ
        await bot.sendMessage(callbackQuery.message.chat.id, "✅ Доступ предоставлен!");
        // ... ваш основной код ...
    }
});
                        

<?php
// --- Файл: subgram_api.php ---
const API_KEY = "ВАШ_API_КЛЮЧ_БОТА";
const URL = "https://api.subgram.org/get-sponsors";

function getSubgramSponsors($userId, $chatId, $options = []) {
    $payload = ['user_id' => $userId, 'chat_id' => $chatId];
    $payload = array_merge($payload, $options);
    
    $headers = [
        'Auth: ' . API_KEY,
        'Content-Type: application/json'
    ];
    
    $ch = curl_init(URL);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($ch, CURLOPT_TIMEOUT, 10);
    
    $response_body = curl_exec($ch);
    curl_close($ch);
    
    if ($response_body === false) {
        error_log("Ошибка запроса к SubGram API: cURL error");
        return null;
    }
    
    return json_decode($response_body, true);
}


// --- Файл: bot.php (пример обработчика вебхука) ---
// require_once 'subgram_api.php';
// ... (здесь должны быть ваши функции для отправки запросов к Telegram API, например, sendMessage, deleteMessage, answerCallbackQuery) ...

/**
 * Основная функция для обработки всех статусов от SubGram.
 * @return bool Возвращает true, если нужно дать доступ, иначе false.
 */
function processSubgramCheck($user, $chatId, $apiOptions = []) {
    // 1. Передаем больше данных о пользователе, если не передавали токен.
    $userData = [
        "first_name" => $user['first_name'],
        "username" => $user['username'] ?? null,
        "language_code" => $user['language_code'] ?? null,
        "is_premium" => !empty($user['is_premium'])
    ];
    $userData = array_merge($userData, $apiOptions);
    
    $response = getSubgramSponsors($user['id'], $chatId, $userData);

    if ($response === null) {
        return true; // Дать доступ при ошибке API
    }

    $status = $response['status'] ?? null;
    $keyboard = [];
    $text = "";

    if ($status === "warning") {
        $text = "Пожалуйста, выполните задания ниже:";
        $sponsors = $response['additional']['sponsors'] ?? [];
        // 2. Показываем только тех, на кого надо подписаться
        foreach ($sponsors as $sponsor) {
            if (!empty($sponsor['available_now']) && $sponsor['status'] === "unsubscribed") {
                $keyboard[] = [['text' => $sponsor['button_text'] ?? "Подписаться", 'url' => $sponsor['link']]];
            }
        }
        $keyboard[] = [['text' => "✅ Я выполнил", 'callback_data' => "subgram-op"]];
    
    } elseif ($status === "gender") {
        // 3. Обработка вопроса о поле
        $text = "Укажите ваш пол:";
        $keyboard[] = [
            ['text' => "Мужской", 'callback_data' => "subgram_gender_male"],
            ['text' => "Женский", 'callback_data' => "subgram_gender_female"]
        ];

    } elseif ($status === "age") {
        // 3. Обработка вопроса о возрасте
        $text = "Укажите ваш возраст:";
        $age_categories = ["c1" => "Младше 10", "c2" => "11-13", "c3" => "14-15", "c4" => "16-17", "c5" => "18-24", "c6" => "25 и старше"];
        $row = [];
        foreach ($age_categories as $code => $age_text) {
            $row[] = ['text' => $age_text, 'callback_data' => "subgram_age_{$code}"];
            if (count($row) == 2) {
                $keyboard[] = $row;
                $row = [];
            }
        }
        if (!empty($row)) {
            $keyboard[] = $row;
        }

    } elseif ($status === "register") {
        // 4. Обработка анкеты
        $text = "Для продолжения, пожалуйста, пройдите быструю регистрацию.";
        $reg_url = $response['additional']['registration_url'] ?? null;
        if ($reg_url) {
            $keyboard[] = [['text' => "✅ Пройти регистрацию", 'web_app' => ['url' => $reg_url]]];
            $keyboard[] = [['text' => "Продолжить", 'callback_data' => "subgram-op"]];
        } else {
            return true; // Дать доступ, если URL не пришел
        }
    
    } else { // error или неизвестный статус
        return true; // Дать доступ
    }

    sendMessage($chatId, $text, json_encode(['inline_keyboard' => $keyboard]));
    return false; // Не давать доступ, т.к. отправили сообщение с заданием
}


$update = json_decode(file_get_contents('php://input'), true);

if (isset($update['message'])) {
    $shouldGrantAccess = processSubgramCheck($update['message']['from'], $update['message']['chat']['id']);
    if ($shouldGrantAccess) {
        // Даем доступ
        sendMessage($update['message']['chat']['id'], "✅ Доступ предоставлен!");
        // ... ваш основной код ...
    }
} elseif (isset($update['callback_query'])) {
    $callback = $update['callback_query'];
    $data = $callback['data'];

    if (strpos($data, "subgram") === 0) {
        // 5. Удаляем старое сообщение
        deleteMessage($callback['message']['chat']['id'], $callback['message']['message_id']);

        $api_kwargs = [];
        // 6. Парсим callback_data
        if (strpos($data, "subgram_gender_") === 0) {
            $api_kwargs["gender"] = explode("_", $data)[2];
        } elseif (strpos($data, "subgram_age_") === 0) {
            $api_kwargs["age"] = explode("_", $data)[2];
        }
        // Для subgram-op (Я выполнил/Продолжить) api_kwargs остается пустым

        answerCallbackQuery($callback['id']);
        $shouldGrantAccess = processSubgramCheck($callback['from'], $callback['message']['chat']['id'], $api_kwargs);

        if ($shouldGrantAccess) {
            // Даем доступ
            sendMessage($callback['message']['chat']['id'], "✅ Доступ предоставлен!");
            // ... ваш основной код ...
        }
    }
}
?>