| package main |
| |
| import ( |
| "log" |
| "math/rand" |
| "net" |
| |
| "golang.org/x/net/context" |
| "google.golang.org/grpc" |
| pb "v.io/x/ref/examples/grpc-fortune/proto" |
| "v.io/x/ref/examples/grpc-fortune/vgrpc" |
| ) |
| |
| const ( |
| port = ":50053" |
| ) |
| |
| var ( |
| fortunes = []string{ |
| "앞으로 소녀시대 직접 만날 거예요", |
| "혼자 죽을 거예요", |
| "오래살고 돈 많아 벌 거예요", |
| } |
| random = rand.New(rand.NewSource(99)) |
| ) |
| |
| // TODO(krakauer): Add mutexes once the auth stuff works. |
| |
| type server struct{} |
| |
| func (s *server) Get(ctx context.Context, in *pb.FortuneGetRequest) (*pb.FortuneGetResponse, error) { |
| log.Printf("Returing from Get now.") |
| return &pb.FortuneGetResponse{ |
| Fortune: fortunes[random.Intn(len(fortunes))], |
| }, nil |
| } |
| |
| func (s *server) Add(ctx context.Context, in *pb.FortuneAddRequest) (*pb.FortuneAddResponse, error) { |
| fortunes = append(fortunes, in.Fortune) |
| return &pb.FortuneAddResponse{Succeeded: true}, nil |
| } |
| |
| func (s *server) Has(ctx context.Context, in *pb.FortuneHasRequest) (*pb.FortuneHasResponse, error) { |
| for _, f := range fortunes { |
| if f == in.Fortune { |
| return &pb.FortuneHasResponse{Has: true}, nil |
| } |
| } |
| return &pb.FortuneHasResponse{Has: false}, nil |
| } |
| |
| func main() { |
| lis, err := net.Listen("tcp", port) |
| if err != nil { |
| log.Fatalf("failed to listen: %v", err) |
| } |
| s := grpc.NewServer(grpc.Creds(&vgrpc.VanadiumCred{})) |
| pb.RegisterFortuneServer(s, &server{}) |
| s.Serve(lis) |
| } |
