[478ca74] | 1 | #!/usr/bin/python |
---|
| 2 | |
---|
| 3 | import logging, BaseHTTPServer |
---|
[c5e88d0] | 4 | from ipprequest import * |
---|
| 5 | import ippconstants as const |
---|
[478ca74] | 6 | |
---|
| 7 | logging.basicConfig(level=logging.DEBUG) |
---|
| 8 | |
---|
| 9 | class GutenbachIPPHandler(BaseHTTPServer.BaseHTTPRequestHandler): |
---|
| 10 | def handle_one_request(self): |
---|
| 11 | self.raw_requestline = self.rfile.readline() |
---|
| 12 | if not self.raw_requestline: |
---|
| 13 | self.close_connection = 1 |
---|
| 14 | return |
---|
| 15 | if not self.parse_request(): # An error code has been sent, just exit |
---|
| 16 | return |
---|
| 17 | self.handle_ipp() |
---|
| 18 | |
---|
| 19 | def handle_ipp(self): |
---|
[c5e88d0] | 20 | length = int(self.headers.getheader('content-length', 0)) |
---|
| 21 | request = IPPRequest(request=self.rfile, |
---|
| 22 | length=length) |
---|
| 23 | |
---|
| 24 | response_kwargs = {} |
---|
| 25 | response_kwargs['version'] = request.version |
---|
| 26 | response_kwargs['request_id'] = request.request_id |
---|
| 27 | response_kwargs = self.get_jobs(request, response_kwargs) |
---|
| 28 | response = IPPRequest(**response_kwargs) |
---|
[478ca74] | 29 | |
---|
| 30 | self.send_response(200, "o hai") |
---|
[c5e88d0] | 31 | self.send_header("Content-Type", "application/ipp") |
---|
[478ca74] | 32 | self.send_header("Connection", "close") |
---|
| 33 | self.end_headers() |
---|
[c5e88d0] | 34 | self.wfile.write(response.toBinaryData()) |
---|
| 35 | |
---|
[16055f9] | 36 | # def get_jobs(self, request, response_kwargs): |
---|
| 37 | # """get-jobs response""" |
---|
| 38 | |
---|
| 39 | # job_attributes = [IPPAttribute('job-id', |
---|
| 40 | # [IPPValue(IPPTags.INTEGER, |
---|
| 41 | # 12345, |
---|
| 42 | # unpack=False)]), |
---|
| 43 | # IPPAttribute('job-name', |
---|
| 44 | # [IPPValue(IPPTags.NAME_WITHOUT_LANGUAGE, |
---|
| 45 | # 'foo', |
---|
| 46 | # unpack=False)]), |
---|
| 47 | # IPPAttribute('job-originating-user-name', |
---|
| 48 | # [IPPValue(IPPTags.NAME_WITHOUT_LANGUAGE, |
---|
| 49 | # 'jhamrick', |
---|
| 50 | # unpack=False)]), |
---|
| 51 | # IPPAttribute('job-k-octets', |
---|
| 52 | # [IPPValue(IPPTags.INTEGER, |
---|
| 53 | # 1, |
---|
| 54 | # unpack=False)]), |
---|
| 55 | # IPPAttribute('job-state', |
---|
| 56 | # [IPPValue(IPPTags.ENUM, |
---|
| 57 | # const.IPP_JOB_HELD, |
---|
| 58 | # unpack=False)]), |
---|
| 59 | # IPPAttribute('job-printer-uri', |
---|
| 60 | # [IPPValue(IPPTags.URI, |
---|
| 61 | # 'http://localhost:8000/printers/foo', |
---|
| 62 | # unpack=False)])] |
---|
| 63 | |
---|
| 64 | |
---|
| 65 | # #req_op_attributes = request.getAttributeGroup(IPPTags.OPERATION_ATTRIBUTES_TAG) |
---|
| 66 | # #print req_op_attributes |
---|
| 67 | # #printer_uri = req_op_attributes[0].getAttribute('printer-uri') |
---|
| 68 | |
---|
| 69 | # op_attributes = [IPPAttribute('attributes-charset', |
---|
| 70 | # [IPPValue(IPPTags.CHARSET, |
---|
| 71 | # 'utf-8', |
---|
| 72 | # unpack=False)]), |
---|
| 73 | # IPPAttribute('attributes-natural-language', |
---|
| 74 | # [IPPValue(IPPTags.NATURAL_LANGUAGE, |
---|
| 75 | # 'en-us', |
---|
| 76 | # unpack=False)])] |
---|
[c5e88d0] | 77 | |
---|
[16055f9] | 78 | # job_attribute_group = IPPAttributeGroup(IPPTags.JOB_ATTRIBUTES_TAG, |
---|
| 79 | # job_attributes) |
---|
| 80 | # op_attributes_group = IPPAttributeGroup(IPPTags.OPERATION_ATTRIBUTES_TAG, |
---|
| 81 | # op_attributes) |
---|
| 82 | # response_kwargs['attribute_groups'] = [op_attributes_group,job_attribute_group] |
---|
| 83 | # response_kwargs['operation_id'] = const.IPP_OK |
---|
| 84 | |
---|
| 85 | # return response_kwargs |
---|
| 86 | |
---|
| 87 | ##### Printer Commands |
---|
| 88 | |
---|
| 89 | def print_job(self, request): |
---|
| 90 | pass |
---|
| 91 | |
---|
| 92 | def validate_job(self, request): |
---|
| 93 | pass |
---|
| 94 | |
---|
| 95 | def get_printer_attributes(self, request): |
---|
| 96 | pass |
---|
| 97 | |
---|
| 98 | def get_jobs(self, request): |
---|
| 99 | pass |
---|
| 100 | |
---|
| 101 | def print_uri(self, request): |
---|
| 102 | pass |
---|
| 103 | |
---|
| 104 | def create_job(self, request): |
---|
| 105 | pass |
---|
| 106 | |
---|
| 107 | def cups_get_default(self, request): |
---|
| 108 | pass |
---|
| 109 | |
---|
| 110 | def cups_get_printers(self, request): |
---|
| 111 | pass |
---|
| 112 | |
---|
| 113 | def pause_printer(self, request): |
---|
| 114 | pass |
---|
| 115 | |
---|
| 116 | def resume_printer(self, request): |
---|
| 117 | pass |
---|
| 118 | |
---|
| 119 | def set_printer_attributes(self, request): |
---|
| 120 | pass |
---|
| 121 | |
---|
| 122 | ##### Job Commands |
---|
| 123 | |
---|
| 124 | def cancel_job(self, request): |
---|
| 125 | pass |
---|
| 126 | |
---|
| 127 | def get_job_attributes(self, request): |
---|
| 128 | pass |
---|
| 129 | |
---|
| 130 | def send_document(self, request): |
---|
| 131 | pass |
---|
| 132 | |
---|
| 133 | def send_uri(self, request): |
---|
| 134 | pass |
---|
| 135 | |
---|
| 136 | def set_job_attributes(self, request): |
---|
| 137 | pass |
---|
| 138 | |
---|
| 139 | def cups_get_document(self, request): |
---|
| 140 | pass |
---|
| 141 | |
---|
| 142 | def restart_job(self, request): |
---|
| 143 | pass |
---|
| 144 | |
---|
| 145 | def promote_job(self, request): |
---|
| 146 | pass |
---|
[478ca74] | 147 | |
---|
| 148 | if __name__ == '__main__': |
---|
| 149 | server_address = ('', 8000) |
---|
| 150 | httpd = BaseHTTPServer.HTTPServer(server_address, GutenbachIPPHandler) |
---|
| 151 | httpd.serve_forever() |
---|