keep attacking for long period

package-lock.json

@@ -12,6 +12,14 @@
         "@types/node": "*"
       }
     },
+    "@types/moment": {
+      "version": "2.13.0",
+      "resolved": "https://registry.npmjs.org/@types/moment/-/moment-2.13.0.tgz",
+      "integrity": "sha1-YE69GJvDvDShVIaJQE5hoqSqyJY=",
+      "requires": {
+        "moment": "*"
+      }
+    },
     "@types/node": {
       "version": "14.0.11",
       "resolved": "https://registry.npmjs.org/@types/node/-/node-14.0.11.tgz",
@@ -434,8 +442,7 @@
     "moment": {
       "version": "2.26.0",
       "resolved": "https://registry.npmjs.org/moment/-/moment-2.26.0.tgz",
-      "integrity": "sha512-oIixUO+OamkUkwjhAVE18rAMfRJNsNe/Stid/gwHSOfHrOtw9EhAY2AHvdKZ/k/MggcYELFCJz/Sn2pL8b8JMw==",
-      "optional": true
+      "integrity": "sha512-oIixUO+OamkUkwjhAVE18rAMfRJNsNe/Stid/gwHSOfHrOtw9EhAY2AHvdKZ/k/MggcYELFCJz/Sn2pL8b8JMw=="
     },
     "ms": {
       "version": "2.0.0",

package.json

@@ -22,10 +22,12 @@
   "homepage": "https://github.com/purerosefallen/hisoutensoku-terminiator#readme",
   "dependencies": {
     "@types/bunyan": "^1.8.6",
+    "@types/moment": "^2.13.0",
     "@types/underscore": "^1.10.0",
     "@types/yaml": "^1.9.7",
     "bunyan": "^1.8.12",
     "cqhttp": "^1.2.0",
+    "moment": "^2.26.0",
     "udp-proxy": "^1.2.0",
     "underscore": "^1.10.2",
     "yaml": "^1.10.0"

run.ts

@@ -5,6 +5,7 @@ import * as _ from "underscore";
 import * as yaml from "yaml";
 import { spawn } from "child_process";
 import { attack } from "./attacker";
+import * as moment from "moment";
 
 interface CoolQConfig {
 	apiRoot: string;
@@ -39,13 +40,17 @@ async function startAttack(address: string, port: number): Promise<boolean> {
 		return false;
 	}
 	log.info(`Attack of ${address}:${port} started.`);
-	const err = await attack(address, port, config.attackTimeout);
+	let curTime: moment.Moment = moment();
+	while (moment().diff(curTime) <= config.attackTimeout) {
+		const err = await attack(address, port, 1000);
 		if (err) {
 			log.warn(`Attack of ${address}:${port} failed: ${err}`);
 		} else {
 			log.warn(`Attack of ${address}:${port} succeeded.`);
 		}
-	return !err;
+	}
+	log.info(`Attack of ${address}:${port} finished.`);
+	return true;
 }
 
 async function messageHandler(data: any): Promise<void> {