Begin Main...
(logger=None)
| 120 | |
| 121 | |
| 122 | def main(logger=None): |
| 123 | """ |
| 124 | Begin Main... |
| 125 | """ |
| 126 | if logger is None: |
| 127 | logger = LoggingUtil.create_log(__name__) |
| 128 | |
| 129 | now = datetime.now() |
| 130 | print("Starting: " + str(now)) |
| 131 | logger.info("Starting...") |
| 132 | |
| 133 | # Obtain the list of known email addresses from the config collection |
| 134 | MC = MongoConnector.MongoConnector() |
| 135 | PT = PassiveTotal.PassiveTotal() |
| 136 | zi = ZoneIngestor.ZoneIngestor() |
| 137 | config_collection = MC.get_config_connection() |
| 138 | res = config_collection.find({}) |
| 139 | |
| 140 | jobs_manager = JobsManager.JobsManager(MC, "get_passivetotal_data") |
| 141 | jobs_manager.record_job_start() |
| 142 | |
| 143 | # Perform a search for each email address |
| 144 | for i in range(0, len(res[0]["DNS_Admins"])): |
| 145 | search_pt_email(logger, res[0]["DNS_Admins"][i], PT, zi, jobs_manager) |
| 146 | |
| 147 | for i in range(0, len(res[0]["Whois_Orgs"])): |
| 148 | search_pt_org(logger, res[0]["Whois_Orgs"][i], PT, zi, jobs_manager) |
| 149 | |
| 150 | for i in range(0, len(res[0]["Whois_Name_Servers"])): |
| 151 | search_pt_nameserver( |
| 152 | logger, |
| 153 | res[0]["Whois_Name_Servers"][i], |
| 154 | res[0]["Whois_Orgs"], |
| 155 | PT, |
| 156 | zi, |
| 157 | jobs_manager, |
| 158 | ) |
| 159 | |
| 160 | # Record status |
| 161 | jobs_manager.record_job_complete() |
| 162 | |
| 163 | now = datetime.now() |
| 164 | print("Complete: " + str(now)) |
| 165 | logger.info("Complete.") |
| 166 | |
| 167 | |
| 168 | if __name__ == "__main__": |
no test coverage detected