module AnswersEngine module Client class JobPage < AnswersEngine::Client::Base def find(job_id, gid) self.class.get("/jobs/#{job_id}/pages/#{gid}", @options) end def all(job_id, opts={}) params = @options.merge(opts) self.class.get("/jobs/#{job_id}/pages", params) end def update(job_id, gid, opts={}) body = {} body[:page_type] = opts[:page_type] if opts[:page_type] body[:priority] = opts[:priority] if opts[:priority] body[:vars] = opts[:vars] if opts[:vars] params = @options.merge({body: body.to_json}) self.class.put("/jobs/#{job_id}/pages/#{gid}", params) end def enqueue(job_id, method, url, opts={}) body = {} body[:method] = method != "" ? method : "GET" body[:url] = url body[:page_type] = opts[:page_type] if opts[:page_type] body[:priority] = opts[:priority] if opts[:priority] body[:fetch_type] = opts[:fetch_type] if opts[:fetch_type] body[:body] = opts[:body] if opts[:body] body[:headers] = opts[:headers] if opts[:headers] body[:vars] = opts[:vars] if opts[:vars] body[:force_fetch] = opts[:force_fetch] if opts[:force_fetch] body[:freshness] = opts[:freshness] if opts[:freshness] body[:ua_type] = opts[:ua_type] if opts[:ua_type] body[:no_redirect] = opts[:no_redirect] if opts[:no_redirect] body[:cookie] = opts[:cookie] if opts[:cookie] params = @options.merge({body: body.to_json}) self.class.post("/jobs/#{job_id}/pages", params) end def parsing_update(job_id, gid, opts={}) body = {} body[:outputs] = opts.fetch(:outputs) {[]} body[:pages] = opts.fetch(:pages) {[]} body[:parsing_status] = opts.fetch(:parsing_status){ nil } body[:log_error] = opts[:log_error] if opts[:log_error] params = @options.merge({body: body.to_json}) self.class.put("/jobs/#{job_id}/pages/#{gid}/parsing_update", params) end end end end