mirror of
https://github.com/opencloud-eu/opencloud.git
synced 2026-09-27 06:27:48 -04:00
Dominik Schmidt
12f76239de
Every property of an open extension is indexed under the sibling of its value's kind (ext.<name>.<property>.@keyword/@lower/@number/@bool/@date/ @geo), so a property can change its kind between writes without a mapping change. bleve builds the fields directly and indexes them with IndexAdvanced, the mapping stays as it is; OpenSearch types them through dynamic templates under a dynamic ext object, which the reconciler compares by rule instead of by concrete field. The stored values travel with the document so Move, Delete and Restore keep the extensions. The search service follows ArbitraryMetadataUpdated events that touch an extension.
72 lines
1.8 KiB
Go
72 lines
1.8 KiB
Go
package content
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
|
|
storageProvider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
|
|
"github.com/opencloud-eu/opencloud/pkg/conversions"
|
|
"github.com/opencloud-eu/opencloud/pkg/log"
|
|
"github.com/opencloud-eu/reva/v2/pkg/openextension"
|
|
"github.com/opencloud-eu/reva/v2/pkg/tags"
|
|
"github.com/opencloud-eu/reva/v2/pkg/utils"
|
|
)
|
|
|
|
// Basic is the simplest Extractor implementation.
|
|
type Basic struct {
|
|
logger log.Logger
|
|
}
|
|
|
|
// NewBasicExtractor creates a new Basic instance.
|
|
func NewBasicExtractor(logger log.Logger) (*Basic, error) {
|
|
return &Basic{logger: logger}, nil
|
|
}
|
|
|
|
// Extract literally just rearranges the inputs and processes them into a Document.
|
|
func (b Basic) Extract(_ context.Context, ri *storageProvider.ResourceInfo) (Document, error) {
|
|
doc := Document{
|
|
Name: ri.Name,
|
|
Size: ri.Size,
|
|
MimeType: ri.MimeType,
|
|
}
|
|
|
|
if m := ri.ArbitraryMetadata.GetMetadata(); m != nil {
|
|
if t, ok := m["tags"]; ok {
|
|
doc.Tags = tags.New(t).AsSlice()
|
|
}
|
|
for key, value := range m {
|
|
if _, _, ok := openextension.SplitKey(key); !ok {
|
|
continue
|
|
}
|
|
if doc.OpenExtensions == nil {
|
|
doc.OpenExtensions = map[string]string{}
|
|
}
|
|
doc.OpenExtensions[key] = value
|
|
}
|
|
}
|
|
|
|
if m := ri.Opaque.GetMap(); m != nil && m["favorites"] != nil {
|
|
favEntry := m["favorites"]
|
|
|
|
switch favEntry.Decoder {
|
|
case "json":
|
|
favorites := []string{}
|
|
err := json.Unmarshal(favEntry.Value, &favorites)
|
|
if err != nil {
|
|
b.logger.Error().Err(err).Msg("failed to unmarshal favorites")
|
|
break
|
|
}
|
|
|
|
doc.Favorites = favorites
|
|
default:
|
|
b.logger.Error().Msgf("unsupported decoder for favorites: %s", favEntry.Decoder)
|
|
}
|
|
}
|
|
|
|
if ri.Mtime != nil {
|
|
doc.Mtime = conversions.ToPointer(utils.TSToTime(ri.Mtime).UTC())
|
|
}
|
|
|
|
return doc, nil
|
|
}
|