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