web/notify.moe
Code Issues Pull Requests Activity

Fixed concurrent access

Browse Source
This commit is contained in:
Eduard Urbach 2017-11-24 15:14:29 +01:00
parent 49791a836e
commit 85a26a5c5b
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pages/dashboard/dashboard.go
View File

@ -53,6 +53,7 @@ func Get(ctx *aero.Context) string {
} }
animeList = animeList.Watching() animeList = animeList.Watching()
animeList.Lock()
for _, item := range animeList.Items { for _, item := range animeList.Items {
futureEpisodes := item.Anime().UpcomingEpisodes() futureEpisodes := item.Anime().UpcomingEpisodes()
@ -64,6 +65,8 @@ func Get(ctx *aero.Context) string {
upcomingEpisodes = append(upcomingEpisodes, futureEpisodes...) upcomingEpisodes = append(upcomingEpisodes, futureEpisodes...)
} }
animeList.Unlock()
sort.Slice(upcomingEpisodes, func(i, j int) bool { sort.Slice(upcomingEpisodes, func(i, j int) bool {
return upcomingEpisodes[i].Episode.AiringDate.Start < upcomingEpisodes[j].Episode.AiringDate.Start return upcomingEpisodes[i].Episode.AiringDate.Start < upcomingEpisodes[j].Episode.AiringDate.Start
}) })

3
pages/profile/profile.go
View File

@ -39,6 +39,9 @@ func Profile(ctx *aero.Context, viewUser *arn.User) string {
animeList = viewUser.AnimeList() animeList = viewUser.AnimeList()
// Sort by rating // Sort by rating
animeList.Lock()
defer animeList.Unlock()
sort.Slice(animeList.Items, func(i, j int) bool { sort.Slice(animeList.Items, func(i, j int) bool {
return animeList.Items[i].Rating.Overall > animeList.Items[j].Rating.Overall return animeList.Items[i].Rating.Overall > animeList.Items[j].Rating.Overall
}) })

3
pages/profile/stats.go
View File

@ -33,6 +33,9 @@ func GetStatsByUser(ctx *aero.Context) string {
return ctx.Error(http.StatusInternalServerError, "Anime list not found", err) return ctx.Error(http.StatusInternalServerError, "Anime list not found", err)
} }
animeList.Lock()
defer animeList.Unlock()
for _, item := range animeList.Items { for _, item := range animeList.Items {
currentWatch := item.Episodes * item.Anime().EpisodeLength currentWatch := item.Episodes * item.Anime().EpisodeLength
reWatch := item.RewatchCount * item.Anime().EpisodeCount * item.Anime().EpisodeLength reWatch := item.RewatchCount * item.Anime().EpisodeCount * item.Anime().EpisodeLength