filebrowser/hugo.go
Henrique Dias 35cc2f342b pre hook
2017-03-25 19:54:17 +00:00

270 lines
6.8 KiB
Go

//go:generate go get github.com/jteeuwen/go-bindata
//go:generate go-bindata -nomemcopy -pkg hugo -prefix "assets" -o binary.go assets/...
// Package hugo makes the bridge between the static website generator Hugo
// and the webserver Caddy, also providing an administrative user interface.
package hugo
import (
"bytes"
"io/ioutil"
"log"
"mime"
"net/http"
"os"
"path/filepath"
"reflect"
"strings"
"time"
"github.com/hacdias/caddy-filemanager"
"github.com/hacdias/caddy-filemanager/assets"
"github.com/hacdias/caddy-filemanager/frontmatter"
"github.com/hacdias/caddy-filemanager/utils/variables"
"github.com/hacdias/caddy-hugo/utils/commands"
"github.com/mholt/caddy/caddyhttp/httpserver"
"github.com/robfig/cron"
"github.com/spf13/hugo/parser"
)
// Hugo is hugo
type Hugo struct {
Next httpserver.Handler
Config *Config
FileManager *filemanager.FileManager
}
// ServeHTTP determines if the request is for this plugin, and if all prerequisites are met.
func (h Hugo) ServeHTTP(w http.ResponseWriter, r *http.Request) (int, error) {
// If the site matches the baseURL
if httpserver.Path(r.URL.Path).Matches(h.Config.BaseURL) {
// Serve the hugo assets
if httpserver.Path(r.URL.Path).Matches(h.Config.BaseURL + AssetsURL) {
return serveAssets(w, r, h.Config)
}
// Serve the filemanager assets
if httpserver.Path(r.URL.Path).Matches(h.Config.BaseURL + assets.BaseURL) {
return h.FileManager.ServeHTTP(w, r)
}
// If the url matches exactly with /{admin}/settings/ serve that page
// page variable isn't used here to avoid people using URLs like
// "/{admin}/settings/something".
if r.URL.Path == h.Config.BaseURL+"/settings/" || r.URL.Path == h.Config.BaseURL+"/settings" {
var frontmatter string
var err error
if _, err = os.Stat(h.Config.Root + "config.yaml"); err == nil {
frontmatter = "yaml"
}
if _, err = os.Stat(h.Config.Root + "config.json"); err == nil {
frontmatter = "json"
}
if _, err = os.Stat(h.Config.Root + "config.toml"); err == nil {
frontmatter = "toml"
}
http.Redirect(w, r, h.FileManager.Configs[0].AbsoluteURL()+"/config."+frontmatter, http.StatusTemporaryRedirect)
return 0, nil
}
if r.Method == http.MethodPut && r.Header.Get("archetype") != "" {
filename := r.Header.Get("Filename")
archetype := r.Header.Get("archetype")
if !strings.HasSuffix(filename, ".md") && !strings.HasSuffix(filename, ".markdown") {
return h.FileManager.ServeHTTP(w, r)
}
filename = strings.Replace(r.URL.Path, h.Config.BaseURL+h.Config.WebDavURL+"/content/", "", 1)
filename = filepath.Clean(filename)
args := []string{"new", filename, "--kind", archetype}
if err := commands.Run(h.Config.Hugo, args, h.Config.Root); err != nil {
return http.StatusInternalServerError, err
}
return http.StatusCreated, nil
}
if canBeEdited(r.URL.Path) && r.Method == http.MethodPut {
code, err := h.FileManager.ServeHTTP(w, r)
if err != nil {
return code, err
}
if r.Header.Get("Regenerate") == "true" {
if err = h.Config.BeforePublish(
r,
&h.FileManager.Configs[0],
h.FileManager.Configs[0].User,
); err != nil {
return http.StatusInternalServerError, err
}
RunHugo(h.Config, false)
if err = h.Config.AfterPublish(
r,
&h.FileManager.Configs[0],
h.FileManager.Configs[0].User,
); err != nil {
return http.StatusInternalServerError, err
}
}
if r.Header.Get("Schedule") != "" {
code, err = h.Schedule(w, r)
}
return code, err
}
return h.FileManager.ServeHTTP(w, r)
}
return h.Next.ServeHTTP(w, r)
}
// RunHugo is used to run the static website generator
func RunHugo(c *Config, force bool) {
os.RemoveAll(c.Root + "public")
// Prevent running if watching is enabled
if b, pos := variables.StringInSlice("--watch", c.Args); b && !force {
if len(c.Args) > pos && c.Args[pos+1] != "false" {
return
}
if len(c.Args) == pos+1 {
return
}
}
if err := commands.Run(c.Hugo, c.Args, c.Root); err != nil {
log.Println(err)
}
}
// Schedule schedules a post to be published later
func (h Hugo) Schedule(w http.ResponseWriter, r *http.Request) (int, error) {
t, err := time.Parse("2006-01-02T15:04", r.Header.Get("Schedule"))
if err != nil {
return http.StatusInternalServerError, err
}
format := rune(r.Header.Get("Rune")[0])
scheduler := cron.New()
scheduler.AddFunc(t.Format("05 04 15 02 01 *"), func() {
filename := r.URL.Path
filename = strings.Replace(filename, h.FileManager.Configs[0].WebDavURL, h.Config.Root, 1)
filename = filepath.Clean(filename)
raw, err := ioutil.ReadFile(filename)
if err != nil {
log.Println(err)
return
}
buffer := bytes.NewBuffer(raw)
page, err := parser.ReadFrom(buffer)
if err != nil {
log.Println(err)
return
}
content := strings.TrimSpace(string(page.Content()))
front, err := frontmatter.Unmarshal(page.FrontMatter())
if err != nil {
log.Println(err)
return
}
kind := reflect.TypeOf(front)
if kind == reflect.TypeOf(map[interface{}]interface{}{}) {
delete(front.(map[interface{}]interface{}), "draft")
delete(front.(map[interface{}]interface{}), "Draft")
} else {
delete(front.(map[string]interface{}), "draft")
delete(front.(map[string]interface{}), "Draft")
}
fm, err := frontmatter.Marshal(front, format)
if err != nil {
log.Println(err)
return
}
f := new(bytes.Buffer)
f.Write(fm)
f.Write([]byte(content))
file := f.Bytes()
if err = ioutil.WriteFile(filename, file, 0666); err != nil {
return
}
RunHugo(h.Config, false)
})
scheduler.Start()
return http.StatusOK, nil
}
func canBeEdited(name string) bool {
extensions := [...]string{
".md", ".markdown", ".mdown", ".mmark",
".asciidoc", ".adoc", ".ad",
".rst",
".json", ".toml", ".yaml", ".csv", ".xml", ".rss", ".conf", ".ini",
".tex", ".sty",
".css", ".sass", ".scss",
".js",
".html",
".txt", ".rtf",
".sh", ".bash", ".ps1", ".bat", ".cmd",
".php", ".pl", ".py",
"Caddyfile",
".c", ".cc", ".h", ".hh", ".cpp", ".hpp", ".f90",
".f", ".bas", ".d", ".ada", ".nim", ".cr", ".java", ".cs", ".vala", ".vapi",
}
for _, extension := range extensions {
if strings.HasSuffix(name, extension) {
return true
}
}
return false
}
// serveAssets provides the needed assets for the front-end
func serveAssets(w http.ResponseWriter, r *http.Request, c *Config) (int, error) {
// gets the filename to be used with Assets function
filename := strings.Replace(r.URL.Path, c.BaseURL+AssetsURL, "public", 1)
file, err := Asset(filename)
if err != nil {
return http.StatusNotFound, nil
}
// Get the file extension and its mimetype
extension := filepath.Ext(filename)
mediatype := mime.TypeByExtension(extension)
// Write the header with the Content-Type and write the file
// content to the buffer
w.Header().Set("Content-Type", mediatype)
w.Write(file)
return 200, nil
}