mirror
/
bridgy-fed
kopia lustrzana https://github.com/snarfed/bridgy-fed
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

app.bsky.feed.getAuthorFeed, in progress

pull/368/head
Ryan Barrett 2022-12-28 17:30:22 -08:00
rodzic 3811206666
commit e5b3307828
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: 6BE31FDF4776E9D4
5 zmienionych plików z 181 dodań i 5 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
tests/test_xrpc_actor.py
Wyświetl plik

@ -9,7 +9,7 @@ from . import testutil
@patch('requests.get')
class ActorTest(testutil.TestCase):
class XrpcActorTest(testutil.TestCase):
def test_getProfile(self, mock_get):
mock_get.return_value = requests_response("""

93
tests/test_xrpc_feed.py
Wyświetl plik

@ -1 +1,94 @@
"""Unit tests for feed.py."""
from unittest.mock import patch
from oauth_dropins.webutil import util
from oauth_dropins.webutil.testutil import requests_response
import requests
from . import testutil
@patch('requests.get')
class XrpcFeedTest(testutil.TestCase):
def test_getAuthorFeed(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
'feed': [{
'post': {
},
}, {
'post': {
},
'reply': {
},
}, {
'post': {
},
'reason': {
'by': '',
'indexedAt': testutil.NOW.isoformat(),
}
}],
}, got)
def test_getAuthorFeed_not_domain(self, _):
resp = self.client.get('/xrpc/app.bsky.feed.getAuthorFeed',
query_string={'actor': 'not a domain'})
self.assertEqual(400, resp.status_code)
def test_getPostThread(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)
def test_getRepostedBy(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)
def test_getTimeline(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)
def test_getVotes(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getVotes',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)

59
tests/test_xrpc_graph.py
Wyświetl plik

@ -1 +1,60 @@
"""Unit tests for graph.py."""
from unittest.mock import patch
from oauth_dropins.webutil import util
from oauth_dropins.webutil.testutil import requests_response
import requests
from . import testutil
@patch('requests.get')
class XrpcGraphTest(testutil.TestCase):
def test_getAuthorFeed(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)
def test_getPostThread(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)
def test_getRepostedBy(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)
def test_getTimeline(self, mock_get):
mock_get.return_value = requests_response("""
<body>
</body>
""", url='https://foo.com/')
got = self.client.get('/xrpc/app.bsky.actor.getProfile',
query_string={'actor': 'foo.com'},
).json
self.assertEqual({
}, got)

2
xrpc_actor.py
Wyświetl plik

@ -23,7 +23,7 @@ def getProfile(input, actor=None):
raise ValueError(f'{actor} is not a domain')
url = f'https://{actor}/'
mf2 = util.fetch_mf2(url)
mf2 = util.fetch_mf2(url, gateway=True)
hcard = mf2util.representative_hcard(mf2, mf2['url'])
if not hcard:
raise ValueError(f"Couldn't find a representative h-card (http://microformats.org/wiki/representative-hcard-parsing) on {mf2['url']}")

30
xrpc_feed.py
Wyświetl plik

@ -7,10 +7,35 @@ logger = logging.getLogger(__name__)
@xrpc_server.method('app.bsky.feed.getAuthorFeed')
def getAuthorFeed(input):
def getAuthorFeed(input, author=None, limit=None, before=None):
"""
lexicons/app/bsky/feed/getAuthorFeed.json
lexicons/app/bsky/feed/getAuthorFeed.json, feedViewPost.json
"""
if not re.match(util.DOMAIN_RE, author):
raise ValueError(f'{actor} is not a domain')
url = f'https://{actor}/'
mf2 = util.fetch_mf2(url, gateway=True)
hcard = mf2util.representative_hcard(mf2, mf2['url'])
if not hcard:
raise ValueError(f"Couldn't find a representative h-card (http://microformats.org/wiki/representative-hcard-parsing) on {mf2['url']}")
logger.info(f'Representative h-card: {json.dumps(hcard, indent=2)}')
actor = microformats2.json_to_object(hcard)
logger.info(f'AS1 actor: {json.dumps(actor, indent=2)}')
profile = {
**bluesky.from_as1(actor, from_url=url),
'myState': {
# ?
'follow': 'TODO',
'member': 'TODO',
},
}
logger.info(f'Bluesky profile: {json.dumps(profile, indent=2)}')
return profile
@xrpc_server.method('app.bsky.feed.getPostThread')
def getPostThread(input):
@ -41,4 +66,3 @@ def setVote(input):
"""
lexicons/app/bsky/feed/setVote.json
"""