From 50b93f06d05e1b5a0c10023b0dff1daaf8e3e1cd Mon Sep 17 00:00:00 2001
From: jyhl <zhongpei@vip.qq.com>
Date: Wed, 24 Jun 2020 11:21:05 +0800
Subject: [PATCH] init

---
 README.MD        |   4 ++
 config.cfg       |   9 ++++
 renew_ip.py      | 133 +++++++++++++++++++++++++++++++++++++++++++++++
 requirements.txt |   1 +
 4 files changed, 147 insertions(+)
 create mode 100644 README.MD
 create mode 100644 config.cfg
 create mode 100644 renew_ip.py
 create mode 100644 requirements.txt

diff --git a/README.MD b/README.MD
new file mode 100644
index 0000000..f2406c5
--- /dev/null
+++ b/README.MD
@@ -0,0 +1,4 @@
+# 配置config.cfg
+url : 代理获取url
+index:  ip白名单编号,不同的机器配置不同编号,编号从0开始
+wait: 更新IP间隔，单位秒
diff --git a/config.cfg b/config.cfg
new file mode 100644
index 0000000..0e23253
--- /dev/null
+++ b/config.cfg
@@ -0,0 +1,9 @@
+[main]
+# 代理url
+url=http://ip.16yun.cn:817/myip/pl/b1c75840-40a0-115b-1173-3a66ce51110f/?s=amypvklrkb&u=test
+
+# ip编号,0为第一个
+index=0
+
+# 更新间隔
+wait=60
diff --git a/renew_ip.py b/renew_ip.py
new file mode 100644
index 0000000..fd18ea5
--- /dev/null
+++ b/renew_ip.py
@@ -0,0 +1,133 @@
+import logging
+import re
+import time
+from json import dumps
+
+import requests
+
+try:
+    from urllib import urlencode, unquote
+    from urlparse import urlparse, parse_qsl, ParseResult
+except ImportError:
+    # Python 3 fallback
+    from urllib.parse import (
+        urlencode, unquote, urlparse, parse_qsl, ParseResult
+    )
+
+_IPV4 = re.compile(r'^(\d{1,3}\.){3}\d{1,3}$')
+
+
+def init_logging(name, level=logging.INFO, filename=None):
+    logger = logging.getLogger(name)
+    logger.setLevel(level)
+
+    formatter = logging.Formatter("%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s")
+
+    if filename:
+        fh = logging.FileHandler(filename, "a+")
+        fh.setLevel(level)
+        fh.setFormatter(formatter)
+        logger.addHandler(fh)
+
+    ch = logging.StreamHandler()
+
+    ch.setFormatter(formatter)
+
+    logger.addHandler(ch)
+    return logger
+
+
+def add_url_params(url, params):
+    """ Add GET params to provided URL being aware of existing.
+
+    :param url: string of target URL
+    :param params: dict containing requested params to be added
+    :return: string with updated URL
+
+    >> url = 'http://stackoverflow.com/test?answers=true'
+    >> new_params = {'answers': False, 'data': ['some','values']}
+    >> add_url_params(url, new_params)
+    'http://stackoverflow.com/test?data=some&data=values&answers=false'
+    """
+    # Unquoting URL first so we don't loose existing args
+    url = unquote(url)
+    # Extracting url info
+    parsed_url = urlparse(url)
+    # Extracting URL arguments from parsed URL
+    get_args = parsed_url.query
+    # Converting URL arguments to dict
+    parsed_get_args = dict(parse_qsl(get_args))
+    # Merging URL arguments dict with new params
+    parsed_get_args.update(params)
+
+    # Bool and Dict values should be converted to json-friendly values
+    # you may throw this part away if you don't like it :)
+    parsed_get_args.update(
+        {k: dumps(v) for k, v in parsed_get_args.items()
+         if isinstance(v, (bool, dict))}
+    )
+
+    # Converting URL argument to proper search string
+    encoded_get_args = urlencode(parsed_get_args, doseq=True)
+    # Creating new parsed result object based on provided with new
+    # URL arguments. Same thing happens inside of urlparse.
+    new_url = ParseResult(
+        parsed_url.scheme, parsed_url.netloc, parsed_url.path,
+        parsed_url.params, encoded_get_args, parsed_url.fragment
+    ).geturl()
+
+    return new_url
+
+
+def validate_ipv4(ip):
+    if ip is None:
+        return False
+    return _IPV4.match(ip)
+
+
+logger = init_logging(name="renew", filename="log.txt")
+
+
+def get_ip():
+    r = requests.get("http://current-ip.16yun.cn:802")
+    r.close()
+    if r.ok and validate_ipv4(r.text):
+        logger.info("get public ip {}".format(r.text))
+        return r.text
+
+
+def renew_ip(ip, url, index):
+    url = add_url_params(url, {"index": index, "newip": ip})
+    logger.info("url {}".format(url))
+    r = requests.get(url)
+    r.close()
+    if r.ok:
+        logger.info("renew ip {}".format(ip))
+        return True
+    else:
+        print(r.text)
+
+
+def main(url, index, wait):
+    old_ip = None
+    while True:
+        try:
+            ip = get_ip()
+            if ip != old_ip:
+                renew_ip(ip=ip, url=url, index=index)
+                old_ip = ip
+        except Exception as err:
+            logger.error(err)
+        time.sleep(wait)
+
+
+if __name__ == "__main__":
+    import ConfigParser
+
+    config = ConfigParser.ConfigParser()
+    config.readfp(open('config.cfg'))
+    url = config.get("main", "url")
+    index = config.getint("main", "index")
+    wait = config.getint("main", "wait")
+    logger.info("index {}".format(index))
+    main(url=url, index=index, wait=wait)
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..f229360
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1 @@
+requests