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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
package repository
import (
"fmt"
"codeberg.org/lindenii/furgit/object"
"codeberg.org/lindenii/furgit/object/stored"
"codeberg.org/lindenii/furgit/objectid"
"codeberg.org/lindenii/furgit/objecttype"
)
// ReadStored reads, parses, and wraps one object by ID.
//
//nolint:ireturn
func (repo *Repository) ReadStored(id objectid.ObjectID) (stored.StoredObject, error) {
parsed, err := repo.readParsedObject(id)
if err != nil {
return nil, err
}
switch parsed := parsed.(type) {
case *object.Blob:
return stored.NewStoredBlob(id, parsed), nil
case *object.Tree:
return stored.NewStoredTree(id, parsed), nil
case *object.Commit:
return stored.NewStoredCommit(id, parsed), nil
case *object.Tag:
return stored.NewStoredTag(id, parsed), nil
default:
return nil, fmt.Errorf("repository: unsupported parsed object type %T", parsed)
}
}
// ReadStoredBlob reads and parses a blob object by ID.
func (repo *Repository) ReadStoredBlob(id objectid.ObjectID) (*stored.StoredBlob, error) {
s, err := repo.ReadStored(id)
if err != nil {
return nil, err
}
blob, ok := s.(*stored.StoredBlob)
if !ok {
return nil, fmt.Errorf("repository: expected blob object %s, got %v", id, s.Object().ObjectType())
}
return blob, nil
}
// ReadStoredTree reads and parses a tree object by ID.
func (repo *Repository) ReadStoredTree(id objectid.ObjectID) (*stored.StoredTree, error) {
s, err := repo.ReadStored(id)
if err != nil {
return nil, err
}
tree, ok := s.(*stored.StoredTree)
if !ok {
return nil, fmt.Errorf("repository: expected tree object %s, got %v", id, s.Object().ObjectType())
}
return tree, nil
}
// ReadStoredCommit reads and parses a commit object by ID.
func (repo *Repository) ReadStoredCommit(id objectid.ObjectID) (*stored.StoredCommit, error) {
s, err := repo.ReadStored(id)
if err != nil {
return nil, err
}
commit, ok := s.(*stored.StoredCommit)
if !ok {
return nil, fmt.Errorf("repository: expected commit object %s, got %v", id, s.Object().ObjectType())
}
return commit, nil
}
// ReadStoredTag reads and parses a tag object by ID.
func (repo *Repository) ReadStoredTag(id objectid.ObjectID) (*stored.StoredTag, error) {
s, err := repo.ReadStored(id)
if err != nil {
return nil, err
}
tag, ok := s.(*stored.StoredTag)
if !ok {
return nil, fmt.Errorf("repository: expected tag object %s, got %v", id, s.Object().ObjectType())
}
return tag, nil
}
// readParsedObject reads bytes content from storage and parses one object.
//
//nolint:ireturn
func (repo *Repository) readParsedObject(id objectid.ObjectID) (object.Object, error) {
ty, content, err := repo.objects.ReadBytesContent(id)
if err != nil {
return nil, err
}
parsed, err := object.ParseObjectWithoutHeader(ty, content, repo.algo)
if err != nil {
tyName, ok := objecttype.Name(ty)
if !ok {
tyName = fmt.Sprintf("type %d", ty)
}
return nil, fmt.Errorf("repository: parse object %s (%s): %w", id, tyName, err)
}
return parsed, nil
}
|
