偽装を強める(ランダム性とユーザエージェントの追加)

.gitignore

@@ -1,2 +1,3 @@
 .env
-__pycache__
+__pycache__
+nohup.out

app/main.py

@@ -5,7 +5,7 @@ from selenium.webdriver.common.by import By
 from selenium.webdriver.support.ui import WebDriverWait
 from selenium.webdriver.support import expected_conditions as EC
 from selenium.webdriver.common.keys import Keys
-import time,os
+import time,os,random
 
 import r_kuji
 
@@ -13,6 +13,7 @@ import r_kuji
 profile_dir = "/tmp/profile"
 username = os.environ["RAKUTENID"]
 password = os.environ["RAKUTENPW"]
+user_agent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/113.0.0.0 Safari/537.36 Edg/113.0.1774.57"
 rch_time = int(os.environ["RCH_WATCH_TIME"])
 rch_num = int(os.environ["RCH_WATCH_NUM"])
 target_url = "https://channel.rakuten.co.jp/"
@@ -30,6 +31,7 @@ def gen_driver():
     options = webdriver.ChromeOptions()
     options.add_argument("--window-size=1920,1080")
     options.add_argument("--user-data-dir=" + profile_dir )
+    options.add_argument('--user-agent=' + user_agent )
 
     driver = webdriver.Remote(
         command_executor="http://selenium:4444/wd/hub",
@@ -50,7 +52,7 @@ def init_profiles():
     wait = WebDriverWait(driver, 10)
     element = wait.until(EC.presence_of_element_located((By.TAG_NAME, 'body')))
 
-    driver.save_screenshot('./ss/ss.png')
+    driver.save_screenshot('./ss/initial.png')
 
     # Welcomeメッセージを閉じる
     try: 
@@ -71,22 +73,19 @@ def init_profiles():
         user = driver.find_element(By.CSS_SELECTOR, user_textarea_css)
         user.send_keys(username)
 
-        driver.save_screenshot('./ss/ss_usrname.png')
         user.send_keys(Keys.ENTER)
         time.sleep(10)
 
         # パスワード入力
         passwd = driver.find_element(By.CSS_SELECTOR, passwd_textarea_css)
         passwd.send_keys(password)
-        driver.save_screenshot('./ss/ss_password.png')
         passwd.send_keys(Keys.ENTER)
         time.sleep(10)
-        driver.save_screenshot('./ss/ss_password2.png')
 
     except Exception as e:
         print(e)
 
-    driver.save_screenshot('./ss/ss2.png')
+    driver.save_screenshot('./ss/begin.png')
 
     # Coockie 取得
     cookies = driver.get_cookies()
@@ -103,27 +102,50 @@ def watching_rch():
     wait = WebDriverWait(driver, 10)
     element = wait.until(EC.presence_of_element_located((By.TAG_NAME, 'body')))
 
-    # 10秒待機
-    time.sleep(10)
-
     for i in range(0, rch_num):
-        print( str( i + 1) + "番目のチャンネルの視聴を始めます。視聴時間は" + str(rch_time) + "秒に設定されています。")
+        # 30秒～150秒待機
-        channel_btns = driver.find_elements(By.CSS_SELECTOR, channel_btn_css)
+        random_seconds = random.randint(30, 150)
-        channel_btn = channel_btns[i]
+        time.sleep(random_seconds)
-        channel_btn.click()
+
-        time.sleep(10)
+        print( "Rチャンネル:" + str( i + 1) + "番目のチャンネルの視聴を始めます。視聴時間は" + str(rch_time) + "秒に設定されています。")
-        driver.save_screenshot('./ss/channel_' + str(i) + '.png')
+        
-        time.sleep(rch_time)
+        try:
+            channel_btns = driver.find_elements(By.CSS_SELECTOR, channel_btn_css)
+            channel_btn = channel_btns[i]
+            channel_btn.click()
+        except:
+            print("Rチャンネル:チャンネルが選択できませんでした。")
+            try:
+                driver.save_screenshot('./ss/error.png')
+            except:
+                print("Rチャンネル:スクリーンショットの保存でエラーが発生しました。")
+
+
+        now_time = time.time()
+        end_time = now_time + rch_time
+
+        while time.time() <= end_time:
+            try:
+                driver.save_screenshot('./ss/watching.png')
+            except:
+                print("Rチャンネル:スクリーンショットの保存でエラーが発生しました。")
+            time.sleep(30)
+
+        try:
+            driver.refresh()
+        except:
+            print("Rチャンネル:ページの更新に失敗しました。")
 
     driver.quit()
 
-
 def main():
     init_profiles()
     watching_rch()
 
 if __name__ == '__main__':
-    time.sleep(60) # selniumコンテナの起動を待つ待機
+    # 60-900秒待機 (毎日同時刻にアクセスすることを回避)
+    random_seconds = random.randint(60, 900)
+    time.sleep(random_seconds) # selniumコンテナの起動を待つ待機
     main()
     try: 
         r_kuji.rkuji()

app/r_kuji.py

@@ -27,29 +27,29 @@ class class_rkuji:
     def challenge_rkuji(self):
         for u in self.url_txts:
             if 'redirect' in u:
-                print(f'ラッキーくじ：「{u}」はスキップ。(理由：redirect)')
+                print(f'ラッキーくじ：「{u}」はスキップ。(理由:redirect)')
                 continue
             try:
                 self.driver.get(u)
                 kuji_title = self.driver.title
             except:
-                print(f'ラッキーくじ：「{u}」はスキップ。(理由：アクセス失敗)')
+                print(f'ラッキーくじ：「{u}」はスキップ。(理由:アクセス失敗)')
                 continue
 
             if(len(self.driver.find_elements(By.ID, "entry"))>0):
-                print(f'ラッキーくじ：くじを引きます。({kuji_title})')
+                print(f'ラッキーくじ：「{kuji_title}」くじを引きます。')
                 time.sleep(5)
                 try:
                     start_button = self.driver.find_element(By.ID, "entry")
                     start_button.click()
                     WebDriverWait(self.driver,60).until(EC.url_changes(u))
-                    print(f'ラッキーくじ：くじを引きました。({kuji_title})')
+                    print(f'ラッキーくじ：「{kuji_title}」くじを引きました。')
                     self.driver.save_screenshot('./ss/r_kuji.png')
                     time.sleep(5)
                 except:
-                    (f'ラッキーくじ：「{kuji_title}」はスキップ。(理由：くじ引き失敗)')
+                    (f'ラッキーくじ：「{kuji_title}」はスキップ。(理由:くじ引き失敗)')
             else:
-                print(f'ラッキーくじ：「{kuji_title}」はスキップ。(理由：くじ引き不能)')
+                print(f'ラッキーくじ：「{kuji_title}」はスキップ。(理由:くじ引き不能)')
 
     def close(self):
         self.driver.quit()