TestMu Conference is Back! Future of Testing + AI LambdaTest G2 Announcement

Automation Advisor
Testkube
v1
getExecutionsFilterFromRequest

How to use getExecutionsFilterFromRequest method of v1 Package

Best Testkube code snippet using v1.getExecutionsFilterFromRequest

testsuites.go

Source:testsuites.go

...459}460func (s TestkubeAPI) ListTestSuiteExecutionsHandler() fiber.Handler {461	return func(c *fiber.Ctx) error {462		ctx := context.Background()463		filter := getExecutionsFilterFromRequest(c)464		executionsTotals, err := s.TestExecutionResults.GetExecutionsTotals(ctx, filter)465		if err != nil {466			return s.Error(c, http.StatusBadRequest, err)467		}468		allExecutionsTotals, err := s.TestExecutionResults.GetExecutionsTotals(ctx)469		if err != nil {470			return s.Error(c, http.StatusBadRequest, err)471		}472		executions, err := s.TestExecutionResults.GetExecutions(ctx, filter)473		if err != nil {474			return s.Error(c, http.StatusBadRequest, err)475		}476		return c.JSON(testkube.TestSuiteExecutionsResult{477			Totals:   &allExecutionsTotals,478			Filtered: &executionsTotals,479			Results:  testsuitesmapper.MapToTestExecutionSummary(executions),480		})481	}482}483func (s TestkubeAPI) GetTestSuiteExecutionHandler() fiber.Handler {484	return func(c *fiber.Ctx) error {485		ctx := context.Background()486		id := c.Params("executionID")487		execution, err := s.TestExecutionResults.Get(ctx, id)488		if err == mongo.ErrNoDocuments {489			execution, err = s.TestExecutionResults.GetByName(ctx, id)490			if err == mongo.ErrNoDocuments {491				return s.Error(c, http.StatusNotFound, fmt.Errorf("test suite with execution id/name %s not found", id))492			}493		}494		if err != nil {495			return s.Error(c, http.StatusBadRequest, err)496		}497		execution.Duration = types.FormatDuration(execution.Duration)498		secretMap := make(map[string]string)499		if execution.SecretUUID != "" && execution.TestSuite != nil {500			secretMap, err = s.TestsSuitesClient.GetSecretTestSuiteVars(execution.TestSuite.Name, execution.SecretUUID)501			if err != nil {502				return s.Error(c, http.StatusInternalServerError, err)503			}504		}505		for key, value := range secretMap {506			if variable, ok := execution.Variables[key]; ok && value != "" {507				variable.Value = string(value)508				variable.SecretRef = nil509				execution.Variables[key] = variable510			}511		}512		return c.JSON(execution)513	}514}515// ListTestSuiteTestsHandler for getting list of all available Tests for TestSuites516func (s TestkubeAPI) ListTestSuiteTestsHandler() fiber.Handler {517	return func(c *fiber.Ctx) error {518		name := c.Params("id")519		crTestSuite, err := s.TestsSuitesClient.Get(name)520		if err != nil {521			if errors.IsNotFound(err) {522				return s.Warn(c, http.StatusNotFound, err)523			}524			return s.Error(c, http.StatusBadGateway, err)525		}526		testSuite := testsuitesmapper.MapCRToAPI(*crTestSuite)527		crTests, err := s.TestsClient.ListByNames(testSuite.GetTestNames())528		if err != nil {529			if errors.IsNotFound(err) {530				return s.Warn(c, http.StatusNotFound, err)531			}532			return s.Error(c, http.StatusBadGateway, err)533		}534		return c.JSON(testsmapper.MapTestArrayKubeToAPI(crTests))535	}536}537func (s TestkubeAPI) executeTestSuite(ctx context.Context, testSuite testkube.TestSuite, request testkube.TestSuiteExecutionRequest) (538	testsuiteExecution testkube.TestSuiteExecution, err error) {539	s.Log.Debugw("Got test to execute", "test", testSuite)540	secretUUID, err := s.TestsSuitesClient.GetCurrentSecretUUID(testSuite.Name)541	if err != nil {542		return testsuiteExecution, err543	}544	request.SecretUUID = secretUUID545	if testSuite.ExecutionRequest != nil {546		if request.Name == "" && testSuite.ExecutionRequest.Name != "" {547			request.Name = testSuite.ExecutionRequest.Name548		}549		if request.HttpProxy == "" && testSuite.ExecutionRequest.HttpProxy != "" {550			request.HttpProxy = testSuite.ExecutionRequest.HttpProxy551		}552		if request.HttpsProxy == "" && testSuite.ExecutionRequest.HttpsProxy != "" {553			request.HttpsProxy = testSuite.ExecutionRequest.HttpsProxy554		}555	}556	request.Number = s.getNextExecutionNumber("ts-" + testSuite.Name)557	if request.Name == "" {558		request.Name = fmt.Sprintf("ts-%s-%d", testSuite.Name, request.Number)559	}560	testsuiteExecution = testkube.NewStartedTestSuiteExecution(testSuite, request)561	err = s.TestExecutionResults.Insert(ctx, testsuiteExecution)562	if err != nil {563		s.Log.Infow("Inserting test execution", "error", err)564	}565	s.Events.Notify(testkube.NewEventStartTestSuite(&testsuiteExecution))566	var wg sync.WaitGroup567	wg.Add(1)568	go func(testsuiteExecution *testkube.TestSuiteExecution, request testkube.TestSuiteExecutionRequest) {569		defer func(testExecution *testkube.TestSuiteExecution) {570			duration := testExecution.CalculateDuration()571			testExecution.EndTime = time.Now()572			testExecution.Duration = duration.String()573			err = s.TestExecutionResults.EndExecution(ctx, testExecution.Id, testExecution.EndTime, duration)574			if err != nil {575				s.Log.Errorw("error setting end time", "error", err.Error())576			}577			wg.Done()578		}(testsuiteExecution)579		hasFailedSteps := false580		cancellSteps := false581		for i := range testsuiteExecution.StepResults {582			if cancellSteps {583				testsuiteExecution.StepResults[i].Execution.ExecutionResult.Cancel()584				continue585			}586			// start execution of given step587			testsuiteExecution.StepResults[i].Execution.ExecutionResult.InProgress()588			err = s.TestExecutionResults.Update(ctx, *testsuiteExecution)589			if err != nil {590				s.Log.Infow("Updating test execution", "error", err)591			}592			s.executeTestStep(ctx, *testsuiteExecution, request, &testsuiteExecution.StepResults[i])593			err := s.TestExecutionResults.Update(ctx, *testsuiteExecution)594			if err != nil {595				hasFailedSteps = true596				s.Log.Errorw("saving test suite execution results error", "error", err)597				continue598			}599			if testsuiteExecution.StepResults[i].IsFailed() {600				hasFailedSteps = true601				if testsuiteExecution.StepResults[i].Step.StopTestOnFailure {602					cancellSteps = true603					continue604				}605			}606		}607		testsuiteExecution.Status = testkube.TestSuiteExecutionStatusPassed608		if hasFailedSteps {609			testsuiteExecution.Status = testkube.TestSuiteExecutionStatusFailed610			s.Events.Notify(testkube.NewEventEndTestSuiteFailed(testsuiteExecution))611		} else {612			s.Events.Notify(testkube.NewEventEndTestSuiteSuccess(testsuiteExecution))613		}614		s.Metrics.IncExecuteTestSuite(*testsuiteExecution)615		err := s.TestExecutionResults.Update(ctx, *testsuiteExecution)616		if err != nil {617			s.Log.Errorw("saving final test suite execution result error", "error", err)618		}619	}(&testsuiteExecution, request)620	// wait for sync test suite execution621	if request.Sync {622		wg.Wait()623	}624	return testsuiteExecution, nil625}626func (s TestkubeAPI) executeTestStep(ctx context.Context, testsuiteExecution testkube.TestSuiteExecution,627	request testkube.TestSuiteExecutionRequest, result *testkube.TestSuiteStepExecutionResult) {628	var testSuiteName string629	if testsuiteExecution.TestSuite != nil {630		testSuiteName = testsuiteExecution.TestSuite.Name631	}632	step := result.Step633	l := s.Log.With("type", step.Type(), "testSuiteName", testSuiteName, "name", step.FullName())634	switch step.Type() {635	case testkube.TestSuiteStepTypeExecuteTest:636		executeTestStep := step.Execute637		request := testkube.ExecutionRequest{638			Name:                fmt.Sprintf("%s-%s", testSuiteName, executeTestStep.Name),639			TestSuiteName:       testSuiteName,640			Namespace:           executeTestStep.Namespace,641			Variables:           testsuiteExecution.Variables,642			TestSuiteSecretUUID: request.SecretUUID,643			Sync:                true,644			HttpProxy:           request.HttpProxy,645			HttpsProxy:          request.HttpsProxy,646			ExecutionLabels:     request.ExecutionLabels,647		}648		l.Info("executing test", "variables", testsuiteExecution.Variables, "request", request)649		execution, err := s.executeTest(ctx, testkube.Test{Name: executeTestStep.Name}, request)650		if err != nil {651			result.Err(err)652			return653		}654		result.Execution = &execution655	case testkube.TestSuiteStepTypeDelay:656		l.Debug("delaying execution")657		time.Sleep(time.Millisecond * time.Duration(step.Delay.Duration))658		result.Execution.ExecutionResult.Success()659	default:660		result.Err(fmt.Errorf("can't find handler for execution step type: '%v'", step.Type()))661	}662}663func getExecutionsFilterFromRequest(c *fiber.Ctx) testresult.Filter {664	filter := testresult.NewExecutionsFilter()665	name := c.Query("id", "")666	if name != "" {667		filter = filter.WithName(name)668	}669	textSearch := c.Query("textSearch", "")670	if textSearch != "" {671		filter = filter.WithTextSearch(textSearch)672	}673	page, err := strconv.Atoi(c.Query("page", ""))674	if err == nil {675		filter = filter.WithPage(page)676	}677	pageSize, err := strconv.Atoi(c.Query("pageSize", ""))...

