Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def refresh
- local_to_date = nil
- local_from_date = nil
- if (request.has_field?(:to_date))
- local_to_date = Time.at(request.to_date).utc.to_i
- else
- request.to_date = Time.new.to_i
- end
- if (request.has_field?(:from_date))
- local_from_date = Time.at(request.from_date).utc.to_i
- else
- request.from_date = 1.day.ago.to_i
- end
- # puts 'before refresh call'
- self.async_responder = true
- Atlas::Persona::MemberRefreshService.client(:async => true).refresh(request) do |c|
- c.on_failure do |error|
- rpc_failed error
- end
- c.on_success do |persona_response|
- begin
- <<<<<<< HEAD
- =======
- #SyncSystem.account_sync(request.member_guid, persona_response.accounts, request.from_date, request.to_date)
- unless persona_response.accounts.empty?
- proto_account_guids = persona_response.accounts.map {|a| a.guid}
- db_accounts = ::Account.where("guid IN (?) AND (status = ? OR status = ?)", proto_account_guids, Atlas::StatusType::ENABLED.value, Atlas::StatusType::HIDDEN.value)
- db_accounts.each {|a| response.accounts << a.to_proto(local_from_date, local_to_date, true)}
- end
- >>>>>>> d30a6109a92cab5fc543461c725601d5303060da
- db_accounts = ::Account.where("member_guid = ? AND (status = ? OR status = ?)", request.member_guid, Atlas::StatusType::ENABLED.value, Atlas::StatusType::HIDDEN.value)
- #db_accounts = ::Account.where(:member_guid => request.member_guid, :status => Atlas::StatusType::ENABLED)
- db_accounts.each {|a| response.accounts << a.to_proto(local_from_date, local_to_date, true)}
- response.status = persona_response.status
- response.member_status = persona_response.member_status if persona_response.has_field?(:member_status)
- send_response
- rescue => e
- # puts 'error'
- # puts e.message
- rpc_failed "Refresh was successful in Persona, but failed in Abacus! Error => #{e.message}"
- end
- end
- end
- end
Add Comment
Please, Sign In to add comment