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