From 13bb70fb20deb0f011122de9e8721099c69d6431 Mon Sep 17 00:00:00 2001
From: gupadhyaya <ganeshrvce@gmail.com>
Date: Fri, 19 Jul 2024 11:21:20 +0400
Subject: [PATCH] add grpc server

---
 proxy/grpc/server.go | 65 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 proxy/grpc/server.go

diff --git a/proxy/grpc/server.go b/proxy/grpc/server.go
new file mode 100644
index 0000000..944dd27
--- /dev/null
+++ b/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
+}