package v1 import ( "net/http" "net/url" "time" "github.com/gorilla/mux" conf "github.com/muety/wakapi/config" "github.com/muety/wakapi/middlewares" "github.com/muety/wakapi/models" v1 "github.com/muety/wakapi/models/compat/wakatime/v1" routeutils "github.com/muety/wakapi/routes/utils" "github.com/muety/wakapi/services" "github.com/muety/wakapi/utils" ) type AllTimeHandler struct { config *conf.Config userSrvc services.IUserService summarySrvc services.ISummaryService } func NewAllTimeHandler(userService services.IUserService, summaryService services.ISummaryService) *AllTimeHandler { return &AllTimeHandler{ userSrvc: userService, summarySrvc: summaryService, config: conf.Get(), } } func (h *AllTimeHandler) RegisterRoutes(router *mux.Router) { r := router.PathPrefix("/compat/wakatime/v1/users/{user}/all_time_since_today").Subrouter() r.Use( middlewares.NewAuthenticateMiddleware(h.userSrvc).Handler, ) r.Path("").Methods(http.MethodGet).HandlerFunc(h.Get) } // @Summary Retrieve summary for all time // @Description Mimics https://wakatime.com/developers#all_time_since_today // @ID get-all-time // @Tags wakatime // @Produce json // @Param user path string true "User ID to fetch data for (or 'current')" // @Security ApiKeyAuth // @Success 200 {object} v1.AllTimeViewModel // @Router /compat/wakatime/v1/users/{user}/all_time_since_today [get] func (h *AllTimeHandler) Get(w http.ResponseWriter, r *http.Request) { values, _ := url.ParseQuery(r.URL.RawQuery) user, err := routeutils.CheckEffectiveUser(w, r, h.userSrvc, "current") if err != nil { return // response was already sent by util function } summary, err, status := h.loadUserSummary(user) if err != nil { w.WriteHeader(status) w.Write([]byte(err.Error())) return } vm := v1.NewAllTimeFrom(summary, models.NewFiltersWith(models.SummaryProject, values.Get("project"))) utils.RespondJSON(w, r, http.StatusOK, vm) } func (h *AllTimeHandler) loadUserSummary(user *models.User) (*models.Summary, error, int) { summaryParams := &models.SummaryParams{ From: time.Time{}, To: time.Now(), User: user, Recompute: false, } var retrieveSummary services.SummaryRetriever = h.summarySrvc.Retrieve if summaryParams.Recompute { retrieveSummary = h.summarySrvc.Summarize } summary, err := h.summarySrvc.Aliased(summaryParams.From, summaryParams.To, summaryParams.User, retrieveSummary, summaryParams.Recompute) if err != nil { return nil, err, http.StatusInternalServerError } return summary, nil, http.StatusOK }