Changeset c5e88d0

Timestamp:

Mar 5, 2011, 7:14:21 PM (14 years ago)

Author:

Jessica B. Hamrick <jhamrick@…>

Branches:

no-cups

Children:

16055f9

Parents:

574aee4

git-author:

Jessica B. Hamrick <jhamrick@…> (03/05/11 19:14:21)

git-committer:

Jessica B. Hamrick <jhamrick@…> (03/05/11 19:14:21)

Message:

get-jobs response in GutenbachIPPserver

Location:

server/lib

Files:

• ipprequest.py (modified) (5 diffs)
• server.py (modified) (2 diffs)

server/lib/ipprequest.py

@@ -69 +69 @@
     """
 
-    def __init__(self, value_tag, value):
+    def __init__(self, value_tag, value, unpack=True):
         """
         Initialize an IPPValue:
@@ -87 +87 @@
         self.value_tag = value_tag
         self.value = value
+
+        if not unpack: return
 
         # out-of-band value tags
@@ -378 +380 @@
         self.attributes = attributes
 
+    def getAttribute(self, name):
+        return filter(lambda x: x.name == name, self.attributes)
+
     def toBinaryData(self):
         """
@@ -462 +467 @@
             # make sure attribute_groups is a list of IPPAttributes
             assert len(attribute_groups) > 0
-            for a in attribute_groups: assert isinstance(a, IPPAttribute)
+            for a in attribute_groups: assert isinstance(a, IPPAttributeGroup)
             
         # if the request isn't None, then we'll read directly from
@@ -575 +580 @@
             self.data = data
 
+    def getAttributeGroup(self, tag):
+        return filter(lambda x: x.attribute_group_tag == tag,
+                      self.attribute_groups)
+
     def toBinaryData(self):
         """

server/lib/server.py

@@ -2 +2 @@
 
 import logging, BaseHTTPServer
-import ipprequest
+from ipprequest import *
+import ippconstants as const
 
 logging.basicConfig(level=logging.DEBUG)
@@ -17 +18 @@
 
     def handle_ipp(self):
-        req = ipprequest.IPPRequest(request=self.rfile,
-                                    length=self.headers.getheader('content-length', 0))
+        length = int(self.headers.getheader('content-length', 0))
+        request = IPPRequest(request=self.rfile,
+                             length=length)
+
+        response_kwargs = {}
+        response_kwargs['version'] = request.version
+        response_kwargs['request_id'] = request.request_id
+        response_kwargs = self.get_jobs(request, response_kwargs)
+        response = IPPRequest(**response_kwargs)
 
         self.send_response(200, "o hai")
-        self.send_header("Content-Type", "text/plain")
+        self.send_header("Content-Type", "application/ipp")
         self.send_header("Connection", "close")
         self.end_headers()
-        self.wfile.write("I got ur request")
+        self.wfile.write(response.toBinaryData())
+
+    def get_jobs(self, request, response_kwargs):
+        """get-jobs response"""
+
+        job_attributes = [IPPAttribute('job-id',
+                                       [IPPValue(IPPTags.INTEGER,
+                                                 12345,
+                                                 unpack=False)]),
+                          IPPAttribute('job-name',
+                                       [IPPValue(IPPTags.NAME_WITHOUT_LANGUAGE,
+                                                 'foo',
+                                                 unpack=False)]),
+                          IPPAttribute('job-originating-user-name',
+                                       [IPPValue(IPPTags.NAME_WITHOUT_LANGUAGE,
+                                                 'jhamrick',
+                                                 unpack=False)]),
+                          IPPAttribute('job-k-octets',
+                                       [IPPValue(IPPTags.INTEGER,
+                                                 1,
+                                                 unpack=False)]),
+                          IPPAttribute('job-state',
+                                       [IPPValue(IPPTags.ENUM,
+                                                 const.IPP_JOB_HELD,
+                                                 unpack=False)]),
+                          IPPAttribute('job-printer-uri',
+                                       [IPPValue(IPPTags.URI,
+                                                 'http://localhost:8000/printers/foo',
+                                                 unpack=False)])]
+
+
+        #req_op_attributes = request.getAttributeGroup(IPPTags.OPERATION_ATTRIBUTES_TAG)
+        #print req_op_attributes
+        #printer_uri = req_op_attributes[0].getAttribute('printer-uri')
+
+        op_attributes = [IPPAttribute('attributes-charset',
+                                      [IPPValue(IPPTags.CHARSET,
+                                                'utf-8',
+                                                unpack=False)]),
+                         IPPAttribute('attributes-natural-language',
+                                      [IPPValue(IPPTags.NATURAL_LANGUAGE,
+                                                'en-us',
+                                                unpack=False)])]
+        
+        job_attribute_group = IPPAttributeGroup(IPPTags.JOB_ATTRIBUTES_TAG,
+                                                job_attributes)
+        op_attributes_group = IPPAttributeGroup(IPPTags.OPERATION_ATTRIBUTES_TAG,
+                                                op_attributes)
+        response_kwargs['attribute_groups'] = [op_attributes_group,job_attribute_group]
+        response_kwargs['operation_id'] = const.IPP_OK
+
+        return response_kwargs
 
 if __name__ == '__main__':