1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
package reachability
import (
"errors"
"fmt"
giterrors "codeberg.org/lindenii/furgit/errors"
objectid "codeberg.org/lindenii/furgit/object/id"
"codeberg.org/lindenii/furgit/objectstore"
objecttype "codeberg.org/lindenii/furgit/object/type"
)
func validateDomain(domain Domain) error {
switch domain {
case DomainCommits, DomainObjects:
return nil
default:
return fmt.Errorf("reachability: invalid domain %d", domain)
}
}
func containsOID(set map[objectid.ObjectID]struct{}, id objectid.ObjectID) bool {
if len(set) == 0 {
return false
}
_, ok := set[id]
return ok
}
// The following helpers exist because we don't have unified error handling across the entire project.
// This will be fixed later.
func (walk *Walk) readHeaderType(id objectid.ObjectID) (objecttype.Type, error) {
return walk.reachability.readHeaderType(id)
}
func (r *Reachability) readHeaderType(id objectid.ObjectID) (objecttype.Type, error) {
ty, _, err := r.store.ReadHeader(id)
if err != nil {
if errors.Is(err, objectstore.ErrObjectNotFound) {
return objecttype.TypeInvalid, &giterrors.ObjectMissingError{OID: id}
}
return objecttype.TypeInvalid, err
}
return ty, nil
}
func (walk *Walk) readBytesContent(id objectid.ObjectID) ([]byte, error) {
content, err := walk.reachability.readBytesContent(id)
if err != nil {
return nil, err
}
return content, nil
}
func (r *Reachability) readBytesContent(id objectid.ObjectID) ([]byte, error) {
_, content, err := r.store.ReadBytesContent(id)
if err != nil {
if errors.Is(err, objectstore.ErrObjectNotFound) {
return nil, &giterrors.ObjectMissingError{OID: id}
}
return nil, err
}
return content, nil
}
|
