mirror of https://gitlab.com/bashrc2/epicyon
flake8 format
parent
128e431e9f
commit
a85baf08ed
205
manualapprove.py
205
manualapprove.py
|
|
@ -1,175 +1,190 @@
|
|||
__filename__="manualapprove.py"
|
||||
__author__="Bob Mottram"
|
||||
__license__="AGPL3+"
|
||||
__version__="1.1.0"
|
||||
__maintainer__="Bob Mottram"
|
||||
__email__="bob@freedombone.net"
|
||||
__status__="Production"
|
||||
__filename__ = "manualapprove.py"
|
||||
__author__ = "Bob Mottram"
|
||||
__license__ = "AGPL3+"
|
||||
__version__ = "1.1.0"
|
||||
__maintainer__ = "Bob Mottram"
|
||||
__email__ = "bob@freedombone.net"
|
||||
__status__ = "Production"
|
||||
|
||||
import os
|
||||
import json
|
||||
import time
|
||||
from follow import followedAccountAccepts
|
||||
from follow import followedAccountRejects
|
||||
from follow import removeFromFollowRequests
|
||||
from utils import loadJson
|
||||
from utils import saveJson
|
||||
|
||||
def manualDenyFollowRequest(session,baseDir: str, \
|
||||
|
||||
def manualDenyFollowRequest(session, baseDir: str,
|
||||
httpPrefix: str,
|
||||
nickname: str,domain: str,port: int, \
|
||||
denyHandle: str, \
|
||||
federationList: [], \
|
||||
sendThreads: [],postLog: [], \
|
||||
cachedWebfingers: {},personCache: {}, \
|
||||
debug: bool, \
|
||||
nickname: str, domain: str, port: int,
|
||||
denyHandle: str,
|
||||
federationList: [],
|
||||
sendThreads: [], postLog: [],
|
||||
cachedWebfingers: {}, personCache: {},
|
||||
debug: bool,
|
||||
projectVersion: str) -> None:
|
||||
"""Manually deny a follow request
|
||||
"""
|
||||
handle=nickname+'@'+domain
|
||||
accountsDir=baseDir+'/accounts/'+handle
|
||||
handle = nickname + '@' + domain
|
||||
accountsDir = baseDir + '/accounts/' + handle
|
||||
|
||||
# has this handle already been rejected?
|
||||
rejectedFollowsFilename=accountsDir+'/followrejects.txt'
|
||||
rejectedFollowsFilename = accountsDir + '/followrejects.txt'
|
||||
if os.path.isfile(rejectedFollowsFilename):
|
||||
if denyHandle in open(rejectedFollowsFilename).read():
|
||||
removeFromFollowRequests(baseDir,nickname,domain,denyHandle,debug)
|
||||
print(denyHandle+' has already been rejected as a follower of '+nickname)
|
||||
removeFromFollowRequests(baseDir, nickname, domain,
|
||||
denyHandle, debug)
|
||||
print(denyHandle + ' has already been rejected as a follower of ' +
|
||||
nickname)
|
||||
return
|
||||
|
||||
removeFromFollowRequests(baseDir,nickname,domain,denyHandle,debug)
|
||||
removeFromFollowRequests(baseDir, nickname, domain, denyHandle, debug)
|
||||
|
||||
# Store rejected follows
|
||||
rejectsFile=open(rejectedFollowsFilename, "a+")
|
||||
rejectsFile.write(denyHandle+'\n')
|
||||
rejectsFile = open(rejectedFollowsFilename, "a+")
|
||||
rejectsFile.write(denyHandle + '\n')
|
||||
rejectsFile.close()
|
||||
|
||||
denyNickname=denyHandle.split('@')[0]
|
||||
denyDomain=denyHandle.split('@')[1].replace('\n','')
|
||||
denyPort=port
|
||||
denyNickname = denyHandle.split('@')[0]
|
||||
denyDomain = denyHandle.split('@')[1].replace('\n', '')
|
||||
denyPort = port
|
||||
if ':' in denyDomain:
|
||||
denyPort=denyDomain.split(':')[1]
|
||||
denyDomain=denyDomain.split(':')[0]
|
||||
followedAccountRejects(session,baseDir,httpPrefix, \
|
||||
nickname,domain,port, \
|
||||
denyNickname,denyDomain,denyPort, \
|
||||
federationList, \
|
||||
sendThreads,postLog, \
|
||||
cachedWebfingers,personCache, \
|
||||
debug,projectVersion)
|
||||
denyPort = denyDomain.split(':')[1]
|
||||
denyDomain = denyDomain.split(':')[0]
|
||||
followedAccountRejects(session, baseDir, httpPrefix,
|
||||
nickname, domain, port,
|
||||
denyNickname, denyDomain, denyPort,
|
||||
federationList,
|
||||
sendThreads, postLog,
|
||||
cachedWebfingers, personCache,
|
||||
debug, projectVersion)
|
||||
|
||||
print('Follow request from '+denyHandle+' was denied.')
|
||||
print('Follow request from ' + denyHandle + ' was denied.')
|
||||
|
||||
def approveFollowerHandle(accountDir: str,approveHandle: str) -> None:
|
||||
|
||||
def approveFollowerHandle(accountDir: str, approveHandle: str) -> None:
|
||||
""" Record manually approved handles so that if they unfollow and then
|
||||
re-follow later then they don't need to be manually approved again
|
||||
"""
|
||||
approvedFilename=accountDir+'/approved.txt'
|
||||
approvedFilename = accountDir + '/approved.txt'
|
||||
if os.path.isfile(approvedFilename):
|
||||
if approveHandle not in open(approvedFilename).read():
|
||||
approvedFile=open(approvedFilename, "a+")
|
||||
approvedFile.write(approveHandle+'\n')
|
||||
approvedFile = open(approvedFilename, "a+")
|
||||
approvedFile.write(approveHandle + '\n')
|
||||
approvedFile.close()
|
||||
else:
|
||||
approvedFile=open(approvedFilename, "w+")
|
||||
approvedFile.write(approveHandle+'\n')
|
||||
approvedFile = open(approvedFilename, "w+")
|
||||
approvedFile.write(approveHandle + '\n')
|
||||
approvedFile.close()
|
||||
|
||||
def manualApproveFollowRequest(session,baseDir: str, \
|
||||
|
||||
def manualApproveFollowRequest(session, baseDir: str,
|
||||
httpPrefix: str,
|
||||
nickname: str,domain: str,port: int, \
|
||||
approveHandle: str, \
|
||||
federationList: [], \
|
||||
sendThreads: [],postLog: [], \
|
||||
cachedWebfingers: {},personCache: {}, \
|
||||
acceptedCaps: [], \
|
||||
debug: bool, \
|
||||
nickname: str, domain: str, port: int,
|
||||
approveHandle: str,
|
||||
federationList: [],
|
||||
sendThreads: [], postLog: [],
|
||||
cachedWebfingers: {}, personCache: {},
|
||||
acceptedCaps: [],
|
||||
debug: bool,
|
||||
projectVersion: str) -> None:
|
||||
"""Manually approve a follow request
|
||||
"""
|
||||
handle=nickname+'@'+domain
|
||||
print('Manual follow accept: '+handle+' approving follow request from '+approveHandle)
|
||||
accountDir=baseDir+'/accounts/'+handle
|
||||
approveFollowsFilename=accountDir+'/followrequests.txt'
|
||||
handle = nickname + '@' + domain
|
||||
print('Manual follow accept: ' + handle +
|
||||
' approving follow request from ' + approveHandle)
|
||||
accountDir = baseDir + '/accounts/' + handle
|
||||
approveFollowsFilename = accountDir + '/followrequests.txt'
|
||||
if not os.path.isfile(approveFollowsFilename):
|
||||
print('Manual follow accept: follow requests file '+approveFollowsFilename+' not found')
|
||||
print('Manual follow accept: follow requests file ' +
|
||||
approveFollowsFilename + ' not found')
|
||||
return
|
||||
# is the handle in the requests file?
|
||||
if approveHandle not in open(approveFollowsFilename).read():
|
||||
print('Manual follow accept: '+approveHandle+' not in requests file '+approveFollowsFilename)
|
||||
print('Manual follow accept: ' + approveHandle +
|
||||
' not in requests file ' + approveFollowsFilename)
|
||||
return
|
||||
|
||||
approvefilenew=open(approveFollowsFilename+'.new', 'w+')
|
||||
updateApprovedFollowers=False
|
||||
followActivityfilename=None
|
||||
approvefilenew = open(approveFollowsFilename + '.new', 'w+')
|
||||
updateApprovedFollowers = False
|
||||
followActivityfilename = None
|
||||
with open(approveFollowsFilename, 'r') as approvefile:
|
||||
for handleOfFollowRequester in approvefile:
|
||||
# is this the approved follow?
|
||||
if handleOfFollowRequester.startswith(approveHandle):
|
||||
handleOfFollowRequester=handleOfFollowRequester.replace('\n','')
|
||||
port2=port
|
||||
handleOfFollowRequester = \
|
||||
handleOfFollowRequester.replace('\n', '')
|
||||
port2 = port
|
||||
if ':' in handleOfFollowRequester:
|
||||
port2Str=handleOfFollowRequester.split(':')[1]
|
||||
port2Str = handleOfFollowRequester.split(':')[1]
|
||||
if port2Str.isdigit():
|
||||
port2=int(port2Str)
|
||||
requestsDir=accountDir+'/requests'
|
||||
followActivityfilename=requestsDir+'/'+handleOfFollowRequester+'.follow'
|
||||
port2 = int(port2Str)
|
||||
requestsDir = accountDir + '/requests'
|
||||
followActivityfilename = \
|
||||
requestsDir + '/' + handleOfFollowRequester + '.follow'
|
||||
if os.path.isfile(followActivityfilename):
|
||||
followJson=loadJson(followActivityfilename)
|
||||
followJson = loadJson(followActivityfilename)
|
||||
if followJson:
|
||||
approveNickname=approveHandle.split('@')[0]
|
||||
approveDomain=approveHandle.split('@')[1].replace('\n','')
|
||||
approvePort=port2
|
||||
approveNickname = approveHandle.split('@')[0]
|
||||
approveDomain = \
|
||||
approveHandle.split('@')[1].replace('\n', '')
|
||||
approvePort = port2
|
||||
if ':' in approveDomain:
|
||||
approvePort=approveDomain.split(':')[1]
|
||||
approveDomain=approveDomain.split(':')[0]
|
||||
print('Manual follow accept: Sending Accept for '+handle+' follow request from '+approveNickname+'@'+approveDomain)
|
||||
followedAccountAccepts(session,baseDir,httpPrefix, \
|
||||
nickname,domain,port, \
|
||||
approveNickname,approveDomain,approvePort, \
|
||||
followJson['actor'],federationList, \
|
||||
followJson,acceptedCaps, \
|
||||
sendThreads,postLog, \
|
||||
cachedWebfingers,personCache, \
|
||||
debug,projectVersion,False)
|
||||
updateApprovedFollowers=True
|
||||
approvePort = approveDomain.split(':')[1]
|
||||
approveDomain = approveDomain.split(':')[0]
|
||||
print('Manual follow accept: Sending Accept for ' +
|
||||
handle + ' follow request from ' +
|
||||
approveNickname + '@' + approveDomain)
|
||||
followedAccountAccepts(session, baseDir, httpPrefix,
|
||||
nickname, domain, port,
|
||||
approveNickname, approveDomain,
|
||||
approvePort,
|
||||
followJson['actor'],
|
||||
federationList,
|
||||
followJson, acceptedCaps,
|
||||
sendThreads, postLog,
|
||||
cachedWebfingers, personCache,
|
||||
debug, projectVersion, False)
|
||||
updateApprovedFollowers = True
|
||||
else:
|
||||
# this isn't the approved follow so it will remain
|
||||
# in the requests file
|
||||
approvefilenew.write(handleOfFollowRequester)
|
||||
approvefilenew.close()
|
||||
|
||||
followersFilename=accountDir+'/followers.txt'
|
||||
followersFilename = accountDir + '/followers.txt'
|
||||
if updateApprovedFollowers:
|
||||
# update the followers
|
||||
print('Manual follow accept: updating '+followersFilename)
|
||||
print('Manual follow accept: updating ' + followersFilename)
|
||||
if os.path.isfile(followersFilename):
|
||||
if approveHandle not in open(followersFilename).read():
|
||||
try:
|
||||
with open(followersFilename, 'r+') as followersFile:
|
||||
content=followersFile.read()
|
||||
content = followersFile.read()
|
||||
followersFile.seek(0, 0)
|
||||
followersFile.write(approveHandle+'\n'+content)
|
||||
followersFile.write(approveHandle + '\n' + content)
|
||||
except Exception as e:
|
||||
print('WARN: Manual follow accept. Failed to write entry to followers file '+str(e))
|
||||
print('WARN: Manual follow accept. ' +
|
||||
'Failed to write entry to followers file ' + str(e))
|
||||
else:
|
||||
print('WARN: Manual follow accept: '+approveHandle+' already exists in '+followersFilename)
|
||||
print('WARN: Manual follow accept: ' + approveHandle +
|
||||
' already exists in ' + followersFilename)
|
||||
else:
|
||||
print('Manual follow accept: first follower accepted for '+handle+' is '+approveHandle)
|
||||
followersFile=open(followersFilename, "w+")
|
||||
followersFile.write(approveHandle+'\n')
|
||||
print('Manual follow accept: first follower accepted for ' +
|
||||
handle + ' is ' + approveHandle)
|
||||
followersFile = open(followersFilename, "w+")
|
||||
followersFile.write(approveHandle + '\n')
|
||||
followersFile.close()
|
||||
|
||||
# only update the follow requests file if the follow is confirmed to be
|
||||
# in followers.txt
|
||||
if approveHandle in open(followersFilename).read():
|
||||
# mark this handle as approved for following
|
||||
approveFollowerHandle(accountDir,approveHandle)
|
||||
approveFollowerHandle(accountDir, approveHandle)
|
||||
# update the follow requests with the handles not yet approved
|
||||
os.rename(approveFollowsFilename+'.new',approveFollowsFilename)
|
||||
os.rename(approveFollowsFilename + '.new', approveFollowsFilename)
|
||||
# remove the .follow file
|
||||
if followActivityfilename:
|
||||
if os.path.isfile(followActivityfilename):
|
||||
os.remove(followActivityfilename)
|
||||
else:
|
||||
os.remove(approveFollowsFilename+'.new')
|
||||
os.remove(approveFollowsFilename + '.new')
|
||||
|
|
|
|||
Loading…
Reference in New Issue