Merge
This commit is contained in:
Nex
commit
b34ec3a1f3
@ -1,4 +1,4 @@
|
|||||||
# BDChain gRPC 指南
|
# BDChain gRPC API 指南
|
||||||
|
|
||||||
## 编译 Go 版本 gRPC
|
## 编译 Go 版本 gRPC
|
||||||
|
|
||||||
@ -21,4 +21,4 @@
|
|||||||
### 编译
|
### 编译
|
||||||
|
|
||||||
- 在本项目打开控制台，或者切换工作路径到本项目
|
- 在本项目打开控制台，或者切换工作路径到本项目
|
||||||
- 执行 `gen`
|
- 执行 `./gen`
|
||||||
|
|||||||
@ -1,21 +0,0 @@
|
|||||||
# API 测试工具
|
|
||||||
|
|
||||||
## Go 版本测试服务器 `mockserver`
|
|
||||||
|
|
||||||
### 编译
|
|
||||||
|
|
||||||
1. 准备好 Go 环境
|
|
||||||
2. 下载 [BDChain Go SDK](https://phabricator.internetapi.cn/source/bdchain-go-sdk/repository/master/) 到 `GOPATH`
|
|
||||||
3. 切换工作目录到 `mockserver` 目录
|
|
||||||
4. 使用 `go get -d ./...` 安装此项目依赖
|
|
||||||
5. 使用 `go build` 编译
|
|
||||||
6. `mockserver` 即为编译好的可执行程序
|
|
||||||
|
|
||||||
### 运行
|
|
||||||
|
|
||||||
- 使用 `.\mockserver --help` 查看使用帮助
|
|
||||||
- 目前仅支持使用 `--port N` 设定程序运行的端口为 N
|
|
||||||
|
|
||||||
### 测试连接
|
|
||||||
|
|
||||||
在需要测试连接的位置，设定连接地址和端口为此 `mockserver` 所在地址及端口即可。
|
|
||||||
12
test/mockserver/.gitignore
vendored
12
test/mockserver/.gitignore
vendored
@ -1,12 +0,0 @@
|
|||||||
# IDE
|
|
||||||
.idea/
|
|
||||||
.vscode/
|
|
||||||
debug
|
|
||||||
debug.test
|
|
||||||
|
|
||||||
# Go
|
|
||||||
mockserver
|
|
||||||
mockserver.exe
|
|
||||||
|
|
||||||
# Local
|
|
||||||
/run-*.bat
|
|
||||||
@ -1,39 +0,0 @@
|
|||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"flag"
|
|
||||||
"fmt"
|
|
||||||
"net"
|
|
||||||
"strconv"
|
|
||||||
|
|
||||||
"bdchain/api/grpc/txledger"
|
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
|
||||||
)
|
|
||||||
|
|
||||||
func main() {
|
|
||||||
// flag
|
|
||||||
port := flag.Int("port", 10000, "set the port of test server")
|
|
||||||
flag.Parse()
|
|
||||||
|
|
||||||
// server
|
|
||||||
rpc := grpc.NewServer()
|
|
||||||
srv := (*grpcServer)(&server{})
|
|
||||||
txledger.RegisterTransactionLedgerServer(rpc, srv)
|
|
||||||
|
|
||||||
con, err := net.Listen("tcp", ":"+strconv.Itoa(*port))
|
|
||||||
if err == nil {
|
|
||||||
fmt.Println("server is running on", *port)
|
|
||||||
} else {
|
|
||||||
fmt.Println(err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
// start
|
|
||||||
err = rpc.Serve(con)
|
|
||||||
if err != nil {
|
|
||||||
fmt.Println("server closed with error", err)
|
|
||||||
} else {
|
|
||||||
fmt.Println("server closed")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,191 +0,0 @@
|
|||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"context"
|
|
||||||
|
|
||||||
"google.golang.org/grpc/codes"
|
|
||||||
"google.golang.org/grpc/status"
|
|
||||||
|
|
||||||
"bdchain/api/grpc/common"
|
|
||||||
"bdchain/api/grpc/txledger"
|
|
||||||
|
|
||||||
"github.com/golang/protobuf/proto"
|
|
||||||
"github.com/golang/protobuf/ptypes/empty"
|
|
||||||
)
|
|
||||||
|
|
||||||
/////////////////////////////////////////////////////////////////////////////
|
|
||||||
// server
|
|
||||||
type server struct{}
|
|
||||||
|
|
||||||
/////////////////////////////////////////////////////////////////////////////
|
|
||||||
// grpcServer
|
|
||||||
type grpcServer server
|
|
||||||
|
|
||||||
func (s *grpcServer) ClientVersion(
|
|
||||||
c context.Context,
|
|
||||||
r *empty.Empty,
|
|
||||||
) (res *common.ClientVersionResponse, err error) {
|
|
||||||
switch {
|
|
||||||
case s == nil:
|
|
||||||
err = toStatusError(ErrInvalidServer)
|
|
||||||
case r == nil:
|
|
||||||
err = toStatusError(ErrInvalidRequest)
|
|
||||||
default:
|
|
||||||
res = &common.ClientVersionResponse{
|
|
||||||
Version: "TxLedgerGo/v0.0.1alpha/darwin/go1.11",
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *grpcServer) CreateLedger(
|
|
||||||
c context.Context,
|
|
||||||
r *txledger.CreateLedgerRequest,
|
|
||||||
) (res *txledger.CreateLedgerResponse, err error) {
|
|
||||||
switch {
|
|
||||||
case s == nil:
|
|
||||||
err = toStatusError(ErrInvalidServer)
|
|
||||||
case r == nil:
|
|
||||||
err = toStatusError(ErrInvalidRequest)
|
|
||||||
case r.Name == "":
|
|
||||||
err = toStatusError(ErrEmptyName)
|
|
||||||
case r.Name == "test":
|
|
||||||
res = &txledger.CreateLedgerResponse{
|
|
||||||
Ok: true,
|
|
||||||
}
|
|
||||||
default:
|
|
||||||
err = toStatusError(ErrTestNotImplemented)
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *grpcServer) GetLedgers(
|
|
||||||
c context.Context,
|
|
||||||
r *empty.Empty,
|
|
||||||
) (res *txledger.GetLedgersResponse, err error) {
|
|
||||||
switch {
|
|
||||||
case s == nil:
|
|
||||||
err = toStatusError(ErrInvalidServer)
|
|
||||||
case r == nil:
|
|
||||||
err = toStatusError(ErrInvalidRequest)
|
|
||||||
default:
|
|
||||||
res = &txledger.GetLedgersResponse{
|
|
||||||
Ledgers: []string{
|
|
||||||
"first",
|
|
||||||
"second",
|
|
||||||
"third",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *grpcServer) SendTransaction(
|
|
||||||
c context.Context,
|
|
||||||
r *txledger.SendTransactionRequest,
|
|
||||||
) (res *txledger.SendTransactionResponse, err error) {
|
|
||||||
switch {
|
|
||||||
case s == nil:
|
|
||||||
err = toStatusError(ErrInvalidServer)
|
|
||||||
case r == nil:
|
|
||||||
fallthrough
|
|
||||||
case r.Transaction == nil:
|
|
||||||
err = toStatusError(ErrInvalidRequest)
|
|
||||||
case r.Ledger != "test":
|
|
||||||
err = toStatusError(ErrTestNotImplemented)
|
|
||||||
default:
|
|
||||||
type Input struct {
|
|
||||||
Type common.TransactionType
|
|
||||||
From []byte
|
|
||||||
To []byte
|
|
||||||
Data []byte
|
|
||||||
}
|
|
||||||
type Output struct {
|
|
||||||
Hash []byte
|
|
||||||
Error error
|
|
||||||
}
|
|
||||||
type Case struct {
|
|
||||||
I Input
|
|
||||||
O Output
|
|
||||||
}
|
|
||||||
|
|
||||||
Merge := func(
|
|
||||||
p *status.Status,
|
|
||||||
cs ...*status.Status,
|
|
||||||
) *status.Status {
|
|
||||||
msg := []proto.Message{}
|
|
||||||
for _, c := range cs {
|
|
||||||
msg = append(msg, c.Proto())
|
|
||||||
}
|
|
||||||
r, err := p.WithDetails(msg...)
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
return r
|
|
||||||
}
|
|
||||||
|
|
||||||
tx := r.Transaction
|
|
||||||
for _, c := range [...]Case{
|
|
||||||
{
|
|
||||||
I: Input{
|
|
||||||
Type: common.TransactionType_MESSAGE,
|
|
||||||
From: []byte{
|
|
||||||
0xf0, 0x0d, 0xca, 0xfe, 0xf0, 0x0d, 0xca, 0xfe,
|
|
||||||
0xf0, 0x0d, 0xca, 0xfe, 0xf0, 0x0d, 0xca, 0xfe,
|
|
||||||
0xf0, 0x0d, 0xca, 0xfe,
|
|
||||||
},
|
|
||||||
To: []byte{
|
|
||||||
0xfe, 0xed, 0xba, 0xbe, 0xfe, 0xed, 0xba, 0xbe,
|
|
||||||
0xfe, 0xed, 0xba, 0xbe, 0xfe, 0xed, 0xba, 0xbe,
|
|
||||||
0xfe, 0xed, 0xba, 0xbe,
|
|
||||||
},
|
|
||||||
Data: []byte{
|
|
||||||
0xde, 0xad, 0xbe, 0xef,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
O: Output{
|
|
||||||
Hash: []byte{
|
|
||||||
0xd1, 0x5e, 0xa5, 0xed, 0xd1, 0x5e, 0xa5, 0xed,
|
|
||||||
0xd1, 0x5e, 0xa5, 0xed, 0xd1, 0x5e, 0xa5, 0xed,
|
|
||||||
0xd1, 0x5e, 0xa5, 0xed, 0xd1, 0x5e, 0xa5, 0xed,
|
|
||||||
0xd1, 0x5e, 0xa5, 0xed, 0xd1, 0x5e, 0xa5, 0xed,
|
|
||||||
},
|
|
||||||
Error: nil,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
I: Input{
|
|
||||||
Type: common.TransactionType_MESSAGE,
|
|
||||||
From: nil,
|
|
||||||
To: []byte{
|
|
||||||
0x50, 0xba, 0xda, 0x55,
|
|
||||||
},
|
|
||||||
Data: nil,
|
|
||||||
},
|
|
||||||
O: Output{
|
|
||||||
Hash: nil,
|
|
||||||
Error: Merge(
|
|
||||||
status.New(codes.InvalidArgument, ErrMultiple.Error()),
|
|
||||||
status.New(codes.InvalidArgument, ErrEmptyFrom.Error()),
|
|
||||||
status.New(codes.InvalidArgument, ErrInvalidTo.Error()),
|
|
||||||
).Err(),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
} {
|
|
||||||
if c.I.Type == tx.Type &&
|
|
||||||
bytes.Equal(c.I.From, tx.From) &&
|
|
||||||
bytes.Equal(c.I.To, tx.To) &&
|
|
||||||
bytes.Equal(c.I.Data, tx.Data) {
|
|
||||||
if c.O.Error != nil {
|
|
||||||
err = c.O.Error
|
|
||||||
} else {
|
|
||||||
res = &txledger.SendTransactionResponse{Hash: c.O.Hash}
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
err = toStatusError(ErrTestNotImplemented)
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue
Block a user