chainqueue/entry.py

@@ -115,8 +115,7 @@ class QueueEntry:
     def fail(self, block, tx):
         if self.__match_state(self.store.NETWORK_ERROR):
             return
-        v = self.store.state(self.k)
+        self.store.set(self.k, self.store.NETWORK_ERROR)
-        self.store.change(self.k, v | self.store.NETWORK_ERROR, self.store.QUEUED)
         if self.store.cache:
             self.store.cache.set_block(self.tx_hash, block, tx)
 

chainqueue/store/base.py

@@ -1,14 +1,10 @@
 # standard imports
 import re
 import datetime
-import logging
 
 # local imports
 from chainqueue.cache import CacheTx
 from chainqueue.entry import QueueEntry
-from chainqueue.error import NotLocalTxError
-
-logg = logging.getLogger(__name__)
 
 
 def to_key(t, n, k):
@@ -43,7 +39,6 @@ class Store:
                 'modified',
                 ]:
             setattr(self, v, getattr(self.state_store, v))
-        self.state_store.sync()
 
 
     def put(self, v, cache_adapter=CacheTx):
@@ -61,10 +56,7 @@ class Store:
 
 
     def get(self, k):
-        try:
         s = self.index_store.get(k)
-        except FileNotFoundError:
-            raise NotLocalTxError(k)
         v = self.state_store.get(s)
         return (s, v,)
 

setup.cfg

@@ -4,7 +4,7 @@ version = 0.1.0
 description = Generic blockchain transaction queue control
 author = Louis Holbrook
 author_email = dev@holbrook.no
-url = https://gitlab.com/chaintool/chainqueue
+url = https://gitlab.com/chaintools/chainqueue
 keywords =
 	cic
 	cryptocurrency
@@ -29,11 +29,13 @@ python_requires = >= 3.6
 include_package_data = True
 packages = 
 	chainqueue
-	chainqueue.cache
+	chainqueue.db
+	chainqueue.db.models
+	chainqueue.sql
+	chainqueue.adapters
 	chainqueue.unittest
-	chainqueue.store
 	chainqueue.runnable
 
-#[options.entry_points]
+[options.entry_points]
-#console_scripts =
+console_scripts =
-#	chainqueue-list = chainqueue.runnable.list:main
+	chainqueue-list = chainqueue.runnable.list:main

tests/base_shep.py

@@ -2,7 +2,6 @@
 import tempfile
 import unittest
 import shutil
-import logging
 
 # external imports
 from shep.store.file import SimpleFileStoreFactory
@@ -20,7 +19,6 @@ from tests.common import (
         MockContentStore,
         )
 
-logg = logging.getLogger(__name__)
 
 class TestShepBase(unittest.TestCase):
 
@@ -32,7 +30,6 @@ class TestShepBase(unittest.TestCase):
         counter = MockCounter()
         chain_spec = ChainSpec('foo', 'bar', 42, 'baz')
         self.store = Store(chain_spec, self.state, content_store, counter)
-        logg.debug('using path {}'.format(self.path))
 
 
     def tearDown(self):

tests/test_entry.py

@@ -5,8 +5,6 @@ import unittest
 
 # external imports
 from hexathon import add_0x
-from chainlib.tx import Tx
-from chainlib.block import Block
 
 # local imports
 from chainqueue import QueueEntry
@@ -61,25 +59,5 @@ class TestEntry(TestShepBase):
         self.assertEqual(len(txs), 1)
 
 
-    def test_entry_change(self):
-        signed_tx = add_0x(os.urandom(128).hex())
-        nonce = 42
-        entry = QueueEntry(self.store, cache_adapter=MockCacheTokenTx)
-        tx_hash = entry.create(signed_tx)
-
-        block = Block()
-        block.number = 13
-        tx = Tx(None)
-        tx.index = 666
-
-        entry.readysend()
-        entry.reserve()
-        entry.sendfail()
-
-        entry = QueueEntry(self.store, tx_hash, cache_adapter=MockCacheTokenTx)
-        entry.load()
-        self.assertEqual(str(entry), tx_hash + ': SENDFAIL')
-       
-
 if __name__ == '__main__':
     unittest.main()

tests/test_shep.py

@@ -55,6 +55,5 @@ class TestShep(TestShepBase):
         self.store.put('bar', cache_adapter=MockCacheTokenTx)
 
 
-
 if __name__ == '__main__':
     unittest.main()