Autres/Rivendellaudio
1
0
Fork 0
mirror of https://github.com/ElvishArtisan/rivendell.git synced 2025-05-19 14:43:30 +02:00
Code Issues Projects Releases Wiki Activity

2023-04-12 Fred Gleason <fredg@paravelsystems.com>

Browse Source 
* Removed file purging functionality from the 'Westwood One Wegener
	Portal' replicator.

Signed-off-by: Fred Gleason <fredg@paravelsystems.com>
This commit is contained in:
Fred Gleason 2023-04-12 14:02:39 -04:00
parent 4d95134b13
commit cd0f4dad31
3 changed files with 3 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ChangeLog
View File

@ -24026,3 +24026,6 @@
2023-04-12 Fred Gleason <fredg@paravelsystems.com> 2023-04-12 Fred Gleason <fredg@paravelsystems.com>
* Added 'RDReplicator::roundDownToDow()' methods. * Added 'RDReplicator::roundDownToDow()' methods.
* Added a 'Westwood One Wegener Portal' replicator. * Added a 'Westwood One Wegener Portal' replicator.
2023-04-12 Fred Gleason <fredg@paravelsystems.com>
* Removed file purging functionality from the 'Westwood One Wegener
Portal' replicator.

58
rdrepld/ww1ipump.cpp
View File

@ -91,7 +91,6 @@ void Ww1Ipump::CheckIsciXreference()
sql="update `VERSION` set `LAST_ISCI_XREFERENCE`=now()"; sql="update `VERSION` set `LAST_ISCI_XREFERENCE`=now()";
RDSqlQuery::apply(sql); RDSqlQuery::apply(sql);
xds_isci_datetime=QDateTime(QDate::currentDate(),QTime::currentTime()); xds_isci_datetime=QDateTime(QDate::currentDate(),QTime::currentTime());
PurgeCuts();
} }
} }
} }
@ -403,60 +402,3 @@ bool Ww1Ipump::PostCut(const QString &cutname,const QString &filename)
return true; return true;
} }
void Ww1Ipump::PurgeCuts()
{
QString sql;
RDSqlQuery *q;
RDSqlQuery *q1;
RDSqlQuery *q2;
RDDelete *conv;
RDDelete::ErrorCode conv_err;
sql=QString("select ")+
"`ID`,"+ // 00
"`POSTED_FILENAME` "+ // 01
"from `REPL_CART_STATE` where "+
"`REPLICATOR_NAME`='"+RDEscapeString(config()->name())+"'";
q=new RDSqlQuery(sql);
while(q->next()) {
sql=QString("select `ID` from `ISCI_XREFERENCE` where ")+
"`FILENAME`='"+RDEscapeString(q->value(1).toString())+"'";
q1=new RDSqlQuery(sql);
if(!q1->first()) {
QString path=config()->url();
if(path.right(1)!="/") {
path+="/";
}
QUrl url(path+q->value(1).toString());
conv=new RDDelete(rda->config());
conv->setTargetUrl(url.toString());
//
// FIXME: Finish implementing ssh(1) key support!
//
if((conv_err=conv->runDelete(config()->urlUsername(),
config()->urlPassword(),"",false,
rda->config()->logXloadDebugData()))==
RDDelete::ErrorOk) {
sql=QString::asprintf("delete from `REPL_CART_STATE` where `ID`=%d",
q->value(0).toInt());
q2=new RDSqlQuery(sql);
delete q2;
rda->syslog(LOG_INFO,"purged \"%s\" for replicator \"%s\"",
(const char *)url.toString().toUtf8(),
(const char *)config()->name().toUtf8());
}
else {
rda->syslog(LOG_WARNING,
"unable to delete \"%s\" for replicator \"%s\" [%s]",
(const char *)url.toString().toUtf8(),
(const char *)config()->name().toUtf8(),
(const char *)RDDelete::errorText(conv_err).toUtf8());
}
delete conv;
}
delete q1;
}
delete q;
}

1
rdrepld/ww1ipump.h
View File

@ -36,7 +36,6 @@ class Ww1Ipump : public ReplFactory
bool ValidateFilename(const QString &filename); bool ValidateFilename(const QString &filename);
void CheckCarts(); void CheckCarts();
bool PostCut(const QString &cutname,const QString &filename); bool PostCut(const QString &cutname,const QString &filename);
void PurgeCuts();
QDateTime xds_isci_datetime; QDateTime xds_isci_datetime;
}; };