api_plugin_manager.cpp

Go to the documentation of this file.

/*
 * This program source code file is part of KiCad, a free EDA CAD application.
 *
 * Copyright (C) 2024 Jon Evans <[email protected]>
 * Copyright The KiCad Developers, see AUTHORS.txt for contributors.
 *
 * This program is free software: you can redistribute it and/or modify it
 * under the terms of the GNU General Public License as published by the
 * Free Software Foundation, either version 3 of the License, or (at your
 * option) any later version.
 *
 * 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/>.
 */
 
#include <fstream>
 
#include <env_vars.h>
#include <fmt/format.h>
#include <wx/dir.h>
#include <wx/log.h>
#include <wx/process.h>
#include <wx/timer.h>
#include <wx/utils.h>
 
#include <api/api_plugin_manager.h>
#include <api/api_server.h>
#include <api/api_utils.h>
#include <gestfich.h>
#include <paths.h>
#include <pgm_base.h>
#include <api/python_manager.h>
#include <reporter.h>
#include <settings/settings_manager.h>
#include <settings/common_settings.h>
 
 
wxDEFINE_EVENT( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, wxCommandEvent );
wxDEFINE_EVENT( EDA_EVT_PLUGIN_AVAILABILITY_CHANGED, wxCommandEvent );
 
 
class ACTION_PROCESS : public wxProcess
{
public:
    ACTION_PROCESS( std::function<void( int, const wxString&, const wxString& )> aCallback ) :
            wxProcess(),
            m_callback( std::move( aCallback ) )
    {}
 
    void OnTerminate( int aPid, int aStatus ) override
    {
        if( m_callback )
        {
            wxString output, error;
 
            if( wxInputStream* processOut = GetInputStream() )
            {
                while( processOut->CanRead() )
                {
                    char buffer[4096];
                    buffer[ processOut->Read( buffer, sizeof( buffer ) - 1 ).LastRead() ] = '\0';
                    output.append( buffer, processOut->LastRead() );
                }
            }
 
            if( wxInputStream* processErr = GetErrorStream() )
            {
                while( processErr->CanRead() )
                {
                    char buffer[4096];
                    buffer[ processErr->Read( buffer, sizeof( buffer ) - 1 ).LastRead() ] = '\0';
                    error.append( buffer, processErr->LastRead() );
                }
            }
 
            m_callback( aStatus, output, error );
        }
 
        wxProcess::OnTerminate( aPid, aStatus );
    }
 
private:
    std::function<void( int, const wxString&, const wxString& )> m_callback;
};
 
 
static void reportPluginActionMessage( REPORTER* aReporter, const wxString& aActionName,
                                       const wxString& aMessage )
{
    if( !aReporter || aMessage.IsEmpty() )
        return;
 
    aReporter->Report( wxString::Format( _( "Plugin action '%s': %s" ), aActionName, aMessage ),
                       RPT_SEVERITY_ERROR );
}
 
 
static void reportPluginLoadMessage( REPORTER* aReporter, const wxString& aPluginName,
                                     const wxString& aMessage )
{
    if( !aReporter || aMessage.IsEmpty() )
        return;
 
    aReporter->Report( wxString::Format( _( "Plugin '%s': %s" ), aPluginName, aMessage ),
                       RPT_SEVERITY_ERROR );
}
 
 
static void reportPluginActionResult( REPORTER* aReporter, const wxString& aActionName,
                                      int aRetVal, const wxString& aError )
{
    wxString trimmedError = aError;
    trimmedError.Trim();
    trimmedError.Trim( false );
 
    if( aRetVal != 0 )
    {
        reportPluginActionMessage( aReporter, aActionName,
                                   wxString::Format( _( "exited with code %d" ), aRetVal ) );
    }
 
    if( !trimmedError.IsEmpty() )
        reportPluginActionMessage( aReporter, aActionName, trimmedError );
}
 
 
API_PLUGIN_MANAGER::API_PLUGIN_MANAGER( wxEvtHandler* aEvtHandler ) :
        wxEvtHandler(),
        m_parent( aEvtHandler ),
        m_lastPid( 0 ),
        m_raiseTimer( nullptr )
{
    // Read and store pcm schema
    wxFileName schemaFile( PATHS::GetStockDataPath( true ), wxS( "api.v1.schema.json" ) );
    schemaFile.Normalize( FN_NORMALIZE_FLAGS | wxPATH_NORM_ENV_VARS );
    schemaFile.AppendDir( wxS( "schemas" ) );
 
    m_schema_validator = std::make_unique<JSON_SCHEMA_VALIDATOR>( schemaFile );
 
    Bind( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, &API_PLUGIN_MANAGER::processNextJob, this );
}
 
 
class PLUGIN_TRAVERSER : public wxDirTraverser
{
private:
    std::function<void( const wxFileName& )> m_action;
 
public:
    explicit PLUGIN_TRAVERSER( std::function<void( const wxFileName& )> aAction )
            : m_action( std::move( aAction ) )
    {
    }
 
