mirror of https://gitlab.com/bashrc2/epicyon
Less verbose
parent
041b6f0a8c
commit
6dc85f69dc
|
@ -731,7 +731,7 @@ if args.json:
|
||||||
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
||||||
}
|
}
|
||||||
testJson = getJson(session, args.json, asHeader, None,
|
testJson = getJson(session, args.json, asHeader, None,
|
||||||
__version__, httpPrefix, None)
|
debug, __version__, httpPrefix, None)
|
||||||
pprint(testJson)
|
pprint(testJson)
|
||||||
sys.exit()
|
sys.exit()
|
||||||
|
|
||||||
|
|
4
inbox.py
4
inbox.py
|
@ -253,8 +253,8 @@ def getPersonPubKey(baseDir: str, session, personUrl: str,
|
||||||
'Accept': 'application/activity+json; profile="' + profileStr + '"'
|
'Accept': 'application/activity+json; profile="' + profileStr + '"'
|
||||||
}
|
}
|
||||||
personJson = \
|
personJson = \
|
||||||
getJson(session, personUrl, asHeader, None, projectVersion,
|
getJson(session, personUrl, asHeader, None, debug,
|
||||||
httpPrefix, personDomain)
|
projectVersion, httpPrefix, personDomain)
|
||||||
if not personJson:
|
if not personJson:
|
||||||
return None
|
return None
|
||||||
pubKey = None
|
pubKey = None
|
||||||
|
|
|
@ -85,8 +85,8 @@ def _updateMovedHandle(baseDir: str, nickname: str, domain: str,
|
||||||
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
||||||
}
|
}
|
||||||
personJson = \
|
personJson = \
|
||||||
getJson(session, personUrl, asHeader, None, __version__,
|
getJson(session, personUrl, asHeader, None,
|
||||||
httpPrefix, None)
|
debug, __version__, httpPrefix, None)
|
||||||
if not personJson:
|
if not personJson:
|
||||||
return ctr
|
return ctr
|
||||||
if not personJson.get('movedTo'):
|
if not personJson.get('movedTo'):
|
||||||
|
|
|
@ -1225,8 +1225,8 @@ def getActorJson(handle: str, http: bool, gnunet: bool,
|
||||||
}
|
}
|
||||||
|
|
||||||
personJson = \
|
personJson = \
|
||||||
getJson(session, personUrl, asHeader, None, __version__,
|
getJson(session, personUrl, asHeader, None,
|
||||||
httpPrefix, None, 20, quiet)
|
debug, __version__, httpPrefix, None, 20, quiet)
|
||||||
if personJson:
|
if personJson:
|
||||||
if not quiet:
|
if not quiet:
|
||||||
pprint(personJson)
|
pprint(personJson)
|
||||||
|
@ -1237,7 +1237,7 @@ def getActorJson(handle: str, http: bool, gnunet: bool,
|
||||||
}
|
}
|
||||||
personJson = \
|
personJson = \
|
||||||
getJson(session, personUrl, asHeader, None,
|
getJson(session, personUrl, asHeader, None,
|
||||||
__version__, httpPrefix, None)
|
debug, __version__, httpPrefix, None)
|
||||||
if not quiet:
|
if not quiet:
|
||||||
if personJson:
|
if personJson:
|
||||||
pprint(personJson)
|
pprint(personJson)
|
||||||
|
|
17
posts.py
17
posts.py
|
@ -183,7 +183,7 @@ def parseUserFeed(session, feedUrl: str, asHeader: {},
|
||||||
return None
|
return None
|
||||||
|
|
||||||
feedJson = getJson(session, feedUrl, asHeader, None,
|
feedJson = getJson(session, feedUrl, asHeader, None,
|
||||||
projectVersion, httpPrefix, domain)
|
False, projectVersion, httpPrefix, domain)
|
||||||
if not feedJson:
|
if not feedJson:
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
@ -220,6 +220,7 @@ def getPersonBox(baseDir: str, session, wfRequest: {},
|
||||||
nickname: str, domain: str,
|
nickname: str, domain: str,
|
||||||
boxName='inbox',
|
boxName='inbox',
|
||||||
sourceId=0) -> (str, str, str, str, str, str, str, str):
|
sourceId=0) -> (str, str, str, str, str, str, str, str):
|
||||||
|
debug = False
|
||||||
profileStr = 'https://www.w3.org/ns/activitystreams'
|
profileStr = 'https://www.w3.org/ns/activitystreams'
|
||||||
asHeader = {
|
asHeader = {
|
||||||
'Accept': 'application/activity+json; profile="' + profileStr + '"'
|
'Accept': 'application/activity+json; profile="' + profileStr + '"'
|
||||||
|
@ -229,7 +230,7 @@ def getPersonBox(baseDir: str, session, wfRequest: {},
|
||||||
return None, None, None, None, None, None, None
|
return None, None, None, None, None, None, None
|
||||||
|
|
||||||
if not wfRequest.get('errors'):
|
if not wfRequest.get('errors'):
|
||||||
personUrl = getUserUrl(wfRequest, sourceId, False)
|
personUrl = getUserUrl(wfRequest, sourceId, debug)
|
||||||
else:
|
else:
|
||||||
if nickname == 'dev':
|
if nickname == 'dev':
|
||||||
# try single user instance
|
# try single user instance
|
||||||
|
@ -250,13 +251,13 @@ def getPersonBox(baseDir: str, session, wfRequest: {},
|
||||||
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
||||||
}
|
}
|
||||||
personJson = getJson(session, personUrl, asHeader, None,
|
personJson = getJson(session, personUrl, asHeader, None,
|
||||||
projectVersion, httpPrefix, domain)
|
debug, projectVersion, httpPrefix, domain)
|
||||||
if not personJson:
|
if not personJson:
|
||||||
asHeader = {
|
asHeader = {
|
||||||
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
||||||
}
|
}
|
||||||
personJson = getJson(session, personUrl, asHeader, None,
|
personJson = getJson(session, personUrl, asHeader, None,
|
||||||
projectVersion, httpPrefix, domain)
|
debug, projectVersion, httpPrefix, domain)
|
||||||
if not personJson:
|
if not personJson:
|
||||||
print('Unable to get actor')
|
print('Unable to get actor')
|
||||||
return None, None, None, None, None, None, None
|
return None, None, None, None, None, None, None
|
||||||
|
@ -3537,7 +3538,7 @@ def getPublicPostDomains(session, baseDir: str, nickname: str, domain: str,
|
||||||
def downloadFollowCollection(followType: str,
|
def downloadFollowCollection(followType: str,
|
||||||
session, httpPrefix,
|
session, httpPrefix,
|
||||||
actor: str, pageNumber=1,
|
actor: str, pageNumber=1,
|
||||||
noOfPages=1) -> []:
|
noOfPages=1, debug=False) -> []:
|
||||||
"""Returns a list of following/followers for the given actor
|
"""Returns a list of following/followers for the given actor
|
||||||
by downloading the json for their following/followers collection
|
by downloading the json for their following/followers collection
|
||||||
"""
|
"""
|
||||||
|
@ -3554,8 +3555,8 @@ def downloadFollowCollection(followType: str,
|
||||||
for pageCtr in range(noOfPages):
|
for pageCtr in range(noOfPages):
|
||||||
url = actor + '/' + followType + '?page=' + str(pageNumber + pageCtr)
|
url = actor + '/' + followType + '?page=' + str(pageNumber + pageCtr)
|
||||||
followersJson = \
|
followersJson = \
|
||||||
getJson(session, url, sessionHeaders, None, __version__,
|
getJson(session, url, sessionHeaders, None,
|
||||||
httpPrefix, None)
|
debug, __version__, httpPrefix, None)
|
||||||
if followersJson:
|
if followersJson:
|
||||||
if followersJson.get('orderedItems'):
|
if followersJson.get('orderedItems'):
|
||||||
for followerActor in followersJson['orderedItems']:
|
for followerActor in followersJson['orderedItems']:
|
||||||
|
@ -3913,7 +3914,7 @@ def downloadAnnounce(session, baseDir: str, httpPrefix: str,
|
||||||
postJsonObject['object'])
|
postJsonObject['object'])
|
||||||
announcedJson = \
|
announcedJson = \
|
||||||
getJson(session, postJsonObject['object'], asHeader,
|
getJson(session, postJsonObject['object'], asHeader,
|
||||||
None, projectVersion, httpPrefix, domain)
|
None, debug, projectVersion, httpPrefix, domain)
|
||||||
|
|
||||||
if not announcedJson:
|
if not announcedJson:
|
||||||
return None
|
return None
|
||||||
|
|
|
@ -84,11 +84,11 @@ def urlExists(session, url: str, timeoutSec=3,
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
|
||||||
def getJson(session, url: str, headers: {}, params: {},
|
def getJson(session, url: str, headers: {}, params: {}, debug: bool,
|
||||||
version='1.2.0', httpPrefix='https',
|
version='1.2.0', httpPrefix='https',
|
||||||
domain='testdomain', timeoutSec=20, quiet=False) -> {}:
|
domain='testdomain', timeoutSec=20, quiet=False) -> {}:
|
||||||
if not isinstance(url, str):
|
if not isinstance(url, str):
|
||||||
if not quiet:
|
if debug and not quiet:
|
||||||
print('url: ' + str(url))
|
print('url: ' + str(url))
|
||||||
print('ERROR: getJson failed, url should be a string')
|
print('ERROR: getJson failed, url should be a string')
|
||||||
return None
|
return None
|
||||||
|
@ -114,7 +114,7 @@ def getJson(session, url: str, headers: {}, params: {},
|
||||||
sessionHeaders2 = sessionHeaders.copy()
|
sessionHeaders2 = sessionHeaders.copy()
|
||||||
if sessionHeaders2.get('Authorization'):
|
if sessionHeaders2.get('Authorization'):
|
||||||
sessionHeaders2['Authorization'] = 'REDACTED'
|
sessionHeaders2['Authorization'] = 'REDACTED'
|
||||||
if not quiet:
|
if debug and not quiet:
|
||||||
print('ERROR: getJson failed\nurl: ' + str(url) + ' ' +
|
print('ERROR: getJson failed\nurl: ' + str(url) + ' ' +
|
||||||
'headers: ' + str(sessionHeaders2) + ' ' +
|
'headers: ' + str(sessionHeaders2) + ' ' +
|
||||||
'params: ' + str(sessionParams))
|
'params: ' + str(sessionParams))
|
||||||
|
@ -123,7 +123,7 @@ def getJson(session, url: str, headers: {}, params: {},
|
||||||
sessionHeaders2 = sessionHeaders.copy()
|
sessionHeaders2 = sessionHeaders.copy()
|
||||||
if sessionHeaders2.get('Authorization'):
|
if sessionHeaders2.get('Authorization'):
|
||||||
sessionHeaders2['Authorization'] = 'REDACTED'
|
sessionHeaders2['Authorization'] = 'REDACTED'
|
||||||
if not quiet:
|
if debug and not quiet:
|
||||||
print('ERROR: getJson failed\nurl: ' + str(url) + ' ' +
|
print('ERROR: getJson failed\nurl: ' + str(url) + ' ' +
|
||||||
'headers: ' + str(sessionHeaders2) + ' ' +
|
'headers: ' + str(sessionHeaders2) + ' ' +
|
||||||
'params: ' + str(sessionParams) + ' ')
|
'params: ' + str(sessionParams) + ' ')
|
||||||
|
|
|
@ -279,7 +279,7 @@ def getSpeakerFromServer(baseDir: str, session,
|
||||||
domainFull + '/users/' + nickname + '/speaker'
|
domainFull + '/users/' + nickname + '/speaker'
|
||||||
|
|
||||||
speakerJson = \
|
speakerJson = \
|
||||||
getJson(session, url, headers, None,
|
getJson(session, url, headers, None, debug,
|
||||||
__version__, httpPrefix, domain, 20, True)
|
__version__, httpPrefix, domain, 20, True)
|
||||||
return speakerJson
|
return speakerJson
|
||||||
|
|
||||||
|
|
|
@ -156,14 +156,14 @@ def htmlProfileAfterSearch(cssCache: {},
|
||||||
}
|
}
|
||||||
personUrl = httpPrefix + '://' + searchDomainFull
|
personUrl = httpPrefix + '://' + searchDomainFull
|
||||||
profileJson = \
|
profileJson = \
|
||||||
getJson(session, personUrl, asHeader, None,
|
getJson(session, personUrl, asHeader, None, debug,
|
||||||
projectVersion, httpPrefix, domain)
|
projectVersion, httpPrefix, domain)
|
||||||
if not profileJson:
|
if not profileJson:
|
||||||
asHeader = {
|
asHeader = {
|
||||||
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
'Accept': 'application/ld+json; profile="' + profileStr + '"'
|
||||||
}
|
}
|
||||||
profileJson = \
|
profileJson = \
|
||||||
getJson(session, personUrl, asHeader, None,
|
getJson(session, personUrl, asHeader, None, debug,
|
||||||
projectVersion, httpPrefix, domain)
|
projectVersion, httpPrefix, domain)
|
||||||
if not profileJson:
|
if not profileJson:
|
||||||
print('DEBUG: No actor returned from ' + personUrl)
|
print('DEBUG: No actor returned from ' + personUrl)
|
||||||
|
|
|
@ -441,7 +441,7 @@ def setBlogAddress(actorJson: {}, blogAddress: str) -> None:
|
||||||
def updateAvatarImageCache(session, baseDir: str, httpPrefix: str,
|
def updateAvatarImageCache(session, baseDir: str, httpPrefix: str,
|
||||||
actor: str, avatarUrl: str,
|
actor: str, avatarUrl: str,
|
||||||
personCache: {}, allowDownloads: bool,
|
personCache: {}, allowDownloads: bool,
|
||||||
force=False) -> str:
|
force=False, debug=False) -> str:
|
||||||
"""Updates the cached avatar for the given actor
|
"""Updates the cached avatar for the given actor
|
||||||
"""
|
"""
|
||||||
if not avatarUrl:
|
if not avatarUrl:
|
||||||
|
@ -502,8 +502,8 @@ def updateAvatarImageCache(session, baseDir: str, httpPrefix: str,
|
||||||
'Accept': 'application/ld+json; profile="' + prof + '"'
|
'Accept': 'application/ld+json; profile="' + prof + '"'
|
||||||
}
|
}
|
||||||
personJson = \
|
personJson = \
|
||||||
getJson(session, actor, sessionHeaders, None, __version__,
|
getJson(session, actor, sessionHeaders, None,
|
||||||
httpPrefix, None)
|
debug, __version__, httpPrefix, None)
|
||||||
if personJson:
|
if personJson:
|
||||||
if not personJson.get('id'):
|
if not personJson.get('id'):
|
||||||
return None
|
return None
|
||||||
|
|
|
@ -74,7 +74,8 @@ def webfingerHandle(session, handle: str, httpPrefix: str,
|
||||||
}
|
}
|
||||||
try:
|
try:
|
||||||
result = \
|
result = \
|
||||||
getJson(session, url, hdr, par, projectVersion,
|
getJson(session, url, hdr, par,
|
||||||
|
debug, projectVersion,
|
||||||
httpPrefix, fromDomain)
|
httpPrefix, fromDomain)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print(e)
|
print(e)
|
||||||
|
|
Loading…
Reference in New Issue