mirror of
https://github.com/1f349/go-webdav.git
synced 2024-12-22 16:24:14 +00:00
485 lines
12 KiB
Go
485 lines
12 KiB
Go
package carddav
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"mime"
|
|
"net"
|
|
"net/http"
|
|
"net/url"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/emersion/go-vcard"
|
|
"github.com/emersion/go-webdav"
|
|
"github.com/emersion/go-webdav/internal"
|
|
)
|
|
|
|
// Discover performs a DNS-based CardDAV service discovery as described in
|
|
// RFC 6352 section 11. It returns the URL to the CardDAV server.
|
|
func Discover(domain string) (string, error) {
|
|
// Only lookup carddavs (not carddav), plaintext connections are insecure
|
|
_, addrs, err := net.LookupSRV("carddavs", "tcp", domain)
|
|
if dnsErr, ok := err.(*net.DNSError); ok {
|
|
if dnsErr.IsTemporary {
|
|
return "", err
|
|
}
|
|
} else if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
if len(addrs) == 0 {
|
|
return "", fmt.Errorf("carddav: domain doesn't have an SRV record")
|
|
}
|
|
addr := addrs[0]
|
|
|
|
target := strings.TrimSuffix(addr.Target, ".")
|
|
if target == "" {
|
|
return "", fmt.Errorf("carddav: empty target in SRV record")
|
|
}
|
|
|
|
u := url.URL{Scheme: "https"}
|
|
if addr.Port == 443 {
|
|
u.Host = target
|
|
} else {
|
|
u.Host = fmt.Sprintf("%v:%v", target, addr.Port)
|
|
}
|
|
return u.String(), nil
|
|
}
|
|
|
|
// Client provides access to a remote CardDAV server.
|
|
type Client struct {
|
|
*webdav.Client
|
|
|
|
ic *internal.Client
|
|
}
|
|
|
|
func NewClient(c webdav.HTTPClient, endpoint string) (*Client, error) {
|
|
wc, err := webdav.NewClient(c, endpoint)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
ic, err := internal.NewClient(c, endpoint)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &Client{wc, ic}, nil
|
|
}
|
|
|
|
func (c *Client) HasSupport() error {
|
|
classes, _, err := c.ic.Options("")
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if !classes["addressbook"] {
|
|
return fmt.Errorf("carddav: server doesn't support the DAV addressbook class")
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (c *Client) FindAddressBookHomeSet(principal string) (string, error) {
|
|
propfind := internal.NewPropNamePropfind(addressBookHomeSetName)
|
|
resp, err := c.ic.PropfindFlat(principal, propfind)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
var prop addressbookHomeSet
|
|
if err := resp.DecodeProp(&prop); err != nil {
|
|
return "", err
|
|
}
|
|
|
|
return prop.Href.Path, nil
|
|
}
|
|
|
|
func decodeSupportedAddressData(supported *supportedAddressData) []AddressDataType {
|
|
l := make([]AddressDataType, len(supported.Types))
|
|
for i, t := range supported.Types {
|
|
l[i] = AddressDataType{t.ContentType, t.Version}
|
|
}
|
|
return l
|
|
}
|
|
|
|
func (c *Client) FindAddressBooks(addressBookHomeSet string) ([]AddressBook, error) {
|
|
propfind := internal.NewPropNamePropfind(
|
|
internal.ResourceTypeName,
|
|
internal.DisplayNameName,
|
|
addressBookDescriptionName,
|
|
maxResourceSizeName,
|
|
supportedAddressDataName,
|
|
)
|
|
ms, err := c.ic.Propfind(addressBookHomeSet, internal.DepthOne, propfind)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
l := make([]AddressBook, 0, len(ms.Responses))
|
|
for _, resp := range ms.Responses {
|
|
path, err := resp.Path()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var resType internal.ResourceType
|
|
if err := resp.DecodeProp(&resType); err != nil {
|
|
return nil, err
|
|
}
|
|
if !resType.Is(addressBookName) {
|
|
continue
|
|
}
|
|
|
|
var desc addressbookDescription
|
|
if err := resp.DecodeProp(&desc); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
var dispName internal.DisplayName
|
|
if err := resp.DecodeProp(&dispName); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
var maxResSize maxResourceSize
|
|
if err := resp.DecodeProp(&maxResSize); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
if maxResSize.Size < 0 {
|
|
return nil, fmt.Errorf("carddav: max-resource-size must be a positive integer")
|
|
}
|
|
|
|
var supported supportedAddressData
|
|
if err := resp.DecodeProp(&supported); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
l = append(l, AddressBook{
|
|
Path: path,
|
|
Name: dispName.Name,
|
|
Description: desc.Description,
|
|
MaxResourceSize: maxResSize.Size,
|
|
SupportedAddressData: decodeSupportedAddressData(&supported),
|
|
})
|
|
}
|
|
|
|
return l, nil
|
|
}
|
|
|
|
func encodeAddressPropReq(req *AddressDataRequest) (*internal.Prop, error) {
|
|
var addrDataReq addressDataReq
|
|
if req.AllProp {
|
|
addrDataReq.Allprop = &struct{}{}
|
|
} else {
|
|
for _, name := range req.Props {
|
|
addrDataReq.Props = append(addrDataReq.Props, prop{Name: name})
|
|
}
|
|
}
|
|
|
|
getLastModReq := internal.NewRawXMLElement(internal.GetLastModifiedName, nil, nil)
|
|
getETagReq := internal.NewRawXMLElement(internal.GetETagName, nil, nil)
|
|
return internal.EncodeProp(&addrDataReq, getLastModReq, getETagReq)
|
|
}
|
|
|
|
func encodePropFilter(pf *PropFilter) (*propFilter, error) {
|
|
el := &propFilter{Name: pf.Name, Test: filterTest(pf.Test)}
|
|
if pf.IsNotDefined {
|
|
if len(pf.TextMatches) > 0 || len(pf.Params) > 0 {
|
|
return nil, fmt.Errorf("carddav: failed to encode PropFilter: IsNotDefined cannot be set with TextMatches or Params")
|
|
}
|
|
el.IsNotDefined = &struct{}{}
|
|
}
|
|
for _, tm := range pf.TextMatches {
|
|
el.TextMatches = append(el.TextMatches, *encodeTextMatch(&tm))
|
|
}
|
|
for _, param := range pf.Params {
|
|
paramEl, err := encodeParamFilter(¶m)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
el.Params = append(el.Params, *paramEl)
|
|
}
|
|
return el, nil
|
|
}
|
|
|
|
func encodeParamFilter(pf *ParamFilter) (*paramFilter, error) {
|
|
el := ¶mFilter{Name: pf.Name}
|
|
if pf.IsNotDefined {
|
|
if pf.TextMatch != nil {
|
|
return nil, fmt.Errorf("carddav: failed to encode ParamFilter: only one of IsNotDefined or TextMatch can be set")
|
|
}
|
|
el.IsNotDefined = &struct{}{}
|
|
}
|
|
if pf.TextMatch != nil {
|
|
el.TextMatch = encodeTextMatch(pf.TextMatch)
|
|
}
|
|
return el, nil
|
|
}
|
|
|
|
func encodeTextMatch(tm *TextMatch) *textMatch {
|
|
return &textMatch{
|
|
Text: tm.Text,
|
|
NegateCondition: negateCondition(tm.NegateCondition),
|
|
MatchType: matchType(tm.MatchType),
|
|
}
|
|
}
|
|
|
|
func decodeAddressList(ms *internal.Multistatus) ([]AddressObject, error) {
|
|
addrs := make([]AddressObject, 0, len(ms.Responses))
|
|
for _, resp := range ms.Responses {
|
|
path, err := resp.Path()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var addrData addressDataResp
|
|
if err := resp.DecodeProp(&addrData); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var getLastMod internal.GetLastModified
|
|
if err := resp.DecodeProp(&getLastMod); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
var getETag internal.GetETag
|
|
if err := resp.DecodeProp(&getETag); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
r := bytes.NewReader(addrData.Data)
|
|
card, err := vcard.NewDecoder(r).Decode()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
addrs = append(addrs, AddressObject{
|
|
Path: path,
|
|
ModTime: time.Time(getLastMod.LastModified),
|
|
ETag: string(getETag.ETag),
|
|
Card: card,
|
|
})
|
|
}
|
|
|
|
return addrs, nil
|
|
}
|
|
|
|
func (c *Client) QueryAddressBook(addressBook string, query *AddressBookQuery) ([]AddressObject, error) {
|
|
propReq, err := encodeAddressPropReq(&query.DataRequest)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
addressbookQuery := addressbookQuery{Prop: propReq}
|
|
addressbookQuery.Filter.Test = filterTest(query.FilterTest)
|
|
for _, pf := range query.PropFilters {
|
|
el, err := encodePropFilter(&pf)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
addressbookQuery.Filter.Props = append(addressbookQuery.Filter.Props, *el)
|
|
}
|
|
if query.Limit > 0 {
|
|
addressbookQuery.Limit = &limit{NResults: uint(query.Limit)}
|
|
}
|
|
|
|
req, err := c.ic.NewXMLRequest("REPORT", addressBook, &addressbookQuery)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req.Header.Add("Depth", "1")
|
|
|
|
ms, err := c.ic.DoMultiStatus(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return decodeAddressList(ms)
|
|
}
|
|
|
|
func (c *Client) MultiGetAddressBook(path string, multiGet *AddressBookMultiGet) ([]AddressObject, error) {
|
|
propReq, err := encodeAddressPropReq(&multiGet.DataRequest)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
addressbookMultiget := addressbookMultiget{Prop: propReq}
|
|
|
|
if multiGet == nil || len(multiGet.Paths) == 0 {
|
|
href := internal.Href{Path: path}
|
|
addressbookMultiget.Hrefs = []internal.Href{href}
|
|
} else {
|
|
addressbookMultiget.Hrefs = make([]internal.Href, len(multiGet.Paths))
|
|
for i, p := range multiGet.Paths {
|
|
addressbookMultiget.Hrefs[i] = internal.Href{Path: p}
|
|
}
|
|
}
|
|
|
|
req, err := c.ic.NewXMLRequest("REPORT", path, &addressbookMultiget)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req.Header.Add("Depth", "1")
|
|
|
|
ms, err := c.ic.DoMultiStatus(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return decodeAddressList(ms)
|
|
}
|
|
|
|
func populateAddressObject(ao *AddressObject, resp *http.Response) error {
|
|
if loc := resp.Header.Get("Location"); loc != "" {
|
|
u, err := url.Parse(loc)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
ao.Path = u.Path
|
|
}
|
|
if etag := resp.Header.Get("ETag"); etag != "" {
|
|
etag, err := strconv.Unquote(etag)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
ao.ETag = etag
|
|
}
|
|
if lastModified := resp.Header.Get("Last-Modified"); lastModified != "" {
|
|
t, err := http.ParseTime(lastModified)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
ao.ModTime = t
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *Client) GetAddressObject(path string) (*AddressObject, error) {
|
|
req, err := c.ic.NewRequest(http.MethodGet, path, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
req.Header.Set("Accept", vcard.MIMEType)
|
|
|
|
resp, err := c.ic.Do(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
mediaType, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type"))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if !strings.EqualFold(mediaType, vcard.MIMEType) {
|
|
return nil, fmt.Errorf("carddav: expected Content-Type %q, got %q", vcard.MIMEType, mediaType)
|
|
}
|
|
|
|
card, err := vcard.NewDecoder(resp.Body).Decode()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
ao := &AddressObject{
|
|
Path: resp.Request.URL.Path,
|
|
Card: card,
|
|
}
|
|
if err := populateAddressObject(ao, resp); err != nil {
|
|
return nil, err
|
|
}
|
|
return ao, nil
|
|
}
|
|
|
|
func (c *Client) PutAddressObject(path string, card vcard.Card) (*AddressObject, error) {
|
|
// TODO: add support for If-None-Match and If-Match
|
|
|
|
// TODO: some servers want a Content-Length header, so we can't stream the
|
|
// request body here. See the Radicale issue:
|
|
// https://github.com/Kozea/Radicale/issues/1016
|
|
|
|
//pr, pw := io.Pipe()
|
|
//go func() {
|
|
// err := vcard.NewEncoder(pw).Encode(card)
|
|
// pw.CloseWithError(err)
|
|
//}()
|
|
|
|
var buf bytes.Buffer
|
|
if err := vcard.NewEncoder(&buf).Encode(card); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req, err := c.ic.NewRequest(http.MethodPut, path, &buf)
|
|
if err != nil {
|
|
//pr.Close()
|
|
return nil, err
|
|
}
|
|
req.Header.Set("Content-Type", vcard.MIMEType)
|
|
|
|
resp, err := c.ic.Do(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
resp.Body.Close()
|
|
|
|
ao := &AddressObject{Path: path}
|
|
if err := populateAddressObject(ao, resp); err != nil {
|
|
return nil, err
|
|
}
|
|
return ao, nil
|
|
}
|
|
|
|
// SyncCollection do a sync-collection operation on resource(path), it returns a SyncResponse
|
|
func (c *Client) SyncCollection(path string, query *SyncQuery) (*SyncResponse, error) {
|
|
var limit *internal.Limit
|
|
if query.Limit > 0 {
|
|
limit = &internal.Limit{NResults: uint(query.Limit)}
|
|
}
|
|
|
|
propReq, err := encodeAddressPropReq(&query.DataRequest)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
ms, err := c.ic.SyncCollection(path, query.SyncToken, internal.DepthOne, limit, propReq)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
ret := &SyncResponse{SyncToken: ms.SyncToken}
|
|
for _, resp := range ms.Responses {
|
|
p, err := resp.Path()
|
|
if err != nil {
|
|
if err, ok := err.(*internal.HTTPError); ok && err.Code == http.StatusNotFound {
|
|
ret.Deleted = append(ret.Deleted, p)
|
|
continue
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
if p == path || path == fmt.Sprintf("%s/", p) {
|
|
continue
|
|
}
|
|
|
|
var getLastMod internal.GetLastModified
|
|
if err := resp.DecodeProp(&getLastMod); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
var getETag internal.GetETag
|
|
if err := resp.DecodeProp(&getETag); err != nil && !internal.IsNotFound(err) {
|
|
return nil, err
|
|
}
|
|
|
|
o := AddressObject{
|
|
Path: p,
|
|
ModTime: time.Time(getLastMod.LastModified),
|
|
ETag: string(getETag.ETag),
|
|
}
|
|
ret.Updated = append(ret.Updated, o)
|
|
}
|
|
|
|
return ret, nil
|
|
}
|