Flex Coder

Comment down 👇

const claimed = await USER.getProp('daily_claimed').value();
const today = new Date().toISOString().slice(0, 10);
if (claimed === today) {
  sendMessage('⏳ You already claimed your 50 daily kudos for today!');
  return;
}
USER.setProp('daily_claimed', today);
const balance = (await USER.getProp('balance').value()) || 0;
USER.setProp('balance', balance + 50);
sendMessage('🎁 Credited *50 kudos* to your account! Check the ledger via `/pot` or tip the pool with `/tip 10`.');

const amount = Math.max(1, parseInt(params, 10) || 10);
const balance = (await USER.getProp('balance').value()) || 0;
if (balance < amount) {
  sendMessage(`⚠️ Insufficient balance! You have *${balance}* kudos available.`);
  return;
}
USER.setProp('balance', balance - amount);
const pool = (await BOT.getProp('sprint_pool').value()) || 0;
BOT.setProp('sprint_pool', pool + amount);
const totalTipped = (await USER.getProp('total_tipped').value()) || 0;
USER.setProp('total_tipped', totalTipped + amount);
sendMessage(`✨ You pitched *${amount}* kudos into the sprint pot! Current balance: *${balance - amount}*.`);

const pool = (await BOT.getProp('sprint_pool').value()) || 0;
const tipped = (await USER.getProp('total_tipped').value()) || 0;
const balance = (await USER.getProp('balance').value()) || 0;
sendMessage(`🏆 *Sprint Kudos Ledger*\n\n🔥 Total Team Pot: *${pool}* kudos\n👤 Your Contributions: *${tipped}* kudos\n💰 Available Balance: *${balance}* kudos`, {
  buttons: [
    [
      { text: "🎁 Claim Daily Kudos", command: "/daily" },
      { text: "⚡ Tip 10 Kudos", command: "/tip 10" }
    ]
  ]
});

⚠️ Note: Make sure FIREBASE_URL and FIREBASE_SECRET are configured in your environment so properties persist seamlessly between deployments.

sendMessage("Let's get your creative project rolling. Reply with the client or campaign name:");
waitForAnswer("/brief_name");

TEMP.setProp("campaign", message);
sendMessage("Great! Now send your audio voice memo brief or attach your scope document:");
waitForAnswer("/brief_asset");

const campaign = await TEMP.getProp("campaign").value();
pushDB("project_briefs", {
  user_id: user.id,
  username: user.username || user.first_name,
  campaign: campaign,
  message_id: message_id,
  submitted_at: Date.now()
});
clearWait();
sendMessage("✅ Creative brief for *" + campaign + "* logged successfully! Our team will review the audio assets.");

⚠️ Note: Ensure FIREBASE_URL and FIREBASE_SECRET are configured in your environment so pushDB can generate persistent records.

if (!params) return sendMessage("<b>Usage:</b> <code>/preview https://example.com</code>");
sendChatAction("upload_photo");
const res = await HTTP.get({ url: `https://api.microlink.io?url=${encodeURIComponent(params)}` });
if (!res?.data?.image?.url) return sendMessage("❌ Could not extract OpenGraph metadata from that URL.");
const { title, description, image } = res.data;
sendPhoto(image.url, {
  caption: `🌐 <b>${title || "No title"}</b>\n\n${description || "No description"}\n\n🔗 <code>${params}</code>`
});

if (!params) return sendMessage("<b>Usage:</b> <code>/headers https://example.com</code>");
sendChatAction("typing");
const res = await HTTP.custom({ url: params, method: "HEAD" });
const cache = res?.headers?.["cache-control"] || "none";
const server = res?.headers?.["server"] || "hidden";
const type = res?.headers?.["content-type"] || "unknown";
sendMessage(`📡 <b>Response Headers</b>\n\n• <b>Target:</b> <code>${params}</code>\n• <b>Content-Type:</b> <code>${type}</code>\n• <b>Cache-Control:</b> <code>${cache}</code>\n• <b>Server:</b> <code>${server}</code>`);

