hyperpy/hyperspace-rpc
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: hyperpy:0.0.1a1
Branches Tags
hyperpy:master
hyperpy:0.0.1a3 hyperpy:0.0.1a2 hyperpy:0.0.1a1
...
compare: hyperpy:master
Branches Tags
hyperpy:master
hyperpy:0.0.1a3 hyperpy:0.0.1a2 hyperpy:0.0.1a1

4 Commits
0.0.1a1 ... master

Author SHA1 Message Date
Luke Murphy
4adb778960 Mark as WIP
All checks were successful
continuous-integration/drone/push Build is passing
Details
2020-08-16 20:41:57 +02:00
Luke Murphy
87b92548a4 Remove test files
All checks were successful
continuous-integration/drone/push Build is passing
Details
2020-08-16 20:41:29 +02:00
Luke Murphy
5f1f88106c Fix import paths
All checks were successful
continuous-integration/drone/tag Build is passing
Details
continuous-integration/drone/push Build is passing
Details
2020-08-10 14:44:59 +02:00
Luke Murphy
361bec2846 Add missing hrpc generated files
All checks were successful
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/tag Build is passing
Details
2020-08-09 23:35:39 +02:00
6 changed files with 18 additions and 4224 deletions
Expand all files Collapse all files

8
CHANGELOG.md
View File

@ -1,3 +1,11 @@
# hyperspace-rpc 0.0.1a3 (2020-08-10)
- Fix import paths and add import re-writer
# hyperspace-rpc 0.0.1a2 (2020-08-09)
- Add missing hrpc.proto generate service and stub files
# hyperspace-rpc 0.0.1a1 (2020-08-09) # hyperspace-rpc 0.0.1a1 (2020-08-09)
- The first alpha development release is made! - The first alpha development release is made!

2
README.md
View File

@ -4,6 +4,8 @@
## Raw RPC layer for Hyperspace ## Raw RPC layer for Hyperspace
> **Work In Progres**
## Install ## Install
```sh ```sh

732
hyperspace_rpc/schema_grpc.py
View File

