@@ -562,7 +562,6 @@ func (s *server) GetHistoryTestCase(ctx context.Context, in *HistoryTestCase) (r
562
562
return
563
563
}
564
564
565
- << << << < HEAD
566
565
var ExecutionCountNum = promauto .NewCounter (prometheus.CounterOpts {
567
566
Name : "atest_execution_count" ,
568
567
Help : "The total number of request execution" ,
@@ -607,10 +606,10 @@ func (s *server) RunTestCase(ctx context.Context, in *TestCaseIdentity) (result
607
606
Parameters : in .Parameters ,
608
607
}
609
608
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
+ }
614
613
normalResult := ToNormalTestCaseResult (result )
615
614
var testSuite * testing.TestSuite
616
615
if testSuite , err = s .getSuiteFromTestTask (task ); err != nil {
@@ -623,7 +622,11 @@ func (s *server) RunTestCase(ctx context.Context, in *TestCaseIdentity) (result
623
622
result = & TestCaseResult {
624
623
Error : err .Error (),
625
624
}
626
- == == == =
625
+ }
626
+ }
627
+ return
628
+ }
629
+
627
630
func (s * server ) GetTestCaseAllHistory (ctx context.Context , in * TestCase ) (result * HistoryTestCases , err error ) {
628
631
var items []testing.HistoryTestCase
629
632
loader := s .getLoader (ctx )
@@ -632,138 +635,90 @@ func (s *server) GetTestCaseAllHistory(ctx context.Context, in *TestCase) (resul
632
635
result = & HistoryTestCases {}
633
636
for _ , item := range items {
634
637
result .Data = append (result .Data , ConvertToGRPCHistoryTestCase (item ))
635
- >> >> >> > 6 c2cd54 (feat : add history case revert api and ui )
636
638
}
637
639
}
638
640
return
639
641
}
640
642
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 ) {
733
688
var reply * TestResult
734
689
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
+ }
767
722
if reply != nil {
768
723
result .Output = reply .Message
769
724
result .Error = reply .Error
@@ -773,7 +728,7 @@ func (s *server) getRunResult(ctx context.Context, task *TestTask) (result *Test
773
728
result .Header = lastItem .Header
774
729
result .StatusCode = lastItem .StatusCode
775
730
}
776
- return
731
+ return
777
732
}
778
733
779
734
func mapInterToPair (data map [string ]interface {}) (pairs []* Pair ) {
0 commit comments