Thread.py

import time

import requests
from PySide6.QtCore import QThread, Signal

from chaindb import UserClient, blockchain

ConfirmationScore = 5


class Thread(QThread):
    sigMsg = Signal(str)
    sigSendSuccess = Signal()

    def __init__(self, parent=None):
        super().__init__(parent)

        self.currentNonce = -1
        self.running = True

        self.msg = None

        self.chaindb = UserClient()

    def run(self):
        while True:
            if not self.running:
                break
            time.sleep(1)
            try:
                self.recv()
                self.send()
            except Exception as e:
                print(e)

    def recv(self):
        arr = self.chaindb.ListTransactionsOwnedBy(10086, confirmations=ConfirmationScore)
        arr.sort(key=lambda tx: tx.Transaction.Nonce)
        for tx in arr:
            if tx.Transaction.Nonce <= self.currentNonce:
                continue
            if tx.ConfirmationScore < ConfirmationScore:
                continue
            self.sigMsg.emit(tx.Transaction.Data)
            self.currentNonce = tx.Transaction.Nonce

    def send(self):
        if not self.msg:
            return

        if not self.chaindb.Insert(blockchain.Transaction(
                OwnerID=10086,
                Nonce=self.currentNonce + 1,
                Data=self.msg,
        ), confirmations=ConfirmationScore):
            return

        self.msg = None
        self.sigSendSuccess.emit()