Start from scratch
This commit is contained in:
Simon Ser
@@ -1,35 +0,0 @@
|
||||
package carddav
|
||||
|
||||
// TODO: add context support
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"os"
|
||||
|
||||
"github.com/emersion/go-vcard"
|
||||
)
|
||||
|
||||
var (
|
||||
ErrNotFound = errors.New("carddav: not found")
|
||||
)
|
||||
|
||||
type AddressBookInfo struct {
|
||||
Name string
|
||||
Description string
|
||||
MaxResourceSize int
|
||||
}
|
||||
|
||||
type AddressObject interface {
|
||||
ID() string
|
||||
Stat() (os.FileInfo, error) // can return nil, nil
|
||||
Card() (vcard.Card, error)
|
||||
SetCard(vcard.Card) error
|
||||
Remove() error
|
||||
}
|
||||
|
||||
type AddressBook interface {
|
||||
Info() (*AddressBookInfo, error)
|
||||
GetAddressObject(id string) (AddressObject, error)
|
||||
ListAddressObjects() ([]AddressObject, error)
|
||||
CreateAddressObject(vcard.Card) (AddressObject, error)
|
||||
}
|
||||
@@ -1,193 +0,0 @@
|
||||
// Package carddav provides a CardDAV server implementation, as defined in
|
||||
// RFC 6352.
|
||||
package carddav
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"encoding/xml"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"os"
|
||||
|
||||
"github.com/emersion/go-vcard"
|
||||
"github.com/emersion/go-webdav"
|
||||
"golang.org/x/net/context"
|
||||
|
||||
"log"
|
||||
)
|
||||
|
||||
var addressDataName = xml.Name{Space: "urn:ietf:params:xml:ns:carddav", Local: "address-data"}
|
||||
|
||||
type responseWriter struct {
|
||||
http.ResponseWriter
|
||||
}
|
||||
|
||||
func (w responseWriter) Write(b []byte) (int, error) {
|
||||
return w.ResponseWriter.Write(b)
|
||||
}
|
||||
|
||||
type Handler struct {
|
||||
ab AddressBook
|
||||
webdav *webdav.Handler
|
||||
}
|
||||
|
||||
func NewHandler(ab AddressBook) *Handler {
|
||||
return &Handler{
|
||||
ab: ab,
|
||||
webdav: &webdav.Handler{
|
||||
FileSystem: &fileSystem{ab},
|
||||
Logger: func(req *http.Request, err error) {
|
||||
if err != nil {
|
||||
log.Println("ERROR", req, err)
|
||||
}
|
||||
},
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
||||
if r.Method == http.MethodOptions {
|
||||
w.Header().Add("DAV", "addressbook")
|
||||
}
|
||||
|
||||
w = responseWriter{w}
|
||||
switch r.Method {
|
||||
case "REPORT":
|
||||
code, err := h.handleReport(w, r)
|
||||
if err != nil {
|
||||
if code == 0 {
|
||||
code = http.StatusInternalServerError
|
||||
}
|
||||
http.Error(w, err.Error(), code)
|
||||
}
|
||||
case "OPTIONS":
|
||||
w.Header().Add("Allow", "REPORT")
|
||||
fallthrough
|
||||
default:
|
||||
h.webdav.ServeHTTP(w, r)
|
||||
}
|
||||
}
|
||||
|
||||
func (h *Handler) handleReport(w http.ResponseWriter, r *http.Request) (int, error) {
|
||||
var mg addressbookMultiget
|
||||
if err := xml.NewDecoder(r.Body).Decode(&mg); err != nil {
|
||||
return http.StatusBadRequest, err
|
||||
}
|
||||
|
||||
mw := webdav.NewMultistatusWriter(w)
|
||||
defer mw.Close()
|
||||
|
||||
if len(mg.Href) == 0 {
|
||||
mg.Href = []string{r.URL.Path}
|
||||
}
|
||||
for _, href := range mg.Href {
|
||||
pstats, status, err := multiget(r.Context(), h.webdav.FileSystem, h.webdav.LockSystem, href, []xml.Name(mg.Prop), mg.Allprop != nil)
|
||||
if err != nil {
|
||||
return status, err
|
||||
}
|
||||
|
||||
resp := &webdav.Response{
|
||||
Href: []string{(&url.URL{Path: href}).EscapedPath()},
|
||||
Status: status,
|
||||
Propstat: pstats,
|
||||
}
|
||||
|
||||
if err := mw.Write(resp); err != nil {
|
||||
return 0, err
|
||||
}
|
||||
}
|
||||
|
||||
return 0, nil
|
||||
}
|
||||
|
||||
func multiget(ctx context.Context, fs webdav.FileSystem, ls webdav.LockSystem, name string, pnames []xml.Name, allprop bool) ([]webdav.Propstat, int, error) {
|
||||
wantAddressData := false
|
||||
for i, pname := range pnames {
|
||||
if pname == addressDataName {
|
||||
pnames = append(pnames[:i], pnames[i+1:]...)
|
||||
wantAddressData = true
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
var pstats []webdav.Propstat
|
||||
var err error
|
||||
if allprop {
|
||||
wantAddressData = true
|
||||
pstats, err = webdav.Allprop(ctx, fs, ls, name, pnames)
|
||||
} else {
|
||||
pstats, err = webdav.Props(ctx, fs, ls, name, pnames)
|
||||
}
|
||||
if err != nil {
|
||||
return pstats, 0, err
|
||||
}
|
||||
|
||||
// TODO: locking stuff
|
||||
|
||||
f, err := fs.OpenFile(ctx, name, os.O_RDONLY, 0)
|
||||
if err != nil {
|
||||
return nil, http.StatusNotFound, err
|
||||
}
|
||||
defer f.Close()
|
||||
fi, err := f.Stat()
|
||||
if err != nil {
|
||||
return nil, http.StatusNotFound, err
|
||||
}
|
||||
|
||||
if wantAddressData {
|
||||
if fi.IsDir() {
|
||||
// TODO
|
||||
return nil, http.StatusNotFound, err
|
||||
}
|
||||
|
||||
prop, status, err := addressdata(f.(*file).ao)
|
||||
if err != nil {
|
||||
return nil, status, err
|
||||
}
|
||||
if status == 0 {
|
||||
status = http.StatusOK
|
||||
}
|
||||
|
||||
inserted := false
|
||||
for i, pstat := range pstats {
|
||||
if pstat.Status == status {
|
||||
pstats[i].Props = append(pstat.Props, prop)
|
||||
inserted = true
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
if !inserted {
|
||||
pstats = append(pstats, webdav.Propstat{
|
||||
Props: []webdav.Property{prop},
|
||||
Status: status,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
return pstats, 0, nil
|
||||
}
|
||||
|
||||
func addressdata(ao AddressObject) (webdav.Property, int, error) {
|
||||
prop := webdav.Property{XMLName: addressDataName}
|
||||
|
||||
card, err := ao.Card()
|
||||
if err != nil {
|
||||
return prop, 0, err
|
||||
}
|
||||
|
||||
// TODO: restrict to requested props
|
||||
|
||||
var b bytes.Buffer
|
||||
if err := vcard.NewEncoder(&b).Encode(card); err != nil {
|
||||
return prop, 0, err
|
||||
}
|
||||
|
||||
var escaped bytes.Buffer
|
||||
if err := xml.EscapeText(&escaped, b.Bytes()); err != nil {
|
||||
return prop, 0, err
|
||||
}
|
||||
|
||||
prop.InnerXML = escaped.Bytes()
|
||||
return prop, 0, nil
|
||||
}
|
||||
408
carddav/fs.go
408
carddav/fs.go
@@ -1,408 +0,0 @@
|
||||
package carddav
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"encoding/xml"
|
||||
"errors"
|
||||
"os"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/emersion/go-vcard"
|
||||
"github.com/emersion/go-webdav"
|
||||
"golang.org/x/net/context"
|
||||
)
|
||||
|
||||
var (
|
||||
errNotYetImplemented = errors.New("not yet implemented")
|
||||
errUnsupported = errors.New("unsupported")
|
||||
)
|
||||
|
||||
const nsDAV = "DAV:"
|
||||
|
||||
var (
|
||||
resourcetype = xml.Name{Space: nsDAV, Local: "resourcetype"}
|
||||
displayname = xml.Name{Space: nsDAV, Local: "displayname"}
|
||||
getcontenttype = xml.Name{Space: nsDAV, Local: "getcontenttype"}
|
||||
)
|
||||
|
||||
const nsCardDAV = "urn:ietf:params:xml:ns:carddav"
|
||||
|
||||
var (
|
||||
addressBookDescription = xml.Name{Space: nsCardDAV, Local: "addressbook-description"}
|
||||
addressBookSupportedAddressData = xml.Name{Space: nsCardDAV, Local: "supported-address-data"}
|
||||
addressBookMaxResourceSize = xml.Name{Space: nsCardDAV, Local: "max-resource-size"}
|
||||
addressBookHomeSet = xml.Name{Space: nsCardDAV, Local: "addressbook-home-set"}
|
||||
)
|
||||
|
||||
func addressObjectName(ao AddressObject) string {
|
||||
return ao.ID()
|
||||
}
|
||||
|
||||
type fileInfo struct {
|
||||
name string
|
||||
size int64
|
||||
mode os.FileMode
|
||||
modTime time.Time
|
||||
}
|
||||
|
||||
func addressObjectFileInfo(ao AddressObject) *fileInfo {
|
||||
return &fileInfo{
|
||||
name: addressObjectName(ao),
|
||||
mode: os.ModePerm,
|
||||
}
|
||||
}
|
||||
|
||||
func (fi *fileInfo) Name() string {
|
||||
return fi.name
|
||||
}
|
||||
|
||||
func (fi *fileInfo) Size() int64 {
|
||||
return fi.size
|
||||
}
|
||||
|
||||
func (fi *fileInfo) Mode() os.FileMode {
|
||||
return fi.mode
|
||||
}
|
||||
|
||||
func (fi *fileInfo) ModTime() time.Time {
|
||||
return fi.modTime
|
||||
}
|
||||
|
||||
func (fi *fileInfo) IsDir() bool {
|
||||
return fi.mode.IsDir()
|
||||
}
|
||||
|
||||
func (fi *fileInfo) Sys() interface{} {
|
||||
return nil
|
||||
}
|
||||
|
||||
type file struct {
|
||||
r *bytes.Reader
|
||||
w *bytes.Buffer
|
||||
fs *fileSystem
|
||||
ao AddressObject
|
||||
}
|
||||
|
||||
func (f *file) Close() error {
|
||||
if f.w != nil {
|
||||
defer func() {
|
||||
f.w = nil
|
||||
}()
|
||||
|
||||
card, err := vcard.NewDecoder(f.w).Decode()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := f.ao.SetCard(card); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
f.r = nil
|
||||
return nil
|
||||
}
|
||||
|
||||
func (f *file) Read(b []byte) (int, error) {
|
||||
if f.r == nil {
|
||||
card, err := f.ao.Card()
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
var b bytes.Buffer
|
||||
if err := vcard.NewEncoder(&b).Encode(card); err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
f.r = bytes.NewReader(b.Bytes())
|
||||
}
|
||||
|
||||
return f.r.Read(b)
|
||||
}
|
||||
|
||||
func (f *file) Write(b []byte) (int, error) {
|
||||
if f.w == nil {
|
||||
f.w = &bytes.Buffer{}
|
||||
}
|
||||
return f.w.Write(b)
|
||||
}
|
||||
|
||||
func (f *file) Seek(offset int64, whence int) (int64, error) {
|
||||
if f.r == nil {
|
||||
if _, err := f.Read(nil); err != nil {
|
||||
return 0, err
|
||||
}
|
||||
}
|
||||
|
||||
return f.r.Seek(offset, whence)
|
||||
}
|
||||
|
||||
func (f *file) Readdir(count int) ([]os.FileInfo, error) {
|
||||
return nil, errUnsupported
|
||||
}
|
||||
|
||||
func (f *file) Stat() (os.FileInfo, error) {
|
||||
info, err := f.ao.Stat()
|
||||
if info != nil || err != nil {
|
||||
return info, err
|
||||
}
|
||||
return addressObjectFileInfo(f.ao), nil
|
||||
}
|
||||
|
||||
func (f *file) DeadProps() (map[xml.Name]webdav.Property, error) {
|
||||
return map[xml.Name]webdav.Property{
|
||||
getcontenttype: webdav.Property{
|
||||
XMLName: getcontenttype,
|
||||
InnerXML: []byte(vcard.MIMEType),
|
||||
},
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (f *file) Patch([]webdav.Proppatch) ([]webdav.Propstat, error) {
|
||||
return nil, errUnsupported
|
||||
}
|
||||
|
||||
type newFile struct {
|
||||
buf bytes.Buffer
|
||||
fs *fileSystem
|
||||
ao AddressObject
|
||||
}
|
||||
|
||||
func (f *newFile) Close() error {
|
||||
if f.ao == nil {
|
||||
defer f.buf.Reset()
|
||||
|
||||
card, err := vcard.NewDecoder(&f.buf).Decode()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
ao, err := f.fs.ab.CreateAddressObject(card)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
f.ao = ao
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (f *newFile) Read(b []byte) (int, error) {
|
||||
return 0, errUnsupported
|
||||
}
|
||||
|
||||
func (f *newFile) Write(b []byte) (int, error) {
|
||||
// TODO: limit amount of data in f.buf
|
||||
if f.ao != nil {
|
||||
return 0, errUnsupported
|
||||
}
|
||||
|
||||
return f.buf.Write(b)
|
||||
}
|
||||
|
||||
func (f *newFile) Seek(offset int64, whence int) (int64, error) {
|
||||
return 0, errUnsupported
|
||||
}
|
||||
|
||||
func (f *newFile) Readdir(count int) ([]os.FileInfo, error) {
|
||||
return nil, errUnsupported
|
||||
}
|
||||
|
||||
func (f *newFile) Stat() (os.FileInfo, error) {
|
||||
// Only available after a successful call to Close
|
||||
if f.ao == nil {
|
||||
return nil, errUnsupported
|
||||
}
|
||||
|
||||
info, err := f.ao.Stat()
|
||||
if info != nil || err != nil {
|
||||
return info, err
|
||||
}
|
||||
return addressObjectFileInfo(f.ao), nil
|
||||
}
|
||||
|
||||
type dir struct {
|
||||
fs *fileSystem
|
||||
name string
|
||||
files []os.FileInfo
|
||||
|
||||
n int
|
||||
}
|
||||
|
||||
func (d *dir) Close() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (d *dir) Read(b []byte) (int, error) {
|
||||
return 0, errUnsupported
|
||||
}
|
||||
|
||||
func (d *dir) Write(b []byte) (int, error) {
|
||||
return 0, errUnsupported
|
||||
}
|
||||
|
||||
func (d *dir) Seek(offset int64, whence int) (int64, error) {
|
||||
return 0, errUnsupported
|
||||
}
|
||||
|
||||
func (d *dir) Readdir(count int) ([]os.FileInfo, error) {
|
||||
if d.files == nil {
|
||||
aos, err := d.fs.ab.ListAddressObjects()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
d.files = make([]os.FileInfo, len(aos))
|
||||
for i, ao := range aos {
|
||||
d.files[i] = addressObjectFileInfo(ao)
|
||||
}
|
||||
}
|
||||
|
||||
if count == 0 {
|
||||
count = len(d.files) - d.n
|
||||
}
|
||||
if d.n >= len(d.files) {
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
from := d.n
|
||||
d.n += count
|
||||
if d.n > len(d.files) {
|
||||
d.n = len(d.files)
|
||||
}
|
||||
|
||||
return d.files[from:d.n], nil
|
||||
}
|
||||
|
||||
func (d *dir) Stat() (os.FileInfo, error) {
|
||||
return &fileInfo{
|
||||
name: d.name,
|
||||
mode: os.ModeDir | os.ModePerm,
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (d *dir) DeadProps() (map[xml.Name]webdav.Property, error) {
|
||||
info, err := d.fs.ab.Info()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return map[xml.Name]webdav.Property{
|
||||
resourcetype: webdav.Property{
|
||||
XMLName: resourcetype,
|
||||
InnerXML: []byte(`<collection xmlns="DAV:"/><addressbook xmlns="urn:ietf:params:xml:ns:carddav"/>`),
|
||||
},
|
||||
displayname: webdav.Property{
|
||||
XMLName: displayname,
|
||||
InnerXML: []byte(info.Name),
|
||||
},
|
||||
addressBookDescription: webdav.Property{
|
||||
XMLName: addressBookDescription,
|
||||
InnerXML: []byte(info.Description),
|
||||
},
|
||||
addressBookSupportedAddressData: webdav.Property{
|
||||
XMLName: addressBookSupportedAddressData,
|
||||
InnerXML: []byte(`<address-data-type xmlns="urn:ietf:params:xml:ns:carddav" content-type="text/vcard" version="3.0"/>` +
|
||||
`<address-data-type xmlns="urn:ietf:params:xml:ns:carddav" content-type="text/vcard" version="4.0"/>`),
|
||||
},
|
||||
addressBookMaxResourceSize: webdav.Property{
|
||||
XMLName: addressBookMaxResourceSize,
|
||||
InnerXML: []byte(strconv.Itoa(info.MaxResourceSize)),
|
||||
},
|
||||
addressBookHomeSet: webdav.Property{
|
||||
XMLName: addressBookHomeSet,
|
||||
InnerXML: []byte(`<href xmlns="DAV:">/</href>`),
|
||||
},
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (d *dir) Patch([]webdav.Proppatch) ([]webdav.Propstat, error) {
|
||||
return nil, errUnsupported
|
||||
}
|
||||
|
||||
type fileSystem struct {
|
||||
ab AddressBook
|
||||
}
|
||||
|
||||
func (fs *fileSystem) Mkdir(ctx context.Context, name string, perm os.FileMode) error {
|
||||
return errNotYetImplemented
|
||||
}
|
||||
|
||||
func (fs *fileSystem) addressObjectID(name string) string {
|
||||
return strings.TrimLeft(name, "/")
|
||||
}
|
||||
|
||||
func (fs *fileSystem) OpenFile(ctx context.Context, name string, flag int, perm os.FileMode) (webdav.File, error) {
|
||||
if name == "/" {
|
||||
return &dir{
|
||||
fs: fs,
|
||||
name: name,
|
||||
}, nil
|
||||
}
|
||||
|
||||
id := fs.addressObjectID(name)
|
||||
ao, err := fs.ab.GetAddressObject(id)
|
||||
if err == ErrNotFound && flag & os.O_CREATE != 0 {
|
||||
return &newFile{fs: fs}, nil
|
||||
} else if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
f := &file{
|
||||
fs: fs,
|
||||
ao: ao,
|
||||
}
|
||||
|
||||
if flag&os.O_RDONLY != 0 {
|
||||
// This file will be read, cache its contents
|
||||
if _, err := f.Read(nil); err != nil {
|
||||
return f, err
|
||||
}
|
||||
}
|
||||
|
||||
return f, nil
|
||||
}
|
||||
|
||||
func (fs *fileSystem) RemoveAll(ctx context.Context, name string) error {
|
||||
if name == "/" {
|
||||
return errUnsupported
|
||||
}
|
||||
|
||||
id := fs.addressObjectID(name)
|
||||
ao, err := fs.ab.GetAddressObject(id)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return ao.Remove()
|
||||
}
|
||||
|
||||
func (fs *fileSystem) Rename(ctx context.Context, oldName, newName string) error {
|
||||
return errNotYetImplemented
|
||||
}
|
||||
|
||||
func (fs *fileSystem) Stat(ctx context.Context, name string) (os.FileInfo, error) {
|
||||
if name == "/" {
|
||||
return &fileInfo{
|
||||
name: name,
|
||||
mode: os.ModeDir | os.ModePerm,
|
||||
}, nil
|
||||
}
|
||||
|
||||
id := fs.addressObjectID(name)
|
||||
ao, err := fs.ab.GetAddressObject(id)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
info, err := ao.Stat()
|
||||
if info != nil || err != nil {
|
||||
return info, err
|
||||
}
|
||||
|
||||
return addressObjectFileInfo(ao), nil
|
||||
}
|
||||
@@ -1,24 +0,0 @@
|
||||
package carddav
|
||||
|
||||
import (
|
||||
"encoding/xml"
|
||||
|
||||
"github.com/emersion/go-webdav"
|
||||
)
|
||||
|
||||
// https://tools.ietf.org/html/rfc6352#section-10.7
|
||||
type addressbookMultiget struct {
|
||||
XMLName xml.Name `xml:"urn:ietf:params:xml:ns:carddav addressbook-multiget"`
|
||||
Allprop *struct{} `xml:"DAV: allprop"`
|
||||
Propname *struct{} `xml:"DAV: propname"`
|
||||
Prop webdav.PropfindProps `xml:"DAV: prop"`
|
||||
Href []string `xml:"DAV: href"`
|
||||
}
|
||||
|
||||
// TODO
|
||||
type addressData struct {
|
||||
XMLName xml.Name `xml:"urn:ietf:params:xml:ns:carddav address-data"`
|
||||
ContentType string `xml:"content-type,attr"`
|
||||
Version string `xml:"version,attr"`
|
||||
Prop []string `xml:"prop>name,attr"`
|
||||
}
|
||||
Reference in New Issue
Block a user