sendChatAction("typing");
const target = params || "backend";
const res = await HTTP.get({
  url: `https://ops.internal-infra.net/logs/tail?service=${target}`
});
if (!res || !res.logs) {
  sendMessage(`❌ Unable to fetch tail output for <b>${target}</b>.`);
  return;
}
sendMessage(`📋 <b>Tail output: ${target}</b>\n<pre>${res.logs}</pre>`);

sendChatAction("upload_document");
const target = params || "backend";
const res = await HTTP.post({
  url: "https://ops.internal-infra.net/logs/archive",
  body: { service: target, requested_by: user.username || user.id }
});
if (!res || !res.file_url) {
  sendMessage(`❌ Archive generation failed for <b>${target}</b>.`);
  return;
}
pushDB("audit/log_requests", { user_id: user.id, service: target, date: Date.now() });
sendDocument(res.file_url, {
  caption: `🗜️ <b>Diagnostic dump:</b> <code>${target}</code>`
});

⚠️ Note: Protect sensitive internal endpoints by ensuring your bot server's outbound IP is allowlisted on your private network firewall.

const holder = await BOT.getProp("staging_locked_by").value();
if (holder) {
  sendMessage(`🔴 *Staging 1 is LOCKED* by ${holder}`, {
    buttons: [{ text: "🔓 Release Staging", command: "/unlock_staging" }]
  });
} else {
  sendMessage("🟢 *Staging 1 is AVAILABLE* for testing.", {
    buttons: [{ text: "🔒 Claim Staging", command: "/lock_staging" }]
  });
}

if (isCallback) {
  answerCallback("Environment claimed!", false);
}
const claimant = user.first_name || user.username || "Anonymous Dev";
BOT.setProp("staging_locked_by", claimant);
editCallbackMessage(`🔴 *Staging 1 is LOCKED* by ${claimant}`, [
  { text: "🔓 Release Staging", command: "/unlock_staging" }
]);

if (isCallback) {
  answerCallback("Environment released!", false);
}
BOT.deleteProp("staging_locked_by");
editCallbackMessage("🟢 *Staging 1 is AVAILABLE* for testing.", [
  { text: "🔒 Claim Staging", command: "/lock_staging" }
]);

⚠️ Note: Shared status across all users is handled automatically via BOT.setProp, which syncs to your configured Firebase Realtime DB without any manual database setup.

const actions = [
  [{ text: "/incident" }, { text: "/swap" }],
  [{ text: "/clockout" }]
];
sendReplyKeyboard("🛠 *On-call dock initialized.*\nUse the quick controls below to log activities or rotate coverage.", actions, "Markdown");

pushDB("ops_shifts", {
  engineer: user.first_name || user.username,
  uid: user.id,
  action: "ROTATION_COMPLETED",
  time: Date.now()
});
sendMessage("📋 *Shift swap logged to database.* Standby team alerted.", { parse_mode: "Markdown" });

pushDB("ops_shifts", {
  engineer: user.first_name || user.username,
  uid: user.id,
  action: "SIGNED_OFF",
  time: Date.now()
});
removeKeyboard("👋 *Shift ended.* Custom dock buttons dismissed.");

sendMessage('🎧 *Client Review Suite*\nSelect a sound asset below to audition the draft mix in-chat:', {
  buttons: [
    [{ text: '🎵 Synth Lead Hook', command: '/preview synth' }, { text: '🥁 Live Drum Break', command: '/preview drums' }],
    [{ text: '⚡ Ambient Stinger FX', command: '/preview stinger' }]
  ]
});

const track = params.trim();
sendChatAction('upload_document');
sendAudio(`https://cdn.example.com/audio/${track}-preview.mp3`, {
  caption: `Draft preview: *${track}* (128kbps demo).\nTap below to pull the uncompressed stem.`,
  buttons: [
    [{ text: '📦 Deliver 24-bit WAV', command: `/master ${track}` }],
    [{ text: '« Back to Catalog', command: '/samples' }]
  ]
});

