Harbor Documentation

Harbor::Contrib::Stats::ApacheRequest

Public Class Methods

all_unprocessed(limit=nil, offset=nil) 

      # File lib/harbor/contrib/stats/reconciliation/request.rb, line 61
61:         def self.all_unprocessed(limit=nil, offset=nil)
62:           query = "select *\nfrom apache_requests\nwhere processed is null\norder by date asc\nlimit ?\noffset ?\n"
63:           repository.adapter.query(query, limit, offset)
64:         end

create(id, ip_address, request_type, uri, referrer, date) 

      # File lib/harbor/contrib/stats/reconciliation/request.rb, line 49
49:         def self.create(id, ip_address, request_type, uri, referrer, date)
50:           
51:           insert_query = "insert into apache_requests\nvalues(?,?,?,?,?,?,?)\n"
52:           
53:           repository.adapter.execute(insert_query, id, ip_address, request_type, uri, referrer, date, nil)
54:         
55:         end

create_table!() 

      # File lib/harbor/contrib/stats/reconciliation/request.rb, line 30
30:         def self.create_table!
31:           unless repository.adapter.storage_exists?('apache_requests')
32:             repository.adapter.execute("create table apache_requests\n(\nid integer, remote_ip inet, request_method varchar, uri text, referrer text, date timestamp, processed boolean\n)\n"
33:             )
34:           end
35:         end

drop_table!() 

      # File lib/harbor/contrib/stats/reconciliation/request.rb, line 43
43:         def self.drop_table!
44:           if repository.adapter.storage_exists?('apache_requests')
45:             repository.adapter.execute('drop table apache_requests')
46:           end
47:         end

unprocessed_count() 

      # File lib/harbor/contrib/stats/reconciliation/request.rb, line 74
74:         def self.unprocessed_count
75:           query = "select count(*)\nfrom apache_requests\nwhere processed is null\n"
76:           repository.adapter.query(query).first
77:         end

Public Instance Methods

mark_as_processed!() 

      # File lib/harbor/contrib/stats/reconciliation/request.rb, line 26
26:         def mark_as_processed!
27:           repository.adapter.execute('update apache_requests set processed = ? where id = ?', true, self.id)
28:         end