|
3 | 3 | * Use of this source code is governed by a license that |
4 | 4 | * can be found in the LICENSE file. |
5 | 5 | */ |
6 | | -const vizion = require('vizion'); |
7 | 6 | const eachLimit = require('async/eachLimit'); |
8 | 7 | const debug = require('debug')('pm2:worker'); |
9 | 8 | const domain = require('domain'); |
@@ -95,51 +94,6 @@ module.exports = function(God) { |
95 | 94 | } |
96 | 95 | }; |
97 | 96 |
|
98 | | - // Deprecated |
99 | | - var versioningRefresh = function(proc_key, cb) { |
100 | | - var proc = _getProcessById(proc_key.pm2_env.pm_id); |
101 | | - if (!(proc && |
102 | | - proc.pm2_env && |
103 | | - (proc.pm2_env.vizion !== false && proc.pm2_env.vizion != "false") && |
104 | | - proc.pm2_env.versioning && |
105 | | - proc.pm2_env.versioning.repo_path)) { |
106 | | - return cb(); |
107 | | - } |
108 | | - |
109 | | - if (proc.pm2_env.vizion_running === true) |
110 | | - { |
111 | | - debug('Vizion is already running for proc id: %d, skipping this round', proc.pm2_env.pm_id); |
112 | | - return cb(); |
113 | | - } |
114 | | - |
115 | | - proc.pm2_env.vizion_running = true; |
116 | | - var repo_path = proc.pm2_env.versioning.repo_path; |
117 | | - |
118 | | - vizion.analyze({ |
119 | | - folder: proc.pm2_env.versioning.repo_path |
120 | | - }, |
121 | | - function(err, meta) { |
122 | | - if (err != null) |
123 | | - return cb(); |
124 | | - |
125 | | - proc = _getProcessById(proc_key.pm2_env.pm_id); |
126 | | - |
127 | | - if (!(proc && |
128 | | - proc.pm2_env && |
129 | | - proc.pm2_env.versioning && |
130 | | - proc.pm2_env.versioning.repo_path)) { |
131 | | - console.error('Proc not defined anymore or versioning unknown'); |
132 | | - return cb(); |
133 | | - } |
134 | | - |
135 | | - proc.pm2_env.vizion_running = false; |
136 | | - meta.repo_path = repo_path; |
137 | | - proc.pm2_env.versioning = meta; |
138 | | - debug('[PM2][WORKER] %s parsed for versioning', proc.pm2_env.name); |
139 | | - return cb(); |
140 | | - }); |
141 | | - }; |
142 | | - |
143 | 97 | var tasks = function() { |
144 | 98 | if (God.Worker.is_running === true) { |
145 | 99 | debug('[PM2][WORKER] Worker is already running, skipping this round'); |
|
0 commit comments