98 lines
2.3 KiB
Go
Raw Normal View History

2016-11-19 23:54:31 +09:00
package dashboard
import (
2017-10-02 06:29:58 +02:00
"net/http"
2017-06-28 21:32:13 +02:00
"sort"
2017-06-28 21:17:49 +02:00
2016-11-19 23:54:31 +09:00
"github.com/aerogo/aero"
2017-06-26 12:50:15 -03:00
"github.com/aerogo/flow"
2017-06-08 01:14:45 +02:00
"github.com/animenotifier/arn"
"github.com/animenotifier/notify.moe/components"
2017-06-07 23:37:13 +02:00
"github.com/animenotifier/notify.moe/utils"
2016-11-19 23:54:31 +09:00
)
2017-11-01 09:45:14 +01:00
const maxForumActivity = 5
const maxFollowing = 5
2017-06-27 16:51:27 +02:00
const maxSoundTracks = 5
2017-06-28 21:17:49 +02:00
const maxScheduleItems = 5
2017-07-22 15:04:54 +02:00
// Get the dashboard.
2016-11-19 23:54:31 +09:00
func Get(ctx *aero.Context) string {
2017-06-29 20:52:30 +02:00
var forumActivity []arn.Postable
2017-06-26 13:53:06 -03:00
var followingList []*arn.User
2017-06-27 16:51:27 +02:00
var soundTracks []*arn.SoundTrack
2017-06-28 21:17:49 +02:00
var upcomingEpisodes []*arn.UpcomingEpisode
2017-06-26 19:03:48 +02:00
2017-06-26 13:58:02 -03:00
user := utils.GetUser(ctx)
2017-06-07 21:12:59 +02:00
2017-10-02 06:29:58 +02:00
if user == nil {
return ctx.Error(http.StatusUnauthorized, "Not logged in", nil)
}
2017-06-26 12:50:15 -03:00
flow.Parallel(func() {
2017-11-01 09:45:14 +01:00
posts := arn.AllPosts()
threads := arn.AllThreads()
arn.SortPostsLatestFirst(posts)
arn.SortThreadsLatestFirst(threads)
posts = arn.FilterPostsWithUniqueThreads(posts, maxForumActivity)
postPostables := arn.ToPostables(posts)
threadPostables := arn.ToPostables(threads)
allPostables := append(postPostables, threadPostables...)
arn.SortPostablesLatestFirst(allPostables)
forumActivity = arn.FilterPostablesWithUniqueThreads(allPostables, maxForumActivity)
2017-06-28 21:17:49 +02:00
}, func() {
2017-07-17 22:43:26 +02:00
animeList, err := arn.GetAnimeList(user.ID)
2017-06-28 21:17:49 +02:00
if err != nil {
return
}
2017-07-05 15:50:29 +02:00
animeList = animeList.Watching()
2017-11-24 15:14:29 +01:00
animeList.Lock()
2017-06-28 21:17:49 +02:00
for _, item := range animeList.Items {
2017-07-05 14:34:33 +02:00
futureEpisodes := item.Anime().UpcomingEpisodes()
2017-06-29 08:32:46 +02:00
if len(futureEpisodes) == 0 {
continue
2017-06-28 21:17:49 +02:00
}
2017-06-29 08:32:46 +02:00
upcomingEpisodes = append(upcomingEpisodes, futureEpisodes...)
2017-06-28 21:17:49 +02:00
}
2017-06-28 21:32:13 +02:00
2017-11-24 15:14:29 +01:00
animeList.Unlock()
2017-06-28 21:32:13 +02:00
sort.Slice(upcomingEpisodes, func(i, j int) bool {
return upcomingEpisodes[i].Episode.AiringDate.Start < upcomingEpisodes[j].Episode.AiringDate.Start
})
2017-07-10 20:51:06 +02:00
if len(upcomingEpisodes) >= maxScheduleItems {
upcomingEpisodes = upcomingEpisodes[:maxScheduleItems]
}
2017-06-27 12:39:41 +02:00
}, func() {
2017-11-18 11:37:29 +01:00
soundTracks = arn.FilterSoundTracks(func(track *arn.SoundTrack) bool {
2017-10-15 20:26:50 +02:00
return !track.IsDraft && len(track.Media) > 0
})
2017-06-27 16:51:27 +02:00
arn.SortSoundTracksLatestFirst(soundTracks)
if len(soundTracks) > maxSoundTracks {
soundTracks = soundTracks[:maxSoundTracks]
}
2017-06-26 13:53:06 -03:00
}, func() {
2017-07-21 11:46:49 +02:00
followingList = user.Follows().Users()
2017-07-21 11:25:53 +02:00
arn.SortUsersLastSeen(followingList)
2017-06-26 13:53:06 -03:00
if len(followingList) > maxFollowing {
followingList = followingList[:maxFollowing]
}
})
return ctx.HTML(components.Dashboard(upcomingEpisodes, forumActivity, soundTracks, followingList, user))
2016-11-19 23:54:31 +09:00
}