feat(tvix/store/protos): implement Size() and Digest() for Directory
This adds Size() and Digest() functions for the golang version. Change-Id: If71445a9bb26100bb4076ac4f5c96945b33919f9 Reviewed-on: https://cl.tvl.fyi/c/depot/+/7325 Tested-by: BuildkiteCI Reviewed-by: tazjin <tazjin@tvl.su>
This commit is contained in:
parent
81fd9caf3e
commit
c3fb6d2218
4 changed files with 251 additions and 0 deletions
39
tvix/store/protos/castore.go
Normal file
39
tvix/store/protos/castore.go
Normal file
|
@ -0,0 +1,39 @@
|
|||
package storev1
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"google.golang.org/protobuf/proto"
|
||||
"lukechampine.com/blake3"
|
||||
)
|
||||
|
||||
// The size of a directory is calculated by summing up the numbers of
|
||||
// `directories`, `files` and `symlinks`, and for each directory, its size
|
||||
// field.
|
||||
func (d *Directory) Size() uint32 {
|
||||
var size uint32
|
||||
size = uint32(len(d.Files) + len(d.Symlinks))
|
||||
for _, d := range d.Directories {
|
||||
size += 1 + d.Size
|
||||
}
|
||||
return size
|
||||
}
|
||||
|
||||
func (d *Directory) Digest() ([]byte, error) {
|
||||
b, err := proto.MarshalOptions{
|
||||
Deterministic: true,
|
||||
}.Marshal(d)
|
||||
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error while marshalling directory: %w", err)
|
||||
}
|
||||
|
||||
h := blake3.New(32, nil)
|
||||
|
||||
_, err = h.Write(b)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error writing to hasher: %w", err)
|
||||
}
|
||||
|
||||
return h.Sum(nil), nil
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue