Add balance to user account 💸

const ADMIN_ID = process.env.ADMIN_ID;

  if (flex.user.id != ADMIN_ID) return;
  await sendMessage("*Enter your user id 🆔*", "MARKDOWN");
  await waitForAnswer("/getId");

const ADMIN_ID = process.env.ADMIN_ID;
  if (flex.user.id != ADMIN_ID) return;
  await USER.setProperty("id", flex.message);
  await sendMessage("*Enter your balance 💸*", "MARKDOWN");
  await waitForAnswer("/getBal");

  const ADMIN_ID = process.env.ADMIN_ID;
  const id = await USER.getProperty("id");
  const btn = [
    [
      {
        text: "Claim Reward 🎉",
        callback_data: /claimBal ${id} ${flex.message} ,
      },
    ],
  ];
  if (flex.user.id != ADMIN_ID) return;

  await BOT.sendMessage(
    id,
    "*🎉 Congratulation you have get points from admin*\n\nClick following button to claim reward!!",
    "MARKDOWN",
    btn,
  );
  await sendMessage(*Point add request sended to *${id} ✅, "MARKDOWN");
  await USER.deleteProperty("id");
  await clearWait();

  const parts = flex.params.split(" ");
  const id = parts[0];
  const amount = parseFloat(parts[1]);
  if (flex.user.id != id) return;
  if (!isCallback) return;
  await FLEX.setProperty("balance", amount);
  await answerCallback("Balance added successfully ✅", true);

⚠️ Note: add your user id in .env file like ADMIN_ID=1234567890

✨ What's New

🔹 Smart Property Operations
getProp() and setProp() on BOT, USER, TEMP, and FLEX now support .add() and .remove().

• Numbers → add / subtract
• Strings → append / remove
• Arrays → push / filter

No more manual read-modify-write operations.

🔹 Flexible Options Object
chat_id and other options can now be placed anywhere inside the options object for all BOT and API methods.

BOT.sendMessage("Hello", { parse_mode: "HTML", chat_id: 123 })

API.sendMessage({ text: "Hello", chat_id: 123 })

No fixed parameter order required.

🔹 No More await
BOT, USER, TEMP, FLEX, API, and HTTP methods now handle promises automatically and log errors internally.

BOT.sendMessage("Hello")
Less code. Same result.

❤️ Thank you for supporting FlexGram

📢 YouTube Channel Update

⚠️ Note: Subscribe Backup Channel: https://youtube.com/@flecdev

⚠️ Note: Subscribe Backup Channel: https://youtube.com/@flecdev

⚠️ Note: Subscribe Backup Channel: https://youtube.com/@flecdev

Drop your suggestions in the comments. I'm looking for new video ideas, so let me know what you'd like to learn, see, or explore next 👇

sendMessage("How would you rate our service today?", {
  buttons: [
    [
      { text: "⭐ 1", command: "/rate 1" },
      { text: "⭐ 2", command: "/rate 2" },
      { text: "⭐ 3", command: "/rate 3" },
      { text: "⭐ 4", command: "/rate 4" },
      { text: "⭐ 5", command: "/rate 5" }
    ]
  ]
})

TEMP.setProp("rating", params)
sendMessage("Awesome! Now, please type a short comment about your experience:")
waitForAnswer("save")

const rating = await TEMP.getProp("rating").value()
USER.setProp("last_rating", rating)
USER.setProp("last_comment", message)
sendMessage("Thank you! Your feedback has been saved securely.")
clearWait()

⚠️ Note: Make sure your FIREBASE_URL and FIREBASE_SECRET environment variables are configured so the persistent feedback data is successfully saved to your database.

if (!params) return sendMessage("Provide a URL: `/monitor https://myapi.com`", { parse_mode: "Markdown" });
USER.setProp("url", params);
sendMessage(`Now tracking \`${params}\`. Click below to run a test.`, {
  buttons: [{ text: "Check Status ⚡", command: "/status" }],
  parse_mode: "Markdown"
});