    wxDirTraverseResult OnFile( const wxString& aFilePath ) override
    {
        wxFileName file( aFilePath );
 
        if( file.GetFullName() == wxS( "plugin.json" ) )
            m_action( file );
 
        return wxDIR_CONTINUE;
    }
 
    wxDirTraverseResult OnDir( const wxString& dirPath ) override
    {
        return wxDIR_CONTINUE;
    }
};
 
 
void API_PLUGIN_MANAGER::ReloadPlugins( std::optional<wxString> aDirectoryToScan,
                                        std::shared_ptr<REPORTER> aReporter )
{
    m_reloadReporter = std::move( aReporter );
 
    m_plugins.clear();
    m_pluginsCache.clear();
    m_actionsCache.clear();
    m_environmentCache.clear();
    m_buttonBindings.clear();
    m_menuBindings.clear();
    m_readyPlugins.clear();
 
    PLUGIN_TRAVERSER loader(
            [&]( const wxFileName& aFile )
            {
                wxLogTrace( traceApi, wxString::Format( "Manager: loading plugin from %s",
                                                        aFile.GetFullPath() ) );
 
                auto plugin = std::make_unique<API_PLUGIN>( aFile, *m_schema_validator );
 
                if( plugin->IsOk() )
                {
                    const wxString& id = plugin->Identifier();
 
                    if( m_pluginsCache.contains( id ) )
                    {
                        wxLogTrace( traceApi, wxString::Format( "Manager: identifier %s already present, reloading", id ) );
 
                        for( const PLUGIN_ACTION& action : m_pluginsCache[id]->Actions() )
                            m_actionsCache[action.identifier] = &action;
 
                        m_pluginsCache.erase( id );
                        return;
                    }
 
                    m_pluginsCache[id] = plugin.get();
 
                    for( const PLUGIN_ACTION& action : plugin->Actions() )
                        m_actionsCache[action.identifier] = &action;
 
                    m_plugins.insert( std::move( plugin ) );
                }
                else
                {
                    wxLogTrace( traceApi, "Manager: loading failed" );
 
                    reportPluginLoadMessage( m_reloadReporter.get(), aFile.GetFullPath(),
                                             plugin->ErrorMessage() );
                }
            } );
 
    if( aDirectoryToScan )
    {
        wxDir customDir( *aDirectoryToScan );
        wxLogTrace( traceApi, wxString::Format( "Manager: scanning custom path (%s) for plugins...",
                                                customDir.GetName() ) );
        customDir.Traverse( loader );
    }
    else
    {
        wxDir systemPluginsDir( PATHS::GetStockPluginsPath() );
 
        if( systemPluginsDir.IsOpened() )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: scanning system path (%s) for plugins...",
                                                    systemPluginsDir.GetName() ) );
            systemPluginsDir.Traverse( loader );
        }
 
        wxString thirdPartyPath;
        const ENV_VAR_MAP& env = Pgm().GetLocalEnvVariables();
 
        if( std::optional<wxString> v = ENV_VAR::GetVersionedEnvVarValue( env, wxT( "3RD_PARTY" ) ) )
            thirdPartyPath = *v;
        else
            thirdPartyPath = PATHS::GetDefault3rdPartyPath();
 
        wxDir thirdParty( thirdPartyPath );
 
        if( thirdParty.IsOpened() )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: scanning PCM path (%s) for plugins...",
                                                    thirdParty.GetName() ) );
            thirdParty.Traverse( loader );
        }
 
        wxDir userPluginsDir( PATHS::GetUserPluginsPath() );
 
        if( userPluginsDir.IsOpened() )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: scanning user path (%s) for plugins...",
                                                    userPluginsDir.GetName() ) );
            userPluginsDir.Traverse( loader );
        }
    }
 
    processPluginDependencies();
 
    if( !Busy() )
        m_reloadReporter.reset();
 
    wxCommandEvent* evt = new wxCommandEvent( EDA_EVT_PLUGIN_AVAILABILITY_CHANGED, wxID_ANY );
    m_parent->QueueEvent( evt );
}
 
 
void API_PLUGIN_MANAGER::RecreatePluginEnvironment( const wxString& aIdentifier )
{
    if( !m_pluginsCache.contains( aIdentifier ) )
        return;
 
    const API_PLUGIN* plugin = m_pluginsCache.at( aIdentifier );
    wxCHECK( plugin, /* void */ );
 
    if( plugin->Runtime().type != PLUGIN_RUNTIME_TYPE::PYTHON )
        return;
 
    std::optional<wxString> env = PYTHON_MANAGER::GetPythonEnvironment( plugin->Identifier() );
    wxCHECK( env.has_value(), /* void */ );
 
    wxFileName envConfigPath( *env, wxS( "pyvenv.cfg" ) );
    envConfigPath.MakeAbsolute();
 
    if( envConfigPath.DirExists() && envConfigPath.Rmdir( wxPATH_RMDIR_RECURSIVE ) )
    {
        wxLogTrace( traceApi,
                    wxString::Format( "Manager: Removed existing Python environment at %s for %s",
                                      envConfigPath.GetPath(), plugin->Identifier() ) );
 
        JOB job;
        job.type = JOB_TYPE::CREATE_ENV;
        job.identifier = plugin->Identifier();
        job.plugin_path = plugin->BasePath();
        job.env_path = envConfigPath.GetPath();
        m_jobs.emplace_back( job );
 
        wxCommandEvent* evt = new wxCommandEvent( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, wxID_ANY );
        QueueEvent( evt );
    }
}
 
 
std::optional<const PLUGIN_ACTION*> API_PLUGIN_MANAGER::GetAction( const wxString& aIdentifier )
{
    if( !m_actionsCache.contains( aIdentifier ) )
        return std::nullopt;
 
    return m_actionsCache.at( aIdentifier );
}
 
 
int API_PLUGIN_MANAGER::doInvokeAction( const wxString& aIdentifier, std::vector<wxString> aExtraArgs,
                                        bool aSync, wxString* aStdout, wxString* aStderr,
                                        std::shared_ptr<REPORTER> aReporter )
{
    if( !m_actionsCache.contains( aIdentifier ) )
    {
        reportPluginActionMessage( aReporter.get(), aIdentifier, _( "action is not registered" ) );
        return -1;
    }
 
    const PLUGIN_ACTION* action = m_actionsCache.at( aIdentifier );
    const API_PLUGIN& plugin = action->plugin;
 
    if( !m_readyPlugins.count( plugin.Identifier() ) )
    {
        wxLogTrace( traceApi, wxString::Format( "Manager: Plugin %s is not ready",
                                                plugin.Identifier() ) );
        return -1;
    }
 
    wxFileName pluginFile( action->entrypoint );
    pluginFile.MakeAbsolute( plugin.BasePath() );
    pluginFile.Normalize( wxPATH_NORM_ABSOLUTE | wxPATH_NORM_SHORTCUT | wxPATH_NORM_DOTS
                          | wxPATH_NORM_TILDE, plugin.BasePath() );
    wxString pluginPath = pluginFile.GetFullPath();
 
    std::vector<const wchar_t*> args;
    std::optional<wxString> py;
 
    switch( plugin.Runtime().type )
    {
    case PLUGIN_RUNTIME_TYPE::PYTHON:
    {
        py = PYTHON_MANAGER::GetVirtualPython( plugin.Identifier() );
 
        if( !py )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: Python interpreter for %s not found",
                                                    plugin.Identifier() ) );
            reportPluginActionMessage( aReporter.get(), action->name,
                                       _( "missing plugin environment" ) );
            return -1;
        }
 
        if( !pluginFile.IsFileReadable() )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: Python entrypoint %s is not readable",
                                                    pluginFile.GetFullPath() ) );
            reportPluginActionMessage( aReporter.get(), action->name,
                                       wxString::Format( _( "entrypoint '%s' could not be read" ),
                                                         pluginFile.GetFullPath() ) );
            return -1;
        }
 
        std::optional<wxString> pythonHome =
                PYTHON_MANAGER::GetPythonEnvironment( plugin.Identifier() );
 
        PYTHON_MANAGER manager( *py );
        wxExecuteEnv   env;
        wxGetEnvMap( &env.env );
 
        if( Pgm().ApiServerOrNull() )
        {
            env.env[wxS( "KICAD_API_SOCKET" )] = Pgm().GetApiServer().SocketPath();
            env.env[wxS( "KICAD_API_TOKEN" )] = Pgm().GetApiServer().Token();
        }
 
        env.cwd = pluginFile.GetPath();
 
