mirror of https://github.com/statping/statping
				
				
				
			
		
			
				
	
	
		
			99 lines
		
	
	
		
			2.6 KiB
		
	
	
	
		
			Go
		
	
	
			
		
		
	
	
			99 lines
		
	
	
		
			2.6 KiB
		
	
	
	
		
			Go
		
	
	
package notifiers
 | 
						|
 | 
						|
import (
 | 
						|
	"github.com/statping-ng/statping-ng/database"
 | 
						|
	"github.com/statping-ng/statping-ng/types/core"
 | 
						|
	"github.com/statping-ng/statping-ng/types/failures"
 | 
						|
	"github.com/statping-ng/statping-ng/types/notifications"
 | 
						|
	"github.com/statping-ng/statping-ng/types/null"
 | 
						|
	"github.com/statping-ng/statping-ng/types/services"
 | 
						|
	"github.com/statping-ng/statping-ng/utils"
 | 
						|
	"github.com/stretchr/testify/assert"
 | 
						|
	"github.com/stretchr/testify/require"
 | 
						|
	"testing"
 | 
						|
	"time"
 | 
						|
)
 | 
						|
 | 
						|
var (
 | 
						|
	EMAIL_HOST     string
 | 
						|
	EMAIL_USER     string
 | 
						|
	EMAIL_PASS     string
 | 
						|
	EMAIL_OUTGOING string
 | 
						|
	EMAIL_SEND_TO  string
 | 
						|
	EMAIL_PORT     int64
 | 
						|
)
 | 
						|
 | 
						|
func TestEmailNotifier(t *testing.T) {
 | 
						|
	t.Parallel()
 | 
						|
	err := utils.InitLogs()
 | 
						|
	require.Nil(t, err)
 | 
						|
 | 
						|
	EMAIL_HOST = utils.Params.GetString("EMAIL_HOST")
 | 
						|
	EMAIL_USER = utils.Params.GetString("EMAIL_USER")
 | 
						|
	EMAIL_PASS = utils.Params.GetString("EMAIL_PASS")
 | 
						|
	EMAIL_OUTGOING = utils.Params.GetString("EMAIL_OUTGOING")
 | 
						|
	EMAIL_SEND_TO = utils.Params.GetString("EMAIL_SEND_TO")
 | 
						|
	EMAIL_PORT = utils.ToInt(utils.Params.GetString("EMAIL_PORT"))
 | 
						|
 | 
						|
	db, err := database.OpenTester()
 | 
						|
	require.Nil(t, err)
 | 
						|
	db.AutoMigrate(¬ifications.Notification{})
 | 
						|
	notifications.SetDB(db)
 | 
						|
	core.Example()
 | 
						|
 | 
						|
	if EMAIL_HOST == "" || EMAIL_USER == "" || EMAIL_PASS == "" {
 | 
						|
		t.Log("email notifier testing skipped, missing EMAIL_ environment variables")
 | 
						|
		t.SkipNow()
 | 
						|
	}
 | 
						|
 | 
						|
	t.Run("New email", func(t *testing.T) {
 | 
						|
		email.Host = null.NewNullString(EMAIL_HOST)
 | 
						|
		email.Username = null.NewNullString(EMAIL_USER)
 | 
						|
		email.Password = null.NewNullString(EMAIL_PASS)
 | 
						|
		email.Var1 = null.NewNullString(EMAIL_OUTGOING)
 | 
						|
		email.Var2 = null.NewNullString(EMAIL_SEND_TO)
 | 
						|
		email.Port = null.NewNullInt64(EMAIL_PORT)
 | 
						|
		email.Delay = time.Duration(100 * time.Millisecond)
 | 
						|
		email.Enabled = null.NewNullBool(true)
 | 
						|
 | 
						|
		Add(email)
 | 
						|
		assert.Equal(t, "Hunter Long", email.Author)
 | 
						|
		assert.Equal(t, EMAIL_HOST, email.Host.String)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email Within Limits", func(t *testing.T) {
 | 
						|
		ok := email.CanSend()
 | 
						|
		assert.True(t, ok)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email OnSave", func(t *testing.T) {
 | 
						|
		_, err := email.OnSave()
 | 
						|
		assert.Nil(t, err)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email OnFailure", func(t *testing.T) {
 | 
						|
		_, err := email.OnFailure(services.Example(false), failures.Example())
 | 
						|
		assert.Nil(t, err)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email OnSuccess", func(t *testing.T) {
 | 
						|
		_, err := email.OnSuccess(services.Example(false))
 | 
						|
		assert.Nil(t, err)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email Check Back Online", func(t *testing.T) {
 | 
						|
		assert.True(t, services.Example(true).Online)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email OnSuccess Again", func(t *testing.T) {
 | 
						|
		_, err := email.OnSuccess(services.Example(true))
 | 
						|
		assert.Nil(t, err)
 | 
						|
	})
 | 
						|
 | 
						|
	t.Run("email Test", func(t *testing.T) {
 | 
						|
		_, err := email.OnTest()
 | 
						|
		assert.Nil(t, err)
 | 
						|
	})
 | 
						|
 | 
						|
}
 |