const url = await USER.getProp("url").value();
if (!url) return sendMessage("Set a URL first: `/monitor <url>`", { parse_mode: "Markdown" });
sendChatAction("typing");
const ok = await HTTP.get({ url }).then(() => true).catch(() => false);
const text = `*Uptime Monitor*\n\nURL: \`${url}\`\nStatus: ${ok ? "✅ *ONLINE*" : "🚨 *OFFLINE*"}`;
const btns = [{ text: "🔄 Refresh Status", command: "/status" }];
if (isCallback) {
  answerCallback(ok ? "Systems nominal!" : "Server unreachable!", !ok);
  editCallbackMessage(text, btns, message_id);
} else {
  sendMessage(text, { buttons: btns, parse_mode: "Markdown" });
}

⚠️ Note: Ensure your target URLs include the full protocol like https:// to prevent HTTP client errors.

const r1 = await BOT.getProp("room1").value() || "Free";
const r2 = await BOT.getProp("room2").value() || "Free";
sendMessage("Quiet Room Bookings:\n\nRoom 1: " + r1 + "\nRoom 2: " + r2, {
  buttons: [
    [{ text: r1 === "Free" ? "🟢 Book Room 1" : "🔴 Vacate Room 1", command: "/book 1" }],
    [{ text: r2 === "Free" ? "🟢 Book Room 2" : "🔴 Vacate Room 2", command: "/book 2" }]
  ]
});

const roomKey = "room" + params;
const current = await BOT.getProp(roomKey).value() || "Free";
const nextState = current === "Free" ? user.first_name : "Free";
BOT.setProp(roomKey, nextState);
answerCallback("Room " + params + " updated!");
const r1 = await BOT.getProp("room1").value() || "Free";
const r2 = await BOT.getProp("room2").value() || "Free";
editCallbackMessage("Quiet Room Bookings:\n\nRoom 1: " + r1 + "\nRoom 2: " + r2, [
  [{ text: r1 === "Free" ? "🟢 Book Room 1" : "🔴 Vacate Room 1", command: "/book 1" }],
  [{ text: r2 === "Free" ? "🟢 Book Room 2" : "🔴 Vacate Room 2", command: "/book 2" }]
], message_id);

⚠️ Note: Make sure your FIREBASE_URL and FIREBASE_SECRET environment variables are configured so the bot can persist the global room state across restarts.

if (!inlineQuery) return;
const res = await HTTP.get({ url: `https://registry.npmjs.org/${encodeURIComponent(inlineQuery)}` });
if (res && res.name) {
  API.answerInlineQuery({
    inline_query_id: inlineQueryId,
    results: [{
      type: "article", id: res.name, title: res.name, description: res.description,
      input_message_content: { message_text: `*${res.name}*\n${res.description || ""}\nhttps://www.npmjs.com/package/${res.name}`, parse_mode: "Markdown" }
    }]
  });
}

if (!params) return sendMessage("Send package name");
sendChatAction("typing");
const res = await HTTP.get({ url: `https://registry.npmjs.org/${encodeURIComponent(params)}` });
if (!res || !res.name) return sendMessage("Not found");
sendMessage(`*${res.name}*\n${res.description || ""}\nhttps://www.npmjs.com/package/${res.name}`, { parse_mode: "Markdown" });

⚠️ Note: Remember to message @BotFather and send the /setinline command to enable inline mode for your bot before testing.

const { setDB } = require('../core/firebase');
setDB(`subscribers/${user.id}`, true);
sendMessage('Welcome to the Bakery Alerts VIP club! 🥐 You will get notified the moment hot pastries are ready.');

const { getDB } = require('../core/firebase');
if (user.id !== parseInt(process.env.ADMIN_ID)) return sendMessage('Unauthorized access.');
const subs = await getDB('subscribers') || {};
const ids = Object.keys(subs);
const res = await broadcast(ids, '🥐 *Warm pastries ready right now!* Get 30% off for the next 45 minutes.', [{ text: 'Get Code', command: '/claim' }], 100);
sendMessage(`Broadcast complete! Sent: ${res.sent}, Failed: ${res.failed}`);

sendMessage('Show this code at the register to claim your 30% discount:\n\n*BAKERYVIP30*');

⚠️ Note: You must add your Telegram user ID as the ADMIN_ID environment variable so only authorized staff can trigger the alerts.

Comment Down 👇

const prompt = "<b>Issue Reporter</b>\n\nPlease send a headline for the bug:";
sendMessage(prompt);
waitForAnswer("get_desc");

TEMP.setProp("bug_title", message);
sendMessage("Got it. Now reply with full details or steps to reproduce:");
waitForAnswer("finish_report");

const title = await TEMP.getProp("bug_title").value();
pushDB("bugs", { userId: user.id, title, desc: message });
TEMP.deleteProp("bug_title");
clearWait();
sendMessage("<b>Report logged!</b> Our team will review it shortly.");

sendChatAction("typing");
let current = await BOT.getProp("build_status").value() || "Ready";
sendMessage(`*Staging Control Panel*\nCurrent Status: *${current}*`, {
  buttons: [
    [{ text: "🚀 Deploy Staging", command: "/run_deploy" }],
    [{ text: "🔄 Check Status", command: "/staging" }]
  ]
});

if (isCallback) {
  await answerCallback("Initiating deploy sequence...", true);
  await BOT.setProp("build_status", "Deploying...");
  let res = await HTTP.post({
    url: "https://api.github.com/repos/acme/app/dispatches",
    body: { event_type: "deploy" }
  });
  let result = res ? "Deployed" : "Failed";
  await BOT.setProp("build_status", result);
  editCallbackMessage(`*Staging Control Panel*\nCurrent Status: *${result}*`, [
    [{ text: "🔄 Refresh Status", command: "/staging" }]
  ], message_id);
}

⚠️ Note: Replace the target URL in HTTP.post with your CI/CD pipeline or GitHub action dispatch webhook.

if (!params[0]) return sendMessage("Usage: /setbase USD");
let code = params[0].toUpperCase();
USER.setProperty("base", code);
sendMessage(`Base currency updated to *${code}*`);

let base = await USER.getProp("base").value();
let current = base || "USD";
sendMessage(`Your active currency preference is set to *${current}*`);

let amount = parseFloat(params[0]) || 100;
let target = (params[1] || "EUR").toUpperCase();
let base = (await USER.getProp("base").value()) || "USD";
sendChatAction("typing");
let data = await HTTP.get({ url: `https://open.er-api.com/v6/latest/${base}` });
let rate = data?.rates?.[target];
if (!rate) return sendMessage("Conversion failed. Check currency codes.");
let converted = (amount * rate).toFixed(2);
sendMessage(`*${amount} ${base}* = *${converted} ${target}*`);

const rsvp = await USER.getProp('rsvp').value();
if (rsvp) return sendMessage('You already reserved a spot for this meetup!');
const count = await BOT.getProp('rsvps').value() || 0;
if (count >= 30) return sendMessage('Sorry, this meetup is completely full!');
await USER.setProp('rsvp', true);
await BOT.getProp('rsvps').add(1);
sendMessage(`*RSVP Confirmed!* You bagged spot #${count + 1} of 30.`);

const rsvp = await USER.getProp('rsvp').value();
if (!rsvp) return sendMessage('You do not have an active spot reserved.');
await USER.deleteProp('rsvp');
await BOT.getProp('rsvps').add(-1);
sendMessage('Your reservation was canceled and the spot is back open.');

const count = await BOT.getProp('rsvps').value() || 0;
const left = Math.max(0, 30 - count);
sendMessage(`*Meetup Capacity Status*\n\nBooked spots: ${count}/30\nRemaining spots: ${left}`);

⚠️ Note: Ensure FIREBASE_URL and FIREBASE_SECRET are configured in your environment variables so persistent state works seamlessly.

if (!params) return sendMessage("Usage: /addsnippet Title | Code");
const [title, code] = params.split("|").map(s => s.trim());
if (!title || !code) return sendMessage("Provide both title and code split by |");
const list = (await BOT.getProp("snippets").value()) || [];
list.push({ title, code });
await BOT.setProperty("snippets", list);
sendMessage(`*Snippet saved!* Type \`@yourbot ${title}\` in any chat to use it.`);

const query = inlineQuery.toLowerCase();
const list = (await BOT.getProp("snippets").value()) || [];
const matches = list.filter(item => item.title.toLowerCase().includes(query));
const results = matches.map((item, id) => ({
  type: "article",
  id: String(id),
  title: item.title,
  input_message_content: { message_text: `\`\`\`\n${item.code}\n\`\`\``, parse_mode: "Markdown" }
}));
answerInlineQuery(results);