@ -1,732 +0,0 @@
import hrpc_pb2 as hrpc__pb2
import purerpc
import schema_pb2 as schema__pb2
class HyperspaceServicer(purerpc.Servicer):
async def Status(self, input_message):
raise NotImplementedError()
@property
def service(self) -> purerpc.Service:
service_obj = purerpc.Service("hyperspace.Hyperspace")
service_obj.add_method(
"Status",
self.Status,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
hrpc__pb2.Void,
schema__pb2.HyperspaceStatusResponse,
),
)
return service_obj
class HyperspaceStub:
def __init__(self, channel):
self._client = purerpc.Client("hyperspace.Hyperspace", channel)
self.Status = self._client.get_method_stub(
"Status",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
hrpc__pb2.Void,
schema__pb2.HyperspaceStatusResponse,
),
)
class CorestoreServicer(purerpc.Servicer):
async def Open(self, input_message):
raise NotImplementedError()
async def OnFeed(self, input_message):
raise NotImplementedError()
@property
def service(self) -> purerpc.Service:
service_obj = purerpc.Service("hyperspace.Corestore")
service_obj.add_method(
"Open",
self.Open,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.OpenRequest,
schema__pb2.OpenResponse,
),
)
service_obj.add_method(
"OnFeed",
self.OnFeed,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.FeedEvent,
hrpc__pb2.Void,
),
)
return service_obj
class CorestoreStub:
def __init__(self, channel):
self._client = purerpc.Client("hyperspace.Corestore", channel)
self.Open = self._client.get_method_stub(
"Open",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.OpenRequest,
schema__pb2.OpenResponse,
),
)
self.OnFeed = self._client.get_method_stub(
"OnFeed",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.FeedEvent,
hrpc__pb2.Void,
),
)
class HypercoreServicer(purerpc.Servicer):
async def Get(self, input_message):
raise NotImplementedError()
async def Append(self, input_message):
raise NotImplementedError()
async def Update(self, input_message):
raise NotImplementedError()
async def Seek(self, input_message):
raise NotImplementedError()
async def Has(self, input_message):
raise NotImplementedError()
async def Cancel(self, input_message):
raise NotImplementedError()
async def Download(self, input_message):
raise NotImplementedError()
async def Downloaded(self, input_message):
raise NotImplementedError()
async def Undownload(self, input_message):
raise NotImplementedError()
async def Close(self, input_message):
raise NotImplementedError()
async def RegisterExtension(self, input_message):
raise NotImplementedError()
async def UnregisterExtension(self, input_message):
raise NotImplementedError()
async def SendExtension(self, input_message):
raise NotImplementedError()
async def AcquireLock(self, input_message):
raise NotImplementedError()
async def ReleaseLock(self, input_message):
raise NotImplementedError()
async def OnAppend(self, input_message):
raise NotImplementedError()
async def OnClose(self, input_message):
raise NotImplementedError()
async def OnPeerOpen(self, input_message):
raise NotImplementedError()
async def OnPeerRemove(self, input_message):
raise NotImplementedError()
async def OnExtension(self, input_message):
raise NotImplementedError()
async def OnWait(self, input_message):
raise NotImplementedError()
@property
def service(self) -> purerpc.Service:
service_obj = purerpc.Service("hyperspace.Hypercore")
service_obj.add_method(
"Get",
self.Get,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.GetRequest,
schema__pb2.GetResponse,
),
)
service_obj.add_method(
"Append",
self.Append,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.AppendRequest,
schema__pb2.AppendResponse,
),
)
service_obj.add_method(
"Update",
self.Update,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UpdateRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"Seek",
self.Seek,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.SeekRequest,
schema__pb2.SeekResponse,
),
)
service_obj.add_method(
"Has",
self.Has,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.HasRequest,
schema__pb2.HasResponse,
),
)
service_obj.add_method(
"Cancel",
self.Cancel,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.CancelRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"Download",
self.Download,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.DownloadRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"Downloaded",
self.Downloaded,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.DownloadedRequest,
schema__pb2.DownloadedResponse,
),
)
service_obj.add_method(
"Undownload",
self.Undownload,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UndownloadRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"Close",
self.Close,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.CloseRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"RegisterExtension",
self.RegisterExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.RegisterExtensionRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"UnregisterExtension",
self.UnregisterExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UnregisterExtensionRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"SendExtension",
self.SendExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"AcquireLock",
self.AcquireLock,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.LockRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"ReleaseLock",
self.ReleaseLock,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.LockRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnAppend",
self.OnAppend,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.AppendEvent,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnClose",
self.OnClose,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.CloseEvent,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnPeerOpen",
self.OnPeerOpen,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnPeerRemove",
self.OnPeerRemove,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnExtension",
self.OnExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnWait",
self.OnWait,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.WaitEvent,
hrpc__pb2.Void,
),
)
return service_obj
class HypercoreStub:
def __init__(self, channel):
self._client = purerpc.Client("hyperspace.Hypercore", channel)
self.Get = self._client.get_method_stub(
"Get",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.GetRequest,
schema__pb2.GetResponse,
),
)
self.Append = self._client.get_method_stub(
"Append",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.AppendRequest,
schema__pb2.AppendResponse,
),
)
self.Update = self._client.get_method_stub(
"Update",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UpdateRequest,
hrpc__pb2.Void,
),
)
self.Seek = self._client.get_method_stub(
"Seek",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.SeekRequest,
schema__pb2.SeekResponse,
),
)
self.Has = self._client.get_method_stub(
"Has",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.HasRequest,
schema__pb2.HasResponse,
),
)
self.Cancel = self._client.get_method_stub(
"Cancel",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.CancelRequest,
hrpc__pb2.Void,
),
)
self.Download = self._client.get_method_stub(
"Download",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.DownloadRequest,
hrpc__pb2.Void,
),
)
self.Downloaded = self._client.get_method_stub(
"Downloaded",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.DownloadedRequest,
schema__pb2.DownloadedResponse,
),
)
self.Undownload = self._client.get_method_stub(
"Undownload",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UndownloadRequest,
hrpc__pb2.Void,
),
)
self.Close = self._client.get_method_stub(
"Close",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.CloseRequest,
hrpc__pb2.Void,
),
)
self.RegisterExtension = self._client.get_method_stub(
"RegisterExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.RegisterExtensionRequest,
hrpc__pb2.Void,
),
)
self.UnregisterExtension = self._client.get_method_stub(
"UnregisterExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UnregisterExtensionRequest,
hrpc__pb2.Void,
),
)
self.SendExtension = self._client.get_method_stub(
"SendExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
self.AcquireLock = self._client.get_method_stub(
"AcquireLock",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.LockRequest,
hrpc__pb2.Void,
),
)
self.ReleaseLock = self._client.get_method_stub(
"ReleaseLock",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.LockRequest,
hrpc__pb2.Void,
),
)
self.OnAppend = self._client.get_method_stub(
"OnAppend",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.AppendEvent,
hrpc__pb2.Void,
),
)
self.OnClose = self._client.get_method_stub(
"OnClose",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.CloseEvent,
hrpc__pb2.Void,
),
)
self.OnPeerOpen = self._client.get_method_stub(
"OnPeerOpen",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
self.OnPeerRemove = self._client.get_method_stub(
"OnPeerRemove",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
self.OnExtension = self._client.get_method_stub(
"OnExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
self.OnWait = self._client.get_method_stub(
"OnWait",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.WaitEvent,
hrpc__pb2.Void,
),
)
class NetworkServicer(purerpc.Servicer):
async def Open(self, input_message):
raise NotImplementedError()
async def Configure(self, input_message):
raise NotImplementedError()
async def Status(self, input_message):
raise NotImplementedError()
async def AllStatuses(self, input_message):
raise NotImplementedError()
async def RegisterExtension(self, input_message):
raise NotImplementedError()
async def UnregisterExtension(self, input_message):
raise NotImplementedError()
async def SendExtension(self, input_message):
raise NotImplementedError()
async def OnPeerAdd(self, input_message):
raise NotImplementedError()
async def OnPeerRemove(self, input_message):
raise NotImplementedError()
async def OnExtension(self, input_message):
raise NotImplementedError()
@property
def service(self) -> purerpc.Service:
service_obj = purerpc.Service("hyperspace.Network")
service_obj.add_method(
"Open",
self.Open,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
hrpc__pb2.Void,
schema__pb2.OpenNetworkResponse,
),
)
service_obj.add_method(
"Configure",
self.Configure,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ConfigureNetworkRequest,
schema__pb2.NetworkStatusResponse,
),
)
service_obj.add_method(
"Status",
self.Status,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.NetworkStatusRequest,
schema__pb2.NetworkStatusResponse,
),
)
service_obj.add_method(
"AllStatuses",
self.AllStatuses,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
hrpc__pb2.Void,
schema__pb2.AllNetworkStatusesResponse,
),
)
service_obj.add_method(
"RegisterExtension",
self.RegisterExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.RegisterExtensionRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"UnregisterExtension",
self.UnregisterExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UnregisterExtensionRequest,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"SendExtension",
self.SendExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnPeerAdd",
self.OnPeerAdd,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnPeerRemove",
self.OnPeerRemove,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
service_obj.add_method(
"OnExtension",
self.OnExtension,
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
return service_obj
class NetworkStub:
def __init__(self, channel):
self._client = purerpc.Client("hyperspace.Network", channel)
self.Open = self._client.get_method_stub(
"Open",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
hrpc__pb2.Void,
schema__pb2.OpenNetworkResponse,
),
)
self.Configure = self._client.get_method_stub(
"Configure",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ConfigureNetworkRequest,
schema__pb2.NetworkStatusResponse,
),
)
self.Status = self._client.get_method_stub(
"Status",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.NetworkStatusRequest,
schema__pb2.NetworkStatusResponse,
),
)
self.AllStatuses = self._client.get_method_stub(
"AllStatuses",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
hrpc__pb2.Void,
schema__pb2.AllNetworkStatusesResponse,
),
)
self.RegisterExtension = self._client.get_method_stub(
"RegisterExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.RegisterExtensionRequest,
hrpc__pb2.Void,
),
)
self.UnregisterExtension = self._client.get_method_stub(
"UnregisterExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.UnregisterExtensionRequest,
hrpc__pb2.Void,
),
)
self.SendExtension = self._client.get_method_stub(
"SendExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)
self.OnPeerAdd = self._client.get_method_stub(
"OnPeerAdd",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
self.OnPeerRemove = self._client.get_method_stub(
"OnPeerRemove",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.PeerEvent,
hrpc__pb2.Void,
),
)
self.OnExtension = self._client.get_method_stub(
"OnExtension",
purerpc.RPCSignature(
purerpc.Cardinality.UNARY_UNARY,
schema__pb2.ExtensionMessage,
hrpc__pb2.Void,
),
)

3491
hyperspace_rpc/schema_pb2.py
View File

File diff suppressed because one or more lines are too long

7
makefile Normal file
View File

@ -0,0 +1,7 @@
default: rewrite
rewrite:
@sed -i 's/import hrpc_pb2 as hrpc__pb2/from . import hrpc_pb2 as hrpc__pb2/g' hyperspace_rpc/*.py && \
sed -i 's/import schema_pb2 as schema__pb2/from . import schema_pb2 as schema__pb2/g' hyperspace_rpc/*.py
.PHONY: rewrite

2
pyproject.toml
View File

@ -4,7 +4,7 @@ build-backend = "poetry.masonry.api"
[tool.poetry] [tool.poetry]
name = "hyperspace-rpc" name = "hyperspace-rpc"
version = "0.0.1a1" version = "0.0.1a3"
description = "Raw RPC layer for Hyperspace" description = "Raw RPC layer for Hyperspace"
authors = ["decentral1se <hi@decentral1.se>"] authors = ["decentral1se <hi@decentral1.se>"]
maintainers = ["decentral1se <hi@decentral1.se>"] maintainers = ["decentral1se <hi@decentral1.se>"]