//
// Copyright 2020 DxOS.org
//

import { spawnSync } from 'child_process';

class LogCache {
  constructor(maxLines = 500) {
    // Sets in JS iterate in insertion order.
    this.buffer = new Set();
    this.maxLines = maxLines;
  }

  append(lines) {
    const added = [];
    for (const line of lines) {
      if (!this.buffer.has(line)) {
        this.buffer.add(line);
        added.push(line);
      }
    }

    if (this.buffer.size > this.maxLines) {
      this.buffer = new Set(Array.from(this.buffer).slice(parseInt(this.maxLines / 2)));
    }

    return added;
  }
}

const _caches = new Map();
const getLogCache = (name) => {
  let cache = _caches.get(name);
  if (!cache) {
    cache = new LogCache();
    _caches.set(name, cache);
  }
  return cache;
}

const getLogs = async (name, lines = 100) => {
  const command = 'wire';
  const args = ['service', 'logs', '--lines', lines, name];

  const child = spawnSync(command, args, { encoding: 'utf8' });
  const logLines = child.stdout.split(/\n/);
  const cache = getLogCache(name);
  return cache.append(logLines);
};

export const logResolvers = {
  Query: {
    wns_log: async () => {
      const logs = await getLogs('wns-list');
      return {
        timestamp: new Date().toUTCString(),
        json: JSON.stringify(logs)
      };
    },
    signal_log: async () => {
      const logs = await getLogs('signal');
      return {
        timestamp: new Date().toUTCString(),
        json: JSON.stringify(logs)
      };
    },
    ipfs_log: async () => {
      const logs = await getLogs('ipfs');
      return {
        timestamp: new Date().toUTCString(),
        json: JSON.stringify(logs)
      };
    },
    ipfs_swarm_log: async () => {
      const logs = await getLogs('ipfs');
      return {
        timestamp: new Date().toUTCString(),
        json: JSON.stringify(logs)
      };
    },
    app_log: async () => {
      const logs = await getLogs('ipfs');
      return {
        timestamp: new Date().toUTCString(),
        json: JSON.stringify(logs)
      };
    }
  }
};