How can I implement delayed_job gem to this action/actions? It gets plist from an API and inserts those values to database. I just want it insert datas as a background process...
def get_videos_from_outer(page=params[:page], kid=params[:kid], totalCount="")
@videos = Video.where(program_id: params[:p_id])
@program = Program.find(params[:p_id])
@fetch = Typhoeus::Request.post("URL", :params => {:commandtype=>"getprogramepisodes", :feedtype=>"plist",:id=>kid.to_i, :page=>page.to_i})
@plist = Plist::parse_xml(@fetch.body.force_encoding 'utf-8')
@totalCount = @plist.second.first['totalCount']
if !totalCount.blank?
@totalCount = totalCount
end
import_outer_videos(@plist, kid, page.to_i, @totalCount.to_i)
end
And the import_outer_videos
method.
private
def import_outer_videos(plist, kid, page, totalCount)
@totalCount = totalCount
plist.second.each_with_index do |t, i|
# First page has odd data and here we're getting rid off them
if page.to_i==1
if i > 0
@new = Video.create(:thumb_path=>t['tnPath'], :vid=>t['id'], :title=>t['title'], :type=>t['type'], :kid=>kid, :program_id=>@program.id)
end
else
@new = Video.create(:thumb_path=>t['tnPath'], :vid=>t['id'], :title=>t['title'], :type=>t['type'], :kid=>kid, :program_id=>@program.id)
end
end
if page.to_i < (@totalCount.to_i/20) + 1
page = page.to_i + 1
get_videos_from_outer(page.to_i, kid.to_i, @totalCount)
else
redirect_to :action=>"index", :p_id=>params[:p_id]
end
if @new.errors.blank?
flash[:notice]="#{@totalCount} videos has been transfered."
else
flash[:notice]="No new video."
end
end
Create app/workers/my_job.rb
, with something like:
class MyJob < Struct.new(:p1, :p2)
def perform
# put all your hard work here.
# APIClass.get_videos_from_outer(p1, p2)
# or something.
end
end
Then call it with:
Delayed::Job.enqueue(MyJob.new(foo, bar), 0, 2.hours.from_now)
or something.