lib/imperituroard/projects/mhub/sk.rb in imperituroard-0.4.0 vs lib/imperituroard/projects/mhub/sk.rb in imperituroard-0.4.1

- old
+ new

@@ -18,47 +18,55 @@ input_params = {:msisdn => msisdn, :callback_url => callback_url, :text => text, :alphaname => alphaname} output_params = {} request_message = {} begin - uri = URI(sk_url) - #8 - client id - https = Net::HTTP.new(uri.host, uri.port) - https.use_ssl=true - https.verify_mode = OpenSSL::SSL::VERIFY_NONE - req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) + thr_sk_send_sms_one = Thread.new do - req.basic_auth sk_login, sk_password + uri = URI(sk_url) + #8 - client id - request_message = { - "phone_number": msisdn, - "extra_id": "4232j4h89932kjhs", - "callback_url": callback_url, - #"start_time": "2019-08-16 09:59:10", - "tag": "Dabrab_custom_api_1", - "channels": [ - "sms" - ], - "channel_options": { - "sms": { - "text": text, - "alpha_name": alphaname, - "ttl": 600 - } - } - } + https = Net::HTTP.new(uri.host, uri.port) + https.use_ssl=true + https.verify_mode = OpenSSL::SSL::VERIFY_NONE + req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) - req.body = request_message.to_json - res = https.request(req) - output_params = {:code => 200, - :result => "Sksk_1.sk_send_sms_one: Request processed", - :body => {:request_message => request_message, - :res_code => res.code, - :res_body => JSON.parse(res.body.to_s)}} - p res.body + req.basic_auth sk_login, sk_password + req["Content-Type"] = "application/json" + req["Accept"] = "application/json" + + request_message = { + "phone_number": msisdn, + "extra_id": "4232j4h89932kjhs", + "callback_url": callback_url, + #"start_time": "2019-08-16 09:59:10", + "tag": "Dabrab_custom_api_1", + "channels": [ + "sms" + ], + "channel_options": { + "sms": { + "text": text, + "alpha_name": alphaname, + "ttl": 600 + } + } + } + + req.body = request_message.to_json + res = https.request(req) + output_params = {:code => 200, + :result => "Sksk_1.sk_send_sms_one: Request processed", + :body => {:request_message => request_message, + :res_code => res.code, + :res_body => JSON.parse(res.body.to_s)}} + end + + thr_sk_send_sms_one.join + rescue output_params = {:code => 500, :result => "Sksk_1.sk_send_sms_one: Something wrong", :body => {:request_message => request_message}} end internal_func.printer_texter({:input => input_params, :output => output_params, :procedure => "Sksk_1.sk_send_sms_one"}, "debug") output_params @@ -71,47 +79,58 @@ output_params = {} request_message = {} begin - uri = URI(sk_url) - #8 - client id + thr_sk_send_viber_one = Thread.new do - https = Net::HTTP.new(uri.host, uri.port) - https.use_ssl=true - https.verify_mode = OpenSSL::SSL::VERIFY_NONE - req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) - req.basic_auth sk_login, sk_password + uri = URI(sk_url) + #8 - client id - request_message = { - "phone_number": msisdn, - "extra_id": "4232j4h89932kjhs", - "callback_url": callback_url, - #"start_time": "2019-08-16 09:59:10", - "tag": "Dabrab_custom_api_1", - "channels": [ - "viber" - ], - "channel_options": { - "viber": { - "text": text, - "ttl": 60, - # "img": "http://olddogs.org/logo.png", - # "caption": "Old Dogs need you!", - # "action": "http://olddogs.org", - }, - } - } - req.body = request_message.to_json - res = https.request(req) - output_params = {:code => 200, - :result => "Sksk_1.sk_send_viber_one: Request processed", - :body => {:request_message => request_message, - :res_code => res.code, - :res_body => JSON.parse(res.body.to_s)}} + https = Net::HTTP.new(uri.host, uri.port) + https.use_ssl=true + https.verify_mode = OpenSSL::SSL::VERIFY_NONE + req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) + req.basic_auth sk_login, sk_password + + req["Content-Type"] = "application/json" + req["Accept"] = "application/json" + + request_message = { + "phone_number": msisdn, + "extra_id": "4232j4h89932kjhs", + "callback_url": callback_url, + #"start_time": "2019-08-16 09:59:10", + "tag": "Dabrab_custom_api_1", + "channels": [ + "viber" + ], + "channel_options": { + "viber": { + "text": text, + "ttl": 60, + # "img": "http://olddogs.org/logo.png", + # "caption": "Old Dogs need you!", + # "action": "http://olddogs.org", + }, + } + } + req.body = request_message.to_json + res = https.request(req) + output_params = {:code => 200, + :result => "Sksk_1.sk_send_viber_one: Request processed", + :body => {:request_message => request_message, + :res_code => res.code, + :res_body => JSON.parse(res.body.to_s)}} + + end + + thr_sk_send_viber_one.join + + rescue output_params = {:code => 500, :result => "Sksk_1.sk_send_viber_one: Something wrong"} end internal_func.printer_texter({:input => input_params, :output => output_params, :procedure => "Sksk_1.sk_send_viber_one"}, "debug") output_params @@ -123,55 +142,64 @@ output_params = {} request_message = {} begin - uri = URI(sk_url) - #8 - client id + thr_sk_send_viber_sms_one = Thread.new do - https = Net::HTTP.new(uri.host, uri.port) - https.use_ssl=true - https.verify_mode = OpenSSL::SSL::VERIFY_NONE - req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) + uri = URI(sk_url) + #8 - client id - req.basic_auth sk_login, sk_password + https = Net::HTTP.new(uri.host, uri.port) + https.use_ssl=true + https.verify_mode = OpenSSL::SSL::VERIFY_NONE + req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) - request_message = { - "phone_number": msisdn, - "extra_id": "4232j4h89932kjhs", - "callback_url": callback_url, - #"start_time": "2019-08-16 09:59:10", - "tag": "Dabrab_custom_api_1", - "channels": [ - "viber", - "sms" - ], - "channel_options": { - "sms": { - "text": sms_text, - "alpha_name": alphaname, - "ttl": 600 - }, - "viber": { - "text": viber_txt, - "ttl": 60, - # "img": "http://olddogs.org/logo.png", - # "caption": "Old Dogs need you!", - # "action": "http://olddogs.org", - }, - } - } + req.basic_auth sk_login, sk_password - req.body = request_message.to_json - res = https.request(req) + req["Content-Type"] = "application/json" + req["Accept"] = "application/json" - output_params = {:code => 200, - :result => "Sksk_1.sk_send_viber_sms_one: Request processed", - :body => {:request_message => request_message, - :res_code => res.code, - :res_body => JSON.parse(res.body.to_s)}} + request_message = { + "phone_number": msisdn, + "extra_id": "4232j4h89932kjhs", + "callback_url": callback_url, + #"start_time": "2019-08-16 09:59:10", + "tag": "Dabrab_custom_api_1", + "channels": [ + "viber", + "sms" + ], + "channel_options": { + "sms": { + "text": sms_text, + "alpha_name": alphaname, + "ttl": 600 + }, + "viber": { + "text": viber_txt, + "ttl": 60, + # "img": "http://olddogs.org/logo.png", + # "caption": "Old Dogs need you!", + # "action": "http://olddogs.org", + }, + } + } + req.body = request_message.to_json + res = https.request(req) + + output_params = {:code => 200, + :result => "Sksk_1.sk_send_viber_sms_one: Request processed", + :body => {:request_message => request_message, + :res_code => res.code, + :res_body => JSON.parse(res.body.to_s)}} + + end + + thr_sk_send_viber_sms_one.join + rescue output_params = {:code => 500, :result => "Sksk_1.sk_send_viber_sms_one: Something wrong"} end internal_func.printer_texter({:input => input_params, :output => output_params, :procedure => "Sksk_1.sk_send_viber_sms_one"}, "debug") output_params @@ -184,47 +212,55 @@ input_params = {:msisdn_list => msisdn_list, :callback_url => callback_url, :text => text, :alphaname => alphaname} output_params = {} request_message = {} begin - uri = URI(sk_url_broadcast) - #8 - client id - https = Net::HTTP.new(uri.host, uri.port) - https.use_ssl = true - https.verify_mode = OpenSSL::SSL::VERIFY_NONE - req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) + thr_sk_send_sms_list = Thread.new do - req.basic_auth sk_login, sk_password + uri = URI(sk_url_broadcast) + #8 - client id - # [{"phone_number": 375298766719}, {"phone_number": 375295730878}] - request_message = { - "recipients": msisdn_list, - "callback_url": callback_url, - "tag": "Dabrab_custom_api_1", - "channels": [ - "sms" - ], - "channel_options": { - "sms": { - "alpha_name": alphaname, - "text": text, - "ttl": 60 - } - } - } + https = Net::HTTP.new(uri.host, uri.port) + https.use_ssl = true + https.verify_mode = OpenSSL::SSL::VERIFY_NONE + req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) - p request_message + req.basic_auth sk_login, sk_password - req.body = request_message.to_json - res = https.request(req) + req["Content-Type"] = "application/json" + req["Accept"] = "application/json" - output_params = {:code => 200, - :result => "Sksk_1.sk_send_sms_list: Request processed", - :body => {:request_message => request_message, - :res_code => res.code, - :res_body => JSON.parse(res.body.to_s)}} + # [{"phone_number": 375298766719}, {"phone_number": 375295730878}] + request_message = { + "recipients": msisdn_list, + "callback_url": callback_url, + "tag": "Dabrab_custom_api_1", + "channels": [ + "sms" + ], + "channel_options": { + "sms": { + "alpha_name": alphaname, + "text": text, + "ttl": 60 + } + } + } + + req.body = request_message.to_json + res = https.request(req) + + output_params = {:code => 200, + :result => "Sksk_1.sk_send_sms_list: Request processed", + :body => {:request_message => request_message, + :res_code => res.code, + :res_body => JSON.parse(res.body.to_s)}} + + end + thr_sk_send_sms_list.join + rescue output_params = {:code => 500, :result => "Sksk_1.sk_send_sms_list: Something wrong"} end internal_func.printer_texter({:input => input_params, :output => output_params, :procedure => "Sksk_1.sk_send_sms_list"}, "debug") output_params @@ -236,106 +272,114 @@ input_params = {:msisdn_list => msisdn_list, :callback_url => callback_url, :text => text} output_params = {} request_message = {} begin - uri = URI(sk_url_broadcast) - #8 - client id - https = Net::HTTP.new(uri.host, uri.port) - https.use_ssl = true - https.verify_mode = OpenSSL::SSL::VERIFY_NONE - req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) + thr_sk_send_viber_list = Thread.new do + uri = URI(sk_url_broadcast) + #8 - client id - req.basic_auth sk_login, sk_password + https = Net::HTTP.new(uri.host, uri.port) + https.use_ssl = true + https.verify_mode = OpenSSL::SSL::VERIFY_NONE + req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) - # [{"phone_number": 375298766719}, {"phone_number": 375295730878}] - request_message = { - "recipients": msisdn_list, - "callback_url": callback_url, - "tag": "Dabrab_custom_api_1", - "channels": [ - "viber" - ], - "channel_options": { - "viber": { - "text": text, - "ttl": 60 - } - } - } + req["Content-Type"] = "application/json" + req["Accept"] = "application/json" - p request_message + req.basic_auth sk_login, sk_password - req.body = request_message.to_json - res = https.request(req) - output_params = {:code => 200, - :result => "Sksk_1.sk_send_viber_list: Request processed", - :body => {:request_message => request_message, - :res_code => res.code, - :res_body => JSON.parse(res.body.to_s)}} + # [{"phone_number": 375298766719}, {"phone_number": 375295730878}] + request_message = { + "recipients": msisdn_list, + "callback_url": callback_url, + "tag": "Dabrab_custom_api_1", + "channels": [ + "viber" + ], + "channel_options": { + "viber": { + "text": text, + "ttl": 60 + } + } + } + + req.body = request_message.to_json + res = https.request(req) + + output_params = {:code => 200, + :result => "Sksk_1.sk_send_viber_list: Request processed", + :body => {:request_message => request_message, + :res_code => res.code, + :res_body => JSON.parse(res.body.to_s)}} + end + thr_sk_send_viber_list.join rescue output_params = {:code => 500, :result => "Sksk_1.sk_send_viber_list: Something wrong"} end internal_func.printer_texter({:input => input_params, :output => output_params, :procedure => "Sksk_1.sk_send_viber_list"}, "debug") output_params end def sk_send_viber_sms_list(msisdn_list, callback_url, sms_text, viber_text, alphaname) - p "stat" - input_params = {:msisdn_list => msisdn_list, :callback_url => callback_url, :sms_text => sms_text, :viber_text => viber_text, :alphaname => alphaname} output_params = {} request_message = {} begin - p "hhhh" - uri = URI(sk_url_broadcast) - #8 - client id + thr_sk_send_viber_sms_list = Thread.new do + uri = URI(sk_url_broadcast) + #8 - client id + https = Net::HTTP.new(uri.host, uri.port) + https.use_ssl = true + https.verify_mode = OpenSSL::SSL::VERIFY_NONE + req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) - https = Net::HTTP.new(uri.host, uri.port) - https.use_ssl = true - https.verify_mode = OpenSSL::SSL::VERIFY_NONE - req = Net::HTTP::Post.new(uri.path, initheader = {:"Content-Type" => 'application/json'}) + req.basic_auth sk_login, sk_password - req.basic_auth sk_login, sk_password - # [{"phone_number": 375298766719}, {"phone_number": 375295730878}] - request_message = { - "recipients": msisdn_list, - "callback_url": callback_url, - "tag": "Dabrab_custom_api_1", - "channels": [ - "viber", - "sms" - ], - "channel_options": { - "sms": { - "alpha_name": alphaname, - "text": sms_text, - "ttl": 60 - }, - "viber": { - "text": viber_text, - "ttl": 60 - } - } - } + req["Content-Type"] = "application/json" + req["Accept"] = "application/json" + # [{"phone_number": 375298766719}, {"phone_number": 375295730878}] + request_message = { + "recipients": msisdn_list, + "callback_url": callback_url, + "tag": "Dabrab_custom_api_1", + "channels": [ + "viber", + "sms" + ], + "channel_options": { + "sms": { + "alpha_name": alphaname, + "text": sms_text, + "ttl": 60 + }, + "viber": { + "text": viber_text, + "ttl": 60 + } + } + } - p request_message + req.body = request_message.to_json + res = https.request(req) - req.body = request_message.to_json - res = https.request(req) + output_params = {:code => 200, + :result => "Sksk_1.sk_send_viber_sms_list: Request processed", + :body => {:request_message => request_message, + :res_code => res.code, + :res_body => JSON.parse(res.body.to_s)}} + end - output_params = {:code => 200, - :result => "Sksk_1.sk_send_viber_sms_list: Request processed", - :body => {:request_message => request_message, - :res_code => res.code, - :res_body => JSON.parse(res.body.to_s)}} + thr_sk_send_viber_sms_list.join + rescue output_params = {:code => 500, :result => "Sksk_1.sk_send_viber_sms_list: Something wrong"} end internal_func.printer_texter({:input => input_params, :output => output_params, :procedure => "Sksk_1.sk_send_viber_sms_list"}, "debug") output_params \ No newline at end of file