|
|
import os |
|
|
import sys |
|
|
import time |
|
|
import json |
|
|
import threading |
|
|
import subprocess |
|
|
import signal |
|
|
import requests |
|
|
from datetime import datetime, timedelta |
|
|
from flask import Flask, render_template_string, jsonify, request |
|
|
import logging |
|
|
|
|
|
|
|
|
log = logging.getLogger('werkzeug') |
|
|
log.setLevel(logging.ERROR) |
|
|
app = Flask(__name__) |
|
|
|
|
|
|
|
|
|
|
|
SHEET_ID = os.environ.get("SHEET_ID") |
|
|
SHEET_URL = f"https://docs.google.com/spreadsheets/d/{SHEET_ID}/export?format=csv" |
|
|
|
|
|
|
|
|
bots = {} |
|
|
bot_processes = {} |
|
|
last_rejoin = {} |
|
|
server_locks = {} |
|
|
|
|
|
|
|
|
HTML = """<!DOCTYPE html> |
|
|
<html> |
|
|
<head> |
|
|
<title>Bot Manager</title> |
|
|
<meta charset="utf-8"> |
|
|
<meta name="viewport" content="width=device-width,initial-scale=1"> |
|
|
<style> |
|
|
*{margin:0;padding:0;box-sizing:border-box} |
|
|
body{font-family:Arial,sans-serif;background:#1a1a1a;color:#fff;padding:10px} |
|
|
.header{background:#2a2a2a;padding:15px;border-radius:8px;margin-bottom:15px} |
|
|
h1{font-size:24px;margin-bottom:10px} |
|
|
.stats{display:grid;grid-template-columns:repeat(auto-fit,minmax(120px,1fr));gap:10px;margin-bottom:15px} |
|
|
.stat{background:#333;padding:12px;border-radius:5px;text-align:center} |
|
|
.stat span{display:block;font-size:24px;font-weight:bold;color:#4CAF50;margin-top:5px} |
|
|
.controls{margin-bottom:15px} |
|
|
button{background:#4CAF50;border:none;color:white;padding:10px 20px;margin:5px;border-radius:5px;cursor:pointer;font-size:14px} |
|
|
button:hover{background:#45a049} |
|
|
button:disabled{background:#666;cursor:not-allowed} |
|
|
.grid{display:grid;grid-template-columns:repeat(auto-fill,minmax(280px,1fr));gap:12px} |
|
|
.bot{background:#2a2a2a;padding:15px;border-radius:8px;border-left:4px solid #666} |
|
|
.bot.online{border-color:#4CAF50} |
|
|
.bot.offline{border-color:#f44336} |
|
|
.bot.connecting{border-color:#ff9800} |
|
|
.bot-name{font-weight:bold;font-size:16px;margin-bottom:8px} |
|
|
.bot-info{color:#999;font-size:13px;margin:4px 0} |
|
|
.bot-status{display:inline-block;padding:4px 10px;border-radius:4px;font-size:12px;margin-top:8px;font-weight:bold} |
|
|
.online .bot-status{background:#4CAF50;color:white} |
|
|
.offline .bot-status{background:#f44336;color:white} |
|
|
.connecting .bot-status{background:#ff9800;color:white} |
|
|
.msg{background:#2196F3;color:white;padding:10px;border-radius:5px;margin:10px 0} |
|
|
.error{background:#f44336} |
|
|
</style> |
|
|
</head> |
|
|
<body> |
|
|
<div class="header"> |
|
|
<h1>🎮 Minecraft Bot Manager</h1> |
|
|
<div class="stats"> |
|
|
<div class="stat">Total<span id="total">0</span></div> |
|
|
<div class="stat">Online<span id="online">0</span></div> |
|
|
<div class="stat">Offline<span id="offline">0</span></div> |
|
|
<div class="stat">Connecting<span id="connecting">0</span></div> |
|
|
</div> |
|
|
<div class="controls"> |
|
|
<button onclick="reloadSheet()">📋 Reload Sheet</button> |
|
|
<button onclick="refreshStatus()">🔄 Refresh</button> |
|
|
</div> |
|
|
<div id="msg"></div> |
|
|
</div> |
|
|
<div class="grid" id="grid"></div> |
|
|
<script> |
|
|
let data={}; |
|
|
let updateTimer; |
|
|
|
|
|
async function fetchBots(){ |
|
|
try{ |
|
|
const r=await fetch('/api/bots'); |
|
|
data=await r.json(); |
|
|
renderBots(); |
|
|
}catch(e){ |
|
|
showMsg('Failed to fetch bots','error'); |
|
|
} |
|
|
} |
|
|
|
|
|
async function rejoinBot(name){ |
|
|
if(!confirm(`Rejoin bot ${name}?`))return; |
|
|
try{ |
|
|
const r=await fetch('/api/rejoin',{ |
|
|
method:'POST', |
|
|
headers:{'Content-Type':'application/json'}, |
|
|
body:JSON.stringify({name:name}) |
|
|
}); |
|
|
const res=await r.json(); |
|
|
if(res.error){ |
|
|
showMsg(res.error,'error'); |
|
|
}else{ |
|
|
showMsg(`Rejoining ${name}...`); |
|
|
fetchBots(); |
|
|
} |
|
|
}catch(e){ |
|
|
showMsg('Failed to rejoin bot','error'); |
|
|
} |
|
|
} |
|
|
|
|
|
async function reloadSheet(){ |
|
|
try{ |
|
|
showMsg('Reloading from sheet...'); |
|
|
await fetch('/api/reload',{method:'POST'}); |
|
|
setTimeout(fetchBots,1000); |
|
|
}catch(e){ |
|
|
showMsg('Failed to reload','error'); |
|
|
} |
|
|
} |
|
|
|
|
|
async function refreshStatus(){ |
|
|
fetchBots(); |
|
|
} |
|
|
|
|
|
function showMsg(text,type=''){ |
|
|
const el=document.getElementById('msg'); |
|
|
el.className=type; |
|
|
el.textContent=text; |
|
|
if(text)setTimeout(()=>el.textContent='',5000); |
|
|
} |
|
|
|
|
|
function renderBots(){ |
|
|
const g=document.getElementById('grid'); |
|
|
g.innerHTML=''; |
|
|
let total=0,online=0,offline=0,connecting=0; |
|
|
|
|
|
|
|
|
for(const[name,bot]of Object.entries(data)){ |
|
|
total++; |
|
|
if(bot.status==='online')online++; |
|
|
else if(bot.status==='offline')offline++; |
|
|
else connecting++; |
|
|
|
|
|
const div=document.createElement('div'); |
|
|
div.className='bot '+bot.status; |
|
|
let btnHtml=''; |
|
|
if(bot.status==='offline'){ |
|
|
if(bot.can_rejoin){ |
|
|
btnHtml=`<button onclick="rejoinBot('${name.replace(/'/g,"\\'")}')">🔄 Rejoin</button>`; |
|
|
}else if(bot.cooldown>0){ |
|
|
const m=Math.floor(bot.cooldown/60); |
|
|
const s=bot.cooldown%60; |
|
|
btnHtml=`<button disabled>⏳ ${m}:${s.toString().padStart(2,'0')}</button>`; |
|
|
} |
|
|
} |
|
|
div.innerHTML=` |
|
|
<div class="bot-name">${name}</div> |
|
|
<div class="bot-info">Version: ${bot.version}</div> |
|
|
<div class="bot-info">Server: ${bot.server||'Hidden'}</div> |
|
|
<div class="bot-status">${bot.status.toUpperCase()}</div> |
|
|
${btnHtml}`; |
|
|
g.appendChild(div); |
|
|
} |
|
|
document.getElementById('total').textContent=total; |
|
|
document.getElementById('online').textContent=online; |
|
|
document.getElementById('offline').textContent=offline; |
|
|
document.getElementById('connecting').textContent=connecting; |
|
|
} |
|
|
|
|
|
function startAutoUpdate(){ |
|
|
if(updateTimer)clearInterval(updateTimer); |
|
|
updateTimer=setInterval(fetchBots,5000); |
|
|
} |
|
|
|
|
|
fetchBots(); |
|
|
startAutoUpdate(); |
|
|
</script> |
|
|
</body> |
|
|
</html>""" |
|
|
|
|
|
|
|
|
BOT_SCRIPT = """ |
|
|
const mineflayer = require('mineflayer'); |
|
|
|
|
|
const botName = process.argv[2]; |
|
|
const host = process.argv[3]; |
|
|
const port = parseInt(process.argv[4]) || 25565; |
|
|
const version = process.argv[5] || false; |
|
|
|
|
|
console.log(JSON.stringify({event:'starting',name:botName,host:host,port:port,version:version})); |
|
|
|
|
|
const bot = mineflayer.createBot({ |
|
|
host: host, |
|
|
port: port, |
|
|
username: botName, |
|
|
auth: 'offline', |
|
|
version: version === 'false' ? false : version, |
|
|
hideErrors: false, |
|
|
checkTimeoutInterval: 30000, |
|
|
keepAlive: true, |
|
|
skipValidation: true |
|
|
}); |
|
|
|
|
|
let isConnected = false; |
|
|
let afkInterval = null; |
|
|
|
|
|
function startAfk() { |
|
|
if (afkInterval) clearInterval(afkInterval); |
|
|
|
|
|
// Anti-AFK movement |
|
|
afkInterval = setInterval(() => { |
|
|
if (!bot.entity || !isConnected) return; |
|
|
|
|
|
// Random movement |
|
|
const actions = ['forward', 'back', 'left', 'right', 'jump', 'sneak']; |
|
|
const action = actions[Math.floor(Math.random() * actions.length)]; |
|
|
|
|
|
bot.setControlState(action, true); |
|
|
setTimeout(() => { |
|
|
bot.setControlState(action, false); |
|
|
}, 200); |
|
|
|
|
|
// Random look |
|
|
if (Math.random() > 0.5) { |
|
|
const yaw = bot.entity.yaw + (Math.random() - 0.5); |
|
|
const pitch = bot.entity.pitch + (Math.random() - 0.5) * 0.5; |
|
|
bot.look(yaw, pitch, true); |
|
|
} |
|
|
}, 15000); // Move every 15 seconds |
|
|
} |
|
|
|
|
|
bot.once('spawn', () => { |
|
|
console.log(JSON.stringify({event:'connected',name:botName})); |
|
|
isConnected = true; |
|
|
startAfk(); |
|
|
|
|
|
// Handle resource packs |
|
|
bot._client.on('resource_pack_send', (packet) => { |
|
|
bot._client.write('resource_pack_receive', { result: 0 }); |
|
|
}); |
|
|
|
|
|
// Random chat to stay active |
|
|
setInterval(() => { |
|
|
if (isConnected && Math.random() > 0.95) { |
|
|
const messages = ['hi', 'hello', 'hey', ':)', 'o/', 'test']; |
|
|
bot.chat(messages[Math.floor(Math.random() * messages.length)]); |
|
|
} |
|
|
}, 300000); // Every 5 minutes maybe chat |
|
|
}); |
|
|
|
|
|
bot.on('respawn', () => { |
|
|
console.log(JSON.stringify({event:'respawned',name:botName})); |
|
|
startAfk(); |
|
|
}); |
|
|
|
|
|
bot.on('death', () => { |
|
|
console.log(JSON.stringify({event:'died',name:botName})); |
|
|
}); |
|
|
|
|
|
bot.on('kicked', (reason) => { |
|
|
console.log(JSON.stringify({event:'kicked',name:botName,reason:reason})); |
|
|
isConnected = false; |
|
|
}); |
|
|
|
|
|
bot.on('error', (err) => { |
|
|
console.log(JSON.stringify({event:'error',name:botName,error:err.message})); |
|
|
}); |
|
|
|
|
|
bot.on('end', (reason) => { |
|
|
console.log(JSON.stringify({event:'disconnected',name:botName,reason:reason})); |
|
|
isConnected = false; |
|
|
if (afkInterval) clearInterval(afkInterval); |
|
|
process.exit(); |
|
|
}); |
|
|
|
|
|
// Keep alive signal |
|
|
setInterval(() => { |
|
|
if (isConnected) { |
|
|
console.log(JSON.stringify({event:'alive',name:botName})); |
|
|
} |
|
|
}, 30000); |
|
|
|
|
|
// Graceful shutdown |
|
|
process.on('SIGTERM', () => { |
|
|
if (afkInterval) clearInterval(afkInterval); |
|
|
bot.quit(); |
|
|
process.exit(); |
|
|
}); |
|
|
|
|
|
process.on('SIGINT', () => { |
|
|
if (afkInterval) clearInterval(afkInterval); |
|
|
bot.quit(); |
|
|
process.exit(); |
|
|
}); |
|
|
""" |
|
|
|
|
|
def write_bot_script(): |
|
|
"""Write bot script to temp directory""" |
|
|
path = '/tmp/bot.js' |
|
|
try: |
|
|
with open(path, 'w') as f: |
|
|
f.write(BOT_SCRIPT) |
|
|
return True |
|
|
except Exception as e: |
|
|
print(f"Error writing bot script: {e}") |
|
|
return False |
|
|
|
|
|
def fetch_sheet_data(): |
|
|
"""Fetch bot configuration from Google Sheets""" |
|
|
try: |
|
|
resp = requests.get(SHEET_URL, timeout=10) |
|
|
if resp.status_code != 200: |
|
|
return [] |
|
|
|
|
|
lines = resp.text.strip().split('\n') |
|
|
data = [] |
|
|
|
|
|
for i, line in enumerate(lines[1:], 1): |
|
|
parts = [p.strip().strip('"') for p in line.split(',')] |
|
|
if len(parts) >= 3: |
|
|
name = parts[0] |
|
|
ip = parts[1] |
|
|
port = parts[2] |
|
|
version = parts[3] if len(parts) > 3 else "false" |
|
|
|
|
|
if name and ip and port and port.isdigit(): |
|
|
data.append({ |
|
|
'name': name, |
|
|
'ip': ip, |
|
|
'port': port, |
|
|
'version': version if version else "false" |
|
|
}) |
|
|
|
|
|
print(f"Loaded {len(data)} bots from sheet") |
|
|
return data |
|
|
except Exception as e: |
|
|
print(f"Error fetching sheet: {e}") |
|
|
return [] |
|
|
|
|
|
def start_bot(config): |
|
|
"""Start a bot process""" |
|
|
name = config['name'] |
|
|
server_key = f"{config['ip']}:{config['port']}" |
|
|
|
|
|
|
|
|
if server_key in server_locks and server_locks[server_key] != name: |
|
|
return False, "Server already has another bot" |
|
|
|
|
|
|
|
|
if name in bot_processes: |
|
|
try: |
|
|
proc = bot_processes[name] |
|
|
proc.terminate() |
|
|
proc.wait(timeout=3) |
|
|
except: |
|
|
pass |
|
|
|
|
|
try: |
|
|
|
|
|
proc = subprocess.Popen( |
|
|
['node', '/tmp/bot.js', name, config['ip'], config['port'], config['version']], |
|
|
stdout=subprocess.PIPE, |
|
|
stderr=subprocess.STDOUT, |
|
|
text=True, |
|
|
bufsize=1 |
|
|
) |
|
|
|
|
|
bot_processes[name] = proc |
|
|
server_locks[server_key] = name |
|
|
|
|
|
bots[name] = { |
|
|
'status': 'connecting', |
|
|
'ip': config['ip'], |
|
|
'port': config['port'], |
|
|
'version': config['version'], |
|
|
'server': server_key, |
|
|
'start_time': time.time() |
|
|
} |
|
|
|
|
|
|
|
|
threading.Thread(target=monitor_bot, args=(name,), daemon=True).start() |
|
|
|
|
|
return True, "Bot started" |
|
|
except Exception as e: |
|
|
return False, str(e) |
|
|
|
|
|
def monitor_bot(name): |
|
|
"""Monitor bot process output""" |
|
|
if name not in bot_processes: |
|
|
return |
|
|
|
|
|
proc = bot_processes[name] |
|
|
|
|
|
try: |
|
|
while proc.poll() is None: |
|
|
line = proc.stdout.readline() |
|
|
if not line: |
|
|
continue |
|
|
|
|
|
try: |
|
|
data = json.loads(line.strip()) |
|
|
event = data.get('event') |
|
|
|
|
|
if event == 'connected' or event == 'alive': |
|
|
if name in bots: |
|
|
bots[name]['status'] = 'online' |
|
|
elif event in ['disconnected', 'kicked', 'error']: |
|
|
if name in bots: |
|
|
bots[name]['status'] = 'offline' |
|
|
|
|
|
|
|
|
if event in ['connected', 'disconnected', 'kicked', 'error']: |
|
|
print(f"[{name}] {event}: {data.get('reason', '')}") |
|
|
|
|
|
except json.JSONDecodeError: |
|
|
|
|
|
pass |
|
|
except: |
|
|
pass |
|
|
|
|
|
|
|
|
if name in bots: |
|
|
bots[name]['status'] = 'offline' |
|
|
server = bots[name].get('server') |
|
|
if server in server_locks and server_locks[server] == name: |
|
|
del server_locks[server] |
|
|
|
|
|
def sync_bots(): |
|
|
"""Sync bots with sheet data""" |
|
|
data = fetch_sheet_data() |
|
|
names = {d['name'] for d in data} |
|
|
|
|
|
|
|
|
for name in list(bots.keys()): |
|
|
if name not in names: |
|
|
if name in bot_processes: |
|
|
try: |
|
|
bot_processes[name].terminate() |
|
|
except: |
|
|
pass |
|
|
if name in bots: |
|
|
server = bots[name].get('server') |
|
|
if server in server_locks and server_locks[server] == name: |
|
|
del server_locks[server] |
|
|
del bots[name] |
|
|
print(f"Removed bot: {name}") |
|
|
|
|
|
|
|
|
for config in data: |
|
|
if config['name'] not in bots: |
|
|
success, msg = start_bot(config) |
|
|
if success: |
|
|
print(f"Added bot: {config['name']}") |
|
|
|
|
|
@app.route('/') |
|
|
def index(): |
|
|
return HTML |
|
|
|
|
|
@app.route('/api/bots') |
|
|
def api_bots(): |
|
|
"""Get bot status""" |
|
|
result = {} |
|
|
now = datetime.now() |
|
|
|
|
|
for name, bot in bots.items(): |
|
|
can_rejoin = True |
|
|
cooldown = 0 |
|
|
|
|
|
if name in last_rejoin: |
|
|
elapsed = now - last_rejoin[name] |
|
|
if elapsed < timedelta(hours=1): |
|
|
can_rejoin = False |
|
|
cooldown = int((timedelta(hours=1) - elapsed).total_seconds()) |
|
|
|
|
|
result[name] = { |
|
|
'status': bot['status'], |
|
|
'version': bot['version'], |
|
|
'server': 'Hidden', |
|
|
'can_rejoin': can_rejoin, |
|
|
'cooldown': cooldown |
|
|
} |
|
|
|
|
|
return jsonify(result) |
|
|
|
|
|
@app.route('/api/rejoin', methods=['POST']) |
|
|
def api_rejoin(): |
|
|
"""Rejoin a bot""" |
|
|
name = request.json.get('name') |
|
|
|
|
|
if name not in bots: |
|
|
return jsonify({'error': 'Bot not found'}), 404 |
|
|
|
|
|
now = datetime.now() |
|
|
|
|
|
|
|
|
if name in last_rejoin: |
|
|
elapsed = now - last_rejoin[name] |
|
|
if elapsed < timedelta(hours=1): |
|
|
mins = int((timedelta(hours=1) - elapsed).total_seconds() / 60) |
|
|
return jsonify({'error': f'Please wait {mins} minutes before rejoining'}), 429 |
|
|
|
|
|
if bots[name]['status'] == 'online': |
|
|
return jsonify({'error': 'Bot is already online'}), 400 |
|
|
|
|
|
config = { |
|
|
'name': name, |
|
|
'ip': bots[name]['ip'], |
|
|
'port': bots[name]['port'], |
|
|
'version': bots[name]['version'] |
|
|
} |
|
|
|
|
|
success, msg = start_bot(config) |
|
|
|
|
|
if success: |
|
|
last_rejoin[name] = now |
|
|
return jsonify({'success': True, 'message': 'Bot rejoining'}) |
|
|
else: |
|
|
return jsonify({'error': msg}), 500 |
|
|
|
|
|
@app.route('/api/reload', methods=['POST']) |
|
|
def api_reload(): |
|
|
"""Reload bots from sheet""" |
|
|
sync_bots() |
|
|
return jsonify({'success': True, 'message': 'Reloaded from sheet'}) |
|
|
|
|
|
def cleanup(sig=None, frame=None): |
|
|
"""Clean shutdown""" |
|
|
print("\nShutting down...") |
|
|
for name, proc in bot_processes.items(): |
|
|
try: |
|
|
proc.terminate() |
|
|
except: |
|
|
pass |
|
|
sys.exit(0) |
|
|
|
|
|
if __name__ == '__main__': |
|
|
signal.signal(signal.SIGINT, cleanup) |
|
|
signal.signal(signal.SIGTERM, cleanup) |
|
|
|
|
|
|
|
|
if not write_bot_script(): |
|
|
print("Failed to write bot script!") |
|
|
sys.exit(1) |
|
|
|
|
|
print("Bot Manager starting...") |
|
|
|
|
|
|
|
|
sync_bots() |
|
|
|
|
|
|
|
|
def auto_sync(): |
|
|
while True: |
|
|
time.sleep(60) |
|
|
try: |
|
|
sync_bots() |
|
|
except Exception as e: |
|
|
print(f"Auto sync error: {e}") |
|
|
|
|
|
threading.Thread(target=auto_sync, daemon=True).start() |
|
|
|
|
|
|
|
|
print("Server starting on port 7860...") |
|
|
app.run(host='0.0.0.0', port=7860, debug=False, use_reloader=False) |
