chaintool/chainsyncer
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Move filter registration to session store

Browse Source
This commit is contained in:
lash 2022-03-18 00:02:18 +00:00
parent 18f16d878f
commit 78bd6ca538
Signed by: lash
GPG Key ID: 21D2E7BB88C2A746
6 changed files with 29 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
chainsyncer/session.py
View File

@ -14,13 +14,14 @@ class SyncSession:
self.get = self.session_store.get
self.next = self.session_store.next_item
self.item = None
self.filters = self.session_store.filters
def register(self, fltr):
if self.started:
raise RuntimeError('filters cannot be changed after syncer start')
self.session_store.register(fltr)
self.filters.append(fltr)
# def register(self, fltr):
# if self.started:
# raise RuntimeError('filters cannot be changed after syncer start')
# self.session_store.register(fltr)
# self.filters.append(fltr)
def start(self, offset=0, target=-1):

4
chainsyncer/state/base.py
View File

@ -84,3 +84,7 @@ class SyncState:
def next_item(self):
return None
def filters(self):
return []

7
chainsyncer/store/fs.py
View File

@ -151,9 +151,14 @@ class SyncFsStore:
factory = SimpleFileStoreFactory(base_filter_path, binary=True)
filter_state_backend = PersistedState(factory.add, 0, check_alias=False)
self.filter_state = SyncState(filter_state_backend)
self.register = self.filter_state.register
self.filters = []
def register(self, fltr):
self.filters.append(fltr)
self.filter_state.register(fltr)
def __create_path(self, base_path, default_path, session_id=None):
logg.debug('fs store path {} does not exist, creating'.format(self.session_path))
if session_id == None:

8
tests/test_filter.py
View File

@ -41,9 +41,9 @@ class TestFilter(unittest.TestCase):
def test_filter_basic(self):
fltr_one = MockFilter('foo')
self.session.register(fltr_one)
self.store.register(fltr_one)
fltr_two = MockFilter('bar')
self.session.register(fltr_two)
self.store.register(fltr_two)
tx_hash = os.urandom(32).hex()
tx = MockTx(42, tx_hash)
@ -57,9 +57,9 @@ class TestFilter(unittest.TestCase):
def test_filter_interrupt(self):
fltr_one = MockFilter('foo', brk=True)
self.session.register(fltr_one)
self.store.register(fltr_one)
fltr_two = MockFilter('bar')
self.session.register(fltr_two)
self.store.register(fltr_two)
tx_hash = os.urandom(32).hex()
tx = MockTx(42, tx_hash)

16
tests/test_fs.py
View File

@ -95,7 +95,7 @@ class TestFs(unittest.TestCase):
session = SyncSession(store)
fltr_one = MockFilter('foo')
session.register(fltr_one)
store.register(fltr_one)
session.start()
o = session.get(0)
@ -108,9 +108,9 @@ class TestFs(unittest.TestCase):
session = SyncSession(store)
fltr_one = MockFilter('foo')
session.register(fltr_one)
store.register(fltr_one)
fltr_two = MockFilter('two')
session.register(fltr_two)
store.register(fltr_two)
session.start()
o = session.get(0)
@ -131,9 +131,9 @@ class TestFs(unittest.TestCase):
session = SyncSession(store)
fltr_one = MockFilter('foo')
session.register(fltr_one)
store.register(fltr_one)
fltr_two = MockFilter('bar')
session.register(fltr_two)
store.register(fltr_two)
session.start()
o = session.get(0)
@ -148,9 +148,9 @@ class TestFs(unittest.TestCase):
session = SyncSession(store)
fltr_one = MockFilter('foo')
session.register(fltr_one)
store.register(fltr_one)
fltr_two = MockFilter('bar')
session.register(fltr_two)
store.register(fltr_two)
session.start()
o = session.get(0)
@ -175,7 +175,7 @@ class TestFs(unittest.TestCase):
session = SyncSession(store)
fltr_one = MockFilter('foo')
session.register(fltr_one)
store.register(fltr_one)
session.start(target=0)
o = session.get(0)

2
tests/test_session.py
View File

@ -43,7 +43,7 @@ class TestFilter(unittest.TestCase):
session = SyncSession(self.store)
session.start(target=1)
fltr_one = MockFilter('foo')
session.register(fltr_one)
self.store.register(fltr_one)
tx_hash = os.urandom(32).hex()
tx = MockTx(42, tx_hash)