MCPcopy Create free account
hub / github.com/adobe/Marinus / main

Function main

python3_cron_scripts/get_passivetotal_data.py:122–165  ·  view source on GitHub ↗

Begin Main...

(logger=None)

Source from the content-addressed store, hash-verified

120
121
122def 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
168if __name__ == "__main__":

Callers 1

Calls 7

get_config_connectionMethod · 0.95
record_job_startMethod · 0.95
record_job_completeMethod · 0.95
search_pt_emailFunction · 0.85
search_pt_orgFunction · 0.85
search_pt_nameserverFunction · 0.85
create_logMethod · 0.80

Tested by

no test coverage detected