Api.setChatPermissions({
  chat_id: chat.chatid,
  permissions: JSON.stringify({ can_send_messages: false })
});

Bot.sendMessage("Now no one can send messages.");

Api.setChatPermissions({
  chat_id: chat.chatid,
  permissions: JSON.stringify({ can_send_messages: true })
});

Bot.sendMessage("Now everyone can send messages.");

let prompt = message;
let url = "https://carflow-mocha.vercel.app/api/gpt?prompt=" + encodeURIComponent(prompt);

HTTP.get({
  url: url,
  success: "/onResponse",
  error: "/onError"
});

let res = JSON.parse(content);
Bot.sendMessage(res.text);

Bot.sendMessage("❌ GPT API failed. Please try again.");

let prompt = message;
let url = "https://carflow-mocha.vercel.app/api/gpt4?prompt=" + encodeURIComponent(prompt);

HTTP.get({
  url: url,
  success: "/onResponse",
  error: "/onError"
});

let res = JSON.parse(content);
Bot.sendMessage(res.choices[0].message.content);

Bot.sendMessage("❌ GPT API failed. Please try again.");

function containsLink(msg) {
  var urlPattern = /https?:\/\/[^\s]+|www\.[^\s]+/gi;
  return urlPattern.test(msg);
}

function containsBadWord(msg) {
  var badWords = Bot.getProperty("Words");
  if (!badWords) return false;
  var lowerMsg = msg.toLowerCase();
  return badWords.some(word => lowerMsg.includes(word));
}

function isForwarded() {
  return request.forward_from || request.forward_from_chat;
}

if (chat.type !== "private") {
  if (containsLink(message) || containsBadWord(message) || isForwarded()) {
    let url = "https://api.telegram.org/bot" + bot.token + "/getChatAdministrators?chat_id=" + chat.chatid;
    HTTP.get({
      url: url,
      success: "/check"
    });
  }
}

let admins = JSON.parse(content).result;
let isAdmin = admins.some(admin => admin.user.id === user.telegramid);

if (!isAdmin) {
  Api.deleteMessage({
    chat_id: chat.chatid,
    message_id: request.message_id
  });

  Bot.sendMessage("⚠️ Your message was deleted. Forwarded messages, links, and bad words are not allowed.");
}

Bot.sendMessage("✅ *Enter your https://gist.github.com file link to load abuse words list:*\n\nExample - https://www.cs.cmu.edu/~biglou/resources/bad-words.txt ( 1383 Abuse Words )\n\nFollow these steps:\n\n1. Go to: https://gist.github.com\n2. Login with GitHub\n3. Paste abuse words (one per line)\n4. Click: *Create secret gist*\n5. Click on *Raw* → Copy the link\n\nNow send the link below:");
Bot.runCommand("/fetch_link");

if (!message || !message.includes("http")) {
  Bot.sendMessage("❌ Please send a valid link starting with http or https.");
  return;
}

Bot.sendMessage("Fetching and saving words list...");

HTTP.get({
  url: message,
  success: "/save"
});

let lines = content.split("\n");

let cleanWords = lines.map(w => w.trim()).filter(w => w.length > 0);

Bot.setProperty("Words", cleanWords, "json");

Bot.sendMessage("✅ words list updated with " + cleanWords.length + " words.");

var filters = Bot.getProperty("filters", {}) || {};
var chatId = chat.chatid;
var chatFilters = filters[chatId] || [];

var text = message.replace("/filter", "").trim();
var isReply = request.reply_to_message;
var media = isReply ? request.reply_to_message : null;

if (!text && !media) {
  return Bot.sendMessage("Reply to media or use: /filter <trigger> <reply>");
}

let trigger = "";
let replyText = null;

if (text && !text.includes(" ")) {
  trigger = text;
} else if (text && text.includes(" ")) {
  let parts = text.split(" ");
  trigger = parts.shift();
  replyText = parts.join(" ");
} else if (!text && media && media.caption) {
  replyText = media.caption;
  trigger = "media_" + media.message_id;
}

let mediaInfo = null;
if (media) {
  mediaInfo = {
    message_id: media.message_id,
    type: media.photo ? "photo" :
          media.audio ? "audio" :
          media.document ? "document" :
          media.voice ? "voice" :
          media.video ? "video" :
          media.animation ? "animation" :
          media.sticker ? "sticker" : "unknown"
  };
}

chatFilters.push({
  trigger: trigger.toLowerCase(),
  media: mediaInfo,
  reply: replyText || null
});

filters[chatId] = chatFilters;
Bot.setProperty("filters", filters, "json");
Bot.sendMessage("✅ Filter saved for: " + trigger);

var filters = Bot.getProperty("filters", {}) || {};
var chatId = chat.chatid;
var chatFilters = filters[chatId] || [];

if (chatFilters.length === 0) {
  return Bot.sendMessage("No filters set.");
}

var out = "*Active Filters:*\\n" + chatFilters.map(f => {
  let mark = f.media ? "📎 " : "💬 ";
  return mark + "`" + f.trigger + "`";
}).join("\\n");

Api.sendMessage({ chat_id: chatId, text: out, parse_mode: "Markdown" });

var filters = Bot.getProperty("filters", {}) || {};
var chatId = chat.chatid;
var chatFilters = filters[chatId] || [];
var msg = message.toLowerCase();
var isAdmin = user.telegramid === Bot.getProperty("admin_id");

for (var i = 0; i < chatFilters.length; i++) {
  var f = chatFilters[i];
  var trigger = f.trigger.toLowerCase();

  var matched =
    (trigger.startsWith("exact:") && msg === trigger.slice(6)) ||
    (trigger.startsWith("prefix:") && msg.startsWith(trigger.slice(7))) ||
    (!trigger.startsWith("exact:") && !trigger.startsWith("prefix:") && msg.includes(trigger));
    
  if (msg === f.trigger + " force" && f.reply) {
    Api.sendMessage({ chat_id: chatId, text: formatReply(f.reply, true), parse_mode: "Markdown" });
    return;
  }
  
if (msg === f.trigger + " noformat" && f.reply) {
  Api.sendMessage({ chat_id: chatId, text: f.reply });
  return;
}

  if (matched) {
    if (f.media) {
      Api.copyMessage({ chat_id: chatId, from_chat_id: chatId, message_id: f.media.message_id });
      return;
    } else if (f.reply) {
      let replyText = formatConditionalReply(f.reply, isAdmin);
      Api.sendMessage({ chat_id: chatId, text: formatReply(replyText), parse_mode: "Markdown" });
      return;
    }
  }
}

function formatReply(text, forceUser) {
  return text
    .replace(/{first}/gi, user.first_name || "")
    .replace(/{last}/gi, user.last_name || "")
    .replace(/{fullname}/gi, (user.first_name || "") + " " + (user.last_name || ""))
    .replace(/{username}/gi, user.username ? "@" + user.username : "[" + user.first_name + "](tg://user?id=" + user.telegramid + ")")
    .replace(/{mention}/gi, "[" + user.first_name + "](tg://user?id=" + user.telegramid + ")")
    .replace(/{id}/gi, user.telegramid)
    .replace(/{chatname}/gi, chat.title || "")
    .replace(/{rules}/gi, "[Rules](https://t.me/c/" + chat.chatid.toString().substring(4) + "/1)");
}

function formatConditionalReply(text, isAdmin) {
  let blocks = text.split("%%%");
  let chosen = blocks[Math.floor(Math.random() * blocks.length)];
  
  if (chosen.includes("{admin}") && !isAdmin) return "";
  if (chosen.includes("{user}") && isAdmin) return "";

  return chosen
    .replace(/{admin}/gi, "")
    .replace(/{user}/gi, "")
    .replace(/{protect}/gi, "")
    .replace(/{replytag}/gi, user.first_name)
    .replace(/{nonotif}/gi, "")
    .replace(/{preview}/gi, "")
    .replace(/{preview:top}/gi, "");
}

Examples of delay formats:
• /set_delay 10s — Delete after 10 seconds
• /set_delay 1m — Delete after 1 minute
• /set_delay 15m — Delete after 15 minutes
• /set_delay 2h — Delete after 2 hours
• /set_delay 1d — Delete after 1 day

if (typeof request === "string") {
  try { request = JSON.parse(request.replace(/\n/g, "\\\n")); } catch (e) { return; }
}

let { channel_post: message } = request;
if (!message) return;

let chat_id = message.chat.id;
let message_id = message.message_id;
let text = message.text || message.caption || "";

let delayMatch = text.match(/\/set_delay\s+(\d+)([smhd])/i);
if (!delayMatch) return;

