add grpc server

proxy/grpc/server.go

@@ -0,0 +1,65 @@
+package grpc
+
+import (
+	"context"
+
+	"github.com/rollkit/go-sequencing"
+	"google.golang.org/grpc"
+
+	pbseq "github.com/rollkit/go-sequencing/types/pb/sequencing"
+)
+
+func NewServer(
+	input sequencing.SequencerInput,
+	output sequencing.SequencerOutput,
+	verifier sequencing.BatchVerifier,
+	opts ...grpc.ServerOption,
+) *grpc.Server {
+	srv := grpc.NewServer(opts...)
+
+	proxyInputSrv := &proxyInputSrv{SequencerInput: input}
+	proxyOutputSrv := &proxyOutputSrv{SequencerOutput: output}
+	proxyVerificationSrv := &proxyVerificationSrv{BatchVerifier: verifier}
+
+	pbseq.RegisterSequencerInputServer(srv, proxyInputSrv)
+	pbseq.RegisterSequencerOutputServer(srv, proxyOutputSrv)
+	pbseq.RegisterBatchVerifierServer(srv, proxyVerificationSrv)
+
+	return srv
+}
+
+type proxyInputSrv struct {
+	sequencing.SequencerInput
+}
+
+type proxyOutputSrv struct {
+	sequencing.SequencerOutput
+}
+
+type proxyVerificationSrv struct {
+	sequencing.BatchVerifier
+}
+
+func (s *proxyInputSrv) SubmitRollupTransaction(ctx context.Context, req *pbseq.SubmitRollupTransactionRequest) (*pbseq.SubmitRollupTransactionResponse, error) {
+	err := s.SequencerInput.SubmitRollupTransaction(ctx, req.RollupId, req.Data)
+	if err != nil {
+		return nil, err
+	}
+	return &pbseq.SubmitRollupTransactionResponse{}, nil
+}
+
+func (s *proxyOutputSrv) GetNextBatch(ctx context.Context, req *pbseq.BatchRequest) (*pbseq.BatchResponse, error) {
+	batch, err := s.SequencerOutput.GetNextBatch(ctx, req.Transactions)
+	if err != nil {
+		return nil, err
+	}
+	return &pbseq.BatchResponse{Transactions: batch}, nil
+}
+
+func (s *proxyVerificationSrv) VerifyBatch(ctx context.Context, req *pbseq.BatchRequest) (*pbseq.VerificationResponse, error) {
+	ok, err := s.BatchVerifier.VerifyBatch(ctx, req.Transactions)
+	if err != nil {
+		return nil, err
+	}
+	return &pbseq.VerificationResponse{Success: ok}, nil
+}