/* * "$Id: ippserver.c 12142 2014-08-30 02:35:43Z msweet $" * * Sample IPP Everywhere server for CUPS. * * Copyright 2010-2014 by Apple Inc. * * These coded instructions, statements, and computer programs are the * property of Apple Inc. and are protected by Federal copyright * law. Distribution and use rights are outlined in the file "LICENSE.txt" * which should have been included with this file. If this file is * file is missing or damaged, see the license at "http://www.cups.org/". * * This file is subject to the Apple OS-Developed Software exception. */ /* * Disable private and deprecated stuff so we can verify that the public API * is sufficient to implement a server. */ #define _IPP_PRIVATE_STRUCTURES 0 /* Disable private IPP stuff */ #define _CUPS_NO_DEPRECATED 1 /* Disable deprecated stuff */ /* * Include necessary headers... */ #include /* CUPS configuration header */ #include /* Public API */ #include /* CUPS string functions */ #include /* For multithreading functions */ #include #include #include #include #include #include #include #ifdef WIN32 # include # include # include # define WEXITSTATUS(s) (s) # include typedef ULONG nfds_t; # define poll WSAPoll #else extern char **environ; # include # include # include #endif /* WIN32 */ #ifdef HAVE_DNSSD # include #endif /* HAVE_DNSSD */ #ifdef HAVE_SYS_MOUNT_H # include #endif /* HAVE_SYS_MOUNT_H */ #ifdef HAVE_SYS_STATFS_H # include #endif /* HAVE_SYS_STATFS_H */ #ifdef HAVE_SYS_STATVFS_H # include #endif /* HAVE_SYS_STATVFS_H */ #ifdef HAVE_SYS_VFS_H # include #endif /* HAVE_SYS_VFS_H */ /* * Constants... */ enum _ipp_preason_e /* printer-state-reasons bit values */ { _IPP_PREASON_NONE = 0x0000, /* none */ _IPP_PREASON_OTHER = 0x0001, /* other */ _IPP_PREASON_COVER_OPEN = 0x0002, /* cover-open */ _IPP_PREASON_INPUT_TRAY_MISSING = 0x0004, /* input-tray-missing */ _IPP_PREASON_MARKER_SUPPLY_EMPTY = 0x0008, /* marker-supply-empty */ _IPP_PREASON_MARKER_SUPPLY_LOW = 0x0010, /* marker-supply-low */ _IPP_PREASON_MARKER_WASTE_ALMOST_FULL = 0x0020, /* marker-waste-almost-full */ _IPP_PREASON_MARKER_WASTE_FULL = 0x0040, /* marker-waste-full */ _IPP_PREASON_MEDIA_EMPTY = 0x0080, /* media-empty */ _IPP_PREASON_MEDIA_JAM = 0x0100, /* media-jam */ _IPP_PREASON_MEDIA_LOW = 0x0200, /* media-low */ _IPP_PREASON_MEDIA_NEEDED = 0x0400, /* media-needed */ _IPP_PREASON_MOVING_TO_PAUSED = 0x0800, /* moving-to-paused */ _IPP_PREASON_PAUSED = 0x1000, /* paused */ _IPP_PREASON_SPOOL_AREA_FULL = 0x2000,/* spool-area-full */ _IPP_PREASON_TONER_EMPTY = 0x4000, /* toner-empty */ _IPP_PREASON_TONER_LOW = 0x8000 /* toner-low */ }; typedef unsigned int _ipp_preason_t; /* Bitfield for printer-state-reasons */ typedef enum _ipp_media_class_e { _IPP_GENERAL, /* General-purpose size */ _IPP_PHOTO_ONLY, /* Photo-only size */ _IPP_ENV_ONLY /* Envelope-only size */ } _ipp_media_class_t; typedef enum _ipp_media_size_e { _IPP_MEDIA_SIZE_NONE = -1, _IPP_MEDIA_SIZE_A4, _IPP_MEDIA_SIZE_A5, _IPP_MEDIA_SIZE_A6, _IPP_MEDIA_SIZE_DL, _IPP_MEDIA_SIZE_LEGAL, _IPP_MEDIA_SIZE_LETTER, _IPP_MEDIA_SIZE_COM10, _IPP_MEDIA_SIZE_3x5, _IPP_MEDIA_SIZE_L, _IPP_MEDIA_SIZE_4x6, _IPP_MEDIA_SIZE_5x7 } _ipp_media_size_t; static const char * const media_supported[] = { /* media-supported values */ "iso_a4_210x297mm", /* A4 */ "iso_a5_148x210mm", /* A5 */ "iso_a6_105x148mm", /* A6 */ "iso_dl_110x220mm", /* DL */ "na_legal_8.5x14in", /* Legal */ "na_letter_8.5x11in", /* Letter */ "na_number-10_4.125x9.5in", /* #10 */ "na_index-3x5_3x5in", /* 3x5 */ "oe_photo-l_3.5x5in", /* L */ "na_index-4x6_4x6in", /* 4x6 */ "na_5x7_5x7in" /* 5x7 aka 2L */ }; static const int media_col_sizes[][3] = { /* media-col-database sizes */ { 21000, 29700, _IPP_GENERAL }, /* A4 */ { 14800, 21000, _IPP_PHOTO_ONLY }, /* A5 */ { 10500, 14800, _IPP_PHOTO_ONLY }, /* A6 */ { 11000, 22000, _IPP_ENV_ONLY }, /* DL */ { 21590, 35560, _IPP_GENERAL }, /* Legal */ { 21590, 27940, _IPP_GENERAL }, /* Letter */ { 10477, 24130, _IPP_ENV_ONLY }, /* #10 */ { 7630, 12700, _IPP_PHOTO_ONLY }, /* 3x5 */ { 8890, 12700, _IPP_PHOTO_ONLY }, /* L */ { 10160, 15240, _IPP_PHOTO_ONLY }, /* 4x6 */ { 12700, 17780, _IPP_PHOTO_ONLY } /* 5x7 aka 2L */ }; typedef enum _ipp_media_source_e { _IPP_MEDIA_SOURCE_NONE = -1, _IPP_MEDIA_SOURCE_AUTO, _IPP_MEDIA_SOURCE_MAIN, _IPP_MEDIA_SOURCE_MANUAL, _IPP_MEDIA_SOURCE_ENVELOPE, _IPP_MEDIA_SOURCE_PHOTO } _ipp_media_source_t; static const char * const media_source_supported[] = /* media-source-supported values */ { "auto", "main", "manual", "envelope", "photo" }; typedef enum _ipp_media_type_e { _IPP_MEDIA_TYPE_NONE = -1, _IPP_MEDIA_TYPE_AUTO, _IPP_MEDIA_TYPE_CARDSTOCK, _IPP_MEDIA_TYPE_ENVELOPE, _IPP_MEDIA_TYPE_LABELS, _IPP_MEDIA_TYPE_OTHER, _IPP_MEDIA_TYPE_GLOSSY, _IPP_MEDIA_TYPE_HIGH_GLOSS, _IPP_MEDIA_TYPE_MATTE, _IPP_MEDIA_TYPE_SATIN, _IPP_MEDIA_TYPE_SEMI_GLOSS, _IPP_MEDIA_TYPE_STATIONERY, _IPP_MEDIA_TYPE_LETTERHEAD, _IPP_MEDIA_TYPE_TRANSPARENCY } _ipp_media_type_t; static const char * const media_type_supported[] = /* media-type-supported values */ { "auto", "cardstock", "envelope", "labels", "other", "photographic-glossy", "photographic-high-gloss", "photographic-matte", "photographic-satin", "photographic-semi-gloss", "stationery", "stationery-letterhead", "transparency" }; typedef enum _ipp_supply_e { _IPP_SUPPLY_CYAN, /* Cyan Toner */ _IPP_SUPPLY_MAGENTA, /* Magenta Toner */ _IPP_SUPPLY_YELLOW, /* Yellow Toner */ _IPP_SUPPLY_BLACK, /* Black Toner */ _IPP_SUPPLY_WASTE /* Waste Toner */ } _ipp_supply_t; static const char * const printer_supplies[] = { /* printer-supply-description values */ "Cyan Toner", "Magenta Toner", "Yellow Toner", "Black Toner", "Toner Waste" }; /* * Structures... */ typedef struct _ipp_filter_s /**** Attribute filter ****/ { cups_array_t *ra; /* Requested attributes */ ipp_tag_t group_tag; /* Group to copy */ } _ipp_filter_t; typedef struct _ipp_job_s _ipp_job_t; typedef struct _ipp_printer_s /**** Printer data ****/ { int ipv4, /* IPv4 listener */ ipv6; /* IPv6 listener */ #ifdef HAVE_DNSSD DNSServiceRef common_ref, /* Shared service connection */ ipp_ref, /* Bonjour IPP service */ # ifdef HAVE_SSL ipps_ref, /* Bonjour IPPS service */ # endif /* HAVE_SSL */ http_ref, /* Bonjour HTTP service */ printer_ref; /* Bonjour LPD service */ TXTRecordRef ipp_txt; /* Bonjour IPP TXT record */ char *dnssd_name; /* printer-dnssd-name */ #endif /* HAVE_DNSSD */ char *name, /* printer-name */ *icon, /* Icon filename */ *directory, /* Spool directory */ *hostname, /* Hostname */ *uri, /* printer-uri-supported */ *command; /* Command to run with job file */ int port; /* Port */ size_t urilen; /* Length of printer URI */ ipp_t *attrs; /* Static attributes */ time_t start_time; /* Startup time */ time_t config_time; /* printer-config-change-time */ ipp_pstate_t state; /* printer-state value */ _ipp_preason_t state_reasons; /* printer-state-reasons values */ time_t state_time; /* printer-state-change-time */ cups_array_t *jobs; /* Jobs */ _ipp_job_t *active_job; /* Current active/pending job */ int next_job_id; /* Next job-id value */ _cups_rwlock_t rwlock; /* Printer lock */ _ipp_media_size_t main_size; /* Ready media */ _ipp_media_type_t main_type; int main_level; _ipp_media_size_t envelope_size; int envelope_level; _ipp_media_size_t photo_size; _ipp_media_type_t photo_type; int photo_level; int supplies[5]; /* Supply levels (0-100) */ } _ipp_printer_t; struct _ipp_job_s /**** Job data ****/ { int id; /* Job ID */ const char *name, /* job-name */ *username, /* job-originating-user-name */ *format; /* document-format */ ipp_jstate_t state; /* job-state value */ time_t created, /* time-at-creation value */ processing, /* time-at-processing value */ completed; /* time-at-completed value */ int impressions, /* job-impressions value */ impcompleted; /* job-impressions-completed value */ ipp_t *attrs; /* Static attributes */ int cancel; /* Non-zero when job canceled */ char *filename; /* Print file name */ int fd; /* Print file descriptor */ _ipp_printer_t *printer; /* Printer */ }; typedef struct _ipp_client_s /**** Client data ****/ { http_t *http; /* HTTP connection */ ipp_t *request, /* IPP request */ *response; /* IPP response */ time_t start; /* Request start time */ http_state_t operation; /* Request operation */ ipp_op_t operation_id; /* IPP operation-id */ char uri[1024], /* Request URI */ *options; /* URI options */ http_addr_t addr; /* Client address */ char hostname[256]; /* Client hostname */ _ipp_printer_t *printer; /* Printer */ _ipp_job_t *job; /* Current job, if any */ } _ipp_client_t; /* * Local functions... */ static void clean_jobs(_ipp_printer_t *printer); static int compare_jobs(_ipp_job_t *a, _ipp_job_t *b); static void copy_attributes(ipp_t *to, ipp_t *from, cups_array_t *ra, ipp_tag_t group_tag, int quickcopy); static void copy_job_attributes(_ipp_client_t *client, _ipp_job_t *job, cups_array_t *ra); static _ipp_client_t *create_client(_ipp_printer_t *printer, int sock); static _ipp_job_t *create_job(_ipp_client_t *client); static int create_listener(int family, int port); static ipp_t *create_media_col(const char *media, const char *source, const char *type, int width, int length, int margins); static ipp_t *create_media_size(int width, int length); static _ipp_printer_t *create_printer(const char *servername, const char *name, const char *location, const char *make, const char *model, const char *icon, const char *docformats, int ppm, int ppm_color, int duplex, int port, int pin, #ifdef HAVE_DNSSD const char *subtype, #endif /* HAVE_DNSSD */ const char *directory, const char *command); static void debug_attributes(const char *title, ipp_t *ipp, int response); static void delete_client(_ipp_client_t *client); static void delete_job(_ipp_job_t *job); static void delete_printer(_ipp_printer_t *printer); #ifdef HAVE_DNSSD static void dnssd_callback(DNSServiceRef sdRef, DNSServiceFlags flags, DNSServiceErrorType errorCode, const char *name, const char *regtype, const char *domain, _ipp_printer_t *printer); #endif /* HAVE_DNSSD */ static int filter_cb(_ipp_filter_t *filter, ipp_t *dst, ipp_attribute_t *attr); static _ipp_job_t *find_job(_ipp_client_t *client); static void html_escape(_ipp_client_t *client, const char *s, size_t slen); static void html_footer(_ipp_client_t *client); static void html_header(_ipp_client_t *client, const char *title); static void html_printf(_ipp_client_t *client, const char *format, ...) __attribute__((__format__(__printf__, 2, 3))); static void ipp_cancel_job(_ipp_client_t *client); static void ipp_close_job(_ipp_client_t *client); static void ipp_create_job(_ipp_client_t *client); static void ipp_get_job_attributes(_ipp_client_t *client); static void ipp_get_jobs(_ipp_client_t *client); static void ipp_get_printer_attributes(_ipp_client_t *client); static void ipp_identify_printer(_ipp_client_t *client); static void ipp_print_job(_ipp_client_t *client); static void ipp_print_uri(_ipp_client_t *client); static void ipp_send_document(_ipp_client_t *client); static void ipp_send_uri(_ipp_client_t *client); static void ipp_validate_job(_ipp_client_t *client); static int parse_options(_ipp_client_t *client, cups_option_t **options); static void *process_client(_ipp_client_t *client); static int process_http(_ipp_client_t *client); static int process_ipp(_ipp_client_t *client); static void *process_job(_ipp_job_t *job); #ifdef HAVE_DNSSD static int register_printer(_ipp_printer_t *printer, const char *location, const char *make, const char *model, const char *formats, const char *adminurl, const char *uuid, int color, int duplex, const char *regtype); #endif /* HAVE_DNSSD */ static int respond_http(_ipp_client_t *client, http_status_t code, const char *content_coding, const char *type, size_t length); static void respond_ipp(_ipp_client_t *client, ipp_status_t status, const char *message, ...) __attribute__ ((__format__ (__printf__, 3, 4))); static void respond_unsupported(_ipp_client_t *client, ipp_attribute_t *attr); static void run_printer(_ipp_printer_t *printer); static char *time_string(time_t tv, char *buffer, size_t bufsize); static void usage(int status) __attribute__((noreturn)); static int valid_doc_attributes(_ipp_client_t *client); static int valid_job_attributes(_ipp_client_t *client); /* * Globals... */ static int KeepFiles = 0, Verbosity = 0; /* * 'main()' - Main entry to the sample server. */ int /* O - Exit status */ main(int argc, /* I - Number of command-line args */ char *argv[]) /* I - Command-line arguments */ { int i; /* Looping var */ const char *opt, /* Current option character */ *command = NULL, /* Command to run with job files */ *servername = NULL, /* Server host name */ *name = NULL, /* Printer name */ *location = "", /* Location of printer */ *make = "Test", /* Manufacturer */ *model = "Printer", /* Model */ *icon = "printer.png", /* Icon file */ *formats = "application/pdf,image/jpeg,image/pwg-raster"; /* Supported formats */ #ifdef HAVE_SSL const char *keypath = NULL; /* Keychain path */ #endif /* HAVE_SSL */ #ifdef HAVE_DNSSD const char *subtype = "_print"; /* Bonjour service subtype */ #endif /* HAVE_DNSSD */ int port = 0, /* Port number (0 = auto) */ duplex = 0, /* Duplex mode */ ppm = 10, /* Pages per minute for mono */ ppm_color = 0, /* Pages per minute for color */ pin = 0; /* PIN printing mode? */ char directory[1024] = "", /* Spool directory */ hostname[1024]; /* Auto-detected hostname */ _ipp_printer_t *printer; /* Printer object */ /* * Parse command-line arguments... */ for (i = 1; i < argc; i ++) if (argv[i][0] == '-') { for (opt = argv[i] + 1; *opt; opt ++) { switch (*opt) { case '2' : /* -2 (enable 2-sided printing) */ duplex = 1; break; #ifdef HAVE_SSL case 'K' : /* -K keypath */ i ++; if (i >= argc) usage(1); keypath = argv[i]; break; #endif /* HAVE_SSL */ case 'M' : /* -M manufacturer */ i ++; if (i >= argc) usage(1); make = argv[i]; break; case 'P' : /* -P (PIN printing mode) */ pin = 1; break; case 'c' : /* -c command */ i ++; if (i >= argc) usage(1); command = argv[i]; break; case 'd' : /* -d spool-directory */ i ++; if (i >= argc) usage(1); strlcpy(directory, argv[i], sizeof(directory)); break; case 'f' : /* -f type/subtype[,...] */ i ++; if (i >= argc) usage(1); formats = argv[i]; break; case 'h' : /* -h (show help) */ usage(0); case 'i' : /* -i icon.png */ i ++; if (i >= argc) usage(1); icon = argv[i]; break; case 'k' : /* -k (keep files) */ KeepFiles = 1; break; case 'l' : /* -l location */ i ++; if (i >= argc) usage(1); location = argv[i]; break; case 'm' : /* -m model */ i ++; if (i >= argc) usage(1); model = argv[i]; break; case 'n' : /* -n hostname */ i ++; if (i >= argc) usage(1); servername = argv[i]; break; case 'p' : /* -p port */ i ++; if (i >= argc || !isdigit(argv[i][0] & 255)) usage(1); port = atoi(argv[i]); break; #ifdef HAVE_DNSSD case 'r' : /* -r subtype */ i ++; if (i >= argc) usage(1); subtype = argv[i]; break; #endif /* HAVE_DNSSD */ case 's' : /* -s speed[,color-speed] */ i ++; if (i >= argc) usage(1); if (sscanf(argv[i], "%d,%d", &ppm, &ppm_color) < 1) usage(1); break; case 'v' : /* -v (be verbose) */ Verbosity ++; break; default : /* Unknown */ fprintf(stderr, "Unknown option \"-%c\".\n", *opt); usage(1); } } } else if (!name) { name = argv[i]; } else { fprintf(stderr, "Unexpected command-line argument \"%s\"\n", argv[i]); usage(1); } if (!name) usage(1); /* * Apply defaults as needed... */ if (!servername) servername = httpGetHostname(NULL, hostname, sizeof(hostname)); if (!port) { #ifdef WIN32 /* * Windows is almost always used as a single user system, so use a default port * number of 8631. */ port = 8631; #else /* * Use 8000 + UID mod 1000 for the default port number... */ port = 8000 + ((int)getuid() % 1000); #endif /* WIN32 */ fprintf(stderr, "Listening on port %d.\n", port); } if (!directory[0]) { snprintf(directory, sizeof(directory), "/tmp/ippserver.%d", (int)getpid()); if (mkdir(directory, 0777) && errno != EEXIST) { fprintf(stderr, "Unable to create spool directory \"%s\": %s\n", directory, strerror(errno)); usage(1); } if (Verbosity) fprintf(stderr, "Using spool directory \"%s\".\n", directory); } #ifdef HAVE_SSL cupsSetServerCredentials(keypath, servername, 1); #endif /* HAVE_SSL */ /* * Create the printer... */ if ((printer = create_printer(servername, name, location, make, model, icon, formats, ppm, ppm_color, duplex, port, pin, #ifdef HAVE_DNSSD subtype, #endif /* HAVE_DNSSD */ directory, command)) == NULL) return (1); /* * Run the print service... */ run_printer(printer); /* * Destroy the printer and exit... */ delete_printer(printer); return (0); } /* * 'clean_jobs()' - Clean out old (completed) jobs. */ static void clean_jobs(_ipp_printer_t *printer) /* I - Printer */ { _ipp_job_t *job; /* Current job */ time_t cleantime; /* Clean time */ if (cupsArrayCount(printer->jobs) == 0) return; cleantime = time(NULL) - 60; _cupsRWLockWrite(&(printer->rwlock)); for (job = (_ipp_job_t *)cupsArrayFirst(printer->jobs); job; job = (_ipp_job_t *)cupsArrayNext(printer->jobs)) if (job->completed && job->completed < cleantime) { cupsArrayRemove(printer->jobs, job); delete_job(job); } else break; _cupsRWUnlock(&(printer->rwlock)); } /* * 'compare_jobs()' - Compare two jobs. */ static int /* O - Result of comparison */ compare_jobs(_ipp_job_t *a, /* I - First job */ _ipp_job_t *b) /* I - Second job */ { return (b->id - a->id); } /* * 'copy_attributes()' - Copy attributes from one request to another. */ static void copy_attributes(ipp_t *to, /* I - Destination request */ ipp_t *from, /* I - Source request */ cups_array_t *ra, /* I - Requested attributes */ ipp_tag_t group_tag, /* I - Group to copy */ int quickcopy) /* I - Do a quick copy? */ { _ipp_filter_t filter; /* Filter data */ filter.ra = ra; filter.group_tag = group_tag; ippCopyAttributes(to, from, quickcopy, (ipp_copycb_t)filter_cb, &filter); } /* * 'copy_job_attrs()' - Copy job attributes to the response. */ static void copy_job_attributes( _ipp_client_t *client, /* I - Client */ _ipp_job_t *job, /* I - Job */ cups_array_t *ra) /* I - requested-attributes */ { copy_attributes(client->response, job->attrs, ra, IPP_TAG_JOB, 0); if (!ra || cupsArrayFind(ra, "date-time-at-completed")) { if (job->completed) ippAddDate(client->response, IPP_TAG_JOB, "date-time-at-completed", ippTimeToDate(job->completed)); else ippAddOutOfBand(client->response, IPP_TAG_JOB, IPP_TAG_NOVALUE, "date-time-at-completed"); } if (!ra || cupsArrayFind(ra, "date-time-at-processing")) { if (job->processing) ippAddDate(client->response, IPP_TAG_JOB, "date-time-at-processing", ippTimeToDate(job->processing)); else ippAddOutOfBand(client->response, IPP_TAG_JOB, IPP_TAG_NOVALUE, "date-time-at-processing"); } if (!ra || cupsArrayFind(ra, "job-impressions")) ippAddInteger(client->response, IPP_TAG_JOB, IPP_TAG_INTEGER, "job-impressions", job->impressions); if (!ra || cupsArrayFind(ra, "job-impressions-completed")) ippAddInteger(client->response, IPP_TAG_JOB, IPP_TAG_INTEGER, "job-impressions-completed", job->impcompleted); if (!ra || cupsArrayFind(ra, "job-printer-up-time")) ippAddInteger(client->response, IPP_TAG_JOB, IPP_TAG_INTEGER, "job-printer-up-time", (int)(time(NULL) - client->printer->start_time)); if (!ra || cupsArrayFind(ra, "job-state")) ippAddInteger(client->response, IPP_TAG_JOB, IPP_TAG_ENUM, "job-state", job->state); if (!ra || cupsArrayFind(ra, "job-state-message")) { switch (job->state) { case IPP_JSTATE_PENDING : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job pending."); break; case IPP_JSTATE_HELD : if (job->fd >= 0) ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job incoming."); else if (ippFindAttribute(job->attrs, "job-hold-until", IPP_TAG_ZERO)) ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job held."); else ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job created."); break; case IPP_JSTATE_PROCESSING : if (job->cancel) ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job canceling."); else ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job printing."); break; case IPP_JSTATE_STOPPED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job stopped."); break; case IPP_JSTATE_CANCELED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job canceled."); break; case IPP_JSTATE_ABORTED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job aborted."); break; case IPP_JSTATE_COMPLETED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_TEXT), "job-state-message", NULL, "Job completed."); break; } } if (!ra || cupsArrayFind(ra, "job-state-reasons")) { switch (job->state) { case IPP_JSTATE_PENDING : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "none"); break; case IPP_JSTATE_HELD : if (job->fd >= 0) ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-incoming"); else if (ippFindAttribute(job->attrs, "job-hold-until", IPP_TAG_ZERO)) ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-hold-until-specified"); else ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-data-insufficient"); break; case IPP_JSTATE_PROCESSING : if (job->cancel) ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "processing-to-stop-point"); else ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-printing"); break; case IPP_JSTATE_STOPPED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-stopped"); break; case IPP_JSTATE_CANCELED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-canceled-by-user"); break; case IPP_JSTATE_ABORTED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "aborted-by-system"); break; case IPP_JSTATE_COMPLETED : ippAddString(client->response, IPP_TAG_JOB, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-state-reasons", NULL, "job-completed-successfully"); break; } } if (!ra || cupsArrayFind(ra, "time-at-completed")) ippAddInteger(client->response, IPP_TAG_JOB, job->completed ? IPP_TAG_INTEGER : IPP_TAG_NOVALUE, "time-at-completed", (int)(job->completed - client->printer->start_time)); if (!ra || cupsArrayFind(ra, "time-at-processing")) ippAddInteger(client->response, IPP_TAG_JOB, job->processing ? IPP_TAG_INTEGER : IPP_TAG_NOVALUE, "time-at-processing", (int)(job->processing - client->printer->start_time)); } /* * 'create_client()' - Accept a new network connection and create a client * object. */ static _ipp_client_t * /* O - Client */ create_client(_ipp_printer_t *printer, /* I - Printer */ int sock) /* I - Listen socket */ { _ipp_client_t *client; /* Client */ if ((client = calloc(1, sizeof(_ipp_client_t))) == NULL) { perror("Unable to allocate memory for client"); return (NULL); } client->printer = printer; /* * Accept the client and get the remote address... */ if ((client->http = httpAcceptConnection(sock, 1)) == NULL) { perror("Unable to accept client connection"); free(client); return (NULL); } httpGetHostname(client->http, client->hostname, sizeof(client->hostname)); if (Verbosity) fprintf(stderr, "Accepted connection from %s\n", client->hostname); return (client); } /* * 'create_job()' - Create a new job object from a Print-Job or Create-Job * request. */ static _ipp_job_t * /* O - Job */ create_job(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* Job */ ipp_attribute_t *attr; /* Job attribute */ char uri[1024], /* job-uri value */ uuid[64]; /* job-uuid value */ _cupsRWLockWrite(&(client->printer->rwlock)); if (client->printer->active_job && client->printer->active_job->state < IPP_JSTATE_CANCELED) { /* * Only accept a single job at a time... */ _cupsRWLockWrite(&(client->printer->rwlock)); return (NULL); } /* * Allocate and initialize the job object... */ if ((job = calloc(1, sizeof(_ipp_job_t))) == NULL) { perror("Unable to allocate memory for job"); return (NULL); } job->printer = client->printer; job->attrs = ippNew(); job->state = IPP_JSTATE_HELD; job->fd = -1; /* * Copy all of the job attributes... */ copy_attributes(job->attrs, client->request, NULL, IPP_TAG_JOB, 0); /* * Get the requesting-user-name, document format, and priority... */ if ((attr = ippFindAttribute(client->request, "requesting-user-name", IPP_TAG_NAME)) != NULL) job->username = ippGetString(attr, 0, NULL); else job->username = "anonymous"; ippAddString(job->attrs, IPP_TAG_JOB, IPP_TAG_NAME, "job-originating-user-name", NULL, job->username); if (ippGetOperation(client->request) != IPP_OP_CREATE_JOB) { if ((attr = ippFindAttribute(job->attrs, "document-format-detected", IPP_TAG_MIMETYPE)) != NULL) job->format = ippGetString(attr, 0, NULL); else if ((attr = ippFindAttribute(job->attrs, "document-format-supplied", IPP_TAG_MIMETYPE)) != NULL) job->format = ippGetString(attr, 0, NULL); else job->format = "application/octet-stream"; } if ((attr = ippFindAttribute(client->request, "job-impressions", IPP_TAG_INTEGER)) != NULL) job->impressions = ippGetInteger(attr, 0); if ((attr = ippFindAttribute(client->request, "job-name", IPP_TAG_NAME)) != NULL) job->name = ippGetString(attr, 0, NULL); /* * Add job description attributes and add to the jobs array... */ job->id = client->printer->next_job_id ++; snprintf(uri, sizeof(uri), "%s/%d", client->printer->uri, job->id); httpAssembleUUID(client->printer->hostname, client->printer->port, client->printer->name, job->id, uuid, sizeof(uuid)); ippAddDate(job->attrs, IPP_TAG_JOB, "date-time-at-creation", ippTimeToDate(time(&job->created))); ippAddInteger(job->attrs, IPP_TAG_JOB, IPP_TAG_INTEGER, "job-id", job->id); ippAddString(job->attrs, IPP_TAG_JOB, IPP_TAG_URI, "job-uri", NULL, uri); ippAddString(job->attrs, IPP_TAG_JOB, IPP_TAG_URI, "job-uuid", NULL, uuid); ippAddString(job->attrs, IPP_TAG_JOB, IPP_TAG_URI, "job-printer-uri", NULL, client->printer->uri); ippAddInteger(job->attrs, IPP_TAG_JOB, IPP_TAG_INTEGER, "time-at-creation", (int)(job->created - client->printer->start_time)); cupsArrayAdd(client->printer->jobs, job); client->printer->active_job = job; _cupsRWUnlock(&(client->printer->rwlock)); return (job); } /* * 'create_job_filename()' - Create the filename for a document in a job. */ static void create_job_filename( _ipp_printer_t *printer, /* I - Printer */ _ipp_job_t *job, /* I - Job */ char *fname, /* I - Filename buffer */ size_t fnamesize) /* I - Size of filename buffer */ { char name[256], /* "Safe" filename */ *nameptr; /* Pointer into filename */ const char *ext, /* Filename extension */ *job_name; /* job-name value */ ipp_attribute_t *job_name_attr; /* job-name attribute */ /* * Make a name from the job-name attribute... */ if ((job_name_attr = ippFindAttribute(job->attrs, "job-name", IPP_TAG_NAME)) != NULL) job_name = ippGetString(job_name_attr, 0, NULL); else job_name = "untitled"; for (nameptr = name; *job_name && nameptr < (name + sizeof(name) - 1); job_name ++) if (isalnum(*job_name & 255) || *job_name == '-') *nameptr++ = (char)tolower(*job_name & 255); else *nameptr++ = '_'; *nameptr = '\0'; /* * Figure out the extension... */ if (!strcasecmp(job->format, "image/jpeg")) ext = "jpg"; else if (!strcasecmp(job->format, "image/png")) ext = "png"; else if (!strcasecmp(job->format, "image/pwg-raster")) ext = "ras"; else if (!strcasecmp(job->format, "image/urf")) ext = "urf"; else if (!strcasecmp(job->format, "application/pdf")) ext = "pdf"; else if (!strcasecmp(job->format, "application/postscript")) ext = "ps"; else ext = "prn"; /* * Create a filename with the job-id, job-name, and document-format (extension)... */ snprintf(fname, fnamesize, "%s/%d-%s.%s", printer->directory, job->id, name, ext); } /* * 'create_listener()' - Create a listener socket. */ static int /* O - Listener socket or -1 on error */ create_listener(int family, /* I - Address family */ int port) /* I - Port number */ { int sock; /* Listener socket */ http_addrlist_t *addrlist; /* Listen address */ char service[255]; /* Service port */ snprintf(service, sizeof(service), "%d", port); if ((addrlist = httpAddrGetList(NULL, family, service)) == NULL) return (-1); sock = httpAddrListen(&(addrlist->addr), port); httpAddrFreeList(addrlist); return (sock); } /* * 'create_media_col()' - Create a media-col value. */ static ipp_t * /* O - media-col collection */ create_media_col(const char *media, /* I - Media name */ const char *source, /* I - Media source */ const char *type, /* I - Media type */ int width, /* I - x-dimension in 2540ths */ int length, /* I - y-dimension in 2540ths */ int margins) /* I - Value for margins */ { ipp_t *media_col = ippNew(), /* media-col value */ *media_size = create_media_size(width, length); /* media-size value */ char media_key[256]; /* media-key value */ if (type && source) snprintf(media_key, sizeof(media_key), "%s_%s_%s%s", media, source, type, margins == 0 ? "_borderless" : ""); else if (type) snprintf(media_key, sizeof(media_key), "%s__%s%s", media, type, margins == 0 ? "_borderless" : ""); else if (source) snprintf(media_key, sizeof(media_key), "%s_%s%s", media, source, margins == 0 ? "_borderless" : ""); else snprintf(media_key, sizeof(media_key), "%s%s", media, margins == 0 ? "_borderless" : ""); ippAddString(media_col, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "media-key", NULL, media_key); ippAddCollection(media_col, IPP_TAG_PRINTER, "media-size", media_size); ippAddString(media_col, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "media-size-name", NULL, media); ippAddInteger(media_col, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-bottom-margin", margins); ippAddInteger(media_col, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-left-margin", margins); ippAddInteger(media_col, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-right-margin", margins); ippAddInteger(media_col, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-top-margin", margins); if (source) ippAddString(media_col, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "media-source", NULL, source); if (type) ippAddString(media_col, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "media-type", NULL, type); ippDelete(media_size); return (media_col); } /* * 'create_media_size()' - Create a media-size value. */ static ipp_t * /* O - media-col collection */ create_media_size(int width, /* I - x-dimension in 2540ths */ int length) /* I - y-dimension in 2540ths */ { ipp_t *media_size = ippNew(); /* media-size value */ ippAddInteger(media_size, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "x-dimension", width); ippAddInteger(media_size, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "y-dimension", length); return (media_size); } /* * 'create_printer()' - Create, register, and listen for connections to a * printer object. */ static _ipp_printer_t * /* O - Printer */ create_printer(const char *servername, /* I - Server hostname (NULL for default) */ const char *name, /* I - printer-name */ const char *location, /* I - printer-location */ const char *make, /* I - printer-make-and-model */ const char *model, /* I - printer-make-and-model */ const char *icon, /* I - printer-icons */ const char *docformats, /* I - document-format-supported */ int ppm, /* I - Pages per minute in grayscale */ int ppm_color, /* I - Pages per minute in color (0 for gray) */ int duplex, /* I - 1 = duplex, 0 = simplex */ int port, /* I - Port for listeners or 0 for auto */ int pin, /* I - Require PIN printing */ #ifdef HAVE_DNSSD const char *subtype, /* I - Bonjour service subtype */ #endif /* HAVE_DNSSD */ const char *directory, /* I - Spool directory */ const char *command) /* I - Command to run on job files */ { int i, j; /* Looping vars */ _ipp_printer_t *printer; /* Printer */ #ifndef WIN32 char path[1024]; /* Full path to command */ #endif /* !WIN32 */ char uri[1024], /* Printer URI */ icons[1024], /* printer-icons URI */ adminurl[1024], /* printer-more-info URI */ supplyurl[1024],/* printer-supply-info-uri URI */ device_id[1024],/* printer-device-id */ make_model[128],/* printer-make-and-model */ uuid[128]; /* printer-uuid */ int num_formats; /* Number of document-format-supported values */ char *defformat, /* document-format-default value */ *formats[100], /* document-format-supported values */ *ptr; /* Pointer into string */ const char *prefix; /* Prefix string */ int num_database; /* Number of database values */ ipp_attribute_t *media_col_database, /* media-col-database value */ *media_size_supported; /* media-size-supported value */ ipp_t *media_col_default; /* media-col-default value */ int media_col_index;/* Current media-col-database value */ int k_supported; /* Maximum file size supported */ #ifdef HAVE_STATVFS struct statvfs spoolinfo; /* FS info for spool directory */ double spoolsize; /* FS size */ #elif defined(HAVE_STATFS) struct statfs spoolinfo; /* FS info for spool directory */ double spoolsize; /* FS size */ #endif /* HAVE_STATVFS */ static const int orients[4] = /* orientation-requested-supported values */ { IPP_ORIENT_PORTRAIT, IPP_ORIENT_LANDSCAPE, IPP_ORIENT_REVERSE_LANDSCAPE, IPP_ORIENT_REVERSE_PORTRAIT }; static const char * const versions[] =/* ipp-versions-supported values */ { "1.0", "1.1", "2.0" }; static const char * const features[] =/* ipp-features-supported values */ { "ipp-everywhere" }; static const int ops[] = /* operations-supported values */ { IPP_OP_PRINT_JOB, IPP_OP_PRINT_URI, IPP_OP_VALIDATE_JOB, IPP_OP_CREATE_JOB, IPP_OP_SEND_DOCUMENT, IPP_OP_SEND_URI, IPP_OP_CANCEL_JOB, IPP_OP_GET_JOB_ATTRIBUTES, IPP_OP_GET_JOBS, IPP_OP_GET_PRINTER_ATTRIBUTES, IPP_OP_CANCEL_MY_JOBS, IPP_OP_CLOSE_JOB, IPP_OP_IDENTIFY_PRINTER }; static const char * const charsets[] =/* charset-supported values */ { "us-ascii", "utf-8" }; static const char * const compressions[] =/* compression-supported values */ { #ifdef HAVE_LIBZ "deflate", "gzip", #endif /* HAVE_LIBZ */ "none" }; static const char * const identify_actions[] = { "display", "sound" }; static const char * const job_creation[] = { /* job-creation-attributes-supported values */ "copies", "ipp-attribute-fidelity", "job-account-id", "job-accounting-user-id", "job-name", "job-password", "job-priority", "media", "media-col", "multiple-document-handling", "orientation-requested", "print-quality", "sides" }; static const char * const media_col_supported[] = { /* media-col-supported values */ "media-bottom-margin", "media-left-margin", "media-right-margin", "media-size", "media-source", "media-top-margin", "media-type" }; static const int media_xxx_margin_supported[] = { /* media-xxx-margin-supported values */ 0, 635 }; static const char * const multiple_document_handling[] = { /* multiple-document-handling-supported values */ "separate-documents-uncollated-copies", "separate-documents-collated-copies" }; static const char * const overrides[] = { /* overrides-supported */ "document-number", "pages" }; static const char * const print_color_mode_supported[] = { /* print-color-mode-supported values */ "auto", "color", "monochrome" }; static const int print_quality_supported[] = { /* print-quality-supported values */ IPP_QUALITY_DRAFT, IPP_QUALITY_NORMAL, IPP_QUALITY_HIGH }; static const int pwg_raster_document_resolution_supported[] = { 150, 300, 600 }; static const char * const pwg_raster_document_type_supported[] = { "black-1", "cmyk-8", "sgray-8", "srgb-8", "srgb-16" }; static const char * const reference_uri_schemes_supported[] = { /* reference-uri-schemes-supported */ "file", "ftp", "http" #ifdef HAVE_SSL , "https" #endif /* HAVE_SSL */ }; static const char * const sides_supported[] = { /* sides-supported values */ "one-sided", "two-sided-long-edge", "two-sided-short-edge" }; static const char * const urf_supported[] = { /* urf-supported values */ "CP1", "IS1-5-7", "MT1-2-3-4-5-6-8-9-10-11-12-13", "RS600", "SRGB24", "V1.4", "W8", "DM1" }; static const char * const which_jobs[] = { /* which-jobs-supported values */ "completed", "not-completed", "aborted", "all", "canceled", "pending", "pending-held", "processing", "processing-stopped" }; #ifndef WIN32 /* * If a command was specified, make sure it exists and is executable... */ if (command) { if (*command == '/' || !strncmp(command, "./", 2)) { if (access(command, X_OK)) { fprintf(stderr, "ippserver: Unable to execute command \"%s\": %s\n", command, strerror(errno)); return (NULL); } } else { if (!cupsFileFind(command, getenv("PATH"), 1, path, sizeof(path))) { fprintf(stderr, "ippserver: Unable to find command \"%s\".\n", command); return (NULL); } command = path; } } #endif /* !WIN32 */ /* * Allocate memory for the printer... */ if ((printer = calloc(1, sizeof(_ipp_printer_t))) == NULL) { perror("ippserver: Unable to allocate memory for printer"); return (NULL); } printer->ipv4 = -1; printer->ipv6 = -1; printer->name = strdup(name); #ifdef HAVE_DNSSD printer->dnssd_name = strdup(printer->name); #endif /* HAVE_DNSSD */ printer->command = command ? strdup(command) : NULL; printer->directory = strdup(directory); printer->hostname = strdup(servername); printer->port = port; printer->start_time = time(NULL); printer->config_time = printer->start_time; printer->state = IPP_PSTATE_IDLE; printer->state_reasons = _IPP_PREASON_NONE; printer->state_time = printer->start_time; printer->jobs = cupsArrayNew((cups_array_func_t)compare_jobs, NULL); printer->next_job_id = 1; httpAssembleURI(HTTP_URI_CODING_ALL, uri, sizeof(uri), "ipp", NULL, printer->hostname, printer->port, "/ipp/print"); printer->uri = strdup(uri); printer->urilen = strlen(uri); if (icon) printer->icon = strdup(icon); printer->main_size = _IPP_MEDIA_SIZE_A4; printer->main_type = _IPP_MEDIA_TYPE_STATIONERY; printer->main_level = 500; printer->envelope_size = _IPP_MEDIA_SIZE_NONE; printer->envelope_level = 0; printer->photo_size = _IPP_MEDIA_SIZE_NONE; printer->photo_type = _IPP_MEDIA_TYPE_NONE; printer->photo_level = 0; printer->supplies[_IPP_SUPPLY_CYAN] = 100; printer->supplies[_IPP_SUPPLY_MAGENTA] = 100; printer->supplies[_IPP_SUPPLY_YELLOW] = 100; printer->supplies[_IPP_SUPPLY_BLACK] = 100; printer->supplies[_IPP_SUPPLY_WASTE] = 0; _cupsRWInit(&(printer->rwlock)); /* * Create the listener sockets... */ if ((printer->ipv4 = create_listener(AF_INET, printer->port)) < 0) { perror("Unable to create IPv4 listener"); goto bad_printer; } if ((printer->ipv6 = create_listener(AF_INET6, printer->port)) < 0) { perror("Unable to create IPv6 listener"); goto bad_printer; } /* * Prepare values for the printer attributes... */ httpAssembleURI(HTTP_URI_CODING_ALL, icons, sizeof(icons), "http", NULL, printer->hostname, printer->port, "/icon.png"); httpAssembleURI(HTTP_URI_CODING_ALL, adminurl, sizeof(adminurl), "http", NULL, printer->hostname, printer->port, "/"); httpAssembleURI(HTTP_URI_CODING_ALL, supplyurl, sizeof(supplyurl), "http", NULL, printer->hostname, printer->port, "/supplies"); if (Verbosity) { fprintf(stderr, "printer-more-info=\"%s\"\n", adminurl); fprintf(stderr, "printer-supply-info-uri=\"%s\"\n", supplyurl); fprintf(stderr, "printer-uri=\"%s\"\n", uri); } snprintf(make_model, sizeof(make_model), "%s %s", make, model); num_formats = 1; formats[0] = strdup(docformats); defformat = formats[0]; for (ptr = strchr(formats[0], ','); ptr; ptr = strchr(ptr, ',')) { *ptr++ = '\0'; formats[num_formats++] = ptr; if (!strcasecmp(ptr, "application/octet-stream")) defformat = ptr; } snprintf(device_id, sizeof(device_id), "MFG:%s;MDL:%s;", make, model); ptr = device_id + strlen(device_id); prefix = "CMD:"; for (i = 0; i < num_formats; i ++) { if (!strcasecmp(formats[i], "application/pdf")) snprintf(ptr, sizeof(device_id) - (size_t)(ptr - device_id), "%sPDF", prefix); else if (!strcasecmp(formats[i], "application/postscript")) snprintf(ptr, sizeof(device_id) - (size_t)(ptr - device_id), "%sPS", prefix); else if (!strcasecmp(formats[i], "application/vnd.hp-PCL")) snprintf(ptr, sizeof(device_id) - (size_t)(ptr - device_id), "%sPCL", prefix); else if (!strcasecmp(formats[i], "image/jpeg")) snprintf(ptr, sizeof(device_id) - (size_t)(ptr - device_id), "%sJPEG", prefix); else if (!strcasecmp(formats[i], "image/png")) snprintf(ptr, sizeof(device_id) - (size_t)(ptr - device_id), "%sPNG", prefix); else if (strcasecmp(formats[i], "application/octet-stream")) snprintf(ptr, sizeof(device_id) - (size_t)(ptr - device_id), "%s%s", prefix, formats[i]); ptr += strlen(ptr); prefix = ","; } if (ptr < (device_id + sizeof(device_id) - 1)) { *ptr++ = ';'; *ptr = '\0'; } /* * Get the maximum spool size based on the size of the filesystem used for * the spool directory. If the host OS doesn't support the statfs call * or the filesystem is larger than 2TiB, always report INT_MAX. */ #ifdef HAVE_STATVFS if (statvfs(printer->directory, &spoolinfo)) k_supported = INT_MAX; else if ((spoolsize = (double)spoolinfo.f_frsize * spoolinfo.f_blocks / 1024) > INT_MAX) k_supported = INT_MAX; else k_supported = (int)spoolsize; #elif defined(HAVE_STATFS) if (statfs(printer->directory, &spoolinfo)) k_supported = INT_MAX; else if ((spoolsize = (double)spoolinfo.f_bsize * spoolinfo.f_blocks / 1024) > INT_MAX) k_supported = INT_MAX; else k_supported = (int)spoolsize; #else k_supported = INT_MAX; #endif /* HAVE_STATVFS */ /* * Create the printer attributes. This list of attributes is sorted to improve * performance when the client provides a requested-attributes attribute... */ printer->attrs = ippNew(); /* charset-configured */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_CHARSET), "charset-configured", NULL, "utf-8"); /* charset-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_CHARSET), "charset-supported", sizeof(charsets) / sizeof(charsets[0]), NULL, charsets); /* color-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "color-supported", ppm_color > 0); /* compression-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "compression-supported", (int)(sizeof(compressions) / sizeof(compressions[0])), NULL, compressions); /* copies-default */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "copies-default", 1); /* copies-supported */ ippAddRange(printer->attrs, IPP_TAG_PRINTER, "copies-supported", 1, 999); /* document-format-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_MIMETYPE, "document-format-default", NULL, defformat); /* document-format-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_MIMETYPE, "document-format-supported", num_formats, NULL, (const char * const *)formats); /* document-password-supported */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "document-password-supported", 127); /* finishings-default */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_ENUM, "finishings-default", IPP_FINISHINGS_NONE); /* finishings-supported */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_ENUM, "finishings-supported", IPP_FINISHINGS_NONE); /* generated-natural-language-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_LANGUAGE), "generated-natural-language-supported", NULL, "en"); /* identify-actions-default */ ippAddString (printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "identify-actions-default", NULL, "sound"); /* identify-actions-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "identify-actions-supported", sizeof(identify_actions) / sizeof(identify_actions[0]), NULL, identify_actions); /* ipp-features-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "ipp-features-supported", sizeof(features) / sizeof(features[0]), NULL, features); /* ipp-versions-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "ipp-versions-supported", sizeof(versions) / sizeof(versions[0]), NULL, versions); /* job-account-id-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_NAME), "job-account-id-default", NULL, ""); /* job-account-id-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "job-account-id-supported", 1); /* job-accounting-user-id-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_NAME), "job-accounting-user-id-default", NULL, ""); /* job-accounting-user-id-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "job-accounting-user-id-supported", 1); /* job-creation-attributes-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "job-creation-attributes-supported", sizeof(job_creation) / sizeof(job_creation[0]), NULL, job_creation); /* job-ids-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "job-ids-supported", 1); /* job-k-octets-supported */ ippAddRange(printer->attrs, IPP_TAG_PRINTER, "job-k-octets-supported", 0, k_supported); /* job-password-supported */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "job-password-supported", 4); /* job-preferred-attributes-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "job-preferred-attributes-supported", 0); /* job-priority-default */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "job-priority-default", 50); /* job-priority-supported */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "job-priority-supported", 100); /* job-sheets-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_NAME), "job-sheets-default", NULL, "none"); /* job-sheets-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_NAME), "job-sheets-supported", NULL, "none"); /* media-bottom-margin-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-bottom-margin-supported", (int)(sizeof(media_xxx_margin_supported) / sizeof(media_xxx_margin_supported[0])), media_xxx_margin_supported); /* media-col-database */ for (num_database = 0, i = 0; i < (int)(sizeof(media_col_sizes) / sizeof(media_col_sizes[0])); i ++) { if (media_col_sizes[i][2] == _IPP_ENV_ONLY) num_database += 3; /* auto + manual + envelope */ else if (media_col_sizes[i][2] == _IPP_PHOTO_ONLY) num_database += 6 * 3; /* auto + photographic-* from auto, manual, and photo */ else num_database += 2; /* Regular + borderless */ } media_col_database = ippAddCollections(printer->attrs, IPP_TAG_PRINTER, "media-col-database", num_database, NULL); for (media_col_index = 0, i = 0; i < (int)(sizeof(media_col_sizes) / sizeof(media_col_sizes[0])); i ++) { switch (media_col_sizes[i][2]) { case _IPP_GENERAL : /* * Regular + borderless for the general class; no source/type * selectors... */ ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], NULL, NULL, media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[1])); ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], NULL, NULL, media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[0])); break; case _IPP_ENV_ONLY : /* * Regular margins for "auto", "manual", and "envelope" sources. */ ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], "auto", "envelope", media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[1])); ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], "manual", "envelope", media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[1])); ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], "envelope", "envelope", media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[1])); break; case _IPP_PHOTO_ONLY : /* * Photos have specific media types and can only be printed via * the auto, manual, and photo sources... */ for (j = 0; j < (int)(sizeof(media_type_supported) / sizeof(media_type_supported[0])); j ++) { if (strcmp(media_type_supported[j], "auto") && strncmp(media_type_supported[j], "photographic-", 13)) continue; ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], "auto", media_type_supported[j], media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[0])); ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], "manual", media_type_supported[j], media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[0])); ippSetCollection(printer->attrs, &media_col_database, media_col_index ++, create_media_col(media_supported[i], "photo", media_type_supported[j], media_col_sizes[i][0], media_col_sizes[i][1], media_xxx_margin_supported[0])); } break; } } /* media-col-default */ media_col_default = create_media_col(media_supported[0], media_source_supported[0], media_type_supported[0], media_col_sizes[0][0], media_col_sizes[0][1], media_xxx_margin_supported[1]); ippAddCollection(printer->attrs, IPP_TAG_PRINTER, "media-col-default", media_col_default); ippDelete(media_col_default); /* media-col-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "media-col-supported", (int)(sizeof(media_col_supported) / sizeof(media_col_supported[0])), NULL, media_col_supported); /* media-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "media-default", NULL, media_supported[0]); /* media-left-margin-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-left-margin-supported", (int)(sizeof(media_xxx_margin_supported) / sizeof(media_xxx_margin_supported[0])), media_xxx_margin_supported); /* media-right-margin-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-right-margin-supported", (int)(sizeof(media_xxx_margin_supported) / sizeof(media_xxx_margin_supported[0])), media_xxx_margin_supported); /* media-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "media-supported", (int)(sizeof(media_supported) / sizeof(media_supported[0])), NULL, media_supported); /* media-size-supported */ media_size_supported = ippAddCollections(printer->attrs, IPP_TAG_PRINTER, "media-size-supported", (int)(sizeof(media_col_sizes) / sizeof(media_col_sizes[0])), NULL); for (i = 0; i < (int)(sizeof(media_col_sizes) / sizeof(media_col_sizes[0])); i ++) ippSetCollection(printer->attrs, &media_size_supported, i, create_media_size(media_col_sizes[i][0], media_col_sizes[i][1])); /* media-source-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "media-source-supported", (int)(sizeof(media_source_supported) / sizeof(media_source_supported[0])), NULL, media_source_supported); /* media-top-margin-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "media-top-margin-supported", (int)(sizeof(media_xxx_margin_supported) / sizeof(media_xxx_margin_supported[0])), media_xxx_margin_supported); /* media-type-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "media-type-supported", (int)(sizeof(media_type_supported) / sizeof(media_type_supported[0])), NULL, media_type_supported); /* multiple-document-handling-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "multiple-document-handling-supported", sizeof(multiple_document_handling) / sizeof(multiple_document_handling[0]), NULL, multiple_document_handling); /* multiple-document-jobs-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "multiple-document-jobs-supported", 0); /* multiple-operation-time-out */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "multiple-operation-time-out", 60); /* multiple-operation-time-out-action */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "multiple-operation-time-out-action", NULL, "abort-job"); /* natural-language-configured */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_LANGUAGE), "natural-language-configured", NULL, "en"); /* number-up-default */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "number-up-default", 1); /* number-up-supported */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "number-up-supported", 1); /* operations-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_ENUM, "operations-supported", sizeof(ops) / sizeof(ops[0]), ops); /* orientation-requested-default */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_NOVALUE, "orientation-requested-default", 0); /* orientation-requested-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_ENUM, "orientation-requested-supported", 4, orients); /* output-bin-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "output-bin-default", NULL, "face-down"); /* output-bin-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "output-bin-supported", NULL, "face-down"); /* overrides-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "overrides-supported", (int)(sizeof(overrides) / sizeof(overrides[0])), NULL, overrides); /* page-ranges-supported */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "page-ranges-supported", 1); /* pages-per-minute */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "pages-per-minute", ppm); /* pages-per-minute-color */ if (ppm_color > 0) ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "pages-per-minute-color", ppm_color); /* pdl-override-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "pdl-override-supported", NULL, "attempted"); /* print-color-mode-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "print-color-mode-default", NULL, "auto"); /* print-color-mode-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "print-color-mode-supported", (int)(sizeof(print_color_mode_supported) / sizeof(print_color_mode_supported[0])), NULL, print_color_mode_supported); /* print-content-optimize-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "print-content-optimize-default", NULL, "auto"); /* print-content-optimize-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "print-content-optimize-supported", NULL, "auto"); /* print-rendering-intent-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "print-rendering-intent-default", NULL, "auto"); /* print-rendering-intent-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "print-rendering-intent-supported", NULL, "auto"); /* print-quality-default */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_ENUM, "print-quality-default", IPP_QUALITY_NORMAL); /* print-quality-supported */ ippAddIntegers(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_ENUM, "print-quality-supported", (int)(sizeof(print_quality_supported) / sizeof(print_quality_supported[0])), print_quality_supported); /* printer-device-id */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_TEXT, "printer-device-id", NULL, device_id); /* printer-get-attributes-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "printer-get-attributes-supported", NULL, "document-format"); /* printer-geo-location */ ippAddInteger(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_UNKNOWN, "printer-geo-location", 0); /* printer-icons */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_URI, "printer-icons", NULL, icons); /* printer-is-accepting-jobs */ ippAddBoolean(printer->attrs, IPP_TAG_PRINTER, "printer-is-accepting-jobs", 1); /* printer-info */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_TEXT, "printer-info", NULL, name); /* printer-location */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_TEXT, "printer-location", NULL, location); /* printer-make-and-model */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_TEXT, "printer-make-and-model", NULL, make_model); /* printer-mandatory-job-attributes */ if (pin) { static const char * const names[] = { "job-accounting-user-id", "job-password" }; ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "printer-mandatory-job-attributes", (int)(sizeof(names) / sizeof(names[0])), NULL, names); } /* printer-more-info */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_URI, "printer-more-info", NULL, adminurl); /* printer-name */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_NAME, "printer-name", NULL, name); /* printer-organization */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_TEXT), "printer-organization", NULL, "Apple Inc."); /* printer-organizational-unit */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_TEXT), "printer-organizational-unit", NULL, "Printing Engineering"); /* printer-resolution-default */ ippAddResolution(printer->attrs, IPP_TAG_PRINTER, "printer-resolution-default", IPP_RES_PER_INCH, 600, 600); /* printer-resolution-supported */ ippAddResolution(printer->attrs, IPP_TAG_PRINTER, "printer-resolution-supported", IPP_RES_PER_INCH, 600, 600); /* printer-supply-description */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_TEXT), "printer-supply-description", (int)(sizeof(printer_supplies) / sizeof(printer_supplies[0])), NULL, printer_supplies); /* printer-supply-info-uri */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_URI, "printer-supply-info-uri", NULL, supplyurl); /* printer-uri-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_URI, "printer-uri-supported", NULL, uri); /* printer-uuid */ httpAssembleUUID(printer->hostname, port, name, 0, uuid, sizeof(uuid)); ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_URI, "printer-uuid", NULL, uuid); /* pwg-raster-document-xxx-supported */ for (i = 0; i < num_formats; i ++) if (!strcasecmp(formats[i], "image/pwg-raster")) break; if (i < num_formats) { ippAddResolutions(printer->attrs, IPP_TAG_PRINTER, "pwg-raster-document-resolution-supported", (int)(sizeof(pwg_raster_document_resolution_supported) / sizeof(pwg_raster_document_resolution_supported[0])), IPP_RES_PER_INCH, pwg_raster_document_resolution_supported, pwg_raster_document_resolution_supported); ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "pwg-raster-document-sheet-back", NULL, "normal"); ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "pwg-raster-document-type-supported", (int)(sizeof(pwg_raster_document_type_supported) / sizeof(pwg_raster_document_type_supported[0])), NULL, pwg_raster_document_type_supported); } /* reference-uri-scheme-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_URISCHEME), "reference-uri-schemes-supported", (int)(sizeof(reference_uri_schemes_supported) / sizeof(reference_uri_schemes_supported[0])), NULL, reference_uri_schemes_supported); /* sides-default */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "sides-default", NULL, "one-sided"); /* sides-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "sides-supported", duplex ? 3 : 1, NULL, sides_supported); /* urf-supported */ for (i = 0; i < num_formats; i ++) if (!strcasecmp(formats[i], "image/urf")) break; if (i < num_formats) ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_TAG_KEYWORD, "urf-supported", (int)(sizeof(urf_supported) / sizeof(urf_supported[0])) - !duplex, NULL, urf_supported); /* uri-authentication-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "uri-authentication-supported", NULL, "none"); /* uri-security-supported */ ippAddString(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "uri-security-supported", NULL, "none"); /* which-jobs-supported */ ippAddStrings(printer->attrs, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "which-jobs-supported", sizeof(which_jobs) / sizeof(which_jobs[0]), NULL, which_jobs); free(formats[0]); debug_attributes("Printer", printer->attrs, 0); #ifdef HAVE_DNSSD /* * Register the printer with Bonjour... */ if (!register_printer(printer, location, make, model, docformats, adminurl, uuid + 9, ppm_color > 0, duplex, subtype)) goto bad_printer; #endif /* HAVE_DNSSD */ /* * Return it! */ return (printer); /* * If we get here we were unable to create the printer... */ bad_printer: delete_printer(printer); return (NULL); } /* * 'debug_attributes()' - Print attributes in a request or response. */ static void debug_attributes(const char *title, /* I - Title */ ipp_t *ipp, /* I - Request/response */ int type) /* I - 0 = object, 1 = request, 2 = response */ { ipp_tag_t group_tag; /* Current group */ ipp_attribute_t *attr; /* Current attribute */ char buffer[2048]; /* String buffer for value */ int major, minor; /* Version */ if (Verbosity <= 1) return; fprintf(stderr, "%s:\n", title); major = ippGetVersion(ipp, &minor); fprintf(stderr, " version=%d.%d\n", major, minor); if (type == 1) fprintf(stderr, " operation-id=%s(%04x)\n", ippOpString(ippGetOperation(ipp)), ippGetOperation(ipp)); else if (type == 2) fprintf(stderr, " status-code=%s(%04x)\n", ippErrorString(ippGetStatusCode(ipp)), ippGetStatusCode(ipp)); fprintf(stderr, " request-id=%d\n\n", ippGetRequestId(ipp)); for (attr = ippFirstAttribute(ipp), group_tag = IPP_TAG_ZERO; attr; attr = ippNextAttribute(ipp)) { if (ippGetGroupTag(attr) != group_tag) { group_tag = ippGetGroupTag(attr); fprintf(stderr, " %s\n", ippTagString(group_tag)); } if (ippGetName(attr)) { ippAttributeString(attr, buffer, sizeof(buffer)); fprintf(stderr, " %s (%s%s) %s\n", ippGetName(attr), ippGetCount(attr) > 1 ? "1setOf " : "", ippTagString(ippGetValueTag(attr)), buffer); } } } /* * 'delete_client()' - Close the socket and free all memory used by a client * object. */ static void delete_client(_ipp_client_t *client) /* I - Client */ { if (Verbosity) fprintf(stderr, "Closing connection from %s\n", client->hostname); /* * Flush pending writes before closing... */ httpFlushWrite(client->http); /* * Free memory... */ httpClose(client->http); ippDelete(client->request); ippDelete(client->response); free(client); } /* * 'delete_job()' - Remove from the printer and free all memory used by a job * object. */ static void delete_job(_ipp_job_t *job) /* I - Job */ { if (Verbosity) fprintf(stderr, "Removing job #%d from history.\n", job->id); ippDelete(job->attrs); if (job->filename) { if (!KeepFiles) unlink(job->filename); free(job->filename); } free(job); } /* * 'delete_printer()' - Unregister, close listen sockets, and free all memory * used by a printer object. */ static void delete_printer(_ipp_printer_t *printer) /* I - Printer */ { if (printer->ipv4 >= 0) close(printer->ipv4); if (printer->ipv6 >= 0) close(printer->ipv6); #if HAVE_DNSSD if (printer->printer_ref) DNSServiceRefDeallocate(printer->printer_ref); if (printer->ipp_ref) DNSServiceRefDeallocate(printer->ipp_ref); # ifdef HAVE_SSL if (printer->ipps_ref) DNSServiceRefDeallocate(printer->ipps_ref); # endif /* HAVE_SSL */ if (printer->http_ref) DNSServiceRefDeallocate(printer->http_ref); if (printer->common_ref) DNSServiceRefDeallocate(printer->common_ref); TXTRecordDeallocate(&(printer->ipp_txt)); if (printer->dnssd_name) free(printer->dnssd_name); #endif /* HAVE_DNSSD */ if (printer->name) free(printer->name); if (printer->icon) free(printer->icon); if (printer->command) free(printer->command); if (printer->directory) free(printer->directory); if (printer->hostname) free(printer->hostname); if (printer->uri) free(printer->uri); ippDelete(printer->attrs); cupsArrayDelete(printer->jobs); free(printer); } #ifdef HAVE_DNSSD /* * 'dnssd_callback()' - Handle Bonjour registration events. */ static void dnssd_callback( DNSServiceRef sdRef, /* I - Service reference */ DNSServiceFlags flags, /* I - Status flags */ DNSServiceErrorType errorCode, /* I - Error, if any */ const char *name, /* I - Service name */ const char *regtype, /* I - Service type */ const char *domain, /* I - Domain for service */ _ipp_printer_t *printer) /* I - Printer */ { (void)sdRef; (void)flags; (void)domain; if (errorCode) { fprintf(stderr, "DNSServiceRegister for %s failed with error %d.\n", regtype, (int)errorCode); return; } else if (strcasecmp(name, printer->dnssd_name)) { if (Verbosity) fprintf(stderr, "Now using DNS-SD service name \"%s\".\n", name); /* No lock needed since only the main thread accesses/changes this */ free(printer->dnssd_name); printer->dnssd_name = strdup(name); } } #endif /* HAVE_DNSSD */ /* * 'filter_cb()' - Filter printer attributes based on the requested array. */ static int /* O - 1 to copy, 0 to ignore */ filter_cb(_ipp_filter_t *filter, /* I - Filter parameters */ ipp_t *dst, /* I - Destination (unused) */ ipp_attribute_t *attr) /* I - Source attribute */ { /* * Filter attributes as needed... */ // (void)dst; ipp_tag_t group = ippGetGroupTag(attr); const char *name = ippGetName(attr); if ((filter->group_tag != IPP_TAG_ZERO && group != filter->group_tag && group != IPP_TAG_ZERO) || !name || (!strcmp(name, "media-col-database") && !cupsArrayFind(filter->ra, (void *)name))) return (0); return (!filter->ra || cupsArrayFind(filter->ra, (void *)name) != NULL); } /* * 'find_job()' - Find a job specified in a request. */ static _ipp_job_t * /* O - Job or NULL */ find_job(_ipp_client_t *client) /* I - Client */ { ipp_attribute_t *attr; /* job-id or job-uri attribute */ _ipp_job_t key, /* Job search key */ *job; /* Matching job, if any */ if ((attr = ippFindAttribute(client->request, "job-uri", IPP_TAG_URI)) != NULL) { const char *uri = ippGetString(attr, 0, NULL); if (!strncmp(uri, client->printer->uri, client->printer->urilen) && uri[client->printer->urilen] == '/') key.id = atoi(uri + client->printer->urilen + 1); else return (NULL); } else if ((attr = ippFindAttribute(client->request, "job-id", IPP_TAG_INTEGER)) != NULL) key.id = ippGetInteger(attr, 0); _cupsRWLockRead(&(client->printer->rwlock)); job = (_ipp_job_t *)cupsArrayFind(client->printer->jobs, &key); _cupsRWUnlock(&(client->printer->rwlock)); return (job); } /* * 'html_escape()' - Write a HTML-safe string. */ static void html_escape(_ipp_client_t *client, /* I - Client */ const char *s, /* I - String to write */ size_t slen) /* I - Number of characters to write */ { const char *start, /* Start of segment */ *end; /* End of string */ start = s; end = s + (slen > 0 ? slen : strlen(s)); while (*s && s < end) { if (*s == '&' || *s == '<') { if (s > start) httpWrite2(client->http, start, (size_t)(s - start)); if (*s == '&') httpWrite2(client->http, "&", 5); else httpWrite2(client->http, "<", 4); start = s + 1; } s ++; } if (s > start) httpWrite2(client->http, start, (size_t)(s - start)); } /* * 'html_footer()' - Show the web interface footer. * * This function also writes the trailing 0-length chunk. */ static void html_footer(_ipp_client_t *client) /* I - Client */ { html_printf(client, "\n" "\n" "\n"); httpWrite2(client->http, "", 0); } /* * 'html_header()' - Show the web interface header and title. */ static void html_header(_ipp_client_t *client, /* I - Client */ const char *title) /* I - Title */ { html_printf(client, "\n" "\n" "\n" "%s\n" "\n" "\n" "\n" "\n" "\n" "\n" "\n" "" "" "" "" "
StatusSuppliesMedia
\n" "
\n", title, !strcmp(client->uri, "/") ? " sel" : "", !strcmp(client->uri, "/supplies") ? " sel" : "", !strcmp(client->uri, "/media") ? " sel" : ""); } /* * 'html_printf()' - Send formatted text to the client, quoting as needed. */ static void html_printf(_ipp_client_t *client, /* I - Client */ const char *format, /* I - Printf-style format string */ ...) /* I - Additional arguments as needed */ { va_list ap; /* Pointer to arguments */ const char *start; /* Start of string */ char size, /* Size character (h, l, L) */ type; /* Format type character */ int width, /* Width of field */ prec; /* Number of characters of precision */ char tformat[100], /* Temporary format string for sprintf() */ *tptr, /* Pointer into temporary format */ temp[1024]; /* Buffer for formatted numbers */ char *s; /* Pointer to string */ /* * Loop through the format string, formatting as needed... */ va_start(ap, format); start = format; while (*format) { if (*format == '%') { if (format > start) httpWrite2(client->http, start, (size_t)(format - start)); tptr = tformat; *tptr++ = *format++; if (*format == '%') { httpWrite2(client->http, "%", 1); format ++; start = format; continue; } else if (strchr(" -+#\'", *format)) *tptr++ = *format++; if (*format == '*') { /* * Get width from argument... */ format ++; width = va_arg(ap, int); snprintf(tptr, sizeof(tformat) - (size_t)(tptr - tformat), "%d", width); tptr += strlen(tptr); } else { width = 0; while (isdigit(*format & 255)) { if (tptr < (tformat + sizeof(tformat) - 1)) *tptr++ = *format; width = width * 10 + *format++ - '0'; } } if (*format == '.') { if (tptr < (tformat + sizeof(tformat) - 1)) *tptr++ = *format; format ++; if (*format == '*') { /* * Get precision from argument... */ format ++; prec = va_arg(ap, int); snprintf(tptr, sizeof(tformat) - (size_t)(tptr - tformat), "%d", prec); tptr += strlen(tptr); } else { prec = 0; while (isdigit(*format & 255)) { if (tptr < (tformat + sizeof(tformat) - 1)) *tptr++ = *format; prec = prec * 10 + *format++ - '0'; } } } if (*format == 'l' && format[1] == 'l') { size = 'L'; if (tptr < (tformat + sizeof(tformat) - 2)) { *tptr++ = 'l'; *tptr++ = 'l'; } format += 2; } else if (*format == 'h' || *format == 'l' || *format == 'L') { if (tptr < (tformat + sizeof(tformat) - 1)) *tptr++ = *format; size = *format++; } else size = 0; if (!*format) { start = format; break; } if (tptr < (tformat + sizeof(tformat) - 1)) *tptr++ = *format; type = *format++; *tptr = '\0'; start = format; switch (type) { case 'E' : /* Floating point formats */ case 'G' : case 'e' : case 'f' : case 'g' : if ((size_t)(width + 2) > sizeof(temp)) break; sprintf(temp, tformat, va_arg(ap, double)); httpWrite2(client->http, temp, strlen(temp)); break; case 'B' : /* Integer formats */ case 'X' : case 'b' : case 'd' : case 'i' : case 'o' : case 'u' : case 'x' : if ((size_t)(width + 2) > sizeof(temp)) break; # ifdef HAVE_LONG_LONG if (size == 'L') sprintf(temp, tformat, va_arg(ap, long long)); else # endif /* HAVE_LONG_LONG */ if (size == 'l') sprintf(temp, tformat, va_arg(ap, long)); else sprintf(temp, tformat, va_arg(ap, int)); httpWrite2(client->http, temp, strlen(temp)); break; case 'p' : /* Pointer value */ if ((size_t)(width + 2) > sizeof(temp)) break; sprintf(temp, tformat, va_arg(ap, void *)); httpWrite2(client->http, temp, strlen(temp)); break; case 'c' : /* Character or character array */ if (width <= 1) { temp[0] = (char)va_arg(ap, int); temp[1] = '\0'; html_escape(client, temp, 1); } else html_escape(client, va_arg(ap, char *), (size_t)width); break; case 's' : /* String */ if ((s = va_arg(ap, char *)) == NULL) s = "(null)"; html_escape(client, s, strlen(s)); break; } } else format ++; } if (format > start) httpWrite2(client->http, start, (size_t)(format - start)); va_end(ap); } /* * 'ipp_cancel_job()' - Cancel a job. */ static void ipp_cancel_job(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* Job information */ /* * Get the job... */ if ((job = find_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_NOT_FOUND, "Job does not exist."); return; } /* * See if the job is already completed, canceled, or aborted; if so, * we can't cancel... */ switch (job->state) { case IPP_JSTATE_CANCELED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is already canceled - can\'t cancel.", job->id); break; case IPP_JSTATE_ABORTED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is already aborted - can\'t cancel.", job->id); break; case IPP_JSTATE_COMPLETED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is already completed - can\'t cancel.", job->id); break; default : /* * Cancel the job... */ _cupsRWLockWrite(&(client->printer->rwlock)); if (job->state == IPP_JSTATE_PROCESSING || (job->state == IPP_JSTATE_HELD && job->fd >= 0)) job->cancel = 1; else { job->state = IPP_JSTATE_CANCELED; job->completed = time(NULL); } _cupsRWUnlock(&(client->printer->rwlock)); respond_ipp(client, IPP_STATUS_OK, NULL); break; } } /* * 'ipp_close_job()' - Close an open job. */ static void ipp_close_job(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* Job information */ /* * Get the job... */ if ((job = find_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_NOT_FOUND, "Job does not exist."); return; } /* * See if the job is already completed, canceled, or aborted; if so, * we can't cancel... */ switch (job->state) { case IPP_JSTATE_CANCELED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is canceled - can\'t close.", job->id); break; case IPP_JSTATE_ABORTED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is aborted - can\'t close.", job->id); break; case IPP_JSTATE_COMPLETED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is completed - can\'t close.", job->id); break; case IPP_JSTATE_PROCESSING : case IPP_JSTATE_STOPPED : respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job #%d is already closed.", job->id); break; default : respond_ipp(client, IPP_STATUS_OK, NULL); break; } } /* * 'ipp_create_job()' - Create a job object. */ static void ipp_create_job(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* New job */ cups_array_t *ra; /* Attributes to send in response */ /* * Validate print job attributes... */ if (!valid_job_attributes(client)) { httpFlush(client->http); return; } /* * Do we have a file to print? */ if (httpGetState(client->http) == HTTP_STATE_POST_RECV) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Unexpected document data following request."); return; } /* * Create the job... */ if ((job = create_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BUSY, "Currently printing another job."); return; } /* * Return the job info... */ respond_ipp(client, IPP_STATUS_OK, NULL); ra = cupsArrayNew((cups_array_func_t)strcmp, NULL); cupsArrayAdd(ra, "job-id"); cupsArrayAdd(ra, "job-state"); cupsArrayAdd(ra, "job-state-message"); cupsArrayAdd(ra, "job-state-reasons"); cupsArrayAdd(ra, "job-uri"); copy_job_attributes(client, job, ra); cupsArrayDelete(ra); } /* * 'ipp_get_job_attributes()' - Get the attributes for a job object. */ static void ipp_get_job_attributes( _ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* Job */ cups_array_t *ra; /* requested-attributes */ if ((job = find_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_NOT_FOUND, "Job not found."); return; } respond_ipp(client, IPP_STATUS_OK, NULL); ra = ippCreateRequestedArray(client->request); copy_job_attributes(client, job, ra); cupsArrayDelete(ra); } /* * 'ipp_get_jobs()' - Get a list of job objects. */ static void ipp_get_jobs(_ipp_client_t *client) /* I - Client */ { ipp_attribute_t *attr; /* Current attribute */ const char *which_jobs = NULL; /* which-jobs values */ int job_comparison; /* Job comparison */ ipp_jstate_t job_state; /* job-state value */ int first_job_id, /* First job ID */ limit, /* Maximum number of jobs to return */ count; /* Number of jobs that match */ const char *username; /* Username */ _ipp_job_t *job; /* Current job pointer */ cups_array_t *ra; /* Requested attributes array */ /* * See if the "which-jobs" attribute have been specified... */ if ((attr = ippFindAttribute(client->request, "which-jobs", IPP_TAG_KEYWORD)) != NULL) { which_jobs = ippGetString(attr, 0, NULL); fprintf(stderr, "%s Get-Jobs which-jobs=%s", client->hostname, which_jobs); } if (!which_jobs || !strcmp(which_jobs, "not-completed")) { job_comparison = -1; job_state = IPP_JSTATE_STOPPED; } else if (!strcmp(which_jobs, "completed")) { job_comparison = 1; job_state = IPP_JSTATE_CANCELED; } else if (!strcmp(which_jobs, "aborted")) { job_comparison = 0; job_state = IPP_JSTATE_ABORTED; } else if (!strcmp(which_jobs, "all")) { job_comparison = 1; job_state = IPP_JSTATE_PENDING; } else if (!strcmp(which_jobs, "canceled")) { job_comparison = 0; job_state = IPP_JSTATE_CANCELED; } else if (!strcmp(which_jobs, "pending")) { job_comparison = 0; job_state = IPP_JSTATE_PENDING; } else if (!strcmp(which_jobs, "pending-held")) { job_comparison = 0; job_state = IPP_JSTATE_HELD; } else if (!strcmp(which_jobs, "processing")) { job_comparison = 0; job_state = IPP_JSTATE_PROCESSING; } else if (!strcmp(which_jobs, "processing-stopped")) { job_comparison = 0; job_state = IPP_JSTATE_STOPPED; } else { respond_ipp(client, IPP_STATUS_ERROR_ATTRIBUTES_OR_VALUES, "The which-jobs value \"%s\" is not supported.", which_jobs); ippAddString(client->response, IPP_TAG_UNSUPPORTED_GROUP, IPP_TAG_KEYWORD, "which-jobs", NULL, which_jobs); return; } /* * See if they want to limit the number of jobs reported... */ if ((attr = ippFindAttribute(client->request, "limit", IPP_TAG_INTEGER)) != NULL) { limit = ippGetInteger(attr, 0); fprintf(stderr, "%s Get-Jobs limit=%d", client->hostname, limit); } else limit = 0; if ((attr = ippFindAttribute(client->request, "first-job-id", IPP_TAG_INTEGER)) != NULL) { first_job_id = ippGetInteger(attr, 0); fprintf(stderr, "%s Get-Jobs first-job-id=%d", client->hostname, first_job_id); } else first_job_id = 1; /* * See if we only want to see jobs for a specific user... */ username = NULL; if ((attr = ippFindAttribute(client->request, "my-jobs", IPP_TAG_BOOLEAN)) != NULL) { int my_jobs = ippGetBoolean(attr, 0); fprintf(stderr, "%s Get-Jobs my-jobs=%s\n", client->hostname, my_jobs ? "true" : "false"); if (my_jobs) { if ((attr = ippFindAttribute(client->request, "requesting-user-name", IPP_TAG_NAME)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Need requesting-user-name with my-jobs."); return; } username = ippGetString(attr, 0, NULL); fprintf(stderr, "%s Get-Jobs requesting-user-name=\"%s\"\n", client->hostname, username); } } /* * OK, build a list of jobs for this printer... */ ra = ippCreateRequestedArray(client->request); respond_ipp(client, IPP_STATUS_OK, NULL); _cupsRWLockRead(&(client->printer->rwlock)); for (count = 0, job = (_ipp_job_t *)cupsArrayFirst(client->printer->jobs); (limit <= 0 || count < limit) && job; job = (_ipp_job_t *)cupsArrayNext(client->printer->jobs)) { /* * Filter out jobs that don't match... */ if ((job_comparison < 0 && job->state > job_state) || (job_comparison == 0 && job->state != job_state) || (job_comparison > 0 && job->state < job_state) || job->id < first_job_id || (username && job->username && strcasecmp(username, job->username))) continue; if (count > 0) ippAddSeparator(client->response); count ++; copy_job_attributes(client, job, ra); } cupsArrayDelete(ra); _cupsRWUnlock(&(client->printer->rwlock)); } /* * 'ipp_get_printer_attributes()' - Get the attributes for a printer object. */ static void ipp_get_printer_attributes( _ipp_client_t *client) /* I - Client */ { cups_array_t *ra; /* Requested attributes array */ _ipp_printer_t *printer; /* Printer */ /* * Send the attributes... */ ra = ippCreateRequestedArray(client->request); printer = client->printer; respond_ipp(client, IPP_STATUS_OK, NULL); _cupsRWLockRead(&(printer->rwlock)); copy_attributes(client->response, printer->attrs, ra, IPP_TAG_ZERO, IPP_TAG_CUPS_CONST); if (!ra || cupsArrayFind(ra, "media-col-ready")) { int i, /* Looping var */ num_ready = 0; /* Number of ready media */ ipp_t *ready[3]; /* Ready media */ if (printer->main_size != _IPP_MEDIA_SIZE_NONE) { if (printer->main_type != _IPP_MEDIA_TYPE_NONE) ready[num_ready ++] = create_media_col(media_supported[printer->main_size], "main", media_type_supported[printer->main_type], media_col_sizes[printer->main_size][0], media_col_sizes[printer->main_size][1], 635); else ready[num_ready ++] = create_media_col(media_supported[printer->main_size], "main", NULL, media_col_sizes[printer->main_size][0], media_col_sizes[printer->main_size][1], 635); } if (printer->envelope_size != _IPP_MEDIA_SIZE_NONE) ready[num_ready ++] = create_media_col(media_supported[printer->envelope_size], "envelope", NULL, media_col_sizes[printer->envelope_size][0], media_col_sizes[printer->envelope_size][1], 635); if (printer->photo_size != _IPP_MEDIA_SIZE_NONE) { if (printer->photo_type != _IPP_MEDIA_TYPE_NONE) ready[num_ready ++] = create_media_col(media_supported[printer->photo_size], "photo", media_type_supported[printer->photo_type], media_col_sizes[printer->photo_size][0], media_col_sizes[printer->photo_size][1], 0); else ready[num_ready ++] = create_media_col(media_supported[printer->photo_size], "photo", NULL, media_col_sizes[printer->photo_size][0], media_col_sizes[printer->photo_size][1], 0); } if (num_ready) { ippAddCollections(client->response, IPP_TAG_PRINTER, "media-col-ready", num_ready, (const ipp_t **)ready); for (i = 0; i < num_ready; i ++) ippDelete(ready[i]); } else ippAddOutOfBand(client->response, IPP_TAG_PRINTER, IPP_TAG_NOVALUE, "media-col-ready"); } if (!ra || cupsArrayFind(ra, "media-ready")) { int num_ready = 0; /* Number of ready media */ const char *ready[3]; /* Ready media */ if (printer->main_size != _IPP_MEDIA_SIZE_NONE) ready[num_ready ++] = media_supported[printer->main_size]; if (printer->envelope_size != _IPP_MEDIA_SIZE_NONE) ready[num_ready ++] = media_supported[printer->envelope_size]; if (printer->photo_size != _IPP_MEDIA_SIZE_NONE) ready[num_ready ++] = media_supported[printer->photo_size]; if (num_ready) ippAddStrings(client->response, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "media-ready", num_ready, NULL, ready); else ippAddOutOfBand(client->response, IPP_TAG_PRINTER, IPP_TAG_NOVALUE, "media-ready"); } if (!ra || cupsArrayFind(ra, "printer-config-change-date-time")) ippAddDate(client->response, IPP_TAG_PRINTER, "printer-config-change-date-time", ippTimeToDate(printer->config_time)); if (!ra || cupsArrayFind(ra, "printer-config-change-time")) ippAddInteger(client->response, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "printer-config-change-time", (int)(printer->config_time - printer->start_time)); if (!ra || cupsArrayFind(ra, "printer-current-time")) ippAddDate(client->response, IPP_TAG_PRINTER, "printer-current-time", ippTimeToDate(time(NULL))); if (!ra || cupsArrayFind(ra, "printer-state")) ippAddInteger(client->response, IPP_TAG_PRINTER, IPP_TAG_ENUM, "printer-state", printer->state); if (!ra || cupsArrayFind(ra, "printer-state-change-date-time")) ippAddDate(client->response, IPP_TAG_PRINTER, "printer-state-change-date-time", ippTimeToDate(printer->state_time)); if (!ra || cupsArrayFind(ra, "printer-state-change-time")) ippAddInteger(client->response, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "printer-state-change-time", (int)(printer->state_time - printer->start_time)); if (!ra || cupsArrayFind(ra, "printer-state-message")) { static const char * const messages[] = { "Idle.", "Printing.", "Stopped." }; ippAddString(client->response, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_TEXT), "printer-state-message", NULL, messages[printer->state - IPP_PSTATE_IDLE]); } if (!ra || cupsArrayFind(ra, "printer-state-reasons")) { if (printer->state_reasons == _IPP_PREASON_NONE) ippAddString(client->response, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "printer-state-reasons", NULL, "none"); else { int num_reasons = 0;/* Number of reasons */ const char *reasons[32]; /* Reason strings */ if (printer->state_reasons & _IPP_PREASON_OTHER) reasons[num_reasons ++] = "other"; if (printer->state_reasons & _IPP_PREASON_COVER_OPEN) reasons[num_reasons ++] = "cover-open"; if (printer->state_reasons & _IPP_PREASON_INPUT_TRAY_MISSING) reasons[num_reasons ++] = "input-tray-missing"; if (printer->state_reasons & _IPP_PREASON_MARKER_SUPPLY_EMPTY) reasons[num_reasons ++] = "marker-supply-empty-warning"; if (printer->state_reasons & _IPP_PREASON_MARKER_SUPPLY_LOW) reasons[num_reasons ++] = "marker-supply-low-report"; if (printer->state_reasons & _IPP_PREASON_MARKER_WASTE_ALMOST_FULL) reasons[num_reasons ++] = "marker-waste-almost-full-report"; if (printer->state_reasons & _IPP_PREASON_MARKER_WASTE_FULL) reasons[num_reasons ++] = "marker-waste-full-warning"; if (printer->state_reasons & _IPP_PREASON_MEDIA_EMPTY) reasons[num_reasons ++] = "media-empty-warning"; if (printer->state_reasons & _IPP_PREASON_MEDIA_JAM) reasons[num_reasons ++] = "media-jam-warning"; if (printer->state_reasons & _IPP_PREASON_MEDIA_LOW) reasons[num_reasons ++] = "media-low-report"; if (printer->state_reasons & _IPP_PREASON_MEDIA_NEEDED) reasons[num_reasons ++] = "media-needed-report"; if (printer->state_reasons & _IPP_PREASON_MOVING_TO_PAUSED) reasons[num_reasons ++] = "moving-to-paused"; if (printer->state_reasons & _IPP_PREASON_PAUSED) reasons[num_reasons ++] = "paused"; if (printer->state_reasons & _IPP_PREASON_SPOOL_AREA_FULL) reasons[num_reasons ++] = "spool-area-full"; if (printer->state_reasons & _IPP_PREASON_TONER_EMPTY) reasons[num_reasons ++] = "toner-empty-warning"; if (printer->state_reasons & _IPP_PREASON_TONER_LOW) reasons[num_reasons ++] = "toner-low-report"; ippAddStrings(client->response, IPP_TAG_PRINTER, IPP_CONST_TAG(IPP_TAG_KEYWORD), "printer-state-reasons", num_reasons, NULL, reasons); } } if (!ra || cupsArrayFind(ra, "printer-supply")) { int i; /* Looping var */ char buffer[256]; /* Supply value buffer */ ipp_attribute_t *attr = NULL; /* Attribute */ static const char * const colorants[] = { "cyan", "magenta", "yellow", "black", "unknown" }; for (i = 0; i < 5; i ++) { snprintf(buffer, sizeof(buffer), "index=%d;class=%s;type=%s;unit=percent;maxcapacity=100;level=%d;colorantname=%s;", i + 1, i < 4 ? "supplyThatIsConsumed" : "receptacleThatIsFilled", i < 4 ? "toner" : "wasteToner", printer->supplies[i], colorants[i]); if (!attr) attr = ippAddOctetString(client->response, IPP_TAG_PRINTER, "printer-supply", buffer, (int)strlen(buffer)); else ippSetOctetString(client->response, &attr, i, buffer, (int)strlen(buffer)); } } if (!ra || cupsArrayFind(ra, "printer-up-time")) ippAddInteger(client->response, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "printer-up-time", (int)(time(NULL) - printer->start_time)); if (!ra || cupsArrayFind(ra, "queued-job-count")) ippAddInteger(client->response, IPP_TAG_PRINTER, IPP_TAG_INTEGER, "queued-job-count", printer->active_job && printer->active_job->state < IPP_JSTATE_CANCELED); _cupsRWUnlock(&(printer->rwlock)); cupsArrayDelete(ra); } /* * 'ipp_identify_printer()' - Beep or display a message. */ static void ipp_identify_printer( _ipp_client_t *client) /* I - Client */ { /* TODO: Do something */ respond_ipp(client, IPP_STATUS_OK, NULL); } /* * 'ipp_print_job()' - Create a job object with an attached document. */ static void ipp_print_job(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* New job */ char filename[1024], /* Filename buffer */ buffer[4096]; /* Copy buffer */ ssize_t bytes; /* Bytes read */ cups_array_t *ra; /* Attributes to send in response */ /* * Validate print job attributes... */ if (!valid_job_attributes(client)) { httpFlush(client->http); return; } /* * Do we have a file to print? */ if (httpGetState(client->http) == HTTP_STATE_POST_SEND) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "No file in request."); return; } /* * Print the job... */ if ((job = create_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BUSY, "Currently printing another job."); return; } /* * Create a file for the request data... */ create_job_filename(client->printer, job, filename, sizeof(filename)); if (Verbosity) fprintf(stderr, "Creating job file \"%s\", format \"%s\".\n", filename, job->format); if ((job->fd = open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0600)) < 0) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to create print file: %s", strerror(errno)); return; } while ((bytes = httpRead2(client->http, buffer, sizeof(buffer))) > 0) { if (write(job->fd, buffer, (size_t)bytes) < bytes) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } } if (bytes < 0) { /* * Got an error while reading the print data, so abort this job. */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to read print file."); return; } if (close(job->fd)) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } job->fd = -1; job->filename = strdup(filename); job->state = IPP_JSTATE_PENDING; /* * Process the job... */ if (!_cupsThreadCreate((_cups_thread_func_t)process_job, job)) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to process job."); return; } /* * Return the job info... */ respond_ipp(client, IPP_STATUS_OK, NULL); ra = cupsArrayNew((cups_array_func_t)strcmp, NULL); cupsArrayAdd(ra, "job-id"); cupsArrayAdd(ra, "job-state"); cupsArrayAdd(ra, "job-state-message"); cupsArrayAdd(ra, "job-state-reasons"); cupsArrayAdd(ra, "job-uri"); copy_job_attributes(client, job, ra); cupsArrayDelete(ra); } /* * 'ipp_print_uri()' - Create a job object with a referenced document. */ static void ipp_print_uri(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* New job */ ipp_attribute_t *uri; /* document-uri */ char scheme[256], /* URI scheme */ userpass[256], /* Username and password info */ hostname[256], /* Hostname */ resource[1024]; /* Resource path */ int port; /* Port number */ http_uri_status_t uri_status; /* URI decode status */ http_encryption_t encryption; /* Encryption to use, if any */ http_t *http; /* Connection for http/https URIs */ http_status_t status; /* Access status for http/https URIs */ int infile; /* Input file for local file URIs */ char filename[1024], /* Filename buffer */ buffer[4096]; /* Copy buffer */ ssize_t bytes; /* Bytes read */ cups_array_t *ra; /* Attributes to send in response */ static const char * const uri_status_strings[] = { /* URI decode errors */ "URI too large.", "Bad arguments to function.", "Bad resource in URI.", "Bad port number in URI.", "Bad hostname in URI.", "Bad username in URI.", "Bad scheme in URI.", "Bad/empty URI." }; /* * Validate print job attributes... */ if (!valid_job_attributes(client)) { httpFlush(client->http); return; } /* * Do we have a file to print? */ if (httpGetState(client->http) == HTTP_STATE_POST_RECV) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Unexpected document data following request."); return; } /* * Do we have a document URI? */ if ((uri = ippFindAttribute(client->request, "document-uri", IPP_TAG_URI)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Missing document-uri."); return; } if (ippGetCount(uri) != 1) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Too many document-uri values."); return; } uri_status = httpSeparateURI(HTTP_URI_CODING_ALL, ippGetString(uri, 0, NULL), scheme, sizeof(scheme), userpass, sizeof(userpass), hostname, sizeof(hostname), &port, resource, sizeof(resource)); if (uri_status < HTTP_URI_STATUS_OK) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Bad document-uri: %s", uri_status_strings[uri_status - HTTP_URI_STATUS_OVERFLOW]); return; } if (strcmp(scheme, "file") && #ifdef HAVE_SSL strcmp(scheme, "https") && #endif /* HAVE_SSL */ strcmp(scheme, "http")) { respond_ipp(client, IPP_STATUS_ERROR_URI_SCHEME, "URI scheme \"%s\" not supported.", scheme); return; } if (!strcmp(scheme, "file") && access(resource, R_OK)) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to access URI: %s", strerror(errno)); return; } /* * Print the job... */ if ((job = create_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BUSY, "Currently printing another job."); return; } /* * Create a file for the request data... */ if (!strcasecmp(job->format, "image/jpeg")) snprintf(filename, sizeof(filename), "%s/%d.jpg", client->printer->directory, job->id); else if (!strcasecmp(job->format, "image/png")) snprintf(filename, sizeof(filename), "%s/%d.png", client->printer->directory, job->id); else if (!strcasecmp(job->format, "application/pdf")) snprintf(filename, sizeof(filename), "%s/%d.pdf", client->printer->directory, job->id); else if (!strcasecmp(job->format, "application/postscript")) snprintf(filename, sizeof(filename), "%s/%d.ps", client->printer->directory, job->id); else snprintf(filename, sizeof(filename), "%s/%d.prn", client->printer->directory, job->id); if ((job->fd = open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0600)) < 0) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to create print file: %s", strerror(errno)); return; } if (!strcmp(scheme, "file")) { if ((infile = open(resource, O_RDONLY)) < 0) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to access URI: %s", strerror(errno)); return; } do { if ((bytes = read(infile, buffer, sizeof(buffer))) < 0 && (errno == EAGAIN || errno == EINTR)) bytes = 1; else if (bytes > 0 && write(job->fd, buffer, (size_t)bytes) < bytes) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); close(infile); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } } while (bytes > 0); close(infile); } else { #ifdef HAVE_SSL if (port == 443 || !strcmp(scheme, "https")) encryption = HTTP_ENCRYPTION_ALWAYS; else #endif /* HAVE_SSL */ encryption = HTTP_ENCRYPTION_IF_REQUESTED; if ((http = httpConnect2(hostname, port, NULL, AF_UNSPEC, encryption, 1, 30000, NULL)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to connect to %s: %s", hostname, cupsLastErrorString()); job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); return; } httpClearFields(http); httpSetField(http, HTTP_FIELD_ACCEPT_LANGUAGE, "en"); if (httpGet(http, resource)) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to GET URI: %s", strerror(errno)); job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); httpClose(http); return; } while ((status = httpUpdate(http)) == HTTP_STATUS_CONTINUE); if (status != HTTP_STATUS_OK) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to GET URI: %s", httpStatus(status)); job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); httpClose(http); return; } while ((bytes = httpRead2(http, buffer, sizeof(buffer))) > 0) { if (write(job->fd, buffer, (size_t)bytes) < bytes) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); httpClose(http); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } } httpClose(http); } if (close(job->fd)) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } job->fd = -1; job->filename = strdup(filename); job->state = IPP_JSTATE_PENDING; /* * Process the job... */ #if 0 if (!_cupsThreadCreate((_cups_thread_func_t)process_job, job)) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to process job."); return; } #else process_job(job); #endif /* 0 */ /* * Return the job info... */ respond_ipp(client, IPP_STATUS_OK, NULL); ra = cupsArrayNew((cups_array_func_t)strcmp, NULL); cupsArrayAdd(ra, "job-id"); cupsArrayAdd(ra, "job-state"); cupsArrayAdd(ra, "job-state-reasons"); cupsArrayAdd(ra, "job-uri"); copy_job_attributes(client, job, ra); cupsArrayDelete(ra); } /* * 'ipp_send_document()' - Add an attached document to a job object created with * Create-Job. */ static void ipp_send_document(_ipp_client_t *client)/* I - Client */ { _ipp_job_t *job; /* Job information */ char filename[1024], /* Filename buffer */ buffer[4096]; /* Copy buffer */ ssize_t bytes; /* Bytes read */ ipp_attribute_t *attr; /* Current attribute */ cups_array_t *ra; /* Attributes to send in response */ /* * Get the job... */ if ((job = find_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_NOT_FOUND, "Job does not exist."); httpFlush(client->http); return; } /* * See if we already have a document for this job or the job has already * in a non-pending state... */ if (job->state > IPP_JSTATE_HELD) { respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job is not in a pending state."); httpFlush(client->http); return; } else if (job->filename || job->fd >= 0) { respond_ipp(client, IPP_STATUS_ERROR_MULTIPLE_JOBS_NOT_SUPPORTED, "Multiple document jobs are not supported."); httpFlush(client->http); return; } if ((attr = ippFindAttribute(client->request, "last-document", IPP_TAG_ZERO)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Missing required last-document attribute."); httpFlush(client->http); return; } else if (ippGetValueTag(attr) != IPP_TAG_BOOLEAN || ippGetCount(attr) != 1 || !ippGetBoolean(attr, 0)) { respond_unsupported(client, attr); httpFlush(client->http); return; } /* * Validate document attributes... */ if (!valid_doc_attributes(client)) { httpFlush(client->http); return; } copy_attributes(job->attrs, client->request, NULL, IPP_TAG_JOB, 0); /* * Get the document format for the job... */ _cupsRWLockWrite(&(client->printer->rwlock)); if ((attr = ippFindAttribute(job->attrs, "document-format-detected", IPP_TAG_MIMETYPE)) != NULL) job->format = ippGetString(attr, 0, NULL); else if ((attr = ippFindAttribute(job->attrs, "document-format-supplied", IPP_TAG_MIMETYPE)) != NULL) job->format = ippGetString(attr, 0, NULL); else job->format = "application/octet-stream"; /* * Create a file for the request data... */ create_job_filename(client->printer, job, filename, sizeof(filename)); if (Verbosity) fprintf(stderr, "Creating job file \"%s\", format \"%s\".\n", filename, job->format); job->fd = open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0600); _cupsRWUnlock(&(client->printer->rwlock)); if (job->fd < 0) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to create print file: %s", strerror(errno)); return; } while ((bytes = httpRead2(client->http, buffer, sizeof(buffer))) > 0) { if (write(job->fd, buffer, (size_t)bytes) < bytes) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } } if (bytes < 0) { /* * Got an error while reading the print data, so abort this job. */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to read print file."); return; } if (close(job->fd)) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } _cupsRWLockWrite(&(client->printer->rwlock)); job->fd = -1; job->filename = strdup(filename); job->state = IPP_JSTATE_PENDING; _cupsRWUnlock(&(client->printer->rwlock)); /* * Process the job... */ #if 0 if (!_cupsThreadCreate((_cups_thread_func_t)process_job, job)) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to process job."); return; } #else process_job(job); #endif /* 0 */ /* * Return the job info... */ respond_ipp(client, IPP_STATUS_OK, NULL); ra = cupsArrayNew((cups_array_func_t)strcmp, NULL); cupsArrayAdd(ra, "job-id"); cupsArrayAdd(ra, "job-state"); cupsArrayAdd(ra, "job-state-reasons"); cupsArrayAdd(ra, "job-uri"); copy_job_attributes(client, job, ra); cupsArrayDelete(ra); } /* * 'ipp_send_uri()' - Add a referenced document to a job object created with * Create-Job. */ static void ipp_send_uri(_ipp_client_t *client) /* I - Client */ { _ipp_job_t *job; /* Job information */ ipp_attribute_t *uri; /* document-uri */ char scheme[256], /* URI scheme */ userpass[256], /* Username and password info */ hostname[256], /* Hostname */ resource[1024]; /* Resource path */ int port; /* Port number */ http_uri_status_t uri_status; /* URI decode status */ http_encryption_t encryption; /* Encryption to use, if any */ http_t *http; /* Connection for http/https URIs */ http_status_t status; /* Access status for http/https URIs */ int infile; /* Input file for local file URIs */ char filename[1024], /* Filename buffer */ buffer[4096]; /* Copy buffer */ ssize_t bytes; /* Bytes read */ ipp_attribute_t *attr; /* Current attribute */ cups_array_t *ra; /* Attributes to send in response */ static const char * const uri_status_strings[] = { /* URI decode errors */ "URI too large.", "Bad arguments to function.", "Bad resource in URI.", "Bad port number in URI.", "Bad hostname in URI.", "Bad username in URI.", "Bad scheme in URI.", "Bad/empty URI." }; /* * Get the job... */ if ((job = find_job(client)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_NOT_FOUND, "Job does not exist."); httpFlush(client->http); return; } /* * See if we already have a document for this job or the job has already * in a non-pending state... */ if (job->state > IPP_JSTATE_HELD) { respond_ipp(client, IPP_STATUS_ERROR_NOT_POSSIBLE, "Job is not in a pending state."); httpFlush(client->http); return; } else if (job->filename || job->fd >= 0) { respond_ipp(client, IPP_STATUS_ERROR_MULTIPLE_JOBS_NOT_SUPPORTED, "Multiple document jobs are not supported."); httpFlush(client->http); return; } if ((attr = ippFindAttribute(client->request, "last-document", IPP_TAG_ZERO)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Missing required last-document attribute."); httpFlush(client->http); return; } else if (ippGetValueTag(attr) != IPP_TAG_BOOLEAN || ippGetCount(attr) != 1 || !ippGetBoolean(attr, 0)) { respond_unsupported(client, attr); httpFlush(client->http); return; } /* * Validate document attributes... */ if (!valid_doc_attributes(client)) { httpFlush(client->http); return; } /* * Do we have a file to print? */ if (httpGetState(client->http) == HTTP_STATE_POST_RECV) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Unexpected document data following request."); return; } /* * Do we have a document URI? */ if ((uri = ippFindAttribute(client->request, "document-uri", IPP_TAG_URI)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Missing document-uri."); return; } if (ippGetCount(uri) != 1) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Too many document-uri values."); return; } uri_status = httpSeparateURI(HTTP_URI_CODING_ALL, ippGetString(uri, 0, NULL), scheme, sizeof(scheme), userpass, sizeof(userpass), hostname, sizeof(hostname), &port, resource, sizeof(resource)); if (uri_status < HTTP_URI_STATUS_OK) { respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Bad document-uri: %s", uri_status_strings[uri_status - HTTP_URI_STATUS_OVERFLOW]); return; } if (strcmp(scheme, "file") && #ifdef HAVE_SSL strcmp(scheme, "https") && #endif /* HAVE_SSL */ strcmp(scheme, "http")) { respond_ipp(client, IPP_STATUS_ERROR_URI_SCHEME, "URI scheme \"%s\" not supported.", scheme); return; } if (!strcmp(scheme, "file") && access(resource, R_OK)) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to access URI: %s", strerror(errno)); return; } /* * Get the document format for the job... */ _cupsRWLockWrite(&(client->printer->rwlock)); if ((attr = ippFindAttribute(job->attrs, "document-format", IPP_TAG_MIMETYPE)) != NULL) job->format = ippGetString(attr, 0, NULL); else job->format = "application/octet-stream"; /* * Create a file for the request data... */ if (!strcasecmp(job->format, "image/jpeg")) snprintf(filename, sizeof(filename), "%s/%d.jpg", client->printer->directory, job->id); else if (!strcasecmp(job->format, "image/png")) snprintf(filename, sizeof(filename), "%s/%d.png", client->printer->directory, job->id); else if (!strcasecmp(job->format, "application/pdf")) snprintf(filename, sizeof(filename), "%s/%d.pdf", client->printer->directory, job->id); else if (!strcasecmp(job->format, "application/postscript")) snprintf(filename, sizeof(filename), "%s/%d.ps", client->printer->directory, job->id); else snprintf(filename, sizeof(filename), "%s/%d.prn", client->printer->directory, job->id); job->fd = open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0600); _cupsRWUnlock(&(client->printer->rwlock)); if (job->fd < 0) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to create print file: %s", strerror(errno)); return; } if (!strcmp(scheme, "file")) { if ((infile = open(resource, O_RDONLY)) < 0) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to access URI: %s", strerror(errno)); return; } do { if ((bytes = read(infile, buffer, sizeof(buffer))) < 0 && (errno == EAGAIN || errno == EINTR)) bytes = 1; else if (bytes > 0 && write(job->fd, buffer, (size_t)bytes) < bytes) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); close(infile); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } } while (bytes > 0); close(infile); } else { #ifdef HAVE_SSL if (port == 443 || !strcmp(scheme, "https")) encryption = HTTP_ENCRYPTION_ALWAYS; else #endif /* HAVE_SSL */ encryption = HTTP_ENCRYPTION_IF_REQUESTED; if ((http = httpConnect2(hostname, port, NULL, AF_UNSPEC, encryption, 1, 30000, NULL)) == NULL) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to connect to %s: %s", hostname, cupsLastErrorString()); job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); return; } httpClearFields(http); httpSetField(http, HTTP_FIELD_ACCEPT_LANGUAGE, "en"); if (httpGet(http, resource)) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to GET URI: %s", strerror(errno)); job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); httpClose(http); return; } while ((status = httpUpdate(http)) == HTTP_STATUS_CONTINUE); if (status != HTTP_STATUS_OK) { respond_ipp(client, IPP_STATUS_ERROR_DOCUMENT_ACCESS, "Unable to GET URI: %s", httpStatus(status)); job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); httpClose(http); return; } while ((bytes = httpRead2(http, buffer, sizeof(buffer))) > 0) { if (write(job->fd, buffer, (size_t)bytes) < bytes) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; close(job->fd); job->fd = -1; unlink(filename); httpClose(http); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } } httpClose(http); } if (close(job->fd)) { int error = errno; /* Write error */ job->state = IPP_JSTATE_ABORTED; job->fd = -1; unlink(filename); respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to write print file: %s", strerror(error)); return; } _cupsRWLockWrite(&(client->printer->rwlock)); job->fd = -1; job->filename = strdup(filename); job->state = IPP_JSTATE_PENDING; _cupsRWUnlock(&(client->printer->rwlock)); /* * Process the job... */ #if 0 if (!_cupsThreadCreate((_cups_thread_func_t)process_job, job)) { job->state = IPP_JSTATE_ABORTED; respond_ipp(client, IPP_STATUS_ERROR_INTERNAL, "Unable to process job."); return; } #else process_job(job); #endif /* 0 */ /* * Return the job info... */ respond_ipp(client, IPP_STATUS_OK, NULL); ra = cupsArrayNew((cups_array_func_t)strcmp, NULL); cupsArrayAdd(ra, "job-id"); cupsArrayAdd(ra, "job-state"); cupsArrayAdd(ra, "job-state-reasons"); cupsArrayAdd(ra, "job-uri"); copy_job_attributes(client, job, ra); cupsArrayDelete(ra); } /* * 'ipp_validate_job()' - Validate job creation attributes. */ static void ipp_validate_job(_ipp_client_t *client) /* I - Client */ { if (valid_job_attributes(client)) respond_ipp(client, IPP_STATUS_OK, NULL); } /* * 'parse_options()' - Parse URL options into CUPS options. * * The client->options string is destroyed by this function. */ static int /* O - Number of options */ parse_options(_ipp_client_t *client, /* I - Client */ cups_option_t **options) /* O - Options */ { char *name, /* Name */ *value, /* Value */ *next; /* Next name=value pair */ int num_options = 0; /* Number of options */ *options = NULL; for (name = client->options; name && *name; name = next) { if ((value = strchr(name, '=')) == NULL) break; *value++ = '\0'; if ((next = strchr(value, '&')) != NULL) *next++ = '\0'; num_options = cupsAddOption(name, value, num_options, options); } return (num_options); } /* * 'process_client()' - Process client requests on a thread. */ static void * /* O - Exit status */ process_client(_ipp_client_t *client) /* I - Client */ { /* * Loop until we are out of requests or timeout (30 seconds)... */ #ifdef HAVE_SSL int first_time = 1; /* First time request? */ #endif /* HAVE_SSL */ while (httpWait(client->http, 30000)) { #ifdef HAVE_SSL if (first_time) { /* * See if we need to negotiate a TLS connection... */ char buf[1]; /* First byte from client */ if (recv(httpGetFd(client->http), buf, 1, MSG_PEEK) == 1 && (!buf[0] || !strchr("DGHOPT", buf[0]))) { fprintf(stderr, "%s Starting HTTPS session.\n", client->hostname); if (httpEncryption(client->http, HTTP_ENCRYPTION_ALWAYS)) { fprintf(stderr, "%s Unable to encrypt connection: %s\n", client->hostname, cupsLastErrorString()); break; } fprintf(stderr, "%s Connection now encrypted.\n", client->hostname); } first_time = 0; } #endif /* HAVE_SSL */ if (!process_http(client)) break; } /* * Close the conection to the client and return... */ delete_client(client); return (NULL); } /* * 'process_http()' - Process a HTTP request. */ int /* O - 1 on success, 0 on failure */ process_http(_ipp_client_t *client) /* I - Client connection */ { char uri[1024]; /* URI */ http_state_t http_state; /* HTTP state */ http_status_t http_status; /* HTTP status */ ipp_state_t ipp_state; /* State of IPP transfer */ char scheme[32], /* Method/scheme */ userpass[128], /* Username:password */ hostname[HTTP_MAX_HOST]; /* Hostname */ int port; /* Port number */ const char *encoding; /* Content-Encoding value */ static const char * const http_states[] = { /* Strings for logging HTTP method */ "WAITING", "OPTIONS", "GET", "GET_SEND", "HEAD", "POST", "POST_RECV", "POST_SEND", "PUT", "PUT_RECV", "DELETE", "TRACE", "CONNECT", "STATUS", "UNKNOWN_METHOD", "UNKNOWN_VERSION" }; /* * Clear state variables... */ ippDelete(client->request); ippDelete(client->response); client->request = NULL; client->response = NULL; client->operation = HTTP_STATE_WAITING; /* * Read a request from the connection... */ while ((http_state = httpReadRequest(client->http, uri, sizeof(uri))) == HTTP_STATE_WAITING) usleep(1); /* * Parse the request line... */ if (http_state == HTTP_STATE_ERROR) { if (httpError(client->http) == EPIPE) fprintf(stderr, "%s Client closed connection.\n", client->hostname); else fprintf(stderr, "%s Bad request line (%s).\n", client->hostname, strerror(httpError(client->http))); return (0); } else if (http_state == HTTP_STATE_UNKNOWN_METHOD) { fprintf(stderr, "%s Bad/unknown operation.\n", client->hostname); respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0); return (0); } else if (http_state == HTTP_STATE_UNKNOWN_VERSION) { fprintf(stderr, "%s Bad HTTP version.\n", client->hostname); respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0); return (0); } fprintf(stderr, "%s %s %s\n", client->hostname, http_states[http_state], uri); /* * Separate the URI into its components... */ if (httpSeparateURI(HTTP_URI_CODING_MOST, uri, scheme, sizeof(scheme), userpass, sizeof(userpass), hostname, sizeof(hostname), &port, client->uri, sizeof(client->uri)) < HTTP_URI_STATUS_OK && (http_state != HTTP_STATE_OPTIONS || strcmp(uri, "*"))) { fprintf(stderr, "%s Bad URI \"%s\".\n", client->hostname, uri); respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0); return (0); } if ((client->options = strchr(client->uri, '?')) != NULL) *(client->options)++ = '\0'; /* * Process the request... */ client->start = time(NULL); client->operation = httpGetState(client->http); /* * Parse incoming parameters until the status changes... */ while ((http_status = httpUpdate(client->http)) == HTTP_STATUS_CONTINUE); if (http_status != HTTP_STATUS_OK) { respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0); return (0); } if (!httpGetField(client->http, HTTP_FIELD_HOST)[0] && httpGetVersion(client->http) >= HTTP_VERSION_1_1) { /* * HTTP/1.1 and higher require the "Host:" field... */ respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0); return (0); } /* * Handle HTTP Upgrade... */ if (!strcasecmp(httpGetField(client->http, HTTP_FIELD_CONNECTION), "Upgrade")) { #ifdef HAVE_SSL if (strstr(httpGetField(client->http, HTTP_FIELD_UPGRADE), "TLS/") != NULL && !httpIsEncrypted(client->http)) { if (!respond_http(client, HTTP_STATUS_SWITCHING_PROTOCOLS, NULL, NULL, 0)) return (0); fprintf(stderr, "%s Upgrading to encrypted connection.\n", client->hostname); if (httpEncryption(client->http, HTTP_ENCRYPTION_REQUIRED)) { fprintf(stderr, "%s Unable to encrypt connection: %s\n", client->hostname, cupsLastErrorString()); return (0); } fprintf(stderr, "%s Connection now encrypted.\n", client->hostname); } else #endif /* HAVE_SSL */ if (!respond_http(client, HTTP_STATUS_NOT_IMPLEMENTED, NULL, NULL, 0)) return (0); } /* * Handle HTTP Expect... */ if (httpGetExpect(client->http) && (client->operation == HTTP_STATE_POST || client->operation == HTTP_STATE_PUT)) { if (httpGetExpect(client->http) == HTTP_STATUS_CONTINUE) { /* * Send 100-continue header... */ if (!respond_http(client, HTTP_STATUS_CONTINUE, NULL, NULL, 0)) return (0); } else { /* * Send 417-expectation-failed header... */ if (!respond_http(client, HTTP_STATUS_EXPECTATION_FAILED, NULL, NULL, 0)) return (0); } } /* * Handle new transfers... */ encoding = httpGetContentEncoding(client->http); switch (client->operation) { case HTTP_STATE_OPTIONS : /* * Do OPTIONS command... */ return (respond_http(client, HTTP_STATUS_OK, NULL, NULL, 0)); case HTTP_STATE_HEAD : if (!strcmp(client->uri, "/icon.png")) return (respond_http(client, HTTP_STATUS_OK, NULL, "image/png", 0)); else if (!strcmp(client->uri, "/") || !strcmp(client->uri, "/media") || !strcmp(client->uri, "/supplies")) return (respond_http(client, HTTP_STATUS_OK, NULL, "text/html", 0)); else return (respond_http(client, HTTP_STATUS_NOT_FOUND, NULL, NULL, 0)); case HTTP_STATE_GET : if (!strcmp(client->uri, "/icon.png")) { /* * Send PNG icon file. */ int fd; /* Icon file */ struct stat fileinfo; /* Icon file information */ char buffer[4096]; /* Copy buffer */ ssize_t bytes; /* Bytes */ fprintf(stderr, "Icon file is \"%s\".\n", client->printer->icon); if (!stat(client->printer->icon, &fileinfo) && (fd = open(client->printer->icon, O_RDONLY)) >= 0) { if (!respond_http(client, HTTP_STATUS_OK, NULL, "image/png", (size_t)fileinfo.st_size)) { close(fd); return (0); } while ((bytes = read(fd, buffer, sizeof(buffer))) > 0) httpWrite2(client->http, buffer, (size_t)bytes); httpFlushWrite(client->http); close(fd); } else return (respond_http(client, HTTP_STATUS_NOT_FOUND, NULL, NULL, 0)); } else if (!strcmp(client->uri, "/")) { /* * Show web status page... */ _ipp_job_t *job; /* Current job */ int i; /* Looping var */ _ipp_preason_t reason; /* Current reason */ static const char * const reasons[] = { /* Reason strings */ "Other", "Cover Open", "Input Tray Missing", "Marker Supply Empty", "Marker Supply Low", "Marker Waste Almost Full", "Marker Waste Full", "Media Empty", "Media Jam", "Media Low", "Media Needed", "Moving to Paused", "Paused", "Spool Area Full", "Toner Empty", "Toner Low" }; if (!respond_http(client, HTTP_STATUS_OK, encoding, "text/html", 0)) return (0); html_header(client, client->printer->name); html_printf(client, "

ippserver (" CUPS_SVERSION ")

\n" "

%s, %d job(s).", client->printer->state == IPP_PSTATE_IDLE ? "Idle" : client->printer->state == IPP_PSTATE_PROCESSING ? "Printing" : "Stopped", cupsArrayCount(client->printer->jobs)); for (i = 0, reason = 1; i < (int)(sizeof(reasons) / sizeof(reasons[0])); i ++, reason <<= 1) if (client->printer->state_reasons & reason) html_printf(client, "\n
    %s", reasons[i]); html_printf(client, "

\n"); if (cupsArrayCount(client->printer->jobs) > 0) { _cupsRWLockRead(&(client->printer->rwlock)); html_printf(client, "\n"); for (job = (_ipp_job_t *)cupsArrayFirst(client->printer->jobs); job; job = (_ipp_job_t *)cupsArrayNext(client->printer->jobs)) { char when[256], /* When job queued/started/finished */ hhmmss[64]; /* Time HH:MM:SS */ switch (job->state) { case IPP_JSTATE_PENDING : case IPP_JSTATE_HELD : snprintf(when, sizeof(when), "Queued at %s", time_string(job->created, hhmmss, sizeof(hhmmss))); break; case IPP_JSTATE_PROCESSING : case IPP_JSTATE_STOPPED : snprintf(when, sizeof(when), "Started at %s", time_string(job->processing, hhmmss, sizeof(hhmmss))); break; case IPP_JSTATE_ABORTED : snprintf(when, sizeof(when), "Aborted at %s", time_string(job->completed, hhmmss, sizeof(hhmmss))); break; case IPP_JSTATE_CANCELED : snprintf(when, sizeof(when), "Canceled at %s", time_string(job->completed, hhmmss, sizeof(hhmmss))); break; case IPP_JSTATE_COMPLETED : snprintf(when, sizeof(when), "Completed at %s", time_string(job->completed, hhmmss, sizeof(hhmmss))); break; } html_printf(client, "\n", job->id, job->name, job->username, when); } html_printf(client, "
Job #NameOwnerWhen
%d%s%s%s
\n"); _cupsRWUnlock(&(client->printer->rwlock)); } html_footer(client); return (1); } else if (!strcmp(client->uri, "/media")) { /* * Show web media page... */ int i, /* Looping var */ num_options; /* Number of form options */ cups_option_t *options; /* Form options */ static const char * const sizes[] = { /* Size strings */ "ISO A4", "ISO A5", "ISO A6", "DL Envelope", "US Legal", "US Letter", "#10 Envelope", "3x5 Photo", "3.5x5 Photo", "4x6 Photo", "5x7 Photo" }; static const char * const types[] = /* Type strings */ { "Auto", "Cardstock", "Envelope", "Labels", "Other", "Glossy Photo", "High-Gloss Photo", "Matte Photo", "Satin Photo", "Semi-Gloss Photo", "Plain", "Letterhead", "Transparency" }; static const int sheets[] = /* Number of sheets */ { 250, 100, 25, 5, 0 }; if (!respond_http(client, HTTP_STATUS_OK, encoding, "text/html", 0)) return (0); html_header(client, client->printer->name); if ((num_options = parse_options(client, &options)) > 0) { /* * WARNING: A real printer/server implementation MUST NOT implement * media updates via a GET request - GET requests are supposed to be * idempotent (without side-effects) and we obviously are not * authenticating access here. This form is provided solely to * enable testing and development! */ const char *val; /* Form value */ if ((val = cupsGetOption("main_size", num_options, options)) != NULL) client->printer->main_size = atoi(val); if ((val = cupsGetOption("main_type", num_options, options)) != NULL) client->printer->main_type = atoi(val); if ((val = cupsGetOption("main_level", num_options, options)) != NULL) client->printer->main_level = atoi(val); if ((val = cupsGetOption("envelope_size", num_options, options)) != NULL) client->printer->envelope_size = atoi(val); if ((val = cupsGetOption("envelope_level", num_options, options)) != NULL) client->printer->envelope_level = atoi(val); if ((val = cupsGetOption("photo_size", num_options, options)) != NULL) client->printer->photo_size = atoi(val); if ((val = cupsGetOption("photo_type", num_options, options)) != NULL) client->printer->photo_type = atoi(val); if ((val = cupsGetOption("photo_level", num_options, options)) != NULL) client->printer->photo_level = atoi(val); if ((client->printer->main_level < 100 && client->printer->main_level > 0) || (client->printer->envelope_level < 25 && client->printer->envelope_level > 0) || (client->printer->photo_level < 25 && client->printer->photo_level > 0)) client->printer->state_reasons |= _IPP_PREASON_MEDIA_LOW; else client->printer->state_reasons &= (_ipp_preason_t)~_IPP_PREASON_MEDIA_LOW; if ((client->printer->main_level == 0 && client->printer->main_size > _IPP_MEDIA_SIZE_NONE) || (client->printer->envelope_level == 0 && client->printer->envelope_size > _IPP_MEDIA_SIZE_NONE) || (client->printer->photo_level == 0 && client->printer->photo_size > _IPP_MEDIA_SIZE_NONE)) { client->printer->state_reasons |= _IPP_PREASON_MEDIA_EMPTY; if (client->printer->active_job) client->printer->state_reasons |= _IPP_PREASON_MEDIA_NEEDED; } else client->printer->state_reasons &= (_ipp_preason_t)~(_IPP_PREASON_MEDIA_EMPTY | _IPP_PREASON_MEDIA_NEEDED); html_printf(client, "
Media updated.
\n"); } html_printf(client, "
\n"); html_printf(client, "\n"); html_printf(client, "\n"); html_printf(client, "\n"); html_printf(client, "\n"); html_printf(client, "
Main Tray:
Envelope Feeder:
Photo Tray:
\n"); html_footer(client); return (1); } else if (!strcmp(client->uri, "/supplies")) { /* * Show web supplies page... */ int i, j, /* Looping vars */ num_options; /* Number of form options */ cups_option_t *options; /* Form options */ static const int levels[] = { 0, 5, 10, 25, 50, 75, 90, 95, 100 }; if (!respond_http(client, HTTP_STATUS_OK, encoding, "text/html", 0)) return (0); html_header(client, client->printer->name); if ((num_options = parse_options(client, &options)) > 0) { /* * WARNING: A real printer/server implementation MUST NOT implement * supply updates via a GET request - GET requests are supposed to be * idempotent (without side-effects) and we obviously are not * authenticating access here. This form is provided solely to * enable testing and development! */ char name[64]; /* Form field */ const char *val; /* Form value */ client->printer->state_reasons &= (_ipp_preason_t)~(_IPP_PREASON_MARKER_SUPPLY_EMPTY | _IPP_PREASON_MARKER_SUPPLY_LOW | _IPP_PREASON_MARKER_WASTE_ALMOST_FULL | _IPP_PREASON_MARKER_WASTE_FULL | _IPP_PREASON_TONER_EMPTY | _IPP_PREASON_TONER_LOW); for (i = 0; i < (int)(sizeof(printer_supplies) / sizeof(printer_supplies[0])); i ++) { snprintf(name, sizeof(name), "supply_%d", i); if ((val = cupsGetOption(name, num_options, options)) != NULL) { int level = client->printer->supplies[i] = atoi(val); /* New level */ if (i < 4) { if (level == 0) client->printer->state_reasons |= _IPP_PREASON_TONER_EMPTY; else if (level < 10) client->printer->state_reasons |= _IPP_PREASON_TONER_LOW; } else { if (level == 100) client->printer->state_reasons |= _IPP_PREASON_MARKER_WASTE_FULL; else if (level > 90) client->printer->state_reasons |= _IPP_PREASON_MARKER_WASTE_ALMOST_FULL; } } } html_printf(client, "
Supplies updated.
\n"); } html_printf(client, "
\n"); html_printf(client, "\n"); for (i = 0; i < (int)(sizeof(printer_supplies) / sizeof(printer_supplies[0])); i ++) { html_printf(client, "\n"); } html_printf(client, "\n
%s:
\n
\n"); html_footer(client); return (1); } else return (respond_http(client, HTTP_STATUS_NOT_FOUND, NULL, NULL, 0)); break; case HTTP_STATE_POST : if (strcmp(httpGetField(client->http, HTTP_FIELD_CONTENT_TYPE), "application/ipp")) { /* * Not an IPP request... */ return (respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0)); } /* * Read the IPP request... */ client->request = ippNew(); while ((ipp_state = ippRead(client->http, client->request)) != IPP_STATE_DATA) { if (ipp_state == IPP_STATE_ERROR) { fprintf(stderr, "%s IPP read error (%s).\n", client->hostname, cupsLastErrorString()); respond_http(client, HTTP_STATUS_BAD_REQUEST, NULL, NULL, 0); return (0); } } /* * Now that we have the IPP request, process the request... */ return (process_ipp(client)); default : break; /* Anti-compiler-warning-code */ } return (1); } /* * 'process_ipp()' - Process an IPP request. */ static int /* O - 1 on success, 0 on error */ process_ipp(_ipp_client_t *client) /* I - Client */ { ipp_tag_t group; /* Current group tag */ ipp_attribute_t *attr; /* Current attribute */ ipp_attribute_t *charset; /* Character set attribute */ ipp_attribute_t *language; /* Language attribute */ ipp_attribute_t *uri; /* Printer URI attribute */ int major, minor; /* Version number */ const char *name; /* Name of attribute */ debug_attributes("Request", client->request, 1); /* * First build an empty response message for this request... */ client->operation_id = ippGetOperation(client->request); client->response = ippNewResponse(client->request); /* * Then validate the request header and required attributes... */ major = ippGetVersion(client->request, &minor); if (major < 1 || major > 2) { /* * Return an error, since we only support IPP 1.x and 2.x. */ respond_ipp(client, IPP_STATUS_ERROR_VERSION_NOT_SUPPORTED, "Bad request version number %d.%d.", major, minor); } else if (ippGetRequestId(client->request) <= 0) respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Bad request-id %d.", ippGetRequestId(client->request)); else if (!ippFirstAttribute(client->request)) respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "No attributes in request."); else { /* * Make sure that the attributes are provided in the correct order and * don't repeat groups... */ for (attr = ippFirstAttribute(client->request), group = ippGetGroupTag(attr); attr; attr = ippNextAttribute(client->request)) { if (ippGetGroupTag(attr) < group && ippGetGroupTag(attr) != IPP_TAG_ZERO) { /* * Out of order; return an error... */ respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Attribute groups are out of order (%x < %x).", ippGetGroupTag(attr), group); break; } else group = ippGetGroupTag(attr); } if (!attr) { /* * Then make sure that the first three attributes are: * * attributes-charset * attributes-natural-language * printer-uri/job-uri */ attr = ippFirstAttribute(client->request); name = ippGetName(attr); if (attr && name && !strcmp(name, "attributes-charset") && ippGetValueTag(attr) == IPP_TAG_CHARSET) charset = attr; else charset = NULL; attr = ippNextAttribute(client->request); name = ippGetName(attr); if (attr && name && !strcmp(name, "attributes-natural-language") && ippGetValueTag(attr) == IPP_TAG_LANGUAGE) language = attr; else language = NULL; if ((attr = ippFindAttribute(client->request, "printer-uri", IPP_TAG_URI)) != NULL) uri = attr; else if ((attr = ippFindAttribute(client->request, "job-uri", IPP_TAG_URI)) != NULL) uri = attr; else uri = NULL; if (charset && strcasecmp(ippGetString(charset, 0, NULL), "us-ascii") && strcasecmp(ippGetString(charset, 0, NULL), "utf-8")) { /* * Bad character set... */ respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Unsupported character set \"%s\".", ippGetString(charset, 0, NULL)); } else if (!charset || !language || !uri) { /* * Return an error, since attributes-charset, * attributes-natural-language, and printer-uri/job-uri are required * for all operations. */ respond_ipp(client, IPP_STATUS_ERROR_BAD_REQUEST, "Missing required attributes."); } else { char scheme[32], /* URI scheme */ userpass[32], /* Username/password in URI */ host[256], /* Host name in URI */ resource[256]; /* Resource path in URI */ int port; /* Port number in URI */ name = ippGetName(uri); if (httpSeparateURI(HTTP_URI_CODING_ALL, ippGetString(uri, 0, NULL), scheme, sizeof(scheme), userpass, sizeof(userpass), host, sizeof(host), &port, resource, sizeof(resource)) < HTTP_URI_STATUS_OK) respond_ipp(client, IPP_STATUS_ERROR_ATTRIBUTES_OR_VALUES, "Bad %s value '%s'.", name, ippGetString(uri, 0, NULL)); else if ((!strcmp(name, "job-uri") && strncmp(resource, "/ipp/print/", 11)) || (!strcmp(name, "printer-uri") && strcmp(resource, "/ipp/print"))) respond_ipp(client, IPP_STATUS_ERROR_NOT_FOUND, "%s %s not found.", name, ippGetString(uri, 0, NULL)); else { /* * Try processing the operation... */ switch (ippGetOperation(client->request)) { case IPP_OP_PRINT_JOB : ipp_print_job(client); break; case IPP_OP_PRINT_URI : ipp_print_uri(client); break; case IPP_OP_VALIDATE_JOB : ipp_validate_job(client); break; case IPP_OP_CREATE_JOB : ipp_create_job(client); break; case IPP_OP_SEND_DOCUMENT : ipp_send_document(client); break; case IPP_OP_SEND_URI : ipp_send_uri(client); break; case IPP_OP_CANCEL_JOB : ipp_cancel_job(client); break; case IPP_OP_GET_JOB_ATTRIBUTES : ipp_get_job_attributes(client); break; case IPP_OP_GET_JOBS : ipp_get_jobs(client); break; case IPP_OP_GET_PRINTER_ATTRIBUTES : ipp_get_printer_attributes(client); break; case IPP_OP_CLOSE_JOB : ipp_close_job(client); break; case IPP_OP_IDENTIFY_PRINTER : ipp_identify_printer(client); break; default : respond_ipp(client, IPP_STATUS_ERROR_OPERATION_NOT_SUPPORTED, "Operation not supported."); break; } } } } } /* * Send the HTTP header and return... */ if (httpGetState(client->http) != HTTP_STATE_POST_SEND) httpFlush(client->http); /* Flush trailing (junk) data */ return (respond_http(client, HTTP_STATUS_OK, NULL, "application/ipp", ippLength(client->response))); } /* * 'process_job()' - Process a print job. */ static void * /* O - Thread exit status */ process_job(_ipp_job_t *job) /* I - Job */ { job->state = IPP_JSTATE_PROCESSING; job->printer->state = IPP_PSTATE_PROCESSING; job->processing = time(NULL); while (job->printer->state_reasons & _IPP_PREASON_MEDIA_EMPTY) { job->printer->state_reasons |= _IPP_PREASON_MEDIA_NEEDED; sleep(1); } job->printer->state_reasons &= (_ipp_preason_t)~_IPP_PREASON_MEDIA_NEEDED; if (job->printer->command) { /* * Execute a command with the job spool file and wait for it to complete... */ int pid, /* Process ID */ status; /* Exit status */ time_t start, /* Start time */ end; /* End time */ char *myargv[3], /* Command-line arguments */ *myenvp[200]; /* Environment variables */ int myenvc; /* Number of environment variables */ ipp_attribute_t *attr; /* Job attribute */ char val[1280], /* IPP_NAME=value */ *valptr; /* Pointer into string */ fprintf(stderr, "Running command \"%s %s\".\n", job->printer->command, job->filename); time(&start); /* * Setup the command-line arguments... */ myargv[0] = job->printer->command; myargv[1] = job->filename; myargv[2] = NULL; /* * Copy the current environment, then add ENV variables for every Job * attribute... */ for (myenvc = 0; environ[myenvc] && myenvc < (int)(sizeof(myenvp) / sizeof(myenvp[0]) - 1); myenvc ++) myenvp[myenvc] = strdup(environ[myenvc]); for (attr = ippFirstAttribute(job->attrs); attr && myenvc < (int)(sizeof(myenvp) / sizeof(myenvp[0]) - 1); attr = ippNextAttribute(job->attrs)) { /* * Convert "attribute-name" to "IPP_ATTRIBUTE_NAME=" and then add the * value(s) from the attribute. */ const char *name = ippGetName(attr); if (!name) continue; valptr = val; *valptr++ = 'I'; *valptr++ = 'P'; *valptr++ = 'P'; *valptr++ = '_'; while (*name && valptr < (val + sizeof(val) - 2)) { if (*name == '-') *valptr++ = '_'; else *valptr++ = (char)toupper(*name & 255); name ++; } *valptr++ = '='; ippAttributeString(attr, valptr, sizeof(val) - (size_t)(valptr - val)); myenvp[myenvc++] = strdup(val); } myenvp[myenvc] = NULL; /* * Now run the program... */ #ifdef WIN32 status = _spawnvpe(_P_WAIT, job->printer->command, myargv, myenvp); #else if ((pid = fork()) == 0) { /* * Child comes here... */ execve(job->printer->command, myargv, myenvp); exit(errno); } else if (pid < 0) { /* * Unable to fork process... */ perror("Unable to start job processing command"); status = -1; } else { /* * Free memory used for environment... */ while (myenvc > 0) free(myenvp[-- myenvc]); /* * Wait for child to complete... */ # ifdef HAVE_WAITPID while (waitpid(pid, &status, 0) < 0); # else while (wait(&status) < 0); # endif /* HAVE_WAITPID */ } #endif /* WIN32 */ if (status) { #ifndef WIN32 if (WIFEXITED(status)) #endif /* !WIN32 */ fprintf(stderr, "Command \"%s\" exited with status %d.\n", job->printer->command, WEXITSTATUS(status)); #ifndef WIN32 else fprintf(stderr, "Command \"%s\" terminated with signal %d.\n", job->printer->command, WTERMSIG(status)); #endif /* !WIN32 */ job->state = IPP_JSTATE_ABORTED; } else if (status < 0) job->state = IPP_JSTATE_ABORTED; else fprintf(stderr, "Command \"%s\" completed successfully.\n", job->printer->command); /* * Make sure processing takes at least 5 seconds... */ time(&end); if ((end - start) < 5) sleep(5); } else { /* * Sleep for a random amount of time to simulate job processing. */ sleep((unsigned)(5 + (rand() % 11))); } if (job->cancel) job->state = IPP_JSTATE_CANCELED; else if (job->state == IPP_JSTATE_PROCESSING) job->state = IPP_JSTATE_COMPLETED; job->completed = time(NULL); job->printer->state = IPP_PSTATE_IDLE; job->printer->active_job = NULL; return (NULL); } #ifdef HAVE_DNSSD /* * 'register_printer()' - Register a printer object via Bonjour. */ static int /* O - 1 on success, 0 on error */ register_printer( _ipp_printer_t *printer, /* I - Printer */ const char *location, /* I - Location */ const char *make, /* I - Manufacturer */ const char *model, /* I - Model name */ const char *formats, /* I - Supported formats */ const char *adminurl, /* I - Web interface URL */ const char *uuid, /* I - Printer UUID */ int color, /* I - 1 = color, 0 = monochrome */ int duplex, /* I - 1 = duplex, 0 = simplex */ const char *subtype) /* I - Service subtype */ { DNSServiceErrorType error; /* Error from Bonjour */ char make_model[256],/* Make and model together */ product[256], /* Product string */ regtype[256]; /* Bonjour service type */ /* * Build the TXT record for IPP... */ snprintf(make_model, sizeof(make_model), "%s %s", make, model); snprintf(product, sizeof(product), "(%s)", model); TXTRecordCreate(&(printer->ipp_txt), 1024, NULL); TXTRecordSetValue(&(printer->ipp_txt), "rp", 9, "ipp/print"); TXTRecordSetValue(&(printer->ipp_txt), "ty", (uint8_t)strlen(make_model), make_model); TXTRecordSetValue(&(printer->ipp_txt), "adminurl", (uint8_t)strlen(adminurl), adminurl); if (*location) TXTRecordSetValue(&(printer->ipp_txt), "note", (uint8_t)strlen(location), location); TXTRecordSetValue(&(printer->ipp_txt), "product", (uint8_t)strlen(product), product); TXTRecordSetValue(&(printer->ipp_txt), "pdl", (uint8_t)strlen(formats), formats); TXTRecordSetValue(&(printer->ipp_txt), "Color", 1, color ? "T" : "F"); TXTRecordSetValue(&(printer->ipp_txt), "Duplex", 1, duplex ? "T" : "F"); TXTRecordSetValue(&(printer->ipp_txt), "usb_MFG", (uint8_t)strlen(make), make); TXTRecordSetValue(&(printer->ipp_txt), "usb_MDL", (uint8_t)strlen(model), model); TXTRecordSetValue(&(printer->ipp_txt), "UUID", (uint8_t)strlen(uuid), uuid); # ifdef HAVE_SSL TXTRecordSetValue(&(printer->ipp_txt), "TLS", 3, "1.2"); # endif /* HAVE_SSL */ /* * Create a shared service reference for Bonjour... */ if ((error = DNSServiceCreateConnection(&(printer->common_ref))) != kDNSServiceErr_NoError) { fprintf(stderr, "Unable to create mDNSResponder connection: %d\n", error); return (0); } /* * Register the _printer._tcp (LPD) service type with a port number of 0 to * defend our service name but not actually support LPD... */ printer->printer_ref = printer->common_ref; if ((error = DNSServiceRegister(&(printer->printer_ref), kDNSServiceFlagsShareConnection, 0 /* interfaceIndex */, printer->dnssd_name, "_printer._tcp", NULL /* domain */, NULL /* host */, 0 /* port */, 0 /* txtLen */, NULL /* txtRecord */, (DNSServiceRegisterReply)dnssd_callback, printer)) != kDNSServiceErr_NoError) { fprintf(stderr, "Unable to register \"%s._printer._tcp\": %d\n", printer->dnssd_name, error); return (0); } /* * Then register the _ipp._tcp (IPP) service type with the real port number to * advertise our IPP printer... */ printer->ipp_ref = printer->common_ref; if (subtype && *subtype) snprintf(regtype, sizeof(regtype), "_ipp._tcp,%s", subtype); else strlcpy(regtype, "_ipp._tcp", sizeof(regtype)); if ((error = DNSServiceRegister(&(printer->ipp_ref), kDNSServiceFlagsShareConnection, 0 /* interfaceIndex */, printer->dnssd_name, regtype, NULL /* domain */, NULL /* host */, htons(printer->port), TXTRecordGetLength(&(printer->ipp_txt)), TXTRecordGetBytesPtr(&(printer->ipp_txt)), (DNSServiceRegisterReply)dnssd_callback, printer)) != kDNSServiceErr_NoError) { fprintf(stderr, "Unable to register \"%s.%s\": %d\n", printer->dnssd_name, regtype, error); return (0); } # ifdef HAVE_SSL /* * Then register the _ipps._tcp (IPP) service type with the real port number to * advertise our IPP printer... */ printer->ipps_ref = printer->common_ref; if (subtype && *subtype) snprintf(regtype, sizeof(regtype), "_ipps._tcp,%s", subtype); else strlcpy(regtype, "_ipps._tcp", sizeof(regtype)); if ((error = DNSServiceRegister(&(printer->ipps_ref), kDNSServiceFlagsShareConnection, 0 /* interfaceIndex */, printer->dnssd_name, regtype, NULL /* domain */, NULL /* host */, htons(printer->port), TXTRecordGetLength(&(printer->ipp_txt)), TXTRecordGetBytesPtr(&(printer->ipp_txt)), (DNSServiceRegisterReply)dnssd_callback, printer)) != kDNSServiceErr_NoError) { fprintf(stderr, "Unable to register \"%s.%s\": %d\n", printer->dnssd_name, regtype, error); return (0); } # endif /* HAVE_SSL */ /* * Similarly, register the _http._tcp,_printer (HTTP) service type with the * real port number to advertise our IPP printer... */ printer->http_ref = printer->common_ref; if ((error = DNSServiceRegister(&(printer->http_ref), kDNSServiceFlagsShareConnection, 0 /* interfaceIndex */, printer->dnssd_name, "_http._tcp,_printer", NULL /* domain */, NULL /* host */, htons(printer->port), 0 /* txtLen */, NULL, /* txtRecord */ (DNSServiceRegisterReply)dnssd_callback, printer)) != kDNSServiceErr_NoError) { fprintf(stderr, "Unable to register \"%s.%s\": %d\n", printer->dnssd_name, regtype, error); return (0); } return (1); } #endif /* HAVE_DNSSD */ /* * 'respond_http()' - Send a HTTP response. */ int /* O - 1 on success, 0 on failure */ respond_http( _ipp_client_t *client, /* I - Client */ http_status_t code, /* I - HTTP status of response */ const char *content_encoding, /* I - Content-Encoding of response */ const char *type, /* I - MIME media type of response */ size_t length) /* I - Length of response */ { char message[1024]; /* Text message */ fprintf(stderr, "%s %s\n", client->hostname, httpStatus(code)); if (code == HTTP_STATUS_CONTINUE) { /* * 100-continue doesn't send any headers... */ return (httpWriteResponse(client->http, HTTP_STATUS_CONTINUE) == 0); } /* * Format an error message... */ if (!type && !length && code != HTTP_STATUS_OK && code != HTTP_STATUS_SWITCHING_PROTOCOLS) { snprintf(message, sizeof(message), "%d - %s\n", code, httpStatus(code)); type = "text/plain"; length = strlen(message); } else message[0] = '\0'; /* * Send the HTTP response header... */ httpClearFields(client->http); if (code == HTTP_STATUS_METHOD_NOT_ALLOWED || client->operation == HTTP_STATE_OPTIONS) httpSetField(client->http, HTTP_FIELD_ALLOW, "GET, HEAD, OPTIONS, POST"); if (type) { if (!strcmp(type, "text/html")) httpSetField(client->http, HTTP_FIELD_CONTENT_TYPE, "text/html; charset=utf-8"); else httpSetField(client->http, HTTP_FIELD_CONTENT_TYPE, type); if (content_encoding) httpSetField(client->http, HTTP_FIELD_CONTENT_ENCODING, content_encoding); } httpSetLength(client->http, length); if (httpWriteResponse(client->http, code) < 0) return (0); /* * Send the response data... */ if (message[0]) { /* * Send a plain text message. */ if (httpPrintf(client->http, "%s", message) < 0) return (0); if (httpWrite2(client->http, "", 0) < 0) return (0); } else if (client->response) { /* * Send an IPP response... */ debug_attributes("Response", client->response, 2); ippSetState(client->response, IPP_STATE_IDLE); if (ippWrite(client->http, client->response) != IPP_STATE_DATA) return (0); } return (1); } /* * 'respond_ipp()' - Send an IPP response. */ static void respond_ipp(_ipp_client_t *client, /* I - Client */ ipp_status_t status, /* I - status-code */ const char *message, /* I - printf-style status-message */ ...) /* I - Additional args as needed */ { const char *formatted = NULL; /* Formatted message */ ippSetStatusCode(client->response, status); if (message) { va_list ap; /* Pointer to additional args */ ipp_attribute_t *attr; /* New status-message attribute */ va_start(ap, message); if ((attr = ippFindAttribute(client->response, "status-message", IPP_TAG_TEXT)) != NULL) ippSetStringfv(client->response, &attr, 0, message, ap); else attr = ippAddStringfv(client->response, IPP_TAG_OPERATION, IPP_TAG_TEXT, "status-message", NULL, message, ap); va_end(ap); formatted = ippGetString(attr, 0, NULL); } if (formatted) fprintf(stderr, "%s %s %s (%s)\n", client->hostname, ippOpString(client->operation_id), ippErrorString(status), formatted); else fprintf(stderr, "%s %s %s\n", client->hostname, ippOpString(client->operation_id), ippErrorString(status)); } /* * 'respond_unsupported()' - Respond with an unsupported attribute. */ static void respond_unsupported( _ipp_client_t *client, /* I - Client */ ipp_attribute_t *attr) /* I - Atribute */ { ipp_attribute_t *temp; /* Copy of attribute */ respond_ipp(client, IPP_STATUS_ERROR_ATTRIBUTES_OR_VALUES, "Unsupported %s %s%s value.", ippGetName(attr), ippGetCount(attr) > 1 ? "1setOf " : "", ippTagString(ippGetValueTag(attr))); temp = ippCopyAttribute(client->response, attr, 0); ippSetGroupTag(client->response, &temp, IPP_TAG_UNSUPPORTED_GROUP); } /* * 'run_printer()' - Run the printer service. */ static void run_printer(_ipp_printer_t *printer) /* I - Printer */ { int num_fds; /* Number of file descriptors */ struct pollfd polldata[3]; /* poll() data */ int timeout; /* Timeout for poll() */ _ipp_client_t *client; /* New client */ /* * Setup poll() data for the Bonjour service socket and IPv4/6 listeners... */ polldata[0].fd = printer->ipv4; polldata[0].events = POLLIN; polldata[1].fd = printer->ipv6; polldata[1].events = POLLIN; num_fds = 2; #ifdef HAVE_DNSSD polldata[num_fds ].fd = DNSServiceRefSockFD(printer->common_ref); polldata[num_fds ++].events = POLLIN; #endif /* HAVE_DNSSD */ /* * Loop until we are killed or have a hard error... */ for (;;) { if (cupsArrayCount(printer->jobs)) timeout = 10; else timeout = -1; if (poll(polldata, (nfds_t)num_fds, timeout) < 0 && errno != EINTR) { perror("poll() failed"); break; } if (polldata[0].revents & POLLIN) { if ((client = create_client(printer, printer->ipv4)) != NULL) { if (!_cupsThreadCreate((_cups_thread_func_t)process_client, client)) { perror("Unable to create client thread"); delete_client(client); } } } if (polldata[1].revents & POLLIN) { if ((client = create_client(printer, printer->ipv6)) != NULL) { if (!_cupsThreadCreate((_cups_thread_func_t)process_client, client)) { perror("Unable to create client thread"); delete_client(client); } } } #ifdef HAVE_DNSSD if (polldata[2].revents & POLLIN) DNSServiceProcessResult(printer->common_ref); #endif /* HAVE_DNSSD */ /* * Clean out old jobs... */ clean_jobs(printer); } } /* * 'time_string()' - Return the local time in hours, minutes, and seconds. */ static char * time_string(time_t tv, /* I - Time value */ char *buffer, /* I - Buffer */ size_t bufsize) /* I - Size of buffer */ { struct tm *curtime = localtime(&tv); /* Local time */ strftime(buffer, bufsize, "%X", curtime); return (buffer); } /* * 'usage()' - Show program usage. */ static void usage(int status) /* O - Exit status */ { if (!status) { puts(CUPS_SVERSION " - Copyright 2010-2013 by Apple Inc. All rights " "reserved."); puts(""); } puts("Usage: ippserver [options] \"name\""); puts(""); puts("Options:"); puts("-2 Supports 2-sided printing (default=1-sided)"); puts("-M manufacturer Manufacturer name (default=Test)"); puts("-P PIN printing mode"); puts("-c command Run command for every print job"); printf("-d spool-directory Spool directory " "(default=/tmp/ippserver.%d)\n", (int)getpid()); puts("-f type/subtype[,...] List of supported types " "(default=application/pdf,image/jpeg)"); puts("-h Show program help"); puts("-i iconfile.png PNG icon file (default=printer.png)"); puts("-k Keep job spool files"); puts("-l location Location of printer (default=empty string)"); puts("-m model Model name (default=Printer)"); puts("-n hostname Hostname for printer"); puts("-p port Port number (default=auto)"); #ifdef HAVE_DNSSD puts("-r subtype Bonjour service subtype (default=_print)"); #endif /* HAVE_DNSSD */ puts("-s speed[,color-speed] Speed in pages per minute (default=10,0)"); puts("-v[vvv] Be (very) verbose"); exit(status); } /* * 'valid_doc_attributes()' - Determine whether the document attributes are * valid. * * When one or more document attributes are invalid, this function adds a * suitable response and attributes to the unsupported group. */ static int /* O - 1 if valid, 0 if not */ valid_doc_attributes( _ipp_client_t *client) /* I - Client */ { int valid = 1; /* Valid attributes? */ ipp_op_t op = ippGetOperation(client->request); /* IPP operation */ const char *op_name = ippOpString(op); /* IPP operation name */ ipp_attribute_t *attr, /* Current attribute */ *supported; /* xxx-supported attribute */ const char *compression = NULL, /* compression value */ *format = NULL; /* document-format value */ /* * Check operation attributes... */ if ((attr = ippFindAttribute(client->request, "compression", IPP_TAG_ZERO)) != NULL) { /* * If compression is specified, only accept a supported value in a Print-Job * or Send-Document request... */ compression = ippGetString(attr, 0, NULL); supported = ippFindAttribute(client->printer->attrs, "compression-supported", IPP_TAG_KEYWORD); if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_KEYWORD || ippGetGroupTag(attr) != IPP_TAG_OPERATION || (op != IPP_OP_PRINT_JOB && op != IPP_OP_SEND_DOCUMENT && op != IPP_OP_VALIDATE_JOB) || !ippContainsString(supported, compression)) { respond_unsupported(client, attr); valid = 0; } else { fprintf(stderr, "%s %s compression=\"%s\"\n", client->hostname, op_name, compression); ippAddString(client->request, IPP_TAG_JOB, IPP_TAG_KEYWORD, "compression-supplied", NULL, compression); if (strcmp(compression, "none")) { if (Verbosity) fprintf(stderr, "Receiving job file with \"%s\" compression.\n", compression); httpSetField(client->http, HTTP_FIELD_CONTENT_ENCODING, compression); } } } /* * Is it a format we support? */ if ((attr = ippFindAttribute(client->request, "document-format", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_MIMETYPE || ippGetGroupTag(attr) != IPP_TAG_OPERATION) { respond_unsupported(client, attr); valid = 0; } else { format = ippGetString(attr, 0, NULL); fprintf(stderr, "%s %s document-format=\"%s\"\n", client->hostname, op_name, format); ippAddString(client->request, IPP_TAG_JOB, IPP_TAG_MIMETYPE, "document-format-supplied", NULL, format); } } else { format = ippGetString(ippFindAttribute(client->printer->attrs, "document-format-default", IPP_TAG_MIMETYPE), 0, NULL); if (!format) format = "application/octet-stream"; /* Should never happen */ attr = ippAddString(client->request, IPP_TAG_OPERATION, IPP_TAG_MIMETYPE, "document-format", NULL, format); } if (!strcmp(format, "application/octet-stream") && (ippGetOperation(client->request) == IPP_OP_PRINT_JOB || ippGetOperation(client->request) == IPP_OP_SEND_DOCUMENT)) { /* * Auto-type the file using the first 8 bytes of the file... */ unsigned char header[8]; /* First 8 bytes of file */ memset(header, 0, sizeof(header)); httpPeek(client->http, (char *)header, sizeof(header)); if (!memcmp(header, "%PDF", 4)) format = "application/pdf"; else if (!memcmp(header, "%!", 2)) format = "application/postscript"; else if (!memcmp(header, "\377\330\377", 3) && header[3] >= 0xe0 && header[3] <= 0xef) format = "image/jpeg"; else if (!memcmp(header, "\211PNG", 4)) format = "image/png"; else if (!memcmp(header, "RAS2", 4)) format = "image/pwg-raster"; else if (!memcmp(header, "UNIRAST", 8)) format = "image/urf"; else format = NULL; if (format) { fprintf(stderr, "%s %s Auto-typed document-format=\"%s\"\n", client->hostname, op_name, format); ippAddString(client->request, IPP_TAG_JOB, IPP_TAG_MIMETYPE, "document-format-detected", NULL, format); } } if (op != IPP_OP_CREATE_JOB && (supported = ippFindAttribute(client->printer->attrs, "document-format-supported", IPP_TAG_MIMETYPE)) != NULL && !ippContainsString(supported, format)) { respond_unsupported(client, attr); valid = 0; } /* * document-name */ if ((attr = ippFindAttribute(client->request, "document-name", IPP_TAG_NAME)) != NULL) ippAddString(client->request, IPP_TAG_JOB, IPP_TAG_NAME, "document-name-supplied", NULL, ippGetString(attr, 0, NULL)); return (valid); } /* * 'valid_job_attributes()' - Determine whether the job attributes are valid. * * When one or more job attributes are invalid, this function adds a suitable * response and attributes to the unsupported group. */ static int /* O - 1 if valid, 0 if not */ valid_job_attributes( _ipp_client_t *client) /* I - Client */ { int i, /* Looping var */ valid = 1; /* Valid attributes? */ ipp_attribute_t *attr, /* Current attribute */ *supported; /* xxx-supported attribute */ /* * Check operation attributes... */ valid = valid_doc_attributes(client); /* * Check the various job template attributes... */ if ((attr = ippFindAttribute(client->request, "copies", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_INTEGER || ippGetInteger(attr, 0) < 1 || ippGetInteger(attr, 0) > 999) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "ipp-attribute-fidelity", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_BOOLEAN) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "job-hold-until", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || (ippGetValueTag(attr) != IPP_TAG_NAME && ippGetValueTag(attr) != IPP_TAG_NAMELANG && ippGetValueTag(attr) != IPP_TAG_KEYWORD) || strcmp(ippGetString(attr, 0, NULL), "no-hold")) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "job-impressions", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_INTEGER || ippGetInteger(attr, 0) < 0) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "job-name", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || (ippGetValueTag(attr) != IPP_TAG_NAME && ippGetValueTag(attr) != IPP_TAG_NAMELANG)) { respond_unsupported(client, attr); valid = 0; } ippSetGroupTag(client->request, &attr, IPP_TAG_JOB); } else ippAddString(client->request, IPP_TAG_JOB, IPP_TAG_NAME, "job-name", NULL, "Untitled"); if ((attr = ippFindAttribute(client->request, "job-priority", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_INTEGER || ippGetInteger(attr, 0) < 1 || ippGetInteger(attr, 0) > 100) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "job-sheets", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || (ippGetValueTag(attr) != IPP_TAG_NAME && ippGetValueTag(attr) != IPP_TAG_NAMELANG && ippGetValueTag(attr) != IPP_TAG_KEYWORD) || strcmp(ippGetString(attr, 0, NULL), "none")) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "media", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || (ippGetValueTag(attr) != IPP_TAG_NAME && ippGetValueTag(attr) != IPP_TAG_NAMELANG && ippGetValueTag(attr) != IPP_TAG_KEYWORD)) { respond_unsupported(client, attr); valid = 0; } else { for (i = 0; i < (int)(sizeof(media_supported) / sizeof(media_supported[0])); i ++) if (!strcmp(ippGetString(attr, 0, NULL), media_supported[i])) break; if (i >= (int)(sizeof(media_supported) / sizeof(media_supported[0]))) { respond_unsupported(client, attr); valid = 0; } } } if ((attr = ippFindAttribute(client->request, "media-col", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_BEGIN_COLLECTION) { respond_unsupported(client, attr); valid = 0; } /* TODO: check for valid media-col */ } if ((attr = ippFindAttribute(client->request, "multiple-document-handling", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_KEYWORD || (strcmp(ippGetString(attr, 0, NULL), "separate-documents-uncollated-copies") && strcmp(ippGetString(attr, 0, NULL), "separate-documents-collated-copies"))) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "orientation-requested", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_ENUM || ippGetInteger(attr, 0) < IPP_ORIENT_PORTRAIT || ippGetInteger(attr, 0) > IPP_ORIENT_REVERSE_PORTRAIT) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "page-ranges", IPP_TAG_ZERO)) != NULL) { if (ippGetValueTag(attr) != IPP_TAG_RANGE) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "print-quality", IPP_TAG_ZERO)) != NULL) { if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_ENUM || ippGetInteger(attr, 0) < IPP_QUALITY_DRAFT || ippGetInteger(attr, 0) > IPP_QUALITY_HIGH) { respond_unsupported(client, attr); valid = 0; } } if ((attr = ippFindAttribute(client->request, "printer-resolution", IPP_TAG_ZERO)) != NULL) { supported = ippFindAttribute(client->printer->attrs, "printer-resolution-supported", IPP_TAG_RESOLUTION); if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_RESOLUTION || !supported) { respond_unsupported(client, attr); valid = 0; } else { int count, /* Number of supported values */ xdpi, /* Horizontal resolution for job template attribute */ ydpi, /* Vertical resolution for job template attribute */ sydpi; /* Vertical resolution for supported value */ ipp_res_t units, /* Units for job template attribute */ sunits; /* Units for supported value */ xdpi = ippGetResolution(attr, 0, &ydpi, &units); count = ippGetCount(supported); for (i = 0; i < count; i ++) { if (xdpi == ippGetResolution(supported, i, &sydpi, &sunits) && ydpi == sydpi && units == sunits) break; } if (i >= count) { respond_unsupported(client, attr); valid = 0; } } } if ((attr = ippFindAttribute(client->request, "sides", IPP_TAG_ZERO)) != NULL) { const char *sides = ippGetString(attr, 0, NULL); /* "sides" value... */ if (ippGetCount(attr) != 1 || ippGetValueTag(attr) != IPP_TAG_KEYWORD) { respond_unsupported(client, attr); valid = 0; } else if ((supported = ippFindAttribute(client->printer->attrs, "sides-supported", IPP_TAG_KEYWORD)) != NULL) { if (!ippContainsString(supported, sides)) { respond_unsupported(client, attr); valid = 0; } } else if (strcmp(sides, "one-sided")) { respond_unsupported(client, attr); valid = 0; } } return (valid); } /* * End of "$Id: ippserver.c 12142 2014-08-30 02:35:43Z msweet $". */