1 files changed, 69 insertions, 0 deletions
diff --git a/deps/npm/lib/unpublish.js b/deps/npm/lib/unpublish.js
new file mode 100644
index 0000000000..2945a7887f
--- /dev/null
+++ b/deps/npm/lib/unpublish.js
@@ -0,0 +1,69 @@
+
+module.exports = unpublish
+
+var registry = require("./utils/npm-registry-client/index.js")
+  , log = require("./utils/log.js")
+  , npm = require("./npm.js")
+  , readJson = require("./utils/read-json.js")
+  , path = require("path")
+  , output = require("./utils/output.js")
+
+unpublish.usage = "npm unpublish <project>[@<version>]"
+
+unpublish.completion = function (opts, cb) {
+  if (opts.conf.argv.remain.length >= 3) return cb()
+  var un = encodeURIComponent(npm.config.get("username"))
+  if (!un) return cb()
+  registry.get("/-/by-user/"+un, function (er, pkgs) {
+    // do a bit of filtering at this point, so that we don't need
+    // to fetch versions for more than one thing, but also don't
+    // accidentally a whole project.
+    pkgs = pkgs[un]
+    if (!pkgs || !pkgs.length) return cb()
+    var partial = opts.partialWord.split("@")
+      , pp = partial.shift()
+      , pv = partial.join("@")
+    pkgs = pkgs.filter(function (p) {
+      return p.indexOf(pp) === 0
+    })
+    if (pkgs.length > 1) return cb(null, pkgs)
+    registry.get(pkgs[0], function (er, d) {
+      if (er) return cb(er)
+      var vers = Object.keys(d.versions)
+      if (!vers.length) return cb(null, pkgs)
+      return cb(null, vers.map(function (v) {
+        return pkgs[0]+"@"+v
+      }))
+    })
+  })
+}
+
+function unpublish (args, cb) {
+  var thing = args.length ? args.shift().split("@") : []
+    , project = thing.shift()
+    , version = thing.join("@")
+
+  if (!project || path.resolve(project) === npm.prefix) {
+    // if there's a package.json in the current folder, then
+    // read the package name and version out of that.
+    var cwdJson = path.join(process.cwd(), "package.json")
+    return readJson(cwdJson, function (er, data) {
+      if (er) return cb("Usage:\n"+unpublish.usage)
+      gotProject(data.name, data.version, cb)
+    })
+  }
+  return gotProject(project, version, cb)
+}
+
+function gotProject (project, version, cb_) {
+  function cb (er) {
+    if (er) return cb_(er)
+    output.write("- " + project + (version ? "@" + version : ""), cb_)
+  }
+
+  // remove from the cache first
+  npm.commands.cache(["clean", project, version], function (er) {
+    if (er) return log.er(cb, "Failed to clean cache")(er)
+    registry.unpublish(project, version, cb)
+  })
+}