lbry-app/flowtype-plugin.js at master · LittleSecretary/lbry-app · GitHub

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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
var spawnSync = require('child_process').spawnSync;
var flow = require('flow-bin');
var merge = require('lodash.merge');

var store = {
  error: null,
  flowOptions: [
    'check',
    '--color=always',
  ],
  options: {
    warn: false,

    formatter: function (errorCode, errorDetails) {
      return 'Flow: ' + errorCode + '\n\n' + errorDetails;
    },
  },
};


function flowErrorCode(status) {
  var error;
  switch (status) {
    /*
    case 0:
      error = null;
      break;
    */
    case 1:
      error = 'Server Initializing';
      break;
    case 2:
      error = 'Type Error';
      break;
    case 3:
      error = 'Out of Time';
      break;
    case 4:
      error = 'Kill Error';
      break;
    case 6:
      error = 'No Server Running';
      break;
    case 7:
      error = 'Out of Retries';
      break;
    case 8:
      error = 'Invalid Flowconfig';
      break;
    case 9:
      error = 'Build Id Mismatch';
      break;
    case 10:
      error = 'Input Error';
      break;
    case 11:
      error = 'Lock Stolen';
      break;
    case 12:
      error = 'Could Not Find Flowconfig';
      break;
    case 13:
      error = 'Server Out of Date';
      break;
    case 14:
      error = 'Server Client Directory Mismatch';
      break;
    case 15:
      error = 'Out of Shared Memory';
      break;
  }

  return error;
}


function checkFlowStatus(compiler, next) {
  var res = spawnSync(flow, store.flowOptions);
  var status = res.status;

  if (status !== 0) {
    var errorCode = flowErrorCode(status);
    var errorDetails = res.stdout.toString() + res.stderr.toString();

    store.error = new Error(store.options.formatter(errorCode, errorDetails));
  }

  next();
}


function pushError(compilation) {
  if (store.error) {
    if (store.options.warn) {
      compilation.warnings.push(store.error);
    } else {
      compilation.errors.push(store.error);
    }

    store.error = null;
  }
}


function FlowFlowPlugin(options) {
  store.options = merge(store.options, options);
}

FlowFlowPlugin.prototype.apply = function(compiler) {
  compiler.plugin('run', checkFlowStatus);
  compiler.plugin('watch-run', checkFlowStatus);

  compiler.plugin('compilation', pushError);
};

module.exports = FlowFlowPlugin;