@@ -562,7 +562,6 @@ func (s *server) GetHistoryTestCase(ctx context.Context, in *HistoryTestCase) (r
562562	return 
563563}
564564
565- << << << <  HEAD 
566565var  ExecutionCountNum  =  promauto .NewCounter (prometheus.CounterOpts {
567566	Name : "atest_execution_count" ,
568567	Help : "The total number of request execution" ,
@@ -607,10 +606,10 @@ func (s *server) RunTestCase(ctx context.Context, in *TestCaseIdentity) (result
607606			Parameters : in .Parameters ,
608607		}
609608
610- 		result  =  s .getRunResult (ctx , task )   
611- 		if  result .Error  !=  ""  {   
612- 		    return    
613- 		}   
609+ 		result  =  s .getRunResult (ctx , task )
610+ 		if  result .Error  !=  ""  {
611+ 			 return 
612+ 		}
614613		normalResult  :=  ToNormalTestCaseResult (result )
615614		var  testSuite  * testing.TestSuite 
616615		if  testSuite , err  =  s .getSuiteFromTestTask (task ); err  !=  nil  {
@@ -623,7 +622,11 @@ func (s *server) RunTestCase(ctx context.Context, in *TestCaseIdentity) (result
623622			result  =  & TestCaseResult {
624623				Error : err .Error (),
625624			}
626- == == == = 
625+ 		}
626+ 	}
627+ 	return 
628+ }
629+ 
627630func  (s  * server ) GetTestCaseAllHistory (ctx  context.Context , in  * TestCase ) (result  * HistoryTestCases , err  error ) {
628631	var  items  []testing.HistoryTestCase 
629632	loader  :=  s .getLoader (ctx )
@@ -632,138 +635,90 @@ func (s *server) GetTestCaseAllHistory(ctx context.Context, in *TestCase) (resul
632635		result  =  & HistoryTestCases {}
633636		for  _ , item  :=  range  items  {
634637			result .Data  =  append (result .Data , ConvertToGRPCHistoryTestCase (item ))
635- >> >> >> >  6 c2cd54  (feat : add  history  case  revert  api  and  ui )
636638		}
637639	}
638640	return 
639641}
640642
641- << << << <  HEAD 
642- == == == = 
643- func  (s  * server ) RunTestCase (ctx  context .Context , in  * TestCaseIdentity ) (result  * TestCaseResult , err  error ) {  
644-     var  targetTestSuite  testing.TestSuite   
645-   
646-     loader  :=  s .getLoader (ctx )  
647-     defer  loader .Close ()  
648-     targetTestSuite , err  =  loader .GetTestSuite (in .Suite , true )  
649-     if  err  !=  nil  {  
650-        err  =  nil   
651-        result  =  & TestCaseResult {  
652-           Error : fmt .Sprintf ("not found suite: %s" , in .Suite ),  
653-        }  
654-        return   
655-     }  
656-   
657-     var  data  []byte   
658-     if  data , err  =  yaml .Marshal (targetTestSuite ); err  ==  nil  {  
659-        task  :=  & TestTask {  
660-           Kind :       "testcaseInSuite" ,  
661-           Data :       string (data ),  
662-           CaseName :   in .Testcase ,  
663-           Level :      "debug" ,  
664-           Parameters : in .Parameters ,  
665-        }  
666-        result  =  s .getRunResult (ctx , task )  
667-        if  result .Error  !=  ""  {  
668-           return   
669-        }  
670-        normalResult  :=  ToNormalTestCaseResult (result )  
671-        var  testSuite  * testing.TestSuite   
672-        if  testSuite , err  =  s .getSuiteFromTestTask (task ); err  !=  nil  {  
673-           result  =  & TestCaseResult {  
674-              Error : err .Error (),  
675-           }  
676-        }  
677-        err  =  loader .CreateHistoryTestCase (normalResult , testSuite )  
678-        if  err  !=  nil  {  
679-           result  =  & TestCaseResult {  
680-              Error : err .Error (),  
681-           }  
682-        }  
683-     }  
684-     return   
685- }  
686-   
687- >> >> >> >  6 c2cd54  (feat : add  history  case  revert  api  and  ui )
688- func  (s  * server ) RunHistoryTestCase (ctx  context .Context , in  * HistoryTestCase ) (result  * TestCaseResult , err  error ) {  
689-     var  targetTestCase  testing.HistoryTestCase   
690-   
691-     loader  :=  s .getLoader (ctx )  
692-     defer  loader .Close ()  
693-     targetTestCase , err  =  loader .GetHistoryTestCase (in .ID )  
694-     if  err  !=  nil  {  
695-        err  =  nil   
696-        result  =  & TestCaseResult {  
697-           Error : fmt .Sprintf ("not found : %s" , in .ID ),  
698-        }  
699-        return   
700-     }  
701-   
702-     var  data  []byte   
703-     if  data , err  =  yaml .Marshal (targetTestCase ); err  ==  nil  {  
704-        task  :=  & TestTask {  
705-           Kind :       "historyTestcase" ,  
706-           Data :       string (data ),  
707-           CaseName :   targetTestCase .CaseName ,  
708-           Level :      "debug" ,  
709-           Parameters : in .SuiteParam ,  
710-        }  
711-        result  =  s .getRunResult (ctx , task )  
712-        if  result .Error  !=  ""  {  
713-           return   
714-        }  
715-        normalResult  :=  ToNormalTestCaseResult (result )  
716-        var  testSuite  * testing.TestSuite   
717-        if  testSuite , err  =  s .getSuiteFromTestTask (task ); err  !=  nil  {  
718-           result  =  & TestCaseResult {  
719-              Error : err .Error (),  
720-           }  
721-        }  
722-        err  =  loader .CreateHistoryTestCase (normalResult , testSuite )  
723-        if  err  !=  nil  {  
724-           result  =  & TestCaseResult {  
725-              Error : err .Error (),  
726-           }  
727-        }  
728-     }  
729-     return   
730- }  
731- 
732- func  (s  * server ) getRunResult (ctx  context .Context , task  * TestTask ) (result  * TestCaseResult ) {  
643+ func  (s  * server ) RunHistoryTestCase (ctx  context.Context , in  * HistoryTestCase ) (result  * TestCaseResult , err  error ) {
644+ 	var  targetTestCase  testing.HistoryTestCase 
645+ 
646+ 	loader  :=  s .getLoader (ctx )
647+ 	defer  loader .Close ()
648+ 	targetTestCase , err  =  loader .GetHistoryTestCase (in .ID )
649+ 	if  err  !=  nil  {
650+ 		err  =  nil 
651+ 		result  =  & TestCaseResult {
652+ 			Error : fmt .Sprintf ("not found : %s" , in .ID ),
653+ 		}
654+ 		return 
655+ 	}
656+ 
657+ 	var  data  []byte 
658+ 	if  data , err  =  yaml .Marshal (targetTestCase ); err  ==  nil  {
659+ 		task  :=  & TestTask {
660+ 			Kind :       "historyTestcase" ,
661+ 			Data :       string (data ),
662+ 			CaseName :   targetTestCase .CaseName ,
663+ 			Level :      "debug" ,
664+ 			Parameters : in .SuiteParam ,
665+ 		}
666+ 		result  =  s .getRunResult (ctx , task )
667+ 		if  result .Error  !=  ""  {
668+ 			return 
669+ 		}
670+ 		normalResult  :=  ToNormalTestCaseResult (result )
671+ 		var  testSuite  * testing.TestSuite 
672+ 		if  testSuite , err  =  s .getSuiteFromTestTask (task ); err  !=  nil  {
673+ 			result  =  & TestCaseResult {
674+ 				Error : err .Error (),
675+ 			}
676+ 		}
677+ 		err  =  loader .CreateHistoryTestCase (normalResult , testSuite )
678+ 		if  err  !=  nil  {
679+ 			result  =  & TestCaseResult {
680+ 				Error : err .Error (),
681+ 			}
682+ 		}
683+ 	}
684+ 	return 
685+ }
686+ 
687+ func  (s  * server ) getRunResult (ctx  context.Context , task  * TestTask ) (result  * TestCaseResult ) {
733688	var  reply  * TestResult 
734689	var  lastItem  * TestCaseResult 
735-      if  reply , err  :=  s .Run (ctx , task ); err  ==  nil  &&  len (reply .TestCaseResult ) >  0  {   
736-         lastIndex  :=  len (reply .TestCaseResult ) -  1    
737-         lastItem  :=  reply .TestCaseResult [lastIndex ]   
738-    
739-         if  len (lastItem .Body ) >  GrpcMaxRecvMsgSize  {   
740-            e  :=  "the HTTP response body exceeded the maximum message size limit received by the gRPC client"    
741-            return  & TestCaseResult {   
742-               Output :     reply .Message ,   
743-               Error :      e ,   
744-               Body :       "" ,   
745-               Header :     lastItem .Header ,   
746-               StatusCode : http .StatusOK ,   
747-           }   
748-        }   
749-    
750-         result  =  & TestCaseResult {   
751-            Output :     reply .Message ,   
752-            Error :      reply .Error ,   
753-            Body :       lastItem .Body ,   
754-            Header :     lastItem .Header ,   
755-            StatusCode : lastItem .StatusCode ,   
756-        }   
757-      } else  if  err  !=  nil  {   
758- 		result  =  & TestCaseResult {   
759-            Error : err .Error (),   
760-        }   
761-      } else  {   
762- 		result  =  & TestCaseResult {   
763-            Output : reply .Message ,   
764-            Error :  reply .Error ,   
765-        }   
766-      }
690+ 	 if  reply , err  :=  s .Run (ctx , task ); err  ==  nil  &&  len (reply .TestCaseResult ) >  0  {
691+ 		 lastIndex  :=  len (reply .TestCaseResult ) -  1 
692+ 		 lastItem  :=  reply .TestCaseResult [lastIndex ]
693+ 
694+ 		 if  len (lastItem .Body ) >  GrpcMaxRecvMsgSize  {
695+ 			 e  :=  "the HTTP response body exceeded the maximum message size limit received by the gRPC client" 
696+ 			 return  & TestCaseResult {
697+ 				 Output :     reply .Message ,
698+ 				 Error :      e ,
699+ 				 Body :       "" ,
700+ 				 Header :     lastItem .Header ,
701+ 				 StatusCode : http .StatusOK ,
702+ 			} 
703+ 		} 
704+ 
705+ 		 result  =  & TestCaseResult {
706+ 			 Output :     reply .Message ,
707+ 			 Error :      reply .Error ,
708+ 			 Body :       lastItem .Body ,
709+ 			 Header :     lastItem .Header ,
710+ 			 StatusCode : lastItem .StatusCode ,
711+ 		} 
712+ 	 } else  if  err  !=  nil  {
713+ 		result  =  & TestCaseResult {
714+ 			 Error : err .Error (),
715+ 		} 
716+ 	 } else  {
717+ 		result  =  & TestCaseResult {
718+ 			 Output : reply .Message ,
719+ 			 Error :  reply .Error ,
720+ 		} 
721+ 	 }
767722	if  reply  !=  nil  {
768723		result .Output  =  reply .Message 
769724		result .Error  =  reply .Error 
@@ -773,7 +728,7 @@ func (s *server) getRunResult(ctx context.Context, task *TestTask) (result *Test
773728		result .Header  =  lastItem .Header 
774729		result .StatusCode  =  lastItem .StatusCode 
775730	}
776-      return    
731+ 	 return 
777732}
778733
779734func  mapInterToPair (data  map [string ]interface {}) (pairs  []* Pair ) {
0 commit comments