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
|
package link
import (
"fmt"
"log"
"os"
opt "codeberg.org/snonux/gonf/api/options"
"codeberg.org/snonux/gonf/internal/resource"
"codeberg.org/snonux/gonf/internal/resource/embed"
)
type kind int
const (
unsetKind kind = iota
symlinkKind
hardlinkKind
)
type Link struct {
embed.DependsOn
embed.Absence
resource resource.Resource
path string
target string
kind kind
}
// SetSymlink implements opt.Linkable.
func (l *Link) SetSymlink(target string) {
l.kind = symlinkKind
l.target = target
}
// SetHardlink implements opt.Linkable.
func (l *Link) SetHardlink(target string) {
l.kind = hardlinkKind
l.target = target
}
func build(path string, opts ...opt.Option) *Link {
l := &Link{path: path}
for _, o := range opts {
o(l)
}
return l
}
// apply performs the idempotent OS work for l without registering a
// resource. Kind-vs-absent validation happens here (not in build) to match
// the pre-split behavior where a resource was registered before its target
// was validated.
func (l *Link) apply() error {
switch {
case l.Absent:
return ensureAbsent(l.path)
case l.kind == symlinkKind:
return ensureSymlink(l)
case l.kind == hardlinkKind:
return ensureHardlink(l)
default:
return fmt.Errorf("link %s: must specify IsSymlink, IsHardlink, or IsAbsent", l.path)
}
}
// resourceType returns the registry type name for l. Absent links with no
// kind specified register generically as "Link", since removal doesn't
// depend on knowing the prior kind.
func (l *Link) resourceType() string {
switch l.kind {
case symlinkKind:
return "Symlink"
case hardlinkKind:
return "Hardlink"
default:
return "Link"
}
}
// Ensure builds and applies the link resource described by opts, without
// registering it. Used by other resource packages (e.g. dir) to recreate an
// individual symlink without it becoming its own top-level resource.
func Ensure(path string, opts ...opt.Option) error {
return build(path, opts...).apply()
}
func Present(path string, opts ...opt.Option) resource.Resource {
l := build(path, opts...)
l.resource = resource.Register(l.resourceType(), l.path,
resource.ApplierFunc(func() error { return l.apply() }), l.DependsOn.IDs...)
return l.resource
}
func Absent(path string, opts ...opt.Option) resource.Resource {
opts = append(opts, opt.IsAbsent)
return Present(path, opts...)
}
func ensureAbsent(path string) error {
log.Printf("ensuring link absent: %s", path)
if err := os.Remove(path); err != nil {
if os.IsNotExist(err) {
log.Printf("%s already absent", path)
return nil
}
return fmt.Errorf("failed to remove %s: %w", path, err)
}
log.Printf("removed %s", path)
return nil
}
|