#ifdef _WIN32
        wxString systemRoot;
        wxGetEnv( wxS( "SYSTEMROOT" ), &systemRoot );
        env.env[wxS( "SYSTEMROOT" )] = systemRoot;
 
        if( Pgm().GetCommonSettings()->m_Api.python_interpreter == FindKicadFile( "pythonw.exe" )
            || wxGetEnv( wxT( "KICAD_RUN_FROM_BUILD_DIR" ), nullptr ) )
        {
            wxLogTrace( traceApi, "Configured Python is the KiCad one; erasing path overrides..." );
            env.env.erase( "PYTHONHOME" );
            env.env.erase( "PYTHONPATH" );
        }
#endif
 
        if( pythonHome )
            env.env[wxS( "VIRTUAL_ENV" )] = *pythonHome;
 
        std::vector<wxString> pyArgs( aExtraArgs );
        pyArgs.insert( pyArgs.begin(), pluginFile.GetFullPath() );
 
        if( aSync )
        {
            wxString stdOut;
            wxString stdErr;
            wxString* stdoutSink = aStdout ? aStdout : &stdOut;
            wxString* stderrSink = aStderr ? aStderr : &stdErr;
            int ret = manager.ExecuteSync( pyArgs, stdoutSink, stderrSink, &env );
            reportPluginActionResult( aReporter.get(), action->name, ret, *stderrSink );
            return ret;
        }
 
        [[maybe_unused]] long pid = manager.Execute( pyArgs,
                [aReporter, action]( int aRetVal, const wxString& aOutput,
                                         const wxString& aError )
                {
                    wxLogTrace( traceApi,
                                wxString::Format( "Manager: action exited with code %d", aRetVal ) );
 
                    if( !aError.IsEmpty() )
                        wxLogTrace( traceApi, wxString::Format( "Manager: action stderr: %s", aError ) );
 
                    reportPluginActionResult( aReporter.get(), action->name, aRetVal, aError );
                },
                &env, true );
 
        if( !pid )
        {
            reportPluginActionMessage( aReporter.get(), action->name,
                                       _( "process could not be created" ) );
            return -1;
        }
 
