commento/api/domain_statistics.go

84 lines
2.0 KiB
Go
Raw Permalink Normal View History

2018-06-04 00:05:44 +08:00
package main
import (
"net/http"
)
func domainStatistics(domain string) ([]int64, error) {
statement := `
SELECT COUNT(views.viewDate)
FROM (
SELECT to_char(date_trunc('day', (current_date - offs)), 'YYYY-MM-DD') AS date
FROM generate_series(0, 30, 1) AS offs
) gen LEFT OUTER JOIN views
ON gen.date = to_char(date_trunc('day', views.viewDate), 'YYYY-MM-DD') AND
views.domain=$1
GROUP BY gen.date
ORDER BY gen.date;
`
rows, err := db.Query(statement, domain)
if err != nil {
logger.Errorf("cannot get daily views: %v", err)
return []int64{}, errorInternal
}
defer rows.Close()
last30Days := []int64{}
for rows.Next() {
var count int64
if err = rows.Scan(&count); err != nil {
logger.Errorf("cannot get daily views for the last month: %v", err)
return []int64{}, errorInternal
}
last30Days = append(last30Days, count)
}
return last30Days, nil
}
func domainStatisticsHandler(w http.ResponseWriter, r *http.Request) {
type request struct {
OwnerToken *string `json:"ownerToken"`
2018-06-20 11:50:11 +08:00
Domain *string `json:"domain"`
2018-06-04 00:05:44 +08:00
}
var x request
if err := bodyUnmarshal(r, &x); err != nil {
bodyMarshal(w, response{"success": false, "message": err.Error()})
2018-06-04 00:05:44 +08:00
return
}
o, err := ownerGetByOwnerToken(*x.OwnerToken)
2018-06-04 00:05:44 +08:00
if err != nil {
bodyMarshal(w, response{"success": false, "message": err.Error()})
2018-06-04 00:05:44 +08:00
return
}
2018-07-24 15:00:45 +08:00
domain := domainStrip(*x.Domain)
2018-06-04 00:05:44 +08:00
isOwner, err := domainOwnershipVerify(o.OwnerHex, domain)
if err != nil {
bodyMarshal(w, response{"success": false, "message": err.Error()})
2018-06-04 00:05:44 +08:00
return
}
if !isOwner {
bodyMarshal(w, response{"success": false, "message": errorNotAuthorised.Error()})
2018-06-04 00:05:44 +08:00
return
}
viewsLast30Days, err := domainStatistics(domain)
if err != nil {
bodyMarshal(w, response{"success": false, "message": err.Error()})
2018-06-04 00:05:44 +08:00
return
}
commentsLast30Days, err := commentStatistics(domain)
if err != nil {
bodyMarshal(w, response{"success": false, "message": err.Error()})
2018-06-04 00:05:44 +08:00
return
}
bodyMarshal(w, response{"success": true, "viewsLast30Days": viewsLast30Days, "commentsLast30Days": commentsLast30Days})
2018-06-04 00:05:44 +08:00
}