Method Open

server/resource/caldav_filesystem.go:103–156

Open opens a file for reading Pattern: Direct SQL query - CalDAV stores raw iCalendar content, not file references Note: ForeignKeyData is configured on the column but CalDAV bypasses the JSON API file format

(name string)

// Pattern: Direct SQL query - CalDAV stores raw iCalendar content, not file references
// Note: ForeignKeyData is configured on the column but CalDAV bypasses the JSON API file format
func (dcfs *DaptinCaldavFileSystem) Open(name string) (io.ReadCloser, error) {
	userID, collectionName, resourceName, isRoot, isUserRoot, isCollectionRoot := dcfs.parsePath(name)

	// Validate user ownership of path
	if err := dcfs.validateUserOwnership(userID); err != nil {
		return nil, err
	}

	if isRoot || isUserRoot || isCollectionRoot {
		// Directories cannot be opened for reading
		return nil, os.ErrInvalid
	}

	transaction, err := dcfs.cruds["calendar"].Connection().Beginx()
	if err != nil {
		return nil, err
	}
	defer transaction.Commit()

	// Build rpath: /calendars/{collection_name}/{resource_name}
	rpath := path.Join("/calendars", collectionName, resourceName)

	// Use direct SQL to read raw content (not file references)
	query, args, err := statementbuilder.Squirrel.
		Select("content").
		From("calendar").
		Where(goqu.Ex{
			"rpath":           rpath,
			"user_account_id": dcfs.sessionUser.UserId,
		}).
		Prepared(true).
		ToSQL()

	if err != nil {
		return nil, err
	}

	stmt, err := transaction.Preparex(query)
	if err != nil {
		return nil, err
	}
	defer stmt.Close()

	var content []byte
	err = stmt.QueryRow(args...).Scan(&content)
	if err != nil {
		return nil, os.ErrNotExist
	}

	return &caldavFile{
		content: content,
		offset:  0,
	}, nil
}

// Stat returns file/directory information
func (dcfs *DaptinCaldavFileSystem) Stat(name string) (*webdav.FileInfo, error) {