Skip to content
Snippets Groups Projects
grpc_router.go 2.57 KiB
Newer Older
  • Learn to ignore specific revisions
  • /*
     * 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"
    	"fachstellen-proxy/internal/config"
    	"fachstellen-proxy/internal/mock"
    	"fmt"
    	"google.golang.org/grpc"
    	"google.golang.org/grpc/codes"
    	"google.golang.org/grpc/credentials/insecure"
    	"google.golang.org/grpc/status"
    	"net"
    )
    
    type collaborationRouter struct {
    	pb.UnimplementedCollaborationServiceServer
    }
    
    func (s *collaborationRouter) FindVorgang(ctx context.Context, in *pb.GrpcFindVorgangRequest) (*pb.GrpcFindVorgangResponse, error) {
    	if in.VorgangId == "" {
    		return nil, status.Error(codes.InvalidArgument, "VorgangId is missing")
    	}
    
    	conn, err := grpc.NewClient(getCollaborationServerAddress(), grpc.WithTransportCredentials(insecure.NewCredentials()))
    	if err != nil {
    		logger.Fatal("collaboration router failed to route: %v", err)
    	}
    	defer conn.Close()
    
    	client := pb.NewCollaborationServiceClient(conn)
    
    	return client.FindVorgang(context.Background(), in)
    }
    
    func StartCollaborationRouter(conf config.Config) *grpc.Server {
    	s := grpc.NewServer()
    	pb.RegisterCollaborationServiceServer(s, &collaborationRouter{})
    
    	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", conf.Grpc.Collaboration.Router.Port))
    	if err != nil {
    		logger.Fatal("collaboration router failed to listen: %v", err)
    	}
    
    	logger.Info("collaboration router listening on port %d", conf.Grpc.Collaboration.Router.Port)
    	if err := s.Serve(lis); err != nil {
    		logger.Fatal("collaboration router failed to serve: %v", err)
    	}
    
    	return s
    }
    
    func getCollaborationServerAddress() string {
    	// TODO: Nur wenn GRPC_MOCK == true, sonst Adresse aus VorgangId lesen
    	return fmt.Sprintf("localhost:%d", mock.GrpcMockPort)
    }