alps/server.go

218 lines
4.4 KiB
Go
Raw Normal View History

2019-12-02 14:31:00 +00:00
package koushin
import (
2019-12-02 16:24:19 +00:00
"fmt"
2019-12-02 14:31:00 +00:00
"net/http"
2019-12-02 16:24:19 +00:00
"net/url"
2019-12-03 12:07:25 +00:00
"strings"
2019-12-02 16:24:19 +00:00
"time"
2019-12-02 14:31:00 +00:00
2019-12-03 10:12:26 +00:00
"github.com/labstack/echo/v4"
2019-12-02 14:31:00 +00:00
)
2019-12-02 16:24:19 +00:00
const cookieName = "koushin_session"
const messagesPerPage = 50
2019-12-02 16:24:19 +00:00
type Server struct {
Sessions *SessionManager
Plugins []Plugin
2019-12-09 17:16:27 +00:00
2019-12-02 16:24:19 +00:00
imap struct {
2019-12-03 10:12:26 +00:00
host string
tls bool
2019-12-02 16:24:19 +00:00
insecure bool
}
2019-12-03 14:21:59 +00:00
smtp struct {
host string
tls bool
insecure bool
}
2019-12-02 16:24:19 +00:00
}
2019-12-03 14:21:59 +00:00
func (s *Server) parseIMAPURL(imapURL string) error {
2019-12-02 16:24:19 +00:00
u, err := url.Parse(imapURL)
if err != nil {
2019-12-03 14:21:59 +00:00
return fmt.Errorf("failed to parse IMAP server URL: %v", err)
2019-12-02 16:24:19 +00:00
}
s.imap.host = u.Host
switch u.Scheme {
case "imap":
// This space is intentionally left blank
case "imaps":
s.imap.tls = true
case "imap+insecure":
s.imap.insecure = true
default:
2019-12-03 14:21:59 +00:00
return fmt.Errorf("unrecognized IMAP URL scheme: %s", u.Scheme)
}
return nil
}
func (s *Server) parseSMTPURL(smtpURL string) error {
u, err := url.Parse(smtpURL)
if err != nil {
return fmt.Errorf("failed to parse SMTP server URL: %v", err)
}
s.smtp.host = u.Host
switch u.Scheme {
case "smtp":
// This space is intentionally left blank
case "smtps":
s.smtp.tls = true
case "smtp+insecure":
s.smtp.insecure = true
default:
return fmt.Errorf("unrecognized SMTP URL scheme: %s", u.Scheme)
2019-12-02 16:24:19 +00:00
}
2019-12-03 14:21:59 +00:00
return nil
}
func newServer(imapURL, smtpURL string) (*Server, error) {
2019-12-03 14:21:59 +00:00
s := &Server{}
s.Sessions = newSessionManager(s.connectIMAP)
2019-12-03 14:21:59 +00:00
if err := s.parseIMAPURL(imapURL); err != nil {
return nil, err
}
2019-12-02 14:31:00 +00:00
2019-12-03 14:21:59 +00:00
if smtpURL != "" {
if err := s.parseSMTPURL(smtpURL); err != nil {
return nil, err
}
}
2019-12-02 16:24:19 +00:00
return s, nil
}
// Context is the context used by HTTP handlers.
//
// Use a type assertion to get it from a echo.Context:
//
// ctx := ectx.(*koushin.Context)
type Context struct {
2019-12-02 16:24:19 +00:00
echo.Context
Server *Server
Session *Session
2019-12-02 16:24:19 +00:00
}
var aLongTimeAgo = time.Unix(233431200, 0)
func (ctx *Context) SetSession(s *Session) {
2019-12-02 16:24:19 +00:00
cookie := http.Cookie{
2019-12-03 10:12:26 +00:00
Name: cookieName,
2019-12-02 16:24:19 +00:00
HttpOnly: true,
// TODO: domain, secure
}
if s != nil {
cookie.Value = s.token
} else {
2019-12-02 16:24:19 +00:00
cookie.Expires = aLongTimeAgo // unset the cookie
}
ctx.SetCookie(&cookie)
2019-12-02 16:24:19 +00:00
}
func isPublic(path string) bool {
return path == "/login" || strings.HasPrefix(path, "/assets/") ||
strings.HasPrefix(path, "/themes/")
}
type Options struct {
IMAPURL, SMTPURL string
Theme string
}
2019-12-02 16:24:19 +00:00
func New(e *echo.Echo, options *Options) error {
s, err := newServer(options.IMAPURL, options.SMTPURL)
2019-12-02 16:24:19 +00:00
if err != nil {
return err
}
s.Plugins, err = loadAllLuaPlugins(e.Logger)
if err != nil {
2019-12-09 16:54:24 +00:00
return fmt.Errorf("failed to load plugins: %v", err)
2019-12-02 16:24:19 +00:00
}
e.Renderer, err = loadTemplates(e.Logger, options.Theme, s.Plugins)
2019-12-09 15:02:12 +00:00
if err != nil {
2019-12-09 16:54:24 +00:00
return fmt.Errorf("failed to load templates: %v", err)
2019-12-09 15:02:12 +00:00
}
2019-12-03 12:17:51 +00:00
e.HTTPErrorHandler = func(err error, c echo.Context) {
code := http.StatusInternalServerError
if he, ok := err.(*echo.HTTPError); ok {
code = he.Code
} else {
c.Logger().Error(err)
}
// TODO: hide internal errors
c.String(code, err.Error())
}
2019-12-02 16:24:19 +00:00
e.Use(func(next echo.HandlerFunc) echo.HandlerFunc {
return func(ectx echo.Context) error {
ctx := &Context{Context: ectx, Server: s}
2019-12-09 15:02:12 +00:00
ctx.Set("context", ctx)
2019-12-02 16:24:19 +00:00
cookie, err := ctx.Cookie(cookieName)
if err == http.ErrNoCookie {
2019-12-02 16:31:34 +00:00
// Require auth for all pages except /login
if isPublic(ctx.Path()) {
2019-12-02 16:31:34 +00:00
return next(ctx)
} else {
return ctx.Redirect(http.StatusFound, "/login")
}
2019-12-02 16:24:19 +00:00
} else if err != nil {
return err
}
ctx.Session, err = ctx.Server.Sessions.get(cookie.Value)
2019-12-02 16:24:19 +00:00
if err == ErrSessionExpired {
ctx.SetSession(nil)
2019-12-02 16:24:19 +00:00
return ctx.Redirect(http.StatusFound, "/login")
} else if err != nil {
return err
}
ctx.Session.ping()
2019-12-02 16:24:19 +00:00
return next(ctx)
}
})
2019-12-04 19:55:08 +00:00
e.GET("/mailbox/:mbox", handleGetMailbox)
2019-12-02 14:31:00 +00:00
2019-12-02 18:53:09 +00:00
e.GET("/message/:mbox/:uid", func(ectx echo.Context) error {
ctx := ectx.(*Context)
2019-12-03 12:07:25 +00:00
return handleGetPart(ctx, false)
})
e.GET("/message/:mbox/:uid/raw", func(ectx echo.Context) error {
ctx := ectx.(*Context)
2019-12-03 12:07:25 +00:00
return handleGetPart(ctx, true)
2019-12-02 18:53:09 +00:00
})
2019-12-02 16:24:19 +00:00
e.GET("/login", handleLogin)
e.POST("/login", handleLogin)
2019-12-04 19:55:08 +00:00
e.GET("/logout", handleLogout)
2019-12-03 12:24:46 +00:00
2019-12-03 13:33:20 +00:00
e.GET("/compose", handleCompose)
e.POST("/compose", handleCompose)
2019-12-03 17:41:23 +00:00
e.GET("/message/:mbox/:uid/reply", handleCompose)
e.POST("/message/:mbox/:uid/reply", handleCompose)
2019-12-02 14:31:00 +00:00
e.Static("/assets", "public/assets")
e.Static("/themes", "public/themes")
2019-12-02 14:31:00 +00:00
for _, p := range s.Plugins {
p.SetRoutes(e.Group(""))
}
return nil
2019-12-02 14:31:00 +00:00
}