Update 080 podr2

core/node.go

@@ -217,13 +217,7 @@ type P2P interface {
 		callOpts []grpc.CallOption,
 	) (*pb.ResponseSpaceProofVerifyTotal, error)
 
-	RequestGenTag(
-		addr string,
-		requestGenTag *pb.RequestGenTag,
-		timeout time.Duration,
-		dialOpts []grpc.DialOption,
-		callOpts []grpc.CallOption,
-	) (*pb.ResponseGenTag, error)
+	RequestGenTag(c pb.Podr2ApiClient) (pb.Podr2Api_RequestGenTagClient, error)
 
 	RequestEcho(
 		addr string,

core/podr2.go

@@ -31,24 +31,8 @@ func (n *Node) NewPodr2VerifierApiClient(addr string, opts ...grpc.DialOption) (
 	return pb.NewPodr2VerifierApiClient(conn), nil
 }
 
-func (n *Node) RequestGenTag(
-	addr string,
-	requestGenTag *pb.RequestGenTag,
-	timeout time.Duration,
-	dialOpts []grpc.DialOption,
-	callOpts []grpc.CallOption,
-) (*pb.ResponseGenTag, error) {
-	conn, err := grpc.Dial(addr, dialOpts...)
-	if err != nil {
-		return nil, err
-	}
-	defer conn.Close()
-	c := pb.NewPodr2ApiClient(conn)
-
-	ctx, cancel := context.WithTimeout(context.Background(), timeout)
-	defer cancel()
-
-	result, err := c.RequestGenTag(ctx, requestGenTag, callOpts...)
+func (n *Node) RequestGenTag(c pb.Podr2ApiClient) (pb.Podr2Api_RequestGenTagClient, error) {
+	result, err := c.RequestGenTag(context.Background())
 	return result, err
 }
 

pb/podr2-api.proto

@@ -4,7 +4,8 @@ package podr2;
 option go_package = "./;pb";
 
 service Podr2Api {
-  rpc request_gen_tag(RequestGenTag) returns (ResponseGenTag) {}
+  rpc request_gen_tag(stream RequestGenTag)
+      returns (stream ResponseGenTag) {}
 
   // A echo rpc to measure network RTT.
   rpc Echo (EchoMessage) returns (EchoMessage) {}
@@ -45,6 +46,11 @@ message DigestInfo {
 }
 
 message ResponseGenTag {
+  bool processing = 1;
+  GenTagMsg msg = 2;
+}
+
+message GenTagMsg {
   Tag tag = 1;
   bytes u_sig = 2;
   bytes signature = 3;
@@ -83,4 +89,4 @@ enum StatusCode {
   OutOfMemory = 10004;
   AlgorithmError = 10005;
   UnknownError = 10006;
-}
+}

pb/pubkey-api.proto

@@ -23,24 +23,25 @@ message IdentityPubkeyResponse {
     // the identity public key
     bytes pubkey = 1;
     // The timestamp for the processing of the request
-    uint64 timestamp = 2;
-    // Use the sr25519 algorithm to sign the timestamp fields above
+    int64 timestamp = 2;
+    // Use the sr25519 algorithm to sign the timestamp fields above (use it's Big-Endian bytes)
     bytes signature = 3;
 }
 
 message MasterPubkeyResponse {
     // the master public key
     bytes pubkey = 1;
     // The timestamp for the processing of the request
-    uint64 timestamp = 2;
+    int64 timestamp = 2;
+    // Use the sr25519 algorithm to sign the timestamp fields above (use it's Big-Endian bytes)
     bytes signature = 3;
 }
 
 message Podr2PubkeyResponse {
     // the PODR2 public key
     bytes pubkey = 1;
     // The timestamp for the processing of the request
-    uint64 timestamp = 2;
-    // Use the RSA algorithm to sign the timestamp fields above
+    int64 timestamp = 2;
+    // Use the RSA algorithm to sign the timestamp fields above (use it's Big-Endian bytes)
     bytes signature = 3;
 }