Changeset 57bc2dc for server

Timestamp:

Jan 21, 2012, 5:20:10 PM (12 years ago)

Author:

Jessica B. Hamrick <jhamrick@…>

Branches:

no-cups

Children:

1b6dc13, 441604f

Parents:

f0807b8

git-author:

Jessica B. Hamrick <jhamrick@…> (01/21/12 17:19:59)

git-committer:

Jessica B. Hamrick <jhamrick@…> (01/21/12 17:20:10)

Message:

Add support for print-job and verify-job in printer.py

Location:

server/lib/gutenbach/server

Files:

• job.py (modified) (2 diffs)
• printer.py (modified) (14 diffs)

server/lib/gutenbach/server/job.py

@@ -53 +53 @@
         """
         return cmp(self.priority, other.priority)
+
+    def __del__(self):
+        if self.player:
+            self.player.mplayer_stop()
+            self.player = None
+        if self.document and not self.document.closed:
+            self.document.close()
+            self.document = None
+
+        self.id = None
+        self.creator = None
+        self.name = None
+        self.priority = None
+        self._why_done = None
 
     ######################################################################
@@ -259 +273 @@
         if not hasattr(document, "close"):
             raise errors.InvalidDocument, "no close attribute"
+        if not hasattr(document, "closed"):
+            raise errors.InvalidDocument, "no closed attribute"
 
     def spool(self, document=None):

server/lib/gutenbach/server/printer.py

@@ -9 +9 @@
 import traceback
 import sys
+import tempfile
 from . import sync
 
@@ -361 +362 @@
     ######################################################################
 
-    def print_job(self):
-        pass
-
-    def validate_job(self):
-        pass
+    def print_job(self, document, document_name=None, document_format=None,
+                  document_natural_language=None, requesting_user_name=None,
+                  compression=None, job_name=None, job_k_octets=None):
+
+        # create the job
+        job_id = self.create_job(
+            requesting_user_name=requesting_user_name,
+            job_name=job_name,
+            job_k_octets=job_k_octets)
+        
+        # send the document
+        self.send_document(
+            job_id,
+            document,
+            document_name=document_name,
+            document_format=document_format,
+            document_natural_language=document_natural_language,
+            requesting_user_name=requesting_user_name,
+            compression=compression,
+            last_document=False)
+
+        return job_id
+
+    def verify_job(self, document_name=None, document_format=None,
+                  document_natural_language=None, requesting_user_name=None,
+                  compression=None, job_name=None, job_k_octets=None):
+
+        job_id = self._next_job_id
+        job = GutenbachJob(
+            job_id,
+            creator=requesting_user_name,
+            name=job_name)
+        job.spool(tempfile.TemporaryFile())
+        job.abort()
+        del job
 
     def get_jobs(self, requesting_user_name=None, which_jobs=None,
@@ -397 +428 @@
         pass
 
-    def create_job(self, requesting_user_name=None, job_name=None, job_k_octets=None):
+    def create_job(self, requesting_user_name=None, job_name=None,
+                   job_k_octets=None):
+
         job_id = self._next_job_id
         self._next_job_id += 1
@@ -405 +438 @@
             creator=requesting_user_name,
             name=job_name)
-        
+
         self.jobs[job_id] = job
         self.pending_jobs.append(job_id)
@@ -425 +458 @@
         self.paused = True
 
-
-
     @sync
     def resume_printer(self):
@@ -441 +472 @@
         self.paused = False
 
+    @sync
     def get_printer_attributes(self, requested_attributes=None):
         if requested_attributes is None:
@@ -452 +484 @@
         return attributes
 
+    @sync
     def set_printer_attributes(self, job_id, attributes):
         for attr in attributes:
@@ -459 +492 @@
                 raise ipp.errors.ClientErrorAttributes
 
+    @sync
     def cancel_job(self, job_id, requesting_user_name=None):
         job = self.get_job(job_id)
@@ -467 +501 @@
             raise
 
+    @sync
     def send_document(self, job_id, document, document_name=None,
                       document_format=None, document_natural_language=None,
@@ -475 +510 @@
         job.spool(document)
 
+    @sync
     def send_uri(self, job_id, document_uri, document_name=None,
                  document_format=None, document_natural_language=None,
@@ -484 +520 @@
         #job.spool_uri(document_uri)
 
+    @sync
     def get_job_attributes(self, job_id, requested_attributes=None):
         if requested_attributes is None:
@@ -495 +532 @@
         return attributes
 
+    @sync
     def set_job_attributes(self, job_id, attributes):
         job = self.get_job(job_id)
@@ -504 +542 @@
             elif attr == "job-originating-user-name":
                 job.creator = attributes[attr] # XXX: do we want this?
-                
+
+    @sync
     def restart_job(self, job_id, requesting_user_name=None):
         job = self.get_job(job_id)
@@ -513 +552 @@
             raise ipp.errors.ClientErrorNotPossible
 
-        with self.lock:
-            self.finished_jobs.remove(job_id)
-            self.pending_jobs.append(job_id)
-
+        self.finished_jobs.remove(job_id)
+        self.pending_jobs.append(job_id)
+
+    @sync
     def promote_job(self, job_id, requesting_user_name=None):
         # According to RFC 3998, we need to put the job at the front