lib/imperituroard.rb in imperituroard-0.2.4 vs lib/imperituroard.rb in imperituroard-0.2.5

@@ -202,11 +202,13 @@
       thr2 = Thread.new do
         for t in imei_list
           prof_name1 = mongo_client.get_profile_name_from_imei(t)
           if prof_name1[:code]==200
             begin
-              permiss1 = mongo_client.check_login_profile_permiss(login, prof_name1[:body]["profile"])[:code]
+              permiss1 = mongo_client.check_login_profile_permiss(login, prof_name1[:body]["profile"])
+              p "permiss1"
+              p permiss1
               if permiss1==200
                 ime_list_approved.append(t)
               else
                 ime_list_notapproved.append({:imei => t, :error => permiss1})
               end
@@ -445,17 +447,14 @@
   #imsi
   #msisdn
   #newdevice_list=[{:imei=>7967843245665, :attributes=>{:address=>"Golubeva51", :profile=>"wqeqcqeqwev", :msisdn=>375298766719, :imsi=>25702858586756875}}]
   #+
   def add_service(login, device_list, remote_ip)
-
     resp_out = {}
-
     not_processed = []
     processed = []
 
-
     input_json = {:login => login, :devices => device_list}
 
     begin
 
       for g in device_list
@@ -523,10 +522,20 @@
     mongo_client.audit_logger("device_remove", remote_ip, input_json, resp_out)
     resp_out
   end
 
 
+  def answ_dev_query_format_process(dev_list)
+    add_functions_connector.answ_dev_query_format_process(dev_list)
+  end
+
+
+  def logger_to_audit_database(proc_name, src_ip, input_json, output_json)
+    mongo_client.audit_logger(proc_name, src_ip, input_json, output_json)
+  end
+
+
   def test()
     ddd = MongoIot.new(mongoip, mongoport, mongo_database)
     #ddd.get_profiles_by_login("test")
 
     ff = [131234123412341233, 131234123127341233]
@@ -545,10 +554,16 @@
     #ddd1.querying_device_activ_status("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "7521234165452")
     #ddd1.querying_device_info("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "a8834c5e-4b4d-4f0f-ad87-14e916f3d0bb")
     list = ["41c0ba82-d771-4669-b766-fcbfbedc17f4", "7521234165452", "feb9c4d1-4944-4b04-a717-df87dfde30f7", "9868e121-c309-4f4f-8ab3-0aa69072caff", "b3b82f35-0723-4a83-90af-d4ea40017194"]
     #p ddd1.querying_device_direct_conn("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", list)
     #p ddd1.querying_device_type_list("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa")
-    p ddd1.querying_device_id("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "7521234165452")
+    #p ddd1.querying_device_id("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "7521234165452")
+    #p ddd1.dev_register_verif_code_mode("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "12321234545345")
+
+    p ddd1.quer_dev_direct_conn_batches("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", ["62c5f5ef-dead-48bf-9f09-292ca5e41577", "4c763ea1-be51-4eff-81db-863bc04791bb"])
+
+    #ddd1.querying_device_info("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "c6e0dfb1-8042-472a-a35d-e984f118d2a6")
+
     #ddd1.dev_delete("Cd1v0k2gTBCbpQlMVlW1FVqOSqga", "kbfo5JlBxTIhjVwtjHleWS5Iw5wa", "484114f6-a49c-4bab-88e6-4ddaf1cc1c8f")
   end
 
 
   def testhua2()