Reorder files and parses templates.

7 files changed, 285 insertions, 0 deletions

diff --git a/app/Makefile b/app/Makefile
new file mode 100644
index 0000000..f246e69
--- /dev/null
+++ b/app/Makefile
@@ -0,0 +1,21 @@
+export STATUS_DB_DRIVER:=sqlite3
+export STATUS_DB_CREDENTIALS:=../db/status.db
+
+all: kill build run
+
+clean:
+	@echo "Removing sqlite3 database..."
+	@rm $$STATUS_DB_CREDENTIALS
+	@echo "Removing binary..."
+	@rm statuspage
+	@echo "Done"
+
+build:
+	go build -o statuspage
+
+run:
+	./statuspage & 
+
+kill:
+	@echo "Killing running instances..."
+	@pkill statuspage || true
diff --git a/app/db.go b/app/db.go
new file mode 100644
index 0000000..dc9a15d
--- /dev/null
+++ b/app/db.go
@@ -0,0 +1,40 @@
+package main
+
+import (
+	"github.com/jinzhu/gorm"
+	_ "github.com/mattn/go-sqlite3"
+	"log"
+	"os"
+)
+
+//var Db gorm.DB
+var dbdriver = os.Getenv("STATUS_DB_DRIVER")
+var dbcred = os.Getenv("STATUS_DB_CREDENTIALS")
+var Db, dberr = gorm.Open(dbdriver, dbcred)
+
+func InitDB() {
+	/*
+		dbdriver := os.Getenv("STATUS_DB_DRIVER")
+		dbcred := os.Getenv("STATUS_DB_CREDENTIALS")
+		Db, err := gorm.Open(dbdriver, dbcred)
+	*/
+	if dberr != nil {
+		log.Panic(dberr)
+	}
+	Db.LogMode(true)
+	if err := Db.DB().Ping(); err != nil {
+		log.Panic(err)
+	}
+
+	//	u := User{}
+	h := Host{}
+	//	Db.Debug().AutoMigrate(&u)
+	db := Db
+	log.Println(db)
+	db.Debug().AutoMigrate(&h)
+
+	/*
+		Db.Model(&u).AddUniqueIndex("idx_user_name", "name")
+		Db.Model(&u).AddUniqueIndex("idx_user_email", "email")
+	*/
+}
diff --git a/app/fetch.go b/app/fetch.go
new file mode 100644
index 0000000..27aa628
--- /dev/null
+++ b/app/fetch.go
@@ -0,0 +1,9 @@
+package main
+
+/*
+import (
+	"fmt"
+)
+
+func
+*/
diff --git a/app/handler.go b/app/handler.go
new file mode 100644
index 0000000..f87e92a
--- /dev/null
+++ b/app/handler.go
@@ -0,0 +1,55 @@
+package main
+
+import (
+	"fmt"
+	//	"html/template"
+	"log"
+	"net/http"
+)
+
+func IndexHandler(w http.ResponseWriter, r *http.Request) {
+	fmt.Fprintf(w, "Hello World! \n")
+	//	w.Write()
+}
+
+func RegisterHandler(w http.ResponseWriter, r *http.Request) {
+	log.Println("Processing registration!")
+	fmt.Fprintf(w, "Processing registration! \n")
+	//	w.Write()
+}
+
+func PrintRegisterHandler(w http.ResponseWriter, r *http.Request) {
+
+	fmt.Fprintf(w, "Printing register etc! \n")
+	//	w.Write()
+}
+
+func PrintNewJobHandler(w http.ResponseWriter, r *http.Request) {
+	log.Println("Printing job")
+
+	job := mainTempl.Lookup("jobs.html")
+
+	err := job.ExecuteTemplate(w, "jobs.html", nil)
+	if err != nil {
+		log.Panic(err)
+	}
+}
+
+func AddNewJobHandler(w http.ResponseWriter, r *http.Request) {
+	log.Printf("Add new job")
+
+	err := r.ParseForm()
+	if err != nil {
+		log.Panic(err)
+	}
+
+	host := &Host{}
+	err = decoder.Decode(host, r.PostForm)
+	if err != nil {
+		log.Panic(err)
+	}
+
+	log.Printf("%v", host)
+	fmt.Fprintf(w, "%s", host.Url)
+	Db.Debug().Save(host)
+}
diff --git a/app/main.go b/app/main.go
new file mode 100644
index 0000000..0a8b7dd
--- /dev/null
+++ b/app/main.go
@@ -0,0 +1,26 @@
+package main
+
+import (
+	"github.com/gorilla/mux"
+	"github.com/gorilla/schema"
+	"html/template"
+	"net/http"
+)
+
+var decoder = schema.NewDecoder()
+
+//var mainTempl = template.Must(template.New("global").ParseFiles("templates/header.html", "templates/navbar.html", "templates/footer.html"))
+var mainTempl = template.Must(template.New("global").ParseGlob("../templates/*.html"))
+
+func main() {
+	InitDB()
+
+	r := mux.NewRouter()
+	r.HandleFunc("/", IndexHandler)
+	r.HandleFunc("/register", RegisterHandler).Methods("POST")
+	r.HandleFunc("/register", PrintRegisterHandler).Methods("GET")
+	r.HandleFunc("/new", AddNewJobHandler).Methods("POST")
+	r.HandleFunc("/new", PrintNewJobHandler).Methods("GET")
+	http.Handle("/", r)
+	http.ListenAndServe(":8080", nil)
+}
diff --git a/app/struct.go b/app/struct.go
new file mode 100644
index 0000000..26c462b
--- /dev/null
+++ b/app/struct.go
@@ -0,0 +1,37 @@
+package main
+
+import (
+	"time"
+)
+
+/* Maybe worth saving uptime history? */
+
+type Host struct {
+	Id        int64
+	UserId    int64
+	Url       string
+	Protocoll string // e.g. http
+	Private   bool
+	Response  int64
+	/*
+		Date      time.Time
+		Success   bool
+		Include   string // Website must include this string
+		Except    string // Website must not include this string
+		Reason    string // Include, Exclude, Connection failure
+		Alert     bool   // True to send alert on failure
+	*/
+	CreatedAt time.Time
+	DeletedAt time.Time
+	UpdatedAt time.Time
+}
+
+type User struct {
+	Id        int64
+	Name      string
+	Email     string
+	Password  string
+	CreatedAt time.Time
+	DeletedAt time.Time
+	UpdatedAt time.Time
+}
diff --git a/app/utilities.go b/app/utilities.go
new file mode 100644
index 0000000..bc6c0ca
--- /dev/null
+++ b/app/utilities.go
@@ -0,0 +1,97 @@
+package main
+
+import (
+	"crypto/md5"
+	"fmt"
+	//	"github.com/garyburd/redigo/redis"
+	"golang.org/x/crypto/bcrypt"
+	"io"
+	"io/ioutil"
+	"log"
+	"math/rand"
+	"net/http"
+	//	"time"
+)
+
+// Returns headers as map and the content of a webpage as string
+func HttpGet(url string) (http.Header, string, error) {
+	response, err := http.Get(url)
+	if err != nil {
+		return nil, "Get request failed.", err
+	}
+
+	defer response.Body.Close()
+	contents, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		return nil, "Reading body failed.", err
+	}
+
+	return response.Header, string(contents), nil
+}
+
+// Hashs and returns a string (md5)
+func Md5Hash(content string) string {
+	h := md5.New()
+	io.WriteString(h, content)
+	hash := fmt.Sprintf("%x", h.Sum(nil))
+
+	return hash
+}
+
+// Creates a random string
+func RandomKey() string {
+	letters := []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789")
+	key := make([]rune, 40)
+	for i := range key {
+		key[i] = letters[rand.Intn(len(letters))]
+	}
+
+	return string(key)
+}
+
+//var pool = newPool()
+
+/*
+// Creates a pool with connections to Redis
+func newPool() *redis.Pool {
+	return &redis.Pool{
+		MaxIdle:     3,
+		IdleTimeout: 240 * time.Second,
+		Dial: func() (redis.Conn, error) {
+			//c, err := redis.Dial("tcp", ":6379")
+			c, err := redis.Dial("tcp", revel.Config.StringDefault("redis.server", "127.0.0.1")+":"+revel.Config.StringDefault("redis.port", "6379"))
+			if err != nil {
+				return nil, err
+			}
+			return c, err
+		},
+		TestOnBorrow: func(c redis.Conn, t time.Time) error {
+			_, err := c.Do("PING")
+			return err
+		},
+	}
+}
+*/
+
+// Hashs password with bcrypt and returns the string
+func HashPassword(password string) (string, error) {
+	if password == "" {
+		return "", nil
+	}
+	p := []byte(password)
+	hash, err := bcrypt.GenerateFromPassword(p, 10)
+	if err != nil {
+		return "", err
+	}
+	return string(hash), nil
+}
+
+// Verify password and hash
+func VerifyPassword(password, hash string) bool {
+	err := bcrypt.CompareHashAndPassword([]byte(hash), []byte(password))
+	if err != nil {
+		log.Printf("%s \n", err)
+		return false
+	}
+	return true
+}