Method RunCommand

cmd/pk/packblobs.go:57–112

(args []string)

}

func (c *packBlobsCmd) RunCommand(args []string) error {
	if len(args) != 0 {
		return cmdmain.UsageError("doesn't take arguments")
	}
	req := &search.SearchQuery{
		Limit: -1,
		Sort:  search.BlobRefAsc,
		Constraint: &search.Constraint{
			File: &search.FileConstraint{
				FileSize: &search.IntConstraint{
					Min: 512 << 10,
				},
			},
		},
	}
	cl := newClient(c.server)
	looseClient, err := cl.NewPathClient("/bs-loose/")
	if err != nil {
		return fmt.Errorf("NewPathClient: %v", err)
	}

	res, err := cl.Query(ctxbg, req)
	if err != nil {
		return err
	}
	total := len(res.Blobs)
	n := 0
	var buf bytes.Buffer
	for _, sr := range res.Blobs {
		n++
		fileRef := sr.Blob
		rc, _, err := looseClient.Fetch(ctxbg, fileRef)
		if err == os.ErrNotExist {
			fmt.Printf("%d/%d: %v already done\n", n, total, fileRef)
			continue
		}
		if err != nil {
			log.Printf("error fetching %v: %v\n", fileRef, err)
			continue
		}
		buf.Reset()
		_, err = io.Copy(&buf, rc)
		rc.Close()
		if err != nil {
			log.Printf("error reading %v: %v\n", fileRef, err)
			continue
		}
		_, err = cl.ReceiveBlob(ctxbg, fileRef, &buf)
		if err != nil {
			log.Printf("error write %v: %v\n", fileRef, err)
			continue
		}
		fmt.Printf("%d/%d: %v\n", n, total, fileRef)
	}
	return nil
}