Class: Sinatra::FacebookObject

Inherits:
Object
  • Object
show all
Defined in:
lib/sinbook.rb

Defined Under Namespace

Classes: APIProxy

Constant Summary collapse

MimeBoundary = 
"--SoMeTeXtWeWiLlNeVeRsEe\r\n"
MimePart = 
%[Content-Disposition: form-data; name="%s"\r\n\r\n%s\r\n] + MimeBoundary
MimeImage = 
%[Content-Disposition: form-data; filename="%s"\r\nContent-Type: image/%s\r\n\r\n%s\r\n] + MimeBoundary
API_SERVER = 
Resolv.getaddress('api.facebook.com')

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(app) ⇒ FacebookObject

Returns a new instance of FacebookObject.



13
14
15
16
17
18
19
20
21
22
 
# File 'lib/sinbook.rb', line 13

def initialize app
  @app = app

  @api_key = app.options.facebook_api_key
  @secret = app.options.facebook_secret
  @app_id = app.options.facebook_app_id
  @url = app.options.facebook_url
  @callback = app.options.facebook_callback
  @symbolize_keys = app.options.facebook_symbolize_keys || false
end

Instance Attribute Details

#api_key ⇒ Object

Returns the value of attribute api_key.



24
25
26
 
# File 'lib/sinbook.rb', line 24

def api_key
  @api_key
end

#app ⇒ Object (readonly)

Returns the value of attribute app.



23
24
25
 
# File 'lib/sinbook.rb', line 23

def app
  @app
end

#app_id ⇒ Object 



27
28
29
 
# File 'lib/sinbook.rb', line 27

def app_id
  @app_id || self[:app_id]
end

#callback(postfix = nil) ⇒ Object 



35
36
37
 
# File 'lib/sinbook.rb', line 35

def callback postfix=nil
  postfix ? "#{@callback}#{postfix}" : @callback
end

#secret ⇒ Object

Returns the value of attribute secret.



24
25
26
 
# File 'lib/sinbook.rb', line 24

def secret
  @secret
end

#url(postfix = nil) ⇒ Object 



31
32
33
 
# File 'lib/sinbook.rb', line 31

def url postfix=nil
  postfix ? "#{@url}#{postfix}" : @url
end

Class Method Details

.connect ⇒ Object 



238
239
240
241
242
243
244
245
246
247
248
249
 
# File 'lib/sinbook.rb', line 238

def self.connect
  sock = TCPSocket.new(API_SERVER, 80)
  begin
    timeout = [3,0].pack('l_2') # 3 seconds
    sock.setsockopt Socket::SOL_SOCKET, Socket::SO_RCVTIMEO, timeout
    sock.setsockopt Socket::SOL_SOCKET, Socket::SO_SNDTIMEO, timeout
  rescue Exception => ex
    # causes issues on solaris?
    puts ex.inspect
  end
  sock
end

.request(data, mime = false) ⇒ Object 



251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
 
# File 'lib/sinbook.rb', line 251

def self.request data, mime=false
  if @keepalive
    @socket ||= connect
  else
    @socket = connect
  end

  @socket.print "POST /restserver.php HTTP/1.1\r\n"
  @socket.print "Host: api.facebook.com\r\n"
  @socket.print "Connection: keep-alive\r\n" if @keepalive
  if mime
    @socket.print "Content-Type: multipart/form-data; boundary=#{MimeBoundary[2..-3]}\r\n"
    @socket.print "MIME-version: 1.0\r\n"
  else
    @socket.print "Content-Type: application/x-www-form-urlencoded\r\n"
  end
  @socket.print "Content-Length: #{data.length}\r\n"
  @socket.print "\r\n#{data}\r\n"
  @socket.print "\r\n\r\n"

  buf = ''
  headers = ''
  headers_done = false
  chunked = true

  while true
    line = @socket.gets
    headers << line unless headers_done
    raise Errno::ECONNRESET unless line

    if line == "\r\n" # end of headers/chunk
      unless headers_done
        headers_done = true
        if headers =~ /Encoding: chunked/i
          chunked = true
        else
          len = headers[/Content-Length: (\d+)/i,1].to_i
          buf = @socket.read(len)
          break # done!
        end
      end

      line = @socket.gets # get size of next chunk
      if line.strip! == '0' # 0 sized chunk
        @socket.gets # read last crlf
        break # done!
      end

      buf << @socket.read(line.to_i(16)) # read in chunk
    end
  end

  buf
rescue Errno::EPIPE, Errno::ECONNRESET
  @socket = nil
  retry
