lib/imperituroard/projects/iot/mongoconnector.rb in imperituroard-0.3.3 vs lib/imperituroard/projects/iot/mongoconnector.rb in imperituroard-0.3.4

- old
+ new

@@ -21,11 +21,11 @@ end def audit_logger(proc_name, src_ip, input_json, output_json, real_ip) out_resp = {} begin - current = DateTime.now + current = internal_func.datetimenow collection = client[:audit] doc = { :proc_name => proc_name, :date => current, :sender => {:src_ip => src_ip, :real_ip => real_ip}, @@ -65,18 +65,49 @@ } out_resp = {:code => 200, :result => "get_profiles_by_login: Request completed successfully", :body => result_ps} else out_resp = {:code => 404, :result => "get_profiles_by_login: Access denied. Incorrect login"} end - rescue out_resp = {:code => 507, :result => "get_profiles_by_login: Unknown SDK error"} end internal_func.printer_texter(out_resp, "debug") out_resp end + + def get_login_info(login) + out_resp = {} + begin + login_profiles = [] + req2 = [] + result_ps = [] + collection = client[:users] + collection2 = client[:device_profiles] + collection.find({:login => login}).each {|row| + login_profiles = row + } + p "login_profiles" + p login_profiles + if login_profiles != [] && login_profiles["login"] != nil && login_profiles["login"] != "" + passw_check = internal_func.check_pass_format(login_profiles["password"]) + if passw_check[:code]==200 + out_resp = {:code => 200, :result => "get_login_info: Request completed successfully", :body => login_profiles} + else + out_resp = {:code => 405, :result => "get_login_info: incorrect password"} + end + else + out_resp = {:code => 404, :result => "get_login_info: login not found in database"} + end + rescue + out_resp = {:code => 507, :result => "get_login_info: Unknown SDK error"} + end + p out_resp + internal_func.printer_texter(out_resp, "debug") + out_resp + end + def get_imei_info_from_db(imeilist) out_resp = {} p imeilist p "imeilist" begin @@ -123,28 +154,17 @@ end end def check_login_profile_permiss(login, profile) out_resp = {} - p "profile" - p profile get_login_info = get_profiles_by_login(login) - p "get_login_info" - p get_login_info - if get_login_info[:code]==200 - - dst_profile = get_profile_id_by_name(profile) - p "dst_profile" - p dst_profile access=1 if get_login_info[:body]!=[] if dst_profile!=[] - p "sgsgsd" for j in get_login_info[:body] - p j if j["profile_id"].to_i==dst_profile["profile_id"].to_i access=0 end if access==0 out_resp = {:code => 200, :result => "check_login_profile_permiss: Permission granted"} @@ -166,20 +186,14 @@ end def check_login_prof_perm_id_one(login, profile_id) out_resp = {} - p "profile" - p profile_id get_login_info = get_profiles_by_login(login) - p "get_login_info" - p get_login_info access=1 if get_login_info[:body]!=[] - p "sgsgsd" for j in get_login_info[:body] - p j if j["profile_id"].to_i==profile_id.to_i access=0 end if access==0 out_resp = {:code => 200, :result => "check_login_prof_perm_id_one: Permission granted"} @@ -196,34 +210,24 @@ def check_imei_exists(imei_list) out_resp = {} res_exists = [] imei_list_res = get_imei_info_from_db(imei_list) - p imei_list_res - p "imei_list" for k in imei_list_res[:body] - p k res_exists.append(k["imei"]) end - p "aaaa" - p imei_list - p res_exists not_ex = imei_list - res_exists - p "not_ex" - p not_ex - p res_exists out_resp = {:code => 200, :result => "check_imei_exists: Request completed successfully", :body => {:exists => res_exists, :not_exists => not_ex}} internal_func.printer_texter(out_resp, "debug") out_resp end def imei_insert_list(imei_list) begin collection = client[:device_imei] - p imei_list for l in imei_list doc = { imei: l, imsi: "unknown", msisdn: "unknown", @@ -243,11 +247,10 @@ def imei_insert_list2(imei_list) begin collection = client[:device_imei] - p imei_list for l in imei_list doc = { imei: l, imsi: "unknown", msisdn: "unknown", @@ -281,20 +284,13 @@ out_resp = {} begin id = "" begin info = get_imei_info_from_db([imei]) - p info - p "info" if info[:body]==[] out_resp = {:code => 505, :result => "get_profile_name_from_imei: get_imei_info_from_db returned empty list from database. IMEIS not found"} else - p "fshhsdf" - p info id = info[:body][0]["profile"] - p id - p "id" - begin p id res = get_profile_name_by_id(id) p res if res.key?("profile") \ No newline at end of file