1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: Apache-2.0
13 "git.arvados.org/arvados.git/sdk/go/blockdigest"
16 // Collection is an arvados#collection resource.
17 type Collection struct {
18 UUID string `json:"uuid"`
19 Etag string `json:"etag"`
20 OwnerUUID string `json:"owner_uuid"`
21 TrashAt *time.Time `json:"trash_at"`
22 ManifestText string `json:"manifest_text"`
23 UnsignedManifestText string `json:"unsigned_manifest_text"`
24 Name string `json:"name"`
25 CreatedAt time.Time `json:"created_at"`
26 ModifiedAt time.Time `json:"modified_at"`
27 ModifiedByClientUUID string `json:"modified_by_client_uuid"`
28 ModifiedByUserUUID string `json:"modified_by_user_uuid"`
29 PortableDataHash string `json:"portable_data_hash"`
30 ReplicationConfirmed *int `json:"replication_confirmed"`
31 ReplicationConfirmedAt *time.Time `json:"replication_confirmed_at"`
32 ReplicationDesired *int `json:"replication_desired"`
33 StorageClassesDesired []string `json:"storage_classes_desired"`
34 StorageClassesConfirmed []string `json:"storage_classes_confirmed"`
35 StorageClassesConfirmedAt time.Time `json:"storage_classes_confirmed_at"`
36 DeleteAt *time.Time `json:"delete_at"`
37 IsTrashed bool `json:"is_trashed"`
38 Properties map[string]interface{} `json:"properties"`
39 WritableBy []string `json:"writable_by,omitempty"`
40 FileCount *int `json:"file_count"`
41 FileSizeTotal *int `json:"file_size_total"`
42 Version *int `json:"version"`
43 PreserveVersion bool `json:"preserve_version"`
44 CurrentVersionUUID string `json:"current_version_uuid"`
45 Description string `json:"description"`
46 Href string `json:"href"`
49 func (c Collection) resourceName() string {
53 // SizedDigests returns the hash+size part of each data block
54 // referenced by the collection.
55 func (c *Collection) SizedDigests() ([]SizedDigest, error) {
56 manifestText := c.ManifestText
57 if manifestText == "" {
58 manifestText = c.UnsignedManifestText
60 if manifestText == "" && c.PortableDataHash != "d41d8cd98f00b204e9800998ecf8427e+0" {
61 // TODO: Check more subtle forms of corruption, too
62 return nil, fmt.Errorf("manifest is missing")
65 scanner := bufio.NewScanner(strings.NewReader(manifestText))
66 scanner.Buffer(make([]byte, 1048576), len(manifestText))
68 line := scanner.Text()
69 tokens := strings.Split(line, " ")
71 return nil, fmt.Errorf("Invalid stream (<3 tokens): %q", line)
73 for _, token := range tokens[1:] {
74 if !blockdigest.LocatorPattern.MatchString(token) {
75 // FIXME: ensure it's a file token
78 // FIXME: shouldn't assume 32 char hash
79 if i := strings.IndexRune(token[33:], '+'); i >= 0 {
82 sds = append(sds, SizedDigest(token))
85 return sds, scanner.Err()
88 type CollectionList struct {
89 Items []Collection `json:"items"`
90 ItemsAvailable int `json:"items_available"`
91 Offset int `json:"offset"`
92 Limit int `json:"limit"`