plugin test tool to include seed data in database - auto deployment to homebrew

.travis/deploy.sh

@@ -1,6 +1,6 @@
 #!/usr/bin/env bash
 
-# update homebrew to newest version by building on travis
+# update homebrew and cypress testing to newest version by building on travis
 body='{ "request": { "branch": "master", "config": { "env": { "VERSION": "'$VERSION'" } } } }'
 
 curl -s -X POST \
@@ -11,10 +11,18 @@ curl -s -X POST \
  -d "$body" \
  https://api.travis-ci.com/repo/hunterlong%2Fstatup-testing/requests
 
-#git clone https://$GH_USER:$GH_TOKEN@github.com/hunterlong/homebrew-statup.git
+# notify Docker hub to built this branch
-#cd homebrew-statup
+if [ "$TRAVIS_BRANCH" == "master" ]
-#
+then
-#./build.sh
+     curl -s -X POST \
-#cd ../
+     -H "Content-Type: application/json" \
+     -H "Accept: application/json" \
+     -H "Travis-API-Version: 3" \
+     -H "Authorization: token $TRAVIS_API" \
+     -d "$body" \
+     https://api.travis-ci.com/repo/hunterlong%2Fhomebrew-statup/requests
 
-curl -H "Content-Type: application/json" --data '{"source_type": "Branch", "source_name": "'"$TRAVIS_BRANCH"'"}' -X POST $DOCKER > /dev/null
+    curl -H "Content-Type: application/json" --data '{"docker_tag": "latest"}' -X POST $DOCKER
+else
+    curl -H "Content-Type: application/json" --data '{"source_type": "Branch", "source_name": "'"$TRAVIS_BRANCH"'"}' -X POST $DOCKER > /dev/null
+fi

cli.go

