__filename__ = "blog.py" __author__ = "Bob Mottram" __license__ = "AGPL3+" __version__ = "1.1.0" __maintainer__ = "Bob Mottram" __email__ = "bob@freedombone.net" __status__ = "Production" import os from datetime import datetime from content import replaceEmojiFromTags from webinterface import getIconsDir from webinterface import getPostAttachmentsAsHtml from webinterface import htmlHeader from webinterface import htmlFooter from webinterface import addEmbeddedElements from utils import getNicknameFromActor from utils import getDomainFromActor from utils import locatePost from utils import loadJson from posts import createBlogsTimeline from newswire import rss2Header from newswire import rss2Footer def noOfBlogReplies(baseDir: str, httpPrefix: str, translate: {}, nickname: str, domain: str, domainFull: str, postId: str, depth=0) -> int: """Returns the number of replies on the post This is recursive, so can handle replies to replies """ if depth > 4: return 0 if not postId: return 0 tryPostBox = ('tlblogs', 'inbox', 'outbox') boxFound = False for postBox in tryPostBox: postFilename = baseDir + '/accounts/' + \ nickname + '@' + domain + '/' + postBox + '/' + \ postId.replace('/', '#') + '.replies' if os.path.isfile(postFilename): boxFound = True break if not boxFound: # post may exist but has no replies for postBox in tryPostBox: postFilename = baseDir + '/accounts/' + \ nickname + '@' + domain + '/' + postBox + '/' + \ postId.replace('/', '#') if os.path.isfile(postFilename): return 1 return 0 removals = [] replies = 0 lines = [] with open(postFilename, "r") as f: lines = f.readlines() for replyPostId in lines: replyPostId = replyPostId.replace('\n', '').replace('\r', '') replyPostId = replyPostId.replace('.json', '') if locatePost(baseDir, nickname, domain, replyPostId): replyPostId = replyPostId.replace('.replies', '') replies += 1 + noOfBlogReplies(baseDir, httpPrefix, translate, nickname, domain, domainFull, replyPostId, depth+1) else: # remove post which no longer exists removals.append(replyPostId) # remove posts from .replies file if they don't exist if lines and removals: print('Rewriting ' + postFilename + ' to remove ' + str(len(removals)) + ' entries') with open(postFilename, 'w+') as f: for replyPostId in lines: replyPostId = replyPostId.replace('\n', '').replace('\r', '') if replyPostId not in removals: f.write(replyPostId + '\n') return replies def getBlogReplies(baseDir: str, httpPrefix: str, translate: {}, nickname: str, domain: str, domainFull: str, postId: str, depth=0) -> str: """Returns a string containing html blog posts """ if depth > 4: return '' if not postId: return '' tryPostBox = ('tlblogs', 'inbox', 'outbox') boxFound = False for postBox in tryPostBox: postFilename = baseDir + '/accounts/' + \ nickname + '@' + domain + '/' + postBox + '/' + \ postId.replace('/', '#') + '.replies' if os.path.isfile(postFilename): boxFound = True break if not boxFound: # post may exist but has no replies for postBox in tryPostBox: postFilename = baseDir + '/accounts/' + \ nickname + '@' + domain + '/' + postBox + '/' + \ postId.replace('/', '#') + '.json' if os.path.isfile(postFilename): postFilename = baseDir + '/accounts/' + \ nickname + '@' + domain + \ '/postcache/' + \ postId.replace('/', '#') + '.html' if os.path.isfile(postFilename): with open(postFilename, "r") as postFile: return postFile.read() + '\n' return '' with open(postFilename, "r") as f: lines = f.readlines() repliesStr = '' for replyPostId in lines: replyPostId = replyPostId.replace('\n', '').replace('\r', '') replyPostId = replyPostId.replace('.json', '') replyPostId = replyPostId.replace('.replies', '') postFilename = baseDir + '/accounts/' + \ nickname + '@' + domain + \ '/postcache/' + \ replyPostId.replace('/', '#') + '.html' if not os.path.isfile(postFilename): continue with open(postFilename, "r") as postFile: repliesStr += postFile.read() + '\n' rply = getBlogReplies(baseDir, httpPrefix, translate, nickname, domain, domainFull, replyPostId, depth+1) if rply not in repliesStr: repliesStr += rply # indicate the reply indentation level indentStr = '>' for indentLevel in range(depth): indentStr += ' >' repliesStr = repliesStr.replace(translate['SHOW MORE'], indentStr) return repliesStr.replace('?tl=outbox', '?tl=tlblogs') return '' def htmlBlogPostContent(authorized: bool, baseDir: str, httpPrefix: str, translate: {}, nickname: str, domain: str, domainFull: str, postJsonObject: {}, handle: str, restrictToDomain: bool, blogSeparator='
' + translate['About the author'] + \ '
\n' replies = noOfBlogReplies(baseDir, httpPrefix, translate, nickname, domain, domainFull, postJsonObject['object']['id']) # separator between blogs should be centered if '' + \ translate['Replies'].lower() + ': ' + str(replies) + '
' blogStr += '' blogStr += '' blogStr += '' # blogStr += '' # blogStr += '' blogStr += '
' return blogStr + htmlFooter() return None def htmlBlogPage(authorized: bool, session, baseDir: str, httpPrefix: str, translate: {}, nickname: str, domain: str, port: int, noOfItems: int, pageNumber: int) -> str: """Returns a html blog page containing posts """ if ' ' in nickname or '@' in nickname or \ '\n' in nickname or '\r' in nickname: return None blogStr = '' cssFilename = baseDir + '/epicyon-profile.css' if os.path.isfile(baseDir + '/epicyon.css'): cssFilename = baseDir + '/epicyon.css' with open(cssFilename, 'r') as cssFile: blogCSS = cssFile.read() blogStr = htmlHeader(cssFilename, blogCSS) htmlBlogRemoveCwButton(blogStr, translate) blogsIndex = baseDir + '/accounts/' + \ nickname + '@' + domain + '/tlblogs.index' if not os.path.isfile(blogsIndex): return blogStr + htmlFooter() timelineJson = createBlogsTimeline(session, baseDir, nickname, domain, port, httpPrefix, noOfItems, False, pageNumber) if not timelineJson: return blogStr + htmlFooter() domainFull = domain if port: if port != 80 and port != 443: domainFull = domain + ':' + str(port) # show previous and next buttons if pageNumber is not None: iconsDir = getIconsDir(baseDir) navigateStr = '' if pageNumber > 1: # show previous button navigateStr += '' + \ '\n' if len(timelineJson['orderedItems']) >= noOfItems: # show next button navigateStr += '' + \ '\n' navigateStr += '
' blogStr += navigateStr for item in timelineJson['orderedItems']: if item['type'] != 'Create': continue blogStr += htmlBlogPostContent(authorized, baseDir, httpPrefix, translate, nickname, domain, domainFull, item, None, True) if len(timelineJson['orderedItems']) >= noOfItems: blogStr += navigateStr # show rss link blogStr += '' blogStr += '' blogStr += '' # blogStr += '' # blogStr += '' blogStr += '
' return blogStr + htmlFooter() return None def htmlBlogPageRSS2(authorized: bool, session, baseDir: str, httpPrefix: str, translate: {}, nickname: str, domain: str, port: int, noOfItems: int, pageNumber: int, includeHeader: bool) -> str: """Returns an RSS version 2 feed containing posts """ if ' ' in nickname or '@' in nickname or \ '\n' in nickname or '\r' in nickname: return None domainFull = domain if port: if port != 80 and port != 443: domainFull = domain + ':' + str(port) blogRSS2 = '' if includeHeader: blogRSS2 = rss2Header(httpPrefix, nickname, domainFull, 'Blog', translate) blogsIndex = baseDir + '/accounts/' + \ nickname + '@' + domain + '/tlblogs.index' if not os.path.isfile(blogsIndex): return blogRSS2 + rss2Footer() timelineJson = createBlogsTimeline(session, baseDir, nickname, domain, port, httpPrefix, noOfItems, False, pageNumber) if not timelineJson: if includeHeader: return blogRSS2 + rss2Footer() else: return blogRSS2 if pageNumber is not None: for item in timelineJson['orderedItems']: if item['type'] != 'Create': continue blogRSS2 += \ htmlBlogPostRSS2(authorized, baseDir, httpPrefix, translate, nickname, domain, domainFull, item, None, True) return blogRSS2 + rss2Footer() def htmlBlogPageRSS3(authorized: bool, session, baseDir: str, httpPrefix: str, translate: {}, nickname: str, domain: str, port: int, noOfItems: int, pageNumber: int) -> str: """Returns an RSS version 3 feed containing posts """ if ' ' in nickname or '@' in nickname or \ '\n' in nickname or '\r' in nickname: return None domainFull = domain if port: if port != 80 and port != 443: domainFull = domain + ':' + str(port) blogRSS3 = '' blogsIndex = baseDir + '/accounts/' + \ nickname + '@' + domain + '/tlblogs.index' if not os.path.isfile(blogsIndex): return blogRSS3 timelineJson = createBlogsTimeline(session, baseDir, nickname, domain, port, httpPrefix, noOfItems, False, pageNumber) if not timelineJson: return blogRSS3 if pageNumber is not None: for item in timelineJson['orderedItems']: if item['type'] != 'Create': continue blogRSS3 += \ htmlBlogPostRSS3(authorized, baseDir, httpPrefix, translate, nickname, domain, domainFull, item, None, True) return blogRSS3 def getBlogIndexesForAccounts(baseDir: str) -> {}: """ Get the index files for blogs for each account and add them to a dict """ blogIndexes = {} for subdir, dirs, files in os.walk(baseDir + '/accounts'): for acct in dirs: if '@' not in acct: continue if 'inbox@' in acct: continue accountDir = os.path.join(baseDir + '/accounts', acct) blogsIndex = accountDir + '/tlblogs.index' if os.path.isfile(blogsIndex): blogIndexes[acct] = blogsIndex return blogIndexes def noOfBlogAccounts(baseDir: str) -> int: """Returns the number of blog accounts """ ctr = 0 for subdir, dirs, files in os.walk(baseDir + '/accounts'): for acct in dirs: if '@' not in acct: continue if 'inbox@' in acct: continue accountDir = os.path.join(baseDir + '/accounts', acct) blogsIndex = accountDir + '/tlblogs.index' if os.path.isfile(blogsIndex): ctr += 1 return ctr def singleBlogAccountNickname(baseDir: str) -> str: """Returns the nickname of a single blog account """ for subdir, dirs, files in os.walk(baseDir + '/accounts'): for acct in dirs: if '@' not in acct: continue if 'inbox@' in acct: continue accountDir = os.path.join(baseDir + '/accounts', acct) blogsIndex = accountDir + '/tlblogs.index' if os.path.isfile(blogsIndex): return acct.split('@')[0] return None def htmlBlogView(authorized: bool, session, baseDir: str, httpPrefix: str, translate: {}, domain: str, port: int, noOfItems: int) -> str: """Show the blog main page """ blogStr = '' cssFilename = baseDir + '/epicyon-profile.css' if os.path.isfile(baseDir + '/epicyon.css'): cssFilename = baseDir + '/epicyon.css' with open(cssFilename, 'r') as cssFile: blogCSS = cssFile.read() blogStr = htmlHeader(cssFilename, blogCSS) if noOfBlogAccounts(baseDir) <= 1: nickname = singleBlogAccountNickname(baseDir) if nickname: return htmlBlogPage(authorized, session, baseDir, httpPrefix, translate, nickname, domain, port, noOfItems, 1) domainFull = domain if port: if port != 80 and port != 443: domainFull = domain + ':' + str(port) for subdir, dirs, files in os.walk(baseDir + '/accounts'): for acct in dirs: if '@' not in acct: continue if 'inbox@' in acct: continue accountDir = os.path.join(baseDir + '/accounts', acct) blogsIndex = accountDir + '/tlblogs.index' if os.path.isfile(blogsIndex): blogStr += '' blogStr += '' + acct + '' blogStr += '
' return blogStr + htmlFooter() return None def htmlEditBlog(mediaInstance: bool, translate: {}, baseDir: str, httpPrefix: str, path: str, pageNumber: int, nickname: str, domain: str, postUrl: str) -> str: """Edit a blog post after it was created """ postFilename = locatePost(baseDir, nickname, domain, postUrl) if not postFilename: print('Edit blog: Filename not found for ' + postUrl) return None postJsonObject = loadJson(postFilename) if not postJsonObject: print('Edit blog: json not loaded for ' + postFilename) return None iconsDir = getIconsDir(baseDir) editBlogText = '' + \ translate['Write your post text below.'] + '
' if os.path.isfile(baseDir + '/accounts/newpost.txt'): with open(baseDir + '/accounts/newpost.txt', 'r') as file: editBlogText = '' + file.read() + '
' cssFilename = baseDir + '/epicyon-profile.css' if os.path.isfile(baseDir + '/epicyon.css'): cssFilename = baseDir + '/epicyon.css' with open(cssFilename, 'r') as cssFile: editBlogCSS = cssFile.read() if httpPrefix != 'https': editBlogCSS = editBlogCSS.replace('https://', httpPrefix+'://') if '?' in path: path = path.split('?')[0] pathBase = path editBlogImageSection = '' dateAndLocation += \ '' dateAndLocation += '' dateAndLocation += '
' dateAndLocation += '