Commit ae62ce6e authored by Ubuntu's avatar Ubuntu

fix buf generate

parent 04ac4c6d
...@@ -16,3 +16,17 @@ cloudstd proto --package "cmp.xxx.v1" --resource "shelf,shelves" ...@@ -16,3 +16,17 @@ cloudstd proto --package "cmp.xxx.v1" --resource "shelf,shelves"
## Modules ## Modules
/\
/ \
/ \
ring/gateway contract
/ \
/ \
/ \
<--------------
validator
syntax = "proto3"; syntax = "proto3";
package meta.base.v1; package base.v1;
option go_package = "basev1"; //option go_package = "basev1";
import "google/protobuf/field_mask.proto"; import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
import "meta/base/v1/resource.proto"; import "base/v1/resource.proto";
// The standard List request definition. // The standard List request definition.
message ListShelvesRequest { message ListShelvesRequest {
......
syntax = "proto3"; syntax = "proto3";
package meta.base.v1; package base.v1;
option go_package = "basev1"; //option go_package = "basev1";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
......
syntax = "proto3"; syntax = "proto3";
package meta.base.v1; package base.v1;
option go_package = "basev1"; //option go_package = "basev1";
import "meta/base/v1/request_response.proto"; import "base/v1/request_response.proto";
// ShelfService defines methods for managing shelves. // ShelfService defines methods for managing shelves.
service ShelfService { service ShelfService {
......
...@@ -2,16 +2,16 @@ version: v1 ...@@ -2,16 +2,16 @@ version: v1
managed: managed:
enabled: true enabled: true
go_package_prefix: go_package_prefix:
default: helloworld default: github.com/cmpchain/metaprotocol/gen/proto/go
except: except:
- buf.build/googleapis/googleapis - buf.build/googleapis/googleapis
plugins: plugins:
- name: go - name: go
out: gen out: gen/proto/go
opt: paths=source_relative opt: paths=source_relative
- name: go-grpc - name: go-grpc
out: gen out: gen/proto/go
opt: paths=source_relative opt: paths=source_relative
- name: grpc-gateway - name: grpc-gateway
out: gen out: gen/proto/go
opt: paths=source_relative opt: paths=source_relative
version: v1
directories:
- baseapi
- crypterapi
- ethrpcapi
- nebulaapi
- p2papi
- ringapi
- sentryapi
- txcheckerapi
\ No newline at end of file
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package meta.crypter.v1; package crypter.v1;
option go_package = "crypterv1"; //option go_package = "crypterv1";
import "google/protobuf/field_mask.proto"; import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
import "meta/crypter/v1/resource.proto"; import "crypter/v1/resource.proto";
......
syntax = "proto3"; syntax = "proto3";
package meta.crypter.v1; package crypter.v1;
option go_package = "crypterv1"; //option go_package = "crypterv1";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
......
syntax = "proto3"; syntax = "proto3";
package meta.crypter.v1; package crypter.v1;
option go_package = "crypterv1"; //option go_package = "crypterv1";
import "meta/crypter/v1/request_response.proto"; import "crypter/v1/request_response.proto";
service CrypterService { service CrypterService {
// rpc Sign(SignRequest) returns (SignResponse) {} // rpc Sign(SignRequest) returns (SignResponse) {}
......
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package protoeth; package ethrpc.v1;
option go_package = "protoeth"; //option go_package = "protoeth";
import "google/protobuf/empty.proto"; import "google/protobuf/empty.proto";
// GetAccounts only for ganache // GetAccounts only for ganache
......
module github.com/cmpchain/metaprotocol module github.com/cmpchain/metaprotocol
go 1.15 go 1.19
require ( require (
github.com/gogo/protobuf v1.3.2 google.golang.org/grpc v1.50.1
github.com/golang/protobuf v1.5.2 google.golang.org/protobuf v1.28.1
google.golang.org/genproto v0.0.0-20221013201013-33fc6f83cba4 )
google.golang.org/grpc v1.50.0
require (
github.com/golang/protobuf v1.5.2 // indirect
golang.org/x/net v0.0.0-20201021035429-f5854403a974 // indirect
golang.org/x/sys v0.0.0-20210119212857-b64e53b001e4 // indirect
golang.org/x/text v0.3.3 // indirect
google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
) )
This diff is collapsed.
...@@ -3,18 +3,20 @@ package main ...@@ -3,18 +3,20 @@ package main
import ( import (
"context" "context"
"fmt" "fmt"
"net"
metabase "github.com/cmpchain/metaprotocol/gen/proto/go/base/v1"
metacrypter "github.com/cmpchain/metaprotocol/gen/proto/go/crypter/v1"
metanebula "github.com/cmpchain/metaprotocol/gen/proto/go/nebula/v1"
metap2p "github.com/cmpchain/metaprotocol/gen/proto/go/p2p/v1"
metaring "github.com/cmpchain/metaprotocol/gen/proto/go/ring/v1"
metasentry "github.com/cmpchain/metaprotocol/gen/proto/go/sentry/v1"
txchecker "github.com/cmpchain/metaprotocol/gen/proto/go/txchecker/v1"
"google.golang.org/grpc" "google.golang.org/grpc"
"google.golang.org/grpc/codes" "google.golang.org/grpc/codes"
"google.golang.org/grpc/status" "google.golang.org/grpc/status"
"net"
metacrypter "github.com/cmpchain/metaprotocol/meta/crypter/v1"
metaring "github.com/cmpchain/metaprotocol/meta/ring/v1"
metabase "github.com/cmpchain/metaprotocol/meta/base/v1"
metap2p "github.com/cmpchain/metaprotocol/meta/p2p/v1"
metanebula "github.com/cmpchain/metaprotocol/meta/nebula/v1"
metasentry "github.com/cmpchain/metaprotocol/meta/sentry/v1"
txchecker "github.com/cmpchain/metaprotocol/meta/txchecker/v1"
) )
type P2PServer struct { type P2PServer struct {
metap2p.UnimplementedP2PServiceServer metap2p.UnimplementedP2PServiceServer
} }
...@@ -24,7 +26,7 @@ type NebulaServer struct { ...@@ -24,7 +26,7 @@ type NebulaServer struct {
} }
type SentryServer struct { type SentryServer struct {
metasentry.UnimplementedShelfServiceServer metasentry.UnimplementedSentryServiceServer
} }
type TxCheckServer struct { type TxCheckServer struct {
...@@ -37,22 +39,24 @@ type BaseType struct { ...@@ -37,22 +39,24 @@ type BaseType struct {
} }
type RingServer struct { type RingServer struct {
metaring.UnimplementedShelfServiceServer metaring.UnimplementedEthRpcServiceServer
} }
type server struct { type server struct {
metacrypter.UnimplementedCrypterServiceServer metacrypter.UnimplementedCrypterServiceServer
} }
func (*server) Sign(ctx context.Context, req *metacrypter.SignRequest) (*metacrypter.SignResponse, error) { // func (*server) Sign(ctx context.Context, req *metacrypter.SignRequest) (*metacrypter.SignResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Sign not implemented") // return nil, status.Errorf(codes.Unimplemented, "method Sign not implemented")
} // }
func (*server) Verify(ctx context.Context, req *metacrypter.VerifyRequest) (*metacrypter.VerifyResponse, error) { //
return nil, status.Errorf(codes.Unimplemented, "method Verify not implemented") // func (*server) Verify(ctx context.Context, req *metacrypter.VerifyRequest) (*metacrypter.VerifyResponse, error) {
} // return nil, status.Errorf(codes.Unimplemented, "method Verify not implemented")
func (*server) Recover(ctx context.Context, req *metacrypter.RecoverRequest) (*metacrypter.RecoverResponse, error) { // }
return nil, status.Errorf(codes.Unimplemented, "method Recover not implemented") //
} // func (*server) Recover(ctx context.Context, req *metacrypter.RecoverRequest) (*metacrypter.RecoverResponse, error) {
// return nil, status.Errorf(codes.Unimplemented, "method Recover not implemented")
// }
func (*server) BatchSign(ctx context.Context, req *metacrypter.BatchSignRequest) (*metacrypter.BatchSignResponse, error) { func (*server) BatchSign(ctx context.Context, req *metacrypter.BatchSignRequest) (*metacrypter.BatchSignResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BatchSign not implemented") return nil, status.Errorf(codes.Unimplemented, "method BatchSign not implemented")
} }
...@@ -70,7 +74,7 @@ func main() { ...@@ -70,7 +74,7 @@ func main() {
fmt.Printf("failed to listen: %v", err) fmt.Printf("failed to listen: %v", err)
return return
} }
s := grpc.NewServer() // 创建gRPC服务器 s := grpc.NewServer() // 创建gRPC服务器
metacrypter.RegisterCrypterServiceServer(s, &server{}) // 在gRPC服务端注册服务 metacrypter.RegisterCrypterServiceServer(s, &server{}) // 在gRPC服务端注册服务
// 启动服务 // 启动服务
err = s.Serve(lis) err = s.Serve(lis)
...@@ -78,4 +82,4 @@ func main() { ...@@ -78,4 +82,4 @@ func main() {
fmt.Printf("failed to serve: %v", err) fmt.Printf("failed to serve: %v", err)
return return
} }
} }
\ No newline at end of file
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package meta.nebula.v1; package nebula.v1;
option go_package = "nebulav1"; //option go_package = "nebulav1";
import "google/protobuf/field_mask.proto"; import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
import "meta/nebula/v1/resource.proto"; import "nebula/v1/resource.proto";
// The standard List request definition. // The standard List request definition.
message ListShelvesRequest { message ListShelvesRequest {
......
syntax = "proto3"; syntax = "proto3";
package meta.nebula.v1; package nebula.v1;
option go_package = "nebulav1"; //option go_package = "nebulav1";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
......
syntax = "proto3"; syntax = "proto3";
package meta.nebula.v1; package nebula.v1;
option go_package = "nebulav1"; //option go_package = "nebulav1";
import "meta/nebula/v1/request_response.proto"; import "nebula/v1/request_response.proto";
// ShelfService defines methods for managing shelves. // ShelfService defines methods for managing shelves.
service ShelfService { service ShelfService {
......
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package meta.p2p.v1; package p2p.v1;
option go_package = "p2pv1"; //option go_package = "p2pv1";
import "google/protobuf/field_mask.proto"; import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
import "meta/p2p/v1/resource.proto"; import "p2p/v1/resource.proto";
message BroadCastRequest { message BroadCastRequest {
MessageHeader header = 1; MessageHeader header = 1;
......
syntax = "proto3"; syntax = "proto3";
package meta.p2p.v1; package p2p.v1;
option go_package = "p2pv1"; //option go_package = "p2pv1";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
enum P2PMsgType { enum P2PMsgType {
......
syntax = "proto3"; syntax = "proto3";
package meta.p2p.v1; package p2p.v1;
option go_package = "p2pv1"; //option go_package = "p2pv1";
import "meta/p2p/v1/request_response.proto"; import "p2p/v1/request_response.proto";
service P2PService { service P2PService {
rpc BroadCastMsg(BroadCastRequest) returns (BroadCastResponse) {} rpc BroadCastMsg(BroadCastRequest) returns (BroadCastResponse) {}
......
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package meta.ring.v1; package ring.v1;
message SendRawTransactionRequest{ message SendRawTransactionRequest{
......
syntax = "proto3"; syntax = "proto3";
package meta.ring.v1; package ring.v1;
syntax = "proto3"; syntax = "proto3";
package meta.ring.v1; package ring.v1;
import "meta/ring/v1/request_response.proto"; import "ring/v1/request_response.proto";
// ShelfService defines methods for managing shelves. // ShelfService defines methods for managing shelves.
//service ShelfService { //service ShelfService {
......
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package meta.sentry.v1; package sentry.v1;
option go_package = "sentryv1"; //option go_package = "sentryv1";
import "google/protobuf/field_mask.proto"; import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
import "meta/sentry/v1/resource.proto"; import "sentry/v1/resource.proto";
// The standard List request definition. // The standard List request definition.
message ListShelvesRequest { message ListShelvesRequest {
......
syntax = "proto3"; syntax = "proto3";
package meta.sentry.v1; package sentry.v1;
option go_package = "sentryv1"; //option go_package = "sentryv1";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
// The default Shelf resource representation. // The default Shelf resource representation.
......
syntax = "proto3"; syntax = "proto3";
package meta.sentry.v1; package sentry.v1;
option go_package = "sentryv1"; //option go_package = "sentryv1";
import "meta/sentry/v1/request_response.proto"; import "sentry/v1/request_response.proto";
import "google/protobuf/empty.proto"; import "google/protobuf/empty.proto";
// SentryService methods for other module. // SentryService methods for other module.
......
version: v1
breaking:
use:
- FILE
lint:
use:
- DEFAULT
syntax = "proto3"; syntax = "proto3";
package meta.txchecker.v1; package txchecker.v1;
option go_package = "txcheckerv1"; //option go_package = "txcheckerv1";
import "google/protobuf/field_mask.proto"; import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
import "meta/txchecker/v1/resource.proto"; import "txchecker/v1/resource.proto";
// The standard BatchGet request definition. // The standard BatchGet request definition.
message BatchCheckTxRequest { message BatchCheckTxRequest {
......
syntax = "proto3"; syntax = "proto3";
package meta.txchecker.v1; package txchecker.v1;
option go_package = "txcheckerv1"; //option go_package = "txcheckerv1";
import "google/protobuf/timestamp.proto"; import "google/protobuf/timestamp.proto";
// // The default Shelf resource representation. // // The default Shelf resource representation.
......
syntax = "proto3"; syntax = "proto3";
package meta.txchecker.v1; package txchecker.v1;
option go_package = "txcheckerv1"; //option go_package = "txcheckerv1";
import "meta/txchecker/v1/request_response.proto"; import "txchecker/v1/request_response.proto";
service ShelfService { service ShelfService {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment