From 1429445bde16dbb06825b6b460c877f5307e7872 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Tue, 3 Oct 2023 11:05:36 -0400 Subject: [PATCH] Update failing versions it test --- engine/z_versions_it_test.go | 214 +++++++++++++++++++---------------- 1 file changed, 115 insertions(+), 99 deletions(-) diff --git a/engine/z_versions_it_test.go b/engine/z_versions_it_test.go index 981f1e129..303def5f8 100644 --- a/engine/z_versions_it_test.go +++ b/engine/z_versions_it_test.go @@ -27,6 +27,7 @@ import ( "os/exec" "path" "reflect" + "strings" "testing" "github.com/cgrates/cgrates/config" @@ -231,7 +232,7 @@ func testVersion(t *testing.T) { func testVersionsWithEngine(t *testing.T) { cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -267,15 +268,16 @@ func testUpdateVersionsAccounts(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -287,15 +289,16 @@ func testUpdateVersionsActionPlans(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -307,15 +310,16 @@ func testUpdateVersionsActionTriggers(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -327,15 +331,16 @@ func testUpdateVersionsActions(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -347,15 +352,16 @@ func testUpdateVersionsChargers(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -367,7 +373,7 @@ func testUpdateVersionsDestinations(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -386,15 +392,16 @@ func testUpdateVersionsAttributes(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -406,15 +413,16 @@ func testUpdateVersionsDispatchers(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -426,7 +434,7 @@ func testUpdateVersionsLoadIDs(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -446,15 +454,16 @@ func testUpdateVersionsRQF(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -466,7 +475,7 @@ func testUpdateVersionsRatingPlan(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -486,7 +495,7 @@ func testUpdateVersionsRatingProfile(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -506,7 +515,7 @@ func testUpdateVersionsResource(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -526,7 +535,7 @@ func testUpdateVersionsReverseDestinations(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -546,15 +555,16 @@ func testUpdateVersionsRoutes(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -566,15 +576,16 @@ func testUpdateVersionsSharedGroups(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -586,15 +597,16 @@ func testUpdateVersionsStats(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -606,7 +618,7 @@ func testUpdateVersionsSubscribers(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -626,15 +638,16 @@ func testUpdateVersionsThresholds(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -646,7 +659,7 @@ func testUpdateVersionsTiming(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output + cmd.Stderr = output if err := cmd.Run(); err != nil { t.Log(cmd.Args) t.Log(output.String()) @@ -667,15 +680,16 @@ func testUpdateVersionsCostDetails(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -687,15 +701,16 @@ func testUpdateVersionsSessionSCosts(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } } @@ -707,14 +722,15 @@ func testUpdateVersionsCDRs(t *testing.T) { } cmd := exec.Command("cgr-engine", fmt.Sprintf(`-config_path=/usr/share/cgrates/conf/samples/%s`, versionsConfigDIR), `-scheduled_shutdown=4ms`) output := bytes.NewBuffer(nil) - cmd.Stdout = output - if err := cmd.Run(); err != nil { + cmd.Stderr = output + if err := cmd.Run(); err == nil || + err.Error() != "exit status 1" { t.Log(cmd.Args) t.Log(output.String()) - t.Fatal(err) + t.Fatalf("expected: %s, \nreceived: %s", "exit status 1", err) } - errExpect := "Migration needed: please backup cgr data and run : \n" - if output.String() != errExpect { - t.Fatalf("Expected %q \n but received: \n %q", errExpect, output.String()) + errExpect := "Migration needed: please backup cgr data and run : " + if !strings.Contains(output.String(), errExpect) { + t.Errorf("expected %s \nto contain: %s", output.String(), errExpect) } }