2 goredo -- djb's redo implementation on pure Go
3 Copyright (C) 2020-2023 Sergey Matveev <stargrave@stargrave.org>
5 This program is free software: you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation, version 3 of the License.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
14 You should have received a copy of the GNU General Public License
15 along with this program. If not, see <http://www.gnu.org/licenses/>.
32 "go.cypherpunks.ru/recfile"
33 "lukechampine.com/blake3"
40 ErrBadRecFormat = errors.New("invalid format of .rec")
43 func recfileWrite(fdDep io.StringWriter, fields ...recfile.Field) error {
44 w := recfile.NewWriter(fdDep)
45 if _, err := w.RecordStart(); err != nil {
48 if _, err := w.WriteFields(fields...); err != nil {
54 func ifcreate(fdDep *os.File, tgt string) error {
55 tracef(CDebug, "ifcreate: %s <- %s", fdDep.Name(), tgt)
58 recfile.Field{Name: "Type", Value: DepTypeIfcreate},
59 recfile.Field{Name: "Target", Value: tgt},
63 func always(fdDep *os.File) error {
64 tracef(CDebug, "always: %s", fdDep.Name())
65 return recfileWrite(fdDep, recfile.Field{Name: "Type", Value: DepTypeAlways})
68 func stamp(fdDep, src *os.File) error {
69 hsh, err := fileHash(src)
73 tracef(CDebug, "stamp: %s <- %s", fdDep.Name(), hex.EncodeToString(hsh))
76 recfile.Field{Name: "Type", Value: DepTypeStamp},
77 recfile.Field{Name: "Hash", Value: hex.EncodeToString(hsh)},
81 func fileHash(fd *os.File) ([]byte, error) {
82 h := blake3.New(32, nil)
83 if _, err := io.Copy(h, bufio.NewReader(fd)); err != nil {
86 return h.Sum(nil), nil
89 func depWrite(fdDep *os.File, cwd string, tgt *Tgt, hsh []byte) error {
90 tracef(CDebug, "ifchange: %s <- %s", fdDep.Name(), tgt)
91 fd, err := os.Open(tgt.a)
96 inode, isDir, err := inodeFromFileByFd(fd)
104 hsh, err = fileHash(fd)
109 fields := []recfile.Field{
110 {Name: "Type", Value: DepTypeIfchange},
111 {Name: "Target", Value: tgt.RelTo(cwd)},
112 {Name: "Hash", Value: hex.EncodeToString(hsh)},
114 fields = append(fields, inode.RecfileFields()...)
115 return recfileWrite(fdDep, fields...)
118 func depsWrite(fdDep *os.File, tgts []*Tgt) error {
120 tracef(CDebug, "no opened fdDep: %s", tgts)
125 for _, tgt := range tgts {
127 if DepCwd != "" && Cwd != DepCwd {
130 tgtDir := path.Join(cwd, DirPrefix)
131 if _, errStat := os.Stat(tgt.a); errStat == nil {
132 err = ErrLine(depWrite(fdDep, tgtDir, tgt, nil))
134 tgtRel := tgt.RelTo(tgtDir)
135 tracef(CDebug, "ifchange: %s <- %s (non-existing)", fdDep.Name(), tgtRel)
136 fields := []recfile.Field{
137 {Name: "Type", Value: DepTypeIfchange},
138 {Name: "Target", Value: tgtRel},
140 inodeDummy := Inode{}
141 fields = append(fields, inodeDummy.RecfileFields()...)
142 err = ErrLine(recfileWrite(fdDep, fields...))
151 type DepInfoIfchange struct {
157 type DepInfo struct {
162 ifchanges []DepInfoIfchange
165 func mustHexDecode(s string) []byte {
166 b, err := hex.DecodeString(s)
173 var missingBuild = errors.New(".rec missing Build:")
175 func depRead(tgt *Tgt) (*DepInfo, error) {
176 data, err := os.ReadFile(tgt.Dep())
180 r := recfile.NewReader(bytes.NewReader(data))
181 m, err := r.NextMap()
188 return nil, missingBuild
192 m, err := r.NextMap()
194 if errors.Is(err, io.EOF) {
201 depInfo.always = true
202 case DepTypeIfcreate:
205 return nil, ErrBadRecFormat
207 depInfo.ifcreates = append(depInfo.ifcreates,
208 NewTgt(path.Join(tgt.h, dep)))
209 case DepTypeIfchange:
212 return nil, ErrBadRecFormat
214 inode, err := inodeFromRec(m)
217 return nil, ErrBadRecFormat
219 hsh := mustHexDecode(m["Hash"])
220 depInfo.ifchanges = append(depInfo.ifchanges, DepInfoIfchange{
221 tgt: NewTgt(path.Join(tgt.h, dep)), inode: inode, hash: hsh,
226 return nil, ErrBadRecFormat
228 depInfo.stamp = mustHexDecode(hsh)
230 return nil, ErrBadRecFormat
236 func depReadOnlyIfchanges(pth string) (ifchanges []string, err error) {
237 data, err := os.ReadFile(pth)
241 r := recfile.NewReader(bytes.NewReader(data))
242 var m map[string]string
246 if errors.Is(err, io.EOF) {
252 if m["Type"] == DepTypeIfchange {
253 ifchanges = append(ifchanges, m["Target"])
259 func depReadBuild(pth string) (string, error) {
260 fd, err := os.Open(pth)
264 r := recfile.NewReader(fd)
265 m, err := r.NextMap()