forked from snapcore/snapd
/
patch2.go
165 lines (143 loc) · 5.53 KB
/
patch2.go
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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
// -*- Mode: Go; indent-tabs-mode: t -*-
/*
* Copyright (C) 2016 Canonical Ltd
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 3 as
* published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
package patch
import (
"github.com/snapcore/snapd/overlord/state"
"github.com/snapcore/snapd/snap"
)
func init() {
patches[2] = []PatchFunc{patch2}
}
type patch2SideInfo struct {
RealName string `yaml:"name,omitempty" json:"name,omitempty"`
SnapID string `yaml:"snap-id" json:"snap-id"`
Revision snap.Revision `yaml:"revision" json:"revision"`
Channel string `yaml:"channel,omitempty" json:"channel,omitempty"`
DeveloperID string `yaml:"developer-id,omitempty" json:"developer-id,omitempty"`
Developer string `yaml:"developer,omitempty" json:"developer,omitempty"` // XXX: obsolete, will be retired after full backfilling of DeveloperID
EditedSummary string `yaml:"summary,omitempty" json:"summary,omitempty"`
EditedDescription string `yaml:"description,omitempty" json:"description,omitempty"`
Size int64 `yaml:"size,omitempty" json:"size,omitempty"`
Sha512 string `yaml:"sha512,omitempty" json:"sha512,omitempty"`
Private bool `yaml:"private,omitempty" json:"private,omitempty"`
}
type patch2DownloadInfo struct {
AnonDownloadURL string `json:"anon-download-url,omitempty"`
DownloadURL string `json:"download-url,omitempty"`
}
type patch2Flags int
type patch2SnapState struct {
SnapType string `json:"type"` // Use Type and SetType
Sequence []*patch2SideInfo `json:"sequence"`
Active bool `json:"active,omitempty"`
// Current indicates the current active revision if Active is
// true or the last active revision if Active is false
// (usually while a snap is being operated on or disabled)
Current snap.Revision `json:"current"`
Channel string `json:"channel,omitempty"`
Flags patch2Flags `json:"flags,omitempty"`
}
type patch2SnapSetup struct {
// FIXME: rename to RequestedChannel to convey the meaning better
Channel string `json:"channel,omitempty"`
UserID int `json:"user-id,omitempty"`
Flags patch2Flags `json:"flags,omitempty"`
SnapPath string `json:"snap-path,omitempty"`
DownloadInfo *patch2DownloadInfo `json:"download-info,omitempty"`
SideInfo *patch2SideInfo `json:"side-info,omitempty"`
}
func patch2SideInfoFromPatch1(oldInfo *patch1SideInfo, name string) *patch2SideInfo {
return &patch2SideInfo{
RealName: name, // NOTE: OfficialName dropped
SnapID: oldInfo.SnapID,
Revision: oldInfo.Revision,
Channel: oldInfo.Channel,
Developer: oldInfo.Developer, // NOTE: no DeveloperID in patch1SideInfo
EditedSummary: oldInfo.EditedSummary,
EditedDescription: oldInfo.EditedDescription,
Size: oldInfo.Size,
Sha512: oldInfo.Sha512,
Private: oldInfo.Private,
}
}
func patch2SequenceFromPatch1(oldSeq []*patch1SideInfo, name string) []*patch2SideInfo {
newSeq := make([]*patch2SideInfo, len(oldSeq))
for i, si := range oldSeq {
newSeq[i] = patch2SideInfoFromPatch1(si, name)
}
return newSeq
}
func patch2SnapStateFromPatch1(oldSnapState *patch1SnapState, name string) *patch2SnapState {
return &patch2SnapState{
SnapType: oldSnapState.SnapType,
Sequence: patch2SequenceFromPatch1(oldSnapState.Sequence, name),
Active: oldSnapState.Active,
Current: oldSnapState.Current,
Channel: oldSnapState.Channel,
Flags: patch2Flags(oldSnapState.Flags),
}
}
// patch2:
// - migrates SnapSetup.Name to SnapSetup.SideInfo.RealName
// - backfills SnapState.{Sequence,Candidate}.RealName if its missing
func patch2(s *state.State) error {
var oldStateMap map[string]*patch1SnapState
err := s.Get("snaps", &oldStateMap)
if err == state.ErrNoState {
return nil
}
if err != nil {
return err
}
newStateMap := make(map[string]*patch2SnapState, len(oldStateMap))
for key, oldSnapState := range oldStateMap {
newStateMap[key] = patch2SnapStateFromPatch1(oldSnapState, key)
}
// migrate SnapSetup in all tasks:
// - the new SnapSetup uses SideInfo, backfil from Candidate
// - also move SnapSetup.{Name,Revision} into SnapSetup.SideInfo.{RealName,Revision}
var oldSS patch1SnapSetup
for _, t := range s.Tasks() {
var newSS patch2SnapSetup
err := t.Get("snap-setup", &oldSS)
if err == state.ErrNoState {
continue
}
if err != nil && err != state.ErrNoState {
return err
}
// some things stay the same
newSS.Channel = oldSS.Channel
newSS.Flags = patch2Flags(oldSS.Flags)
newSS.SnapPath = oldSS.SnapPath
// ... and some change
newSS.SideInfo = &patch2SideInfo{}
if snapst, ok := oldStateMap[oldSS.Name]; ok && snapst.Candidate != nil {
newSS.SideInfo = patch2SideInfoFromPatch1(snapst.Candidate, oldSS.Name)
}
if newSS.SideInfo.RealName == "" {
newSS.SideInfo.RealName = oldSS.Name
}
if newSS.SideInfo.Revision.Unset() {
newSS.SideInfo.Revision = oldSS.Revision
}
t.Set("snap-setup", &newSS)
}
s.Set("snaps", newStateMap)
return nil
}