Skip to content
This repository was archived by the owner on Oct 8, 2024. It is now read-only.

Commit 91a39b1

Browse files
committed
fix sync bug
1 parent 15bcf7a commit 91a39b1

File tree

2 files changed

+45
-22
lines changed

2 files changed

+45
-22
lines changed

app.js

+44-21
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@
213213
} : function(r) {
214214
return r && "function" == typeof Symbol && r.constructor === Symbol && r !== Symbol.prototype ? "symbol" : typeof r;
215215
}, v = (n = T(regeneratorRuntime.mark(function r() {
216-
var e, t, n, s = this;
216+
var e, t, n, s, a = this;
217217
return regeneratorRuntime.wrap(function(r) {
218218
for (;;) switch (r.prev = r.next) {
219219
case 0:
@@ -241,40 +241,63 @@
241241
case "end":
242242
return r.stop();
243243
}
244-
}, r, s);
244+
}, r, a);
245245
}));
246246
return function(e) {
247247
return r.apply(this, arguments);
248248
};
249-
}()), r.next = 21;
249+
}()), s = e.map(function(r) {
250+
return r.port;
251+
}), t.forEach(function() {
252+
var r = T(regeneratorRuntime.mark(function r(e) {
253+
return regeneratorRuntime.wrap(function(r) {
254+
for (;;) switch (r.prev = r.next) {
255+
case 0:
256+
if (s.includes(e.port)) {
257+
r.next = 3;
258+
break;
259+
}
260+
return r.next = 3, N(e.port);
261+
262+
case 3:
263+
case 4:
264+
case "end":
265+
return r.stop();
266+
}
267+
}, r, a);
268+
}));
269+
return function(e) {
270+
return r.apply(this, arguments);
271+
};
272+
}()), r.next = 23;
250273
break;
251274

252-
case 11:
253-
if (r.prev = 11, r.t0 = r.catch(3), "shadowsocks unreachable" !== r.t0.message) {
254-
r.next = 16;
275+
case 13:
276+
if (r.prev = 13, r.t0 = r.catch(3), "shadowsocks unreachable" !== r.t0.message) {
277+
r.next = 18;
255278
break;
256279
}
257-
r.next = 20;
280+
r.next = 22;
258281
break;
259282

260-
case 16:
283+
case 18:
261284
if ("shadowsocks no response" !== r.t0.message) {
262-
r.next = 19;
285+
r.next = 21;
263286
break;
264287
}
265-
r.next = 20;
288+
r.next = 22;
266289
break;
267290

268-
case 19:
291+
case 21:
269292
throw r.t0;
270293

271-
case 20:
272-
case 21:
273294
case 22:
295+
case 23:
296+
case 24:
274297
case "end":
275298
return r.stop();
276299
}
277-
}, r, this, [ [ 3, 11 ] ]);
300+
}, r, this, [ [ 3, 13 ] ]);
278301
})), function() {
279302
return n.apply(this, arguments);
280303
}), b = (s = T(regeneratorRuntime.mark(function r(e) {
@@ -455,7 +478,7 @@
455478
}, r, this);
456479
})), function() {
457480
return i.apply(this, arguments);
458-
}), N = (c = T(regeneratorRuntime.mark(function r() {
481+
}), R = (c = T(regeneratorRuntime.mark(function r() {
459482
var e;
460483
return regeneratorRuntime.wrap(function(r) {
461484
for (;;) switch (r.prev = r.next) {
@@ -474,7 +497,7 @@
474497
}, r, this);
475498
})), function() {
476499
return c.apply(this, arguments);
477-
}), R = (p = T(regeneratorRuntime.mark(function r(e) {
500+
}), N = (p = T(regeneratorRuntime.mark(function r(e) {
478501
return regeneratorRuntime.wrap(function(r) {
479502
for (;;) switch (r.prev = r.next) {
480503
case 0:
@@ -795,7 +818,7 @@
795818
}), v(), setInterval(function() {
796819
v();
797820
}, 3e3), r.exports.login = b, r.exports.addPort = x, r.exports.getAllPorts = y,
798-
r.exports.getAllTraffic = E, r.exports.ping = N, r.exports.removePort = R;
821+
r.exports.getAllTraffic = E, r.exports.ping = R, r.exports.removePort = N;
799822
}, function(r, e, t) {
800823
"use strict";
801824
var n, s, a, o, u, i, c = (n = m(regeneratorRuntime.mark(function r(e, t) {
@@ -1166,17 +1189,17 @@
11661189
} catch (r) {
11671190
console.error("ssl key and/or certificate error corrupted"), process.exit(2);
11681191
}
1169-
var N = new i({
1192+
var R = new i({
11701193
windowMs: 36e5,
11711194
max: 10,
11721195
delayMs: 0
11731196
});
11741197
y.use(o.json()), y.use(o.urlencoded({
11751198
extended: !0
11761199
})), y.use(u());
1177-
var R = t(11);
1178-
y.post("/login", N, R.login), y.post("/", v, R.addPort), y.delete("/", v, R.removePort),
1179-
y.get("/all", v, R.getAllPorts), y.get("/traffic/all", v, R.getAllTraffic), y.get("/ping", v, R.ping),
1200+
var N = t(11);
1201+
y.post("/login", R, N.login), y.post("/", v, N.addPort), y.delete("/", v, N.removePort),
1202+
y.get("/all", v, N.getAllPorts), y.get("/traffic/all", v, N.getAllTraffic), y.get("/ping", v, N.ping),
11801203
E.listen(w, function() {
11811204
console.log("listening on port", w);
11821205
}).on("error", function(r) {

package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "shadowsocks-restful-api",
3-
"version": "0.0.1",
3+
"version": "0.0.2",
44
"description": "Secure, reliable, standard restful api for managing shadowsocks-libev",
55
"main": "app.js",
66
"scripts": {

0 commit comments

Comments
 (0)