added way to see form submission in the UI close #14

Author: dstpierre

form.go

@@ -10,7 +10,6 @@ import (
 
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
-	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
 func submitForm(w http.ResponseWriter, r *http.Request) {
@@ -67,47 +66,15 @@ func listForm(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	db := client.Database(conf.Name)
-
-	opt := options.Find()
-	opt.SetLimit(100)
-	opt.SetSort(bson.M{internal.FieldID: -1})
+	curDB := client.Database(conf.Name)
 
-	filter := bson.M{}
-	if fn := r.URL.Query().Get("name"); len(fn) > 0 {
-		filter["form"] = fn
-	}
+	formName := r.URL.Query().Get("name")
 
-	cur, err := db.Collection("sb_forms").Find(context.Background(), filter, opt)
+	results, err := internal.ListFormSubmissions(curDB, formName)
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusInternalServerError)
 		return
 	}
-	defer cur.Close(context.Background())
-
-	var results []bson.M
-
-	for cur.Next(context.Background()) {
-		var result bson.M
-		err := cur.Decode(&result)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		result["id"] = result["_id"]
-		delete(result, internal.FieldID)
-
-		results = append(results, result)
-	}
-	if err := cur.Err(); err != nil {
-		http.Error(w, err.Error(), http.StatusInternalServerError)
-		return
-	}
-
-	if len(results) == 0 {
-		results = make([]bson.M, 1)
-	}
 
 	respond(w, http.StatusOK, results)
 }

internal/form.go

