grpc support

go.mod

@@ -1,6 +1,6 @@
 module zeno
 
-go 1.23.5
+go 1.25.0
 
 require github.com/charmbracelet/lipgloss v1.1.0
 
@@ -16,5 +16,10 @@ require (
 	github.com/muesli/termenv v0.16.0 // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
-	golang.org/x/sys v0.30.0 // indirect
+	golang.org/x/net v0.55.0 // indirect
+	golang.org/x/sys v0.45.0 // indirect
+	golang.org/x/text v0.37.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa // indirect
+	google.golang.org/grpc v1.83.0 // indirect
+	google.golang.org/protobuf v1.36.11 // indirect
 )

go.sum

@@ -25,6 +25,18 @@ github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e h1:JVG44RsyaB9T2KIHavM
 github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e/go.mod h1:RbqR21r5mrJuqunuUZ/Dhy/avygyECGrLceyNeo4LiM=
 golang.org/x/exp v0.0.0-20220909182711-5c715a9e8561 h1:MDc5xs78ZrZr3HMQugiXOAkSZtfTpbJLDr/lwfgO53E=
 golang.org/x/exp v0.0.0-20220909182711-5c715a9e8561/go.mod h1:cyybsKvd6eL0RnXn6p/Grxp8F5bW7iYuBgsNCOHpMYE=
+golang.org/x/net v0.55.0 h1:bcvxaJn3e1U6InsFWt1JUq1aSjnRxLzT2rtD2KfkDF8=
+golang.org/x/net v0.55.0/go.mod h1:L5U2KuzuOe1lY7Z+aWVIKK6qEeJXnXV9yzGA+WCHJww=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
 golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.45.0 h1:dO4czNzziLiiXplLQgBCEpCvXQ3dnkn0SdaZSYdQ+FY=
+golang.org/x/sys v0.45.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
+golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
+golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa h1:mZHHdPZl0dbGHCflZgAq/Q468DWVFcU2whhB2KAo8fk=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260526163538-3dc84a4a5aaa/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
+google.golang.org/grpc v1.83.0 h1:JeNZEKJFbQxArAMl+hiytHauacDNqJUllNfmIMmpqnQ=
+google.golang.org/grpc v1.83.0/go.mod h1:kDyl6SKsiHKt0uylY5gtn5cEjkrIOhQOGDgIc4JGwzQ=
+google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
+google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=

main.go

@@ -1,19 +1,61 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"net"
 	"strings"
+	"sync"
+	"zeno/pb"
 	"zeno/src/aof"
 	"zeno/src/handler"
 	"zeno/src/resp"
 	"zeno/src/writer"
+
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/reflection"
 )
 
+// gRPC taskServer
+type taskServer struct {
+	pb.UnimplementedTaskServiceServer
+	mu      sync.Mutex
+	tasks   []*pb.Task
+	counter int
+}
+
+func (s *taskServer) SendTask(ctx context.Context, req *pb.SendTaskRequest) (*pb.SendTaskResponse, error) {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+
+	task := req.GetTask()
+	s.counter++
+	task.Id = fmt.Sprintf("%d", s.counter)
+	s.tasks = append(s.tasks, task)
+
+	fmt.Printf("gRPC: received task #%s - %s\n", task.Id, task.Title)
+	return &pb.SendTaskResponse{Success: true}, nil
+}
+
 // main in-mem db goes like this
 // Client -> TCP Request -> RESP deserialze -> commands hander -> RESP serialze -> Response
 
 func main() {
+	go func() {
+		lis, err := net.Listen("tcp", ":6380")
+		if err != nil {
+			fmt.Println("gRPC listen error:", err)
+			return
+		}
+		grpcServer := grpc.NewServer()
+		pb.RegisterTaskServiceServer(grpcServer, &taskServer{})
+		reflection.Register(grpcServer)
+		fmt.Println("gRPC server running on port: 6380")
+		if err := grpcServer.Serve(lis); err != nil {
+			fmt.Println("gRPC serve error:", err)
+		}
+	}()
+
 	fmt.Println("Running on port: 6379")
 	l, err := net.Listen("tcp", ":6379")
 	if err != nil {