You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdelibs/tdeprint/cups/kmcupsmanager.cpp

1167 lines
32 KiB

/*
* This file is part of the KDE libraries
* Copyright (c) 2001 Michael Goffioul <tdeprint@swing.be>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License version 2 as published by the Free Software Foundation.
*
* This library 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
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public License
* along with this library; see the file COPYING.LIB. If not, write to
* the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301, USA.
**/
#include <config.h>
#include "kmcupsmanager.h"
#include "kmprinter.h"
#include "ipprequest.h"
#include "cupsinfos.h"
#include "driver.h"
#include "kmfactory.h"
#include "kmdbentry.h"
#include "cupsaddsmb2.h"
#include "ippreportdlg.h"
#include "kpipeprocess.h"
#include "util.h"
#include "foomatic2loader.h"
#include "ppdloader.h"
#include <tqfile.h>
#include <tqtextstream.h>
#include <tqregexp.h>
#include <tqtimer.h>
#include <tqsocket.h>
#include <tqdatetime.h>
#include <kdebug.h>
#include <tdeapplication.h>
#include <tdelocale.h>
#include <tdeconfig.h>
#include <kstandarddirs.h>
#include <tdesocketbase.h>
#include <klibloader.h>
#include <tdemessagebox.h>
#include <tdeaction.h>
#include <kdialogbase.h>
#include <kextendedsocket.h>
#include <kprocess.h>
#include <kbufferedsocket.h>
#include <kfilterdev.h>
#include <cups/cups.h>
#include <cups/ppd.h>
#include <math.h>
#define ppdi18n(s) i18n(TQString::fromLocal8Bit(s).utf8())
static void extractMaticData(TQString& buf, const TQString& filename);
static TQString printerURI(KMPrinter *p, bool useExistingURI);
static TQString downloadDriver(KMPrinter *p);
static int trials = 5;
//*****************************************************************************************************
KMCupsManager::KMCupsManager(TQObject *parent, const char *name, const TQStringList & /*args*/)
: KMManager(parent,name)
{
// be sure to create the CupsInfos object -> password
// management is handled correctly.
CupsInfos::self();
m_cupsdconf = 0;
m_currentprinter = 0;
m_socket = 0;
setHasManagement(true);
setPrinterOperationMask(KMManager::PrinterAll);
setServerOperationMask(KMManager::ServerAll);
// change LANG variable so that CUPS is always using
// english language: translation may only come from the PPD
// itself, or from KDE.
setenv("LANG", "en_US.UTF-8", 1);
}
KMCupsManager::~KMCupsManager()
{
delete m_socket;
}
TQString KMCupsManager::driverDbCreationProgram()
{
return TQString(__TDE_BINDIR).append(TQString::fromLatin1("/make_driver_db_cups"));
}
TQString KMCupsManager::driverDirectory()
{
TQString d = cupsInstallDir();
if (d.isEmpty()) {
#ifdef __OpenBSD__
d = "/usr/local";
#else
d = "/usr";
#endif
}
d.append("/share/cups/model");
// raw foomatic support
#ifdef __OpenBSD__
d.append(":/usr/local/share/foomatic/db/source");
#else
d.append(":/usr/share/foomatic/db/source");
#endif
return d;
}
TQString KMCupsManager::cupsInstallDir()
{
TDEConfig *conf= KMFactory::self()->printConfig();
conf->setGroup("CUPS");
TQString dir = conf->readPathEntry("InstallDir");
return dir;
}
void KMCupsManager::reportIppError(IppRequest *req)
{
setErrorMsg(req->statusMessage());
}
bool KMCupsManager::createPrinter(KMPrinter *p)
{
bool isclass = p->isClass(false), result(false);
IppRequest req;
TQString uri;
uri = printerURI(p,false);
req.addURI(IPP_TAG_OPERATION,"printer-uri",uri);
// needed to avoid problems when changing printer name
p->setUri(KURL(uri));
if (isclass)
{
req.setOperation(CUPS_ADD_CLASS);
TQStringList members = p->members(), uris;
TQString s;
s = TQString::fromLocal8Bit("ipp://%1/printers/").arg(CupsInfos::self()->hostaddr());
for (TQStringList::ConstIterator it=members.begin(); it!=members.end(); ++it)
uris.append(s+(*it));
req.addURI(IPP_TAG_PRINTER,"member-uris",uris);
}
else
{
req.setOperation(CUPS_ADD_PRINTER);
// only set the device-uri if needed, otherwise you may loose authentification
// data (login/password in URI's like smb or ipp).
KMPrinter *otherP = findPrinter(p->printerName());
if (!otherP || otherP->device() != p->device())
{
/**
* As now the device is a TQString instead of KURL, special encoding
* required for SMB is not needed anymore. Use a unique mechanism
* for all backends.
*/
req.addURI(IPP_TAG_PRINTER,"device-uri",p->device());
}
if (!p->option("kde-banners").isEmpty())
{
TQStringList bans = TQStringList::split(',',p->option("kde-banners"),false);
while (bans.count() < 2)
bans.append("none");
req.addName(IPP_TAG_PRINTER,"job-sheets-default",bans);
}
req.addInteger(IPP_TAG_PRINTER,"job-quota-period",p->option("job-quota-period").toInt());
req.addInteger(IPP_TAG_PRINTER,"job-k-limit",p->option("job-k-limit").toInt());
req.addInteger(IPP_TAG_PRINTER,"job-page-limit",p->option("job-page-limit").toInt());
if (!p->option("requesting-user-name-denied").isEmpty())
req.addName(IPP_TAG_PRINTER,"requesting-user-name-denied",TQStringList::split(",",p->option("requesting-user-name-denied"),false));
else if (!p->option("requesting-user-name-allowed").isEmpty())
req.addName(IPP_TAG_PRINTER,"requesting-user-name-allowed",TQStringList::split(",",p->option("requesting-user-name-allowed"),false));
else
req.addName(IPP_TAG_PRINTER,"requesting-user-name-allowed",TQString::fromLatin1("all"));
}
req.addText(IPP_TAG_PRINTER,"printer-info",p->description());
req.addText(IPP_TAG_PRINTER,"printer-location",p->location());
if (req.doRequest("/admin/"))
{
result = true;
if (p->driver())
result = savePrinterDriver(p,p->driver());
if (result)
upPrinter(p, true);
}
else reportIppError(&req);
return result;
}
bool KMCupsManager::removePrinter(KMPrinter *p)
{
bool result = setPrinterState(p,CUPS_DELETE_PRINTER);
return result;
}
bool KMCupsManager::enablePrinter(KMPrinter *p, bool state)
{
return setPrinterState(p, (state ? CUPS_ACCEPT_JOBS : CUPS_REJECT_JOBS));
}
bool KMCupsManager::startPrinter(KMPrinter *p, bool state)
{
return setPrinterState(p, (state ? IPP_RESUME_PRINTER : IPP_PAUSE_PRINTER));
}
bool KMCupsManager::setDefaultPrinter(KMPrinter *p)
{
return setPrinterState(p,CUPS_SET_DEFAULT);
}
bool KMCupsManager::setPrinterState(KMPrinter *p, int state)
{
IppRequest req;
TQString uri;
req.setOperation(state);
uri = printerURI(p, true);
req.addURI(IPP_TAG_OPERATION,"printer-uri",uri);
if (req.doRequest("/admin/"))
return true;
reportIppError(&req);
return false;
}
bool KMCupsManager::completePrinter(KMPrinter *p)
{
if (completePrinterShort(p))
{
// driver informations
TQString ppdname = downloadDriver(p);
ppd_file_t *ppd = (ppdname.isEmpty() ? NULL : ppdOpenFile(ppdname.local8Bit()));
if (ppd)
{
KMDBEntry entry;
// use the validation mechanism of KMDBEntry to
// fill possible missing entries like manufacturer
// or model.
entry.manufacturer = ppd->manufacturer;
entry.model = ppd->shortnickname;
entry.modelname = ppd->modelname;
// do not check the driver regarding the manager
entry.validate(false);
// update the KMPrinter object
p->setManufacturer(entry.manufacturer);
p->setModel(entry.model);
p->setDriverInfo(TQString::fromLocal8Bit(ppd->nickname));
ppdClose(ppd);
}
if (!ppdname.isEmpty())
TQFile::remove(ppdname);
return true;
}
return false;
}
bool KMCupsManager::completePrinterShort(KMPrinter *p)
{
IppRequest req;
TQStringList keys;
TQString uri;
req.setOperation(IPP_GET_PRINTER_ATTRIBUTES);
uri = printerURI(p, true);
req.addURI(IPP_TAG_OPERATION,"printer-uri",uri);
/*
// change host and port for remote stuffs
if (!p->uri().isEmpty())
{
// THIS IS AN UGLY HACK!! FIXME
// This attempts a "pre-connection" to see if the host is
// actually reachable. It times out after 2 seconds at most,
// preventing application freezes.
m_hostSuccess = false;
m_lookupDone = false;
// Give 2 seconds to connect to the printer, or abort
KExtendedSocket *kes = new KExtendedSocket(p->uri().host(),
p->uri().port());
connect(kes, TQT_SIGNAL(connectionSuccess()), this, TQT_SLOT(hostPingSlot()));
connect(kes, TQT_SIGNAL(connectionFailed(int)), this, TQT_SLOT(hostPingFailedSlot()));
if (kes->startAsyncConnect() != 0) {
delete kes;
m_hostSuccess = false;
} else {
TQDateTime tm = TQDateTime::currentDateTime().addSecs(2);
while (!m_lookupDone && (TQDateTime::currentDateTime() < tm))
tqApp->processEvents();
kes->cancelAsyncConnect();
delete kes;
if (!m_lookupDone)
m_hostSuccess = false;
}
if (m_hostSuccess == true) {
req.setHost(p->uri().host());
req.setPort(p->uri().port());
}
}
*/
// disable location as it has been transferred to listing (for filtering)
//keys.append("printer-location");
keys.append("printer-info");
keys.append("printer-make-and-model");
keys.append("job-sheets-default");
keys.append("job-sheets-supported");
keys.append("job-quota-period");
keys.append("job-k-limit");
keys.append("job-page-limit");
keys.append("requesting-user-name-allowed");
keys.append("requesting-user-name-denied");
if (p->isClass(true))
{
keys.append("member-uris");
keys.append("member-names");
}
else
keys.append("device-uri");
req.addKeyword(IPP_TAG_OPERATION,"requested-attributes",keys);
if (req.doRequest("/printers/"))
{
TQString value;
if (req.text("printer-info",value)) p->setDescription(value);
// disabled location
//if (req.text("printer-location",value)) p->setLocation(value);
if (req.text("printer-make-and-model",value)) p->setDriverInfo(value);
if (req.uri("device-uri",value))
{
/**
* No specific treatment required as the device is
* a normal TQString instead of a KURL
*/
p->setDevice( value );
}
TQStringList values;
/* if (req.uri("member-uris",values))
{
TQStringList members;
for (TQStringList::ConstIterator it=values.begin(); it!=values.end(); ++it)
{
int p = (*it).findRev('/');
if (p != -1)
members.append((*it).right((*it).length()-p-1));
}
p->setMembers(members);
}*/
if (req.name("member-names",values))
p->setMembers(values);
// banners
req.name("job-sheets-default",values);
while (values.count() < 2) values.append("none");
p->setOption("kde-banners",values.join(TQString::fromLatin1(",")));
if (req.name("job-sheets-supported",values)) p->setOption("kde-banners-supported",values.join(TQString::fromLatin1(",")));
// quotas
int ival;
if (req.integer("job-quota-period",ival)) p->setOption("job-quota-period",TQString::number(ival));
if (req.integer("job-k-limit",ival)) p->setOption("job-k-limit",TQString::number(ival));
if (req.integer("job-page-limit",ival)) p->setOption("job-page-limit",TQString::number(ival));
// access permissions (allow and deny are mutually exclusives)
if (req.name("requesting-user-name-allowed",values) && values.count() > 0)
{
p->removeOption("requesting-user-name-denied");
p->setOption("requesting-user-name-allowed",values.join(","));
}
if (req.name("requesting-user-name-denied",values) && values.count() > 0)
{
p->removeOption("requesting-user-name-allowed");
p->setOption("requesting-user-name-denied",values.join(","));
}
return true;
}
reportIppError(&req);
return false;
}
bool KMCupsManager::testPrinter(KMPrinter *p)
{
return KMManager::testPrinter(p);
/*
TQString testpage = testPage();
if (testpage.isEmpty())
{
setErrorMsg(i18n("Unable to locate test page."));
return false;
}
IppRequest req;
TQString uri;
req.setOperation(IPP_PRINT_JOB);
uri = printerURI(p);
req.addURI(IPP_TAG_OPERATION,"printer-uri",uri);
req.addMime(IPP_TAG_OPERATION,"document-format","application/postscript");
if (!CupsInfos::self()->login().isEmpty()) req.addName(IPP_TAG_OPERATION,"requesting-user-name",CupsInfos::self()->login());
req.addName(IPP_TAG_OPERATION,"job-name",TQString::fromLatin1("TDE Print Test"));
if (req.doFileRequest("/printers/",testpage))
return true;
reportIppError(&req);
return false;
*/
}
void KMCupsManager::listPrinters()
{
loadServerPrinters();
}
void KMCupsManager::loadServerPrinters()
{
IppRequest req;
TQStringList keys;
// get printers
req.setOperation(CUPS_GET_PRINTERS);
keys.append("printer-name");
keys.append("printer-type");
keys.append("printer-state");
// location needed for filtering
keys.append("printer-location");
keys.append("printer-uri-supported");
keys.append("printer-is-accepting-jobs");
req.addKeyword(IPP_TAG_OPERATION,"requested-attributes",keys);
// filtering by username (hides printers user doesn't have allowance to use)
req.addName(IPP_TAG_OPERATION, "requesting-user-name", TQString(cupsUser()));
if (req.doRequest("/printers/"))
{
processRequest(&req);
// get classes
req.init();
req.setOperation(CUPS_GET_CLASSES);
req.addKeyword(IPP_TAG_OPERATION,"requested-attributes",keys);
if (req.doRequest("/classes/"))
{
processRequest(&req);
// load default
req.init();
req.setOperation(CUPS_GET_DEFAULT);
req.addKeyword(IPP_TAG_OPERATION,"requested-attributes",TQString::fromLatin1("printer-name"));
if (req.doRequest("/printers/"))
{
TQString s = TQString::null;
req.name("printer-name",s);
setHardDefault(findPrinter(s));
}
// This request may fails for example if no printer is defined. Just
// discard the error message. Indeed as we successfully got printers
// and classes, the most probable reason why this request may fail is
// because of no printer defined. The best would be to actually check
// there's no printer (TODO).
return;
}
}
// something went wrong if we get there, report the error
reportIppError(&req);
}
void KMCupsManager::processRequest(IppRequest* req)
{
ipp_attribute_t *attr = req->first();
ipp_attribute_t *nextAttr;
KMPrinter *printer = new KMPrinter();
while (attr)
{
#ifdef HAVE_CUPS_1_6
TQString attrname(ippGetName(attr));
if (attrname == "printer-name")
{
TQString value = TQString::fromLocal8Bit(ippGetString(attr, 0, NULL));
printer->setName(value);
printer->setPrinterName(value);
}
else if (attrname == "printer-type")
{
int value = ippGetInteger(attr, 0);
printer->setType(0);
printer->addType(((value & CUPS_PRINTER_CLASS) || (value & CUPS_PRINTER_IMPLICIT) ? KMPrinter::Class : KMPrinter::Printer));
if ((value & CUPS_PRINTER_REMOTE)) printer->addType(KMPrinter::Remote);
if ((value & CUPS_PRINTER_IMPLICIT)) printer->addType(KMPrinter::Implicit);
// convert printer-type attribute
printer->setPrinterCap( ( value & CUPS_PRINTER_OPTIONS ) >> 2 );
}
else if (attrname == "printer-state")
{
switch (ippGetInteger(attr, 0))
{
case IPP_PRINTER_IDLE: printer->setState(KMPrinter::Idle); break;
case IPP_PRINTER_PROCESSING: printer->setState(KMPrinter::Processing); break;
case IPP_PRINTER_STOPPED: printer->setState(KMPrinter::Stopped); break;
}
}
else if (attrname == "printer-uri-supported")
{
printer->setUri(KURL(ippGetString(attr, 0, NULL)));
}
else if (attrname == "printer-location")
{
printer->setLocation(TQString::fromLocal8Bit(ippGetString(attr, 0, NULL)));
}
else if (attrname == "printer-is-accepting-jobs")
{
printer->setAcceptJobs(ippGetBoolean(attr, 0));
}
nextAttr = ippNextAttribute(req->request());
if (attrname.isEmpty() || (!nextAttr))
{
addPrinter(printer);
printer = new KMPrinter();
}
attr = nextAttr;
#else // HAVE_CUPS_1_6
TQString attrname(attr->name);
if (attrname == "printer-name")
{
TQString value = TQString::fromLocal8Bit(attr->values[0].string.text);
printer->setName(value);
printer->setPrinterName(value);
}
else if (attrname == "printer-type")
{
int value = attr->values[0].integer;
printer->setType(0);
printer->addType(((value & CUPS_PRINTER_CLASS) || (value & CUPS_PRINTER_IMPLICIT) ? KMPrinter::Class : KMPrinter::Printer));
if ((value & CUPS_PRINTER_REMOTE)) printer->addType(KMPrinter::Remote);
if ((value & CUPS_PRINTER_IMPLICIT)) printer->addType(KMPrinter::Implicit);
// convert printer-type attribute
printer->setPrinterCap( ( value & CUPS_PRINTER_OPTIONS ) >> 2 );
}
else if (attrname == "printer-state")
{
switch (attr->values[0].integer)
{
case IPP_PRINTER_IDLE: printer->setState(KMPrinter::Idle); break;
case IPP_PRINTER_PROCESSING: printer->setState(KMPrinter::Processing); break;
case IPP_PRINTER_STOPPED: printer->setState(KMPrinter::Stopped); break;
}
}
else if (attrname == "printer-uri-supported")
{
printer->setUri(KURL(attr->values[0].string.text));
}
else if (attrname == "printer-location")
{
printer->setLocation(TQString::fromLocal8Bit(attr->values[0].string.text));
}
else if (attrname == "printer-is-accepting-jobs")
{
printer->setAcceptJobs(attr->values[0].boolean);
}
if (attrname.isEmpty() || attr == req->last())
{
addPrinter(printer);
printer = new KMPrinter();
}
attr = attr->next;
#endif // HAVE_CUPS_1_6
}
delete printer;
}
DrMain* KMCupsManager::loadPrinterDriver(KMPrinter *p, bool)
{
if (!p)
return NULL;
if (p->isClass(true))
{
KMPrinter *first_class_member = NULL;
/* find the first printer in the class */
first_class_member = findPrinter(p->members().first());
if (first_class_member == NULL)
{
/* we didn't find a printer in the class */
return NULL;
}
else
{
p = first_class_member;
}
}
TQString fname = downloadDriver(p);
DrMain *driver(0);
if (!fname.isEmpty())
{
driver = loadDriverFile(fname);
if (driver)
driver->set("temporary",fname);
}
return driver;
}
DrMain* KMCupsManager::loadFileDriver(const TQString& filename)
{
if (filename.startsWith("ppd:"))
return loadDriverFile(filename.mid(4));
else if (filename.startsWith("foomatic/"))
return loadMaticDriver(filename);
else
return loadDriverFile(filename);
}
DrMain* KMCupsManager::loadMaticDriver(const TQString& drname)
{
TQStringList comps = TQStringList::split('/', drname, false);
TQString tmpFile = locateLocal("tmp", "foomatic_" + kapp->randomString(8));
#ifdef __OpenBSD__
TQString PATH = getenv("PATH") + TQString::fromLatin1(":/usr/local/bin:/usr/sbin:/usr/local/sbin:/opt/sbin:/opt/local/sbin");
#else
TQString PATH = getenv("PATH") + TQString::fromLatin1(":/usr/sbin:/usr/local/sbin:/opt/sbin:/opt/local/sbin");
#endif
TQString exe = TDEStandardDirs::findExe("foomatic-datafile", PATH);
if (exe.isEmpty())
{
setErrorMsg(i18n("Unable to find the executable foomatic-datafile "
"in your PATH. Check that Foomatic is correctly installed."));
return NULL;
}
KPipeProcess in;
TQFile out(tmpFile);
TQString cmd = TDEProcess::quote(exe);
cmd += " -t cups -d ";
cmd += TDEProcess::quote(comps[2]);
cmd += " -p ";
cmd += TDEProcess::quote(comps[1]);
if (in.open(cmd) && out.open(IO_WriteOnly))
{
TQTextStream tin(&in), tout(&out);
TQString line;
while (!tin.atEnd())
{
line = tin.readLine();
tout << line << endl;
}
in.close();
out.close();
DrMain *driver = loadDriverFile(tmpFile);
if (driver)
{
driver->set("template", tmpFile);
driver->set("temporary", tmpFile);
return driver;
}
}
setErrorMsg(i18n("Unable to create the Foomatic driver [%1,%2]. "
"Either that driver does not exist, or you don't have "
"the required permissions to perform that operation.").arg(comps[1]).arg(comps[2]));
TQFile::remove(tmpFile);
return NULL;
}
DrMain* KMCupsManager::loadDriverFile(const TQString& fname)
{
if (TQFile::exists(fname))
{
TQString msg; /* possible error message */
DrMain *driver = PPDLoader::loadDriver( fname, &msg );
if ( driver )
{
driver->set( "template", fname );
// FIXME: should fix option in group "install"
}
else
setErrorMsg( msg );
return driver;
}
return NULL;
}
void KMCupsManager::saveDriverFile(DrMain *driver, const TQString& filename)
{
kdDebug( 500 ) << "Saving PPD file with template=" << driver->get( "template" ) << endl;
TQIODevice *in = KFilterDev::deviceForFile( driver->get( "template" ) );
TQFile out(filename);
if (in && in->open(IO_ReadOnly) && out.open(IO_WriteOnly))
{
TQTextStream tin(in), tout(&out);
TQString line, keyword;
bool isnumeric(false);
DrBase *opt(0);
while (!tin.eof())
{
line = tin.readLine();
if (line.startsWith("*% COMDATA #"))
{
int p(-1), q(-1);
if ((p=line.find("'name'")) != -1)
{
p = line.find('\'',p+6)+1;
q = line.find('\'',p);
keyword = line.mid(p,q-p);
opt = driver->findOption(keyword);
if (opt && (opt->type() == DrBase::Integer || opt->type() == DrBase::Float))
isnumeric = true;
else
isnumeric = false;
}
/*else if ((p=line.find("'type'")) != -1)
{
p = line.find('\'',p+6)+1;
if (line.find("float",p) != -1 || line.find("int",p) != -1)
isnumeric = true;
else
isnumeric = false;
}*/
else if ((p=line.find("'default'")) != -1 && !keyword.isEmpty() && opt && isnumeric)
{
TQString prefix = line.left(p+9);
tout << prefix << " => '" << opt->valueText() << '\'';
if (line.find(',',p) != -1)
tout << ',';
tout << endl;
continue;
}
tout << line << endl;
}
else if (line.startsWith("*Default"))
{
int p = line.find(':',8);
keyword = line.mid(8,p-8);
DrBase *bopt = 0;
if ( keyword == "PageRegion" || keyword == "ImageableArea" || keyword == "PaperDimension" )
bopt = driver->findOption( TQString::fromLatin1( "PageSize" ) );
else
bopt = driver->findOption( keyword );
if (bopt)
switch (bopt->type())
{
case DrBase::List:
case DrBase::Boolean:
{
DrListOption *opt = static_cast<DrListOption*>(bopt);
if (opt && opt->currentChoice())
tout << "*Default" << keyword << ": " << opt->currentChoice()->name() << endl;
else
tout << line << endl;
}
break;
case DrBase::Integer:
{
DrIntegerOption *opt = static_cast<DrIntegerOption*>(bopt);
tout << "*Default" << keyword << ": " << opt->fixedVal() << endl;
}
break;
case DrBase::Float:
{
DrFloatOption *opt = static_cast<DrFloatOption*>(bopt);
tout << "*Default" << keyword << ": " << opt->fixedVal() << endl;
}
break;
default:
tout << line << endl;
break;
}
else
tout << line << endl;
}
else
tout << line << endl;
}
}
delete in;
}
bool KMCupsManager::savePrinterDriver(KMPrinter *p, DrMain *d)
{
TQString tmpfilename = locateLocal("tmp","print_") + kapp->randomString(8);
// first save the driver in a temporary file
saveDriverFile(d,tmpfilename);
// then send a request
IppRequest req;
TQString uri;
bool result(false);
req.setOperation(CUPS_ADD_PRINTER);
uri = printerURI(p, true);
req.addURI(IPP_TAG_OPERATION,"printer-uri",uri);
result = req.doFileRequest("/admin/",tmpfilename);
// remove temporary file
TQFile::remove(tmpfilename);
if (!result)
reportIppError(&req);
return result;
}
void* KMCupsManager::loadCupsdConfFunction(const char *name)
{
if (!m_cupsdconf)
{
m_cupsdconf = KLibLoader::self()->library("cupsdconf");
if (!m_cupsdconf)
{
setErrorMsg(i18n("Library cupsdconf not found. Check your installation."));
return NULL;
}
}
void* func = m_cupsdconf->symbol(name);
if (!func)
setErrorMsg(i18n("Symbol %1 not found in cupsdconf library.").arg(name));
return func;
}
void KMCupsManager::unloadCupsdConf()
{
if (m_cupsdconf)
{
KLibLoader::self()->unloadLibrary("libcupsdconf");
m_cupsdconf = 0;
}
}
bool KMCupsManager::restartServer()
{
TQString msg;
bool (*f1)(TQString&) = (bool(*)(TQString&))loadCupsdConfFunction("restartServer");
bool result(false);
if (f1)
{
result = f1(msg);
if (!result) setErrorMsg(msg);
}
unloadCupsdConf();
return result;
}
bool KMCupsManager::configureServer(TQWidget *parent)
{
TQString msg;
bool (*f2)(TQWidget*, TQString&) = (bool(*)(TQWidget*, TQString&))loadCupsdConfFunction("configureServer");
bool result(false);
if (f2)
{
result = f2(parent, msg);
if ( !result )
setErrorMsg( msg );
}
unloadCupsdConf();
return result;
}
TQStringList KMCupsManager::detectLocalPrinters()
{
TQStringList list;
IppRequest req;
ipp_attribute_t *nextAttr;
req.setOperation(CUPS_GET_DEVICES);
if (req.doRequest("/"))
{
TQString desc, uri, printer, cl;
ipp_attribute_t *attr = req.first();
while (attr)
{
#ifdef HAVE_CUPS_1_6
TQString attrname(ippGetName(attr));
if (attrname == "device-info") desc = ippGetString(attr, 0, NULL);
else if (attrname == "device-make-and-model") printer = ippGetString(attr, 0, NULL);
else if (attrname == "device-uri") uri = ippGetString(attr, 0, NULL);
else if ( attrname == "device-class" ) cl = ippGetString(attr, 0, NULL);
nextAttr = ippNextAttribute(req.request());
if (attrname.isEmpty() || (!nextAttr))
{
if (!uri.isEmpty())
{
if (printer == "Unknown") printer = TQString::null;
list << cl << uri << desc << printer;
}
uri = desc = printer = cl = TQString::null;
}
attr = nextAttr;
#else // HAVE_CUPS_1_6
TQString attrname(attr->name);
if (attrname == "device-info") desc = attr->values[0].string.text;
else if (attrname == "device-make-and-model") printer = attr->values[0].string.text;
else if (attrname == "device-uri") uri = attr->values[0].string.text;
else if ( attrname == "device-class" ) cl = attr->values[ 0 ].string.text;
if (attrname.isEmpty() || attr == req.last())
{
if (!uri.isEmpty())
{
if (printer == "Unknown") printer = TQString::null;
list << cl << uri << desc << printer;
}
uri = desc = printer = cl = TQString::null;
}
attr = attr->next;
#endif // HAVE_CUPS_1_6
}
}
return list;
}
void KMCupsManager::createPluginActions(TDEActionCollection *coll)
{
TDEAction *act = new TDEAction(i18n("&Export Driver..."), "tdeprint_uploadsmb", 0, this, TQT_SLOT(exportDriver()), coll, "plugin_export_driver");
act->setGroup("plugin");
act = new TDEAction(i18n("&Printer IPP Report"), "tdeprint_report", 0, this, TQT_SLOT(printerIppReport()), coll, "plugin_printer_ipp_report");
act->setGroup("plugin");
}
void KMCupsManager::validatePluginActions(TDEActionCollection *coll, KMPrinter *pr)
{
// save selected printer for future use in slots
m_currentprinter = pr;
coll->action("plugin_export_driver")->setEnabled(pr && pr->isLocal() && !pr->isClass(true) && !pr->isSpecial());
coll->action("plugin_printer_ipp_report")->setEnabled(pr && !pr->isSpecial());
}
void KMCupsManager::exportDriver()
{
if (m_currentprinter && m_currentprinter->isLocal() &&
!m_currentprinter->isClass(true) && !m_currentprinter->isSpecial())
{
TQString path = cupsInstallDir();
if (path.isEmpty()) {
#ifdef __OpenBSD__
path = "/usr/local/share/cups";
#else
path = "/usr/share/cups";
#endif
} else {
path += "/share/cups";
}
CupsAddSmb::exportDest(m_currentprinter->printerName(), path);
}
}
void KMCupsManager::printerIppReport()
{
if (m_currentprinter && !m_currentprinter->isSpecial())
{
IppRequest req;
TQString uri;
req.setOperation(IPP_GET_PRINTER_ATTRIBUTES);
uri = printerURI(m_currentprinter, true);
req.addURI(IPP_TAG_OPERATION,"printer-uri",uri);
/*
if (!m_currentprinter->uri().isEmpty())
{
req.setHost(m_currentprinter->uri().host());
req.setPort(m_currentprinter->uri().port());
}
*/
req.dump(2);
if (req.doRequest("/printers/"))
{
ippReport(req, IPP_TAG_PRINTER, i18n("IPP Report for %1").arg(m_currentprinter->printerName()));
}
else
{
KMessageBox::error(0, "<p>"+i18n("Unable to retrieve printer information. Error received:")+"</p>"+req.statusMessage());
}
}
}
void KMCupsManager::ippReport(IppRequest& req, int group, const TQString& caption)
{
IppReportDlg::report(&req, group, caption);
}
TQString KMCupsManager::stateInformation()
{
return TQString("%1: %2")
.arg(i18n("Server"))
.arg(CupsInfos::self()->host()[0] != '/' ?
TQString(TQString("%1:%2").arg(CupsInfos::self()->host()).arg(CupsInfos::self()->port()))
: CupsInfos::self()->host());
}
void KMCupsManager::checkUpdatePossibleInternal()
{
kdDebug(500) << "Checking for update possible" << endl;
delete m_socket;
m_socket = new KNetwork::TDEBufferedSocket;
m_socket->setTimeout( 1500 );
connect( m_socket, TQT_SIGNAL( connected(const KResolverEntry&) ),
TQT_SLOT( slotConnectionSuccess() ) );
connect( m_socket, TQT_SIGNAL( gotError( int ) ), TQT_SLOT( slotConnectionFailed( int ) ) );
trials = 5;
TQTimer::singleShot( 1, this, TQT_SLOT( slotAsyncConnect() ) );
}
void KMCupsManager::slotConnectionSuccess()
{
kdDebug(500) << "Connection success, trying to send a request..." << endl;
m_socket->close();
IppRequest req;
req.setOperation( CUPS_GET_PRINTERS );
req.addKeyword( IPP_TAG_OPERATION, "requested-attributes", TQString::fromLatin1( "printer-name" ) );
if ( req.doRequest( "/printers/" ) )
setUpdatePossible( true );
else
{
kdDebug(500) << "Unable to get printer list" << endl;
if ( trials > 0 )
{
trials--;
TQTimer::singleShot( 1000, this, TQT_SLOT( slotAsyncConnect() ) );
}
else
{
setErrorMsg( i18n( "Connection to CUPS server failed. Check that the CUPS server is correctly installed and running. "
"Error: %1." ).arg( i18n( "the IPP request failed for an unknown reason" ) ) );
setUpdatePossible( false );
}
}
}
void KMCupsManager::slotAsyncConnect()
{
kdDebug(500) << "Starting async connect to " << CupsInfos::self()->hostaddr() << endl;
//m_socket->startAsyncConnect();
if (CupsInfos::self()->host().startsWith("/"))
m_socket->connect( TQString(), CupsInfos::self()->host());
else
m_socket->connectToHost( CupsInfos::self()->host(), CupsInfos::self()->port() );
}
void KMCupsManager::slotConnectionFailed( int errcode )
{
kdDebug(500) << "Connection failed trials=" << trials << endl;
if ( trials > 0 )
{
//m_socket->setTimeout( ++to );
//m_socket->cancelAsyncConnect();
trials--;
m_socket->close();
TQTimer::singleShot( 1000, this, TQT_SLOT( slotAsyncConnect() ) );
return;
}
TQString einfo;
switch (errcode) {
case KNetwork::TDESocketBase::ConnectionRefused:
case KNetwork::TDESocketBase::ConnectionTimedOut:
einfo = i18n("connection refused") + TQString(" (%1)").arg(errcode);
break;
case KNetwork::TDESocketBase::LookupFailure:
einfo = i18n("host not found") + TQString(" (%1)").arg(errcode);
break;
case KNetwork::TDESocketBase::WouldBlock:
default:
einfo = i18n("read failed (%1)").arg(errcode);
break;
}
setErrorMsg( i18n( "Connection to CUPS server failed. Check that the CUPS server is correctly installed and running. "
"Error: %2: %1." ).arg( einfo, CupsInfos::self()->host()));
setUpdatePossible( false );
}
void KMCupsManager::hostPingSlot() {
m_hostSuccess = true;
m_lookupDone = true;
}
void KMCupsManager::hostPingFailedSlot() {
m_hostSuccess = false;
m_lookupDone = true;
}
//*****************************************************************************************************
static void extractMaticData(TQString& buf, const TQString& filename)
{
TQFile f(filename);
if (f.exists() && f.open(IO_ReadOnly))
{
TQTextStream t(&f);
TQString line;
while (!t.eof())
{
line = t.readLine();
if (line.startsWith("*% COMDATA #"))
buf.append(line.right(line.length()-12)).append('\n');
}
}
}
static TQString printerURI(KMPrinter *p, bool use)
{
TQString uri;
if (use && !p->uri().isEmpty())
uri = p->uri().prettyURL();
else
uri = TQString("ipp://%1/%3/%2").arg(CupsInfos::self()->hostaddr()).arg(p->printerName()).arg((p->isClass(false) ? "classes" : "printers"));
return uri;
}
static TQString downloadDriver(KMPrinter *p)
{
TQString driverfile, prname = p->printerName();
bool changed(false);
/*
if (!p->uri().isEmpty())
{
// try to load the driver from the host:port
// specified in its URI. Doing so may also change
// the printer name to use. Note that for remote
// printer, this operation is read-only, no counterpart
// for saving operation.
cupsSetServer(p->uri().host().local8Bit());
ippSetPort(p->uri().port());
// strip any "@..." from the printer name
prname = prname.replace(TQRegExp("@.*"), "");
changed = true;
}
*/
// download driver
driverfile = cupsGetPPD(prname.local8Bit());
// restore host:port (if they have changed)
if (changed)
{
cupsSetServer(CupsInfos::self()->host().local8Bit());
ippSetPort(CupsInfos::self()->port());
}
return driverfile;
}
#include "kmcupsmanager.moc"