Merge branch 'neo-tx-unspent' into development

neo/Core/Blockchain.py

@@ -384,6 +384,10 @@ def GetUnspent(self, hash, index):
         # abstract
         pass
 
+    def GetAllUnspent(self, hash):
+        # abstract
+        pass
+
     def GetVotes(self, transactions):
         # abstract
         pass

neo/Core/State/UnspentCoinState.py

@@ -22,22 +22,22 @@ def FromTXOutputsConfirmed(outputs):
         uns = UnspentCoinState()
         uns.Items = [0] * len(outputs)
         for i in range(0, len(outputs)):
-            uns.Items[i] = CoinState.Confirmed
+            uns.Items[i] = int(CoinState.Confirmed)
         return uns
 
     def Size(self):
         return super(UnspentCoinState, self).Size() + sys.getsizeof(self.Items)
 
+    @property
     def IsAllSpent(self):
         for item in self.Items:
-            if item & CoinState.Spent > 0:
+            if item == CoinState.Confirmed:
                 return False
         return True
 
     def OrEqValueForItemAt(self, index, value):
 
         length = len(self.Items)
-
         while length < index + 1:
             self.Items.append(0)
             length = len(self.Items)
@@ -50,7 +50,7 @@ def Deserialize(self, reader):
         blen = reader.ReadVarInt()
         self.Items = [0] * blen
         for i in range(0, blen):
-            self.Items[i] = reader.ReadByte()
+            self.Items[i] = int.from_bytes(reader.ReadByte(do_ord=False), 'little')
 
     @staticmethod
     def DeserializeFromDB(buffer):
@@ -68,4 +68,6 @@ def Serialize(self, writer):
 
         writer.WriteVarInt(len(self.Items))
 
-        [writer.WriteByte(item) for item in self.Items]
+        for item in self.Items:
+            byt = item.to_bytes(1, 'little')
+            writer.WriteByte(byt)

neo/Implementations/Blockchains/LevelDB/LevelDBBlockchain.py

@@ -265,6 +265,28 @@ def GetSpentCoins(self, tx_hash):
 
         return result
 
+    def GetUnspent(self, hash, index):
+        # abstract
+        pass
+
+    def GetAllUnspent(self, hash):
+
+        unspents = []
+
+        sn = self._db.snapshot()
+        unspentcoins = DBCollection(self._db, sn, DBPrefix.ST_Coin, UnspentCoinState)
+
+        state = unspentcoins.TryGet(keyval=hash.ToBytes())
+
+        if state:
+            tx, height = self.GetTransaction(hash)
+
+            for index, item in enumerate(state.Items):
+                if item & CoinState.Spent == 0:
+                    unspents.append(tx.outputs[index])
+
+        return unspents
+
     def GetUnclaimed(self, hash):
 
         tx, height = self.GetTransaction(hash)
@@ -675,7 +697,8 @@ def Persist(self, block):
 
             # filte out unspent coins to delete then commit
             for key, unspent in unspentcoins.Current.items():
-                unspentcoins.Remove(key)
+                if unspent.IsAllSpent:
+                    unspentcoins.Remove(key)
             unspentcoins.Commit(wb)
 
             # filter out spent coins to delete then commit to db

neo/SmartContract/ApplicationEngine.py

@@ -275,7 +275,10 @@ def GetPriceForSysCall(self):
         elif api == "Neo.Blockchain.GetContract":
             return 100
 
-        elif api == "Neo.Blockchain.GetReferences":
+        elif api == "Neo.Transaction.GetReferences":
+            return 200
+
+        elif api == "Neo.Transaction.GetUnspentCoins":
             return 200
 
         elif api == "Neo.Account.SetVotes":

neo/SmartContract/StateReader.py

@@ -20,6 +20,7 @@
 from neo.SmartContract.TriggerType import Application, Verification
 
 from neo.VM.InteropService import StackItem, stack_item_to_py
+import json
 
 
 class StateReader(InteropService):
@@ -74,6 +75,7 @@ def __init__(self):
         self.Register("Neo.Transaction.GetInputs", self.Transaction_GetInputs)
         self.Register("Neo.Transaction.GetOutputs", self.Transaction_GetOutputs)
         self.Register("Neo.Transaction.GetReferences", self.Transaction_GetReferences)
+        self.Register("Neo.Transaction.GetUnspentCoins", self.Transaction_GetUnspentCoins)
 
         self.Register("Neo.Attribute.GetData", self.Attribute_GetData)
         self.Register("Neo.Attribute.GetUsage", self.Attribute_GetUsage)
@@ -568,6 +570,18 @@ def Transaction_GetReferences(self, engine):
         engine.EvaluationStack.PushT(refs)
         return True
 
+    def Transaction_GetUnspentCoins(self, engine):
+
+        tx = engine.EvaluationStack.Pop().GetInterface()
+
+        if tx is None:
+            return False
+
+        refs = [StackItem.FromInterface(unspent) for unspent in Blockchain.Default().GetAllUnspent(tx.Hash)]
+
+        engine.EvaluationStack.PushT(refs)
+        return True
+
     def Attribute_GetUsage(self, engine):
 
         attr = engine.EvaluationStack.Pop().GetInterface()