Function TestMsgPipeline_SourceModifier_Errors

internal/msgpipeline/modifier_test.go:580–649

(t *testing.T)

}

func TestMsgPipeline_SourceModifier_Errors(t *testing.T) {
	target := testutils.Target{}
	mod := testutils.Modifier{
		InstName:    "test_modifier",
		InitErr:     errors.New("1"),
		MailFromErr: errors.New("2"),
		RcptToErr:   errors.New("3"),
		BodyErr:     errors.New("4"),
	}
	// Added to make sure it is freed properly too.
	globalMod := 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{&mod}},
				defaultRcpt: &rcptBlock{
					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

	t.Run("mail from 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.MailFromErr = nil

	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

	t.Run("body 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")
		}
	})