ask for more headers when all caught up.

neo/IO/BinaryReader.py

@@ -139,7 +139,7 @@ def Read2000256List(self):
         return items
 
     def ReadHashes(self, maximum=16):
-        len = self.ReadUInt8()
+        len = self.ReadVarInt()
         items = []
         for i in range(0, len):
             ba = bytearray(self.ReadBytes(32))

neo/IO/BinaryWriter.py

@@ -12,6 +12,8 @@
 from autologging import logged
 from neo.UInt160 import UInt160
 from neo.UInt256 import UInt256
+import sys,os
+import inspect
 
 def swap32(i):
     return struct.unpack("<I", struct.pack(">I", i))[0]
@@ -48,7 +50,6 @@ def WriteBytes(self, value):
         self.stream.write(value)
 
     def pack(self, fmt, data):
-        byts = struct.pack(fmt, data)
         return self.WriteBytes(struct.pack(fmt, data))
 
     def WriteChar(self, value, endian="<"):
@@ -64,6 +65,7 @@ def WriteInt8(self, value, endian="<"):
         return self.pack('%sb' % endian, value)
 
     def WriteUInt8(self, value, endian="<"):
+        print("writing uint 8 %s " % value)
         return self.pack('%sB' % endian, value)
 
     def WriteBool(self, value, endian="<"):
@@ -169,7 +171,7 @@ def Write2000256List(self, arr):
 
     def WriteHashes(self, arr):
         length = len(arr)
-        self.WriteUInt8(length)
+        self.WriteVarInt(length)
         for item in arr:
             ba = bytearray(binascii.unhexlify(item))
             ba.reverse()

neo/Implementations/Blockchains/LevelDB/LevelDBBlockchain.py

@@ -200,10 +200,18 @@ def ShowAllContracts(self):
 
     def GetContract(self, hash):
 
+        if type(hash) is str:
+            try:
+                hash = hash.encode('utf-8')
+            except Exception as e:
+                self.__log.debug("could not convert argument to bytes :%s " % e)
+                return None
+
         sn = self._db.snapshot()
         contracts = DBCollection(self._db, sn, DBPrefix.ST_Contract, ContractState)
+        contract = contracts.TryGet(keyval=hash)
         sn.close()
-        return contracts.TryGet(keyval=hash)
+        return contract
 
 
     def GetAllSpentCoins(self):

neo/Network/NeoNode.py

@@ -246,6 +246,7 @@ def DoAskForMoreBlocks(self):
             self.SendSerializedMessage(message)
         else:
             self.Log("all caught up!!!!!! hashes is zero")
+            self.AskForMoreHeaders()
             reactor.callLater(20, self.DoAskForMoreBlocks)
 
     def RequestPeerInfo(self):

neo/SmartContract/StateMachine.py

@@ -7,20 +7,16 @@
 from neo.Core.State.ValidatorState import ValidatorState
 from neo.Core.AssetType import AssetType
 from neo.Cryptography.Crypto import Crypto
-from neo.Cryptography.ECCurve import EllipticCurve,ECDSA
+from neo.Cryptography.ECCurve import ECDSA
 from neo.UInt160 import UInt160
 from neo.UInt256 import UInt256
 from neo.Fixed8 import Fixed8
 from neo.VM.InteropService import StackItem
 from neo.SmartContract.StorageContext import StorageContext
 from neo.SmartContract.StateReader import StateReader
-from neo.IO.BinaryReader import BinaryReader
-from neo.IO.BinaryWriter import BinaryWriter
-from neo.IO.MemoryStream import StreamManager
 
 import sys
 import json
-import binascii
 
 from autologging import logged
 
@@ -143,21 +139,24 @@ def Account_SetVotes(self, engine):
         balance = account.BalanceFor( Blockchain.SystemShare().Hash)
 
         if balance == Fixed8.Zero() and len(vote_list) > 0:
+            print("no balance, return false!")
             return False
 
-#       disable setting votes for now until further testing to make sure we're not duplicating votes
-#
-#        acct = self._accounts.GetAndChange(account.AddressBytes)
-#        voteset = set()
-#        for v in vote_list:
-#            voteset.add(v.GetByteArray())
-#        acct.Votes = list(voteset)
-#        self.__log.debug("SET ACCOUNT VOTES %s " % json.dumps(acct.ToJson(), indent=4))
+        print("Setting votes!!!")
+
+        acct = self._accounts.GetAndChange(account.AddressBytes)
+        voteset = set()
+        for v in vote_list:
+            voteset.add(v.GetByteArray())
+        acct.Votes = list(voteset)
+        print("*****************************************************")
+        print("SET ACCOUNT VOTES %s " % json.dumps(acct.ToJson(), indent=4))
+        print("*****************************************************")
         return True
 
 
     def Validator_Register(self, engine):
-        #Not Implemented
+
         pubkey = ECDSA.decode_secp256r1( engine.EvaluationStack.Pop().GetByteArray())
         if pubkey.IsInfinity:
             return False
@@ -234,6 +233,9 @@ def Asset_Create(self, engine):
 
         asset = self._assets.GetOrAdd(tx.Hash.ToBytes(), new_asset)
 
+        print("*****************************************************")
+        print("CREATED ASSET %s " % tx.Hash.ToBytes())
+        print("*****************************************************")
         engine.EvaluationStack.PushT(StackItem.FromInterface(asset))
 
         return True
@@ -317,6 +319,10 @@ def Contract_Create(self, engine):
             self._contracts_created[hash.ToBytes()] = UInt160( data = engine.CurrentContext.ScriptHash())
 
         engine.EvaluationStack.PushT(StackItem.FromInterface(contract))
+
+        print("*****************************************************")
+        print("CREATED CONTRACT %s " % hash.ToBytes())
+        print("*****************************************************")
         return True
 
 
@@ -381,6 +387,11 @@ def Contract_Migrate(self, engine):
                     self._storages.Add(key, item)
 
         engine.EvaluationStack.PushT(StackItem.FromInterface(contract))
+
+        print("*****************************************************")
+        print("MIGRATED CONTRACT %s " % hash.ToBytes())
+        print("*****************************************************")
+
         return True
 
     def Contract_GetStorageContext(self, engine):

protocol.mainnet.json

@@ -30,7 +30,7 @@
     }
   },
   "ApplicationConfiguration": {
-    "DataDirectoryPath": "./Chains/Chain1",
+    "DataDirectoryPath": "./Chains/ChainMainYo",
     "NodePort": 10333,
     "WsPort": 10334,
     "UriPrefix": [ "http://*:10332" ],