getExecutionsFilterFromRequest

Using AI Code Generation

1func getExecutionsFilterFromRequest(r *http.Request) (*v1.ExecutionsFilter, error) {2	if err := json.NewDecoder(r.Body).Decode(&filter); err != nil {3	}4}5func getExecutionsFilterFromRequest(r *http.Request) (*v1.ExecutionsFilter, error) {6	if err := json.NewDecoder(r.Body).Decode(&filter); err != nil {7	}8}9func getExecutionsFilterFromRequest(r *http.Request) (*v1.ExecutionsFilter, error) {10	if err := json.NewDecoder(r.Body).Decode(&filter); err != nil {11	}12}13func getExecutionsFilterFromRequest(r *http.Request) (*v1.ExecutionsFilter, error) {14	if err := json.NewDecoder(r.Body).Decode(&filter); err != nil {15	}16}17func getExecutionsFilterFromRequest(r *http.Request) (*v1.ExecutionsFilter, error) {18	if err := json.NewDecoder(r.Body).Decode(&filter); err != nil {19	}20}21func getExecutionsFilterFromRequest(r *http.Request) (*v1.ExecutionsFilter, error) {22	if err := json.NewDecoder(r.Body).Decode(&filter); err != nil {23	}24}

getExecutionsFilterFromRequest

