Compare commits
4 Commits
Author | SHA1 | Date |
---|---|---|
Luke Murphy | 4adb778960 | |
Luke Murphy | 87b92548a4 | |
Luke Murphy | 5f1f88106c | |
Luke Murphy | 361bec2846 |
|
@ -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)
|
||||
|
||||
- The first alpha development release is made!
|
||||
|
|
|
@ -4,6 +4,8 @@
|
|||
|
||||
## Raw RPC layer for Hyperspace
|
||||
|
||||
> **Work In Progres**
|
||||
|
||||
## Install
|
||||
|
||||
```sh
|
||||
|
|
|
@ -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,
|
||||
),
|
||||
)
|
File diff suppressed because one or more lines are too long
|
@ -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
|
|
@ -4,7 +4,7 @@ build-backend = "poetry.masonry.api"
|
|||
|
||||
[tool.poetry]
|
||||
name = "hyperspace-rpc"
|
||||
version = "0.0.1a1"
|
||||
version = "0.0.1a3"
|
||||
description = "Raw RPC layer for Hyperspace"
|
||||
authors = ["decentral1se <hi@decentral1.se>"]
|
||||
maintainers = ["decentral1se <hi@decentral1.se>"]
|
||||
|
|
Loading…
Reference in New Issue