105 lines
2.4 KiB
Python
105 lines
2.4 KiB
Python
import importlib
|
|
import threading
|
|
import time
|
|
import traceback
|
|
import json
|
|
|
|
import logging
|
|
log = logging.getLogger('werkzeug')
|
|
log.setLevel(logging.ERROR)
|
|
|
|
from flask import Flask
|
|
from flask_cors import CORS
|
|
build_folder = 'web_interface/build'
|
|
app = Flask(__name__, template_folder=build_folder, static_folder=build_folder, static_url_path='')
|
|
CORS(app)
|
|
|
|
from munch import Munch
|
|
from watchdog.observers import Observer
|
|
from watchdog.events import PatternMatchingEventHandler
|
|
|
|
from mosfet import bot
|
|
|
|
global_state = Munch()
|
|
g = global_state
|
|
g.connection = False
|
|
g.name = None
|
|
g.mcdata = False
|
|
g.pos = False
|
|
g.dimension = None
|
|
g.item_lock = False
|
|
g.inv = {}
|
|
g.objects = {}
|
|
g.mobs = {}
|
|
g.players = {}
|
|
g.player_names = {}
|
|
g.window = None
|
|
g.job = None
|
|
g.correction_count = 0
|
|
g.holding = 0
|
|
g.afk = False
|
|
g.health = 20
|
|
g.food = 20
|
|
g.sand_origin = None
|
|
|
|
@app.route('/api/global')
|
|
def api_global():
|
|
data = json.dumps(g, default=lambda o: str(o), indent=4)
|
|
|
|
response = app.response_class(
|
|
response=data,
|
|
status=200,
|
|
mimetype='application/json'
|
|
)
|
|
return response
|
|
|
|
@app.route('/')
|
|
def root():
|
|
return app.send_static_file('index.html')
|
|
|
|
reload_timeout = time.time()
|
|
|
|
def main():
|
|
def reload_bot(event):
|
|
global reload_timeout
|
|
if time.time() - reload_timeout > 2.0:
|
|
reload_timeout = time.time()
|
|
print('Reloading...')
|
|
g.running = False
|
|
|
|
event_handler = PatternMatchingEventHandler(patterns=['*.py'], ignore_patterns=['./main.py'])
|
|
event_handler.on_any_event = reload_bot
|
|
|
|
observer = Observer()
|
|
observer.schedule(event_handler, 'mosfet', recursive=True)
|
|
observer.start()
|
|
|
|
try:
|
|
while True:
|
|
try:
|
|
g.running = True
|
|
bot.bot(global_state)
|
|
importlib.reload(bot)
|
|
except BaseException as e:
|
|
g.running = True
|
|
traceback.print_exc()
|
|
print('Locking...')
|
|
while g.running:
|
|
time.sleep(1)
|
|
importlib.reload(bot)
|
|
except KeyboardInterrupt:
|
|
observer.stop()
|
|
observer.join()
|
|
|
|
|
|
if __name__ == '__main__':
|
|
host = '0.0.0.0'
|
|
port = 3300
|
|
|
|
threading.Thread(target=app.run, kwargs={'host': host, 'port': port}).start()
|
|
print('Web interface listening on port:', port)
|
|
print('Try going to http://localhost:' + str(port))
|
|
time.sleep(1)
|
|
|
|
main()
|