X-Git-Url: https://git.novaco.in/?p=stratum-mining.git;a=blobdiff_plain;f=lib%2Fhalfnode.py;fp=lib%2Fhalfnode.py;h=d46ff75cb7760a9bbde42e0d4472e66593e36125;hp=233a5c181c5283a32efa2f3f8cfd5dc2c5b606b0;hb=23ebc8506325ec4b8a60ce3c49cab96ae87c006b;hpb=8a7474eb0eefdbc68e9b57371a68c25f33427f0d

diff --git a/lib/halfnode.py b/lib/halfnode.py
index 233a5c1..d46ff75 100644
--- a/lib/halfnode.py
+++ b/lib/halfnode.py
@@ -145,12 +145,12 @@ class CTransaction(object):
         r += ser_vector(self.vout)
         r += struct.pack("<I", self.nLockTime)
         return r
-    
+
     def calc_sha256(self):
         if self.sha256 is None:
             self.sha256 = uint256_from_str(SHA256.new(SHA256.new(self.serialize()).digest()).digest())
         return self.sha256
-    
+
     def is_valid(self):
         self.calc_sha256()
         for tout in self.vout:
@@ -212,14 +212,14 @@ class CBlock(object):
                 return False
             tx.calc_sha256()
             hashes.append(ser_uint256(tx.sha256))
-        
+
         while len(hashes) > 1:
             newhashes = []
             for i in xrange(0, len(hashes), 2):
                 i2 = min(i+1, len(hashes)-1)
                 newhashes.append(SHA256.new(SHA256.new(hashes[i] + hashes[i2]).digest()).digest())
             hashes = newhashes
-        
+
         if uint256_from_str(hashes[0]) != self.hashMerkleRoot:
             return False
         return True
@@ -237,7 +237,7 @@ class msg_version(object):
         self.nNonce = random.getrandbits(64)
         self.strSubVer = MY_SUBVERSION
         self.nStartingHeight = 0
-        
+
     def deserialize(self, f):
         self.nVersion = struct.unpack("<i", f.read(4))[0]
         if self.nVersion == 10300:
@@ -380,7 +380,7 @@ class msg_alert(object):
         return ""
     def __repr__(self):
         return "msg_alert()"
-    
+
 class BitcoinP2PProtocol(Protocol):
     messagemap = {
         "version": msg_version,
@@ -395,14 +395,14 @@ class BitcoinP2PProtocol(Protocol):
         "ping": msg_ping,
         "alert": msg_alert,
     }
-   
+
     def connectionMade(self):
         peer = self.transport.getPeer()
         self.dstaddr = peer.host
         self.dstport = peer.port
         self.recvbuf = ""
         self.last_sent = 0
- 
+
         t = msg_version()
         t.nStartingHeight = getattr(self, 'nStartingHeight', 0)
         t.addrTo.ip = self.dstaddr
@@ -412,11 +412,11 @@ class BitcoinP2PProtocol(Protocol):
         t.addrFrom.port = 0
         t.addrFrom.nTime = time.time()
         self.send_message(t)
-        
+
     def dataReceived(self, data):
         self.recvbuf += data
         self.got_data()
-        
+
     def got_data(self):
         while True:
             if len(self.recvbuf) < 4:
@@ -445,8 +445,8 @@ class BitcoinP2PProtocol(Protocol):
                 self.got_message(t)
             else:
                 print "UNKNOWN COMMAND", command, repr(msg)
-                
-    def prepare_message(self, message):       
+
+    def prepare_message(self, message):
         command = message.command
         data = message.serialize()
         tmsg = "\xf9\xbe\xb4\xd9"
@@ -458,20 +458,20 @@ class BitcoinP2PProtocol(Protocol):
         tmsg += h[:4]
         tmsg += data
         return tmsg
-    
+
     def send_serialized_message(self, tmsg):
         if not self.connected:
             return
-        
+
         self.transport.write(tmsg)
-        self.last_sent = time.time()       
-        
+        self.last_sent = time.time()
+
     def send_message(self, message):
         if not self.connected:
             return
-        
+
         #print message.command
-        
+
         #print "send %s" % repr(message)
         command = message.command
         data = message.serialize()
@@ -483,11 +483,11 @@ class BitcoinP2PProtocol(Protocol):
         h = SHA256.new(th).digest()
         tmsg += h[:4]
         tmsg += data
-        
+
         #print tmsg, len(tmsg)
         self.transport.write(tmsg)
         self.last_sent = time.time()
-        
+
     def got_message(self, message):
         if self.last_sent + 30 * 60 < time.time():
             self.send_message(msg_ping())