let amount = parseInt(delayMatch[1]);
let unit = delayMatch[2].toLowerCase();
let delayMs;

switch (unit) {
  case 's': delayMs = amount * 1000; break
  case 'm': delayMs = amount * 1000 * 60; break
  case 'h': delayMs = amount * 1000 * 60 * 60; break
  case 'd': delayMs = amount * 1000 * 60 * 60 * 24; break
  default: return;
}

let delaySec = Math.floor(delayMs / 1000);

Bot.run({
  command: "/delete_post",
  run_after: delaySec,
  options: {
    chat_id: chat_id,
    message_id: message_id
  }
});

Bot.setProp(`log_${chat_id}_${message_id}`, {
  scheduled_at: new Date().toISOString(),
  delay: `${amount}${unit}`,
  message_id: message_id
}, 'json');

Api.deleteMessage({
  chat_id: options.chat_id,
  message_id: options.message_id,
  on_result: function(response) {
    if (response.ok) {
      Bot.setProp(`log_${options.chat_id}_${options.message_id}`, {
        deleted_at: new Date().toISOString(),
        status: "deleted"
      }, 'json');
    } else {
      Bot.run({
        command: "/on_error",
        options: {
          chat_id: options.chat_id,
          message_id: options.message_id,
          error: JSON.stringify(response)
        }
      });
    }
  }
});

Bot.setProp(`log_${options.chat_id}_${options.message_id}`, {
  error_at: new Date().toISOString(),
  status: "failed",
  error: options.error
}, 'json');

Example post (supports text, media + caption):
New update released! /set_delay 5m

This post will auto-delete after 5 minutes.

Examples of delay formats:
• /set_delay 10s — Delete after 10 seconds
• /set_delay 1m — Delete after 1 minute
• /set_delay 15m — Delete after 15 minutes
• /set_delay 2h — Delete after 2 hours

▎OFFER: 

let apiKey = "Gemini_Api_Key";
let userMessage = message;
let chatId = user.chat_id;

Bot.setProperty("lastMessage_" + chatId, userMessage, "string");

let url = "https://generativelanguage.googleapis.com/v1beta/models/gemini-2.0-flash:generateContent?key=" + apiKey;

let payload = {
  contents: [
    {
      parts: [
        { text: String(userMessage) }
      ]
    }
  ]
};

Api.sendChatAction({ action: "typing" });

HTTP.post({
  url: url,
  headers: {
    "Content-Type": "application/json"
  },
  body: JSON.stringify(payload),
  success: "/gemini_response",
  background: true
});

let data = JSON.parse(content);
let chatId = user.chat_id;

if (data.candidates && data.candidates.length > 0 && data.candidates[0].content && data.candidates[0].content.parts) {
  let reply = data.candidates[0].content.parts.map(p => p.text).join("\n");

  reply = reply.replace(/(\*\*|\*|_|\n\n)/g, " ").trim();
  Bot.setProperty("lastAIResponse_" + chatId, reply, "string");

  Bot.sendMessage(reply);
} else {
  Bot.sendMessage("No response from Gemini AI.");

}

var admin = [your_tg_id];

// Check if the user is an admin
if (!admin.includes(user.telegramid)) {
  Bot.sendMessage("*Only admin can use!* ",{is_reply:true});
  return;
}

Bot.sendMessage("Forward cast sent to all users")

Bot.runAll({
  command: "/onForward",
  options: { chat_id: request.chat.id, message_id: request.message_id },
  on_create: "/id"
})

Api.forwardMessage({
    chat_id: user.telegramid,
    from_chat_id: options.chat_id,
    message_id: options.message_id,
    on_result: "/pin" //optional
  })

const task = options.run_all_task;
Bot.sendMessage(
  "Task for brodcasting created. Task id: " + task.id
);
// save task id:
Bot.setProperty("curBrodcastTaskID", task.id, "integer")
//Bot.inspect(options.run_all_task);

// show current runAll progress

const taskID = Bot.getProperty("curBrodcastTaskID");
let task = new RunAllTask({ id: taskID });
// Bot.inspect(task) // you can check all fields

if(!task.status){
  Bot.sendMessage("This task not found")
  return
}

Bot.sendMessage(
  "Current brodcast: " + 
  "\n Status: " + task.status + " " + task.progress + "%" +
  "\n Progress:" + task.cur_position + "/" + task.total
)

Api.pinChatMessage({message_id:options.result.message_id})

▎OFFER: