mirror of
https://github.com/tomahawk-player/tomahawk.git
synced 2025-08-01 03:40:16 +02:00
Start on acl entry clearing; also change where we strip the JID
This commit is contained in:
@@ -291,3 +291,12 @@ ACLRegistry::save()
|
|||||||
}
|
}
|
||||||
TomahawkSettings::instance()->setAclEntries( entryList );
|
TomahawkSettings::instance()->setAclEntries( entryList );
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
void
|
||||||
|
ACLRegistry::wipeEntries()
|
||||||
|
{
|
||||||
|
tLog() << Q_FUNC_INFO;
|
||||||
|
m_cache.clear();
|
||||||
|
save();
|
||||||
|
}
|
||||||
|
@@ -102,11 +102,14 @@ public slots:
|
|||||||
|
|
||||||
#ifndef ENABLE_HEADLESS
|
#ifndef ENABLE_HEADLESS
|
||||||
void getUserDecision( ACLRegistry::User user, const QString &username );
|
void getUserDecision( ACLRegistry::User user, const QString &username );
|
||||||
|
#endif
|
||||||
|
|
||||||
private slots:
|
private slots:
|
||||||
|
#ifndef ENABLE_HEADLESS
|
||||||
void userDecision( ACLRegistry::User user );
|
void userDecision( ACLRegistry::User user );
|
||||||
void queueNextJob();
|
void queueNextJob();
|
||||||
#endif
|
#endif
|
||||||
|
void wipeEntries();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
/**
|
/**
|
||||||
|
@@ -200,9 +200,10 @@ Connection::checkACL()
|
|||||||
}
|
}
|
||||||
|
|
||||||
QString nodeid = property( "nodeid" ).toString();
|
QString nodeid = property( "nodeid" ).toString();
|
||||||
|
QString barePeerId = nodeid.left( nodeid.indexOf( "/" ) );
|
||||||
tDebug( LOGVERBOSE ) << Q_FUNC_INFO << "Checking ACL for" << name();
|
tDebug( LOGVERBOSE ) << Q_FUNC_INFO << "Checking ACL for" << name();
|
||||||
connect( ACLRegistry::instance(), SIGNAL( aclResult( QString, QString, ACLRegistry::ACL ) ), this, SLOT( checkACLResult( QString, QString, ACLRegistry::ACL ) ), Qt::QueuedConnection );
|
connect( ACLRegistry::instance(), SIGNAL( aclResult( QString, QString, ACLRegistry::ACL ) ), this, SLOT( checkACLResult( QString, QString, ACLRegistry::ACL ) ), Qt::QueuedConnection );
|
||||||
QMetaObject::invokeMethod( ACLRegistry::instance(), "isAuthorizedUser", Qt::QueuedConnection, Q_ARG( QString, nodeid ), Q_ARG( QString, name() ), Q_ARG( ACLRegistry::ACL, ACLRegistry::NotFound ) );
|
QMetaObject::invokeMethod( ACLRegistry::instance(), "isAuthorizedUser", Qt::QueuedConnection, Q_ARG( QString, barePeerId ), Q_ARG( QString, name() ), Q_ARG( ACLRegistry::ACL, ACLRegistry::NotFound ) );
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@@ -171,6 +171,9 @@ SipHandler::onSipInfo( const QString& peerId, const SipInfo& info )
|
|||||||
|
|
||||||
QString barePeerId = peerId.left( peerId.indexOf( "/" ) );
|
QString barePeerId = peerId.left( peerId.indexOf( "/" ) );
|
||||||
|
|
||||||
|
//FIXME: We should probably be using barePeerId in the connectToPeer call below.
|
||||||
|
//But, verify this doesn't cause any problems (there is still a uniquename after all)
|
||||||
|
|
||||||
/*
|
/*
|
||||||
If only one party is externally visible, connection is obvious
|
If only one party is externally visible, connection is obvious
|
||||||
If both are, peer with lowest IP address initiates the connection.
|
If both are, peer with lowest IP address initiates the connection.
|
||||||
@@ -181,11 +184,11 @@ SipHandler::onSipInfo( const QString& peerId, const SipInfo& info )
|
|||||||
if( !Servent::instance()->visibleExternally() ||
|
if( !Servent::instance()->visibleExternally() ||
|
||||||
Servent::instance()->externalAddress() <= info.host().hostName() )
|
Servent::instance()->externalAddress() <= info.host().hostName() )
|
||||||
{
|
{
|
||||||
qDebug() << "Initiate connection to" << barePeerId;
|
qDebug() << "Initiate connection to" << peerId;
|
||||||
Servent::instance()->connectToPeer( info.host().hostName(),
|
Servent::instance()->connectToPeer( info.host().hostName(),
|
||||||
info.port(),
|
info.port(),
|
||||||
info.key(),
|
info.key(),
|
||||||
barePeerId,
|
peerId,
|
||||||
info.uniqname() );
|
info.uniqname() );
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
Reference in New Issue
Block a user