GlcoinCore/lndg
1
0
Fork 0
mirror of https://github.com/cryptosharks131/lndg.git synced 2026-08-13 12:33:04 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

version + rebal logging + grep logs

Browse source
This commit is contained in:
cryptosharks131 2025-06-04 20:47:02 -04:00
parent fedcbaf486
commit 7324b0326a
No known key found for this signature in database
GPG key ID: 0A50748567ADEB28
3 changed files with 33 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

2
gui/templates/base.html
View file

@ -114,7 +114,7 @@
<center><button id="toggleTheme" onclick="toggleTheme()">{% if request.COOKIES.darkmode == 'true' %}Light{%else%}Dark{% endif %} Theme</button></center>
</div>
<div class="w3-container w3-padding-small">
<center>LNDg v1.10.0</center>
<center>LNDg v1.10.1</center>
<center><a href="{% url 'logout' %}">Logout</a></center>
</div>
</div>

10
gui/views.py
View file

@ -231,6 +231,7 @@ def logs(request):
if request.method == 'GET':
try:
count = request.GET.get('tail', 20)
grep = request.GET.get('grep', None)
logfile = '/var/log/lndg-controller.log'
file_size = path.getsize(logfile)-2
if file_size == 0:
@ -240,7 +241,14 @@ def logs(request):
read_size = min(target_size, file_size)
with open(logfile, "rb") as reader:
reader.seek(-read_size, 2)
logs = [line.decode('utf-8') for line in reader.readlines()]
logs = []
for line in reader.readlines():
log_line = line.decode('utf-8')
if grep:
if str(grep) in log_line:
logs.append(log_line)
else:
logs.append(log_line)
return render(request, 'logs.html', {'logs': logs})
except Exception as e:
return render(request, 'error.html', {'error': str(e)})

39
rebalancer.py
View file

@ -416,22 +416,29 @@ def main():
else:
LocalSettings(key='AR-Workers', value='1').save()
worker_count = 1
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.create_task(update_worker_count())
while True:
shutdown_rebalancer = False
scheduled_rebalances = []
active_rebalances = []
if Rebalancer.objects.filter(status=1).exists():
unknown_errors = Rebalancer.objects.filter(status=1)
for unknown_error in unknown_errors:
unknown_error.status = 400
unknown_error.stop = datetime.now()
unknown_error.save()
loop.run_until_complete(start_queue(worker_count))
print(f"{datetime.now().strftime('%c')} : [Rebalancer] : Rebalancer successfully exited...sleeping for 20 seconds")
sleep(20)
try:
print(f"{datetime.now().strftime('%c')} : [Rebalancer] : Rebalancer initializing...")
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.create_task(update_worker_count())
while True:
shutdown_rebalancer = False
scheduled_rebalances = []
active_rebalances = []
if Rebalancer.objects.filter(status=1).exists():
unknown_errors = Rebalancer.objects.filter(status=1)
for unknown_error in unknown_errors:
unknown_error.status = 400
unknown_error.stop = datetime.now()
unknown_error.save()
loop.run_until_complete(start_queue(worker_count))
print(f"{datetime.now().strftime('%c')} : [Rebalancer] : Rebalancer successfully exited...sleeping for 20 seconds")
sleep(20)
except Exception as e:
error = str(e)
print(f"{datetime.now().strftime('%c')} : [Rebalancer] : Rebalancer loop error: {error}")
finally:
print(f"{datetime.now().strftime('%c')} : [Rebalancer] : Rebalancer loop has been terminated")
if __name__ == '__main__':
main()