feat: add new RPC method for block (#79)

blackhorseya · Oct 5, 2024 · 879dd11 · 879dd11
2 parents b196d83 + b50bf02
commit 879dd11
Show file tree

Hide file tree

Showing 10 changed files with 484 additions and 65 deletions.
diff --git a/app/domain/block/block_service.go b/app/domain/block/block_service.go
@@ -240,3 +240,8 @@ func (i *impl) ListBlocks(req *biz.ListBlocksRequest, stream grpc.ServerStreamin
 
 	return nil
 }
+
+func (i *impl) FoundNewBlockNonStream(c context.Context, req *biz.FoundNewBlockRequest) (*model.Block, error) {
+	// TODO: 2024/10/5|sean|implement me
+	panic("implement me")
+}
diff --git a/app/domain/transaction/transaction_service.go b/app/domain/transaction/transaction_service.go
@@ -195,3 +195,11 @@ func (i *txService) ListTransactionsByAccount(
 
 	return nil
 }
+
+func (i *txService) ProcessBlockTransactionsNonStream(
+	block *model.Block,
+	stream grpc.ServerStreamingServer[txM.Transaction],
+) error {
+	// TODO: 2024/10/5|sean|implement me
+	panic("implement me")
+}
diff --git a/entity/domain/block/biz/block.pb.go b/entity/domain/block/biz/block.pb.go
diff --git a/entity/domain/block/biz/block.proto b/entity/domain/block/biz/block.proto
@@ -36,6 +36,7 @@ message ListBlocksRequest {
 service BlockService {
   rpc ScanBlock(ScanBlockRequest) returns (stream Block) {}
   rpc FoundNewBlock(stream Block) returns (stream Block) {}
+  rpc FoundNewBlockNonStream(FoundNewBlockRequest) returns (Block) {}
 
   rpc GetBlock(GetBlockRequest) returns (Block) {}
   rpc ListBlocks(ListBlocksRequest) returns (stream Block) {}

diff --git a/entity/domain/block/biz/block_grpc.pb.go b/entity/domain/block/biz/block_grpc.pb.go
diff --git a/entity/domain/block/biz/block_grpc_mock.pb.go b/entity/domain/block/biz/block_grpc_mock.pb.go