Compare commits

...

2 Commits

Author SHA1 Message Date
Magnus Åhall
aee1c25f54 Bumped to v23 2024-03-29 20:54:51 +01:00
Magnus Åhall
7de9feea58 Restore minute-based schedule 2024-03-29 20:54:42 +01:00
3 changed files with 4 additions and 5 deletions

View File

@ -175,10 +175,9 @@ func main() { // {{{
} // }}} } // }}}
func scheduleHandler() { // {{{ func scheduleHandler() { // {{{
// Wait for the approximate minute. // Wait for the approximate minute.
//wait := 60000 - time.Now().Sub(time.Now().Truncate(time.Minute)).Milliseconds() wait := 60000 - time.Now().Sub(time.Now().Truncate(time.Minute)).Milliseconds()
//time.Sleep(time.Millisecond * time.Duration(wait)) time.Sleep(time.Millisecond * time.Duration(wait))
tick := time.NewTicker(time.Minute) tick := time.NewTicker(time.Minute)
tick = time.NewTicker(time.Second*5)
for { for {
<-tick.C <-tick.C
for _, event := range ExpiredSchedules() { for _, event := range ExpiredSchedules() {
@ -761,7 +760,6 @@ func keyCounter(w http.ResponseWriter, r *http.Request, sess *session.T) { // {{
}) })
} // }}} } // }}}
func notificationAcknowledge(w http.ResponseWriter, r *http.Request, sess *session.T) { // {{{ func notificationAcknowledge(w http.ResponseWriter, r *http.Request, sess *session.T) { // {{{
logger.Info("webserver", "request", "/notification/ack") logger.Info("webserver", "request", "/notification/ack")
var err error var err error

View File

@ -44,6 +44,7 @@ func (nm *Manager) AddService(userID int, service Service) {
} }
func (nm *Manager) Send(userID int, uuid string, msg []byte) (err error) { func (nm *Manager) Send(userID int, uuid string, msg []byte) (err error) {
services, found := nm.services[userID] services, found := nm.services[userID]
if !found { if !found {
return werr.New("No notification services defined for user ID %d", userID).WithCode("002-0008") return werr.New("No notification services defined for user ID %d", userID).WithCode("002-0008")

View File

@ -1 +1 @@
v22 v23