1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
package admin
import (
"encoding/csv"
"fmt"
"io/ioutil"
"log"
"net/http"
"os"
"path/filepath"
"strings"
"time"
"github.com/ponzu-cms/ponzu/management/format"
"github.com/ponzu-cms/ponzu/system/db"
"github.com/ponzu-cms/ponzu/system/item"
"github.com/tidwall/gjson"
)
func exportHandler(res http.ResponseWriter, req *http.Request) {
// /admin/contents/export?type=Blogpost&format=csv
q := req.URL.Query()
t := q.Get("type")
f := strings.ToLower(q.Get("format"))
if t == "" || f == "" {
v, err := Error400()
if err != nil {
res.WriteHeader(http.StatusInternalServerError)
return
}
res.WriteHeader(http.StatusBadRequest)
_, err = res.Write(v)
if err != nil {
res.WriteHeader(http.StatusInternalServerError)
return
}
}
pt, ok := item.Types[t]
if !ok {
res.WriteHeader(http.StatusBadRequest)
return
}
switch f {
case "csv":
csv, ok := pt().(format.CSVFormattable)
if !ok {
res.WriteHeader(http.StatusBadRequest)
return
}
fields := csv.FormatCSV()
exportCSV(res, req, pt, fields)
default:
res.WriteHeader(http.StatusBadRequest)
return
}
}
func exportCSV(res http.ResponseWriter, req *http.Request, pt func() interface{}, fields []string) {
tmpFile, err := ioutil.TempFile(os.TempDir(), "exportcsv-")
if err != nil {
log.Println("Failed to create tmp file for CSV export:", err)
res.WriteHeader(http.StatusInternalServerError)
return
}
defer os.Remove(filepath.Join(os.TempDir(), tmpFile.Name()))
defer tmpFile.Close()
csvBuf := csv.NewWriter(tmpFile)
t := req.URL.Query().Get("type")
// get content data and loop through creating a csv row per result
bb := db.ContentAll(t)
err = csvBuf.Write(fields)
if err != nil {
res.WriteHeader(http.StatusInternalServerError)
log.Println("Failed to write column headers:", fields)
return
}
for row := range bb {
// unmarshal data and loop over fields
rowBuf := []string{}
for _, col := range fields {
// pull out each field as the column value
result := gjson.GetBytes(bb[row], col)
// append it to the buffer
rowBuf = append(rowBuf, result.String())
}
// write row to csv
err := csvBuf.Write(rowBuf)
if err != nil {
res.WriteHeader(http.StatusInternalServerError)
log.Println("Failed to write column headers:", fields)
return
}
}
csvBuf.Flush()
// write the buffer to a content-disposition response
csvB, err := ioutil.ReadAll(tmpFile)
if err != nil {
log.Println("Failed to read tmp file for CSV export:", err)
res.WriteHeader(http.StatusInternalServerError)
return
}
ts := time.Now().Unix()
disposition := `attachment; filename="export-%s-%d.csv"`
res.Header().Set("Content-Type", "text/csv")
res.Header().Set("Content-Disposition", fmt.Sprintf(disposition, t, ts))
res.Header().Set("Content-Length", fmt.Sprintf("%d", len(csvB)))
_, err = res.Write(csvB)
if err != nil {
log.Println("Failed to write tmp file to response for CSV export:", err)
res.WriteHeader(http.StatusInternalServerError)
return
}
}
|
