package alpscaldav import ( "fmt" "html/template" "net/http" "net/url" "time" "git.sr.ht/~emersion/alps" ) func sanityCheckURL(u *url.URL) error { req, err := http.NewRequest(http.MethodOptions, u.String(), nil) if err != nil { return err } resp, err := http.DefaultClient.Do(req) if err != nil { return err } resp.Body.Close() // Servers might require authentication to perform an OPTIONS request if resp.StatusCode/100 != 2 && resp.StatusCode != http.StatusUnauthorized { return fmt.Errorf("HTTP request failed: %v %v", resp.StatusCode, resp.Status) } return nil } func newPlugin(srv *alps.Server) (alps.Plugin, error) { u, err := srv.Upstream("caldavs", "caldav+insecure", "https", "http+insecure") if _, ok := err.(*alps.NoUpstreamError); ok { return nil, nil } else if err != nil { return nil, fmt.Errorf("caldav: failed to parse upstream caldav server: %v", err) } switch u.Scheme { case "caldavs": u.Scheme = "https" case "caldav+insecure", "http+insecure": u.Scheme = "http" } if u.Scheme == "" { // TODO err := fmt.Errorf("discovery not yet implemented") srv.Logger().Printf("caldav: failed to discover CalDAV server: %v", err) return nil, nil } if err := sanityCheckURL(u); err != nil { return nil, fmt.Errorf("caldav: failed to connect to CalDAV server %q: %v", u, err) } srv.Logger().Printf("Configured upstream CalDAV server: %v", u) p := alps.GoPlugin{Name: "caldav"} registerRoutes(&p, u) p.TemplateFuncs(template.FuncMap{ "formatinputdate": func(t time.Time) string { return t.Format("2006-01-02") }, "ornow": func(t time.Time) time.Time { if t.IsZero() { return time.Now() } return t }, }) return p.Plugin(), nil } func init() { alps.RegisterPluginLoader(func(s *alps.Server) ([]alps.Plugin, error) { p, err := newPlugin(s) if err != nil { return nil, err } if p == nil { return nil, nil } return []alps.Plugin{p}, err }) }