Skip to content
Open
Show file tree
Hide file tree
Changes from 7 commits
Commits
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
3 changes: 2 additions & 1 deletion .env
Original file line number Diff line number Diff line change
Expand Up @@ -7,4 +7,5 @@ REDIS_PORT=6379
REDIS_PASSWORD=
TWILIO_ACCOUNT_SID=a
TWILIO_ACCOUNT_TOKEN=b
TWILIO_PHONE_NUMBER=c
TWILIO_PHONE_NUMBER=c
SCRAPPER_SERVICE=https://sms-scrapper.rover.quenecesito.org/sms
1 change: 1 addition & 0 deletions .ruby-version
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
2.7.0
40 changes: 32 additions & 8 deletions workers/sms_request_worker.rb
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 @@ -12,17 +13,40 @@ class SmsRequestWorker

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"
sms_request = SmsRequest.find(sms_request_id)

if sms_request
resp=TwilioSms.send_sms(sms_request.phone, message)
uri = URI("#{ENV['SCRAPPER_ENDPOINT']}/#{sms_request.dui}")

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

sms_request.update_column(:status, 1)
sms_request.update_column(:last_error, resp)
p "The work is done: #{sms_request.inspect}"
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}"
else
p "Request failed: #{sms_request.inspect}"
end
rescue Net::ReadTimeout => exception
STDERR.puts "ReadTimeout error"
rescue Net::OpenTimeout => exception
STDERR.puts "OpenTimeout error"
end
end
end
end
end