Merge pull request #9 from atrc445/fix-seed-db
make comments and private messages work without pusher api keyremotes/1693045480750635534/spooky-22
commit
70783d2ba0
|
@ -1,3 +1,6 @@
|
||||||
|
import traceback
|
||||||
|
import sys
|
||||||
|
|
||||||
from files.helpers.wrappers import *
|
from files.helpers.wrappers import *
|
||||||
from files.helpers.filters import *
|
from files.helpers.filters import *
|
||||||
from files.helpers.alerts import *
|
from files.helpers.alerts import *
|
||||||
|
@ -5,7 +8,7 @@ from files.helpers.images import *
|
||||||
from files.helpers.session import *
|
from files.helpers.session import *
|
||||||
from files.classes import *
|
from files.classes import *
|
||||||
from files.routes.front import comment_idlist
|
from files.routes.front import comment_idlist
|
||||||
from pusher_push_notifications import PushNotifications
|
from pusher_push_notifications import PushNotifications, PusherAuthError
|
||||||
|
|
||||||
from flask import *
|
from flask import *
|
||||||
from files.__main__ import app, limiter
|
from files.__main__ import app, limiter
|
||||||
|
@ -530,18 +533,23 @@ def api_comment(v):
|
||||||
except: g.db.rollback()
|
except: g.db.rollback()
|
||||||
|
|
||||||
if parent.author.id != v.id:
|
if parent.author.id != v.id:
|
||||||
beams_client.publish_to_interests(
|
try:
|
||||||
interests=[str(parent.author.id)],
|
beams_client.publish_to_interests(
|
||||||
publish_body={
|
interests=[str(parent.author.id)],
|
||||||
'web': {
|
publish_body={
|
||||||
'notification': {
|
'web': {
|
||||||
'title': f'New reply by @{v.username}',
|
'notification': {
|
||||||
'body': c.body,
|
'title': f'New reply by @{v.username}',
|
||||||
'deep_link': f'https://{site}{c.permalink}?context=5#context',
|
'body': c.body,
|
||||||
|
'deep_link': f'https://{site}{c.permalink}?context=5#context',
|
||||||
|
},
|
||||||
|
},
|
||||||
},
|
},
|
||||||
},
|
)
|
||||||
},
|
except PusherAuthError as e:
|
||||||
)
|
sys.stderr.write(traceback.format_exc())
|
||||||
|
sys.stderr.flush()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
@ -866,4 +874,4 @@ def unsave_comment(cid, v):
|
||||||
|
|
||||||
g.db.delete(save)
|
g.db.delete(save)
|
||||||
|
|
||||||
return "", 204
|
return "", 204
|
||||||
|
|
|
@ -1,6 +1,8 @@
|
||||||
import qrcode
|
import qrcode
|
||||||
import io
|
import io
|
||||||
import time
|
import time
|
||||||
|
import traceback
|
||||||
|
import sys
|
||||||
|
|
||||||
from files.classes.user import ViewerRelationship
|
from files.classes.user import ViewerRelationship
|
||||||
from files.helpers.alerts import *
|
from files.helpers.alerts import *
|
||||||
|
@ -9,7 +11,7 @@ from files.helpers.markdown import *
|
||||||
from files.mail import *
|
from files.mail import *
|
||||||
from flask import *
|
from flask import *
|
||||||
from files.__main__ import app, limiter
|
from files.__main__ import app, limiter
|
||||||
from pusher_push_notifications import PushNotifications
|
from pusher_push_notifications import PushNotifications, PusherAuthError
|
||||||
|
|
||||||
site = environ.get("DOMAIN").strip()
|
site = environ.get("DOMAIN").strip()
|
||||||
|
|
||||||
|
@ -142,18 +144,24 @@ def message2(v, username):
|
||||||
if existing: return redirect('/notifications?all=true')
|
if existing: return redirect('/notifications?all=true')
|
||||||
|
|
||||||
send_pm(v.id, user, message)
|
send_pm(v.id, user, message)
|
||||||
beams_client.publish_to_interests(
|
|
||||||
interests=[str(user.id)],
|
try:
|
||||||
publish_body={
|
beams_client.publish_to_interests(
|
||||||
'web': {
|
interests=[str(user.id)],
|
||||||
'notification': {
|
publish_body={
|
||||||
'title': f'New message from @{v.username}',
|
'web': {
|
||||||
'body': message,
|
'notification': {
|
||||||
'deep_link': f'https://{site}/notifications',
|
'title': f'New message from @{v.username}',
|
||||||
|
'body': message,
|
||||||
|
'deep_link': f'https://{site}/notifications',
|
||||||
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
)
|
||||||
)
|
except PusherAuthError as e:
|
||||||
|
sys.stderr.write(traceback.format_exc())
|
||||||
|
sys.stderr.flush()
|
||||||
|
|
||||||
return redirect('/notifications?all=true')
|
return redirect('/notifications?all=true')
|
||||||
|
|
||||||
@app.get("/2faqr/<secret>")
|
@app.get("/2faqr/<secret>")
|
||||||
|
@ -541,4 +549,4 @@ def saved_comments(v, username):
|
||||||
listing=listing,
|
listing=listing,
|
||||||
page=page,
|
page=page,
|
||||||
next_exists=next_exists,
|
next_exists=next_exists,
|
||||||
standalone=True)
|
standalone=True)
|
||||||
|
|
|
@ -1 +1 @@
|
||||||
INSERT INTO public.badge_defs VALUES (6, 'Beta User', 'Joined during open beta', 'beta.png', 4, 3, NULL);
|
INSERT INTO public.badge_defs VALUES (6, 'Beta User', 'Joined during open beta', 'beta.png', 4, 3, NULL);
|
||||||
|
|
Loading…
Reference in New Issue