shpak86 / tcp_scanner Goto Github PK

                                      for (var element in addressList) {
                                          var stopwatch1 = Stopwatch();
                                          stopwatch1.start();
                                          // Simple scan
                                          try {
                                            var scannerTask = TcpScannerTask(element, [1883], shuffle: false, parallelism: 1);
                                            Future.delayed(const Duration(seconds: 10), () {
                                              print('ScannerTask cancelled by timeout after ${stopwatch1.elapsed}');
                                              scannerTask
                                                  .cancel()
                                                  .then((report) => print('Host ${report.host} scan was cancelled\n'
                                                  'Scanned ports:\t${report.openPorts.length + report.closedPorts.length}\n'
                                                  'Open ports:\t${report.openPorts}\n'
                                                  'Status:\t${report.status}\n'
                                                  'Elapsed:\t${stopwatch1.elapsed}\n'))
                                                  .catchError((error) => stderr.writeln(error));
                                            });
                                            await scannerTask.start().then((report) async {
                                              print('Host ${report.host} scan completed\n'
                                                  'Scanned ports:\t${report.ports.length}\n'
                                                  'Close ports:\t${report.openPorts}\n'
                                                  'Open ports:\t${report.openPorts}\n'
                                                  'Status:\t${report.status}\n'
                                                  'Elapsed:\t${stopwatch1.elapsed}\n');
                                              if (report.openPorts.contains(1883)) {
                                                esp32Devices.add(report.host);
                                                print('Here is the ESP32 Devices Available on $esp32Devices');
                                                if (esp32Devices.isNotEmpty) {
                                                  await mqttClientWorking();
                                                }
                                              }
                                            })
                                                // Catch errors during the scan
                                                .catchError((error) => stderr.writeln(error));
                                          } catch (e) {
                                            // Here you can catch exceptions threw in the constructor
                                            stderr.writeln('Error: $e');
                                          }
                                        }

I/flutter (19317): HTTP ports scan result
I/flutter (19317): Host:          192.168.4.1
I/flutter (19317): Scanned ports: [503, 513]
I/flutter (19317): Open ports:    [503]
I/flutter (19317): Closed ports:  []
I/flutter (19317): Elapsed time:  0.783s