Add a registryGET function to mirror registryPUT

1 files changed, 42 insertions, 0 deletions

diff --git a/lib/utils/registry.js b/lib/utils/registry.js
index 643944984..841ce5470 100644
--- a/lib/utils/registry.js
+++ b/lib/utils/registry.js
@@ -4,6 +4,7 @@
 exports.publish = publish
 exports.tag = tag
 exports.adduser = adduser
+exports.get = get
 
 var npm = require("../../npm")
   , http = require("http")
@@ -14,6 +15,8 @@ var npm = require("../../npm")
   , sys = require("sys")
   , ini = require("./ini")
 
+function get (project, version, cb) { registryGET(project+"/"+version, cb) }
+
 function tag (project, version, tag, cb) { PUT(project+"/"+tag, version, cb) }
 
 function publish (data, tarball, cb) {
@@ -56,6 +59,45 @@ function publish (data, tarball, cb) {
   })
 }
 
+function GET (where, cb) {
+  reg()
+  where = ini.config.registry + where
+  var u = url.parse(where)
+    , headers = { "host" : u.host
+                , "accept" : "application/json"
+                }
+  if (ini.config.auth) {
+    headers.authorization = 'Basic ' + ini.config.auth
+  }
+  log(u, "registryGET")
+  var client = http.createClient(u.port || (u.protocol === "https:" ? 443 : 80), u.hostname)
+  if (u.protocol === "https:") {
+    client.setSecure("X509_PEM")
+  }
+  var request = client.request("GET", u.pathname, headers)
+
+  request.addListener("response", function (response) {
+    // if (response.statusCode !== 200) return cb(new Error(
+    //   "Status code " + response.statusCode + " from PUT "+where))
+    var data = ""
+    response.setBodyEncoding("utf8")
+    response.addListener("data", function (chunk) { data += chunk })
+    response.addListener("end", function () {
+      try {
+        data = JSON.parse(data)
+      } catch (ex) {
+        ex.message += "\n" + data
+        return cb(ex, data, response)
+      }
+      if (data.error) return cb(new Error(
+        data.error + (" "+data.reason || "")))
+      cb(null, data, response)
+    })
+  })
+  request.end()
+}
+
+
 function PUT (where, what, cb) {
   reg()
   what = JSON.stringify(what)