added exit function, changed notifications

This commit is contained in:
Spekulaas 2024-01-04 16:29:24 +01:00
parent f4a9c7ed2e
commit e4642d7a30

View File

@ -4,6 +4,7 @@ from classes.TxBlock import TxBlock
from helpers import DatabaseHelper as databaseHelper from helpers import DatabaseHelper as databaseHelper
from helpers import UtilityHelper as utilityHelper from helpers import UtilityHelper as utilityHelper
from helpers import BlockHelper as blockHelper
import socket import socket
import pickle import pickle
@ -59,7 +60,16 @@ def connection(ip, port, db):
if type(item) == TxBlock: if type(item) == TxBlock:
print(f"{utilityHelper.blinkMessage('Received block from peer')}") print(f"{utilityHelper.blinkMessage('Received block from peer')}")
utilityHelper.addFile("../data/ledger.dat", item) valid, exit = blockHelper.socketBlock(item)
if not valid:
print(f"{utilityHelper.errorMessage('Received block is not valid')}")
continue
if exit:
print(f"{utilityHelper.errorMessage('Closing connection and application')}")
exit()
continue
continue continue
# DATABASE STUFF # DATABASE STUFF
@ -67,10 +77,12 @@ def connection(ip, port, db):
match item[0]: match item[0]:
case "USER CREATE": case "USER CREATE":
print(f"{utilityHelper.blinkMessage('Received user from peer')}")
db.createUser(item[1], item[2], item[3], item[4]) db.createUser(item[1], item[2], item[3], item[4])
continue continue
case "USER DELETE": case "USER DELETE":
print(f"{utilityHelper.blinkMessage('Peer deleted user')}")
db.deleteUser(item[1]) db.deleteUser(item[1])
continue continue
@ -89,3 +101,9 @@ def connection(ip, port, db):
case "UPDATE LOG STATUS": case "UPDATE LOG STATUS":
db.updateLogStatus(item[1]) db.updateLogStatus(item[1])
continue continue
if type(item) == str:
match item:
case "EXIT":
exit()
continue