Function TestMsgPipeline_RcptModifier_Errors

internal/msgpipeline/modifier_test.go:651–709

(t *testing.T)

}

func TestMsgPipeline_RcptModifier_Errors(t *testing.T) {
	target := testutils.Target{}
	mod := testutils.Modifier{
		InstName:  "test_modifier",
		InitErr:   errors.New("1"),
		RcptToErr: errors.New("3"),
	}
	// Added to make sure it is freed properly too.
	globalMod := testutils.Modifier{}
	sourceMod := testutils.Modifier{}

	d := MsgPipeline{
		msgpipelineCfg: msgpipelineCfg{
			perSource:       map[string]sourceBlock{},
			globalModifiers: modify.Group{Modifiers: []module.Modifier{&globalMod}},
			defaultSource: sourceBlock{
				modifiers: modify.Group{Modifiers: []module.Modifier{&sourceMod}},
				defaultRcpt: &rcptBlock{
					modifiers: modify.Group{Modifiers: []module.Modifier{&mod}},
					targets:   []module.DeliveryTarget{&target},
				},
			},
		},
		Log: testutils.Logger(t, "msgpipeline"),
	}

	t.Run("init err", func(t *testing.T) {
		_, err := testutils.DoTestDeliveryErr(t, &d, "sender@example.com", []string{"rcpt1@example.com", "rcpt2@example.com"})
		if err == nil {
			t.Fatal("expected error")
		}
	})

	mod.InitErr = nil

	// MailFromErr test is inapplicable since RewriteSender is not called for per-rcpt
	// modifiers.

	t.Run("rcpt to err", func(t *testing.T) {
		_, err := testutils.DoTestDeliveryErr(t, &d, "sender@example.com", []string{"rcpt1@example.com", "rcpt2@example.com"})
		if err == nil {
			t.Fatal("expected error")
		}
	})

	mod.RcptToErr = nil

	// BodyErr test is inapplicable since RewriteBody is not called for per-rcpt
	// modifiers.

	t.Run("no err", func(t *testing.T) {
		testutils.DoTestDelivery(t, &d, "sender@example.com", []string{"rcpt1@example.com", "rcpt2@example.com"})
	})

	if mod.UnclosedStates != 0 || globalMod.UnclosedStates != 0 || sourceMod.UnclosedStates != 0 {
		t.Fatalf("modifier state objects leak or double-closed, counters: %d, %d, %d",
			mod.UnclosedStates, globalMod.UnclosedStates, sourceMod.UnclosedStates)
	}