const track = params.trim();
sendChatAction('upload_document');
sendDocument(`https://cdn.example.com/audio/${track}-master.wav`, {
  caption: `Studio master for *${track}* (24-bit 48kHz WAV). Exported and ready for timeline drop.`
});

sendChatAction('typing');
sendPoll(
  'What is your team primary deployment target this quarter?',
  ['Kubernetes / EKS', 'Serverless Edge', 'Bare Metal / VPS', 'Managed PaaS'],
  { is_anonymous: false }
);
sendMessage('🎯 *Live audience poll dispatched.* Toggle stage feedback menu?', {
  buttons: [{ text: 'Open Speaker Rating', command: '/rate_stage' }]
});

sendReplyKeyboard(
  'Select your feedback for the current keynote speaker:',
  [['🔥 Incredible Insights', '👍 Solid Content'], ['⚡ Needs More Demos', '😴 Too Basic']]
);

removeKeyboard('🎉 Rating recorded! Keyboard controls cleared for the next talk.');

⚠️ Note: Ensure your bot is added as an administrator with posting rights if you dispatch polls into a broadcast channel.

const query = (inlineQuery.query || "").toLowerCase();
const assets = await getDB("brand_assets") || {};
const results = Object.keys(assets).filter(k => k.includes(query)).slice(0, 10).map(k => ({
  type: "article",
  id: k,
  title: assets[k].title,
  description: assets[k].desc,
  input_message_content: { message_text: assets[k].text, parse_mode: "HTML" }
}));
await answerInlineQuery(results);

if (!params || !params.includes("|")) return sendMessage("Format: /addasset key | Title | Description | Content");
const [key, title, desc, text] = params.split("|").map(s => s.trim());
await setDB(`brand_assets/${key.toLowerCase()}`, { title, desc, text });
await sendMessage(`Asset <b>${key}</b> indexed successfully!`);

⚠️ Note: Restrict addasset.js access to approved user IDs using user context properties to prevent client or public tampering with your asset database.

sendChatAction("typing")
sendMessage("📍 Please share your current location to start the site audit.")
waitForAnswer("save_location")

if (!flex.message.location) return sendMessage("⚠️ Location missing. Please send your GPS location.")
TEMP.setProperty("lat", flex.message.location.latitude)
TEMP.setProperty("lng", flex.message.location.longitude)
sendMessage("📷 Location saved! Now send a photo of the equipment setup.")
waitForAnswer("save_photo")

if (!flex.message.photo) return sendMessage("⚠️ Photo missing. Please send a photo of the equipment.")
sendChatAction("upload_photo")
let photoId = flex.message.photo.pop().file_id
let lat = await TEMP.getProp("lat").value()
let lng = await TEMP.getProp("lng").value()
HTTP.post({ url: "https://api.fieldops.dev/v1/inspections", body: { user: user.telegramid, lat, lng, photoId } })
clearWait()
sendMessage("✅ *Audit Submitted!* Location coordinates and hardware snapshot are logged.")

⚠️ Note: Ensure your external inspection backend endpoint validates request payloads and accepts JSON body parameters.

if (params) {
  sendChatAction('typing')
  let res = HTTP.get({ url: 'https://dns.google/resolve?name=' + params + '&type=A' })
  let data = JSON.parse(res.body || '{}')
  let ip = data.Answer ? data.Answer[0].data : 'No A record found'
  sendMessage('🌐 *DNS Result for ' + params + '*\n\nIP Address: `' + ip + '`')
} else {
  sendMessage('Type the domain name you want to query:')
  waitForAnswer('get_dns')
}

sendChatAction('typing')
let domain = message.trim().toLowerCase()
let res = HTTP.get({ url: 'https://dns.google/resolve?name=' + domain + '&type=A' })
let data = JSON.parse(res.body || '{}')
let ip = data.Answer ? data.Answer[0].data : 'No A record found'
sendMessage('🌐 *DNS Result for ' + domain + '*\n\nIP Address: `' + ip + '`')
clearWait()

⚠️ Note: Google DNS API requires no authorization keys or external environment configuration.