#include "includes.h"
#include "printing.h"
#ifdef HAVE_CUPS
#include <cups/cups.h>
#include <cups/language.h>
static const char printerprefsfile[] = "/Library/Preferences/com.apple.printservice.plist";
static char *cups_map_printer_name(http_t *http_p, const char *name);
static const char *
cups_passwd_cb(const char *prompt)
{
return (NULL);
}
static const char *cups_server(void)
{
if ((lp_cups_server() != NULL) && (strlen(lp_cups_server()) > 0)) {
DEBUG(10, ("cups server explicitly set to %s\n",
lp_cups_server()));
return lp_cups_server();
}
DEBUG(10, ("cups server left to default %s\n", cupsServer()));
return cupsServer();
}
void cups_printer_fn(void (*fn)(char *, char *))
{
http_t *http;
ipp_t *request,
*response;
ipp_attribute_t *attr;
cups_lang_t *language;
char *name,
*make_model,
*info;
int remote,
shared;
static const char *requested[] =
{
"printer-name",
"printer-make-and-model",
"printer-info",
"printer-type",
"printer-is-shared"
};
Boolean displayPrinter;
CFArrayRef smbQarray;
CFDataRef xmlData;
CFURLRef prefsurl;
Boolean printerprefs;
CFStringRef printername;
CFPropertyListRef plist;
DEBUG(5,("cups_printer_fn(%p)\n", fn));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return;
}
request = ippNew();
request->request.op.operation_id = CUPS_GET_PRINTERS;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddStrings(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes",
(sizeof(requested) / sizeof(requested[0])),
NULL, requested);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(0,("Unable to get printer list - %s\n",
ippErrorString(cupsLastError())));
httpClose(http);
return;
}
printerprefs = false;
smbQarray = NULL;
prefsurl = CFURLCreateFromFileSystemRepresentation(kCFAllocatorDefault, (const UInt8*)printerprefsfile, (CFIndex)strlen(printerprefsfile), false);
if (prefsurl)
{
printerprefs = CFURLCreateDataAndPropertiesFromResource(kCFAllocatorDefault, prefsurl, &xmlData, NULL, NULL, NULL);
if (printerprefs)
{
plist = CFPropertyListCreateFromXMLData(kCFAllocatorDefault, xmlData, kCFPropertyListImmutable, NULL);
if (plist)
{
smbQarray = (CFArrayRef)CFDictionaryGetValue((CFDictionaryRef)plist, CFSTR("smbSharedQueues"));
if (smbQarray)
CFRetain(smbQarray);
CFRelease(plist);
}
CFRelease(xmlData);
}
CFRelease(prefsurl);
}
for (attr = response->attrs; attr != NULL;)
{
while (attr != NULL && attr->group_tag != IPP_TAG_PRINTER)
attr = attr->next;
if (attr == NULL)
break;
name = NULL;
make_model = NULL;
info = NULL;
remote = 0;
shared = 1;
while (attr != NULL && attr->group_tag == IPP_TAG_PRINTER)
{
if (strcmp(attr->name, "printer-name") == 0 &&
attr->value_tag == IPP_TAG_NAME)
name = attr->values[0].string.text;
if (strcmp(attr->name, "printer-make-and-model") == 0 &&
attr->value_tag == IPP_TAG_TEXT)
make_model = attr->values[0].string.text;
if (strcmp(attr->name, "printer-info") == 0 &&
attr->value_tag == IPP_TAG_TEXT)
info = attr->values[0].string.text;
if (strcmp(attr->name, "printer-type") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
remote = attr->values[0].integer & CUPS_PRINTER_REMOTE;
if (strcmp(attr->name, "printer-is-shared") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
shared = attr->values[0].integer;
attr = attr->next;
}
if (!name || remote || !shared)
continue;
if (printerprefs)
{
printername = CFStringCreateWithCString( kCFAllocatorDefault, name, kCFStringEncodingUTF8 );
if (printername)
{
displayPrinter = smbQarray &&
CFArrayContainsValue(smbQarray, CFRangeMake(0, CFArrayGetCount(smbQarray)), printername);
CFRelease(printername);
if (!displayPrinter)
continue;
}
}
if (info == NULL || !info[0])
(*fn)(name, make_model);
else
(*fn)(info, make_model);
}
ippDelete(response);
request = ippNew();
request->request.op.operation_id = CUPS_GET_CLASSES;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddStrings(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes",
(sizeof(requested) / sizeof(requested[0])),
NULL, requested);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(0,("Unable to get printer list - %s\n",
ippErrorString(cupsLastError())));
httpClose(http);
return;
}
for (attr = response->attrs; attr != NULL;)
{
while (attr != NULL && attr->group_tag != IPP_TAG_PRINTER)
attr = attr->next;
if (attr == NULL)
break;
name = NULL;
make_model = NULL;
info = NULL;
remote = 0;
shared = 1;
while (attr != NULL && attr->group_tag == IPP_TAG_PRINTER)
{
if (strcmp(attr->name, "printer-name") == 0 &&
attr->value_tag == IPP_TAG_NAME)
name = attr->values[0].string.text;
if (strcmp(attr->name, "printer-make-and-model") == 0 &&
attr->value_tag == IPP_TAG_TEXT)
make_model = attr->values[0].string.text;
if (strcmp(attr->name, "printer-info") == 0 &&
attr->value_tag == IPP_TAG_TEXT)
info = attr->values[0].string.text;
if (strcmp(attr->name, "printer-type") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
remote = attr->values[0].integer & CUPS_PRINTER_REMOTE;
if (strcmp(attr->name, "printer-is-shared") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
shared = attr->values[0].integer;
attr = attr->next;
}
if (!name || remote || !shared)
continue;
if (printerprefs)
{
printername = CFStringCreateWithCString( kCFAllocatorDefault, name, kCFStringEncodingUTF8 );
if (printername)
{
displayPrinter = smbQarray &&
CFArrayContainsValue(smbQarray, CFRangeMake(0, CFArrayGetCount(smbQarray)), printername);
CFRelease(printername);
if (!displayPrinter)
continue;
}
}
if (info == NULL || !info[0])
(*fn)(name, make_model);
else
(*fn)(info, make_model);
}
ippDelete(response);
httpClose(http);
if (smbQarray)
CFRelease(smbQarray);
}
int cups_printername_ok(const char *name)
{
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_printername_ok(\"%s\")\n", name));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(3,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (0);
}
name = cups_map_printer_name(http, name);
if (name == NULL)
return 0;
request = ippNew();
request->request.op.operation_id = IPP_GET_PRINTER_ATTRIBUTES;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes", NULL, "printer-uri");
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/printers/%s", name);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI,
"printer-uri", NULL, uri);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(3,("Unable to get printer status for %s - %s\n", name,
ippErrorString(cupsLastError())));
httpClose(http);
return (0);
}
httpClose(http);
if (response->request.status.status_code >= IPP_OK_CONFLICT)
{
DEBUG(3,("Unable to get printer status for %s - %s\n", name,
ippErrorString(response->request.status.status_code)));
ippDelete(response);
return (0);
}
else
{
ippDelete(response);
return (1);
}
}
static int
cups_job_delete(int snum, struct printjob *pjob)
{
int ret;
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_job_delete(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (1);
}
request = ippNew();
request->request.op.operation_id = IPP_CANCEL_JOB;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/jobs/%d", pjob->sysjob);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "job-uri", NULL, uri);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, pjob->user);
ret = 1;
if ((response = cupsDoRequest(http, request, "/jobs")) != NULL)
{
if (response->request.status.status_code >= IPP_OK_CONFLICT)
DEBUG(0,("Unable to cancel job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
else
ret = 0;
ippDelete(response);
}
else
DEBUG(0,("Unable to cancel job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
httpClose(http);
return (ret);
}
static int
cups_job_pause(int snum, struct printjob *pjob)
{
int ret;
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_job_pause(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (1);
}
request = ippNew();
request->request.op.operation_id = IPP_HOLD_JOB;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/jobs/%d", pjob->sysjob);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "job-uri", NULL, uri);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, pjob->user);
ret = 1;
if ((response = cupsDoRequest(http, request, "/jobs")) != NULL)
{
if (response->request.status.status_code >= IPP_OK_CONFLICT)
DEBUG(0,("Unable to hold job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
else
ret = 0;
ippDelete(response);
}
else
DEBUG(0,("Unable to hold job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
httpClose(http);
return (ret);
}
static int
cups_job_resume(int snum, struct printjob *pjob)
{
int ret;
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_job_resume(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (1);
}
request = ippNew();
request->request.op.operation_id = IPP_RELEASE_JOB;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/jobs/%d", pjob->sysjob);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "job-uri", NULL, uri);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, pjob->user);
ret = 1;
if ((response = cupsDoRequest(http, request, "/jobs")) != NULL)
{
if (response->request.status.status_code >= IPP_OK_CONFLICT)
DEBUG(0,("Unable to release job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
else
ret = 0;
ippDelete(response);
}
else
DEBUG(0,("Unable to release job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
httpClose(http);
return (ret);
}
static int
cups_job_submit(int snum, struct printjob *pjob)
{
int ret;
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
char *clientname;
pstring new_jobname;
int num_options = 0;
cups_option_t *options;
char *printername;
DEBUG(5,("cups_job_submit(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (1);
}
printername = cups_map_printer_name(http, PRINTERNAME(snum));
if (printername == NULL)
return 2;
request = ippNew();
request->request.op.operation_id = IPP_PRINT_JOB;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/printers/%s",
printername);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI,
"printer-uri", NULL, uri);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, pjob->user);
clientname = client_name();
if (strcmp(clientname, "UNKNOWN") == 0) {
clientname = client_addr();
}
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"job-originating-host-name", NULL,
clientname);
pstr_sprintf(new_jobname,"%s%.8u %s", PRINT_SPOOL_PREFIX,
(unsigned int)pjob->smbjob, pjob->jobname);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "job-name", NULL,
new_jobname);
num_options = 0;
options = NULL;
num_options = cupsParseOptions(lp_cups_options(snum), num_options, &options);
if ( num_options )
cupsEncodeOptions(request, num_options, options);
slprintf(uri, sizeof(uri) - 1, "/printers/%s", printername);
ret = 1;
if ((response = cupsDoFileRequest(http, request, uri,
pjob->filename)) != NULL)
{
if (response->request.status.status_code >= IPP_OK_CONFLICT)
DEBUG(0,("Unable to print file to %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
else
ret = 0;
ippDelete(response);
}
else
DEBUG(0,("Unable to print file to `%s' - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
httpClose(http);
if ( ret == 0 )
unlink(pjob->filename);
return (ret);
}
static int
cups_queue_get(const char *printer_name,
enum printing_types printing_type,
char *lpq_command,
print_queue_struct **q,
print_status_struct *status)
{
http_t *http;
ipp_t *request,
*response;
ipp_attribute_t *attr;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
int qcount,
qalloc;
print_queue_struct *queue,
*temp;
const char *user_name,
*job_name;
int job_id;
int job_k_octets;
time_t job_time;
ipp_jstate_t job_status;
int job_priority;
static const char *jattrs[] =
{
"job-id",
"job-k-octets",
"job-name",
"job-originating-user-name",
"job-priority",
"job-state",
"time-at-creation",
};
static const char *pattrs[] =
{
"printer-state",
"printer-state-message"
};
DEBUG(5,("cups_queue_get(%s, %p, %p)\n", printer_name, q, status));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (0);
}
printer_name = cups_map_printer_name(http, printer_name);
if (printer_name == NULL)
return 2;
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/printers/%s", printer_name);
request = ippNew();
request->request.op.operation_id = IPP_GET_JOBS;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddStrings(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes",
(sizeof(jattrs) / sizeof(jattrs[0])),
NULL, jattrs);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI,
"printer-uri", NULL, uri);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(0,("Unable to get jobs for %s - %s\n", uri,
ippErrorString(cupsLastError())));
httpClose(http);
return (0);
}
if (response->request.status.status_code >= IPP_OK_CONFLICT)
{
DEBUG(0,("Unable to get jobs for %s - %s\n", uri,
ippErrorString(response->request.status.status_code)));
ippDelete(response);
httpClose(http);
return (0);
}
qcount = 0;
qalloc = 0;
queue = NULL;
for (attr = response->attrs; attr != NULL; attr = attr->next)
{
while (attr != NULL && attr->group_tag != IPP_TAG_JOB)
attr = attr->next;
if (attr == NULL)
break;
if (qcount >= qalloc)
{
qalloc += 16;
temp = SMB_REALLOC_ARRAY(queue, print_queue_struct, qalloc);
if (temp == NULL)
{
DEBUG(0,("cups_queue_get: Not enough memory!"));
ippDelete(response);
httpClose(http);
SAFE_FREE(queue);
return (0);
}
queue = temp;
}
temp = queue + qcount;
memset(temp, 0, sizeof(print_queue_struct));
job_id = 0;
job_priority = 50;
job_status = IPP_JOB_PENDING;
job_time = 0;
job_k_octets = 0;
user_name = NULL;
job_name = NULL;
while (attr != NULL && attr->group_tag == IPP_TAG_JOB)
{
if (attr->name == NULL)
{
attr = attr->next;
break;
}
if (strcmp(attr->name, "job-id") == 0 &&
attr->value_tag == IPP_TAG_INTEGER)
job_id = attr->values[0].integer;
if (strcmp(attr->name, "job-k-octets") == 0 &&
attr->value_tag == IPP_TAG_INTEGER)
job_k_octets = attr->values[0].integer;
if (strcmp(attr->name, "job-priority") == 0 &&
attr->value_tag == IPP_TAG_INTEGER)
job_priority = attr->values[0].integer;
if (strcmp(attr->name, "job-state") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
job_status = (ipp_jstate_t)(attr->values[0].integer);
if (strcmp(attr->name, "time-at-creation") == 0 &&
attr->value_tag == IPP_TAG_INTEGER)
job_time = attr->values[0].integer;
if (strcmp(attr->name, "job-name") == 0 &&
attr->value_tag == IPP_TAG_NAME)
job_name = attr->values[0].string.text;
if (strcmp(attr->name, "job-originating-user-name") == 0 &&
attr->value_tag == IPP_TAG_NAME)
user_name = attr->values[0].string.text;
attr = attr->next;
}
if (user_name == NULL || job_name == NULL || job_id == 0)
{
if (attr == NULL)
break;
else
continue;
}
temp->job = job_id;
temp->size = job_k_octets * 1024;
temp->status = job_status == IPP_JOB_PENDING ? LPQ_QUEUED :
job_status == IPP_JOB_STOPPED ? LPQ_PAUSED :
job_status == IPP_JOB_HELD ? LPQ_PAUSED :
LPQ_PRINTING;
temp->priority = job_priority;
temp->time = job_time;
strncpy(temp->fs_user, user_name, sizeof(temp->fs_user) - 1);
strncpy(temp->fs_file, job_name, sizeof(temp->fs_file) - 1);
qcount ++;
if (attr == NULL)
break;
}
ippDelete(response);
request = ippNew();
request->request.op.operation_id = IPP_GET_PRINTER_ATTRIBUTES;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddStrings(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes",
(sizeof(pattrs) / sizeof(pattrs[0])),
NULL, pattrs);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI,
"printer-uri", NULL, uri);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(0,("Unable to get printer status for %s - %s\n", printer_name,
ippErrorString(cupsLastError())));
httpClose(http);
*q = queue;
return (qcount);
}
if (response->request.status.status_code >= IPP_OK_CONFLICT)
{
DEBUG(0,("Unable to get printer status for %s - %s\n", printer_name,
ippErrorString(response->request.status.status_code)));
ippDelete(response);
httpClose(http);
*q = queue;
return (qcount);
}
if ((attr = ippFindAttribute(response, "printer-state", IPP_TAG_ENUM)) != NULL)
{
if (attr->values[0].integer == IPP_PRINTER_STOPPED)
status->status = LPSTAT_STOPPED;
else
status->status = LPSTAT_OK;
}
if ((attr = ippFindAttribute(response, "printer-state-message",
IPP_TAG_TEXT)) != NULL)
fstrcpy(status->message, attr->values[0].string.text);
ippDelete(response);
httpClose(http);
*q = queue;
return (qcount);
}
static int
cups_queue_pause(int snum)
{
extern userdom_struct current_user_info;
int ret;
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
char *printername;
DEBUG(5,("cups_queue_pause(%d)\n", snum));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (1);
}
printername = cups_map_printer_name(http, PRINTERNAME(snum));
if (printername == NULL)
return 2;
request = ippNew();
request->request.op.operation_id = IPP_PAUSE_PRINTER;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/printers/%s",
printername);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri", NULL, uri);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, current_user_info.unix_name);
ret = 1;
if ((response = cupsDoRequest(http, request, "/admin/")) != NULL)
{
if (response->request.status.status_code >= IPP_OK_CONFLICT)
DEBUG(0,("Unable to pause printer %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
else
ret = 0;
ippDelete(response);
}
else
DEBUG(0,("Unable to pause printer %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
httpClose(http);
return (ret);
}
static int
cups_queue_resume(int snum)
{
extern userdom_struct current_user_info;
int ret;
http_t *http;
ipp_t *request,
*response;
cups_lang_t *language;
char uri[HTTP_MAX_URI];
char *printername;
DEBUG(5,("cups_queue_resume(%d)\n", snum));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = httpConnect(cups_server(), ippPort())) == NULL)
{
DEBUG(0,("Unable to connect to CUPS server %s - %s\n",
cups_server(), strerror(errno)));
return (1);
}
printername = cups_map_printer_name(http, PRINTERNAME(snum));
if (printername == NULL)
return 2;
request = ippNew();
request->request.op.operation_id = IPP_RESUME_PRINTER;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/printers/%s",
printername);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri", NULL, uri);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, current_user_info.unix_name);
ret = 1;
if ((response = cupsDoRequest(http, request, "/admin/")) != NULL)
{
if (response->request.status.status_code >= IPP_OK_CONFLICT)
DEBUG(0,("Unable to resume printer %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
else
ret = 0;
ippDelete(response);
}
else
DEBUG(0,("Unable to resume printer %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
httpClose(http);
return (ret);
}
static char *
cups_map_printer_name(http_t *http,
const char *name)
{
ipp_t *request,
*response;
ipp_attribute_t *attr;
cups_lang_t *language;
char *printer_name,
*printer_info;
int remote,
shared;
static char *mapped_name = NULL;
static const char *requested[] =
{
"printer-name",
"printer-info",
"printer-type",
"printer-is-shared"
};
CFArrayRef smbQarray;
CFDataRef xmlData;
CFURLRef prefsurl;
Boolean printerprefs;
CFStringRef printername;
CFPropertyListRef plist;
DEBUG(5,("cups_map_printer_name(%s)\n", name));
if (mapped_name)
{
free(mapped_name);
mapped_name = NULL;
}
request = ippNew();
request->request.op.operation_id = CUPS_GET_PRINTERS;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddStrings(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes",
(sizeof(requested) / sizeof(requested[0])),
NULL, requested);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(0,("Unable to get printer list - %s\n",
ippErrorString(cupsLastError())));
httpClose(http);
return NULL;
}
for (attr = response->attrs; attr != NULL;)
{
while (attr != NULL && attr->group_tag != IPP_TAG_PRINTER)
attr = attr->next;
if (attr == NULL)
break;
printer_name= NULL;
printer_info= NULL;
remote = 0;
shared = 1;
while (attr != NULL && attr->group_tag == IPP_TAG_PRINTER)
{
if (strcmp(attr->name, "printer-name") == 0 &&
attr->value_tag == IPP_TAG_NAME)
printer_name = attr->values[0].string.text;
if (strcmp(attr->name, "printer-info") == 0 &&
attr->value_tag == IPP_TAG_TEXT)
printer_info = attr->values[0].string.text;
if (strcmp(attr->name, "printer-type") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
remote = attr->values[0].integer & CUPS_PRINTER_REMOTE;
if (strcmp(attr->name, "printer-is-shared") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
shared = attr->values[0].integer;
attr = attr->next;
}
if (!name || remote || !shared)
continue;
if (!strcmp(name, printer_name) || !strcmp(name, printer_info))
{
mapped_name = strdup(printer_name);
break;
}
}
ippDelete(response);
if (!mapped_name)
{
request = ippNew();
request->request.op.operation_id = CUPS_GET_CLASSES;
request->request.op.request_id = 1;
language = cupsLangDefault();
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, cupsLangEncoding(language));
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL, language->language);
ippAddStrings(request, IPP_TAG_OPERATION, IPP_TAG_NAME,
"requested-attributes",
(sizeof(requested) / sizeof(requested[0])),
NULL, requested);
if ((response = cupsDoRequest(http, request, "/")) == NULL)
{
DEBUG(0,("Unable to get printer list - %s\n",
ippErrorString(cupsLastError())));
httpClose(http);
return;
}
for (attr = response->attrs; attr != NULL;)
{
while (attr != NULL && attr->group_tag != IPP_TAG_PRINTER)
attr = attr->next;
if (attr == NULL)
break;
printer_name= NULL;
printer_info= NULL;
remote = 0;
shared = 1;
while (attr != NULL && attr->group_tag == IPP_TAG_PRINTER)
{
if (strcmp(attr->name, "printer-name") == 0 &&
attr->value_tag == IPP_TAG_NAME)
printer_name = attr->values[0].string.text;
if (strcmp(attr->name, "printer-info") == 0 &&
attr->value_tag == IPP_TAG_TEXT)
printer_info = attr->values[0].string.text;
if (strcmp(attr->name, "printer-type") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
remote = attr->values[0].integer & CUPS_PRINTER_REMOTE;
if (strcmp(attr->name, "printer-is-shared") == 0 &&
attr->value_tag == IPP_TAG_ENUM)
shared = attr->values[0].integer;
attr = attr->next;
}
if (!name || remote || !shared)
continue;
if (!strcmp(name, printer_name) || !strcmp(name, printer_info))
{
mapped_name = strdup(printer_name);
break;
}
}
ippDelete(response);
}
if (mapped_name)
{
prefsurl = CFURLCreateFromFileSystemRepresentation(kCFAllocatorDefault, (const UInt8*)printerprefsfile, (CFIndex)strlen(printerprefsfile), false);
if (prefsurl)
{
printerprefs = CFURLCreateDataAndPropertiesFromResource(kCFAllocatorDefault, prefsurl, &xmlData, NULL, NULL, NULL);
if (printerprefs)
{
plist = CFPropertyListCreateFromXMLData(kCFAllocatorDefault, xmlData, kCFPropertyListImmutable, NULL);
if (plist)
{
smbQarray = (CFArrayRef)CFDictionaryGetValue((CFDictionaryRef)plist, CFSTR("smbSharedQueues"));
if (smbQarray)
{
printername = CFStringCreateWithCString( kCFAllocatorDefault, mapped_name, kCFStringEncodingUTF8 );
if (printername)
{
if (!CFArrayContainsValue(smbQarray, CFRangeMake(0, CFArrayGetCount(smbQarray)), printername)) {
free(mapped_name);
mapped_name = NULL;
}
CFRelease(printername);
}
} else {
free(mapped_name);
mapped_name = NULL;
}
CFRelease(xmlData);
CFRelease(plist);
}
}
CFRelease(prefsurl);
}
}
return mapped_name;
}
struct printif cups_printif =
{
PRINT_CUPS,
cups_queue_get,
cups_queue_pause,
cups_queue_resume,
cups_job_delete,
cups_job_pause,
cups_job_resume,
cups_job_submit,
};
#else
void print_cups_dummy(void) {}
#endif