100 lines
2.1 KiB
Go
100 lines
2.1 KiB
Go
package main
|
|
|
|
import (
|
|
"errors"
|
|
"log"
|
|
"time"
|
|
|
|
"github.com/ekzyis/sn-goapi"
|
|
)
|
|
|
|
func WaitUntilNextHour() {
|
|
now := time.Now()
|
|
dur := now.Truncate(time.Hour).Add(time.Hour).Sub(now)
|
|
log.Println("sleeping for", dur.Round(time.Second))
|
|
time.Sleep(dur)
|
|
}
|
|
|
|
func WaitUntilNextMinute() {
|
|
now := time.Now()
|
|
dur := now.Truncate(time.Minute).Add(time.Minute).Sub(now)
|
|
log.Println("sleeping for", dur.Round(time.Second))
|
|
time.Sleep(dur)
|
|
}
|
|
|
|
func CheckNotifications() {
|
|
var prevHasNewNotes bool
|
|
for {
|
|
log.Println("Checking notifications ...")
|
|
hasNewNotes, err := sn.CheckNotifications()
|
|
if err != nil {
|
|
SendErrorToDiscord(err)
|
|
} else {
|
|
if !prevHasNewNotes && hasNewNotes {
|
|
// only send embed on "rising edge"
|
|
SendNotificationsEmbedToDiscord()
|
|
log.Println("Forwarded notifications to monitoring")
|
|
} else if hasNewNotes {
|
|
log.Println("Notifications already forwarded")
|
|
}
|
|
}
|
|
prevHasNewNotes = hasNewNotes
|
|
WaitUntilNextMinute()
|
|
}
|
|
}
|
|
|
|
func SessionKeepAlive() {
|
|
for {
|
|
log.Println("Refresh session using GET /api/auth/session ...")
|
|
sn.RefreshSession()
|
|
WaitUntilNextHour()
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
go CheckNotifications()
|
|
go SessionKeepAlive()
|
|
for {
|
|
|
|
stories, err := FetchHackerNewsTopStories()
|
|
if err != nil {
|
|
SendErrorToDiscord(err)
|
|
WaitUntilNextMinute()
|
|
continue
|
|
}
|
|
|
|
if err := SaveStories(&stories); err != nil {
|
|
SendErrorToDiscord(err)
|
|
WaitUntilNextMinute()
|
|
continue
|
|
}
|
|
|
|
var filtered *[]Story
|
|
if filtered, err = CurateContentForStackerNews(); err != nil {
|
|
SendErrorToDiscord(err)
|
|
WaitUntilNextMinute()
|
|
continue
|
|
}
|
|
|
|
for _, story := range *filtered {
|
|
_, err := PostStoryToStackerNews(&story, PostStoryOptions{SkipDupes: false})
|
|
if err != nil {
|
|
var dupesErr *sn.DupesError
|
|
if errors.As(err, &dupesErr) {
|
|
// SendDupesErrorToDiscord(story.ID, dupesErr)
|
|
log.Println(dupesErr)
|
|
// save dupe in db to prevent retries
|
|
parentId := dupesErr.Dupes[0].Id
|
|
if err := SaveSnItem(parentId, story.ID); err != nil {
|
|
SendErrorToDiscord(err)
|
|
}
|
|
continue
|
|
}
|
|
SendErrorToDiscord(err)
|
|
continue
|
|
}
|
|
}
|
|
WaitUntilNextMinute()
|
|
}
|
|
}
|