ensure
  @socket.close if @socket and !@keepalive
end

Instance Method Details

#[](key) ⇒ Object 



85
86
87
 
# File 'lib/sinbook.rb', line 85

def [] key
  params[key]
end

#addurl ⇒ Object 



39
40
41
 
# File 'lib/sinbook.rb', line 39

def addurl
  "http://apps.facebook.com/add.php?api_key=#{self.api_key}"
end

#appurl ⇒ Object 



43
44
45
 
# File 'lib/sinbook.rb', line 43

def appurl
  "http://www.facebook.com/apps/application.php?id=#{self.app_id}"
end

#params ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/sinbook.rb', line 61

def params
  return {} unless valid?
  app.env['facebook.params'] ||= \
    app.env['facebook.vars'].inject({}) do |h,(k,v)|
      s = k.to_sym
      case k
      when 'friends'
        h[s] = v.split(',').map{|e|e.to_i}
      when /time$/
        h[s] = Time.at(v.to_f)
      when 'expires'
        v = v.to_i
        h[s] = v>0 ? Time.at(v) : v
      when 'user', 'app_id', 'canvas_user'
        h[s] = v.to_i
      when /^(logged_out|position_|in_|is_|added)/
        h[s] = v=='1'
      else
        h[s] = v
      end
      h
    end
end

#redirect(url) ⇒ Object 



55
56
57
58
59
 
# File 'lib/sinbook.rb', line 55

def redirect url
  url = self.url + url unless url =~ /^http/
  app.body "<fb:redirect url='#{url}'/>"
  throw :halt
end

#request(method, opts = {}) ⇒ Object

Raises:



168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
 
# File 'lib/sinbook.rb', line 168

def request method, opts = {}
  if method == 'photos.upload'
    image = opts.delete :image
  end

  opts = { :api_key => self.api_key,
           :call_id => Time.now.to_f,
           :format => 'JSON',
           :v => '1.0',
           :session_key => %w[ photos.upload ].include?(method) ? nil : params[:session_key],
           :method => method }.merge(opts)

  args = opts.map{ |k,v|
                   next nil unless v

                   "#{k}=" + case v
                             when Hash
                               Yajl::Encoder.encode(v)
                             when Array
                               if k == :tags
                                 Yajl::Encoder.encode(v)
                               else
                                 v.join(',')
                               end
                             else
                               v.to_s
                             end
                 }.compact.sort

  sig = Digest::MD5.hexdigest(args.join+self.secret)

  if method == 'photos.upload'
    data = MimeBoundary
    data += opts.merge(:sig => sig).inject('') do |buf, (key, val)|
      if val
        buf << (MimePart % [key, val])
      else
        buf
      end
    end
    data += MimeImage % ['upload.jpg', 'jpg', image.respond_to?(:read) ? image.read : image]
  else
    data = Array["sig=#{sig}", *args.map{|a| a.gsub('&','%26') }].join('&')
  end

  ret = self.class.request(data, method == 'photos.upload')

  ret = if ['true', '1'].include? ret
          true
        elsif ['false', '0'].include? ret
          false
        elsif (n = Integer(ret) rescue nil)
          n
        else
          Yajl::Parser.parse(ret, :symbolize_keys => @symbolize_keys)
        end

  raise Facebook::Error, ret['error_msg'] if ret.is_a? Hash and ret['error_code']

  ret
end

#require_login! ⇒ Object 



47
48
49
50
51
52
53
 
# File 'lib/sinbook.rb', line 47

def require_login!
  if valid?
    redirect addurl unless params[:user]
  else
    app.redirect url
  end
end

#valid? ⇒ Boolean

Returns:

  • (Boolean) 


89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/sinbook.rb', line 89

def valid?
  if app.params['fb_sig'] # canvas/iframe mode
    prefix = 'fb_sig'
    vars = app.params
  elsif app.request.cookies[api_key] # fbconnect mode
    prefix = api_key
    vars = app.request.cookies
  else
    return false
  end

  if app.env['facebook.valid?'].nil?
    fbvars = {}
    sig = Digest::MD5.hexdigest(vars.map{|k,v|
      if k =~ /^#{prefix}_(.+)$/
        fbvars[$1] = v
        "#{$1}=#{v}"
      end
    }.compact.sort.join+self.secret)

    if app.env['facebook.valid?'] = (vars[prefix] == sig)
      app.env['facebook.vars'] = fbvars
    end
  end

  app.env['facebook.valid?']
end