1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
package namespace
import (
"google.golang.org/protobuf/types/known/anypb"
core "github.com/authzed/spicedb/pkg/proto/core/v1"
iv1 "github.com/authzed/spicedb/pkg/proto/impl/v1"
)
// WithSourcePosition defines an interface for proto messages in core with SourcePosition information attached.
type WithSourcePosition interface {
GetSourcePosition() *core.SourcePosition
}
// userDefinedMetadataTypeUrls are the type URLs of any user-defined metadata found
// in the namespace proto. If placed here, FilterUserDefinedMetadataInPlace will remove the
// metadata when called on the namespace.
var userDefinedMetadataTypeUrls = map[string]struct{}{
"type.googleapis.com/impl.v1.DocComment": {},
}
// FilterUserDefinedMetadataInPlace removes user-defined metadata (e.g. comments) from the given namespace
// *in place*.
func FilterUserDefinedMetadataInPlace(nsconfig *core.NamespaceDefinition) {
nsconfig.Metadata = nil
for _, relation := range nsconfig.Relation {
if relation.Metadata != nil {
var filteredMessages []*anypb.Any
for _, msg := range relation.Metadata.MetadataMessage {
if _, ok := userDefinedMetadataTypeUrls[msg.TypeUrl]; !ok {
filteredMessages = append(filteredMessages, msg)
}
}
relation.Metadata.MetadataMessage = filteredMessages
}
}
}
// GetComments returns the comment metadata found within the given metadata message.
func GetComments(metadata *core.Metadata) []string {
if metadata == nil {
return []string{}
}
comments := []string{}
for _, msg := range metadata.MetadataMessage {
var dc iv1.DocComment
if err := msg.UnmarshalTo(&dc); err == nil {
comments = append(comments, dc.Comment)
}
}
return comments
}
// AddComment adds a comment to the given metadata message.
func AddComment(metadata *core.Metadata, comment string) (*core.Metadata, error) {
if metadata == nil {
metadata = &core.Metadata{}
}
var dc iv1.DocComment
dc.Comment = comment
encoded, err := anypb.New(&dc)
if err != nil {
return metadata, err
}
metadata.MetadataMessage = append(metadata.MetadataMessage, encoded)
return metadata, nil
}
// GetRelationKind returns the kind of the relation.
func GetRelationKind(relation *core.Relation) iv1.RelationMetadata_RelationKind {
metadata := relation.Metadata
if metadata == nil {
return iv1.RelationMetadata_UNKNOWN_KIND
}
for _, msg := range metadata.MetadataMessage {
var rm iv1.RelationMetadata
if err := msg.UnmarshalTo(&rm); err == nil {
return rm.Kind
}
}
return iv1.RelationMetadata_UNKNOWN_KIND
}
// SetRelationKind sets the kind of relation.
func SetRelationKind(relation *core.Relation, kind iv1.RelationMetadata_RelationKind) error {
metadata := relation.Metadata
if metadata == nil {
metadata = &core.Metadata{}
relation.Metadata = metadata
}
var rm iv1.RelationMetadata
rm.Kind = kind
encoded, err := anypb.New(&rm)
if err != nil {
return err
}
metadata.MetadataMessage = append(metadata.MetadataMessage, encoded)
return nil
}
|
