Adding integrated tile server

[simantics/district.git] / org.simantics.maps.server / node / node-v4.8.0-win-x64 / node_modules / npm / node_modules / npm-registry-client / lib / fetch.js

diff --git a/org.simantics.maps.server/node/node-v4.8.0-win-x64/node_modules/npm/node_modules/npm-registry-client/lib/fetch.js b/org.simantics.maps.server/node/node-v4.8.0-win-x64/node_modules/npm/node_modules/npm-registry-client/lib/fetch.js
new file mode 100644 (file)
index 0000000..e931d37
--- /dev/null
+++ b/org.simantics.maps.server/node/node-v4.8.0-win-x64/node_modules/npm/node_modules/npm-registry-client/lib/fetch.js
@@ -0,0 +1,91 @@
+var assert = require('assert')
+var url = require('url')
+
+var request = require('request')
+var once = require('once')
+
+module.exports = fetch
+
+function fetch (uri, params, cb) {
+  assert(typeof uri === 'string', 'must pass uri to request')
+  assert(params && typeof params === 'object', 'must pass params to request')
+  assert(typeof cb === 'function', 'must pass callback to request')
+
+  cb = once(cb)
+
+  var client = this
+  this.attempt(function (operation) {
+    makeRequest.call(client, uri, params, function (er, req) {
+      if (er) return cb(er)
+
+      req.on('error', function (er) {
+        if (operation.retry(er)) {
+          client.log.info('retry', 'will retry, error on last attempt: ' + er)
+        } else {
+          cb(er)
+        }
+      })
+
+      req.on('response', function (res) {
+        client.log.http('fetch', '' + res.statusCode, uri)
+
+        var er
+        var statusCode = res && res.statusCode
+        if (statusCode === 200) {
+          // Work around bug in node v0.10.0 where the CryptoStream
+          // gets stuck and never starts reading again.
+          res.resume()
+          if (process.version === 'v0.10.0') unstick(res)
+
+          return cb(null, res)
+          // Only retry on 408, 5xx or no `response`.
+        } else if (statusCode === 408) {
+          er = new Error('request timed out')
+        } else if (statusCode >= 500) {
+          er = new Error('server error ' + statusCode)
+        }
+
+        if (er && operation.retry(er)) {
+          client.log.info('retry', 'will retry, error on last attempt: ' + er)
+        } else {
+          cb(new Error('fetch failed with status code ' + statusCode))
+        }
+      })
+    })
+  })
+}
+
+function unstick (response) {
+  response.resume = (function (orig) {
+    return function () {
+      var ret = orig.apply(response, arguments)
+      if (response.socket.encrypted) response.socket.encrypted.read(0)
+      return ret
+    }
+  })(response.resume)
+}
+
+function makeRequest (remote, params, cb) {
+  var parsed = url.parse(remote)
+  this.log.http('fetch', 'GET', parsed.href)
+
+  var headers = params.headers || {}
+  var er = this.authify(
+    params.auth && params.auth.alwaysAuth,
+    parsed,
+    headers,
+    params.auth
+  )
+  if (er) return cb(er)
+
+  var opts = this.initialize(
+    parsed,
+    'GET',
+    'application/x-tar, application/vnd.github+json; q=0.1',
+    headers
+  )
+  // always want to follow redirects for fetch
+  opts.followRedirect = true
+
+  cb(null, request(opts))
+}