Rig up dowork event queue and graceful termination

1 files changed, 3 insertions, 0 deletions

diff --git a/server.go b/server.go
index 7d7a431..dc2708e 100644
--- a/server.go
+++ b/server.go
@@ -10,6 +10,7 @@ import (
 	"sync"
 	"time"
 
+	"git.sr.ht/~sircmpwn/dowork"
 	"github.com/fernet/fernet-go"
 	"github.com/labstack/echo/v4"
 )
@@ -24,6 +25,7 @@ type Server struct {
 	e        *echo.Echo
 	Sessions *SessionManager
 	Options  *Options
+	Queue    *work.Queue
 
 	mutex   sync.RWMutex // used for server reload
 	plugins []Plugin
@@ -66,6 +68,7 @@ func newServer(e *echo.Echo, options *Options) (*Server, error) {
 	}
 
 	s.Sessions = newSessionManager(s.dialIMAP, s.dialSMTP, e.Logger, options.Debug)
+	s.Queue = work.NewQueue("alps")
 
 	return s, nil
 }