silence test logs

Author: pashagolub

internal/api/api_test.go

@@ -30,7 +30,7 @@ func (r *apihandler) StopChain(context.Context, int) error {
 	return nil
 }
 
-var restsrv = Init(config.RestAPIOpts{Port: 8080}, log.Init(config.LoggingOpts{LogLevel: "error"}))
+var restsrv = Init(config.RestAPIOpts{Port: 8080}, log.Init(config.LoggingOpts{LogLevel: "panic"}))
 
 const turl = "http://localhost:8080/"
 

internal/pgengine/pgengine_test.go

@@ -87,7 +87,7 @@ func TestFailedConnect(t *testing.T) {
 	c := config.NewCmdOptions("--connstr='host=fake'", "-c", "pgengine_test")
 	ctx, cancel := context.WithTimeout(context.Background(), pgengine.WaitTime*2)
 	defer cancel()
-	_, err := pgengine.New(ctx, *c, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	_, err := pgengine.New(ctx, *c, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 	assert.ErrorIs(t, err, ctx.Err())
 }
 
@@ -175,7 +175,7 @@ func TestSamplesScripts(t *testing.T) {
 
 	files, err := os.ReadDir("../../samples")
 	assert.NoError(t, err, "Cannot read samples directory")
-	l := log.Init(config.LoggingOpts{LogLevel: "error"})
+	l := log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"})
 	pge := container.Engine
 	for _, f := range files {
 		ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)

internal/scheduler/chain_test.go

@@ -29,7 +29,7 @@ func TestAsyncChains(t *testing.T) {
 	mock, err := pgxmock.NewPool()
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "scheduler_unit_test")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 	n1 := &pgconn.Notification{Payload: `{"ConfigID": 1, "Command": "START"}`}
 	n2 := &pgconn.Notification{Payload: `{"ConfigID": 2, "Command": "START"}`}
 	ns := &pgconn.Notification{Payload: `{"ConfigID": 24, "Command": "STOP"}`}
@@ -60,7 +60,7 @@ func TestChainWorker(t *testing.T) {
 	mock, err := pgxmock.NewPool()
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "-c", "scheduler_unit_test", "--password=somestrong")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic"}))
 	chains := make(chan Chain, 16)
 
 	t.Run("Check chainWorker if context cancelled", func(*testing.T) {
@@ -98,7 +98,7 @@ func TestExecuteChain(t *testing.T) {
 	mock, err := pgxmock.NewPool()
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "-c", "scheduler_unit_test", "--password=somestrong")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
@@ -109,7 +109,7 @@ func TestExecuteChainElement(t *testing.T) {
 	mock, err := pgxmock.NewPool()
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "-c", "scheduler_unit_test", "--password=somestrong")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
@@ -122,7 +122,7 @@ func TestExecuteOnErrorHandler(t *testing.T) {
 	mock, err := pgxmock.NewPool()
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "-c", "scheduler_unit_test", "--password=somestrong")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 
 	t.Run("check error handler if everything is fine", func(t *testing.T) {
 		mock.ExpectExec("FOO").WillReturnResult(pgxmock.NewResult("FOO", 1))

internal/scheduler/interval_chain_test.go

@@ -15,7 +15,7 @@ func TestIntervalChain(t *testing.T) {
 	mock, err := pgxmock.NewPool()
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "scheduler_unit_test")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 
 	ichain := IntervalChain{Interval: 42}
 	assert.True(t, ichain.IsListed([]IntervalChain{ichain}))

internal/scheduler/scheduler_test.go

@@ -34,7 +34,7 @@ func TestRun(t *testing.T) {
 	assert.NoError(t, err, "Creating program tasks failed")
 	err = pge.ExecuteCustomScripts(context.Background(), "../../samples/ManyTasks.sql")
 	assert.NoError(t, err, "Creating many tasks failed")
-	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	sch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 	assert.NoError(t, sch.StartChain(context.Background(), 1))
 	assert.ErrorContains(t, sch.StopChain(context.Background(), -1), "No running chain found")
 	go func() {

internal/scheduler/shell_test.go

@@ -35,7 +35,7 @@ func TestShellCommand(t *testing.T) {
 	mock, err := pgxmock.NewPool() //
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "scheduler_unit_test")
-	scheduler := scheduler.New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	scheduler := scheduler.New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 	ctx := context.Background()
 
 	_, _, err = scheduler.ExecuteProgramCommand(ctx, "", []string{""})

internal/scheduler/tasks_test.go

@@ -15,7 +15,7 @@ func TestExecuteTask(t *testing.T) {
 	mock, err := pgxmock.NewPool() //
 	assert.NoError(t, err)
 	pge := pgengine.NewDB(mock, "scheduler_unit_test")
-	mocksch := New(pge, log.Init(config.LoggingOpts{LogLevel: "error"}))
+	mocksch := New(pge, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))
 
 	et := func(task string, params []string) (err error) {
 		_, err = mocksch.executeBuiltinTask(context.TODO(), task, params)

internal/testutils/testcontainers.go

@@ -56,7 +56,7 @@ func SetupPostgresContainerWithOptions(t *testing.T, customizer func(*config.Cmd
 	}
 
 	var pge *pgengine.PgEngine
-	timeout := time.After(time.Minute)
+	timeout := time.After(3 * time.Minute)
 	done := make(chan bool)
 	go func() {
 		pge, err = pgengine.New(ctx, *cmdOpts, log.Init(config.LoggingOpts{LogLevel: "panic", LogDBLevel: "none"}))