ساخت یک CRUD با گولنگ و gRPC

package main

import (
    "context"
    "log"
    "net"

    "google.golang.org/grpc"
    "path/to/your/project/crudpb"
)

type server struct {
    crudpb.UnimplementedCRUDServiceServer
    items map[string]*crudpb.Item
}

func (s *server) CreateItem(ctx context.Context, req *crudpb.CreateItemRequest) (*crudpb.CreateItemResponse, error) {
    item := req.GetItem()
    s.items[item.Id] = item
    return &crudpb.CreateItemResponse{Item: item}, nil
}

func (s *server) ReadItem(ctx context.Context, req *crudpb.ReadItemRequest) (*crudpb.ReadItemResponse, error) {
    item, exists := s.items[req.GetId()]
    if !exists {
       return nil, grpc.Errorf(codes.NotFound, "item not found")
    }
    return &crudpb.ReadItemResponse{Item: item}, nil
}

func (s *server) UpdateItem(ctx context.Context, req *crudpb.UpdateItemRequest) (*crudpb.UpdateItemResponse, error) {
    item := req.GetItem()
    s.items[item.Id] = item
    return &crudpb.UpdateItemResponse{Item: item}, nil
}

func (s *server) DeleteItem(ctx context.Context, req *crudpb.DeleteItemRequest) (*crudpb.DeleteItemResponse, error) {
    delete(s.items, req.GetId())
    return &crudpb.DeleteItemResponse{Id: req.GetId()}, nil
}

func main() {
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
       log.Fatalf("failed to listen: %v", err)
    }
    s := grpc.NewServer()
    crudpb.RegisterCRUDServiceServer(s, &server{items: make(map[string]*crudpb.Item)})
    log.Println("Server is running on port 50051")
    if err := s.Serve(lis); err != nil {
       log.Fatalf("failed to serve: %v", err)
    }
}

package main

import (
    "context"
    "log"
    "time"

    "google.golang.org/grpc"
    "path/to/your/project/crudpb"
)

func main() {
    conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure(), grpc.WithBlock())
    if err != nil {
       log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()
    c := crudpb.NewCRUDServiceClient(conn)

    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    defer cancel()

    // Create an item
    item := &crudpb.Item{Id: "1", Name: "Item 1", Description: "This is item 1"}
    res, err := c.CreateItem(ctx, &crudpb.CreateItemRequest{Item: item})
    if err != nil {
       log.Fatalf("could not create item: %v", err)
    }
    log.Printf("Item created: %v", res.GetItem())

    // Read an item
    resRead, err := c.ReadItem(ctx, &crudpb.ReadItemRequest{Id: "1"})
    if err != nil {
       log.Fatalf("could not read item: %v", err)
    }
    log.Printf("Item read: %v", resRead.GetItem())

    // Update an item
    item.Description = "This is the updated item 1"
    resUpdate, err := c.UpdateItem(ctx, &crudpb.UpdateItemRequest{Item: item})
    if err != nil {
       log.Fatalf("could not update item: %v", err)
    }
    log.Printf("Item updated: %v", resUpdate.GetItem())

    // Delete an item
    resDelete, err := c.DeleteItem(ctx, &crudpb.DeleteItemRequest{Id: "1"})
    if err != nil {
       log.Fatalf("could not delete item: %v", err)
    }
    log.Printf("Item deleted: %v", resDelete.GetId())
}