Function TestMain

controller/rest/rest_test.go:49–210

(m *testing.M)

}

func TestMain(m *testing.M) {
	// Setup
	cfg := config.NewTestConfig(generatedConfigPath, apiKey)

	tlsConfig, err := tlsutil.LoadTLSCredentials(sslCertFile, sslKeyFile)
	if err != nil {
		log.Fatalf("Failed to load TLS credentials: %v", err)
	}

	shutdownFunc, s, err := StartHttpListener(tlsConfig, addr, cfg)
	if err != nil {
		log.Fatalf("Failed to start HTTP listener: %v", err)
	}

	certPool, err := tlsutil.LoadClientPool(sslCertFile)
	if err != nil {
		log.Fatalf("Failed to load client pool: %v", err)
	}
	client := tlsutil.CreateHTTPClient(certPool, nodeHost)

	url := fmt.Sprintf("https://%s", addr)

	createAuthenticatedRequest := func(method, endpoint string, data proto.Message, response proto.Message) error {
		body, err := proto.Marshal(data)
		if err != nil {
			return err
		}

		req, err := http.NewRequest(method, url+endpoint, bytes.NewBuffer(body))
		if err != nil {
			return err
		}
		req.Header.Set("x-api-key", apiKey.String())
		if body != nil {
			req.Header.Set("Content-Type", "application/x-protobuf")
		}

		do, err := client.Do(req)
		if err != nil {
			return err
		}
		defer do.Body.Close()

		responseBody, _ := io.ReadAll(do.Body)
		if err = proto.Unmarshal(responseBody, response); err != nil {
			return err
		}
		return nil
	}

	createAuthenticatedStreamingRequest := func(method, endpoint string) (io.ReadCloser, error) {
		req, err := http.NewRequest(method, url+endpoint, nil)
		if err != nil {
			return nil, err
		}
		req.Header.Set("x-api-key", apiKey.String())

		resp, err := client.Do(req)