Skip to content

Added PoC for integration with scrapper #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
mxgxw wants to merge 11 commits into
base: master
Choose a base branch
from
+48 −10
Open

Added PoC for integration with scrapper #1

Changes from 3 commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
2ed0576
Added PoC for integration to scrapper
mxgxw Mar 30, 2020
0f2c35a
Added validation for response code
mxgxw Mar 30, 2020
89d46d2
some todos done
rodrigo-puente Mar 30, 2020
471d657
Added timeout for HTTP resquest
mxgxw Mar 30, 2020
37aec5b
Added timeouts
rodrigo-puente Mar 30, 2020
e6efc32
Log the exception
rodrigo-puente Mar 30, 2020
8124ce0
fixed if/begin
rodrigo-puente Mar 30, 2020
57894f5
Added failure codes.
mxgxw Mar 30, 2020
f780728
Re-escritura de mensaje y procesamiento de erro.
mxgxw Mar 30, 2020
846c5c8
[add] Configuración para enviar mensages a Dead
eulesv Mar 31, 2020
4ce94dc
Merge pull request #3 from eulesv/dead
carloscarcamo Apr 5, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 25 additions & 8 deletions workers/sms_request_worker.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
require 'net/http'
require "sidekiq"
require "rack/env"
require "sinatra/activerecord"
Expand All @@ -14,15 +15,31 @@ def perform(sms_request_id)
puts "::::::::::::::::::::::::::::::::::::::::::::::::::: Worker doing somthing \n"
sms_request=SmsRequest.find(sms_request_id)

# GET MESSAGE
message = "Buxos ya llegan los sms, solo falta integrar con scraping XD"

if sms_request
resp=TwilioSms.send_sms(sms_request.phone, message)
# TODO: Add endpoint as parameter
uri = URI('https://sms-scrapper.rover.quenecesito.org/sms/'+sms_request.dui)

# TODO: Add timeout as parameter
Net::HTTP.start(uri.host,uri.port,
:use_ssl => uri.scheme == 'https',
:read_timeout => 10) do |http|
request = Net::HTTP::Get.new uri
response = http.request request
end

if response.code == 200
# TODO: Process response or enqueue again in case of error
message = response.read_body

resp=TwilioSms.send_sms(sms_request.phone, message)

sms_request.update_column(:status, 1)
sms_request.update_column(:last_error, resp)
p "The work is done: #{sms_request.inspect}"
sms_request.update_column(:status, 1)
sms_request.update_column(:last_error, resp)

p "The work is done: #{sms_request.inspect}"
else
p "Request failed: #{sms_request.inspect}"
end
end
end
end
end