113 lines
2.3 KiB
Go
Raw Normal View History

2016-11-19 14:54:31 +00:00
package dashboard
import (
2017-06-28 19:32:13 +00:00
"sort"
2017-06-28 19:17:49 +00:00
2016-11-19 14:54:31 +00:00
"github.com/aerogo/aero"
2017-06-26 15:50:15 +00:00
"github.com/aerogo/flow"
2017-06-07 23:14:45 +00:00
"github.com/animenotifier/arn"
"github.com/animenotifier/notify.moe/components"
2017-06-15 21:03:55 +00:00
"github.com/animenotifier/notify.moe/pages/frontpage"
2017-06-07 21:37:13 +00:00
"github.com/animenotifier/notify.moe/utils"
2016-11-19 14:54:31 +00:00
)
2016-12-06 03:36:31 +00:00
const maxPosts = 5
const maxFollowing = 5
2017-06-27 14:51:27 +00:00
const maxSoundTracks = 5
2017-06-28 19:17:49 +00:00
const maxScheduleItems = 5
2017-06-26 17:03:48 +00:00
// Get the dashboard or the frontpage when logged out.
2016-11-19 14:54:31 +00:00
func Get(ctx *aero.Context) string {
2017-06-07 23:14:45 +00:00
user := utils.GetUser(ctx)
2017-06-15 21:03:55 +00:00
if user == nil {
return frontpage.Get(ctx)
}
2017-06-26 17:03:48 +00:00
return dashboard(ctx)
2017-06-26 15:50:15 +00:00
}
2017-06-07 19:12:59 +00:00
2017-06-26 17:03:48 +00:00
// Render the dashboard.
func dashboard(ctx *aero.Context) string {
2017-06-29 18:52:30 +00:00
var forumActivity []arn.Postable
2017-06-26 16:53:06 +00:00
var userList interface{}
var followingList []*arn.User
2017-06-27 14:51:27 +00:00
var soundTracks []*arn.SoundTrack
2017-06-28 19:17:49 +00:00
var upcomingEpisodes []*arn.UpcomingEpisode
2017-06-26 17:03:48 +00:00
2017-06-26 16:58:02 +00:00
user := utils.GetUser(ctx)
2017-06-07 19:12:59 +00:00
2017-06-26 15:50:15 +00:00
flow.Parallel(func() {
2017-06-29 18:52:30 +00:00
forumActivity, _ = arn.GetForumActivityCached()
2017-06-28 19:17:49 +00:00
}, func() {
animeList, err := arn.GetAnimeList(user)
if err != nil {
return
}
2017-07-01 11:45:23 +00:00
animeList = animeList.WatchingAndPlanned()
2017-06-28 19:17:49 +00:00
var keys []string
for _, item := range animeList.Items {
keys = append(keys, item.AnimeID)
}
objects, getErr := arn.DB.GetMany("Anime", keys)
if getErr != nil {
return
}
allAnimeInList := objects.([]*arn.Anime)
for _, anime := range allAnimeInList {
if len(upcomingEpisodes) >= maxScheduleItems {
break
}
2017-06-29 06:32:46 +00:00
futureEpisodes := anime.UpcomingEpisodes()
if len(futureEpisodes) == 0 {
continue
2017-06-28 19:17:49 +00:00
}
2017-06-29 06:32:46 +00:00
upcomingEpisodes = append(upcomingEpisodes, futureEpisodes...)
2017-06-28 19:17:49 +00:00
}
2017-06-28 19:32:13 +00:00
sort.Slice(upcomingEpisodes, func(i, j int) bool {
return upcomingEpisodes[i].Episode.AiringDate.Start < upcomingEpisodes[j].Episode.AiringDate.Start
})
2017-06-27 10:39:41 +00:00
}, func() {
2017-06-27 14:51:27 +00:00
var err error
soundTracks, err = arn.AllSoundTracks()
if err != nil {
return
}
arn.SortSoundTracksLatestFirst(soundTracks)
if len(soundTracks) > maxSoundTracks {
soundTracks = soundTracks[:maxSoundTracks]
}
2017-06-26 16:53:06 +00:00
}, func() {
2017-06-27 14:51:27 +00:00
var err error
2017-06-26 22:14:47 +00:00
userList, err = arn.DB.GetMany("User", user.Following)
2017-06-27 14:51:27 +00:00
if err != nil {
return
}
2017-06-26 16:53:06 +00:00
followingList = userList.([]*arn.User)
followingList = arn.SortUsersLastSeen(followingList)
if len(followingList) > maxFollowing {
followingList = followingList[:maxFollowing]
}
})
2017-06-29 16:39:42 +00:00
return ctx.HTML(components.Dashboard(upcomingEpisodes, forumActivity, soundTracks, followingList))
2016-11-19 14:54:31 +00:00
}