Method Execute

command/common/install_plugin_command.go:77–164

([]string)

}

func (cmd InstallPluginCommand) Execute([]string) (err error) {
	log.WithField("PluginHome", cmd.Config.PluginHome()).Info("making plugin dir")

	var tempPluginDir string
	tempPluginDir, err = os.MkdirTemp(cmd.Config.PluginHome(), "temp")
	log.WithField("tempPluginDir", tempPluginDir).Debug("making tempPluginDir dir")

	defer func() {
		removed := false
		var removeErr error
		for i := 0; i < 50; i++ {
			removeErr = os.RemoveAll(tempPluginDir)
			if removeErr == nil {
				removed = true
				break
			}

			if os.IsNotExist(err) {
				removed = true
				break
			}

			if _, isPathError := removeErr.(*os.PathError); isPathError {
				time.Sleep(50 * time.Millisecond)
			} else {
				err = removeErr
			}
		}

		if !removed {
			err = removeErr
		}
	}()

	if err != nil {
		return err
	}

	tempPluginPath, pluginSource, err := cmd.getPluginBinaryAndSource(tempPluginDir)
	if _, ok := err.(cancelInstall); ok {
		cmd.UI.DisplayText("Plugin installation cancelled.")
		return nil
	} else if err != nil {
		return err
	}
	log.WithFields(log.Fields{"tempPluginPath": tempPluginPath, "pluginSource": pluginSource}).Debug("getPluginBinaryAndSource")

	// copy twice when downloading from a URL to keep Windows specific code
	// isolated to CreateExecutableCopy
	executablePath, err := cmd.Actor.CreateExecutableCopy(tempPluginPath, tempPluginDir)
	if err != nil {
		return err
	}
	log.WithField("executablePath", executablePath).Debug("created executable copy")

	rpcService, err := shared.NewRPCService(cmd.Config, cmd.UI)
	if err != nil {
		return err