Add loop proxy

Author: madawei2699

.env_sample

@@ -5,5 +5,6 @@ export INS_SESSION_ID_GAME="11658585665%3AiJeECzOuOucZmy%3A6"
 export INS_SESSION_ID_FOOD="11470214398%3AmnKVpyIylVSm3E%3A23"
 export INS_SESSION_ID_HOT="11658769798%3AKI5EpFWvayXPOP%3A12"
 export INS_SESSION_ID_OTHER=11658769798%3AKI5EpFWvayXPOP%3A12,11470214398%3AmnKVpyIylVSm3E%3A23
-export INS_NOT_LOGIN=0
-export INS_GOOGLE_QPS=1
+export INS_NOT_LOGIN=1
+export INS_GOOGLE_QPS=3
+export PROXYS=143.191.230.202:3199,181.214.193.243:3199,168.80.71.40:3199,168.81.103.84:3199,45.43.128.22:3199,196.18.178.96:3199,108.59.14.203:13010,168.80.228.90:3199,168.80.183.191:3199,168.81.230.87:3199,104.233.48.27:3199,108.59.14.203:13010,168.81.246.228:3199,168.80.38.95:3199,196.19.191.80:3199,168.81.38.77:3199,168.81.53.38:3199,108.59.14.203:13010,168.81.100.127:3199,168.80.70.119:3199,196.18.178.13:3199,196.16.95.164:3199,104.239.119.248:3199,168.80.149.204:3199,168.81.151.22:3199,108.59.14.203:13010,181.177.75.245:3199,168.81.71.41:3199,143.191.229.6:3199,168.81.215.148:3199,196.17.123.237:3199,143.191.233.76:3199,108.59.14.203:13010,168.81.20.102:3199,154.16.129.229:3199,168.81.5.181:3199,196.16.249.224:3199,181.215.62.114:3199,196.18.150.79:3199,168.80.37.135:3199,108.59.14.203:13010,196.16.222.77:3199,168.81.20.153:3199,196.18.252.131:3199,108.59.14.203:13010,191.96.198.229:3199,168.81.133.180:3199,181.214.194.129:3199,108.59.14.203:13010,186.179.25.143:3199,168.81.166.221:3199,181.214.197.230:3199,168.81.53.146:3199,67.227.120.64:3199,108.59.14.203:13010,168.80.36.92:3199,168.80.7.28:3199,168.81.198.177:3199,168.80.23.74:3199,108.59.14.203:13010

lib/instaghub/application.ex

@@ -35,7 +35,8 @@ defmodule Instaghub.Application do
       Instaghub.Bucket.Schedule,
       :poolboy.child_spec(:ins_api_pool, poolboy_config_ins()),
       :poolboy.child_spec(:redis_pool, poolboy_config_redis()),
-      Instaghub.INS.Schedule
+      Instaghub.INS.Schedule,
+      Instaghub.Proxy
     ]
 
     # See https://hexdocs.pm/elixir/Supervisor.html

lib/instaghub/kv.ex

@@ -35,7 +35,7 @@ defmodule Instaghub.Bucket do
 
   def reset_req(key) do
     req = get(key)
-    Logger.debug "reset #{key} with 0, before is #{req}"
+    # Logger.debug "reset #{key} with 0, before is #{req}"
     put(key, 0)
   end
 

lib/instaghub/proxy.ex

@@ -0,0 +1,34 @@
+defmodule Instaghub.Proxy do
+  use GenServer
+  require Logger
+
+  @name :proxy
+
+  def start_link(_opts) do
+    GenServer.start_link(__MODULE__, 0, name: @name)
+  end
+
+  def get() do
+    GenServer.call(@name, :get)
+  end
+
+  def init(args) do
+    {:ok, args}
+  end
+
+  def handle_call(:get, _from, index) do
+    proxies = if System.get_env("PROXYS") != nil do
+      System.get_env("PROXYS") |> String.split(",")
+    else
+      nil
+    end
+    if proxies != nil do
+      len = length(proxies)
+      index = rem(index, len)
+      {:reply, proxies |> Enum.at(index), index+1}
+    else
+      {:reply, nil, 0}
+    end
+  end
+
+end

lib/instagram/ins_web_api.ex

@@ -1,6 +1,7 @@
 defmodule Ins.Web.API do
   require Logger
   alias Instaghub.RedisUtil
+  alias Instaghub.Proxy
 
   @base_url "https://www.instagram.com"
   @graphql_url_part "/graphql/query/"
@@ -166,7 +167,7 @@ defmodule Ins.Web.API do
 
   defp get(url_part, params) do
     headers = generate_header(params)
-    proxy_option = get_random_proxy()
+    proxy_option = get_loop_proxy()
     proxy = if proxy_option != nil do
       Logger.info "use proxy #{proxy_option}"
       # disable hackney connect pool for using rotate proxy IP
@@ -189,6 +190,10 @@ defmodule Ins.Web.API do
     |> handle_response
   end
 
+  defp get_loop_proxy() do
+    Proxy.get()
+  end
+
   defp get_random_proxy() do
     proxys = System.get_env("PROXYS")
     if proxys != nil do