Changeset View
Changeset View
Standalone View
Standalone View
swh/graph/client.py
Show All 18 Lines | class RemoteGraphClient(RPCClient): | ||||
"""Client to the Software Heritage Graph.""" | """Client to the Software Heritage Graph.""" | ||||
def __init__(self, url, timeout=None): | def __init__(self, url, timeout=None): | ||||
super().__init__( | super().__init__( | ||||
api_exception=GraphAPIError, url=url, timeout=timeout) | api_exception=GraphAPIError, url=url, timeout=timeout) | ||||
def raw_verb_lines(self, verb, endpoint, **kwargs): | def raw_verb_lines(self, verb, endpoint, **kwargs): | ||||
response = self.raw_verb(verb, endpoint, stream=True, **kwargs) | response = self.raw_verb(verb, endpoint, stream=True, **kwargs) | ||||
self.check_status(response) | |||||
for line in response.iter_lines(): | for line in response.iter_lines(): | ||||
yield line.decode().lstrip('\n') | yield line.decode().lstrip('\n') | ||||
def get_lines(self, endpoint, **kwargs): | def get_lines(self, endpoint, **kwargs): | ||||
yield from self.raw_verb_lines('get', endpoint, **kwargs) | yield from self.raw_verb_lines('get', endpoint, **kwargs) | ||||
# Web API endpoints | # Web API endpoints | ||||
▲ Show 20 Lines • Show All 84 Lines • Show Last 20 Lines |