__filename__ = "epicyon.py" __author__ = "Bob Mottram" __license__ = "AGPL3+" __version__ = "0.0.1" __maintainer__ = "Bob Mottram" __email__ = "bob@freedombone.net" __status__ = "Production" from person import createPerson from person import createSharedInbox from person import createCapabilitiesInbox from person import setPreferredNickname from person import setBio from person import validNickname from person import setProfileImage from skills import setSkillLevel from roles import setRole from person import setOrganizationScheme from webfinger import webfingerHandle from posts import getPosts from posts import createPublicPost from posts import deleteAllPosts from posts import createOutbox from posts import archivePosts from posts import sendPostViaServer from posts import getPublicPostsOfPerson from posts import getUserUrl from posts import archivePosts from session import createSession from session import getJson from blocking import addBlock from blocking import removeBlock from filters import addFilter from filters import removeFilter import json import os import shutil import sys import requests import time from pprint import pprint from tests import testHttpsig from daemon import runDaemon import socket from follow import clearFollows from follow import clearFollowers from utils import followPerson from follow import followerOfPerson from follow import unfollowPerson from follow import unfollowerOfPerson from follow import getFollowersOfPerson from tests import testPostMessageBetweenServers from tests import testFollowBetweenServers from tests import testClientToServer from tests import runAllTests from config import setConfigParam from config import getConfigParam from auth import storeBasicCredentials from auth import removePassword from auth import createPassword from utils import getDomainFromActor from utils import getNicknameFromActor from media import archiveMedia from delete import sendDeleteViaServer from like import sendLikeViaServer from like import sendUndoLikeViaServer from blocking import sendBlockViaServer from blocking import sendUndoBlockViaServer from roles import sendRoleViaServer from skills import sendSkillViaServer from availability import setAvailability from availability import sendAvailabilityViaServer import argparse def str2bool(v): if isinstance(v, bool): return v if v.lower() in ('yes', 'true', 't', 'y', '1'): return True elif v.lower() in ('no', 'false', 'f', 'n', '0'): return False else: raise argparse.ArgumentTypeError('Boolean value expected.') parser = argparse.ArgumentParser(description='ActivityPub Server') parser.add_argument('-n','--nickname', dest='nickname', type=str,default=None, \ help='Nickname of the account to use') parser.add_argument('--fol','--follow', dest='follow', type=str,default=None, \ help='Handle of account to follow. eg. nickname@domain') parser.add_argument('--unfol','--unfollow', dest='unfollow', type=str,default=None, \ help='Handle of account stop following. eg. nickname@domain') parser.add_argument('-d','--domain', dest='domain', type=str,default=None, \ help='Domain name of the server') parser.add_argument('-p','--port', dest='port', type=int,default=None, \ help='Port number to run on') parser.add_argument('--path', dest='baseDir', \ type=str,default=os.getcwd(), \ help='Directory in which to store posts') parser.add_argument('-a','--addaccount', dest='addaccount', \ type=str,default=None, \ help='Adds a new account') parser.add_argument('-r','--rmaccount', dest='rmaccount', \ type=str,default=None, \ help='Remove an account') parser.add_argument('--pass','--password', dest='password', \ type=str,default=None, \ help='Set a password for an account') parser.add_argument('--chpass','--changepassword', \ nargs='+',dest='changepassword', \ help='Change the password for an account') parser.add_argument('--actor', dest='actor', type=str,default=None, \ help='Show the json actor the given handle') parser.add_argument('--posts', dest='posts', type=str,default=None, \ help='Show posts for the given handle') parser.add_argument('--postsraw', dest='postsraw', type=str,default=None, \ help='Show raw json of posts for the given handle') parser.add_argument('--json', dest='json', type=str,default=None, \ help='Show the json for a given activitypub url') parser.add_argument('-f','--federate', nargs='+',dest='federationList', \ help='Specify federation list separated by spaces') parser.add_argument("--debug", type=str2bool, nargs='?', \ const=True, default=False, \ help="Show debug messages") parser.add_argument("--http", type=str2bool, nargs='?', \ const=True, default=False, \ help="Use http only") parser.add_argument("--dat", type=str2bool, nargs='?', \ const=True, default=False, \ help="Use dat protocol only") parser.add_argument("--tor", type=str2bool, nargs='?', \ const=True, default=False, \ help="Route via Tor") parser.add_argument("--tests", type=str2bool, nargs='?', \ const=True, default=False, \ help="Run unit tests") parser.add_argument("--testsnetwork", type=str2bool, nargs='?', \ const=True, default=False, \ help="Run network unit tests") parser.add_argument("--testdata", type=str2bool, nargs='?', \ const=True, default=False, \ help="Generate some data for testing purposes") parser.add_argument("--ocap", type=str2bool, nargs='?', \ const=True, default=False, \ help="Always strictly enforce object capabilities") parser.add_argument("--noreply", type=str2bool, nargs='?', \ const=True, default=False, \ help="Default capabilities don't allow replies on posts") parser.add_argument("--nolike", type=str2bool, nargs='?', \ const=True, default=False, \ help="Default capabilities don't allow likes/favourites on posts") parser.add_argument("--nopics", type=str2bool, nargs='?', \ const=True, default=False, \ help="Default capabilities don't allow attached pictures") parser.add_argument("--noannounce","--norepeat", type=str2bool, nargs='?', \ const=True, default=False, \ help="Default capabilities don't allow announce/repeat") parser.add_argument("--cw", type=str2bool, nargs='?', \ const=True, default=False, \ help="Default capabilities don't allow posts without content warnings") parser.add_argument('--icon','--avatar', dest='avatar', type=str,default=None, \ help='Set the avatar filename for an account') parser.add_argument('--image','--background', dest='backgroundImage', type=str,default=None, \ help='Set the profile background image for an account') parser.add_argument('--archive', dest='archive', type=str,default=None, \ help='Archive old files to the given directory') parser.add_argument('--archiveweeks', dest='archiveWeeks', type=str,default=None, \ help='Specify the number of weeks after which data will be archived') parser.add_argument('--maxposts', dest='archiveMaxPosts', type=str,default=None, \ help='Maximum number of posts in in/outbox') parser.add_argument('--message', dest='message', type=str,default=None, \ help='Message content') parser.add_argument('--delete', dest='delete', type=str,default=None, \ help='Delete a specified post') parser.add_argument("--allowdeletion", type=str2bool, nargs='?', \ const=True, default=False, \ help="Do not allow deletions") parser.add_argument('--repeat','--announce', dest='announce', type=str,default=None, \ help='Announce/repeat a url') parser.add_argument('--favorite','--like', dest='like', type=str,default=None, \ help='Like a url') parser.add_argument('--undolike','--unlike', dest='undolike', type=str,default=None, \ help='Undo a like of a url') parser.add_argument('--sendto', dest='sendto', type=str,default=None, \ help='Address to send a post to') parser.add_argument('--attach', dest='attach', type=str,default=None, \ help='File to attach to a post') parser.add_argument('--imagedescription', dest='imageDescription', type=str,default=None, \ help='Description of an attached image') parser.add_argument("--blurhash", type=str2bool, nargs='?', \ const=True, default=False, \ help="Create blurhash for an image") parser.add_argument('--warning','--warn','--cwsubject','--subject', dest='subject', type=str,default=None, \ help='Subject of content warning') parser.add_argument('--reply','--replyto', dest='replyto', type=str,default=None, \ help='Url of post to reply to') parser.add_argument("--followersonly", type=str2bool, nargs='?', \ const=True, default=True, \ help="Send to followers only") parser.add_argument("--followerspending", type=str2bool, nargs='?', \ const=True, default=True, \ help="Show a list of followers pending") parser.add_argument('--approve', dest='approve', type=str,default=None, \ help='Approve a follow request') parser.add_argument('--deny', dest='deny', type=str,default=None, \ help='Deny a follow request') parser.add_argument("-c","--client", type=str2bool, nargs='?', \ const=True, default=False, \ help="Use as an ActivityPub client") parser.add_argument('--maxreplies', dest='maxReplies', type=int,default=64, \ help='Maximum number of replies to a post') parser.add_argument('--role', dest='role', type=str,default=None, \ help='Set a role for a person') parser.add_argument('--organization','--project', dest='project', type=str,default=None, \ help='Set a project for a person') parser.add_argument('--skill', dest='skill', type=str,default=None, \ help='Set a skill for a person') parser.add_argument('--level', dest='skillLevelPercent', type=int,default=None, \ help='Set a skill level for a person as a percentage, or zero to remove') parser.add_argument('--status','--availability', dest='availability', type=str,default=None, \ help='Set an availability status') parser.add_argument('--block', dest='block', type=str,default=None, \ help='Block a particular address') parser.add_argument('--unblock', dest='unblock', type=str,default=None, \ help='Remove a block on a particular address') parser.add_argument('--delegate', dest='delegate', type=str,default=None, \ help='Address of an account to delegate a role to') parser.add_argument('--undodelegate','--undelegate', dest='undelegate', type=str,default=None, \ help='Removes a delegated role for the given address') parser.add_argument('--filter', dest='filterStr', type=str,default=None, \ help='Adds a word or phrase which if present will cause a message to be ignored') parser.add_argument('--unfilter', dest='unfilterStr', type=str,default=None, \ help='Remove a filter on a particular word or phrase') parser.add_argument('--domainmax', dest='domainMaxPostsPerDay', type=int,default=8640, \ help='Maximum number of received posts from a domain per day') parser.add_argument('--accountmax', dest='accountMaxPostsPerDay', type=int,default=8640, \ help='Maximum number of received posts from an account per day') args = parser.parse_args() debug=False if args.debug: debug=True if args.tests: runAllTests() sys.exit() if args.testsnetwork: print('Network Tests') testPostMessageBetweenServers() testFollowBetweenServers() testClientToServer() sys.exit() httpPrefix='https' if args.http: httpPrefix='http' if args.posts: if '@' not in args.posts: print('Syntax: --posts nickname@domain') sys.exit() if not args.http: args.port=443 nickname=args.posts.split('@')[0] domain=args.posts.split('@')[1] getPublicPostsOfPerson(nickname,domain,False,True, \ args.tor,args.port,httpPrefix,debug) sys.exit() if args.postsraw: if '@' not in args.postsraw: print('Syntax: --postsraw nickname@domain') sys.exit() if not args.http: args.port=443 nickname=args.postsraw.split('@')[0] domain=args.postsraw.split('@')[1] getPublicPostsOfPerson(nickname,domain,False,False, \ args.tor,args.port,httpPrefix,debug) sys.exit() baseDir=args.baseDir if baseDir.endswith('/'): print("--path option should not end with '/'") sys.exit() if args.domain: domain=args.domain setConfigParam(baseDir,'domain',domain) # get domain name from configuration configDomain=getConfigParam(baseDir,'domain') if configDomain: domain=configDomain else: domain='localhost' # get port number from configuration configPort=getConfigParam(baseDir,'port') if configPort: port=configPort else: port=8085 nickname=None if args.nickname: nickname=nickname federationList=[] if args.federationList: if len(args.federationList)==1: if not (args.federationList[0].lower()=='any' or \ args.federationList[0].lower()=='all' or \ args.federationList[0].lower()=='*'): for federationDomain in args.federationList: if '@' in federationDomain: print(federationDomain+': Federate with domains, not individual accounts') sys.exit() federationList=args.federationList.copy() setConfigParam(baseDir,'federationList',federationList) else: configFederationList=getConfigParam(baseDir,'federationList') if configFederationList: federationList=configFederationList useTor=args.tor if domain.endswith('.onion'): useTor=True if args.approve: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if '@' not in args.approve: print('syntax: --approve nick@domain') sys.exit() handle=args.nickname+'@'+domain accountsDir=baseDir+'/accounts/'+handle approveFollowsFilename=accountDir+'/followrequests.txt' if handle in open(approveFollowsFilename).read(): with open(approveFollowsFilename+'.new', 'w') as approvefilenew: with open(approveFollowsFilename, 'r') as approvefile: for approveHandle in approvefile: if approveHandle.startswith(args.approve): if ':' in approveHandle: port=int(approveHandle.split(':')[1].replace('\n','')) # TODO approve follow for handle/port else: approvefilenew.write(approveHandle) os.rename(approveFollowsFilename+'.new',approveFollowsFilename) sys.exit() if args.deny: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if '@' not in args.deny: print('syntax: --deny nick@domain') sys.exit() handle=args.nickname+'@'+domain accountsDir=baseDir+'/accounts/'+handle approveFollowsFilename=accountDir+'/followrequests.txt' if handle in open(approveFollowsFilename).read(): with open(approveFollowsFilename+'.new', 'w') as approvefilenew: with open(approveFollowsFilename, 'r') as approvefile: for approveHandle in approvefile: if not approveHandle.startswith(args.deny): approvefilenew.write(approveHandle) os.rename(approveFollowsFilename+'.new',approveFollowsFilename) print('Follow request from '+args.deny+' was denied.') sys.exit() if args.followerspending: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() accountsDir=baseDir+'/accounts/'+args.nickname+'@'+domain approveFollowsFilename=accountDir+'/followrequests.txt' approveCtr=0 if os.path.isfile(approveFollowsFilename): with open(approveFollowsFilename, 'r') as approvefile: for approve in approvefile: print(approve.replace('\n','')) approveCtr+=1 if approveCtr==0: print('There are no follow requests pending approval.') sys.exit() if args.message: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() session = createSession(domain,port,useTor) if not args.sendto: print('Specify an account to sent to: --sendto [nickname@domain]') sys.exit() if '@' not in args.sendto and \ not args.sendto.lower().endswith('public') and \ not args.sendto.lower().endswith('followers'): print('syntax: --sendto [nickname@domain]') print(' --sendto public') print(' --sendto followers') sys.exit() if '@' in args.sendto: toNickname=args.sendto.split('@')[0] toDomain=args.sendto.split('@')[1].replace('\n','') toPort=443 if ':' in toDomain: toPort=toDomain.split(':')[1] toDomain=toDomain.split(':')[0] else: if args.sendto.endswith('followers'): toNickname=None toDomain='followers' toPort=port else: toNickname=None toDomain='public' toPort=port #ccUrl=httpPrefix+'://'+domain+'/users/'+nickname+'/followers' ccUrl=None sendMessage=args.message followersOnly=args.followersonly clientToServer=args.client attachedImageDescription=args.imageDescription useBlurhash=args.blurhash sendThreads = [] postLog = [] personCache={} cachedWebfingers={} subject=args.subject attach=args.attach replyTo=args.replyto followersOnly=False print('Sending post to '+args.sendto) sendPostViaServer(session,args.nickname,args.password, \ domain,port, \ toNickname,toDomain,toPort,ccUrl, \ httpPrefix,sendMessage,followersOnly, \ attach,attachedImageDescription,useBlurhash, \ cachedWebfingers,personCache, \ args.debug,replyTo,replyTo,subject) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.announce: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending announce/repeat of '+args.announce) sendAnnounceViaServer(session,args.nickname,args.password, domain,port, \ httpPrefix,args.announce, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.like: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending like of '+args.like) sendLikeViaServer(session,args.nickname,args.password, domain,port, \ httpPrefix,args.like, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.undolike: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending undo like of '+args.undolike) sendUndoLikeViaServer(session,args.nickname,args.password, domain,port, \ httpPrefix,args.undolike, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.delete: if not args.nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending delete request of '+args.delete) sendDeleteViaServer(session,args.nickname,args.password, domain,port, \ httpPrefix,args.delete, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.follow: # follow via c2s protocol if '.' not in args.follow: print("This doesn't look like a fediverse handle") sys.exit() if not args.nickname: print('Please specify the nickname for the account with --nickname') sys.exit() if not args.password: print('Please specify the password for '+args.nickname+' on '+domain) sys.exit() followNickname=getNicknameFromActor(args.follow) followDomain,followPort=getDomainFromActor(args.follow) session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} followHttpPrefix=httpPrefix if args.follow.startswith('https'): followHttpPrefix='https' sendFollowRequestViaServer(session,args.nickname,args.password, \ domain,port, \ followNickname,followDomain,followPort, \ httpPrefix, \ cachedWebfingers,personCache, \ debug) for t in range(20): time.sleep(1) # TODO some method to know if it worked print('Ok') sys.exit() if args.unfollow: # unfollow via c2s protocol if '.' not in args.follow: print("This doesn't look like a fediverse handle") sys.exit() if not args.nickname: print('Please specify the nickname for the account with --nickname') sys.exit() if not args.password: print('Please specify the password for '+args.nickname+' on '+domain) sys.exit() followNickname=getNicknameFromActor(args.unfollow) followDomain,followPort=getDomainFromActor(args.unfollow) session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} followHttpPrefix=httpPrefix if args.follow.startswith('https'): followHttpPrefix='https' sendUnfollowRequestViaServer(session,args.nickname,args.password, \ domain,port, \ followNickname,followDomain,followPort, \ httpPrefix, \ cachedWebfingers,personCache, \ debug) for t in range(20): time.sleep(1) # TODO some method to know if it worked print('Ok') sys.exit() nickname='admin' if args.domain: domain=args.domain setConfigParam(baseDir,'domain',domain) if args.port: port=args.port setConfigParam(baseDir,'port',port) ocapAlways=False if args.ocap: ocapAlways=args.ocap if args.dat: httpPrefix='dat' if args.actor: if '@' not in args.actor: print('Syntax: --actor nickname@domain') sys.exit() nickname=args.actor.split('@')[0] domain=args.actor.split('@')[1].replace('\n','') wfCache={} if domain.endswith('.onion'): httpPrefix='http' port=80 else: httpPrefix='https' port=443 session = createSession(domain,port,useTor) wfRequest = webfingerHandle(session,nickname+'@'+domain,httpPrefix,wfCache) if not wfRequest: print('Unable to webfinger '+nickname+'@'+domain) sys.exit() asHeader = {'Accept': 'application/ld+json; profile="https://www.w3.org/ns/activitystreams"'} personUrl = getUserUrl(wfRequest) personJson = getJson(session,personUrl,asHeader,None) if personJson: pprint(personJson) else: print('Failed to get '+personUrl) sys.exit() if args.json: session = createSession(domain,port,True) asHeader = {'Accept': 'application/ld+json; profile="https://www.w3.org/ns/activitystreams"'} testJson = getJson(session,args.json,asHeader,None) pprint(testJson) sys.exit() if args.addaccount: if '@' in args.addaccount: nickname=args.addaccount.split('@')[0] domain=args.addaccount.split('@')[1] else: nickname=args.addaccount if not args.domain or not getConfigParam(baseDir,'domain'): print('Use the --domain option to set the domain name') sys.exit() if not validNickname(nickname): print(nickname+' is a reserved name. Use something different.') sys.exit() if not args.password: print('Use the --password option to set the password for '+nickname) sys.exit() if len(args.password.strip())<8: print('Password should be at least 8 characters') sys.exit() if os.path.isdir(baseDir+'/accounts/'+nickname+'@'+domain): print('Account already exists') sys.exit() createPerson(baseDir,nickname,domain,port,httpPrefix,True,args.password.strip()) if os.path.isdir(baseDir+'/accounts/'+nickname+'@'+domain): print('Account created for '+nickname+'@'+domain) else: print('Account creation failed') sys.exit() if args.rmaccount: if '@' in args.rmaccount: nickname=args.rmaccount.split('@')[0] domain=args.rmaccount.split('@')[1] else: nickname=args.rmaccount if not args.domain or not getConfigParam(baseDir,'domain'): print('Use the --domain option to set the domain name') sys.exit() handle=nickname+'@'+domain accountRemoved=False removePassword(baseDir,nickname) if os.path.isdir(baseDir+'/accounts/'+handle): shutil.rmtree(baseDir+'/accounts/'+handle) accountRemoved=True if os.path.isfile(baseDir+'/accounts/'+handle+'.json'): os.remove(baseDir+'/accounts/'+handle+'.json') accountRemoved=True if os.path.isfile(baseDir+'/wfendpoints/'+handle+'.json'): os.remove(baseDir+'/wfendpoints/'+handle+'.json') accountRemoved=True if os.path.isfile(baseDir+'/keys/private/'+handle+'.key'): os.remove(baseDir+'/keys/private/'+handle+'.key') accountRemoved=True if os.path.isfile(baseDir+'/keys/public/'+handle+'.pem'): os.remove(baseDir+'/keys/public/'+handle+'.pem') accountRemoved=True if accountRemoved: print('Account for '+handle+' was removed') sys.exit() if args.changepassword: if len(args.changepassword)!=2: print('--changepassword [nickname] [new password]') sys.exit() if '@' in args.changepassword[0]: nickname=args.changepassword[0].split('@')[0] domain=args.changepassword[0].split('@')[1] else: nickname=args.changepassword[0] if not args.domain or not getConfigParam(baseDir,'domain'): print('Use the --domain option to set the domain name') sys.exit() newPassword=args.changepassword[1] if len(newPassword)<8: print('Password should be at least 8 characters') sys.exit() if not os.path.isdir(baseDir+'/accounts/'+nickname+'@'+domain): print('Account '+nickname+'@'+domain+' not found') sys.exit() passwordFile=baseDir+'/accounts/passwords' if os.path.isfile(passwordFile): if nickname+':' in open(passwordFile).read(): storeBasicCredentials(baseDir,nickname,newPassword) print('Password for '+nickname+' was changed') else: print(nickname+' is not in the passwords file') else: print('Passwords file not found') sys.exit() archiveWeeks=4 if args.archiveWeeks: archiveWeeks=args.archiveWeeks archiveMaxPosts=256 if args.archiveMaxPosts: archiveMaxPosts=args.archiveMaxPosts if args.archive: if args.archive.lower().endswith('null') or \ args.archive.lower().endswith('delete') or \ args.archive.lower().endswith('none'): args.archive=None print('Archiving with deletion of old posts...') else: print('Archiving to '+args.archive+'...') archiveMedia(baseDir,args.archive,archiveWeeks) archivePosts(baseDir,httpPrefix,args.archive,archiveMaxPosts) print('Archiving complete') sys.exit() if not args.domain and not domain: print('Specify a domain with --domain [name]') sys.exit() if args.avatar: if not os.path.isfile(args.avatar): print(args.avatar+' is not an image filename') sys.exit() if not args.nickname: print('Specify a nickname with --nickname [name]') sys.exit() if setProfileImage(baseDir,httpPrefix,args.nickname,domain, \ port,args.avatar,'avatar','128x128'): print('Avatar added for '+args.nickname) else: print('Avatar was not added for '+args.nickname) sys.exit() if args.backgroundImage: if not os.path.isfile(args.backgroundImage): print(args.backgroundImage+' is not an image filename') sys.exit() if not args.nickname: print('Specify a nickname with --nickname [name]') sys.exit() if setProfileImage(baseDir,httpPrefix,args.nickname,domain, \ port,args.backgroundImage,'background','256x256'): print('Background image added for '+args.nickname) else: print('Background image was not added for '+args.nickname) sys.exit() if args.project: if not args.delegate and not args.undelegate: if not nickname: print('No nickname given') sys.exit() if args.role.lower()=='none' or \ args.role.lower()=='remove' or \ args.role.lower()=='delete': args.role=None if args.role: if setRole(baseDir,nickname,domain,args.project,args.role): print('Role within '+args.project+' set to '+args.role) else: if setRole(baseDir,nickname,domain,args.project,None): print('Left '+args.project) sys.exit() if args.skill: if not nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() if not args.skillLevelPercent: print('Specify a skill level in the range 0-100') sys.exit() if int(args.skillLevelPercent)<0 or int(args.skillLevelPercent)>100: print('Skill level should be a percentage in the range 0-100') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending '+args.skill+' skill level '+str(args.skillLevelPercent)+' for '+nickname) sendSkillViaServer(session,nickname,args.password, domain,port, \ httpPrefix, \ args.skill,args.skillLevelPercent, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.availability: if not nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending availability status of '+nickname+' as '+args.availability) sendAvailabilityViaServer(session,nickname,args.password, domain,port, \ httpPrefix, \ args.availability, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if federationList: print('Federating with: '+str(federationList)) #if not os.path.isdir(baseDir+'/accounts/'+nickname+'@'+domain): # print('Creating default admin account '+nickname+'@'+domain) # print('See config.json for the password. You can remove the password from config.json after moving it elsewhere.') # adminPassword=createPassword(10) # setConfigParam(baseDir,'adminPassword',adminPassword) # createPerson(baseDir,nickname,domain,port,httpPrefix,True,adminPassword) if args.block: if not nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() if '@' in args.block: blockedDomain=args.block.split('@')[1].replace('\n','') blockedNickname=args.block.split('@')[0] blockedActor=httpPrefix+'://'+blockedDomain+'/users/'+blockedNickname args.block=blockedActor else: if '/users/' not in args.block: print(args.block+' does not look like an actor url') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending block of '+args.block) sendBlockViaServer(session,nickname,args.password, domain,port, \ httpPrefix,args.block, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.delegate: if not nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() if not args.project: print('Specify a project with the --project option') sys.exit() if not args.role: print('Specify a role with the --role option') sys.exit() if '@' in args.delegate: delegatedNickname=args.delegate.split('@')[0] args.delegate=blockedActor session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending delegation for '+args.delegate+' with role '+args.role+' in project '+args.project) sendRoleViaServer(session,nickname,args.password, domain,port, \ httpPrefix,args.delegate, \ args.project,args.role, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.undelegate: if not nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() if not args.project: print('Specify a project with the --project option') sys.exit() if '@' in args.undelegate: delegatedNickname=args.undelegate.split('@')[0] args.undelegate=blockedActor session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending delegation removal for '+args.undelegate+' from role '+args.role+' in project '+args.project) sendRoleViaServer(session,nickname,args.password, domain,port, \ httpPrefix,args.delegate, \ args.project,None, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.unblock: if not nickname: print('Specify a nickname with the --nickname option') sys.exit() if not args.password: print('Specify a password with the --password option') sys.exit() if '@' in args.unblock: blockedDomain=args.unblock.split('@')[1].replace('\n','') blockedNickname=args.unblock.split('@')[0] blockedActor=httpPrefix+'://'+blockedDomain+'/users/'+blockedNickname args.unblock=blockedActor else: if '/users/' not in args.unblock: print(args.unblock+' does not look like an actor url') sys.exit() session = createSession(domain,port,useTor) personCache={} cachedWebfingers={} print('Sending undo block of '+args.unblock) sendUndoBlockViaServer(session,nickname,args.password, domain,port, \ httpPrefix,args.unblock, \ cachedWebfingers,personCache, \ True) for i in range(10): # TODO detect send success/fail time.sleep(1) sys.exit() if args.filterStr: if not args.nickname: print('Please specify a nickname') sys.exit() if addFilter(baseDir,args.nickname,domain,args.filterStr): print('Filter added to '+args.nickname+': '+args.filterStr) sys.exit() if args.unfilterStr: if not args.nickname: print('Please specify a nickname') sys.exit() if removeFilter(baseDir,args.nickname,domain,args.unfilterStr): print('Filter removed from '+args.nickname+': '+args.unfilterStr) sys.exit() if args.testdata: useBlurhash=False nickname='testuser567' print('Generating some test data for user: '+nickname) createPerson(baseDir,nickname,domain,port,httpPrefix,True,'likewhateveryouwantscoob') setSkillLevel(baseDir,nickname,domain,'testing',60) setSkillLevel(baseDir,nickname,domain,'typing',50) setRole(baseDir,nickname,domain,'epicyon','tester') setRole(baseDir,nickname,domain,'epicyon','hacker') setRole(baseDir,nickname,domain,'someproject','assistant') setAvailability(baseDir,nickname,domain,'busy') deleteAllPosts(baseDir,nickname,domain,'inbox') deleteAllPosts(baseDir,nickname,domain,'outbox') followPerson(baseDir,nickname,domain,'admin',domain,federationList,True) followerOfPerson(baseDir,nickname,domain,'admin',domain,federationList,True) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"like, this is totally just a test, man",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"Zoiks!!!",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"Hey scoob we need like a hundred more milkshakes",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"Getting kinda spooky around here",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"And they would have gotten away with it too if it wasn't for those pesky hackers",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"man, these centralized sites are, like, the worst!",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"another mystery solved hey",False,True,False,None,None,useBlurhash) createPublicPost(baseDir,nickname,domain,port,httpPrefix,"let's go bowling",False,True,False,None,None,useBlurhash) runDaemon(args.client,baseDir,domain,port,httpPrefix, \ federationList, \ args.noreply,args.nolike,args.nopics, \ args.noannounce,args.cw,ocapAlways, \ useTor,args.maxReplies, \ args.domainMaxPostsPerDay,args.accountMaxPostsPerDay, \ args.allowdeletion,debug)