Method internalFilelist

gcs/public.go:302–338

(prefix string)

}

func (g *PublishedStorage) internalFilelist(prefix string) ([]string, []string, error) {
	paths := make([]string, 0, 1024)
	md5s := make([]string, 0, 1024)

	fullPrefix := filepath.Join(g.prefix, prefix)
	if fullPrefix != "" {
		fullPrefix += "/"
	}

	it := g.bucket.Objects(context.TODO(), &storage.Query{Prefix: fullPrefix})
	for {
		attrs, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			return nil, nil, errors.WithMessagef(err, "error listing under prefix %s in %s", fullPrefix, g)
		}

		path := attrs.Name
		if fullPrefix != "" {
			path = strings.TrimPrefix(path, fullPrefix)
		}
		paths = append(paths, path)

		if attrs.Metadata != nil {
			if md5, ok := attrs.Metadata["Md5"]; ok && md5 != "" {
				md5s = append(md5s, strings.ToLower(md5))
				continue
			}
		}

		md5s = append(md5s, strings.ToLower(hex.EncodeToString(attrs.MD5)))
	}

	return paths, md5s, nil
}

// RenameFile renames (moves) file.
func (g *PublishedStorage) RenameFile(oldName, newName string) error {