200 def test_successful_connection_validate_data(self):
201 """Test successful data (all categories) pull from Mammoth.""" 203 for ind, this_migrator
in enumerate(self.list_of_migrators):
205 if (this_migrator.data_category == DATA_OPT_MEMDATA
and 206 self.list_of_http_requests[ind] ==
""):
209 this_migrator._initiate_http_request()
211 resp = this_migrator.response
213 if this_migrator.data_category == DATA_OPT_CREATE_HIST:
214 self.assertIsInstance(resp, dict)
217 for expected_resp_key
in self.expected_response_hist_keys:
218 self.assertIn(expected_resp_key, resp.keys())
221 chist_error = resp[
"error"]
222 data_fname = resp[
"file"]
223 assert (data_fname ==
"" and chist_error !=
"") \
224 or (data_fname !=
"" and chist_error ==
"")
226 elif this_migrator.data_category == DATA_OPT_GET_HIST:
227 self.assertIsInstance(resp.content, bytes)
230 with self.assertRaises((ValueError)):
235 self.assertIsInstance(resp, dict)
236 self.assertEqual(resp[
"error"], self.default_err_msg)
239 for expected_resp_key
in self.expected_response_keys:
240 self.assertIn(expected_resp_key, resp.keys())
242 data_dict = resp[
"data"]
245 if this_migrator.data_category == DATA_OPT_MEMDATA:
246 memdata_true_dict_struct = self.extected_data_keys[
247 this_migrator.data_category]
249 self.assertEqual(len(data_dict.keys()), 1)
250 self.assertEqual(list(data_dict.keys())[0],
"account")
252 for member_response
in data_dict[
"account"].keys():
253 self.assertEqual(sorted(
254 data_dict[
"account"][member_response].keys()),
255 sorted(memdata_true_dict_struct))
259 for expected_data_key
in self.extected_data_keys[
260 this_migrator.data_category]:
261 self.assertIn(expected_data_key, data_dict.keys())
264 if this_migrator.data_category == DATA_OPT_SETTINGS:
266 self.assertEqual(len(data_dict[
"cuadmin"]), 1)
267 self.assertEqual(data_dict[
"cuadmin"][
268 0][
"cu"].strip(), this_migrator.cu)