`))
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
log.Println(err)
}
res.Write(errView)
return
}
statusDisabled := "disabled"
prevStatus := ""
nextStatus := ""
// total may be less than 10 (default count), so reset count to match total
if total < count {
count = total
}
// nothing previous to current list
if offset == 0 {
prevStatus = statusDisabled
}
// nothing after current list
if (offset+1)*count >= total {
nextStatus = statusDisabled
}
// set up pagination values
urlFmt := req.URL.Path + "?count=%d&offset=%d&&order=%s"
prevURL := fmt.Sprintf(urlFmt, count, offset-1, order)
nextURL := fmt.Sprintf(urlFmt, count, offset+1, order)
start := 1 + count*offset
end := start + count - 1
if total < end {
end = total
}
pagination := fmt.Sprintf(`
`, prevStatus, prevURL, start, end, total, nextStatus, nextURL)
// show indicator that a collection of items will be listed implicitly, but
// that none are created yet
if total < 1 {
pagination = `
`
html = html + b.String() + script + btn
adminView, err := Admin([]byte(html))
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "text/html")
res.Write(adminView)
}
func contentsHandler(res http.ResponseWriter, req *http.Request) {
q := req.URL.Query()
t := q.Get("type")
if t == "" {
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
order := strings.ToLower(q.Get("order"))
if order != "asc" {
order = "desc"
}
status := q.Get("status")
if _, ok := item.Types[t]; !ok {
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
pt := item.Types[t]()
p, ok := pt.(editor.Editable)
if !ok {
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
var hasExt bool
_, ok = pt.(api.Createable)
if ok {
hasExt = true
}
count, err := strconv.Atoi(q.Get("count")) // int: determines number of posts to return (10 default, -1 is all)
if err != nil {
if q.Get("count") == "" {
count = 10
} else {
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
}
offset, err := strconv.Atoi(q.Get("offset")) // int: multiplier of count for pagination (0 default)
if err != nil {
if q.Get("offset") == "" {
offset = 0
} else {
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
}
opts := db.QueryOptions{
Count: count,
Offset: offset,
Order: order,
}
var specifier string
if status == "public" || status == "" {
specifier = "__sorted"
} else if status == "pending" {
specifier = "__pending"
}
b := &bytes.Buffer{}
var total int
var posts [][]byte
html := `
` + t + ` Items
`
if hasExt {
if status == "" {
q.Set("status", "public")
}
// always start from top of results when changing public/pending
q.Del("count")
q.Del("offset")
q.Set("status", "public")
publicURL := req.URL.Path + "?" + q.Encode()
q.Set("status", "pending")
pendingURL := req.URL.Path + "?" + q.Encode()
switch status {
case "public", "":
// get __sorted posts of type t from the db
total, posts = db.Query(t+specifier, opts)
html += `
`))
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
log.Println(err)
}
res.Write(errView)
return
}
statusDisabled := "disabled"
prevStatus := ""
nextStatus := ""
// total may be less than 10 (default count), so reset count to match total
if total < count {
count = total
}
// nothing previous to current list
if offset == 0 {
prevStatus = statusDisabled
}
// nothing after current list
if (offset+1)*count >= total {
nextStatus = statusDisabled
}
// set up pagination values
urlFmt := req.URL.Path + "?count=%d&offset=%d&&order=%s&status=%s&type=%s"
prevURL := fmt.Sprintf(urlFmt, count, offset-1, order, status, t)
nextURL := fmt.Sprintf(urlFmt, count, offset+1, order, status, t)
start := 1 + count*offset
end := start + count - 1
if total < end {
end = total
}
pagination := fmt.Sprintf(`
`, prevStatus, prevURL, start, end, total, nextStatus, nextURL)
// show indicator that a collection of items will be listed implicitly, but
// that none are created yet
if total < 1 {
pagination = `
`
adminView, err := Admin([]byte(html))
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "text/html")
res.Write(adminView)
}
// adminPostListItem is a helper to create the li containing a post.
// p is the asserted post as an Editable, t is the Type of the post.
// specifier is passed to append a name to a namespace like __pending
func adminPostListItem(e editor.Editable, typeName, status string) []byte {
s, ok := e.(item.Sortable)
if !ok {
log.Println("Content type", typeName, "doesn't implement item.Sortable")
post := `
Error retreiving data. Your data type doesn't implement necessary interfaces. (item.Sortable)
`
return []byte(post)
}
i, ok := e.(item.Identifiable)
if !ok {
log.Println("Content type", typeName, "doesn't implement item.Identifiable")
post := `
Error retreiving data. Your data type doesn't implement necessary interfaces. (item.Identifiable)
`
return []byte(post)
}
// use sort to get other info to display in admin UI post list
tsTime := time.Unix(int64(s.Time()/1000), 0)
upTime := time.Unix(int64(s.Touch()/1000), 0)
updatedTime := upTime.Format("01/02/06 03:04 PM")
publishTime := tsTime.Format("01/02/06")
cid := fmt.Sprintf("%d", i.ItemID())
switch status {
case "public", "":
status = ""
default:
status = "__" + status
}
action := "/admin/edit/delete"
link := `` + i.String() + ``
if strings.HasPrefix(typeName, "__") {
link = `` + i.String() + ``
action = "/admin/edit/upload/delete"
}
post := `
`
return []byte(post)
}
func approveContentHandler(res http.ResponseWriter, req *http.Request) {
if req.Method != http.MethodPost {
res.WriteHeader(http.StatusMethodNotAllowed)
errView, err := Error405()
if err != nil {
return
}
res.Write(errView)
return
}
err := req.ParseMultipartForm(1024 * 1024 * 4) // maxMemory 4MB
if err != nil {
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
pendingID := req.FormValue("id")
t := req.FormValue("type")
if strings.Contains(t, "__") {
t = strings.Split(t, "__")[0]
}
post := item.Types[t]()
// run hooks
hook, ok := post.(item.Hookable)
if !ok {
log.Println("Type", t, "does not implement item.Hookable or embed item.Item.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
// check if we have a Mergeable
m, ok := post.(editor.Mergeable)
if !ok {
log.Println("Content type", t, "must implement editor.Mergeable before it can be approved.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
dec := schema.NewDecoder()
dec.IgnoreUnknownKeys(true)
dec.SetAliasTag("json")
err = dec.Decode(post, req.Form)
if err != nil {
log.Println("Error decoding post form for content approval:", t, err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
err = hook.BeforeApprove(res, req)
if err != nil {
log.Println("Error running BeforeApprove hook in approveContentHandler for:", t, err)
return
}
// call its Approve method
err = m.Approve(res, req)
if err != nil {
log.Println("Error running Approve method in approveContentHandler for:", t, err)
return
}
err = hook.AfterApprove(res, req)
if err != nil {
log.Println("Error running AfterApprove hook in approveContentHandler for:", t, err)
return
}
err = hook.BeforeSave(res, req)
if err != nil {
log.Println("Error running BeforeSave hook in approveContentHandler for:", t, err)
return
}
// Store the content in the bucket t
id, err := db.SetContent(t+":-1", req.Form)
if err != nil {
log.Println("Error storing content in approveContentHandler for:", t, err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
// set the target in the context so user can get saved value from db in hook
ctx := context.WithValue(req.Context(), "target", fmt.Sprintf("%s:%d", t, id))
req = req.WithContext(ctx)
err = hook.AfterSave(res, req)
if err != nil {
log.Println("Error running AfterSave hook in approveContentHandler for:", t, err)
return
}
if pendingID != "" {
err = db.DeleteContent(req.FormValue("type") + ":" + pendingID)
if err != nil {
log.Println("Failed to remove content after approval:", err)
}
}
// redirect to the new approved content's editor
redir := req.URL.Scheme + req.URL.Host + strings.TrimSuffix(req.URL.Path, "/approve")
redir += fmt.Sprintf("?type=%s&id=%d", t, id)
http.Redirect(res, req, redir, http.StatusFound)
}
func editHandler(res http.ResponseWriter, req *http.Request) {
switch req.Method {
case http.MethodGet:
q := req.URL.Query()
i := q.Get("id")
t := q.Get("type")
status := q.Get("status")
contentType, ok := item.Types[t]
if !ok {
fmt.Fprintf(res, item.ErrTypeNotRegistered.Error(), t)
return
}
post := contentType()
if i != "" {
if status == "pending" {
t = t + "__pending"
}
data, err := db.Content(t + ":" + i)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
if len(data) < 1 || data == nil {
res.WriteHeader(http.StatusNotFound)
errView, err := Error404()
if err != nil {
return
}
res.Write(errView)
return
}
err = json.Unmarshal(data, post)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
} else {
item, ok := post.(item.Identifiable)
if !ok {
log.Println("Content type", t, "doesn't implement item.Identifiable")
return
}
item.SetItemID(-1)
}
m, err := manager.Manage(post.(editor.Editable), t)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
adminView, err := Admin(m)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "text/html")
res.Write(adminView)
case http.MethodPost:
err := req.ParseMultipartForm(1024 * 1024 * 4) // maxMemory 4MB
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
cid := req.FormValue("id")
t := req.FormValue("type")
ts := req.FormValue("timestamp")
up := req.FormValue("updated")
// create a timestamp if one was not set
if ts == "" {
ts = fmt.Sprintf("%d", int64(time.Nanosecond)*time.Now().UTC().UnixNano()/int64(time.Millisecond))
req.PostForm.Set("timestamp", ts)
}
if up == "" {
req.PostForm.Set("updated", ts)
}
urlPaths, err := upload.StoreFiles(req)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
for name, urlPath := range urlPaths {
req.PostForm.Set(name, urlPath)
}
// check for any multi-value fields (ex. checkbox fields)
// and correctly format for db storage. Essentially, we need
// fieldX.0: value1, fieldX.1: value2 => fieldX: []string{value1, value2}
fieldOrderValue := make(map[string]map[string][]string)
for k, v := range req.PostForm {
if strings.Contains(k, ".") {
fo := strings.Split(k, ".")
// put the order and the field value into map
field := string(fo[0])
order := string(fo[1])
if len(fieldOrderValue[field]) == 0 {
fieldOrderValue[field] = make(map[string][]string)
}
// orderValue is 0:[?type=Thing&id=1]
orderValue := fieldOrderValue[field]
orderValue[order] = v
fieldOrderValue[field] = orderValue
// discard the post form value with name.N
req.PostForm.Del(k)
}
}
// add/set the key & value to the post form in order
for f, ov := range fieldOrderValue {
for i := 0; i < len(ov); i++ {
position := fmt.Sprintf("%d", i)
fieldValue := ov[position]
if req.PostForm.Get(f) == "" {
for i, fv := range fieldValue {
if i == 0 {
req.PostForm.Set(f, fv)
} else {
req.PostForm.Add(f, fv)
}
}
} else {
for _, fv := range fieldValue {
req.PostForm.Add(f, fv)
}
}
}
}
pt := t
if strings.Contains(t, "__") {
pt = strings.Split(t, "__")[0]
}
p, ok := item.Types[pt]
if !ok {
log.Println("Type", t, "is not a content type. Cannot edit or save.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
post := p()
hook, ok := post.(item.Hookable)
if !ok {
log.Println("Type", pt, "does not implement item.Hookable or embed item.Item.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
// Let's be nice and make a proper item for the Hookable methods
dec := schema.NewDecoder()
dec.IgnoreUnknownKeys(true)
dec.SetAliasTag("json")
err = dec.Decode(post, req.PostForm)
if err != nil {
log.Println("Error decoding post form for edit handler:", t, err)
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
if cid == "-1" {
err = hook.BeforeAdminCreate(res, req)
if err != nil {
log.Println("Error running BeforeAdminCreate method in editHandler for:", t, err)
return
}
} else {
err = hook.BeforeAdminUpdate(res, req)
if err != nil {
log.Println("Error running BeforeAdminUpdate method in editHandler for:", t, err)
return
}
}
err = hook.BeforeSave(res, req)
if err != nil {
log.Println("Error running BeforeSave method in editHandler for:", t, err)
return
}
id, err := db.SetContent(t+":"+cid, req.PostForm)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
// set the target in the context so user can get saved value from db in hook
ctx := context.WithValue(req.Context(), "target", fmt.Sprintf("%s:%d", t, id))
req = req.WithContext(ctx)
err = hook.AfterSave(res, req)
if err != nil {
log.Println("Error running AfterSave method in editHandler for:", t, err)
return
}
if cid == "-1" {
err = hook.AfterAdminCreate(res, req)
if err != nil {
log.Println("Error running AfterAdminUpdate method in editHandler for:", t, err)
return
}
} else {
err = hook.AfterAdminUpdate(res, req)
if err != nil {
log.Println("Error running AfterAdminUpdate method in editHandler for:", t, err)
return
}
}
scheme := req.URL.Scheme
host := req.URL.Host
path := req.URL.Path
sid := fmt.Sprintf("%d", id)
redir := scheme + host + path + "?type=" + pt + "&id=" + sid
if req.URL.Query().Get("status") == "pending" {
redir += "&status=pending"
}
http.Redirect(res, req, redir, http.StatusFound)
default:
res.WriteHeader(http.StatusMethodNotAllowed)
}
}
func deleteHandler(res http.ResponseWriter, req *http.Request) {
if req.Method != http.MethodPost {
res.WriteHeader(http.StatusMethodNotAllowed)
return
}
err := req.ParseMultipartForm(1024 * 1024 * 4) // maxMemory 4MB
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
id := req.FormValue("id")
t := req.FormValue("type")
ct := t
if id == "" || t == "" {
res.WriteHeader(http.StatusBadRequest)
return
}
// catch specifier suffix from delete form value
if strings.Contains(t, "__") {
spec := strings.Split(t, "__")
ct = spec[0]
}
p, ok := item.Types[ct]
if !ok {
log.Println("Type", t, "does not implement item.Hookable or embed item.Item.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
post := p()
hook, ok := post.(item.Hookable)
if !ok {
log.Println("Type", t, "does not implement item.Hookable or embed item.Item.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
data, err := db.Content(t + ":" + id)
if err != nil {
log.Println("Error in db.Content ", t+":"+id, err)
return
}
err = json.Unmarshal(data, post)
if err != nil {
log.Println("Error unmarshalling ", t, "=", id, err, " Hooks will be called on a zero-value.")
}
reject := req.URL.Query().Get("reject")
if reject == "true" {
err = hook.BeforeReject(res, req)
if err != nil {
log.Println("Error running BeforeReject method in deleteHandler for:", t, err)
return
}
}
err = hook.BeforeAdminDelete(res, req)
if err != nil {
log.Println("Error running BeforeAdminDelete method in deleteHandler for:", t, err)
return
}
err = hook.BeforeDelete(res, req)
if err != nil {
log.Println("Error running BeforeDelete method in deleteHandler for:", t, err)
return
}
err = db.DeleteContent(t + ":" + id)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
err = hook.AfterDelete(res, req)
if err != nil {
log.Println("Error running AfterDelete method in deleteHandler for:", t, err)
return
}
err = hook.AfterAdminDelete(res, req)
if err != nil {
log.Println("Error running AfterDelete method in deleteHandler for:", t, err)
return
}
if reject == "true" {
err = hook.AfterReject(res, req)
if err != nil {
log.Println("Error running AfterReject method in deleteHandler for:", t, err)
return
}
}
redir := strings.TrimSuffix(req.URL.Scheme+req.URL.Host+req.URL.Path, "/edit/delete")
redir = redir + "/contents?type=" + ct
http.Redirect(res, req, redir, http.StatusFound)
}
func deleteUploadHandler(res http.ResponseWriter, req *http.Request) {
if req.Method != http.MethodPost {
res.WriteHeader(http.StatusMethodNotAllowed)
return
}
err := req.ParseMultipartForm(1024 * 1024 * 4) // maxMemory 4MB
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
id := req.FormValue("id")
t := "__uploads"
if id == "" || t == "" {
res.WriteHeader(http.StatusBadRequest)
return
}
post := interface{}(&item.FileUpload{})
hook, ok := post.(item.Hookable)
if !ok {
log.Println("Type", t, "does not implement item.Hookable or embed item.Item.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
err = hook.BeforeDelete(res, req)
if err != nil {
log.Println("Error running BeforeDelete method in deleteHandler for:", t, err)
return
}
dbTarget := t + ":" + id
// delete from file system, if good, we continue to delete
// from database, if bad error 500
err = deleteUploadFromDisk(dbTarget)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
err = db.DeleteUpload(dbTarget)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
err = hook.AfterDelete(res, req)
if err != nil {
log.Println("Error running AfterDelete method in deleteHandler for:", t, err)
return
}
redir := "/admin/uploads"
http.Redirect(res, req, redir, http.StatusFound)
}
func editUploadHandler(res http.ResponseWriter, req *http.Request) {
switch req.Method {
case http.MethodGet:
q := req.URL.Query()
i := q.Get("id")
t := "__uploads"
post := &item.FileUpload{}
if i != "" {
data, err := db.Upload(t + ":" + i)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
if len(data) < 1 || data == nil {
res.WriteHeader(http.StatusNotFound)
errView, err := Error404()
if err != nil {
return
}
res.Write(errView)
return
}
err = json.Unmarshal(data, post)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
} else {
it, ok := interface{}(post).(item.Identifiable)
if !ok {
log.Println("Content type", t, "doesn't implement item.Identifiable")
return
}
it.SetItemID(-1)
}
m, err := manager.Manage(interface{}(post).(editor.Editable), t)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
adminView, err := Admin(m)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "text/html")
res.Write(adminView)
case http.MethodPost:
err := req.ParseMultipartForm(1024 * 1024 * 4) // maxMemory 4MB
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
t := req.FormValue("type")
pt := "__uploads"
ts := req.FormValue("timestamp")
up := req.FormValue("updated")
// create a timestamp if one was not set
if ts == "" {
ts = fmt.Sprintf("%d", int64(time.Nanosecond)*time.Now().UTC().UnixNano()/int64(time.Millisecond))
req.PostForm.Set("timestamp", ts)
}
if up == "" {
req.PostForm.Set("updated", ts)
}
post := interface{}(&item.FileUpload{})
hook, ok := post.(item.Hookable)
if !ok {
log.Println("Type", pt, "does not implement item.Hookable or embed item.Item.")
res.WriteHeader(http.StatusBadRequest)
errView, err := Error400()
if err != nil {
return
}
res.Write(errView)
return
}
err = hook.BeforeSave(res, req)
if err != nil {
log.Println("Error running BeforeSave method in editHandler for:", t, err)
return
}
// StoreFiles has the SetUpload call (which is equivalent of SetContent in other handlers)
urlPaths, err := upload.StoreFiles(req)
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
errView, err := Error500()
if err != nil {
return
}
res.Write(errView)
return
}
for name, urlPath := range urlPaths {
req.PostForm.Set(name, urlPath)
}
// check for any multi-value fields (ex. checkbox fields)
// and correctly format for db storage. Essentially, we need
// fieldX.0: value1, fieldX.1: value2 => fieldX: []string{value1, value2}
fieldOrderValue := make(map[string]map[string][]string)
ordVal := make(map[string][]string)
for k, v := range req.PostForm {
if strings.Contains(k, ".") {
fo := strings.Split(k, ".")
// put the order and the field value into map
field := string(fo[0])
order := string(fo[1])
fieldOrderValue[field] = ordVal
// orderValue is 0:[?type=Thing&id=1]
orderValue := fieldOrderValue[field]
orderValue[order] = v
fieldOrderValue[field] = orderValue
// discard the post form value with name.N
req.PostForm.Del(k)
}
}
// add/set the key & value to the post form in order
for f, ov := range fieldOrderValue {
for i := 0; i < len(ov); i++ {
position := fmt.Sprintf("%d", i)
fieldValue := ov[position]
if req.PostForm.Get(f) == "" {
for i, fv := range fieldValue {
if i == 0 {
req.PostForm.Set(f, fv)
} else {
req.PostForm.Add(f, fv)
}
}
} else {
for _, fv := range fieldValue {
req.PostForm.Add(f, fv)
}
}
}
}
err = hook.AfterSave(res, req)
if err != nil {
log.Println("Error running AfterSave method in editHandler for:", t, err)
return
}
scheme := req.URL.Scheme
host := req.URL.Host
redir := scheme + host + "/admin/uploads"
http.Redirect(res, req, redir, http.StatusFound)
case http.MethodPut:
urlPaths, err := upload.StoreFiles(req)
if err != nil {
log.Println("Couldn't store file uploads.", err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "application/json")
res.Write([]byte(`{"data": [{"url": "` + urlPaths["file"] + `"}]}`))
default:
res.WriteHeader(http.StatusMethodNotAllowed)
return
}
}
/*
func editUploadHandler(res http.ResponseWriter, req *http.Request) {
if req.Method != http.MethodPost {
res.WriteHeader(http.StatusMethodNotAllowed)
return
}
urlPaths, err := upload.StoreFiles(req)
if err != nil {
log.Println("Couldn't store file uploads.", err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "application/json")
res.Write([]byte(`{"data": [{"url": "` + urlPaths["file"] + `"}]}`))
}
*/
func searchHandler(res http.ResponseWriter, req *http.Request) {
q := req.URL.Query()
t := q.Get("type")
search := q.Get("q")
status := q.Get("status")
var specifier string
if t == "" || search == "" {
http.Redirect(res, req, req.URL.Scheme+req.URL.Host+"/admin", http.StatusFound)
return
}
if status == "pending" {
specifier = "__" + status
}
posts := db.ContentAll(t + specifier)
b := &bytes.Buffer{}
pt, ok := item.Types[t]
if !ok {
res.WriteHeader(http.StatusBadRequest)
return
}
post := pt()
p := post.(editor.Editable)
html := `
` + t + ` Results
`
for i := range posts {
// skip posts that don't have any matching search criteria
match := strings.ToLower(search)
all := strings.ToLower(string(posts[i]))
if !strings.Contains(all, match) {
continue
}
err := json.Unmarshal(posts[i], &p)
if err != nil {
log.Println("Error unmarshal search result json into", t, err, posts[i])
post := `
`
adminView, err := Admin([]byte(html))
if err != nil {
log.Println(err)
res.WriteHeader(http.StatusInternalServerError)
return
}
res.Header().Set("Content-Type", "text/html")
res.Write(adminView)
}
func uploadSearchHandler(res http.ResponseWriter, req *http.Request) {
q := req.URL.Query()
t := "__uploads"
search := q.Get("q")
status := q.Get("status")
if t == "" || search == "" {
http.Redirect(res, req, req.URL.Scheme+req.URL.Host+"/admin", http.StatusFound)
return
}
posts := db.UploadAll()
b := &bytes.Buffer{}
p := interface{}(&item.FileUpload{}).(editor.Editable)
html := `
Uploads Results
`
for i := range posts {
// skip posts that don't have any matching search criteria
match := strings.ToLower(search)
all := strings.ToLower(string(posts[i]))
if !strings.Contains(all, match) {
continue
}
err := json.Unmarshal(posts[i], &p)
if err != nil {
log.Println("Error unmarshal search result json into", t, err, posts[i])
post := `