#include "includes.h"
#include "printing.h"
#ifdef HAVE_CUPS
#include <cups/cups.h>
#include <cups/language.h>
#include <cups/adminutil.h>
extern userdom_struct current_user_info;
#ifdef HAVE_COREFOUNDATION_COREFOUNDATION_H
#undef u32
#include <CoreFoundation/CoreFoundation.h>
#endif
static const char PrintServicePlist[] =
"/Library/Preferences/com.apple.printservice.plist";
struct printer_description
{
const char * printer_name;
const char * printer_info;
const char * printer_location;
BOOL is_shared;
BOOL is_remote;
};
static const char *cups_map_printer_name(http_t *http_p, const char *name);
static BOOL cups_next_printer(ipp_attribute_t ** attrlist,
struct printer_description * desc);
static const char *
cups_passwd_cb(const char *prompt)
{
return (NULL);
}
static http_t *cups_connect(void)
{
http_t *http;
char *server, *p;
int port;
if (lp_cups_server() != NULL && strlen(lp_cups_server()) > 0) {
server = smb_xstrdup(lp_cups_server());
} else {
server = smb_xstrdup(cupsServer());
}
p = strchr(server, ':');
if (p) {
port = atoi(p+1);
*p = '\0';
} else {
port = ippPort();
}
DEBUG(10, ("connecting to cups server %s:%d\n",
server, port));
if ((http = httpConnect(server, port)) == NULL) {
DEBUG(0,("Unable to connect to CUPS server %s:%d - %s\n",
server, port, strerror(errno)));
SAFE_FREE(server);
return NULL;
}
SAFE_FREE(server);
return http;
}
static BOOL cups_sharing_enabled(http_t *http)
{
cups_option_t *options;
int noptions;
if (access(PrintServicePlist, R_OK) == 0) {
return True;
}
if (cupsAdminGetServerSettings(http, &noptions, &options)) {
BOOL result;
const char * val;
val = cupsGetOption(CUPS_SERVER_SHARE_PRINTERS,
noptions, options);
result = (val && atoi(val)) ? True : False;
cupsFreeOptions(noptions, options);
return result;
}
return False;
}
static CFArrayRef printservice_get_queue_names(void)
{
CFArrayRef smbQarray = NULL;
CFDataRef xmlData;
CFURLRef prefsurl;
CFPropertyListRef plist;
smbQarray = NULL;
prefsurl =
CFURLCreateFromFileSystemRepresentation(kCFAllocatorDefault,
(const UInt8*)PrintServicePlist,
(CFIndex)strlen(PrintServicePlist), false);
if (!prefsurl) {
return NULL;
}
if (!CFURLCreateDataAndPropertiesFromResource(kCFAllocatorDefault,
prefsurl, &xmlData, NULL, NULL, NULL)) {
CFRelease(prefsurl);
return NULL;
}
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);
return smbQarray;
}
static BOOL printservice_hide_printer(const char * name, CFArrayRef smbQarray)
{
if (smbQarray) {
CFStringRef printername;
Boolean displayPrinter = True;
printername = CFStringCreateWithCString(kCFAllocatorDefault,
name, kCFStringEncodingUTF8 );
if (printername) {
displayPrinter = CFArrayContainsValue(smbQarray,
CFRangeMake(0, CFArrayGetCount(smbQarray)),
printername);
CFRelease(printername);
}
return displayPrinter ? False : True;
}
return False;
}
static BOOL cups_pcap_cache_add(const struct printer_description *desc,
CFArrayRef smbQarray)
{
const char * share_name = NULL;
const char * share_comment = NULL;
if (share_name == NULL)
share_name = desc->printer_info;
if (share_name == NULL)
share_name = desc->printer_name;
if (share_comment == NULL)
share_comment = desc->printer_location;
if (share_comment == NULL)
share_comment = desc->printer_info;
if (share_comment == NULL)
share_comment = desc->printer_name;
if (share_comment == NULL)
share_comment = "";
if (smbQarray) {
if (!printservice_hide_printer(desc->printer_name,
smbQarray)) {
if (!pcap_cache_add(share_name, share_comment)) {
return False;
}
}
} else {
if (desc->is_shared && !desc->is_remote) {
if (!pcap_cache_add(share_name, share_comment)) {
return False;
}
}
}
return True;
}
BOOL cups_cache_reload(void)
{
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
ipp_attribute_t *attr;
cups_lang_t *language = NULL;
static const char * const requested[] =
{
"printer-name",
"printer-info",
"printer-location",
"printer-type",
"printer-is-shared"
};
struct printer_description desc;
CFArrayRef smbQarray = NULL;
BOOL ret = False;
DEBUG(5, ("reloading cups printcap cache\n"));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
if (!cups_sharing_enabled(http)) {
DEBUG(5, ("CUPS printer sharing globally disabled\n"));
ret = True;
goto out;
}
smbQarray = printservice_get_queue_names();
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())));
goto out;
}
for (attr = response->attrs; attr != NULL;) {
if (!cups_next_printer(&attr, &desc)) {
break;
}
if (!cups_pcap_cache_add(&desc, smbQarray)) {
goto out;
}
}
ippDelete(response);
response = NULL;
request = ippNew();
request->request.op.operation_id = CUPS_GET_CLASSES;
request->request.op.request_id = 1;
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())));
goto out;
}
for (attr = response->attrs; attr != NULL;) {
if (!cups_next_printer(&attr, &desc)) {
break;
}
if (!cups_pcap_cache_add(&desc, smbQarray)) {
goto out;
}
}
ret = True;
out:
if (smbQarray)
CFRelease(smbQarray);
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static int cups_job_delete(const char *sharename, const char *lprm_command, struct printjob *pjob)
{
int ret = 1;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_job_delete(%s, %p (%d))\n", sharename, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
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);
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;
}
} else {
DEBUG(0,("Unable to cancel job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
}
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static int cups_job_pause(int snum, struct printjob *pjob)
{
int ret = 1;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_job_pause(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
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);
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;
}
} else {
DEBUG(0,("Unable to hold job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
}
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static int cups_job_resume(int snum, struct printjob *pjob)
{
int ret = 1;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
DEBUG(5,("cups_job_resume(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
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);
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;
}
} else {
DEBUG(0,("Unable to release job %d - %s\n", pjob->sysjob,
ippErrorString(cupsLastError())));
}
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static int cups_job_submit(int snum, struct printjob *pjob)
{
int ret = 1;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
char *clientname = NULL;
pstring new_jobname;
int num_options = 0;
cups_option_t *options = NULL;
const char *mapped_printer = NULL;
DEBUG(5,("cups_job_submit(%d, %p (%d))\n", snum, pjob, pjob->sysjob));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
mapped_printer = cups_map_printer_name(http, PRINTERNAME(snum));
if (!mapped_printer) {
goto out;
}
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",
mapped_printer);
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", mapped_printer);
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;
}
} else {
DEBUG(0,("Unable to print file to `%s' - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
}
if ( ret == 0 )
unlink(pjob->filename);
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static int cups_queue_get(const char *sharename,
enum printing_types printing_type,
char *lpq_command,
print_queue_struct **q,
print_status_struct *status)
{
fstring printername;
const char *mapped_printer = NULL;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
ipp_attribute_t *attr = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
int qcount = 0,
qalloc = 0;
print_queue_struct *queue = NULL,
*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"
};
*q = NULL;
fstrcpy( printername, lpq_command );
DEBUG(5,("cups_queue_get(%s, %p, %p)\n", printername, q, status));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
mapped_printer = cups_map_printer_name(http, printername);
if (!mapped_printer) {
goto out;
}
slprintf(uri, sizeof(uri) - 1, "ipp://localhost/printers/%s", mapped_printer);
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())));
goto out;
}
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)));
goto out;
}
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;
queue = SMB_REALLOC_ARRAY(queue, print_queue_struct, qalloc);
if (queue == NULL) {
DEBUG(0,("cups_queue_get: Not enough memory!"));
qcount = 0;
goto out;
}
}
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);
response = NULL;
request = ippNew();
request->request.op.operation_id = IPP_GET_PRINTER_ATTRIBUTES;
request->request.op.request_id = 1;
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", mapped_printer,
ippErrorString(cupsLastError())));
*q = queue;
goto out;
}
if (response->request.status.status_code >= IPP_OK_CONFLICT) {
DEBUG(0,("Unable to get printer status for %s - %s\n", mapped_printer,
ippErrorString(response->request.status.status_code)));
*q = queue;
goto out;
}
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);
*q = queue;
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return qcount;
}
static int cups_queue_pause(int snum)
{
int ret = 1;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
const char *mapped_printer = NULL;
DEBUG(5,("cups_queue_pause(%d)\n", snum));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
mapped_printer = cups_map_printer_name(http, PRINTERNAME(snum));
if (!mapped_printer) {
goto out;
}
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",
mapped_printer);
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);
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;
}
} else {
DEBUG(0,("Unable to pause printer %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
}
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static int cups_queue_resume(int snum)
{
int ret = 1;
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
cups_lang_t *language = NULL;
char uri[HTTP_MAX_URI];
const char *mapped_printer = NULL;
DEBUG(5,("cups_queue_resume(%d)\n", snum));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
mapped_printer = cups_map_printer_name(http, PRINTERNAME(snum));
if (mapped_printer == NULL) {
goto out;
}
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",
mapped_printer);
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);
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;
}
} else {
DEBUG(0,("Unable to resume printer %s - %s\n", PRINTERNAME(snum),
ippErrorString(cupsLastError())));
}
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
static BOOL cups_next_printer(ipp_attribute_t ** attrlist,
struct printer_description * desc)
{
ipp_attribute_t * attr;
attr = *attrlist;
ZERO_STRUCTP(desc);
while (attr != NULL && attr->group_tag != IPP_TAG_PRINTER) {
attr = attr->next;
}
if (attr == NULL) {
*attrlist = attr;
return False;
}
while (attr != NULL && attr->group_tag == IPP_TAG_PRINTER) {
if (attr->value_tag == IPP_TAG_NAME &&
strcmp(attr->name, "printer-name") == 0) {
desc->printer_name = attr->values[0].string.text;
}
if (attr->value_tag == IPP_TAG_TEXT &&
strcmp(attr->name, "printer-info") == 0) {
desc->printer_info = attr->values[0].string.text;
}
if (attr->value_tag == IPP_TAG_TEXT &&
strcmp(attr->name, "printer-location") == 0) {
desc->printer_location = attr->values[0].string.text;
}
if (attr->value_tag == IPP_TAG_ENUM &&
strcmp(attr->name, "printer-type") == 0) {
desc->is_remote =
attr->values[0].integer & CUPS_PRINTER_REMOTE;
}
if (attr->value_tag == IPP_TAG_BOOLEAN &&
strcmp(attr->name, "printer-is-shared") == 0) {
desc->is_shared = attr->values[0].boolean;
}
attr = attr->next;
}
*attrlist = attr;
return desc->printer_name ? True : False;
}
static BOOL printer_status(ipp_t * response,
const char * name, const char ** mapped, BOOL * shared)
{
ipp_attribute_t * attr;
struct printer_description desc;
for (attr = response->attrs; attr != NULL;) {
if (!cups_next_printer(&attr, &desc)) {
return False;
}
if (strcmp(name, desc.printer_name) == 0 ||
strcmp(name, desc.printer_info) == 0) {
*mapped = desc.printer_name;
*shared = (!desc.is_remote && desc.is_shared);
return True;
}
}
return False;
}
static const char *
cups_map_printer_name(http_t *http,
const char *name)
{
ipp_t *request,
*response;
cups_lang_t *language;
const char * mapped = NULL;
BOOL shared = False;
static char *mapped_name = NULL;
static const char * const requested[] =
{
"printer-name",
"printer-info",
"printer-type",
"printer-is-shared"
};
DEBUG(5,("cups_map_printer_name(%s)\n", name));
SAFE_FREE(mapped_name);
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())));
return NULL;
}
if (printer_status(response, name, &mapped, &shared)) {
mapped_name = SMB_STRDUP(mapped);
}
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())));
return NULL;
}
if (printer_status(response, name, &mapped, &shared)) {
mapped_name = SMB_STRDUP(mapped);
}
ippDelete(response);
}
if (mapped_name) {
CFArrayRef smbQarray;
smbQarray = printservice_get_queue_names();
if (!smbQarray) {
if (shared) {
return mapped_name;
} else {
SAFE_FREE(mapped_name);
return NULL;
}
}
if (printservice_hide_printer(mapped_name, smbQarray)) {
SAFE_FREE(mapped_name);
}
CFRelease(smbQarray);
return mapped_name;
}
return NULL;
}
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,
};
BOOL cups_pull_comment_location(NT_PRINTER_INFO_LEVEL_2 *printer)
{
http_t *http = NULL;
ipp_t *request = NULL,
*response = NULL;
ipp_attribute_t *attr;
cups_lang_t *language = NULL;
char *name,
*info,
*location;
char uri[HTTP_MAX_URI];
static const char *requested[] =
{
"printer-name",
"printer-info",
"printer-location"
};
BOOL ret = False;
DEBUG(5, ("pulling %s location\n", printer->sharename));
cupsSetPasswordCB(cups_passwd_cb);
if ((http = cups_connect()) == NULL) {
goto out;
}
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);
slprintf(uri, sizeof(uri) - 1, "ipp://%s/printers/%s",
lp_cups_server(), printer->sharename);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI,
"printer-uri", NULL, uri);
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 attributes - %s\n",
ippErrorString(cupsLastError())));
goto out;
}
for (attr = response->attrs; attr != NULL;) {
while (attr != NULL && attr->group_tag != IPP_TAG_PRINTER)
attr = attr->next;
if (attr == NULL)
break;
name = NULL;
info = NULL;
location = NULL;
while ( attr && (attr->group_tag == IPP_TAG_PRINTER) ) {
if ( (strcmp(attr->name, "printer-info") == 0)
&& (attr->value_tag == IPP_TAG_TEXT)
&& !strlen(printer->comment) )
{
DEBUG(5,("cups_pull_comment_location: Using cups comment: %s\n",
attr->values[0].string.text));
pstrcpy(printer->comment,attr->values[0].string.text);
}
if ( (strcmp(attr->name, "printer-location") == 0)
&& (attr->value_tag == IPP_TAG_TEXT)
&& !strlen(printer->location) )
{
DEBUG(5,("cups_pull_comment_location: Using cups location: %s\n",
attr->values[0].string.text));
fstrcpy(printer->location,attr->values[0].string.text);
}
attr = attr->next;
}
if (name == NULL)
break;
}
ret = True;
out:
if (response)
ippDelete(response);
if (language)
cupsLangFree(language);
if (http)
httpClose(http);
return ret;
}
#else
void print_cups_dummy(void);
void print_cups_dummy(void) {}
#endif