Merge pull request #10 from h4ckm3-id/JYTB-Linux-Firefox

Jytb linux firefox - LGTM.

Author: Mark Tripoli

src/main/java/com/triippztech/app/models/Proxies.java

@@ -32,6 +32,7 @@
 
 import java.io.IOException;
 import java.util.*;
+import java.util.logging.Level;
 
 public class Proxies {
     private final String protoType = "https";
@@ -96,26 +97,36 @@ private void refreshProxies()
         this.proxies = null;
         this.generateProxies();
     }
-
-    private void loadNewProxy()
-    {
+    // fix randomproxy problem
+    private void loadNewProxy() {
+        Log.WWARN(workerName, workerColor,"Load new proxies");
         this.usedProxies.add(this.getCurrentProxyModel());
         Datum proxy = randomProxy();
-        if ( isUsed(proxy) )
-            this.loadNewProxy();
-        else {
-            this.setCurrentProxyModel(proxy);
-            this.setCurrentProxy(proxy);
-        }
+            if ( isUsed(proxy) ) {
+                try {
+                    Log.WWARN(workerName, workerColor,"proxy already used");
+                    Thread.sleep(3000);
+                    Log.WWARN(workerName, workerColor,"Refreshing Proxy list...");
+                    this.refreshProxies();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+            else {
+                this.setCurrentProxyModel(proxy);
+                this.setCurrentProxy(proxy);
+            }
+
     }
 
+
+
     private Boolean isUsed(Datum proxy)
     {
         return usedProxies.contains(proxy);
     }
 
-    private Datum randomProxy()
-    {
+    private Datum randomProxy() {
         return proxies.getData().get(new Random().nextInt(proxies.getData().size()));
     }
 

src/main/java/com/triippztech/app/services/BotWorker.java

@@ -41,6 +41,7 @@
 
 import java.io.File;
 import java.io.IOException;
+import java.text.DecimalFormat;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
@@ -81,6 +82,8 @@ private void initializeBot() throws IOException {
         Log.WINFO(this.workerName, this.workerColor, "Initializing. . .");
         this.proxies = new Proxies(this.workerName, this.apiKey, this.workerColor);
         this.userAgent = new UserAgent(this.driverType);
+
+
         switch (this.driverType.name() )
         {
             case Constants.FIREFOX:
@@ -129,7 +132,9 @@ private void setFirefoxDriver() {
         FirefoxProfile profile = new FirefoxProfile();
         FirefoxBinary binary = new FirefoxBinary(this.driverLocation);
         LoggingPreferences logPrefs = new LoggingPreferences();
-
+        System.setProperty(FirefoxDriver.SystemProperty.DRIVER_USE_MARIONETTE,"true");
+        // hide firefox logs from console
+        System.setProperty(FirefoxDriver.SystemProperty.BROWSER_LOGFILE,"/tmp/rust_");
 
         profile.setPreference("media.volume_scale", "0.0");
         profile.setPreference("general.useragent.override", userAgent.randomUA());
@@ -148,8 +153,8 @@ private void setFirefoxDriver() {
         options.setBinary(binary);
 //        options.setProxy(this.proxies.getCurrentProxy());
         options.setCapability("proxy", this.proxies.getCurrentProxy());
-
         this.webDriver = new FirefoxDriver(options);
+
         Log.WINFO(this.workerName, this.workerColor, "Firefox Driver Set");
     }
 
@@ -161,8 +166,13 @@ private void setFirefoxDriver() {
      * @throws ElementClickInterceptedException
      * @throws NoSuchTitleException Our page doesnt end with YouTube, maybe there is an incorrect URL
      */
-    private int setVideo() throws ElementClickInterceptedException, NoSuchTitleException {
+    private int setVideo() throws ElementClickInterceptedException {
+
         this.webDriver.get(this.videoUrl);
+        String a = this.webDriver.getCurrentUrl();
+        String j = this.webDriver.getTitle();
+        System.out.println("Your page title Is : "+j);
+        System.out.println("Current URL Is : "+a);
 
         if ( this.webDriver.getTitle().endsWith("YouTube") )
         {
@@ -179,9 +189,41 @@ private int setVideo() throws ElementClickInterceptedException, NoSuchTitleExcep
             if (this.watchLength == -1) {
                 return calculateWatchTime( currentVideoTime, totalVideoTime );
             } else {
-                return this.watchLength * 1000;
+                // Randomize watch duration every visits,
+                int w = this.watchLength * 1000;
+                int max = w + 5000;
+                int min = w;
+                int range = max - min + min;
+                int rand = (int) (Math.random()* range) + (min / 2);
+                String pattern = "#,##,###.#";
+                DecimalFormat decimalFormat = new DecimalFormat(pattern);
+                String format = decimalFormat.format(rand / 1000);
+
+                System.out.println("Watch durtion: "+format+" Seconds");
+                Log.WINFO(this.workerName, this.workerColor, "Bot Watching now....");
+                return rand;
+
             }
-        } else {
+        } else  {
+            Log.WINFO(this.workerName, this.workerColor, "reCaptcha Showing!!");
+            // STILL NOT WORKING FOR SOLVING RECAPTCHA PROBLEM, NEED RESTART VPS TO SOLVE THIS.
+            try {
+//                new WebDriverWait(this.webDriver, 10).until(ExpectedConditions.frameToBeAvailableAndSwitchToIt(By.xpath("//iframe[starts-with(@name, 'a-') and starts-with(@src, 'https://www.google.com/recaptcha')]")));
+//                new WebDriverWait(this.webDriver, 20).until(ExpectedConditions.elementToBeClickable(By.cssSelector("div.recaptcha-checkbox-checkmark"))).click();
+//                WebElement iFrame = this.webDriver.findElement(By.xpath("html/body/div[1]/div[3]/div[2]/form/div[5]/div"));
+//                this.webDriver.switchTo().frame(iFrame);
+                  Log.WINFO(this.workerName, this.workerColor, "iframe found!");
+            }catch (Exception e){
+                System.out.println("ERROR: "+e);
+            }
+
+
+//            WebDriverWait(this.webDriver, 10).until(EC.element_to_be_clickable((By.CSS_SELECTOR, "span#recaptcha-anchor"))).click()
+//            this.webDriver.switch_to.default_content()
+//            WebDriverWait(this.webDriver, 10).until(EC.frame_to_be_available_and_switch_to_it((By.CSS_SELECTOR,"iframe[title='recaptcha challenge']")))
+//            WebDriverWait(this.webDriver, 10).until(EC.element_to_be_clickable((By.CSS_SELECTOR, "button#recaptcha-audio-button"))).click()
+
+
             throw new NoSuchTitleException(String.format("Title does not end with YouTube, please ensure you have " +
                     "provided the correct URL to the video. Actual title: %s", this.webDriver.getTitle()));
         }
@@ -195,6 +237,7 @@ private int setVideo() throws ElementClickInterceptedException, NoSuchTitleExcep
      * @param videoLength The total lengtht of the video
      * @return watchTime in millis
      */
+
     private Integer calculateWatchTime ( String currentTime, String videoLength )
     {
         int[] curHMS =  Stream.of(currentTime.split(":")).mapToInt(Integer::parseInt).toArray();

src/main/java/com/triippztech/app/services/DriverConfiguration.java

@@ -26,7 +26,7 @@
 
 public class DriverConfiguration {
     // macOS
-    private final static String FIREFOX_MAC = "/Applications/Firefox.app/Contents/MacOS/firefox";
+    private final static String FIREFOX_MAC = "Applications/firefox.app";
     private final static String CHROME_MAC = "/Applications/Google Chrome.app";
     private final static String OPERA_MAC = "/Applications/Opera.app";
     private final static String SAFARI_MAC = "/Applications/Safari.app";
@@ -42,6 +42,8 @@ public class DriverConfiguration {
     private final static String OPERA_WIN_32 = "";
 
     // LINUX
+    private final static String FIREFOX_LINUX = "/usr/bin/firefox";
+    private final static String CHROME_LINUX = "/usr/bin/chromium";
 
     @SuppressWarnings("Duplicates")
     public static void validateDriver(Driver driverType)
@@ -54,15 +56,15 @@ public static void validateDriver(Driver driverType)
                 else if (SystemUtils.IS_OS_WINDOWS)
                     driverExists(FIREFOX_WIN_32, FIREFOX_WIN_64);
                 else
-                    //
+                    driverExists(FIREFOX_LINUX); 
                 break;
             case Constants.CHROME:
                 if (SystemUtils.IS_OS_MAC_OSX)
                     driverExists(CHROME_MAC);
                 else if (SystemUtils.IS_OS_WINDOWS)
                     driverExists(CHROME_WIN_32, CHROME_WIN_64);
                 else
-                    //
+                    driverExists(CHROME_LINUX); 
                 break;
             case Constants.SAFARI:
             case Constants.OPERA:
@@ -86,7 +88,14 @@ private static Boolean driverExists(String location1, String location2)
 
     public static File getDriver()
     {
-        return new File(FIREFOX_MAC);
+       //  return new File(FIREFOX_LINUX);
+//
+        if (SystemUtils.IS_OS_MAC_OSX)
+            return new File(FIREFOX_MAC);
+        else if (SystemUtils.IS_OS_WINDOWS)
+            return new File(FIREFOX_WIN_32, FIREFOX_WIN_64);
+        else
+            return new File(FIREFOX_LINUX);
     }
 
 //    public static File getFirefoxDriver()