File indexing completed on 2025-01-05 03:59:34

 // SPDX-License-Identifier: LGPL-2.1-or-later
 //
 // SPDX-FileCopyrightText: 2008 Henry de Valence <hdevalence@gmail.com>
 // SPDX-FileCopyrightText: 2010 Dennis Nienhüser <nienhueser@kde.org>
 // SPDX-FileCopyrightText: 2010-2013 Bernhard Beschow <bbeschow@cs.tu-berlin.de>
 // SPDX-FileCopyrightText: 2011 Thibaut Gridel <tgridel@free.fr>
 
 #include "ReverseGeocodingRunnerManager.h"
 
 #include <QList>
 #include <QThreadPool>
 #include <QTimer>
 
 #include "MarbleModel.h"
 #include "GeoDataCoordinates.h"
 #include "GeoDataPlacemark.h"
 #include "Planet.h"
 #include "PluginManager.h"
 #include "ReverseGeocodingRunnerPlugin.h"
 #include "RunnerTask.h"
 
 #include "digikam_debug.h"
 
 namespace Marble
 {
 
 class MarbleModel;
 
 class Q_DECL_HIDDEN ReverseGeocodingRunnerManager::Private
 {
 public:
     Private( ReverseGeocodingRunnerManager *parent, const MarbleModel *marbleModel );
 
     QList<const ReverseGeocodingRunnerPlugin *> plugins( const QList<const ReverseGeocodingRunnerPlugin *> &plugins ) const;
 
     void addReverseGeocodingResult( const GeoDataCoordinates &coordinates, const GeoDataPlacemark &placemark );
     void cleanupReverseGeocodingTask( ReverseGeocodingTask *task );
 
     ReverseGeocodingRunnerManager *const q;
     const MarbleModel *const m_marbleModel;
     const PluginManager* m_pluginManager;
     QList<ReverseGeocodingTask*> m_reverseTasks;
     QVector<GeoDataCoordinates> m_reverseGeocodingResults;
     QString m_reverseGeocodingResult;
 };
 
 ReverseGeocodingRunnerManager::Private::Private( ReverseGeocodingRunnerManager *parent, const MarbleModel *marbleModel ) :
     q( parent ),
     m_marbleModel( marbleModel ),
     m_pluginManager( marbleModel->pluginManager() )
 {
     qRegisterMetaType<GeoDataPlacemark>( "GeoDataPlacemark" );
     qRegisterMetaType<GeoDataCoordinates>( "GeoDataCoordinates" );
 }
 
 QList<const ReverseGeocodingRunnerPlugin *> ReverseGeocodingRunnerManager::Private::plugins( const QList<const ReverseGeocodingRunnerPlugin *> &plugins ) const
 {
     QList<const ReverseGeocodingRunnerPlugin *> result;
 
     for( const ReverseGeocodingRunnerPlugin *plugin: plugins ) {
         if ( ( m_marbleModel && m_marbleModel->workOffline() && !plugin->canWorkOffline() ) ) {
             continue;
         }
 
         if ( !plugin->canWork() ) {
             continue;
         }
 
         if ( m_marbleModel && !plugin->supportsCelestialBody( m_marbleModel->planet()->id() ) )
         {
             continue;
         }
 
         result << plugin;
     }
 
     return result;
 }
 
 void ReverseGeocodingRunnerManager::Private::addReverseGeocodingResult( const GeoDataCoordinates &coordinates, const GeoDataPlacemark &placemark )
 {
     if ( !m_reverseGeocodingResults.contains( coordinates ) && !placemark.address().isEmpty() ) {
         m_reverseGeocodingResults.push_back( coordinates );
         m_reverseGeocodingResult = placemark.address();
         Q_EMIT q->reverseGeocodingFinished( coordinates, placemark );
     }
 
     if ( m_reverseTasks.isEmpty() ) {
         Q_EMIT q->reverseGeocodingFinished();
     }
 }
 
 void ReverseGeocodingRunnerManager::Private::cleanupReverseGeocodingTask( ReverseGeocodingTask *task )
 {
     m_reverseTasks.removeAll( task );
     qCDebug(DIGIKAM_MARBLE_LOG) << "removing task " << m_reverseTasks.size() << " " << (quintptr)task;
     if ( m_reverseTasks.isEmpty() ) {
         Q_EMIT q->reverseGeocodingFinished();
     }
 }
 
 ReverseGeocodingRunnerManager::ReverseGeocodingRunnerManager( const MarbleModel *marbleModel, QObject *parent ) :
     QObject( parent ),
     d( new Private( this, marbleModel ) )
 {
     if ( QThreadPool::globalInstance()->maxThreadCount() < 4 ) {
         QThreadPool::globalInstance()->setMaxThreadCount( 4 );
     }
 }
 
 ReverseGeocodingRunnerManager::~ReverseGeocodingRunnerManager()
 {
     delete d;
 }
 
 void ReverseGeocodingRunnerManager::reverseGeocoding( const GeoDataCoordinates &coordinates )
 {
     d->m_reverseTasks.clear();
     d->m_reverseGeocodingResult.clear();
     d->m_reverseGeocodingResults.removeAll( coordinates );
 
     QList<const ReverseGeocodingRunnerPlugin*> plugins = d->plugins( d->m_pluginManager->reverseGeocodingRunnerPlugins() );
     for( const ReverseGeocodingRunnerPlugin* plugin: plugins ) {
         ReverseGeocodingTask* task = new ReverseGeocodingTask( plugin->newRunner(), this, d->m_marbleModel, coordinates );
         connect( task, SIGNAL(finished(ReverseGeocodingTask*)), this, SLOT(cleanupReverseGeocodingTask(ReverseGeocodingTask*)) );
         qCDebug(DIGIKAM_MARBLE_LOG) << "reverse task " << plugin->nameId() << " " << (quintptr)task;
         d->m_reverseTasks << task;
     }
 
     for( ReverseGeocodingTask* task: d->m_reverseTasks ) {
         QThreadPool::globalInstance()->start( task );
     }
 
     if ( plugins.isEmpty() ) {
         GeoDataPlacemark anonymous;
         anonymous.setCoordinate( coordinates );
         Q_EMIT reverseGeocodingFinished( coordinates, anonymous );
         d->cleanupReverseGeocodingTask( nullptr );
     }
 }
 
 QString ReverseGeocodingRunnerManager::searchReverseGeocoding( const GeoDataCoordinates &coordinates, int timeout ) {
     QEventLoop localEventLoop;
     QTimer watchdog;
     watchdog.setSingleShot(true);
     connect( &watchdog, SIGNAL(timeout()),
              &localEventLoop, SLOT(quit()));
     connect(this, SIGNAL(reverseGeocodingFinished()),
             &localEventLoop, SLOT(quit()), Qt::QueuedConnection );
 
     watchdog.start( timeout );
     reverseGeocoding( coordinates );
     localEventLoop.exec();
     return d->m_reverseGeocodingResult;
 }
 
 }
 
 #include "moc_ReverseGeocodingRunnerManager.cpp"