create cloudflare_api module

2026-08-26 04:47:48 +08:00 · 2020-05-14 16:54:33 +08:00
parent 750d39e6b6
commit 6f505b2fe0
2 changed files with 112 additions and 0 deletions
@@ -0,0 +1,109 @@
+from config import api
+from common.query import Query
+from config.log import logger
+from time import sleep
+
+
+class CloudFlareAPI(Query):
+
+    def __init__(self, domain):
+        Query.__init__(self)
+        self.domain = domain
+        self.module = 'Dataset'
+        self.source = 'CloudFlareAPIQuery'
+        self.token = api.cloudflare_api_token
+        self.addr = 'https://api.cloudflare.com/client/v4/'
+        self.header = self.get_header()
+        self.header.update({'Authorization': 'Bearer ' + self.token})
+        self.header.update({'Content-Type': 'application/json'})
+        self.proxy = self.get_proxy(self.source)
+
+    def query(self):
+        """
+        query from source
+        """
+        account_id_resp = self.get(self.addr + 'accounts')
+        account_id = account_id_resp.json()['result'][0]['id']
+        # query domain zone, if it not exist, create
+        zones_resp = self.get(self.addr + 'zones',
+                              params={'name': self.domain}, check=False)
+        if zones_resp.json()['success'] and not zones_resp.json()['result']:
+            zone_id = self.create_zone(account_id)
+            if zone_id:
+                self.list_dns(zone_id)
+                return
+            else:
+                return
+        elif zones_resp.json()['success']:
+            zone_id = zones_resp.json()['result'][0]['id']
+            delete_zone_resp = self.delete(self.addr + f'zones/{zone_id}', check=False)
+            zone_id = self.create_zone(account_id)
+            if zone_id:
+                self.list_dns(zone_id)
+            return
+        elif not zones_resp.json()['success']:
+            logger.log('DEBUG',
+                       f'{self.domain} is banned or not a registered domain, so cannot be added to Cloudflare.')
+            return
+
+    def create_zone(self, account_id):
+        data = {"name": self.domain, "account": {"id": account_id}, "jump_start": True,
+                "type": "full"}
+        create_zone_resp = self.post(
+            self.addr + 'zones', json=data, check=False)
+        if create_zone_resp.json()['success']:
+            return create_zone_resp.json()['result']['id']
+        else:
+            logger.log('DEBUG', f'{self.domain} is temporarily banned and cannot be added to Cloudflare')
+            return False
+
+    def list_dns(self, zone_id):
+        page = 1
+        list_dns_resp = self.get(self.addr + f'zones/{zone_id}/dns_records', params={'page': page, 'per_page': 10})
+        subdomains = self.match_subdomains(self.domain, list_dns_resp.text)
+        self.subdomains = self.subdomains.union(subdomains)
+        if not self.subdomains:
+            # waiting for cloudflare enumerate subdomains
+            sleep(5)
+            self.list_dns(zone_id)
+        else:
+            total_pages = list_dns_resp.json()['result_info']['total_pages']
+            while True:
+                list_dns_resp = self.get(self.addr + f'zones/{zone_id}/dns_records',
+                                         params={'page': page, 'per_page': 10})
+                total_pages = list_dns_resp.json(
+                )['result_info']['total_pages']
+                subdomains = (self.match_subdomains(
+                    self.domain, list_dns_resp.text))
+                self.subdomains = self.subdomains.union(subdomains)
+                page += 1
+                if page > total_pages:
+                    break
+            return
+
+    def run(self):
+        """
+        class entrance
+        """
+        if not self.check(self.token):
+            return
+        self.begin()
+        self.query()
+        self.finish()
+        self.save_json()
+        self.gen_result()
+        self.save_db()
+
+
+def do(domain):  # 统一入口名字 方便多线程调用
+    """
+    class call entrance
+
+    :param str domain: 域名
+    """
+    query = CloudFlareAPI(domain)
+    query.run()
+
+
+if __name__ == '__main__':
+    do('example.com')