Function bytesHaveSchemaLink

pkg/server/share.go:315–351

bytesHaveSchemaLink reports whether bb is a valid Perkeep schema blob and has target somewhere in a schema field used to represent a Merkle-tree-ish file or directory.

(br blob.Ref, bb []byte, target blob.Ref)

// blob and has target somewhere in a schema field used to represent a
// Merkle-tree-ish file or directory.
func bytesHaveSchemaLink(br blob.Ref, bb []byte, target blob.Ref) bool {
	// Fast path for no:
	if !bytes.Contains(bb, []byte(target.String())) {
		return false
	}
	b, err := schema.BlobFromReader(br, bytes.NewReader(bb))
	if err != nil {
		return false
	}
	typ := b.Type()
	switch typ {
	case schema.TypeFile, schema.TypeBytes:
		for _, bp := range b.ByteParts() {
			if bp.BlobRef.Valid() {
				if bp.BlobRef == target {
					return true
				}
			}
			if bp.BytesRef.Valid() {
				if bp.BytesRef == target {
					return true
				}
			}
		}
	case schema.TypeDirectory:
		if d, ok := b.DirectoryEntries(); ok {
			return d == target
		}
	case schema.TypeStaticSet:
		for _, m := range b.StaticSetMembers() {
			if m == target {
				return true
			}
		}
	}
	return false
}