1 files changed, 0 insertions, 189 deletions
diff --git a/deps/node/deps/npm/test/tap/all-package-metadata-entry-stream-unit.js b/deps/node/deps/npm/test/tap/all-package-metadata-entry-stream-unit.js
deleted file mode 100644
index 4e916229..00000000
--- a/deps/node/deps/npm/test/tap/all-package-metadata-entry-stream-unit.js
+++ /dev/null
@@ -1,189 +0,0 @@
-'use strict'
-
-const common = require('../common-tap.js')
-const getStream = require('get-stream')
-const mkdirp = require('mkdirp')
-const mr = require('npm-registry-mock')
-const npm = require('../../')
-const path = require('path')
-const rimraf = require('rimraf')
-const Tacks = require('tacks')
-const test = require('tap').test
-
-const {File} = Tacks
-
-const _createEntryStream = require('../../lib/search/all-package-metadata.js')._createEntryStream
-
-const PKG_DIR = path.resolve(__dirname, 'create-entry-update-stream')
-const CACHE_DIR = path.resolve(PKG_DIR, 'cache')
-
-let server
-
-function setup () {
-  mkdirp.sync(CACHE_DIR)
-}
-
-function cleanup () {
-  rimraf.sync(PKG_DIR)
-}
-
-test('setup', t => {
-  cleanup()
-  mr({port: common.port, throwOnUnmatched: true}, (err, s) => {
-    t.ifError(err, 'registry mocked successfully')
-    npm.load({ cache: CACHE_DIR, registry: common.registry }, err => {
-      t.ifError(err, 'npm loaded successfully')
-      server = s
-      t.pass('all set up')
-      t.done()
-    })
-  })
-})
-
-test('createEntryStream full request', t => {
-  setup()
-  const cachePath = path.join(CACHE_DIR, '.cache.json')
-  const dataTime = +(new Date())
-  server.get('/-/all').once().reply(200, {
-    '_updated': dataTime,
-    'bar': { name: 'bar', version: '1.0.0' },
-    'foo': { name: 'foo', version: '1.0.0' }
-  }, {
-    date: 1234 // should never be used.
-  })
-  return _createEntryStream(cachePath, 600, {
-    registry: common.registry
-  }).then(({
-    entryStream: stream,
-    latest,
-    newEntries
-  }) => {
-    t.equals(latest, dataTime, '`latest` correctly extracted')
-    t.ok(newEntries, 'new entries need to be written to cache')
-    t.ok(stream, 'returned a stream')
-    return getStream.array(stream)
-  }).then(results => {
-    t.deepEquals(results, [{
-      name: 'bar',
-      version: '1.0.0'
-    }, {
-      name: 'foo',
-      version: '1.0.0'
-    }])
-    server.done()
-    cleanup()
-  })
-})
-
-test('createEntryStream cache only', function (t) {
-  setup()
-  const now = Date.now()
-  const cacheTime = now - 100000
-  const cachePath = path.join(CACHE_DIR, '.cache.json')
-  const fixture = new Tacks(File({
-    '_updated': cacheTime,
-    bar: { name: 'bar', version: '1.0.0' },
-    cool: { name: 'cool', version: '1.0.0' },
-    foo: { name: 'foo', version: '2.0.0' },
-    other: { name: 'other', version: '1.0.0' }
-  }))
-  fixture.create(cachePath)
-  return _createEntryStream(cachePath, 600, {
-    registry: common.registry
-  }).then(({
-    entryStream: stream,
-    latest,
-    newEntries
-  }) => {
-    t.equals(latest, cacheTime, '`latest` is cache time')
-    t.ok(stream, 'returned a stream')
-    t.notOk(newEntries, 'cache only means no need to write to cache')
-    return getStream.array(stream)
-  }).then(results => {
-    t.deepEquals(
-      results.map(function (pkg) { return pkg.name }),
-      ['bar', 'cool', 'foo', 'other'],
-      'packages deduped and sorted'
-    )
-    server.done()
-    cleanup()
-  })
-})
-
-test('createEntryStream merged stream', function (t) {
-  setup()
-  const now = Date.now()
-  const cacheTime = now - 6000000
-  server.get('/-/all/since?stale=update_after&startkey=' + cacheTime).once().reply(200, {
-    'bar': { name: 'bar', version: '2.0.0' },
-    'car': { name: 'car', version: '1.0.0' },
-    'foo': { name: 'foo', version: '1.0.0' }
-  }, {
-    date: (new Date(now)).toISOString()
-  })
-  const cachePath = path.join(CACHE_DIR, '.cache.json')
-  const fixture = new Tacks(File({
-    '_updated': cacheTime,
-    bar: { name: 'bar', version: '1.0.0' },
-    cool: { name: 'cool', version: '1.0.0' },
-    foo: { name: 'foo', version: '2.0.0' },
-    other: { name: 'other', version: '1.0.0' }
-  }))
-  fixture.create(cachePath)
-  return _createEntryStream(cachePath, 600, {
-    registry: common.registry
-  }).then(({
-    entryStream: stream,
-    latest,
-    newEntries
-  }) => {
-    t.equals(latest, now, '`latest` correctly extracted from header')
-    t.ok(stream, 'returned a stream')
-    t.ok(newEntries, 'cache update means entries should be written')
-    return getStream.array(stream)
-  }).then(results => {
-    t.deepEquals(
-      results.map(function (pkg) { return pkg.name }),
-      ['bar', 'car', 'cool', 'foo', 'other'],
-      'packages deduped and sorted'
-    )
-    t.deepEquals(results[0], {
-      name: 'bar',
-      version: '2.0.0'
-    }, 'update stream version wins on dedupe')
-    t.deepEquals(results[3], {
-      name: 'foo',
-      version: '1.0.0'
-    }, 'update stream version wins on dedupe even when the newer one has a lower semver.')
-    server.done()
-    cleanup()
-  })
-})
-
-test('createEntryStream no sources', function (t) {
-  setup()
-  const cachePath = path.join(CACHE_DIR, '.cache.json')
-  server.get('/-/all').once().reply(404, {})
-  return _createEntryStream(cachePath, 600, {
-    registry: common.registry
-  }).then(({
-    entryStream: stream,
-    latest,
-    newEntries
-  }) => {
-    throw new Error('should not succeed')
-  }, err => {
-    t.ok(err, 'no sources, got an error')
-    t.match(err.message, /No search sources available/, 'useful error message')
-  }).then(() => {
-    server.done()
-    cleanup()
-  })
-})
-
-test('cleanup', function (t) {
-  cleanup()
-  server.close()
-  t.pass('all done')
-  t.done()
-})