gRPC Implemented

Signed-off-by: sukhman-sukh <[email protected]>

main.go

@@ -0,0 +1,25 @@
+package main
+
+import (
+	"github.com/sdslabs/pinger/pkg/protobuf/pb"
+	"google.golang.org/grpc"
+	"net"
+)
+
+type server struct {
+	pb.AlterServicesServer
+}
+
+func main() {
+	lis, err := net.Listen("tcp", ":5000")
+	if err != nil {
+		panic(err);
+	}
+
+	grpcServer := grpc.NewServer()
+	pb.RegisterAlterServicesServer(grpcServer, &server{})
+	if err := grpcServer.Serve(lis); err != nil {
+		panic(err)
+	}
+	grpcServer.Serve(lis)
+}

pkg/components/central/central.go

@@ -6,9 +6,9 @@ import (
 	"fmt"
 	"time"
 
-	"google.golang.org/grpc"
-
 	"github.com/go-redis/redis/v8"
+	"github.com/sdslabs/pinger/pkg/protobuf/pb"
+	"google.golang.org/grpc"
 
 	"github.com/sdslabs/pinger/pkg/config"
 	"github.com/sdslabs/pinger/pkg/config/configfile"
@@ -17,6 +17,10 @@ import (
 	agentProto "github.com/sdslabs/pinger/pkg/components/agent/proto"
 )
 
+type server struct {
+	pb.AlterServicesServer
+}
+
 func Run(ctx *appcontext.Context) error {
 	fmt.Println("Central server is running!")
 	// run GRPC server and expose API for managing checks
@@ -233,3 +237,45 @@ func getAgentWithLowestLoad(ctx *appcontext.Context) (string, error) {
 
 	return res[0], nil
 }
+
+func (s *server) CreateCheckService(ctx context.Context, req *pb.CreateCheckRequest) (*pb.Response, error) {
+	if req.Check != "" {
+		return &pb.Response{Response: "gRPC Code 0 : OK "}, nil
+	}
+	return nil, errors.New("Fuckoff")
+}
+
+func (s *server) DeleteCheckService(ctx context.Context, req *pb.DeleteCheckRequest) (*pb.Response, error) {
+	if req.UserId != "" {
+		return &pb.Response{Response: "gRPC Code 0 : OK "}, nil
+	}
+	return nil, errors.New("Fuckoff")
+}
+
+func (s *server) UpdateCheckService(ctx context.Context, req *pb.UpdateCheckRequest) (*pb.Response, error) {
+	if req.UserId != "" {
+		return &pb.Response{Response: "gRPC Code 0 : OK "}, nil
+	}
+	return nil, errors.New("Fuckoff")
+}
+
+func (s *server) CreatePageService(ctx context.Context, req *pb.CreatePageRequest) (*pb.Response, error) {
+	if req.NewPageString != "" {
+		return &pb.Response{Response: "gRPC Code 0 : OK "}, nil
+	}
+	return nil, errors.New("Fuckoff")
+}
+
+func (s *server) DeletePageService(ctx context.Context, req *pb.DeletePageRequest) (*pb.Response, error) {
+	if req.PageId != "" {
+		return &pb.Response{Response: "gRPC Code 0 : OK "}, nil
+	}
+	return nil, errors.New("Fuckoff")
+}
+
+func (s *server) UpdatePageService(ctx context.Context, req *pb.UpdatePageRequest) (*pb.Response, error) {
+	if req.PageId != "" {
+		return &pb.Response{Response: "gRPC Code 0 : OK "}, nil
+	}
+	return nil, errors.New("Fuckoff")
+}

pkg/protobuf/alter.proto

@@ -0,0 +1,40 @@
+syntax = "proto3";
+
+package alter;
+
+option go_package = "/pb";
+
+message CreateCheckRequest {
+  string Check = 1;
+  string PageId = 2;
+}
+
+message DeleteCheckRequest {
+  string UserId = 1;
+  string CheckId = 2;
+  string Role = 3;
+}
+
+message UpdateCheckRequest {
+  string CheckId = 1;
+  string UpdateCheckString = 2;
+  string UserId = 3;
+  string Role = 4;
+}
+
+message CreatePageRequest { string NewPageString = 1; }
+
+message DeletePageRequest { string PageId = 1; }
+
+message UpdatePageRequest { string PageId = 1; }
+
+message Response { string Response = 1; }
+
+service AlterServices {
+  rpc CreateCheckService(CreateCheckRequest) returns (Response) {}
+  rpc DeleteCheckService(DeleteCheckRequest) returns (Response) {}
+  rpc UpdateCheckService(UpdateCheckRequest) returns (Response) {}
+  rpc CreatePageService(CreatePageRequest) returns (Response) {}
+  rpc DeletePageService(DeletePageRequest) returns (Response) {}
+  rpc UpdatePageService(UpdatePageRequest) returns (Response) {}
+}