@@ -4,8 +4,10 @@ import (
 	"fmt"
 	"github.com/hunterlong/statup/core"
 	"github.com/hunterlong/statup/plugin"
+	"github.com/hunterlong/statup/types"
 	"github.com/hunterlong/statup/utils"
 	"github.com/joho/godotenv"
+	"math/rand"
 	"strings"
 	"time"
 	"upper.io/db.v3/sqlite"
@@ -111,9 +113,9 @@ func HelpEcho() {
 }
 
 func TestPlugin(plug plugin.PluginActions) {
-	RenderBoxes()
 	defer utils.DeleteFile("./.plugin_test.db")
-	core.CoreApp.AllPlugins = []plugin.PluginActions{plug}
+	RenderBoxes()
+
 	info := plug.GetInfo()
 	fmt.Printf("\n" + BRAKER + "\n")
 	fmt.Printf("    Plugin Name:          %v\n", info.Name)
@@ -123,25 +125,91 @@ func TestPlugin(plug plugin.PluginActions) {
 		fmt.Printf("      - Route %v      - (%v) /%v \n", k+1, r.Method, r.URL)
 	}
 
+	// Function to create a new Core with example services, hits, failures, users, and default communications
+	FakeSeed(plug)
+
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnLoad(sqlbuilder.Database)'")
+	core.OnLoad(core.DbSession)
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnSuccess(Service)'")
+	core.OnSuccess(core.SelectService(1))
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnFailure(Service, FailureData)'")
+	fakeFailD := core.FailureData{
+		Issue: "No issue, just testing this plugin. This would include HTTP failure information though",
+	}
+	core.OnFailure(core.SelectService(1), fakeFailD)
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnSettingsSaved(Core)'")
+	fmt.Println(BRAKER)
+	core.OnSettingsSaved(core.CoreApp)
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnNewService(Service)'")
+	core.OnNewService(core.SelectService(2))
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnNewUser(User)'")
+	user, _ := core.SelectUser(1)
+	core.OnNewUser(user)
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnUpdateService(Service)'")
+	srv := core.SelectService(2)
+	srv.Type = "http"
+	srv.Domain = "https://yahoo.com"
+	core.OnUpdateService(srv)
+	fmt.Println("\n" + BRAKER)
+	fmt.Println(POINT + "Sending 'OnDeletedService(Service)'")
+	core.OnDeletedService(core.SelectService(1))
+	fmt.Println("\n" + BRAKER)
+}
+
+func FakeSeed(plug plugin.PluginActions) {
+	var err error
+	core.CoreApp = core.NewCore()
+
+	core.CoreApp.AllPlugins = []plugin.PluginActions{plug}
+
 	fmt.Printf("\n" + BRAKER)
 
+	fmt.Println("\nCreating a SQLite database for testing, will be deleted automatically...")
+	sqlFake := sqlite.ConnectionURL{
+		Database: "./.plugin_test.db",
+	}
+	core.DbSession, err = sqlite.Open(sqlFake)
+	if err != nil {
+		utils.Log(3, err)
+	}
+	up, _ := core.SqlBox.String("sqlite_up.sql")
+	requests := strings.Split(up, ";")
+	for _, request := range requests {
+		_, err := core.DbSession.Exec(request)
+		if err != nil {
+			utils.Log(2, err)
+		}
+	}
+
+	fmt.Println("Finished creating Test SQLite database")
+	fmt.Println("Inserting example services into test database...")
+
+	core.CoreApp.Name = "Plugin Test"
+	core.CoreApp.Description = "This is a fake Core for testing your plugin"
+	core.CoreApp.Domain = "http://localhost:8080"
+	core.CoreApp.ApiSecret = "0x0x0x0x0"
+	core.CoreApp.ApiKey = "abcdefg12345"
+
 	fakeSrv := &core.Service{
-		Id:     56,
 		Name:   "Test Plugin Service",
 		Domain: "https://google.com",
+		Method: "GET",
 	}
+	fakeSrv.Create()
 
-	fakeFailD := core.FailureData{
+	fakeSrv2 := &core.Service{
-		Issue: "No issue, just testing this plugin.",
+		Name:   "Awesome Plugin Service",
-	}
+		Domain: "https://netflix.com",
-
+		Method: "GET",
-	fakeCore := &core.Core{
-		Name:        "Plugin Test",
-		Description: "This is a fake Core for testing your plugin",
-		ApiSecret:   "0x0x0x0x0",
-		ApiKey:      "abcdefg12345",
-		Services:    []*core.Service{fakeSrv},
 	}
+	fakeSrv2.Create()
 
 	fakeUser := &core.User{
 		Id:        6334,
@@ -151,54 +219,49 @@ func TestPlugin(plug plugin.PluginActions) {
 		Admin:     true,
 		CreatedAt: time.Now(),
 	}
+	fakeUser.Create()
 
-	fmt.Println("\nCreating a SQLite database for testing, will be deleted automatically...")
+	fakeUser = &core.User{
-	sqlFake := sqlite.ConnectionURL{
+		Id:        6335,
-		Database: "./.plugin_test.db",
+		Username:  "Billy",
+		Password:  "$2a$14$NzT/fLdE3f9iB1Eux2C84O6ZoPhI4NfY0Ke32qllCFo8pMTkUPZzy",
+		Email:     "info@awesome.com",
+		CreatedAt: time.Now(),
 	}
-	fakeDb, err := sqlite.Open(sqlFake)
+	fakeUser.Create()
-	if err != nil {
-		utils.Log(3, err)
-	}
-	up, _ := core.SqlBox.String("sqlite_up.sql")
-	requests := strings.Split(up, ";")
-	for _, request := range requests {
-		_, err := fakeDb.Exec(request)
-		if err != nil {
-			utils.Log(2, err)
-		}
-	}
-	fmt.Println("Finished creating Test SQLite database, sending events.")
 
-	fmt.Println("\n" + BRAKER)
+	comm := &types.Communication{
-	fmt.Println(POINT + "Sending 'OnLoad(sqlbuilder.Database)'")
+		Id:     1,
-	core.OnLoad(fakeDb)
+		Method: "email",
-	fmt.Println("\n" + BRAKER)
+	}
-	fmt.Println(POINT + "Sending 'OnSuccess(Service)'")
+	core.Create(comm)
-	core.OnSuccess(fakeSrv)
+
-	fmt.Println("\n" + BRAKER)
+	comm2 := &types.Communication{
-	fmt.Println(POINT + "Sending 'OnFailure(Service, FailureData)'")
+		Id:     2,
-	core.OnFailure(fakeSrv, fakeFailD)
+		Method: "slack",
-	fmt.Println("\n" + BRAKER)
+	}
-	fmt.Println(POINT + "Sending 'OnSettingsSaved(Core)'")
+	core.Create(comm2)
-	fmt.Println(BRAKER)
+
-	core.OnSettingsSaved(fakeCore)
+	for i := 0; i <= 50; i++ {
-	fmt.Println("\n" + BRAKER)
+		dd := core.HitData{
-	fmt.Println(POINT + "Sending 'OnNewService(Service)'")
+			Latency: rand.Float64(),
-	core.OnNewService(fakeSrv)
+		}
-	fmt.Println("\n" + BRAKER)
+		fakeSrv.CreateHit(dd)
-	fmt.Println(POINT + "Sending 'OnNewUser(User)'")
+		dd = core.HitData{
-	core.OnNewUser(fakeUser)
+			Latency: rand.Float64(),
-	fmt.Println("\n" + BRAKER)
+		}
-	fmt.Println(POINT + "Sending 'OnUpdateService(Service)'")
+		fakeSrv2.CreateHit(dd)
-	core.OnUpdateService(fakeSrv)
+		fail := core.FailureData{
-	fmt.Println("\n" + BRAKER)
+			Issue: "This is not an issue, but it would container HTTP response errors.",
-	fmt.Println(POINT + "Sending 'OnDeletedService(Service)'")
+		}
-	core.OnDeletedService(fakeSrv)
+		fakeSrv.CreateFailure(fail)
-	fmt.Println("\n" + BRAKER)
+
-
+		fail = core.FailureData{
-}
+			Issue: "HTTP Status Code 521 did not match 200",
-
+		}
-func FakeSeed() {
+		fakeSrv2.CreateFailure(fail)
+	}
+
+	fmt.Println("Seeding example data is complete, running Plugin Tests")
 
 }

core/services.go

@@ -244,8 +244,6 @@ func (u *Service) Create() (int64, error) {
 	u.Id = uuid.(int64)
 	u.stopRoutine = make(chan struct{})
 	CoreApp.Services = append(CoreApp.Services, u)
-	go u.CheckQueue()
-	OnNewService(u)
 	return uuid.(int64), err
 }
 

core/users.go

@@ -43,7 +43,6 @@ func (u *User) Create() (int64, error) {
 		utils.Log(3, fmt.Sprintf("Failed to create user %v. %v", u.Username, err))
 		return 0, err
 	}
-	OnNewUser(u)
 	return uuid.(int64), err
 }
 

handlers/services.go

@@ -55,7 +55,10 @@ func CreateServiceHandler(w http.ResponseWriter, r *http.Request) {
 	if err != nil {
 		utils.Log(3, fmt.Sprintf("Error starting %v check routine. %v", service.Name, err))
 	}
+
 	go service.CheckQueue()
+	core.OnNewService(service)
+
 	http.Redirect(w, r, "/services", http.StatusSeeOther)
 }
 

handlers/users.go

@@ -54,6 +54,7 @@ func CreateUserHandler(w http.ResponseWriter, r *http.Request) {
 	if err != nil {
 		utils.Log(2, err)
 	}
+	core.OnNewUser(user)
 	http.Redirect(w, r, "/users", http.StatusSeeOther)
 }