update protobufs

hivemind/p2p/p2p_daemon.py

@@ -173,8 +173,6 @@ class P2P:
     async def add_unary_handler(self, handle_name: str, handler: p2pclient.TUnaryHandler):
         return await self._client.add_unary_handler(handle_name, handler)
 
-
-
     async def call_unary_handler(self, peer_id: PeerID, handle_name: str, data: bytes) -> bytes:
         return await self._client.call_unary_handler(peer_id, handle_name, data)
 

hivemind/p2p/p2p_daemon_bindings/control.py

@@ -138,7 +138,7 @@ class ControlClient:
                 self.handler_tasks[call_id].cancel()
 
     async def _write_to_persistent_conn(self, writer: asyncio.StreamWriter):
-        #with closing(writer):
+        # with closing(writer):
         while True:
             msg = await self.pending_messages.get()
             await write_pbmsg(writer, msg)

hivemind/proto/p2pd.proto

@@ -53,13 +53,12 @@ message Response {
 // Persistent connection request
 message PCRequest {
   required bytes callId = 1;
-  optional int64 timeout = 2;
 
   oneof message {
-    AddUnaryHandlerRequest addUnaryHandler = 3;
-    CallUnaryRequest  callUnary = 4;
-    CallUnaryResponse unaryResponse = 5;
-    Cancel cancel = 6;
+    AddUnaryHandlerRequest addUnaryHandler = 2;
+    CallUnaryRequest  callUnary = 3;
+    CallUnaryResponse unaryResponse = 4;
+    Cancel cancel = 5;
   }
 }
 
@@ -215,4 +214,4 @@ message Cancel {
 
 message RPCError {
   optional string message = 1;
-}
+}