Using AI Code Generation

1func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {2	result := v1.GetExecutionsFilter{}3	result.Project = r.URL.Query().Get("project")4	result.Domain = r.URL.Query().Get("domain")5	result.Workflow = r.URL.Query().Get("workflow")6	result.LaunchPlan = r.URL.Query().Get("launch_plan")7	result.Execution = r.URL.Query().Get("execution")8	result.Task = r.URL.Query().Get("task")9	result.NodeExecution = r.URL.Query().Get("node_execution")10	result.ParentNodeExecution = r.URL.Query().Get("parent_node_execution")11	result.Limit, err = getLimitFromRequest(r)12	if err != nil {13	}14	result.Token, err = getTokenFromRequest(r)15	if err != nil {16	}17	result.SortBy = r.URL.Query().Get("sort_by")18	result.SortDirection, err = getSortDirectionFromRequest(r)19	if err != nil {20	}21	result.Phase, err = getPhaseFromRequest(r)22	if err != nil {23	}24	result.TaskType, err = getTaskTypeFromRequest(r)25	if err != nil {26	}27	result.TaskExecution, err = getTaskExecutionFromRequest(r)28	if err != nil {29	}30	result.NodeExecution, err = getNodeExecutionFromRequest(r)31	if err != nil {32	}33	result.ParentNodeExecution, err = getParentNodeExecutionFromRequest(r)34	if err != nil {35	}36}37func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {38	result := v1.GetExecutionsFilter{}39	result.Project = r.URL.Query().Get("project")40	result.Domain = r.URL.Query().Get("domain")41	result.Workflow = r.URL.Query().Get("workflow")42	result.LaunchPlan = r.URL.Query().Get("launch_plan")43	result.Execution = r.URL.Query().Get("execution")44	result.Task = r.URL.Query().Get("task")45	result.NodeExecution = r.URL.Query().Get("node_execution

getExecutionsFilterFromRequest

Using AI Code Generation

1func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {2	if r.Body != nil {3		if body, err = ioutil.ReadAll(r.Body); err != nil {4		}5	}6	if len(body) > 0 {7		filter = &v1.GetExecutionsFilter{}8		if err = json.Unmarshal(body, filter); err != nil {9		}10	}11}12func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {13	if r.Body != nil {14		if body, err = ioutil.ReadAll(r.Body); err != nil {15		}16	}17	if len(body) > 0 {18		filter = &v1.GetExecutionsFilter{}19		if err = json.Unmarshal(body, filter); err != nil {20		}21	}22}23func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {24	if r.Body != nil {25		if body, err = ioutil.ReadAll(r.Body); err != nil {26		}27	}28	if len(body) > 0 {29		filter = &v1.GetExecutionsFilter{}30		if err = json.Unmarshal(body, filter); err != nil {31		}32	}33}34func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {35	if r.Body != nil {36		if body, err = ioutil.ReadAll(r

getExecutionsFilterFromRequest

Using AI Code Generation

1func getExecutionsFilterFromRequest(r *http.Request) (*v1.GetExecutionsFilter, error) {2	if r.URL.Query().Get("workflow_id") != "" {3		filter.WorkflowId = r.URL.Query().Get("workflow_id")4	}5	if r.URL.Query().Get("workflow_name") != "" {6		filter.WorkflowName = r.URL.Query().Get("workflow_name")7	}8	if r.URL.Query().Get("project_id") != "" {9		filter.ProjectID = r.URL.Query().Get("project_id")10	}11	if r.URL.Query().Get("project_name") != "" {12		filter.ProjectName = r.URL.Query().Get("project_name")13	}14	if r.URL.Query().Get("workflow_execution_id") != "" {15		filter.WorkflowExecutionId = r.URL.Query().Get("workflow_execution_id")16	}17	if r.URL.Query().Get("workflow_execution_name") != "" {18		filter.WorkflowExecutionName = r.URL.Query().Get("workflow_execution_name")19	}20	if r.URL.Query().Get("workflow_execution_type") != "" {21		filter.WorkflowExecutionType = r.URL.Query().Get("workflow_execution_type")22	}23	if r.URL.Query().Get("workflow_execution_status") != "" {24		filter.WorkflowExecutionStatus = r.URL.Query().Get("workflow_execution_status")25	}26	if r.URL.Query().Get("workflow_execution_start_time") != "" {27		filter.WorkflowExecutionStartTime, err = time.Parse(time.RFC3339, r.URL.Query().Get("workflow_execution_start_time"))28		if err != nil {29		}30	}31	if r.URL.Query().Get("workflow_execution_end_time") != "" {32		filter.WorkflowExecutionEndTime, err = time.Parse(time.RFC3339, r.URL.Query().Get("workflow_execution_end_time"))33		if err != nil {34		}35	}36	if r.URL.Query().Get("workflow_execution_creation_time") != "" {37		filter.WorkflowExecutionCreationTime, err = time.Parse(time.RFC3339, r.URL.Query().Get("workflow_execution_creation_time"))38		if err != nil {39		}40	}41	if r.URL.Query().Get("workflow_execution_update_time") != "" {42		filter.WorkflowExecutionUpdateTime, err = time.Parse(time.RFC3339

getExecutionsFilterFromRequest

Using AI Code Generation

1import (2func main() {3	r := mux.NewRouter()4	r.HandleFunc("/executions", getExecutionsFilterFromRequest).Methods("GET")5	http.ListenAndServe(":8081", r)6}7func getExecutionsFilterFromRequest(w http.ResponseWriter, r *http.Request) {8	queryParams := r.URL.Query()9	if len(queryParams) > 0 {10		for key, value := range queryParams {11			switch key {12				filter.Labels = strings.Split(value[0], ",")13			}14		}15	}16	fmt.Println(filter)17}18{project:stage:service:keptnContext:timeStart:timeEnd:eventType:pageSize:nextPageKey:sort:labels:}19{project:stage:service:keptnContext:timeStart:timeEnd:eventType:pageSize:nextPageKey:sort:labels:[label1 label2]}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.