1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

const os = require('os');

class CacheCenter {
  constructor(prefixKey = 'updated') {
    this.data = new Map();
    
    this.prefix = prefixKey;
    
    this.ip = getIPAddress();
    this.id = `${this.ip}:${process.env.NODE_APP_INSTANCE || 0}`;
  }

  async get(key) {
    const isCached = this.data.has(key);
    if (isCached) {
      const isCacheLatest = await redis.hget(this._key(key), this.id);
      if (isCacheLatest) {
        return this.data.get(key);
      }
    }
    return undefined;
  }

  async set(key, value) {
    this.data.set(key, value);
    await redis.hset(this._key(key), this.id, Date.now());
    redis.expire(this._key(key), 7 * 24 * 60 * 60);
  }

  async del(key) {
    redis.del(this._key(key));
  }

  has(key) {
    return this.data.has(key);
  }

  _key(key) {
    return `${this.prefix}:${key}`;
  }
}

function getIPAddress() {
  const interfaces = os.networkInterfaces();
  for (const iface of Object.values(interfaces)) {
    for (const alias of iface) {
      if (alias.family === 'IPv4' && alias.address !== '127.0.0.1' && !alias.internal) {
        return alias.address;
      }
    }
  }
  return '127.0.0.1';
}

module.exports = new CacheCenter();

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

class Search {
  


  constructor() {
    this.index = lunr(function() {
      this.field('name', {boost: 10});
      this.field('unscoped', {boost: 8});
      this.field('description', {boost: 4});
      this.field('author', {boost: 6});
      this.field('readme');
    });
  }

  



  add(pkg) {
    this.index.add({
      id: pkg.name,
      name: pkg.name,
      unscoped: getUnscopedName(pkg.name),
      description: pkg.description,
      author: pkg._npmUser ? pkg._npmUser.name : '???',
    });
  }
  
}





function getUnscopedName(name) {
  return name.split('/')[1];
}