Ai
1 Star 0 Fork 1

mysnapcore/mysnapd

forked from tupelo-shen/mysnapd 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
api_aliases.go 4.68 KB
一键复制 编辑 原始数据 按行查看 历史
tupelo-shen 提交于 2022-11-08 22:56 +08:00 . fix: daemon commit
// -*- Mode: Go; indent-tabs-mode: t -*-
/*
* Copyright (C) 2015-2020 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 daemon
import (
"encoding/json"
"errors"
"fmt"
"net/http"
"gitee.com/mysnapcore/mysnapd/i18n"
"gitee.com/mysnapcore/mysnapd/overlord/auth"
"gitee.com/mysnapcore/mysnapd/overlord/snapstate"
"gitee.com/mysnapcore/mysnapd/overlord/state"
"gitee.com/mysnapcore/mysnapd/snap"
)
var (
aliasesCmd = &Command{
Path: "/v2/aliases",
GET: getAliases,
POST: changeAliases,
ReadAccess: openAccess{},
WriteAccess: authenticatedAccess{},
}
)
// aliasAction is an action performed on aliases
type aliasAction struct {
Action string `json:"action"`
Snap string `json:"snap"`
App string `json:"app"`
Alias string `json:"alias"`
// old now unsupported api
Aliases []string `json:"aliases"`
}
func changeAliases(c *Command, r *http.Request, user *auth.UserState) Response {
var a aliasAction
decoder := json.NewDecoder(r.Body)
if err := decoder.Decode(&a); err != nil {
return BadRequest("cannot decode request body into an alias action: %v", err)
}
if len(a.Aliases) != 0 {
return BadRequest("cannot interpret request, snaps can no longer be expected to declare their aliases")
}
var taskset *state.TaskSet
var err error
st := c.d.overlord.State()
st.Lock()
defer st.Unlock()
switch a.Action {
default:
return BadRequest("unsupported alias action: %q", a.Action)
case "alias":
taskset, err = snapstate.Alias(st, a.Snap, a.App, a.Alias)
case "unalias":
if a.Alias == a.Snap {
// Do What I mean:
// check if a snap is referred/intended
// or just an alias
var snapst snapstate.SnapState
err := snapstate.Get(st, a.Snap, &snapst)
if err != nil && !errors.Is(err, state.ErrNoState) {
return InternalError("%v", err)
}
if errors.Is(err, state.ErrNoState) { // not a snap
a.Snap = ""
}
}
if a.Snap != "" {
a.Alias = ""
taskset, err = snapstate.DisableAllAliases(st, a.Snap)
} else {
taskset, a.Snap, err = snapstate.RemoveManualAlias(st, a.Alias)
}
case "prefer":
taskset, err = snapstate.Prefer(st, a.Snap)
}
if err != nil {
return errToResponse(err, nil, BadRequest, "%v")
}
var summary string
switch a.Action {
case "alias":
summary = fmt.Sprintf(i18n.G("Setup alias %q => %q for snap %q"), a.Alias, a.App, a.Snap)
case "unalias":
if a.Alias != "" {
summary = fmt.Sprintf(i18n.G("Remove manual alias %q for snap %q"), a.Alias, a.Snap)
} else {
summary = fmt.Sprintf(i18n.G("Disable all aliases for snap %q"), a.Snap)
}
case "prefer":
summary = fmt.Sprintf(i18n.G("Prefer aliases of snap %q"), a.Snap)
}
change := newChange(st, a.Action, summary, []*state.TaskSet{taskset}, []string{a.Snap})
st.EnsureBefore(0)
return AsyncResponse(nil, change.ID())
}
type aliasStatus struct {
Command string `json:"command"`
Status string `json:"status"`
Manual string `json:"manual,omitempty"`
Auto string `json:"auto,omitempty"`
}
// getAliases produces a response with a map snap -> alias -> aliasStatus
func getAliases(c *Command, r *http.Request, user *auth.UserState) Response {
state := c.d.overlord.State()
state.Lock()
defer state.Unlock()
res := make(map[string]map[string]aliasStatus)
allStates, err := snapstate.All(state)
if err != nil {
return InternalError("cannot list local snaps: %v", err)
}
for snapName, snapst := range allStates {
if err != nil {
return InternalError("cannot retrieve info for snap %q: %v", snapName, err)
}
if len(snapst.Aliases) != 0 {
snapAliases := make(map[string]aliasStatus)
res[snapName] = snapAliases
autoDisabled := snapst.AutoAliasesDisabled
for alias, aliasTarget := range snapst.Aliases {
aliasStatus := aliasStatus{
Manual: aliasTarget.Manual,
Auto: aliasTarget.Auto,
}
status := "auto"
tgt := aliasTarget.Effective(autoDisabled)
if tgt == "" {
status = "disabled"
tgt = aliasTarget.Auto
} else if aliasTarget.Manual != "" {
status = "manual"
}
aliasStatus.Status = status
aliasStatus.Command = snap.JoinSnapApp(snapName, tgt)
snapAliases[alias] = aliasStatus
}
}
}
return SyncResponse(res)
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/mysnapcore/mysnapd.git
git@gitee.com:mysnapcore/mysnapd.git
mysnapcore
mysnapd
mysnapd
v0.1.0

搜索帮助