diff --git a/chainsyncer/store/fs.py b/chainsyncer/store/fs.py index 47c110d..9ebe20c 100644 --- a/chainsyncer/store/fs.py +++ b/chainsyncer/store/fs.py @@ -236,9 +236,9 @@ class SyncFsStore: self.item_keys.append(block_number) logg.info('added existing {}'.format(o)) - fp = os.path.join(self.session_path, str(target)) + fp = os.path.join(self.session_path, 'target') if len(thresholds) == 0: - logg.info('syncer first run') + logg.info('syncer first run target {}'.format(target)) self.first = True f = open(fp, 'w') f.write(str(target)) diff --git a/tests/test_fs.py b/tests/test_fs.py index 2ecf26b..70f0559 100644 --- a/tests/test_fs.py +++ b/tests/test_fs.py @@ -203,5 +203,20 @@ class TestFs(unittest.TestCase): o = store.get(2) + def test_sync_history_interrupted(self): + store = SyncFsStore(self.path, session_id='foo') + session = SyncSession(store) + + session.start(target=13) + o = session.get(0) + o.next(advance_block=True) + o.next(advance_block=True) + session.stop(o) + + store = SyncFsStore(self.path, session_id='foo') + store.start() + o = store.get(0) + + if __name__ == '__main__': unittest.main()