|
|
@@ -6364,6 +6364,151 @@ func TestEventRuleIDPLogin(t *testing.T) {
|
|
|
require.NoError(t, err)
|
|
|
}
|
|
|
|
|
|
+func TestEventRuleEmailField(t *testing.T) {
|
|
|
+ smtpCfg := smtp.Config{
|
|
|
+ Host: "127.0.0.1",
|
|
|
+ Port: 2525,
|
|
|
+ From: "notify@example.com",
|
|
|
+ TemplatesPath: "templates",
|
|
|
+ }
|
|
|
+ err := smtpCfg.Initialize(configDir, true)
|
|
|
+ require.NoError(t, err)
|
|
|
+ lastReceivedEmail.reset()
|
|
|
+
|
|
|
+ a1 := dataprovider.BaseEventAction{
|
|
|
+ Name: "action1",
|
|
|
+ Type: dataprovider.ActionTypeEmail,
|
|
|
+ Options: dataprovider.BaseEventActionOptions{
|
|
|
+ EmailConfig: dataprovider.EventActionEmailConfig{
|
|
|
+ Recipients: []string{"{{Email}}"},
|
|
|
+ Subject: `"{{Event}}" from "{{Name}}"`,
|
|
|
+ Body: "Sample email body",
|
|
|
+ },
|
|
|
+ },
|
|
|
+ }
|
|
|
+ action1, _, err := httpdtest.AddEventAction(a1, http.StatusCreated)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ a2 := dataprovider.BaseEventAction{
|
|
|
+ Name: "action2",
|
|
|
+ Type: dataprovider.ActionTypeEmail,
|
|
|
+ Options: dataprovider.BaseEventActionOptions{
|
|
|
+ EmailConfig: dataprovider.EventActionEmailConfig{
|
|
|
+ Recipients: []string{"failure@example.com"},
|
|
|
+ Subject: `"Failure`,
|
|
|
+ Body: "{{ErrorString}}",
|
|
|
+ },
|
|
|
+ },
|
|
|
+ }
|
|
|
+ action2, _, err := httpdtest.AddEventAction(a2, http.StatusCreated)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ r1 := dataprovider.EventRule{
|
|
|
+ Name: "r1",
|
|
|
+ Status: 1,
|
|
|
+ Trigger: dataprovider.EventTriggerFsEvent,
|
|
|
+ Conditions: dataprovider.EventConditions{
|
|
|
+ FsEvents: []string{"mkdir"},
|
|
|
+ },
|
|
|
+ Actions: []dataprovider.EventAction{
|
|
|
+ {
|
|
|
+ BaseEventAction: dataprovider.BaseEventAction{
|
|
|
+ Name: action1.Name,
|
|
|
+ },
|
|
|
+ },
|
|
|
+ },
|
|
|
+ }
|
|
|
+ r2 := dataprovider.EventRule{
|
|
|
+ Name: "test rule2",
|
|
|
+ Status: 1,
|
|
|
+ Trigger: dataprovider.EventTriggerProviderEvent,
|
|
|
+ Conditions: dataprovider.EventConditions{
|
|
|
+ ProviderEvents: []string{"add"},
|
|
|
+ },
|
|
|
+ Actions: []dataprovider.EventAction{
|
|
|
+ {
|
|
|
+ BaseEventAction: dataprovider.BaseEventAction{
|
|
|
+ Name: action1.Name,
|
|
|
+ },
|
|
|
+ Order: 1,
|
|
|
+ },
|
|
|
+ {
|
|
|
+ BaseEventAction: dataprovider.BaseEventAction{
|
|
|
+ Name: action2.Name,
|
|
|
+ },
|
|
|
+ Options: dataprovider.EventActionOptions{
|
|
|
+ IsFailureAction: true,
|
|
|
+ },
|
|
|
+ },
|
|
|
+ },
|
|
|
+ }
|
|
|
+ rule1, _, err := httpdtest.AddEventRule(r1, http.StatusCreated)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ rule2, _, err := httpdtest.AddEventRule(r2, http.StatusCreated)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ u := getTestUser()
|
|
|
+ u.Email = "user@example.com"
|
|
|
+ user, _, err := httpdtest.AddUser(u, http.StatusCreated)
|
|
|
+ assert.NoError(t, err)
|
|
|
+
|
|
|
+ assert.Eventually(t, func() bool {
|
|
|
+ return lastReceivedEmail.get().From != ""
|
|
|
+ }, 3000*time.Millisecond, 100*time.Millisecond)
|
|
|
+ email := lastReceivedEmail.get()
|
|
|
+ assert.Len(t, email.To, 1)
|
|
|
+ assert.True(t, util.Contains(email.To, user.Email))
|
|
|
+ assert.Contains(t, email.Data, `Subject: "add" from "admin"`)
|
|
|
+
|
|
|
+ // if we add a user without email the notification will fail
|
|
|
+ lastReceivedEmail.reset()
|
|
|
+ u1 := getTestUser()
|
|
|
+ u1.Username += "_1"
|
|
|
+ user1, _, err := httpdtest.AddUser(u1, http.StatusCreated)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ assert.Eventually(t, func() bool {
|
|
|
+ return lastReceivedEmail.get().From != ""
|
|
|
+ }, 3000*time.Millisecond, 100*time.Millisecond)
|
|
|
+ email = lastReceivedEmail.get()
|
|
|
+ assert.Len(t, email.To, 1)
|
|
|
+ assert.True(t, util.Contains(email.To, "failure@example.com"))
|
|
|
+ assert.Contains(t, email.Data, `no recipient addresses set`)
|
|
|
+
|
|
|
+ conn, client, err := getSftpClient(user)
|
|
|
+ if assert.NoError(t, err) {
|
|
|
+ defer conn.Close()
|
|
|
+ defer client.Close()
|
|
|
+
|
|
|
+ lastReceivedEmail.reset()
|
|
|
+ err = client.Mkdir(testFileName)
|
|
|
+ assert.NoError(t, err)
|
|
|
+
|
|
|
+ assert.Eventually(t, func() bool {
|
|
|
+ return lastReceivedEmail.get().From != ""
|
|
|
+ }, 3000*time.Millisecond, 100*time.Millisecond)
|
|
|
+ email := lastReceivedEmail.get()
|
|
|
+ assert.Len(t, email.To, 1)
|
|
|
+ assert.True(t, util.Contains(email.To, user.Email))
|
|
|
+ assert.Contains(t, email.Data, fmt.Sprintf(`Subject: "mkdir" from "%s"`, user.Username))
|
|
|
+ }
|
|
|
+
|
|
|
+ _, err = httpdtest.RemoveEventRule(rule1, http.StatusOK)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ _, err = httpdtest.RemoveEventRule(rule2, http.StatusOK)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ _, err = httpdtest.RemoveEventAction(action1, http.StatusOK)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ _, err = httpdtest.RemoveEventAction(action2, http.StatusOK)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ _, err = httpdtest.RemoveUser(user, http.StatusOK)
|
|
|
+ assert.NoError(t, err)
|
|
|
+ err = os.RemoveAll(user.GetHomeDir())
|
|
|
+ assert.NoError(t, err)
|
|
|
+ _, err = httpdtest.RemoveUser(user1, http.StatusOK)
|
|
|
+ assert.NoError(t, err)
|
|
|
+
|
|
|
+ smtpCfg = smtp.Config{}
|
|
|
+ err = smtpCfg.Initialize(configDir, true)
|
|
|
+ require.NoError(t, err)
|
|
|
+}
|
|
|
+
|
|
|
func TestEventRuleCertificate(t *testing.T) {
|
|
|
smtpCfg := smtp.Config{
|
|
|
Host: "127.0.0.1",
|
Nicola Murino