GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-05-14 02:49:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: run boomer test

Browse Source
This commit is contained in:
debugtalk
2021-11-14 21:40:05 +08:00
parent 16347d6796
commit 4827ebf284
3 changed files with 29 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
boomer.go
View File

@@ -43,11 +43,12 @@ func (b *Boomer) convertBoomerTask(testcase *TestCase) *boomer.Task {
Weight: testcase.Config.Weight,
Fn: func() {
config := &testcase.Config
extractedVariables := make(map[string]interface{})
for _, step := range testcase.TestSteps {
var err error
start := time.Now()
stepData, err := runner.runStep(step, config)
stepData, err := runner.runStep(step, config, extractedVariables)
elapsed := time.Since(start).Nanoseconds() / int64(time.Millisecond)
if err == nil {
boomer.RecordSuccess(step.Type(), step.Name(), elapsed, stepData.ResponseLength)
} else {

43
runner.go
View File

@@ -91,36 +91,33 @@ func (r *Runner) runCase(testcase *TestCase) error {
extractedVariables := make(map[string]interface{})
for _, step := range testcase.TestSteps {
// override variables
// step variables > extracted variables from previous steps
stepVariables := mergeVariables(step.ToStruct().Variables, extractedVariables)
// step variables > testcase config variables
stepVariables = mergeVariables(stepVariables, config.Variables)
// parse step variables
parsedVariables, err := parseVariables(stepVariables)
if err != nil {
log.Error().Interface("variables", config.Variables).Err(err).Msg("parse step variables failed")
return err
}
step.ToStruct().Variables = parsedVariables
stepData, err := r.runStep(step, config)
_, err := r.runStep(step, config, extractedVariables)
if err != nil {
return err
}
// update extracted variables
for k, v := range stepData.ExportVars {
extractedVariables[k] = v
}
}
log.Info().Str("testcase", config.Name).Msg("run testcase end")
return nil
}
func (r *Runner) runStep(step IStep, config *TConfig) (stepData *StepData, err error) {
func (r *Runner) runStep(step IStep, config *TConfig, extractedVariables map[string]interface{}) (stepData *StepData, err error) {
log.Info().Str("step", step.Name()).Msg("run step start")
// override variables
// step variables > extracted variables from previous steps
stepVariables := mergeVariables(step.ToStruct().Variables, extractedVariables)
// step variables > testcase config variables
stepVariables = mergeVariables(stepVariables, config.Variables)
// parse step variables
parsedVariables, err := parseVariables(stepVariables)
if err != nil {
log.Error().Interface("variables", config.Variables).Err(err).Msg("parse step variables failed")
return
}
step.ToStruct().Variables = parsedVariables
if tc, ok := step.(*testcaseWithOptionalArgs); ok {
// run referenced testcase
log.Info().Str("testcase", tc.step.Name).Msg("run referenced testcase")
@@ -139,6 +136,12 @@ func (r *Runner) runStep(step IStep, config *TConfig) (stepData *StepData, err e
return
}
}
// update extracted variables
for k, v := range stepData.ExportVars {
extractedVariables[k] = v
}
log.Info().
Str("step", step.Name()).
Bool("success", stepData.Success).

5
step_test.go
View File

@@ -77,11 +77,12 @@ func TestRunRequestRun(t *testing.T) {
config := &TConfig{
BaseURL: "https://postman-echo.com",
}
extractedVariables := make(map[string]interface{})
runner := NewRunner(t).SetDebug(true)
if _, err := runner.runStep(stepGET, config); err != nil {
if _, err := runner.runStep(stepGET, config, extractedVariables); err != nil {
t.Fatalf("tStep.Run() error: %s", err)
}
if _, err := runner.runStep(stepPOSTData, config); err != nil {
if _, err := runner.runStep(stepPOSTData, config, extractedVariables); err != nil {
t.Fatalf("tStepPOSTData.Run() error: %s", err)
}
}