@@ -0,0 +1,77 @@
+package internal
+
+import (
+	"fmt"
+
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+func ListFormSubmissions(db *mongo.Database, name string) ([]bson.M, error) {
+	opt := options.Find()
+	opt.SetLimit(100)
+	opt.SetSort(bson.M{FieldID: -1})
+
+	filter := bson.M{}
+	if len(name) > 0 {
+		filter["form"] = name
+	}
+
+	cur, err := db.Collection("sb_forms").Find(ctx, filter, opt)
+	if err != nil {
+		return nil, err
+	}
+	defer cur.Close(ctx)
+
+	var results []bson.M
+	for cur.Next(ctx) {
+		var result bson.M
+		if err := cur.Decode(&result); err != nil {
+			return nil, err
+		}
+
+		result["id"] = result[FieldID]
+		delete(result, FieldID)
+
+		results = append(results, result)
+	}
+	if err := cur.Err(); err != nil {
+		return nil, err
+	}
+
+	if len(results) == 0 {
+		results = make([]bson.M, 1)
+	}
+
+	return results, nil
+}
+
+func GetForms(db *mongo.Database) ([]string, error) {
+	pipeline := mongo.Pipeline{bson.D{{"$group", bson.D{{"_id", "$form"}}}}}
+	cur, err := db.Collection("sb_forms").Aggregate(ctx, pipeline)
+	if err != nil {
+		return nil, err
+	}
+	defer cur.Close(ctx)
+
+	var names []string
+	for cur.Next(ctx) {
+		var form bson.M
+		if err := cur.Decode(&form); err != nil {
+			return nil, err
+		}
+
+		names = append(names, fmt.Sprintf("%v", form[FieldID]))
+	}
+
+	if err := cur.Err(); err != nil {
+		return nil, err
+	}
+
+	if len(names) == 0 {
+		names = make([]string, 1)
+	}
+
+	return names, nil
+}

render.go

@@ -6,7 +6,9 @@ import (
 	"log"
 	"net/http"
 	"os"
+	"strconv"
 	"strings"
+	"time"
 
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
@@ -116,6 +118,19 @@ func customFuncs() template.FuncMap {
 			if ok {
 				return oid.Hex()
 			}
+
+			date, ok := dict[s].(time.Time)
+			if ok {
+				return date.Format("2006-01-02 15:04")
+			}
+
+			if s == "sb_posted" {
+				i, err := strconv.ParseInt(fmt.Sprintf("%v", dict[s]), 10, 64)
+				if err == nil {
+					ts := time.Unix(i/1000, 0)
+					return ts.Format("2006-01-02 15:04")
+				}
+			}
 			return fmt.Sprintf("%v", v)
 		},
 	}

server.go

@@ -145,6 +145,8 @@ func Start(dbHost, port string) {
 	http.Handle("/ui/db/save", middleware.Chain(http.HandlerFunc(webUI.dbSave), stdRoot...))
 	http.Handle("/ui/db/del/", middleware.Chain(http.HandlerFunc(webUI.dbDel), stdRoot...))
 	http.Handle("/ui/db/", middleware.Chain(http.HandlerFunc(webUI.dbDoc), stdRoot...))
+	http.Handle("/ui/forms", middleware.Chain(http.HandlerFunc(webUI.forms), stdRoot...))
+	http.Handle("/ui/forms/del/", middleware.Chain(http.HandlerFunc(webUI.formDel), stdRoot...))
 	http.HandleFunc("/", webUI.login)
 
 	log.Fatal(http.ListenAndServe(":"+port, nil))

templates/forms.html

@@ -0,0 +1,66 @@
+{{ template "head" .}}
+
+<body>
+	{{template "navbar" .}}
+
+	<div class="container p-6">
+		<h2 class="title is-2">
+			Form submissions
+		</h2>
+		<p class="subtitle is-5">
+		<div class="dropdown is-active" x-data="{isOpen: false}">
+			<div class="dropdown-trigger">
+				<button @click="isOpen = !isOpen" class="button" aria-haspopup="true" aria-controls="dropdown-menu">
+					<span>
+						{{if .Data.FormName}}
+						{{.Data.FormName}}
+						{{else}}
+						All forms
+						{{end}}
+					</span>
+					<span class="icon is-small">
+						<i class="fas fa-angle-down" aria-hidden="true"></i>
+					</span>
+				</button>
+			</div>
+			<div x-show="isOpen" class="dropdown-menu" id="dropdown-menu" role="menu">
+				<div class="dropdown-content">
+					<a href="/ui/forms" class="dropdown-item">
+						All forms
+					</a>
+					{{range .Data.Forms}}
+					<a href="/ui/forms?fn={{.}}" class="dropdown-item">
+						{{.}}
+					</a>
+					{{end}}
+				</div>
+			</div>
+		</div>
+		<span class="pl-3">filter for a specifics form</span>
+		</p>
+
+		{{range .Data.Entries}}
+		<div class="box py-3">
+			<div class="columns is-multiline">
+				<div class="column">
+					<a href='/ui/forms/del/{{getField "id" .}}' class="delete"
+						onclick="return confirm('Are you sure you want to delete this form submission?\n\nThis is irreversible.')">
+					</a>
+				</div>
+				{{$doc := .}}
+				{{range $key, $val := .}}
+				{{if eq $key "id"}}
+				{{else}}
+				<div class="column">
+					<strong>{{$key}}</strong><br />
+					{{getField $key $doc}}
+				</div>
+				{{end}}
+				{{end}}
+			</div>
+		</div>
+		{{end}}
+	</div>
+</body>
+
+{{template "foot"}}

ui.go

@@ -319,3 +319,58 @@ func (ui) readColumnNames(docs []interface{}) []string {
 
 	return columns
 }
+
+func (x ui) forms(w http.ResponseWriter, r *http.Request) {
+	conf, _, err := middleware.Extract(r, false)
+	if err != nil {
+		renderErr(w, r, err)
+		return
+	}
+
+	formName := r.URL.Query().Get("fn")
+
+	curDB := client.Database(conf.Name)
+
+	forms, err := internal.GetForms(curDB)
+	if err != nil {
+		renderErr(w, r, err)
+		return
+	}
+
+	entries, err := internal.ListFormSubmissions(curDB, formName)
+	if err != nil {
+		renderErr(w, r, err)
+		return
+	}
+
+	var data = new(struct {
+		FormName string
+		Forms    []string
+		Entries  []bson.M
+	})
+
+	data.FormName = formName
+	data.Forms = forms
+	data.Entries = entries
+
+	render(w, r, "forms.html", data, nil)
+}
+
+func (x ui) formDel(w http.ResponseWriter, r *http.Request) {
+	conf, auth, err := middleware.Extract(r, true)
+	if err != nil {
+		renderErr(w, r, err)
+		return
+	}
+
+	curDB := client.Database(conf.Name)
+
+	id := getURLPart(r.URL.Path, 4)
+
+	if _, err := x.base.Delete(auth, curDB, "sb_forms", id); err != nil {
+		renderErr(w, r, err)
+		return
+	}
+
+	http.Redirect(w, r, "/ui/forms", http.StatusSeeOther)
+}