#ifdef __WXMAC__
        if( pid )
        {
            if( !m_raiseTimer )
            {
                m_raiseTimer = new wxTimer( this );
 
                Bind( wxEVT_TIMER,
                        [&]( wxTimerEvent& )
                        {
                            wxString script = wxString::Format(
                                wxS( "tell application \"System Events\"\n"
                                  "  set plist to every process whose unix id is %ld\n"
                                  "  repeat with proc in plist\n"
                                  "    set the frontmost of proc to true\n"
                                  "  end repeat\n"
                                  "end tell" ), m_lastPid );
 
                            wxString cmd = wxString::Format( "osascript -e '%s'", script );
                            wxLogTrace( traceApi, wxString::Format( "Execute: %s", cmd ) );
                            wxExecute( cmd );
                        },
                        m_raiseTimer->GetId() );
            }
 
            m_lastPid = pid;
            m_raiseTimer->StartOnce( 250 );
        }
#endif
 
        break;
    }
 
    case PLUGIN_RUNTIME_TYPE::EXEC:
    {
        if( !pluginFile.IsFileExecutable() )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: Exec entrypoint %s is not executable",
                                                    pluginFile.GetFullPath() ) );
            reportPluginActionMessage( aReporter.get(), action->name,
                                       wxString::Format( _( "entrypoint '%s' is not executable" ),
                                                         pluginFile.GetFullPath() ) );
            return -1;
        }
 
        wxExecuteEnv env;
        wxGetEnvMap( &env.env );
 
        if( Pgm().ApiServerOrNull() )
        {
            env.env[wxS( "KICAD_API_SOCKET" )] = Pgm().GetApiServer().SocketPath();
            env.env[wxS( "KICAD_API_TOKEN" )] = Pgm().GetApiServer().Token();
        }
 
        env.cwd = pluginFile.GetPath();
 
        long pidOrRetCode = 0;
 
        if( aSync )
        {
            wxString cmd = pluginPath;
 
            for( const wxString& arg : action->args )
                cmd << " " << arg;
 
            wxArrayString out, err;
 
            pidOrRetCode = wxExecute( cmd, out, err, wxEXEC_BLOCK, &env );
 
            if( aStdout )
            {
                for( const wxString& line : out )
                    *aStdout << line << "\n";
            }
 
            wxString stdErr;
 
            for( const wxString& line : err )
                stdErr << line << "\n";
 
            if( aStderr )
                *aStderr = stdErr;
 
            reportPluginActionResult( aReporter.get(), action->name, pidOrRetCode, stdErr );
            return pidOrRetCode;
        }
        else
        {
            ACTION_PROCESS* process = new ACTION_PROCESS(
                    [aReporter, action]( int aRetVal, const wxString& aOutput,
                                             const wxString& aError )
                    {
                        wxLogTrace( traceApi,
                                    wxString::Format( "Manager: action exited with code %d", aRetVal ) );
 
                        if( !aError.IsEmpty() )
                            wxLogTrace( traceApi,
                                        wxString::Format( "Manager: action stderr: %s", aError ) );
 
                        reportPluginActionResult( aReporter.get(), action->name, aRetVal, aError );
                    } );
 
            process->Redirect();
            args.emplace_back( pluginPath.wc_str() );
 
            for( const wxString& arg : action->args )
                args.emplace_back( arg.wc_str() );
 
            args.emplace_back( nullptr );
 
            pidOrRetCode = wxExecute( const_cast<wchar_t**>( args.data() ),
                                      wxEXEC_ASYNC | wxEXEC_HIDE_CONSOLE, process, &env );
 
            if( !pidOrRetCode )
                delete process;
        }
 
        if( !pidOrRetCode )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: launching action %s failed",
                                                    action->identifier ) );
            reportPluginActionMessage( aReporter.get(), action->name, _( "could not launch plugin" ) );
        }
        else
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: launching action %s -> pid %ld",
                                                    action->identifier, pidOrRetCode ) );
        }
        break;
    }
 
    default:
        wxLogTrace( traceApi, wxString::Format( "Manager: unhandled runtime for action %s",
                                                action->identifier ) );
    }
 
    return -1;
}
 
 
void API_PLUGIN_MANAGER::InvokeAction( const wxString& aIdentifier,
                                       std::shared_ptr<REPORTER> aReporter )
{
    doInvokeAction( aIdentifier, {}, false, nullptr, nullptr, std::move( aReporter ) );
}
 
 
int API_PLUGIN_MANAGER::InvokeActionSync( const wxString& aIdentifier, std::vector<wxString> aExtraArgs,
                                          wxString* aStdout, wxString* aStderr,
                                          std::shared_ptr<REPORTER> aReporter )
{
    return doInvokeAction( aIdentifier, aExtraArgs, true, aStdout, aStderr,
                           std::move( aReporter ) );
}
 
 
std::vector<const PLUGIN_ACTION*> API_PLUGIN_MANAGER::GetActionsForScope( PLUGIN_ACTION_SCOPE aScope )
{
    std::vector<const PLUGIN_ACTION*> actions;
 
    for( auto& [identifier, action] : m_actionsCache )
    {
        if( !m_readyPlugins.count( action->plugin.Identifier() ) )
            continue;
 
        if( action->scopes.count( aScope ) )
            actions.emplace_back( action );
    }
 
    return actions;
}
 
 
void API_PLUGIN_MANAGER::processPluginDependencies()
{
    bool addedAnyJobs = false;
 
    for( const std::unique_ptr<API_PLUGIN>& plugin : m_plugins )
    {
        if( m_busyPlugins.contains( plugin->Identifier() ) )
            continue;
 
        wxLogTrace( traceApi, wxString::Format( "Manager: processing dependencies for %s",
                                                plugin->Identifier() ) );
        m_environmentCache[plugin->Identifier()] = wxEmptyString;
 
        if( plugin->Runtime().type != PLUGIN_RUNTIME_TYPE::PYTHON )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: %s is not a Python plugin, all set",
                                                    plugin->Identifier() ) );
            m_readyPlugins.insert( plugin->Identifier() );
            continue;
        }
 
        std::optional<wxString> env = PYTHON_MANAGER::GetPythonEnvironment( plugin->Identifier() );
 
        if( !env )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: could not create env for %s",
                                                     plugin->Identifier() ) );
            continue;
        }
 
        m_busyPlugins.insert( plugin->Identifier() );
 
        wxFileName envConfigPath( *env, wxS( "pyvenv.cfg" ) );
        envConfigPath.MakeAbsolute();
 
        if( envConfigPath.IsFileReadable() )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: Python env for %s exists at %s",
                                                    plugin->Identifier(),
                                                    envConfigPath.GetPath() ) );
            JOB job;
            job.type = JOB_TYPE::INSTALL_REQUIREMENTS;
            job.identifier = plugin->Identifier();
            job.plugin_path = plugin->BasePath();
            job.env_path = envConfigPath.GetPath();
            m_jobs.emplace_back( job );
            addedAnyJobs = true;
            continue;
        }
 
        wxLogTrace( traceApi, wxString::Format( "Manager: will create Python env for %s at %s",
                                                plugin->Identifier(), envConfigPath.GetPath() ) );
        JOB job;
        job.type = JOB_TYPE::CREATE_ENV;
        job.identifier = plugin->Identifier();
        job.plugin_path = plugin->BasePath();
        job.env_path = envConfigPath.GetPath();
        m_jobs.emplace_back( job );
        addedAnyJobs = true;
    }
 
    if( addedAnyJobs )
    {
        wxCommandEvent* evt = new wxCommandEvent( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, wxID_ANY );
        QueueEvent( evt );
    }
}
 
 
void API_PLUGIN_MANAGER::processNextJob( wxCommandEvent& aEvent )
{
    if( m_jobs.empty() )
    {
        wxLogTrace( traceApi, "Manager: no more jobs to process" );
        return;
    }
 
    wxLogTrace( traceApi, wxString::Format( "Manager: begin processing; %zu jobs left in queue",
                                            m_jobs.size() ) );
 
    JOB& job = m_jobs.front();
 
    if( job.type == JOB_TYPE::CREATE_ENV )
    {
        wxLogTrace( traceApi, "Manager: Using Python interpreter at %s",
                    Pgm().GetCommonSettings()->m_Api.python_interpreter );
        wxLogTrace( traceApi, wxString::Format( "Manager: creating Python env at %s",
                                                job.env_path ) );
        PYTHON_MANAGER manager( Pgm().GetCommonSettings()->m_Api.python_interpreter );
        wxExecuteEnv   env;
 
#ifdef _WIN32
        wxString systemRoot;
        wxGetEnv( wxS( "SYSTEMROOT" ), &systemRoot );
        env.env[wxS( "SYSTEMROOT" )] = systemRoot;
 
        if( Pgm().GetCommonSettings()->m_Api.python_interpreter == FindKicadFile( "pythonw.exe" )
            || wxGetEnv( wxT( "KICAD_RUN_FROM_BUILD_DIR" ), nullptr ) )
        {
            wxLogTrace( traceApi, "Configured Python is the KiCad one; erasing path overrides..." );
            env.env.erase( "PYTHONHOME" );
            env.env.erase( "PYTHONPATH" );
        }
#endif
        std::vector<wxString> args = {
                "-m",
                "venv",
                "--system-site-packages",
                job.env_path
            };
 
        manager.Execute( args,
                [this, job]( int aRetVal, const wxString& aOutput, const wxString& aError )
                {
                    wxLogTrace( traceApi,
                                wxString::Format( "Manager: created venv (python returned %d)", aRetVal ) );
 
                    if( !aError.IsEmpty() )
                        wxLogTrace( traceApi, wxString::Format( "Manager: venv err: %s", aError ) );
 
                    if( aRetVal != 0 )
                    {
                        wxString error = aError;
                        error.Trim().Trim( false );
 
                        if( error.IsEmpty() )
                            error = wxString::Format( _( "error code %d" ), aRetVal );
 
                        error = wxString::Format( _( "could not create plugin environment: %s" ), error );
 
                        reportPluginLoadMessage( m_reloadReporter.get(), job.identifier, error );
                    }
 
                    wxCommandEvent* evt =
                            new wxCommandEvent( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, wxID_ANY );
                    QueueEvent( evt );
                }, &env );
 
        JOB nextJob( job );
        nextJob.type = JOB_TYPE::SETUP_ENV;
        m_jobs.emplace_back( nextJob );
    }
    else if( job.type == JOB_TYPE::SETUP_ENV )
    {
        wxLogTrace( traceApi, wxString::Format( "Manager: setting up environment for %s",
                                                job.plugin_path ) );
 
        std::optional<wxString> pythonHome = PYTHON_MANAGER::GetPythonEnvironment( job.identifier );
        std::optional<wxString> python = PYTHON_MANAGER::GetVirtualPython( job.identifier );
 
        if( !python )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: error: python not found at %s",
                                                    job.env_path ) );
 
            reportPluginLoadMessage( m_reloadReporter.get(), job.identifier,
                                     _( "missing plugin environment" ) );
        }
        else
        {
            PYTHON_MANAGER manager( *python );
            wxExecuteEnv env;
 
            if( pythonHome )
                env.env[wxS( "VIRTUAL_ENV" )] = *pythonHome;
 
#ifdef _WIN32
            wxString systemRoot;
            wxGetEnv( wxS( "SYSTEMROOT" ), &systemRoot );
            env.env[wxS( "SYSTEMROOT" )] = systemRoot;
 
            if( Pgm().GetCommonSettings()->m_Api.python_interpreter
                        == FindKicadFile( "pythonw.exe" )
                || wxGetEnv( wxT( "KICAD_RUN_FROM_BUILD_DIR" ), nullptr ) )
            {
                wxLogTrace( traceApi,
                            "Configured Python is the KiCad one; erasing path overrides..." );
                env.env.erase( "PYTHONHOME" );
                env.env.erase( "PYTHONPATH" );
            }
#endif
 
            std::vector<wxString> args = {
                    "-m",
                    "pip",
                    "install",
                    "--upgrade",
                    "pip"
                };
 
            manager.Execute( args,
                [this, job]( int aRetVal, const wxString& aOutput, const wxString& aError )
                {
                    wxLogTrace( traceApi, wxString::Format( "Manager: upgrade pip returned %d",
                                                            aRetVal ) );
 
                    if( !aError.IsEmpty() )
                    {
                        wxLogTrace( traceApi,
                                    wxString::Format( "Manager: upgrade pip stderr: %s", aError ) );
                    }
 
                    if( aRetVal != 0 )
                    {
                        wxString error = aError;
                        error.Trim().Trim( false );
 
                        if( error.IsEmpty() )
                            error = wxString::Format( _( "error code %d" ), aRetVal );
 
                        error = wxString::Format( _( "could not create plugin environment: %s" ), error );
 
                        reportPluginLoadMessage( m_reloadReporter.get(), job.identifier, error );
                    }
 
                    wxCommandEvent* evt =
                            new wxCommandEvent( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, wxID_ANY );
                    QueueEvent( evt );
                }, &env );
 
            JOB nextJob( job );
            nextJob.type = JOB_TYPE::INSTALL_REQUIREMENTS;
            m_jobs.emplace_back( nextJob );
        }
    }
    else if( job.type == JOB_TYPE::INSTALL_REQUIREMENTS )
    {
        wxLogTrace( traceApi, wxString::Format( "Manager: installing dependencies for %s",
                                                job.plugin_path ) );
 
        std::optional<wxString> pythonHome = PYTHON_MANAGER::GetPythonEnvironment( job.identifier );
        std::optional<wxString> python = PYTHON_MANAGER::GetVirtualPython( job.identifier );
        wxFileName reqs = wxFileName( job.plugin_path, "requirements.txt" );
 
        if( !python )
        {
            wxLogTrace( traceApi, wxString::Format( "Manager: error: python not found at %s",
                                                    job.env_path ) );
 
            reportPluginLoadMessage( m_reloadReporter.get(), job.identifier,
                                     _( "missing plugin environment" ) );
        }
        else if( !reqs.IsFileReadable() )
        {
            wxLogTrace( traceApi,
                        wxString::Format( "Manager: error: requirements.txt not found at %s",
                                          job.plugin_path ) );
 
            reportPluginLoadMessage( m_reloadReporter.get(), job.identifier,
                                     _( "requirements.txt could not be read" ) );
        }
        else
        {
            wxLogTrace( traceApi, "Manager: Python exe '%s'", *python );
 
            PYTHON_MANAGER manager( *python );
            wxExecuteEnv env;
 
#ifdef _WIN32
            wxString systemRoot;
            wxGetEnv( wxS( "SYSTEMROOT" ), &systemRoot );
            env.env[wxS( "SYSTEMROOT" )] = systemRoot;
 
            // If we are using the KiCad-shipped Python interpreter we have to do hacks
            env.env.erase( "PYTHONHOME" );
            env.env.erase( "PYTHONPATH" );
#endif
 
            if( pythonHome )
                env.env[wxS( "VIRTUAL_ENV" )] = *pythonHome;
 
            std::vector<wxString> args = {
                    "-m",
                    "pip",
                    "install",
                    "--no-input",
                    "--isolated",
                    "--only-binary",
                    ":all:",
                    "--require-virtualenv",
                    "--exists-action",
                    "i",
                    "-r",
                    reqs.GetFullPath()
                };
 
            manager.Execute( args,
                [this, job]( int aRetVal, const wxString& aOutput, const wxString& aError )
                {
                    if( !aError.IsEmpty() )
                        wxLogTrace( traceApi, wxString::Format( "Manager: pip stderr: %s", aError ) );
 
                    if( aRetVal != 0 )
                    {
                        wxString error = aError;
                        error.Trim().Trim( false );
 
                        if( error.IsEmpty() )
                            error = wxString::Format( _( "error code %d" ), aRetVal );
 
                        error = wxString::Format( _( "could not create plugin environment: %s" ), error );
 
                        reportPluginLoadMessage( m_reloadReporter.get(), job.identifier, error );
                    }
 
                    if( aRetVal == 0 )
                    {
                        wxLogTrace( traceApi, wxString::Format( "Manager: marking %s as ready",
                                                                job.identifier ) );
                        m_readyPlugins.insert( job.identifier );
 
                        wxCommandEvent* availabilityEvt =
                                new wxCommandEvent( EDA_EVT_PLUGIN_AVAILABILITY_CHANGED, wxID_ANY );
                        wxTheApp->QueueEvent( availabilityEvt );
                    }
 
                    m_busyPlugins.erase( job.identifier );
 
                    wxCommandEvent* evt = new wxCommandEvent( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED,
                                                              wxID_ANY );
 
                    QueueEvent( evt );
                }, &env );
        }
 
        wxCommandEvent* evt = new wxCommandEvent( EDA_EVT_PLUGIN_MANAGER_JOB_FINISHED, wxID_ANY );
        QueueEvent( evt );
    }
 
    m_jobs.pop_front();
 
    if( !Busy() )
        m_reloadReporter.reset();
 
    wxLogTrace( traceApi, wxString::Format( "Manager: finished job; %zu left in queue",
                                            m_jobs.size() ) );
}
 
 
bool API_PLUGIN_MANAGER::Busy() const
{
    return !m_jobs.empty() || !m_busyPlugins.empty();
}