Skip to content
Snippets Groups Projects
grpc_server.go 1.78 KiB
Newer Older
  • Learn to ignore specific revisions
  • OZGCloud's avatar
    OZGCloud committed
    /*
     * Copyright (C) 2023-2024
     * Das Land Schleswig-Holstein vertreten durch den
     * Ministerpräsidenten des Landes Schleswig-Holstein
     * Staatskanzlei
     * Abteilung Digitalisierung und zentrales IT-Management der Landesregierung
     *
     * Lizenziert unter der EUPL, Version 1.2 oder - sobald
     * diese von der Europäischen Kommission genehmigt wurden -
     * Folgeversionen der EUPL ("Lizenz");
     * Sie dürfen dieses Werk ausschließlich gemäß
     * dieser Lizenz nutzen.
     * Eine Kopie der Lizenz finden Sie hier:
     *
     * https://joinup.ec.europa.eu/collection/eupl/eupl-text-eupl-12
     *
     * Sofern nicht durch anwendbare Rechtsvorschriften
     * gefordert oder in schriftlicher Form vereinbart, wird
     * die unter der Lizenz verbreitete Software "so wie sie
     * ist", OHNE JEGLICHE GEWÄHRLEISTUNG ODER BEDINGUNGEN -
     * ausdrücklich oder stillschweigend - verbreitet.
     * Die sprachspezifischen Genehmigungen und Beschränkungen
     * unter der Lizenz sind dem Lizenztext zu entnehmen.
     */
    
    package server
    
    import (
    	"context"
    	pb "fachstellen-proxy/gen/go"
    	"fmt"
    	"google.golang.org/grpc"
    	"log"
    	"net"
    )
    
    const GrpcMockPort = 50051
    
    type server struct {
    	pb.UnimplementedFachstelleRegistrationServiceServer
    }
    
    func (s *server) Register(ctx context.Context, in *pb.GrpcFachstelleRegistrationRequest) (*pb.GrpcFachstelleRegistrationResponse, error) {
    	return &pb.GrpcFachstelleRegistrationResponse{}, nil
    }
    
    func StartGrpcServer() *grpc.Server {
    	s := grpc.NewServer()
    	pb.RegisterFachstelleRegistrationServiceServer(s, &server{})
    	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", GrpcMockPort))
    	if err != nil {
    		log.Fatalf("gRPC server failed to listen: %v", err)
    	}
    
    	log.Printf("gRPC server listening on port %d", GrpcMockPort)
    	if err := s.Serve(lis); err != nil {
    		log.Fatalf("gRPC server failed to serve: %v", err)
    	}
    
    	return s
    }