@@ -3,6 +3,7 @@ import threading
|
|||||||
import time
|
import time
|
||||||
import traceback
|
import traceback
|
||||||
import uuid
|
import uuid
|
||||||
|
from CodernityDB.database import RecordDeleted
|
||||||
|
|
||||||
from couchpotato import get_db
|
from couchpotato import get_db
|
||||||
from couchpotato.api import addApiView, addNonBlockApiView
|
from couchpotato.api import addApiView, addNonBlockApiView
|
||||||
@@ -270,11 +271,16 @@ class CoreNotifier(Notification):
|
|||||||
if init:
|
if init:
|
||||||
db = get_db()
|
db = get_db()
|
||||||
|
|
||||||
notifications = db.all('notification', with_doc = True)
|
notifications = db.all('notification')
|
||||||
|
|
||||||
for n in notifications:
|
for n in notifications:
|
||||||
if n['doc'].get('time') > (time.time() - 604800):
|
|
||||||
messages.append(n['doc'])
|
try:
|
||||||
|
doc = db.get('id', n.get('_id'))
|
||||||
|
if doc.get('time') > (time.time() - 604800):
|
||||||
|
messages.append(doc)
|
||||||
|
except RecordDeleted:
|
||||||
|
pass
|
||||||
|
|
||||||
return {
|
return {
|
||||||
'success': True,
|
'success': True,
|
||||||
|
|||||||
Reference in New Issue
Block a user