From 16901f7134047b9681fd579ff9c9039c2f6ebc7a Mon Sep 17 00:00:00 2001
From: "James R. Barlow" <jim@purplerock.ca>
Date: Tue, 9 Aug 2016 15:46:24 -0700
Subject: [PATCH] Accept input from stdin if input filename is '-'

---
 ocrmypdf/main.py | 19 +++++++++++++++++--
 1 file changed, 17 insertions(+), 2 deletions(-)

diff --git a/ocrmypdf/main.py b/ocrmypdf/main.py
index f962e9db..96f07141 100755
--- a/ocrmypdf/main.py
+++ b/ocrmypdf/main.py
@@ -459,9 +459,9 @@ def triage_image_file(input_file, output_file, log):
 
 
 @transform(
-    input=options.input_file,
+    input=os.path.join(work_folder, 'origin'),
     filter=formatter('(?i)'),
-    output=os.path.join(work_folder, '{basename[0]}.pdf'),
+    output=os.path.join(work_folder, 'origin.pdf'),
     extras=[_log])
 def triage(
         input_file,
@@ -1298,11 +1298,26 @@ def traverse_ruffus_exception(e_args):
 
 
 def run_pipeline():
+    # Any changes to options will not take effect for options that are already
+    # bound to function parameters in the pipeline. (For example
+    # options.input_file, options.pdf_renderer are already bound.)
+    global options
     if not options.jobs:
         options.jobs = available_cpu_count()
     try:
         options.history_file = os.path.join(
             work_folder, 'ruffus_history.sqlite')
+        start_input_file = os.path.join(
+            work_folder, 'origin')
+
+        if options.input_file == '-':
+            # stdin
+            with open(start_input_file, 'wb') as stream_buffer:
+                from shutil import copyfileobj
+                copyfileobj(sys.stdin.buffer, stream_buffer)
+        else:
+            re_symlink(options.input_file, start_input_file, log)
+
         cmdline.run(options)
     except ruffus_exceptions.RethrownJobError as e:
         if options.verbose: