grpc_server.go

/*
 * 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 mock

import (
	"context"
	pb "fachstellen-proxy/gen/go"
	"fmt"
	"google.golang.org/grpc"
	"google.golang.org/grpc/codes"
	"google.golang.org/grpc/status"
	"net"
)

const GrpcMockPort = 50052

type registrationServer struct {
	pb.UnimplementedFachstelleRegistrationServiceServer
}

func (s *registrationServer) Register(ctx context.Context, in *pb.GrpcFachstelleRegistrationRequest) (*pb.GrpcFachstelleRegistrationResponse, error) {
	if in.Fachstelle == nil {
		return nil, status.Error(codes.InvalidArgument, "Fachstelle is missing")
	}

	if in.Fachstelle.MukId == "conflictMukId" {
		return nil, status.Error(codes.AlreadyExists, "Conflict MukId")
	} else if in.Fachstelle.MukId == "unavailableMukId" {
		return nil, status.Error(codes.Unavailable, "Unavailable MukId")
	} else if in.Fachstelle.MukId == "erroneousMukId" {
		return nil, status.Error(codes.Internal, "Erroneous MukId")
	}

	return &pb.GrpcFachstelleRegistrationResponse{}, nil
}

type collaborationServer struct {
	pb.UnimplementedCollaborationServiceServer
}

func (s *collaborationServer) FindVorgang(ctx context.Context, in *pb.GrpcFindVorgangRequest) (*pb.GrpcFindVorgangResponse, error) {
	if in.VorgangId == "" {
		return nil, status.Error(codes.InvalidArgument, "VorgangId is missing")
	}

	if in.SamlToken == "" {
		return nil, status.Error(codes.InvalidArgument, "SamlToken is missing")
	}

	return &pb.GrpcFindVorgangResponse{Vorgang: &pb.GrpcVorgang{Id: "testVorgangId"}}, nil
}

func StartGrpcServer() *grpc.Server {
	s := grpc.NewServer()
	pb.RegisterFachstelleRegistrationServiceServer(s, &registrationServer{})
	pb.RegisterCollaborationServiceServer(s, &collaborationServer{})

	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", GrpcMockPort))
	if err != nil {
		logger.Fatal("gRPC server failed to listen: %v", err)
	}

	logger.Info("gRPC server listening on port %d", GrpcMockPort)
	if err := s.Serve(lis); err != nil {
		logger.Fatal("gRPC server failed to serve: %v", err)
	}

	return s
}