epicyon/follow.py

753 lines
29 KiB
Python
Raw Normal View History

2019-06-29 18:23:13 +00:00
__filename__ = "follow.py"
__author__ = "Bob Mottram"
__license__ = "AGPL3+"
__version__ = "0.0.1"
__maintainer__ = "Bob Mottram"
__email__ = "bob@freedombone.net"
__status__ = "Production"
import json
2019-07-08 17:15:55 +00:00
import commentjson
2019-06-29 18:23:13 +00:00
from pprint import pprint
import os
import sys
2019-07-27 22:48:34 +00:00
from utils import validNickname
2019-07-02 10:39:55 +00:00
from utils import domainPermitted
2019-07-06 15:17:21 +00:00
from utils import getDomainFromActor
from utils import getNicknameFromActor
2019-07-06 19:24:52 +00:00
from utils import getStatusNumber
from utils import followPerson
2019-07-05 18:57:19 +00:00
from posts import sendSignedJson
2019-07-16 21:38:06 +00:00
from posts import getPersonBox
2019-07-06 13:49:25 +00:00
from acceptreject import createAccept
2019-07-16 21:38:06 +00:00
from webfinger import webfingerHandle
from auth import createBasicAuthHeader
from session import postJson
2019-06-29 18:23:13 +00:00
2019-07-29 19:46:30 +00:00
def isFollowingActor(baseDir: str,nickname: str,domain: str,actor: str) -> bool:
"""Is the given actor a follower of the given nickname?
"""
if ':' in domain:
domain=domain.split(':')[0]
handle=nickname+'@'+domain
if not os.path.isdir(baseDir+'/accounts/'+handle):
return False
followersFile=baseDir+'/accounts/'+handle+'/followers.txt'
if not os.path.isfile(followersFile):
return False
if actor in open(followersFile).read():
return True
followerNickname=getNicknameFromActor(actor)
followerDomain,followerPort=getDomainFromActor(actor)
followerHandle=followerNickname+'@'+followerDomain
if followerPort:
if followerPort!=80 and followerPort!=443:
followerHandle+=':'+str(followerPort)
if followerHandle in open(followersFile).read():
return True
return False
2019-07-06 17:00:22 +00:00
def getFollowersOfPerson(baseDir: str, \
nickname: str,domain: str, \
followFile='following.txt') -> []:
"""Returns a list containing the followers of the given person
Used by the shared inbox to know who to send incoming mail to
"""
followers=[]
2019-07-11 12:29:31 +00:00
if ':' in domain:
domain=domain.split(':')[0]
2019-07-29 19:46:30 +00:00
handle=nickname+'@'+domain
if not os.path.isdir(baseDir+'/accounts/'+handle):
return followers
for subdir, dirs, files in os.walk(baseDir+'/accounts'):
for account in dirs:
filename = os.path.join(subdir, account)+'/'+followFile
2019-07-08 13:30:04 +00:00
if account == handle or account.startswith('inbox@'):
continue
if not os.path.isfile(filename):
continue
with open(filename, 'r') as followingfile:
for followingHandle in followingfile:
if followingHandle.replace('\n','')==handle:
if account not in followers:
followers.append(account)
break
return followers
2019-07-03 09:40:27 +00:00
def followerOfPerson(baseDir: str,nickname: str, domain: str, \
followerNickname: str, followerDomain: str, \
2019-07-06 19:24:52 +00:00
federationList: [],debug :bool) -> bool:
"""Adds a follower of the given person
"""
2019-07-06 19:24:52 +00:00
return followPerson(baseDir,nickname,domain, \
followerNickname,followerDomain, \
federationList,debug,'followers.txt')
2019-06-29 18:23:13 +00:00
2019-07-03 09:40:27 +00:00
def unfollowPerson(baseDir: str,nickname: str, domain: str, \
followNickname: str, followDomain: str, \
2019-07-17 11:54:13 +00:00
followFile='following.txt', \
debug=False) -> bool:
2019-06-29 18:23:13 +00:00
"""Removes a person to the follow list
"""
2019-07-17 11:54:13 +00:00
if ':' in domain:
domain=domain.split(':')[0]
2019-07-03 09:40:27 +00:00
handle=nickname.lower()+'@'+domain.lower()
handleToUnfollow=followNickname.lower()+'@'+followDomain.lower()
2019-07-02 17:20:15 +00:00
if not os.path.isdir(baseDir+'/accounts'):
os.mkdir(baseDir+'/accounts')
2019-06-29 18:23:13 +00:00
if not os.path.isdir(baseDir+'/accounts/'+handle):
os.mkdir(baseDir+'/accounts/'+handle)
filename=baseDir+'/accounts/'+handle+'/'+followFile
2019-07-17 10:34:00 +00:00
if not os.path.isfile(filename):
2019-07-17 11:54:13 +00:00
if debug:
print('DEBUG: follow file '+filename+' was not found')
2019-07-17 10:34:00 +00:00
return False
if handleToUnfollow not in open(filename).read():
2019-07-17 11:54:13 +00:00
if debug:
print('DEBUG: handle to unfollow '+handleToUnfollow+' is not in '+filename)
2019-07-17 10:34:00 +00:00
return
with open(filename, "r") as f:
lines = f.readlines()
with open(filename, "w") as f:
for line in lines:
if line.strip("\n") != handleToUnfollow:
f.write(line)
2019-06-29 18:23:13 +00:00
2019-07-03 09:40:27 +00:00
def unfollowerOfPerson(baseDir: str,nickname: str,domain: str, \
2019-07-17 11:54:13 +00:00
followerNickname: str,followerDomain: str, \
debug=False) -> bool:
"""Remove a follower of a person
"""
2019-07-17 10:38:10 +00:00
return unfollowPerson(baseDir,nickname,domain, \
2019-07-17 11:54:13 +00:00
followerNickname,followerDomain, \
'followers.txt',debug)
2019-06-29 18:23:13 +00:00
2019-07-06 17:00:22 +00:00
def clearFollows(baseDir: str,nickname: str,domain: str, \
followFile='following.txt') -> None:
2019-06-29 18:23:13 +00:00
"""Removes all follows
"""
2019-07-03 09:40:27 +00:00
handle=nickname.lower()+'@'+domain.lower()
2019-07-02 17:20:15 +00:00
if not os.path.isdir(baseDir+'/accounts'):
os.mkdir(baseDir+'/accounts')
2019-06-29 18:23:13 +00:00
if not os.path.isdir(baseDir+'/accounts/'+handle):
os.mkdir(baseDir+'/accounts/'+handle)
filename=baseDir+'/accounts/'+handle+'/'+followFile
if os.path.isfile(filename):
os.remove(filename)
2019-07-03 09:40:27 +00:00
def clearFollowers(baseDir: str,nickname: str,domain: str) -> None:
"""Removes all followers
"""
2019-07-03 09:40:27 +00:00
clearFollows(baseDir,nickname, domain,'followers.txt')
2019-06-29 20:21:37 +00:00
2019-07-06 17:00:22 +00:00
def getNoOfFollows(baseDir: str,nickname: str,domain: str, \
authenticated: bool, \
2019-07-06 17:00:22 +00:00
followFile='following.txt') -> int:
"""Returns the number of follows or followers
"""
# only show number of followers to authenticated
# account holders
if not authenticated:
return 9999
2019-07-03 09:40:27 +00:00
handle=nickname.lower()+'@'+domain.lower()
2019-06-29 20:21:37 +00:00
filename=baseDir+'/accounts/'+handle+'/'+followFile
if not os.path.isfile(filename):
return 0
ctr = 0
with open(filename, "r") as f:
lines = f.readlines()
for line in lines:
if '#' not in line:
if '@' in line and '.' in line and not line.startswith('http'):
ctr += 1
elif line.startswith('http') and '/users/' in line:
ctr += 1
return ctr
def getNoOfFollowers(baseDir: str,nickname: str,domain: str,authenticated: bool) -> int:
"""Returns the number of followers of the given person
"""
return getNoOfFollows(baseDir,nickname,domain,authenticated,'followers.txt')
2019-06-29 20:21:37 +00:00
2019-07-06 17:00:22 +00:00
def getFollowingFeed(baseDir: str,domain: str,port: int,path: str, \
httpPrefix: str, authenticated: bool,
followsPerPage=12, \
2019-07-06 17:00:22 +00:00
followFile='following') -> {}:
"""Returns the following and followers feeds from GET requests
"""
# Show a small number of follows to non-authenticated viewers
if not authenticated:
followsPerPage=6
2019-06-29 20:21:37 +00:00
if '/'+followFile not in path:
return None
# handle page numbers
headerOnly=True
pageNumber=None
if '?page=' in path:
pageNumber=path.split('?page=')[1]
if pageNumber=='true' or not authenticated:
2019-06-29 20:21:37 +00:00
pageNumber=1
else:
try:
pageNumber=int(pageNumber)
except:
pass
path=path.split('?page=')[0]
headerOnly=False
if not path.endswith('/'+followFile):
return None
2019-07-03 09:40:27 +00:00
nickname=None
2019-06-29 20:21:37 +00:00
if path.startswith('/users/'):
2019-07-03 09:40:27 +00:00
nickname=path.replace('/users/','',1).replace('/'+followFile,'')
2019-06-29 20:21:37 +00:00
if path.startswith('/@'):
2019-07-03 09:40:27 +00:00
nickname=path.replace('/@','',1).replace('/'+followFile,'')
if not nickname:
2019-06-29 20:21:37 +00:00
return None
2019-07-03 09:40:27 +00:00
if not validNickname(nickname):
2019-06-29 20:21:37 +00:00
return None
2019-06-30 19:01:43 +00:00
if port!=80 and port!=443:
domain=domain+':'+str(port)
2019-06-29 20:21:37 +00:00
if headerOnly:
following = {
'@context': 'https://www.w3.org/ns/activitystreams',
2019-07-03 19:00:03 +00:00
'first': httpPrefix+'://'+domain+'/users/'+nickname+'/'+followFile+'?page=1',
'id': httpPrefix+'://'+domain+'/users/'+nickname+'/'+followFile,
'totalItems': getNoOfFollows(baseDir,nickname,domain,authenticated),
2019-06-29 20:21:37 +00:00
'type': 'OrderedCollection'}
return following
if not pageNumber:
pageNumber=1
nextPageNumber=int(pageNumber+1)
following = {
'@context': 'https://www.w3.org/ns/activitystreams',
2019-07-03 19:00:03 +00:00
'id': httpPrefix+'://'+domain+'/users/'+nickname+'/'+followFile+'?page='+str(pageNumber),
2019-06-29 20:21:37 +00:00
'orderedItems': [],
2019-07-03 19:00:03 +00:00
'partOf': httpPrefix+'://'+domain+'/users/'+nickname+'/'+followFile,
2019-06-29 20:21:37 +00:00
'totalItems': 0,
'type': 'OrderedCollectionPage'}
handleDomain=domain
if ':' in handleDomain:
handleDomain=domain.split(':')[0]
handle=nickname.lower()+'@'+handleDomain.lower()
2019-06-29 20:21:37 +00:00
filename=baseDir+'/accounts/'+handle+'/'+followFile+'.txt'
if not os.path.isfile(filename):
return following
currPage=1
pageCtr=0
totalCtr=0
with open(filename, "r") as f:
lines = f.readlines()
for line in lines:
if '#' not in line:
if '@' in line and not line.startswith('http'):
2019-06-29 20:21:37 +00:00
pageCtr += 1
totalCtr += 1
if currPage==pageNumber:
2019-07-03 19:00:03 +00:00
url = httpPrefix + '://' + line.lower().replace('\n','').split('@')[1] + \
2019-06-29 20:21:37 +00:00
'/users/' + line.lower().replace('\n','').split('@')[0]
following['orderedItems'].append(url)
2019-07-03 19:00:03 +00:00
elif (line.startswith('http') or line.startswith('dat')) and '/users/' in line:
2019-06-29 20:21:37 +00:00
pageCtr += 1
totalCtr += 1
if currPage==pageNumber:
following['orderedItems'].append(line.lower().replace('\n',''))
if pageCtr>=followsPerPage:
pageCtr=0
currPage += 1
following['totalItems']=totalCtr
lastPage=int(totalCtr/followsPerPage)
if lastPage<1:
lastPage=1
if nextPageNumber>lastPage:
2019-07-03 19:00:03 +00:00
following['next']=httpPrefix+'://'+domain+'/users/'+nickname+'/'+followFile+'?page='+str(lastPage)
2019-06-29 20:21:37 +00:00
return following
2019-07-02 18:17:04 +00:00
2019-07-19 20:03:50 +00:00
def followApprovalRequired(baseDir: str,nicknameToFollow: str, \
domainToFollow: str,debug: bool) -> bool:
""" Returns the policy for follower approvals
"""
manuallyApproveFollows=False
actorFilename=baseDir+'/accounts/'+nicknameToFollow+'@'+domainToFollow+'.json'
if os.path.isfile(actorFilename):
with open(actorFilename, 'r') as fp:
actor=commentjson.load(fp)
if actor.get('manuallyApprovesFollowers'):
manuallyApproveFollows=actor['manuallyApprovesFollowers']
else:
if debug:
print('manuallyApprovesFollowers is missing from '+actorFilename)
else:
if debug:
print('DEBUG: Actor file not found: '+actorFilename)
return manuallyApproveFollows
def storeFollowRequest(baseDir: str, \
nicknameToFollow: str,domainToFollow: str,port: int, \
2019-07-20 13:35:58 +00:00
nickname: str,domain: str,fromPort: int, \
followJson: {}, \
debug: bool) -> bool:
"""Stores the follow request for later use
"""
accountsDir=baseDir+'/accounts/'+nicknameToFollow+'@'+domainToFollow
if not os.path.isdir(accountDir):
return False
2019-07-19 20:03:50 +00:00
if port!=80 and port!=443:
2019-07-20 13:35:58 +00:00
approveHandle=nickname+'@'+domain+':'+str(fromPort)
else:
2019-07-20 13:35:58 +00:00
approveHandle=nickname+'@'+domain
# add to a file which contains a list of requests
approveFollowsFilename=accountDir+'/followrequests.txt'
if os.path.isfile(approveFollowsFilename):
if approveHandle not in open(approveFollowsFilename).read():
with open(approveFollowsFilename, "a") as fp:
fp.write(approveHandle+'\n')
else:
if debug:
print('DEBUG: '+approveHandle+' is already awaiting approval')
else:
with open(approveFollowsFilename, "w") as fp:
fp.write(approveHandle+'\n')
# store the follow request in its own directory
# We don't rely upon the inbox because items in there could expire
requestsDir=accountsDir+'/requests'
if not os.path.isdir(requestsDir):
os.mkdir(requestsDir)
followActivityfilename=requestsDir+'/'+approveHandle+'.follow'
with open(followActivityfilename, 'w') as fp:
commentjson.dump(followJson, fp, indent=4, sort_keys=False)
return True
return False
2019-07-06 17:00:22 +00:00
def receiveFollowRequest(session,baseDir: str,httpPrefix: str, \
port: int,sendThreads: [],postLog: [], \
cachedWebfingers: {},personCache: {}, \
messageJson: {},federationList: [], \
2019-07-09 17:54:08 +00:00
debug : bool, \
acceptedCaps=["inbox:write","objects:read"]) -> bool:
2019-07-02 18:38:51 +00:00
"""Receives a follow request within the POST section of HTTPServer
"""
2019-07-02 18:17:04 +00:00
if not messageJson['type'].startswith('Follow'):
return False
2019-07-06 13:49:25 +00:00
if not messageJson.get('actor'):
if debug:
print('DEBUG: follow request has no actor')
return False
2019-07-02 18:17:04 +00:00
if '/users/' not in messageJson['actor']:
2019-07-06 13:49:25 +00:00
if debug:
print('DEBUG: "users" missing from actor')
2019-07-02 18:17:04 +00:00
return False
2019-07-06 15:17:21 +00:00
domain,tempPort=getDomainFromActor(messageJson['actor'])
fromPort=port
2019-07-16 22:57:45 +00:00
domainFull=domain
2019-07-06 15:17:21 +00:00
if tempPort:
fromPort=tempPort
2019-07-16 22:57:45 +00:00
if tempPort!=80 and tempPort!=443:
2019-07-18 11:35:48 +00:00
domainFull=domain+':'+str(tempPort)
2019-07-02 18:17:04 +00:00
if not domainPermitted(domain,federationList):
2019-07-06 13:49:25 +00:00
if debug:
print('DEBUG: follower from domain not permitted - '+domain)
2019-07-02 18:17:04 +00:00
return False
2019-07-06 15:17:21 +00:00
nickname=getNicknameFromActor(messageJson['actor'])
if not nickname:
if debug:
print('DEBUG: follow request does not contain a nickname')
return False
2019-07-03 09:40:27 +00:00
handle=nickname.lower()+'@'+domain.lower()
2019-07-02 18:17:04 +00:00
if '/users/' not in messageJson['object']:
2019-07-06 13:49:25 +00:00
if debug:
print('DEBUG: "users" not found within object')
2019-07-02 18:17:04 +00:00
return False
2019-07-06 15:17:21 +00:00
domainToFollow,tempPort=getDomainFromActor(messageJson['object'])
2019-07-02 18:17:04 +00:00
if not domainPermitted(domainToFollow,federationList):
2019-07-06 13:49:25 +00:00
if debug:
print('DEBUG: follow domain not permitted '+domainToFollow)
2019-07-02 18:17:04 +00:00
return False
2019-07-16 22:57:45 +00:00
domainToFollowFull=domainToFollow
if tempPort:
if tempPort!=80 and tempPort!=443:
domainToFollowFull=domainToFollow+':'+str(tempPort)
2019-07-06 15:17:21 +00:00
nicknameToFollow=getNicknameFromActor(messageJson['object'])
if not nicknameToFollow:
if debug:
print('DEBUG: follow request does not contain a nickname for the account followed')
return False
2019-07-03 09:40:27 +00:00
handleToFollow=nicknameToFollow.lower()+'@'+domainToFollow.lower()
2019-07-02 18:17:04 +00:00
if domainToFollow==domain:
if not os.path.isdir(baseDir+'/accounts/'+handleToFollow):
2019-07-06 13:49:25 +00:00
if debug:
2019-07-06 17:00:22 +00:00
print('DEBUG: followed account not found - '+ \
baseDir+'/accounts/'+handleToFollow)
2019-07-02 18:17:04 +00:00
return False
2019-07-16 22:57:45 +00:00
if not followerOfPerson(baseDir,nicknameToFollow,domainToFollowFull, \
nickname,domainFull,federationList,debug):
2019-07-06 13:49:25 +00:00
if debug:
2019-07-06 17:00:22 +00:00
print('DEBUG: '+nickname+'@'+domain+ \
' is already a follower of '+ \
nicknameToFollow+'@'+domainToFollow)
2019-07-05 18:57:19 +00:00
return False
2019-07-19 20:03:50 +00:00
# what is the followers policy?
if followApprovalRequired(baseDir,nicknameToFollow, \
domainToFollow,debug):
return storeFollowRequest(baseDir, \
nicknameToFollow,domainToFollow,port, \
2019-07-20 13:35:58 +00:00
nickname,domain,fromPort,
messageJson,debug)
return followedAccountAccepts(session,baseDir,httpPrefix, \
nicknameToFollow,domainToFollow,port, \
nickname,domain,fromPort, \
messageJson['actor'],federationList,
messageJson,acceptedCaps, \
sendThreads,postLog, \
cachedWebfingers,personCache, \
debug)
2019-07-19 20:03:50 +00:00
2019-07-20 08:33:18 +00:00
def followedAccountAccepts(session,baseDir: str,httpPrefix: str, \
nicknameToFollow: str,domainToFollow: str,port: int, \
nickname: str,domain: str,fromPort: int, \
personUrl: str,federationList: [], \
followJson: {},acceptedCaps: [], \
sendThreads: [],postLog: [], \
cachedWebfingers: {},personCache: {}, \
debug: bool):
"""The person receiving a follow request accepts the new follower
and sends back an Accept activity
"""
2019-07-05 18:57:19 +00:00
# send accept back
2019-07-06 13:49:25 +00:00
if debug:
2019-07-20 08:33:18 +00:00
print('DEBUG: sending Accept activity for follow request which arrived at '+ \
2019-07-06 17:00:22 +00:00
nicknameToFollow+'@'+domainToFollow+' back to '+nickname+'@'+domain)
2019-07-09 14:20:23 +00:00
acceptJson=createAccept(baseDir,federationList, \
2019-07-07 13:53:12 +00:00
nicknameToFollow,domainToFollow,port, \
2019-07-20 08:33:18 +00:00
personUrl,'',httpPrefix,followJson,acceptedCaps)
2019-07-06 15:17:21 +00:00
if debug:
pprint(acceptJson)
2019-07-06 17:00:22 +00:00
print('DEBUG: sending follow Accept from '+ \
nicknameToFollow+'@'+domainToFollow+ \
' port '+str(port)+' to '+ \
nickname+'@'+domain+' port '+ str(fromPort))
2019-07-06 13:49:25 +00:00
clientToServer=False
2019-07-06 17:00:22 +00:00
return sendSignedJson(acceptJson,session,baseDir, \
nicknameToFollow,domainToFollow,port, \
2019-07-06 15:17:21 +00:00
nickname,domain,fromPort, '', \
httpPrefix,True,clientToServer, \
2019-07-09 14:20:23 +00:00
federationList, \
2019-07-06 17:00:22 +00:00
sendThreads,postLog,cachedWebfingers, \
personCache,debug)
2019-07-02 18:38:51 +00:00
2019-07-06 17:00:22 +00:00
def sendFollowRequest(session,baseDir: str, \
nickname: str,domain: str,port: int,httpPrefix: str, \
followNickname: str,followDomain: str, \
2019-07-29 16:13:48 +00:00
followPort: int,followHttpPrefix: str, \
2019-07-09 14:20:23 +00:00
clientToServer: bool,federationList: [], \
2019-07-06 17:00:22 +00:00
sendThreads: [],postLog: [],cachedWebfingers: {}, \
personCache: {},debug : bool) -> {}:
2019-07-02 20:54:22 +00:00
"""Gets the json object for sending a follow request
2019-07-06 13:49:25 +00:00
"""
2019-07-02 18:38:51 +00:00
if not domainPermitted(followDomain,federationList):
return None
2019-07-07 13:53:12 +00:00
fullDomain=domain
2019-07-06 13:49:25 +00:00
followActor=httpPrefix+'://'+domain+'/users/'+nickname
2019-07-02 18:38:51 +00:00
if port!=80 and port!=443:
2019-07-07 13:53:12 +00:00
fullDomain=domain+':'+str(port)
2019-07-06 13:49:25 +00:00
followActor=httpPrefix+'://'+domain+':'+str(port)+'/users/'+nickname
2019-07-02 18:38:51 +00:00
2019-07-06 13:49:25 +00:00
requestDomain=followDomain
2019-07-02 18:38:51 +00:00
if followPort!=80 and followPort!=443:
2019-07-06 13:49:25 +00:00
requestDomain=followDomain+':'+str(followPort)
2019-07-06 10:33:57 +00:00
2019-07-06 19:24:52 +00:00
statusNumber,published = getStatusNumber()
followedId=followHttpPrefix+'://'+requestDomain+'/users/'+followNickname
2019-07-05 20:32:21 +00:00
newFollowJson = {
2019-07-02 18:38:51 +00:00
'type': 'Follow',
2019-07-06 10:33:57 +00:00
'actor': followActor,
2019-07-06 19:24:52 +00:00
'object': followedId,
'to': [followedId],
'cc': ['https://www.w3.org/ns/activitystreams#Public'],
'published': published
2019-07-02 18:38:51 +00:00
}
2019-07-02 19:05:59 +00:00
2019-07-05 20:32:21 +00:00
sendSignedJson(newFollowJson,session,baseDir,nickname,domain,port, \
2019-07-06 19:24:52 +00:00
followNickname,followDomain,followPort, \
'https://www.w3.org/ns/activitystreams#Public', \
2019-07-06 13:49:25 +00:00
httpPrefix,True,clientToServer, \
2019-07-09 14:20:23 +00:00
federationList, \
2019-07-06 13:49:25 +00:00
sendThreads,postLog,cachedWebfingers,personCache, debug)
2019-07-05 20:32:21 +00:00
return newFollowJson
2019-07-16 21:38:06 +00:00
def sendFollowRequestViaServer(session,fromNickname: str,password: str,
fromDomain: str,fromPort: int, \
followNickname: str,followDomain: str,followPort: int, \
httpPrefix: str, \
cachedWebfingers: {},personCache: {}, \
debug: bool) -> {}:
"""Creates a follow request via c2s
"""
if not session:
print('WARN: No session for sendFollowRequestViaServer')
return 6
fromDomainFull=fromDomain
if fromPort!=80 and fromPort!=443:
fromDomainFull=fromDomain+':'+str(fromPort)
2019-07-18 11:35:48 +00:00
2019-07-16 21:38:06 +00:00
followDomainFull=followDomain
if followPort!=80 and followPort!=443:
followDomainFull=followDomain+':'+str(followPort)
followActor=httpPrefix+'://'+fromDomainFull+'/users/'+fromNickname
followedId=httpPrefix+'://'+followDomainFull+'/users/'+followNickname
statusNumber,published = getStatusNumber()
newFollowJson = {
'type': 'Follow',
'actor': followActor,
'object': followedId,
'to': [followedId],
'cc': ['https://www.w3.org/ns/activitystreams#Public'],
'published': published
}
handle=httpPrefix+'://'+fromDomainFull+'/@'+fromNickname
# lookup the inbox for the To handle
wfRequest = webfingerHandle(session,handle,httpPrefix,cachedWebfingers)
if not wfRequest:
if debug:
print('DEBUG: announce webfinger failed for '+handle)
return 1
postToBox='outbox'
# get the actor inbox for the To handle
2019-07-22 14:21:49 +00:00
inboxUrl,pubKeyId,pubKey,fromPersonId,sharedInbox,capabilityAcquisition,avatarUrl,preferredName = \
2019-07-16 21:38:06 +00:00
getPersonBox(session,wfRequest,personCache,postToBox)
if not inboxUrl:
if debug:
print('DEBUG: No '+postToBox+' was found for '+handle)
return 3
if not fromPersonId:
if debug:
print('DEBUG: No actor was found for '+handle)
return 4
authHeader=createBasicAuthHeader(fromNickname,password)
headers = {'host': fromDomain, \
'Content-type': 'application/json', \
'Authorization': authHeader}
postResult = \
postJson(session,newFollowJson,[],inboxUrl,headers,"inbox:write")
#if not postResult:
# if debug:
# print('DEBUG: POST announce failed for c2s to '+inboxUrl)
# return 5
if debug:
print('DEBUG: c2s POST follow success')
return newFollowJson
2019-07-17 10:34:00 +00:00
def sendUnfollowRequestViaServer(session,fromNickname: str,password: str,
fromDomain: str,fromPort: int, \
followNickname: str,followDomain: str,followPort: int, \
httpPrefix: str, \
cachedWebfingers: {},personCache: {}, \
debug: bool) -> {}:
"""Creates a unfollow request via c2s
"""
if not session:
print('WARN: No session for sendUnfollowRequestViaServer')
return 6
fromDomainFull=fromDomain
if fromPort!=80 and fromPort!=443:
fromDomainFull=fromDomain+':'+str(fromPort)
followDomainFull=followDomain
if followPort!=80 and followPort!=443:
followDomainFull=followDomain+':'+str(followPort)
followActor=httpPrefix+'://'+fromDomainFull+'/users/'+fromNickname
followedId=httpPrefix+'://'+followDomainFull+'/users/'+followNickname
unfollowJson = {
'type': 'Undo',
'actor': followActor,
'object': {
'type': 'Follow',
'actor': followActor,
'object': followedId,
'to': [followedId],
'cc': ['https://www.w3.org/ns/activitystreams#Public']
}
}
handle=httpPrefix+'://'+fromDomainFull+'/@'+fromNickname
# lookup the inbox for the To handle
wfRequest = webfingerHandle(session,handle,httpPrefix,cachedWebfingers)
if not wfRequest:
if debug:
print('DEBUG: announce webfinger failed for '+handle)
return 1
postToBox='outbox'
# get the actor inbox for the To handle
2019-07-22 14:21:49 +00:00
inboxUrl,pubKeyId,pubKey,fromPersonId,sharedInbox,capabilityAcquisition,avatarUrl,preferredName = \
2019-07-17 10:34:00 +00:00
getPersonBox(session,wfRequest,personCache,postToBox)
if not inboxUrl:
if debug:
print('DEBUG: No '+postToBox+' was found for '+handle)
return 3
if not fromPersonId:
if debug:
print('DEBUG: No actor was found for '+handle)
return 4
authHeader=createBasicAuthHeader(fromNickname,password)
headers = {'host': fromDomain, \
'Content-type': 'application/json', \
'Authorization': authHeader}
postResult = \
postJson(session,unfollowJson,[],inboxUrl,headers,"inbox:write")
#if not postResult:
# if debug:
# print('DEBUG: POST announce failed for c2s to '+inboxUrl)
# return 5
if debug:
print('DEBUG: c2s POST unfollow success')
return unfollowJson
2019-07-11 12:29:31 +00:00
def getFollowersOfActor(baseDir :str,actor :str,debug: bool) -> {}:
"""In a shared inbox if we receive a post we know who it's from
2019-07-08 17:15:55 +00:00
and if it's addressed to followers then we need to get a list of those.
This returns a list of account handles which follow the given actor
and also the corresponding capability id if it exists
"""
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: getting followers of '+actor)
recipientsDict={}
2019-07-08 17:15:55 +00:00
if ':' not in actor:
2019-07-08 22:12:24 +00:00
return recipientsDict
2019-07-08 17:15:55 +00:00
httpPrefix=actor.split(':')[0]
nickname=getNicknameFromActor(actor)
if not nickname:
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: no nickname found in '+actor)
2019-07-08 22:12:24 +00:00
return recipientsDict
domain,port=getDomainFromActor(actor)
if not domain:
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: no domain found in '+actor)
2019-07-08 22:12:24 +00:00
return recipientsDict
actorHandle=nickname+'@'+domain
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: searching for handle '+actorHandle)
# for each of the accounts
for subdir, dirs, files in os.walk(baseDir+'/accounts'):
for account in dirs:
if '@' in account and not account.startswith('inbox@'):
followingFilename = os.path.join(subdir, account)+'/following.txt'
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: examining follows of '+account)
print(followingFilename)
if os.path.isfile(followingFilename):
# does this account follow the given actor?
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: checking if '+actorHandle+' in '+followingFilename)
2019-07-08 17:15:55 +00:00
if actorHandle in open(followingFilename).read():
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: '+account+' follows '+actorHandle)
2019-07-08 22:12:24 +00:00
ocapFilename=baseDir+'/accounts/'+account+'/ocap/accept/'+httpPrefix+':##'+domain+':'+str(port)+'#users#'+nickname+'.json'
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: checking capabilities of'+account)
2019-07-08 17:15:55 +00:00
if os.path.isfile(ocapFilename):
with open(ocapFilename, 'r') as fp:
ocapJson=commentjson.load(fp)
2019-07-11 12:29:31 +00:00
if ocapJson.get('id'):
if debug:
print('DEBUG: capabilities id found for '+account)
recipientsDict[account]=ocapJson['id']
else:
if debug:
print('DEBUG: capabilities has no id attribute')
recipientsDict[account]=None
2019-07-08 17:15:55 +00:00
else:
2019-07-11 12:29:31 +00:00
if debug:
print('DEBUG: No capabilities file found for '+account+' granted by '+actorHandle)
print(ocapFilename)
2019-07-08 22:12:24 +00:00
recipientsDict[account]=None
return recipientsDict
2019-07-17 10:34:00 +00:00
def outboxUndoFollow(baseDir: str,messageJson: {},debug: bool) -> None:
"""When an unfollow request is received by the outbox from c2s
This removes the followed handle from the following.txt file
of the relevant account
2019-07-29 20:36:26 +00:00
TODO the unfollow should also be sent to the previously followed account
2019-07-17 10:34:00 +00:00
"""
if not messageJson.get('type'):
return
if not messageJson['type']=='Undo':
return
if not messageJson.get('object'):
return
if not isinstance(messageJson['object'], dict):
return
if not messageJson['object'].get('type'):
return
if not messageJson['object']['type']=='Follow':
return
if not messageJson['object'].get('object'):
return
if not messageJson['object'].get('actor'):
return
if not isinstance(messageJson['object']['object'], str):
return
if debug:
print('DEBUG: undo follow arrived in outbox')
nicknameFollower=getNicknameFromActor(messageJson['object']['actor'])
domainFollower,portFollower=getDomainFromActor(messageJson['object']['actor'])
domainFollowerFull=domainFollower
if portFollower:
if portFollower!=80 and portFollower!=443:
domainFollowerFull=domainFollower+':'+str(portFollower)
nicknameFollowing=getNicknameFromActor(messageJson['object']['object'])
domainFollowing,portFollowing=getDomainFromActor(messageJson['object']['object'])
domainFollowingFull=domainFollowing
if portFollowing:
if portFollowing!=80 and portFollowing!=443:
domainFollowingFull=domainFollowing+':'+str(portFollowing)
if unfollowPerson(baseDir,nicknameFollower,domainFollowerFull, \
nicknameFollowing,domainFollowingFull):
if debug:
print('DEBUG: '+nicknameFollower+' unfollowed '+nicknameFollowing+'@'+domainFollowingFull)
else:
if debug:
print('WARN: '+nicknameFollower+' could not unfollow '+nicknameFollowing+'@'+domainFollowingFull)