test(backend): Rename ArtifactApiTest to ArtifactAPITest

Signed-off-by: Helber Belmiro <[email protected]>

Author: hbelmiro

backend/test/integration/artifact_api_test.go

@@ -38,7 +38,7 @@ import (
 	"github.com/stretchr/testify/suite"
 )
 
-type ArtifactApiTest struct {
+type ArtifactAPITest struct {
 	suite.Suite
 	namespace            string
 	resourceNamespace    string
@@ -48,7 +48,7 @@ type ArtifactApiTest struct {
 	runClient            *api_server.RunClient
 }
 
-func (s *ArtifactApiTest) SetupTest() {
+func (s *ArtifactAPITest) SetupTest() {
 	if !*runIntegrationTests {
 		s.T().SkipNow()
 		return
@@ -83,21 +83,21 @@ func (s *ArtifactApiTest) SetupTest() {
 	}
 }
 
-func (s *ArtifactApiTest) TearDownSuite() {
+func (s *ArtifactAPITest) TearDownSuite() {
 	if *runIntegrationTests {
 		if !*isDevMode {
 			s.cleanUp()
 		}
 	}
 }
 
-func (s *ArtifactApiTest) cleanUp() {
+func (s *ArtifactAPITest) cleanUp() {
 	test.DeleteAllExperiments(s.experimentClient, s.namespace, s.T())
 	test.DeleteAllPipelines(s.pipelineClient, s.T())
 	test.DeleteAllRuns(s.runClient, s.namespace, s.T())
 }
 
-func (s *ArtifactApiTest) TestV1PipelineArtifactRead() {
+func (s *ArtifactAPITest) TestV1PipelineArtifactRead() {
 	runID := s.runPipeline()
 
 	s.waitForRunCompletion(runID)
@@ -108,15 +108,15 @@ func (s *ArtifactApiTest) TestV1PipelineArtifactRead() {
 	s.testReadArtifactEndpoint(runID, nodeID, artifactName)
 }
 
-func (s *ArtifactApiTest) createExperiment() *experiment_model.APIExperiment {
+func (s *ArtifactAPITest) createExperiment() *experiment_model.APIExperiment {
 	experimentName := fmt.Sprintf("artifact-test-experiment-%d", time.Now().Unix())
 	experiment := test.GetExperiment(experimentName, "Test for artifact reading", s.namespace)
 	experiment, err := s.experimentClient.Create(&params.ExperimentServiceCreateExperimentV1Params{Experiment: experiment})
 	require.NoError(s.T(), err)
 	return experiment
 }
 
-func (s *ArtifactApiTest) uploadPipeline() *pipeline_upload_model.APIPipeline {
+func (s *ArtifactAPITest) uploadPipeline() *pipeline_upload_model.APIPipeline {
 	pipelineParams := uploadParams.NewUploadPipelineParams()
 	pipelineName := fmt.Sprintf("large-artifact-test-%d", time.Now().Unix())
 	pipelineParams.SetName(&pipelineName)
@@ -125,7 +125,7 @@ func (s *ArtifactApiTest) uploadPipeline() *pipeline_upload_model.APIPipeline {
 	return pipeline
 }
 
-func (s *ArtifactApiTest) runPipeline() string {
+func (s *ArtifactAPITest) runPipeline() string {
 	experiment := s.createExperiment()
 	pipeline := s.uploadPipeline()
 
@@ -149,7 +149,7 @@ func (s *ArtifactApiTest) runPipeline() string {
 	return run.Run.ID
 }
 
-func (s *ArtifactApiTest) waitForRunCompletion(runID string) {
+func (s *ArtifactAPITest) waitForRunCompletion(runID string) {
 	t := s.T()
 	maxWaitTime := 2 * time.Minute
 	startTime := time.Now()
@@ -172,7 +172,7 @@ func (s *ArtifactApiTest) waitForRunCompletion(runID string) {
 	require.Fail(t, "Run did not complete within %v", maxWaitTime)
 }
 
-func (s *ArtifactApiTest) extractWorkflowNodeID(runID string) string {
+func (s *ArtifactAPITest) extractWorkflowNodeID(runID string) string {
 	t := s.T()
 
 	resp, err := http.Get(fmt.Sprintf("http://localhost:8888/apis/v1beta1/runs/%s", runID))
@@ -193,7 +193,7 @@ func (s *ArtifactApiTest) extractWorkflowNodeID(runID string) string {
 	return nodeID
 }
 
-func (s *ArtifactApiTest) testReadArtifactEndpoint(runID, nodeID, artifactName string) {
+func (s *ArtifactAPITest) testReadArtifactEndpoint(runID, nodeID, artifactName string) {
 	t := s.T()
 
 	baseURL := "http://localhost:8888"
@@ -233,7 +233,7 @@ func (s *ArtifactApiTest) testReadArtifactEndpoint(runID, nodeID, artifactName s
 	t.Log("ReadArtifact endpoint validated successfully")
 }
 
-func (s *ArtifactApiTest) validateResponseHeaders(resp *http.Response) {
+func (s *ArtifactAPITest) validateResponseHeaders(resp *http.Response) {
 	t := s.T()
 
 	contentType := resp.Header.Get("Content-Type")
@@ -252,11 +252,11 @@ func (s *ArtifactApiTest) validateResponseHeaders(resp *http.Response) {
 	}
 }
 
-func (s *ArtifactApiTest) requireGzipCompressed(body []byte) {
+func (s *ArtifactAPITest) requireGzipCompressed(body []byte) {
 	require.True(s.T(), len(body) > 2 && body[0] == 0x1f && body[1] == 0x8b,
 		"Artifact should be gzip compressed")
 }
 
 func TestArtifactAPI(t *testing.T) {
-	suite.Run(t, new(ArtifactApiTest))
+	suite.Run(t, new(ArtifactAPITest))
 }