sch_io_http_lib.cpp

Go to the documentation of this file.

/*
 * This program source code file is part of KiCad, a free EDA CAD application.
 *
 * Copyright (C) 2023 Andre F. K. Iwers <[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 <https://www.gnu.org/licenses/>.
 */
 
 
#include <wx/log.h>
#include <wx/tokenzr.h>
 
#include <fmt.h>
#include <lib_symbol.h>
 
#include <libraries/symbol_library_adapter.h>
#include <http_lib/http_lib_connection.h>
#include "sch_io_http_lib.h"
#include <ki_exception.h>
 
 
SCH_IO_HTTP_LIB::SCH_IO_HTTP_LIB() :
        SCH_IO( wxS( "HTTP library" ) ),
        m_adapter( nullptr )
{
}
 
 
void SCH_IO_HTTP_LIB::EnumerateSymbolLib( wxArrayString& aSymbolNameList, const wxString& aLibraryPath,
                                          const std::map<std::string, UTF8>* aProperties )
{
    wxCHECK_RET( m_adapter, "HTTP plugin missing library manager adapter handle!" );
    ensureSettings( aLibraryPath );
    ensureConnection();
 
    if( !m_conn )
        THROW_IO_ERROR( m_lastError );
 
    // The name list drives the library tree and only needs part names, which the category
    // listing already provides.  Avoid the per-part detail fetch done by the full enumeration.
    for( const HTTP_LIB_CATEGORY& category : m_conn->getCategories() )
    {
        syncCacheIfStale( category );
 
        for( const HTTP_LIB_PART& part : m_cachedCategories[category.id].cachedParts )
            aSymbolNameList.Add( part.name );
    }
}
 
 
void SCH_IO_HTTP_LIB::EnumerateSymbolLib( std::vector<LIB_SYMBOL*>& aSymbolList, const wxString& aLibraryPath,
                                          const std::map<std::string, UTF8>* aProperties )
{
    wxCHECK_RET( m_adapter, "HTTP plugin missing library manager adapter handle!" );
    ensureSettings( aLibraryPath );
    ensureConnection();
 
    if( !m_conn )
        THROW_IO_ERROR( m_lastError );
 
    bool powerSymbolsOnly = ( aProperties && aProperties->contains( SYMBOL_LIBRARY_ADAPTER::PropPowerSymsOnly ) );
 
    for( const HTTP_LIB_CATEGORY& category : m_conn->getCategories() )
    {
        syncCacheIfStale( category );
 
        for( HTTP_LIB_PART& part : m_cachedCategories[category.id].cachedParts )
        {
            // The category listing may omit fields, so the chooser would show blank columns
            // until each part is selected individually.  Back-fill from the per-part endpoint.
            if( !part.detailsLoaded )
            {
                HTTP_LIB_PART fullPart;
 
                if( m_conn->SelectOne( part.id, fullPart ) )
                {
                    // The listing name keys m_cache for LoadSymbol; keep it even if the detail
                    // record reports a different (or missing) name.
                    fullPart.id = part.id;
                    fullPart.name = part.name;
                    part = std::move( fullPart );
                }
            }
 
            wxString libIDString( part.name );
 
            LIB_SYMBOL* symbol = loadSymbolFromPart( aLibraryPath, libIDString, category, part );
 
            if( symbol && ( !powerSymbolsOnly || symbol->IsPower() ) )
                aSymbolList.emplace_back( symbol );
        }
    }
}
 
 
LIB_SYMBOL* SCH_IO_HTTP_LIB::LoadSymbol( const wxString& aLibraryPath, const wxString& aAliasName,
                                         const std::map<std::string, UTF8>* aProperties )
{
    wxCHECK_MSG( m_adapter, nullptr, "HTTP plugin missing library manager adapter handle!" );
    ensureSettings( aLibraryPath );
    ensureConnection();
 
    if( !m_conn )
        THROW_IO_ERROR( m_lastError );
 
    std::string part_id = "";
 
    std::string partName( aAliasName.ToUTF8() );
 
    const HTTP_LIB_CATEGORY* foundCategory = nullptr;
    HTTP_LIB_PART            result;
 
    std::vector<HTTP_LIB_CATEGORY> categories = m_conn->getCategories();
 
    if( m_conn->GetCachedParts().empty() )
        syncCache();
 
    std::tuple  relations = m_conn->GetCachedParts()[partName];
    std::string associatedCatID = std::get<1>( relations );
 
    // get the matching category
    for( const HTTP_LIB_CATEGORY& categoryIter : categories )
    {
        if( categoryIter.id == associatedCatID )
        {
            foundCategory = &categoryIter;
            break;
        }
    }
 
    // return Null if no category was found. This should never happen
    if( foundCategory == nullptr )
    {
        wxLogTrace( traceHTTPLib, wxT( "loadSymbol: no category found for %s" ), partName );
        return nullptr;
    }
 
    // get the matching query ID
    for( const HTTP_LIB_PART& part : m_cachedCategories[foundCategory->id].cachedParts )
    {
        if( part.id == std::get<0>( relations ) )
        {
            part_id = part.id;
            break;
        }
    }
 
    if( m_conn->SelectOne( part_id, result ) )
    {
        wxLogTrace( traceHTTPLib, wxT( "LoadSymbol: SelectOne (%s) found in %s" ), part_id, foundCategory->name );
    }
    else
    {
        wxLogTrace( traceHTTPLib, wxT( "LoadSymbol: SelectOne (%s) failed for category %s" ), part_id,
                    foundCategory->name );
 
        THROW_IO_ERROR( m_lastError );
    }
 
    wxCHECK( foundCategory, nullptr );
 
    return loadSymbolFromPart( aLibraryPath, aAliasName, *foundCategory, result );
}
 
 
void SCH_IO_HTTP_LIB::GetSubLibraryNames( std::vector<wxString>& aNames )
{
    aNames.clear();
 
    ensureSettings( wxEmptyString );
    connect();
 
    // connect() leaves m_conn null when the endpoint is unreachable so a network loss
    // degrades to an empty result instead of a null dereference while building the tree.
    if( !m_conn )
        return;
 
    std::set<wxString> categoryNames;
 
    for( const HTTP_LIB_CATEGORY& categoryIter : m_conn->getCategories() )
    {
        if( categoryNames.count( categoryIter.name ) )
            continue;
 
        aNames.emplace_back( categoryIter.name );
        categoryNames.insert( categoryIter.name );
    }
}
 
 
wxString SCH_IO_HTTP_LIB::GetSubLibraryDescription( const wxString& aName )
{
    ensureSettings( wxEmptyString );
    connect();
 
    if( !m_conn )
        return wxEmptyString;
 
    return m_conn->getCategoryDescription( std::string( aName.mb_str() ) );
}
 
 
void SCH_IO_HTTP_LIB::GetAvailableSymbolFields( std::vector<wxString>& aNames )
{
    // TODO: Implement this sometime; This is currently broken...
    std::copy( m_customFields.begin(), m_customFields.end(), std::back_inserter( aNames ) );
}
 
 
void SCH_IO_HTTP_LIB::GetDefaultSymbolFields( std::vector<wxString>& aNames )
{
    std::copy( m_defaultShownFields.begin(), m_defaultShownFields.end(), std::back_inserter( aNames ) );
}
 
 
void SCH_IO_HTTP_LIB::ensureSettings( const wxString& aSettingsPath )
{
    auto tryLoad =
            [&]()
            {
                if( !m_settings->LoadFromFile() )
                {
                    THROW_IO_ERROR( wxString::Format( _( "HTTP library settings file %s missing or invalid." ),
                                                      aSettingsPath ) );
                }
 
                if( m_settings->m_Source.api_version.empty() )
                {
                    THROW_IO_ERROR( wxString::Format( _( "HTTP library settings file %s is missing the API version "
                                                         "number." ),
                                                      aSettingsPath ) );
                }
 
                if( m_settings->getSupportedAPIVersion() != m_settings->m_Source.api_version )
                {
                    THROW_IO_ERROR( wxString::Format( _( "HTTP library settings file %s uses API version %s, but "
                                                         "KiCad requires version %s." ),
                                                      aSettingsPath, m_settings->m_Source.api_version,
                                                      m_settings->getSupportedAPIVersion() ) );
                }
 
                if( m_settings->m_Source.root_url.empty() )
                {
                    THROW_IO_ERROR( wxString::Format( _( "HTTP library settings file %s is missing the root URL." ),
                                                      aSettingsPath ) );
                }
 
                // map lib source type
                m_settings->m_Source.type = m_settings->get_HTTP_LIB_SOURCE_TYPE();
 
                if( m_settings->m_Source.type == HTTP_LIB_SOURCE_TYPE::INVALID )
                {
                    THROW_IO_ERROR( wxString::Format( _( "HTTP library settings file %s has invalid library type." ),
                                                      aSettingsPath ) );
                }
 
                // make sure that the root url finishes with a forward slash
                if( m_settings->m_Source.root_url.at( m_settings->m_Source.root_url.length() - 1 ) != '/' )
                    m_settings->m_Source.root_url += "/";
 
                // Append api version to root URL
                m_settings->m_Source.root_url += m_settings->m_Source.api_version + "/";
            };
 
    if( !m_settings && !aSettingsPath.IsEmpty() )
    {
        std::string path( aSettingsPath.ToUTF8() );
        m_settings = std::make_unique<HTTP_LIB_SETTINGS>( path );
 
        m_settings->SetReadOnly( true );
 
        tryLoad();
    }
    else if( m_settings )
    {
        // If we have valid settings but no connection yet; reload settings in case user is editing
        tryLoad();
    }
    else if( !m_settings )
    {
        wxLogTrace( traceHTTPLib, wxT( "ensureSettings: no settings available!" ) );
    }
}
 
 
void SCH_IO_HTTP_LIB::ensureConnection()
{
    wxCHECK_RET( m_settings, "Call ensureSettings before ensureConnection!" );
 
    connect();
 
    if( !m_conn || !m_conn->IsValidEndpoint() )
    {
        THROW_IO_ERROR( wxString::Format( _( "Could not connect to %s. Errors: %s" ),
                                          m_settings->m_Source.root_url,
                                          m_lastError ) );
    }
}
 
 
void SCH_IO_HTTP_LIB::connect()
{
    wxCHECK_RET( m_settings, "Call ensureSettings before connect()!" );
 
    if( !m_conn )
    {
        m_conn = std::make_unique<HTTP_LIB_CONNECTION>( m_settings->m_Source, true );
 
        if( !m_conn->IsValidEndpoint() )
        {
            m_lastError = m_conn->GetLastError();
 
            // Make sure we release pointer so we are able to query API again next time
            m_conn.reset();
 
            return;
        }
    }
}
 
 
void SCH_IO_HTTP_LIB::syncCache()
{
    for( const HTTP_LIB_CATEGORY& category : m_conn->getCategories() )
        syncCache( category );
}
 
 
void SCH_IO_HTTP_LIB::syncCacheIfStale( const HTTP_LIB_CATEGORY& category )
{
    auto it = m_cachedCategories.find( category.id );
 
    if( it != m_cachedCategories.end()
        && std::difftime( std::time( nullptr ), it->second.lastCached )
                   < m_settings->m_Source.timeout_categories )
    {
        return;
    }
 
    syncCache( category );
}
 
 
void SCH_IO_HTTP_LIB::syncCache( const HTTP_LIB_CATEGORY& category )
{
    std::vector<HTTP_LIB_PART> found_parts;
 
    if( !m_conn->SelectAll( category, found_parts ) )
    {
        if( !m_conn->GetLastError().empty() )
        {
            THROW_IO_ERROR( wxString::Format( _( "Error retrieving data from HTTP library %s: %s" ),
                                              category.name,
                                              m_conn->GetLastError() ) );
        }
 
        return;
    }
 
    // remove cached parts
    m_cachedCategories[category.id].cachedParts.clear();
 
    // Copy newly cached data across
    m_cachedCategories[category.id].cachedParts = found_parts;
    m_cachedCategories[category.id].lastCached = std::time( nullptr );
}
 
 
LIB_SYMBOL* SCH_IO_HTTP_LIB::loadSymbolFromPart( const wxString& aLibraryPath,
                                                 const wxString& aSymbolName,
                                                 const HTTP_LIB_CATEGORY& aCategory,
                                                 const HTTP_LIB_PART& aPart )
{
    LIB_SYMBOL* symbol = nullptr;
    LIB_SYMBOL* originalSymbol = nullptr;
    LIB_ID      symbolId;
 
    std::string symbolIdStr = aPart.symbolIdStr;
 
    // Extract library nickname from the library path (e.g., "/path/to/W5.kicad_httplib" -> "W5")
    wxFileName libFileName( aLibraryPath );
    wxString   libNickname = libFileName.GetName();
 
    // Get or Create the symbol using the found symbol
    if( !symbolIdStr.empty() )
    {
        symbolId.Parse( symbolIdStr );
 
        if( symbolId.IsValid() )
            originalSymbol = m_adapter->LoadSymbol( symbolId );
 
        if( originalSymbol )
        {
            wxLogTrace( traceHTTPLib, wxT( "loadSymbolFromPart: found original symbol '%s'" ), symbolIdStr );
 
            symbol = originalSymbol->Duplicate();
            symbol->SetSourceLibId( symbolId );
            symbol->SetName( aSymbolName );
 
            LIB_ID libId = symbol->GetLibId();
            libId.SetLibNickname( libNickname );
            libId.SetSubLibraryName( aCategory.name );
            symbol->SetLibId( libId );
        }
        else if( !symbolId.IsValid() )
        {
            wxLogTrace( traceHTTPLib, wxT( "loadSymbolFromPart: source symbol id '%s' is invalid, "
                                           "will create empty symbol" ), symbolIdStr );
        }
        else
        {
            wxLogTrace( traceHTTPLib, wxT( "loadSymbolFromPart: source symbol '%s' not found, "
                                           "will create empty symbol" ), symbolIdStr );
        }
    }
 
    if( !symbol )
    {
        // Actual symbol not found: return metadata only; error will be
        // indicated in the symbol chooser
        symbol = new LIB_SYMBOL( aSymbolName );
 
        LIB_ID libId = symbol->GetLibId();
        libId.SetLibNickname( libNickname );
        libId.SetSubLibraryName( aCategory.name );
        symbol->SetLibId( libId );
    }
 
    symbol->SetExcludedFromBOM( aPart.exclude_from_bom );
    symbol->SetExcludedFromBoard( aPart.exclude_from_board );
    symbol->SetExcludedFromSim( aPart.exclude_from_sim );
 
    wxArrayString fp_filters;
 
    for( auto& [fieldName, fieldProperties] : aPart.fields )
    {
        wxString lowerFieldName = wxString( fieldName ).Lower();
 
        if( lowerFieldName == footprint_field )
        {
            SCH_FIELD*        field = &symbol->GetFootprintField();
            wxStringTokenizer tokenizer( std::get<0>( fieldProperties ), ";\t\r\n", wxTOKEN_STRTOK );
 
            while( tokenizer.HasMoreTokens() )
                fp_filters.Add( tokenizer.GetNextToken() );
 
            if( fp_filters.size() > 0 )
                field->SetText( fp_filters[0] );
 
            field->SetVisible( std::get<1>( fieldProperties ) );
        }
        else if( lowerFieldName == description_field )
        {
            SCH_FIELD* field = &symbol->GetDescriptionField();
            field->SetText( std::get<0>( fieldProperties ) );
            field->SetVisible( std::get<1>( fieldProperties ) );
        }
        else if( lowerFieldName == value_field )
        {
            SCH_FIELD* field = &symbol->GetValueField();
            field->SetText( std::get<0>( fieldProperties ) );
            field->SetVisible( std::get<1>( fieldProperties ) );
        }
        else if( lowerFieldName == datasheet_field )
        {
            SCH_FIELD* field = &symbol->GetDatasheetField();
            field->SetText( std::get<0>( fieldProperties ) );
            field->SetVisible( std::get<1>( fieldProperties ) );
        }
        else if( lowerFieldName == reference_field )
        {
            SCH_FIELD* field = &symbol->GetReferenceField();
            field->SetText( std::get<0>( fieldProperties ) );
            field->SetVisible( std::get<1>( fieldProperties ) );
        }
        else if( lowerFieldName == keywords_field )
        {
            symbol->SetKeyWords( std::get<0>( fieldProperties ) );
        }
        else
        {
            // Check if field exists, if so replace Text and adjust visiblity.
            //
            // This proves useful in situations where, for instance, an individual requires a particular value, such as
            // the material type showcased at a specific position for a capacitor. Subsequently, this value could be defined
            // in the symbol itself and then, potentially, be modified by the HTTP library as necessary.
            SCH_FIELD* field = symbol->GetField( fieldName );
 
            if( field != nullptr )
            {
                // adjust values accordingly
                field->SetText( std::get<0>( fieldProperties ) );
                field->SetVisible( std::get<1>( fieldProperties ) );
            }
            else
            {
                // Generic fields
                field = new SCH_FIELD( symbol, FIELD_T::USER );
                field->SetName( fieldName );
 
                field->SetText( std::get<0>( fieldProperties ) );
                field->SetVisible( std::get<1>( fieldProperties ) );
                symbol->AddField( field );
 
                m_customFields.insert( fieldName );
            }
        }
    }
 
    symbol->SetDescription( aPart.desc );
    symbol->SetKeyWords( aPart.keywords );
 
    for( const std::string& filter : aPart.fp_filters )
        fp_filters.push_back( filter );
 
    symbol->SetFPFilters( fp_filters );
 
    // Pin-to-pad maps (issue #2282): attach non-destructively.  Prefer the spec-form named maps +
    // associations when the payload supplies them; otherwise fall back to the legacy flat form for
    // one release, bound to the symbol's concrete Footprint field (fp_filters may carry globs).
    if( !aPart.named_pin_maps.IsEmpty() || !aPart.associated_footprints.empty() )
    {
        symbol->SetPinMaps( aPart.named_pin_maps );
        symbol->SetAssociatedFootprints( aPart.associated_footprints );
    }
    else
    {
        const wxString assignedFootprint = symbol->GetFootprintField().GetText();
 
        if( !aPart.pin_map.empty() && !assignedFootprint.IsEmpty() )
        {
            const wxString mapName = wxS( "HTTP Library" );
 
            symbol->PinMaps().AddOrReplace( MakeLegacyPinMap( mapName, aPart.pin_map ) );
 
            LIB_ID fpId;
            fpId.Parse( assignedFootprint );
            symbol->SetAssociatedFootprints( { { fpId, mapName } } );
        }
    }
 
    return symbol;
}
 
void SCH_IO_HTTP_LIB::SaveSymbol( const wxString& aLibraryPath, const LIB_SYMBOL* aSymbol,
                                  const std::map<std::string, UTF8>* aProperties )
{
    // TODO: Implement this sometime;
}