extract async-job-request-runner from http

src/http.coffee

@@ -1,53 +1,7 @@
-buildRequest = require './http/build-request'
 extractResponseBody = require './http/extract-response-body'
-jobs = require './http/jobs'
-
-###
-Allow the server to respond with an async job by enabling the corresponding feature header
-###
-allowAsyncJobResponse = (requestOptions) ->
-  requestOptions.headers ?= {}
-  requestOptions.headers[jobs.ASYNC_JOB_FEATURE_HEADER] = true
-
-###
-Check a response for the signature of an async job
-###
-isAsyncJobResponse = (response) ->
-  (response.status is jobs.JOB_HTTP_STATUS) and (response.body?[jobs.JOB_ROOT_KEY]?.id?)
-
-###
-Given an async job response, mark a request as a monitor on the async job by setting a header
-###
-markAsAsyncJobMonitorRequest = (asyncJobResponse, requestOptions) ->
-  requestOptions.headers ?= {}
-  requestOptions.headers[jobs.JOB_ID_HEADER] = asyncJobResponse.body[jobs.JOB_ROOT_KEY].id
 
 module.exports = (Promise) ->
-  Transaction = require('ag-transaction')(Promise)
-  requestRunner = require('./http/request-runner')(Promise, Transaction)
-
-  asyncJobRequestRunner = do ->
-    (method, path, options = {}) ->
-      allowAsyncJobResponse options
-      ###
-      (f: () ->
-        TransactionRunner ((superagent.Response & asyncJob) | superagent.Response)
-      ) -> TransactionRunner superagent.Response
-      ###
-      retryUntilComplete = (f) ->
-        f().flatMapDone (response) ->
-          if !isAsyncJobResponse response
-            Transaction.unit response
-          else
-            markAsAsyncJobMonitorRequest response, options
-            retryUntilComplete f
-
-      # NOTE: Node will emit faux 'socket hang up' errors if request is built
-      # but never ran. Avoid this by starting from an empty transaction and
-      # creating the request only when we're actually going to run.
-      Transaction.empty.flatMapDone ->
-        retryUntilComplete ->
-          requestRunner buildRequest(method, path, options)
+  asyncJobRequestRunner = require('./http/async-job-request-runner')(Promise)
 
   runRequest = (args...) ->
     asyncJobRequestRunner(args...).run (t) ->

src/http/async-job-request-runner.coffee

@@ -0,0 +1,49 @@
+jobs = require './jobs'
+buildRequest = require './build-request'
+
+###
+Allow the server to respond with an async job by enabling the corresponding feature header
+###
+allowAsyncJobResponse = (requestOptions) ->
+  requestOptions.headers ?= {}
+  requestOptions.headers[jobs.ASYNC_JOB_FEATURE_HEADER] = true
+
+###
+Check a response for the signature of an async job
+###
+isAsyncJobResponse = (response) ->
+  (response.status is jobs.JOB_HTTP_STATUS) and (response.body?[jobs.JOB_ROOT_KEY]?.id?)
+
+###
+Given an async job response, mark a request as a monitor on the async job by setting a header
+###
+markAsAsyncJobMonitorRequest = (asyncJobResponse, requestOptions) ->
+  requestOptions.headers ?= {}
+  requestOptions.headers[jobs.JOB_ID_HEADER] = asyncJobResponse.body[jobs.JOB_ROOT_KEY].id
+
+module.exports = (Promise) ->
+  Transaction = require('ag-transaction')(Promise)
+  requestRunner = require('./request-runner')(Promise, Transaction)
+
+  asyncJobRequestRunner = do ->
+    (method, path, options = {}) ->
+      allowAsyncJobResponse options
+      ###
+      (f: () ->
+        TransactionRunner ((superagent.Response & asyncJob) | superagent.Response)
+      ) -> TransactionRunner superagent.Response
+      ###
+      retryUntilComplete = (f) ->
+        f().flatMapDone (response) ->
+          if !isAsyncJobResponse response
+            Transaction.unit response
+          else
+            markAsAsyncJobMonitorRequest response, options
+            retryUntilComplete f
+
+      # NOTE: Node will emit faux 'socket hang up' errors if request is built
+      # but never ran. Avoid this by starting from an empty transaction and
+      # creating the request only when we're actually going to run.
+      Transaction.empty.flatMapDone ->
+        retryUntilComplete ->
+          requestRunner buildRequest(method, path, options)