Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b4a65a1af4 | ||
|
|
65aeeda263 | ||
|
|
f61e014d2a | ||
| ce6a5c7477 | |||
|
|
f66f58f67f | ||
|
|
5f036dbc89 | ||
|
|
6394c8496d |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -1,5 +1,6 @@
|
||||
.direnv
|
||||
server.log
|
||||
shell.nix
|
||||
mem.go
|
||||
nxcaldav
|
||||
in/
|
||||
|
||||
59
config.yaml
59
config.yaml
@@ -3,74 +3,45 @@ database:
|
||||
server:
|
||||
bind_address: 0.0.0.0:14243
|
||||
default_class: CONFIDENTIAL
|
||||
public_url: http://nxc.nx2.site/
|
||||
email_domain: nx2.site
|
||||
public_url: http://example.com/
|
||||
email_domain: example.com
|
||||
redaction_text: '[-]'
|
||||
|
||||
smtp:
|
||||
host: localhost
|
||||
port: 587
|
||||
user: nxcaldav@nx2.site
|
||||
password: Vastly-Wrinkle9-Corsage
|
||||
password_cmd: echo "Vastly-Wrinkle9-Corsage"
|
||||
|
||||
users:
|
||||
- name: daniel
|
||||
password: ll
|
||||
- name: alice
|
||||
password: 123
|
||||
groups:
|
||||
- family
|
||||
- name: lennart
|
||||
password: ll
|
||||
- name: bob
|
||||
password: abc
|
||||
groups:
|
||||
- family
|
||||
- name: shared
|
||||
password: Oxidant-Ageless3-Dispersed
|
||||
|
||||
calendars:
|
||||
- id: preservation
|
||||
owner: lennart
|
||||
- id: test
|
||||
owner: alice
|
||||
color: '#F6F5F4'
|
||||
- id: effort
|
||||
owner: lennart
|
||||
color: '#FF0000'
|
||||
- id: experience
|
||||
owner: lennart
|
||||
color: '#2C33FF'
|
||||
- id: leisure
|
||||
owner: lennart
|
||||
color: '#10B400'
|
||||
- id: daniel
|
||||
owner: daniel
|
||||
color: '#ff2222'
|
||||
- access:
|
||||
- group: family
|
||||
mode: read-write
|
||||
id: family
|
||||
- id: family
|
||||
owner: shared
|
||||
color: '#999999'
|
||||
access:
|
||||
- group: family
|
||||
mode: read-write
|
||||
|
||||
address_books:
|
||||
- id: contacts
|
||||
owner: lennart
|
||||
- id: contacts
|
||||
owner: daniel
|
||||
owner: alice
|
||||
- id: family
|
||||
owner: shared
|
||||
owner: bob
|
||||
access:
|
||||
- group: family
|
||||
mode: read-write
|
||||
|
||||
aggregates:
|
||||
- access:
|
||||
- group: family
|
||||
mode: read-only
|
||||
- ics: future-only
|
||||
id: lennart-aggregat
|
||||
owner: lennart
|
||||
color: '#dd9999'
|
||||
sources:
|
||||
- preservation
|
||||
- effort
|
||||
- experience
|
||||
- leisure
|
||||
- family
|
||||
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
#!/usr/bin/env python3
|
||||
import os
|
||||
import argparse
|
||||
import psycopg2
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
#!/usr/bin/env python3
|
||||
import os
|
||||
import argparse
|
||||
import psycopg2
|
||||
|
||||
@@ -8,7 +8,6 @@ import (
|
||||
"log"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"os/exec"
|
||||
"path"
|
||||
"slices"
|
||||
"strings"
|
||||
@@ -140,16 +139,9 @@ func (b *DBBackend) initSchema(ctx context.Context) error {
|
||||
}
|
||||
|
||||
func (b *DBBackend) resolvePassword(u config.User) (string, error) {
|
||||
var raw string
|
||||
if u.PasswordCmd != "" {
|
||||
cmd := exec.Command("sh", "-c", u.PasswordCmd)
|
||||
out, err := cmd.Output()
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("failed to run password command for %s: %v", u.Name, err)
|
||||
}
|
||||
raw = strings.TrimSpace(string(out))
|
||||
} else {
|
||||
raw = u.Password
|
||||
raw, err := config.ResolvePassword(u.Password, u.PasswordCmd)
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("failed to resolve password for %s: %v", u.Name, err)
|
||||
}
|
||||
|
||||
// If it already looks like a bcrypt hash, return as is.
|
||||
|
||||
@@ -10,6 +10,7 @@ import (
|
||||
"strings"
|
||||
|
||||
"github.com/emersion/go-ical"
|
||||
"nxcaldav/internal/config"
|
||||
)
|
||||
|
||||
// sendInvitation sends an iMIP (RFC 6047) invitation email.
|
||||
@@ -99,8 +100,14 @@ func (b *DBBackend) sendInvitation(senderName, recipientEmail, summary, descript
|
||||
if err = c.StartTLS(tlsConfig); err != nil { return err }
|
||||
}
|
||||
}
|
||||
if b.smtp.User != "" && b.smtp.Password != "" {
|
||||
auth := smtp.PlainAuth("", b.smtp.User, b.smtp.Password, b.smtp.Host)
|
||||
|
||||
smtpPassword, err := config.ResolvePassword(b.smtp.Password, b.smtp.PasswordCmd)
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to resolve SMTP password: %v", err)
|
||||
}
|
||||
|
||||
if b.smtp.User != "" && smtpPassword != "" {
|
||||
auth := smtp.PlainAuth("", b.smtp.User, smtpPassword, b.smtp.Host)
|
||||
if err = c.Auth(auth); err != nil { return err }
|
||||
}
|
||||
|
||||
|
||||
@@ -1,8 +1,10 @@
|
||||
package config
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/url"
|
||||
"os"
|
||||
"os/exec"
|
||||
"slices"
|
||||
"strings"
|
||||
|
||||
@@ -64,10 +66,11 @@ func (s ServerConfig) BasePath() string {
|
||||
|
||||
|
||||
type SMTPConfig struct {
|
||||
Host string `yaml:"host"`
|
||||
Port int `yaml:"port"`
|
||||
User string `yaml:"user"`
|
||||
Password string `yaml:"password"`
|
||||
Host string `yaml:"host"`
|
||||
Port int `yaml:"port"`
|
||||
User string `yaml:"user"`
|
||||
Password string `yaml:"password"`
|
||||
PasswordCmd string `yaml:"password_cmd"`
|
||||
}
|
||||
|
||||
type Config struct {
|
||||
@@ -79,6 +82,18 @@ type Config struct {
|
||||
AddressBooks []AddressBook `yaml:"address_books"`
|
||||
Aggregates []Aggregate `yaml:"aggregates"`
|
||||
}
|
||||
|
||||
func ResolvePassword(password, passwordCmd string) (string, error) {
|
||||
if passwordCmd != "" {
|
||||
cmd := exec.Command("sh", "-c", passwordCmd)
|
||||
out, err := cmd.Output()
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("failed to run password command: %v", err)
|
||||
}
|
||||
return strings.TrimSpace(string(out)), nil
|
||||
}
|
||||
return password, nil
|
||||
}
|
||||
func (c *Config) setDefaults() {
|
||||
if c.Server.BindAddress == "" { c.Server.BindAddress = ":8080" }
|
||||
if c.Server.Redaction == "" { c.Server.Redaction = "Busy" }
|
||||
|
||||
@@ -6,7 +6,6 @@ import (
|
||||
"fmt"
|
||||
"context"
|
||||
"io"
|
||||
"log"
|
||||
"net/http"
|
||||
|
||||
"nxcaldav/internal/backend"
|
||||
|
||||
115
main.go
115
main.go
@@ -19,11 +19,9 @@ import (
|
||||
"nxcaldav/internal/extra"
|
||||
)
|
||||
|
||||
|
||||
|
||||
func main() {
|
||||
// -- GET CONFIG
|
||||
path := "config.yaml";
|
||||
path := "config.yaml"
|
||||
if len(os.Args) == 3 {
|
||||
if os.Args[1] == "-c" {
|
||||
path = os.Args[2]
|
||||
@@ -41,18 +39,18 @@ func main() {
|
||||
log.Fatalf("failed to initialize database backend: %v", err)
|
||||
}
|
||||
|
||||
|
||||
// -- GET CONTEXT AND DB
|
||||
caldavHandler := &caldav.Handler{Backend: be}
|
||||
carddavHandler := &carddav.Handler{Backend: be}
|
||||
publicURL, _ := url.Parse(cfg.Server.PublicURL)
|
||||
|
||||
|
||||
// -- DISCOVERIES
|
||||
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
|
||||
|
||||
scheme := r.URL.Scheme
|
||||
if scheme == "" { scheme = "http" }
|
||||
scheme := r.URL.Scheme
|
||||
if scheme == "" {
|
||||
scheme = "http"
|
||||
}
|
||||
|
||||
// set host (because reverse proxies exist)
|
||||
if publicURL != nil && publicURL.Host != "" {
|
||||
@@ -60,7 +58,7 @@ func main() {
|
||||
r.URL.Host = publicURL.Host
|
||||
|
||||
// prioritize X-Forwarded-Proto, then PublicURL (e.g. Cloudfalre proxy)
|
||||
scheme := publicURL.Scheme
|
||||
scheme = publicURL.Scheme
|
||||
if proto := r.Header.Get("X-Forwarded-Proto"); proto != "" {
|
||||
scheme = proto
|
||||
}
|
||||
@@ -103,67 +101,68 @@ func main() {
|
||||
return
|
||||
}
|
||||
|
||||
log.Printf("[user: %s] %s %s", user, r.Method, r.URL.Path)
|
||||
log.Printf("[user: %s] %s %s", user, r.Method, r.URL.Path)
|
||||
|
||||
principalPath := prefix + fmt.Sprintf("/%s/", user)
|
||||
ctx := context.WithValue(r.Context(), "principal", principalPath)
|
||||
principalPath := prefix + fmt.Sprintf("/%s/", user)
|
||||
ctx := context.WithValue(r.Context(), "principal", principalPath)
|
||||
|
||||
// set header for carddav
|
||||
// set header for carddav
|
||||
if slices.Contains([]string{
|
||||
"/.well-known/carddav",
|
||||
prefix + "/.well-known/carddav",
|
||||
principalPath,
|
||||
strings.TrimSuffix(principalPath, "/"),
|
||||
"/.well-known/carddav",
|
||||
prefix + "/.well-known/carddav",
|
||||
principalPath,
|
||||
strings.TrimSuffix(principalPath, "/"),
|
||||
}, r.URL.Path) || strings.Contains(r.URL.Path, "/addressbooks/") {
|
||||
w.Header().Add("DAV", "addressbook")
|
||||
w.Header().Add("DAV", "addressbook")
|
||||
}
|
||||
|
||||
// for caldav discovery
|
||||
if slices.Contains([]string{
|
||||
"/.well-known/caldav",
|
||||
prefix+"/.well-known/caldav",
|
||||
}, r.URL.Path) {
|
||||
http.Redirect(w, r, fmt.Sprintf( "%s://%s%s", scheme, r.Host, principalPath), http.StatusMovedPermanently)
|
||||
return
|
||||
}
|
||||
// for caldav discovery
|
||||
if slices.Contains([]string{
|
||||
"/.well-known/caldav",
|
||||
prefix + "/.well-known/caldav",
|
||||
}, r.URL.Path) {
|
||||
http.Redirect(w, r, fmt.Sprintf("%s://%s%s", scheme, r.Host, principalPath), http.StatusMovedPermanently)
|
||||
return
|
||||
}
|
||||
|
||||
// serve caldav
|
||||
if strings.Contains(r.URL.Path, "/calendars/") {
|
||||
if r.Method == "PROPFIND" {
|
||||
// Calendar colors
|
||||
// needed because color info is not RFC, so I hacked it in with regex, to look like Radicales response
|
||||
extra.InjectColor(r, ctx, caldavHandler, w, be)
|
||||
} else {
|
||||
caldavHandler.ServeHTTP(w, r.WithContext(ctx))
|
||||
}
|
||||
// serve caldav
|
||||
if strings.Contains(r.URL.Path, "/calendars/") {
|
||||
if r.Method == "PROPFIND" {
|
||||
// Calendar colors
|
||||
// needed because color info is not RFC, so I hacked it in with regex, to look like Radicales response
|
||||
extra.InjectColor(r, ctx, caldavHandler, w, be)
|
||||
} else {
|
||||
caldavHandler.ServeHTTP(w, r.WithContext(ctx))
|
||||
}
|
||||
|
||||
// serve carddav
|
||||
} else if strings.Contains(r.URL.Path, "/addressbooks/") {
|
||||
carddavHandler.ServeHTTP(w, r.WithContext(ctx))
|
||||
// serve carddav
|
||||
} else if strings.Contains(r.URL.Path, "/addressbooks/") {
|
||||
carddavHandler.ServeHTTP(w, r.WithContext(ctx))
|
||||
|
||||
// catch weird requests
|
||||
} else {
|
||||
// catch weird requests
|
||||
} else {
|
||||
|
||||
if strings.HasSuffix(r.URL.Path, user+"/") || strings.HasSuffix(r.URL.Path, user) {
|
||||
// For principal path, use merged discovery handler
|
||||
if r.Method == "PROPFIND" {
|
||||
extra.HandleDiscoveryPropfind(r, ctx, caldavHandler, w, be)
|
||||
} else {
|
||||
caldavHandler.ServeHTTP(w, r.WithContext(ctx))
|
||||
// Ensure DAV header includes addressbook for OPTIONS
|
||||
if r.Method == "OPTIONS" {
|
||||
dav := w.Header().Get("DAV")
|
||||
if dav != "" && !strings.Contains(dav, "addressbook") {
|
||||
w.Header().Set("DAV", dav+", addressbook")
|
||||
}
|
||||
}
|
||||
}
|
||||
} else {
|
||||
http.NotFound(w, r)
|
||||
}
|
||||
}
|
||||
if strings.HasSuffix(r.URL.Path, user+"/") || strings.HasSuffix(r.URL.Path, user) {
|
||||
// For principal path, use merged discovery handler
|
||||
if r.Method == "PROPFIND" {
|
||||
extra.HandleDiscoveryPropfind(r, ctx, caldavHandler, w, be)
|
||||
} else {
|
||||
caldavHandler.ServeHTTP(w, r.WithContext(ctx))
|
||||
// Ensure DAV header includes addressbook for OPTIONS
|
||||
if r.Method == "OPTIONS" {
|
||||
dav := w.Header().Get("DAV")
|
||||
if dav != "" && !strings.Contains(dav, "addressbook") {
|
||||
w.Header().Set("DAV", dav+", addressbook")
|
||||
}
|
||||
}
|
||||
}
|
||||
} else {
|
||||
http.NotFound(w, r)
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
fmt.Printf("Starting CalDAV/CardDAV server on %s...\n", cfg.Server.BindAddress)
|
||||
fmt.Printf("Starting CalDAV/CardDAV server on %s...\n", cfg.Server.BindAddress)
|
||||
server := &http.Server{
|
||||
Addr: cfg.Server.BindAddress,
|
||||
ReadTimeout: 30 * time.Second,
|
||||
|
||||
Reference in New Issue
Block a user