|
|
@ -157,7 +157,6 @@ class ChangeDetectionStore:
|
|
|
|
def data(self):
|
|
|
|
def data(self):
|
|
|
|
|
|
|
|
|
|
|
|
has_unviewed = False
|
|
|
|
has_unviewed = False
|
|
|
|
|
|
|
|
|
|
|
|
for uuid, v in self.__data['watching'].items():
|
|
|
|
for uuid, v in self.__data['watching'].items():
|
|
|
|
self.__data['watching'][uuid]['newest_history_key'] = self.get_newest_history_key(uuid)
|
|
|
|
self.__data['watching'][uuid]['newest_history_key'] = self.get_newest_history_key(uuid)
|
|
|
|
if int(v['newest_history_key']) <= int(v['last_viewed']):
|
|
|
|
if int(v['newest_history_key']) <= int(v['last_viewed']):
|
|
|
@ -271,8 +270,8 @@ class ChangeDetectionStore:
|
|
|
|
if self.stop_thread:
|
|
|
|
if self.stop_thread:
|
|
|
|
print("Shutting down datastore thread")
|
|
|
|
print("Shutting down datastore thread")
|
|
|
|
return
|
|
|
|
return
|
|
|
|
|
|
|
|
|
|
|
|
if self.needs_write:
|
|
|
|
if self.needs_write:
|
|
|
|
self.sync_to_json()
|
|
|
|
self.sync_to_json()
|
|
|
|
|
|
|
|
|
|
|
|
time.sleep(3)
|
|
|
|
time.sleep(3)
|
|
|
|
|
|
|
|
|
|
|
|