livemap.pb.tester.go

// Code generated by protoc-gen-customizer. DO NOT EDIT.
// source: services/livemapper/livemap.proto

package livemapper

import (
	"context"
	"log"
	"net"

	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"
	"google.golang.org/grpc/test/bufconn"
)

func NewTestLivemapperServiceClient(srv LivemapperServiceServer) (LivemapperServiceClient, context.Context, context.CancelFunc) {
	ctx, cancel := context.WithCancel(context.Background())

	buffer := 101024 * 1024
	lis := bufconn.Listen(buffer)

	server := grpc.NewServer()
	RegisterLivemapperServiceServer(server, srv)
	go func() {
		if err := server.Serve(lis); err != nil {
			log.Printf("error serving test grpc server: %v", err)
		}
	}()

	conn, err := grpc.DialContext(ctx, "",
		grpc.WithContextDialer(func(context.Context, string) (net.Conn, error) {
			return lis.Dial()
		}), grpc.WithTransportCredentials(insecure.NewCredentials()))
	if err != nil {
		log.Printf("error connecting to test grpc server: %v", err)
	}

	go func() {
		<-ctx.Done()
		err := lis.Close()
		if err != nil {
			log.Printf("error closing listener: %v", err)
		}
		server.Stop()
	}()

	client := NewLivemapperServiceClient(conn)
	return client, ctx, cancel
}