mj-saunders
/
epicyon
forked from indymedia/epicyon
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Populate post cache when importing rss items

main
Bob Mottram 2020-10-08 13:13:42 +01:00
parent bd4db02b3a
commit 936b752a0e
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
newsdaemon.py
View File

@ -11,6 +11,7 @@ import time
from collections import OrderedDict from collections import OrderedDict
from newswire import getDictFromNewswire from newswire import getDictFromNewswire
from posts import createNewsPost from posts import createNewsPost
from inbox import inboxStorePostToHtmlCache
from utils import saveJson from utils import saveJson
from utils import getStatusNumber from utils import getStatusNumber
@ -42,7 +43,10 @@ def updateFeedsIndex(baseDir: str, domain: str, postId: str) -> None:
def convertRSStoActivityPub(baseDir: str, httpPrefix: str, def convertRSStoActivityPub(baseDir: str, httpPrefix: str,
domain: str, port: int, domain: str, port: int,
newswire: {}, newswire: {},
translate: {}) -> None: translate: {},
recentPostsCache: {}, maxRecentPosts: int,
session, cachedWebfingers: {},
personCache: {}) -> None:
"""Converts rss items in a newswire into posts """Converts rss items in a newswire into posts
""" """
basePath = baseDir + '/accounts/news@' + domain + '/outbox' basePath = baseDir + '/accounts/news@' + domain + '/outbox'
@ -120,6 +124,12 @@ def convertRSStoActivityPub(baseDir: str, httpPrefix: str,
# save the post and update the index # save the post and update the index
if saveJson(blog, filename): if saveJson(blog, filename):
updateFeedsIndex(baseDir, domain, postId + '.json') updateFeedsIndex(baseDir, domain, postId + '.json')
# convert json to html
inboxStorePostToHtmlCache(recentPostsCache, maxRecentPosts,
translate, baseDir, httpPrefix,
session, cachedWebfingers, personCache,
'news', domain, port,
blog, False, 'outbox')
newswire[originalDateStr][1] = '/@news/' + statusNumber newswire[originalDateStr][1] = '/@news/' + statusNumber
@ -151,7 +161,12 @@ def runNewswireDaemon(baseDir: str, httpd,
convertRSStoActivityPub(baseDir, convertRSStoActivityPub(baseDir,
httpPrefix, domain, port, httpPrefix, domain, port,
newNewswire, translate) newNewswire, translate,
httpd.recentPostsCache,
httpd.maxRecentPosts,
httpd.session,
httpd.cachedWebfingers,
httpd.personCache)
print('Newswire feed converted to ActivityPub') print('Newswire feed converted to ActivityPub')
# wait a while before the next feeds update # wait a while before the next feeds update