Padra/oracle/worker/bearer.py

import socket
import threading
import config as cfg
from .worker import Worker
class Bearer(Worker):

    def __init__(self, parent):
        super().__init__(self,parent)
        print("\n\n Bearer \n\n")

    def socketOracle(self,HOST,PORT):
        self.connector = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connector.connect((HOST, PORT))

        t = threading.Thread(target=self.receive)
        t.start()
        self.toSEND({
            "type":"oracleInit",
            "oracle":"Bearer"
        })
        print("socket is created and Listener is created\n")

    def start(self,a):
        print("Bearer",a)
        self.socketOracle(self.connectorIP,self.connectorPort)