#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <cups/cups.h>
#include <cups/language.h>
#include <cups/string.h>
#include <signal.h>
const char *password_cb(const char *);
int report_printer_state(ipp_t *ipp);
char *password = NULL;
int
main(int argc,
char *argv[])
{
int i;
int num_options;
cups_option_t *options;
char method[255],
hostname[1024],
username[255],
resource[1024],
filename[1024];
int port;
char uri[HTTP_MAX_URI];
ipp_status_t ipp_status;
http_t *http;
ipp_t *request,
*response,
*supported;
ipp_attribute_t *job_id_attr;
int job_id;
ipp_attribute_t *job_state;
ipp_attribute_t *copies_sup;
ipp_attribute_t *charset_sup;
ipp_attribute_t *format_sup;
const char *charset;
cups_lang_t *language;
int copies;
const char *content_type;
#if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
struct sigaction action;
#endif
int version;
int reasons;
setbuf(stderr, NULL);
if (argc == 1)
{
char *s;
if ((s = strrchr(argv[0], '/')) != NULL)
s ++;
else
s = argv[0];
printf("network %s \"Unknown\" \"Internet Printing Protocol (%s)\"\n", s, s);
return (0);
}
else if (argc < 6 || argc > 7)
{
fprintf(stderr, "Usage: %s job-id user title copies options [file]\n",
argv[0]);
return (1);
}
if (argc == 6)
{
int fd;
char buffer[8192];
int bytes;
if ((fd = cupsTempFd(filename, sizeof(filename))) < 0)
{
perror("ERROR: unable to create temporary file");
return (1);
}
while ((bytes = fread(buffer, 1, sizeof(buffer), stdin)) > 0)
if (write(fd, buffer, bytes) < bytes)
{
perror("ERROR: unable to write to temporary file");
close(fd);
unlink(filename);
return (1);
}
close(fd);
}
else
strlcpy(filename, argv[6], sizeof(filename));
httpSeparate(argv[0], method, username, hostname, &port, resource);
cupsSetPasswordCB(password_cb);
if (username[0])
{
if ((password = strchr(username, ':')) != NULL)
*password++ = '\0';
cupsSetUser(username);
}
do
{
fprintf(stderr, "INFO: Connecting to %s on port %d...\n", hostname, port);
if ((http = httpConnect(hostname, port)) == NULL)
{
if (errno == ECONNREFUSED || errno == EHOSTDOWN ||
errno == EHOSTUNREACH)
{
fprintf(stderr, "INFO: Network host \'%s\' is busy; will retry in 30 seconds...",
hostname);
sleep(30);
}
else
{
perror("ERROR: Unable to connect to IPP host");
sleep(30);
}
}
}
while (http == NULL);
fprintf(stderr, "INFO: Connected to %s...\n", hostname);
snprintf(uri, sizeof(uri), "%s://%s:%d%s", method, hostname, port, resource);
language = cupsLangDefault();
charset_sup = NULL;
copies_sup = NULL;
format_sup = NULL;
version = 1;
supported = NULL;
do
{
request = ippNew();
request->request.op.version[1] = version;
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, "utf-8");
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL,
language != NULL ? language->language : "en");
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri",
NULL, uri);
fputs("DEBUG: Getting supported attributes...\n", stderr);
if ((supported = cupsDoRequest(http, request, resource)) == NULL)
ipp_status = cupsLastError();
else
ipp_status = supported->request.status.status_code;
if (ipp_status > IPP_OK_CONFLICT)
{
if (ipp_status == IPP_PRINTER_BUSY ||
ipp_status == IPP_SERVICE_UNAVAILABLE)
{
fputs("INFO: Printer busy; will retry in 10 seconds...\n", stderr);
report_printer_state(supported);
sleep(10);
}
else if ((ipp_status == IPP_BAD_REQUEST ||
ipp_status == IPP_VERSION_NOT_SUPPORTED) && version == 1)
{
fputs("INFO: Printer does not support IPP/1.1, trying IPP/1.0...\n", stderr);
version = 0;
httpReconnect(http);
}
else
fprintf(stderr, "ERROR: Unable to get printer status (%s)!\n",
ippErrorString(ipp_status));
if (supported)
ippDelete(supported);
continue;
}
else if ((copies_sup = ippFindAttribute(supported, "copies-supported",
IPP_TAG_RANGE)) != NULL)
{
if (copies_sup->values[0].range.upper <= 1)
copies_sup = NULL;
}
charset_sup = ippFindAttribute(supported, "charset-supported",
IPP_TAG_CHARSET);
format_sup = ippFindAttribute(supported, "document-format-supported",
IPP_TAG_MIMETYPE);
if (format_sup)
{
fprintf(stderr, "DEBUG: document-format-supported (%d values)\n",
format_sup->num_values);
for (i = 0; i < format_sup->num_values; i ++)
fprintf(stderr, "DEBUG: [%d] = \"%s\"\n", i,
format_sup->values[i].string.text);
}
report_printer_state(supported);
}
while (ipp_status > IPP_OK_CONFLICT);
if (argc < 7)
{
#ifdef HAVE_SIGSET
sigset(SIGTERM, SIG_IGN);
#elif defined(HAVE_SIGACTION)
memset(&action, 0, sizeof(action));
sigemptyset(&action.sa_mask);
action.sa_handler = SIG_IGN;
sigaction(SIGTERM, &action, NULL);
#else
signal(SIGTERM, SIG_IGN);
#endif
}
if (copies_sup || argc < 7)
copies = 1;
else
copies = atoi(argv[4]);
charset = language ? cupsLangEncoding(language) : "us-ascii";
if (charset_sup)
{
for (i = 0; i < charset_sup->num_values; i ++)
if (strcasecmp(charset, charset_sup->values[i].string.text) == 0)
break;
if (i >= charset_sup->num_values)
{
for (i = 0; i < charset_sup->num_values; i ++)
if (strcasecmp("us-ascii", charset_sup->values[i].string.text) == 0)
break;
if (i < charset_sup->num_values)
charset = "us-ascii";
else
charset = "utf-8";
}
}
reasons = 0;
while (copies > 0)
{
request = ippNew();
request->request.op.version[1] = version;
request->request.op.operation_id = IPP_PRINT_JOB;
request->request.op.request_id = 1;
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, charset);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL,
language != NULL ? language->language : "en");
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri",
NULL, uri);
fprintf(stderr, "DEBUG: printer-uri = \"%s\"\n", uri);
if (argv[2][0])
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, argv[2]);
fprintf(stderr, "DEBUG: requesting-user-name = \"%s\"\n", argv[2]);
if (argv[3][0])
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "job-name", NULL,
argv[3]);
fprintf(stderr, "DEBUG: job-name = \"%s\"\n", argv[3]);
options = NULL;
num_options = cupsParseOptions(argv[5], 0, &options);
if (argc > 6)
content_type = getenv("CONTENT_TYPE");
else
content_type = "application/vnd.cups-raw";
if (content_type != NULL && format_sup != NULL)
{
for (i = 0; i < format_sup->num_values; i ++)
if (strcasecmp(content_type, format_sup->values[i].string.text) == 0)
break;
if (i < format_sup->num_values)
num_options = cupsAddOption("document-format", content_type,
num_options, &options);
}
if (copies_sup)
{
cupsEncodeOptions(request, num_options, options);
ippAddInteger(request, IPP_TAG_JOB, IPP_TAG_INTEGER, "copies",
atoi(argv[4]));
}
cupsFreeOptions(num_options, options);
if (!copies_sup)
httpReconnect(http);
if ((response = cupsDoFileRequest(http, request, resource, filename)) == NULL)
ipp_status = cupsLastError();
else
ipp_status = response->request.status.status_code;
if (ipp_status > IPP_OK_CONFLICT)
{
job_id = 0;
if (ipp_status == IPP_SERVICE_UNAVAILABLE ||
ipp_status == IPP_PRINTER_BUSY)
{
fputs("INFO: Printer is busy; retrying print job...\n", stderr);
sleep(10);
}
else
fprintf(stderr, "ERROR: Print file was not accepted (%s)!\n",
ippErrorString(ipp_status));
}
else if ((job_id_attr = ippFindAttribute(response, "job-id",
IPP_TAG_INTEGER)) == NULL)
{
fputs("INFO: Print file accepted - job ID unknown.\n", stderr);
job_id = 0;
}
else
{
job_id = job_id_attr->values[0].integer;
fprintf(stderr, "INFO: Print file accepted - job ID %d.\n", job_id);
}
if (response)
ippDelete(response);
if (ipp_status <= IPP_OK_CONFLICT && argc > 6)
{
fprintf(stderr, "PAGE: 1 %d\n", copies_sup ? atoi(argv[4]) : 1);
copies --;
}
else if (ipp_status != IPP_SERVICE_UNAVAILABLE &&
ipp_status != IPP_PRINTER_BUSY)
break;
if (!job_id)
continue;
fputs("INFO: Waiting for job to complete...\n", stderr);
for (;;)
{
request = ippNew();
request->request.op.version[1] = version;
request->request.op.operation_id = IPP_GET_JOB_ATTRIBUTES;
request->request.op.request_id = 1;
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_CHARSET,
"attributes-charset", NULL, charset);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL,
language != NULL ? language->language : "en");
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri",
NULL, uri);
ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id",
job_id);
if (argv[2][0])
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, argv[2]);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_KEYWORD,
"requested-attributes", NULL, "job-state");
if (!copies_sup)
httpReconnect(http);
if ((response = cupsDoRequest(http, request, resource)) == NULL)
ipp_status = cupsLastError();
else
ipp_status = response->request.status.status_code;
if (ipp_status == IPP_NOT_FOUND)
{
ippDelete(response);
ipp_status = IPP_OK;
break;
}
if (ipp_status > IPP_OK_CONFLICT)
{
if (ipp_status != IPP_SERVICE_UNAVAILABLE &&
ipp_status != IPP_PRINTER_BUSY)
{
if (response)
ippDelete(response);
fprintf(stderr, "ERROR: Unable to get job %d attributes (%s)!\n",
job_id, ippErrorString(ipp_status));
break;
}
}
else if ((job_state = ippFindAttribute(response, "job-state", IPP_TAG_ENUM)) != NULL)
{
if (job_state->values[0].integer > IPP_JOB_PROCESSING ||
job_state->values[0].integer == IPP_JOB_HELD)
{
ippDelete(response);
break;
}
}
if (response)
ippDelete(response);
request = ippNew();
request->request.op.version[1] = version;
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, charset);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_LANGUAGE,
"attributes-natural-language", NULL,
language != NULL ? language->language : "en");
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri",
NULL, uri);
if (argv[2][0])
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name",
NULL, argv[2]);
ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_KEYWORD,
"requested-attributes", NULL, "printer-state-reasons");
if (!copies_sup)
httpReconnect(http);
if ((response = cupsDoRequest(http, request, resource)) != NULL)
{
reasons = report_printer_state(response);
ippDelete(response);
}
sleep(10);
}
}
httpClose(http);
if (supported)
ippDelete(supported);
if (argc < 7)
unlink(filename);
if (ipp_status <= IPP_OK_CONFLICT && reasons == 0)
fputs("INFO: Ready to print.\n", stderr);
return (ipp_status > IPP_OK_CONFLICT);
}
const char *
password_cb(const char *prompt)
{
(void)prompt;
return (password);
}
int
report_printer_state(ipp_t *ipp)
{
int i;
int count;
ipp_attribute_t *reasons;
const char *message;
char unknown[1024];
if ((reasons = ippFindAttribute(ipp, "printer-state-reasons",
IPP_TAG_KEYWORD)) == NULL)
return (0);
for (i = 0, count = 0; i < reasons->num_values; i ++)
{
message = NULL;
if (strncmp(reasons->values[i].string.text, "media-needed", 12) == 0)
message = "Media tray needs to be filled.";
else if (strncmp(reasons->values[i].string.text, "media-jam", 9) == 0)
message = "Media jam!";
else if (strncmp(reasons->values[i].string.text, "moving-to-paused", 16) == 0 ||
strncmp(reasons->values[i].string.text, "paused", 6) == 0 ||
strncmp(reasons->values[i].string.text, "shutdown", 8) == 0)
message = "Printer off-line.";
else if (strncmp(reasons->values[i].string.text, "toner-low", 9) == 0)
message = "Toner low.";
else if (strncmp(reasons->values[i].string.text, "toner-empty", 11) == 0)
message = "Out of toner!";
else if (strncmp(reasons->values[i].string.text, "cover-open", 10) == 0)
message = "Cover open.";
else if (strncmp(reasons->values[i].string.text, "interlock-open", 14) == 0)
message = "Interlock open.";
else if (strncmp(reasons->values[i].string.text, "door-open", 9) == 0)
message = "Door open.";
else if (strncmp(reasons->values[i].string.text, "input-tray-missing", 18) == 0)
message = "Media tray missing!";
else if (strncmp(reasons->values[i].string.text, "media-low", 9) == 0)
message = "Media tray almost empty.";
else if (strncmp(reasons->values[i].string.text, "media-empty", 11) == 0)
message = "Media tray empty!";
else if (strncmp(reasons->values[i].string.text, "output-tray-missing", 19) == 0)
message = "Output tray missing!";
else if (strncmp(reasons->values[i].string.text, "output-area-almost-full", 23) == 0)
message = "Output bin almost full.";
else if (strncmp(reasons->values[i].string.text, "output-area-full", 16) == 0)
message = "Output bin full!";
else if (strncmp(reasons->values[i].string.text, "marker-supply-low", 17) == 0)
message = "Ink/toner almost empty.";
else if (strncmp(reasons->values[i].string.text, "marker-supply-empty", 19) == 0)
message = "Ink/toner empty!";
else if (strncmp(reasons->values[i].string.text, "marker-waste-almost-full", 24) == 0)
message = "Ink/toner waste bin almost full.";
else if (strncmp(reasons->values[i].string.text, "marker-waste-full", 17) == 0)
message = "Ink/toner waste bin full!";
else if (strncmp(reasons->values[i].string.text, "fuser-over-temp", 15) == 0)
message = "Fuser temperature high!";
else if (strncmp(reasons->values[i].string.text, "fuser-under-temp", 16) == 0)
message = "Fuser temperature low!";
else if (strncmp(reasons->values[i].string.text, "opc-near-eol", 12) == 0)
message = "OPC almost at end-of-life.";
else if (strncmp(reasons->values[i].string.text, "opc-life-over", 13) == 0)
message = "OPC at end-of-life!";
else if (strncmp(reasons->values[i].string.text, "developer-low", 13) == 0)
message = "Developer almost empty.";
else if (strncmp(reasons->values[i].string.text, "developer-empty", 15) == 0)
message = "Developer empty!";
else if (strstr(reasons->values[i].string.text, "error") != NULL)
{
message = unknown;
snprintf(unknown, sizeof(unknown), "Unknown printer error (%s)!",
reasons->values[i].string.text);
}
if (message)
{
count ++;
if (strstr(reasons->values[i].string.text, "error"))
fprintf(stderr, "ERROR: %s\n", message);
else if (strstr(reasons->values[i].string.text, "warning"))
fprintf(stderr, "WARNING: %s\n", message);
else
fprintf(stderr, "INFO: %s\n", message);
}
}
return (count);
}