7835d261d8
Previously a useful gist, this changeset polishes the original tarsum tool into a utility that can be used to calculate content digests. Any algorithm from the digest package is supported with additional support from tarsum. This tool is very useful for quickly checking backend digests and verifying correctness. Signed-off-by: Stephen J Day <stephen.day@docker.com>
129 lines
2.5 KiB
Go
129 lines
2.5 KiB
Go
package main
|
|
|
|
import (
|
|
"flag"
|
|
"fmt"
|
|
"io"
|
|
"io/ioutil"
|
|
"log"
|
|
"os"
|
|
"strings"
|
|
|
|
"github.com/docker/distribution/digest"
|
|
"github.com/docker/distribution/version"
|
|
"github.com/docker/docker/pkg/tarsum"
|
|
)
|
|
|
|
var (
|
|
algorithm = digest.Canonical
|
|
showVersion bool
|
|
)
|
|
|
|
type job struct {
|
|
name string
|
|
reader io.Reader
|
|
}
|
|
|
|
func init() {
|
|
flag.Var(&algorithm, "a", "select the digest algorithm (shorthand)")
|
|
flag.Var(&algorithm, "algorithm", "select the digest algorithm")
|
|
flag.BoolVar(&showVersion, "version", false, "show the version and exit")
|
|
|
|
log.SetFlags(0)
|
|
log.SetPrefix(os.Args[0] + ": ")
|
|
}
|
|
|
|
func usage() {
|
|
fmt.Fprintf(os.Stderr, "usage: %s [files...]\n", os.Args[0])
|
|
fmt.Fprintf(os.Stderr, `
|
|
Calculate the digest of one or more input files, emitting the result
|
|
to standard out. If no files are provided, the digest of stdin will
|
|
be calculated.
|
|
|
|
`)
|
|
flag.PrintDefaults()
|
|
}
|
|
|
|
func unsupported() {
|
|
log.Fatalf("unsupported digest algorithm: %v", algorithm)
|
|
}
|
|
|
|
func main() {
|
|
var jobs []job
|
|
|
|
flag.Usage = usage
|
|
flag.Parse()
|
|
if showVersion {
|
|
version.PrintVersion()
|
|
return
|
|
}
|
|
|
|
var fail bool // if we fail on one item, foul the exit code
|
|
if flag.NArg() > 0 {
|
|
for _, path := range flag.Args() {
|
|
fp, err := os.Open(path)
|
|
|
|
if err != nil {
|
|
log.Printf("%s: %v", path, err)
|
|
fail = true
|
|
continue
|
|
}
|
|
defer fp.Close()
|
|
|
|
jobs = append(jobs, job{name: path, reader: fp})
|
|
}
|
|
} else {
|
|
// just read stdin
|
|
jobs = append(jobs, job{name: "-", reader: os.Stdin})
|
|
}
|
|
|
|
digestFn := algorithm.FromReader
|
|
|
|
if !algorithm.Available() {
|
|
// we cannot digest if is not available. An exception is made for
|
|
// tarsum.
|
|
if !strings.HasPrefix(algorithm.String(), "tarsum") {
|
|
unsupported()
|
|
}
|
|
|
|
var version tarsum.Version
|
|
if algorithm == "tarsum" {
|
|
// small hack: if we just have tarsum, use latest
|
|
version = tarsum.Version1
|
|
} else {
|
|
var err error
|
|
version, err = tarsum.GetVersionFromTarsum(algorithm.String())
|
|
if err != nil {
|
|
unsupported()
|
|
}
|
|
}
|
|
|
|
digestFn = func(rd io.Reader) (digest.Digest, error) {
|
|
ts, err := tarsum.NewTarSum(rd, true, version)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
if _, err := io.Copy(ioutil.Discard, ts); err != nil {
|
|
return "", err
|
|
}
|
|
|
|
return digest.Digest(ts.Sum(nil)), nil
|
|
}
|
|
}
|
|
|
|
for _, job := range jobs {
|
|
dgst, err := digestFn(job.reader)
|
|
if err != nil {
|
|
log.Printf("%s: %v", job.name, err)
|
|
fail = true
|
|
continue
|
|
}
|
|
|
|
fmt.Printf("%v\t%s\n", dgst, job.name)
|
|
}
|
|
|
|
if fail {
|
|
os.Exit(1)
|
|
}
|
|
}
|