Method UpgradePlugin

agent/app/service/agents_channels.go:400–438

(req dto.AgentPluginUpgradeReq)

}

func (a AgentService) UpgradePlugin(req dto.AgentPluginUpgradeReq) error {
	agent, install, err := a.loadAgentAndInstall(req.AgentID)
	if err != nil {
		return err
	}
	if err := task.CheckScopeTaskIsExecuting(task.TaskScopeAI, req.AgentID); err != nil {
		return err
	}
	spec, pluginID, err := resolvePluginMeta(req.Type)
	if err != nil {
		return err
	}
	upgradeTask, err := task.NewTaskWithOps(req.Type, task.TaskUpgrade, task.TaskScopeAI, req.TaskID, req.AgentID)
	if err != nil {
		return err
	}
	upgradeTask.AddSubTask("Upgrade OpenClaw plugin", func(t *task.Task) error {
		mgr := cmd.NewCommandMgr(cmd.WithTask(*t), cmd.WithContext(t.TaskCtx), cmd.WithTimeout(10*time.Minute))
		if err := uninstallOpenclawPlugin(mgr, install.ContainerName, pluginID); err != nil {
			return err
		}
		time.Sleep(2 * time.Second)
		if err := installOpenclawPlugin(mgr, install.ContainerName, spec, pluginID); err != nil {
			return err
		}
		conf, err := readOpenclawConfig(agent.ConfigPath)
		if err != nil {
			return err
		}
		appendPluginAllow(conf, pluginID)
		return writeOpenclawConfigRaw(agent.ConfigPath, conf)
	}, nil)
	go func() {
		if err := upgradeTask.Execute(); err != nil {
			global.LOG.Errorf("upgrade openclaw plugin failed: %v", err)
		}
	}()
	return nil
}

func (a AgentService) UninstallPlugin(req dto.AgentPluginUninstallReq) error {
	agent, install, err := a.loadAgentAndInstall(req.AgentID)