123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- # Copyright (C) 2012-2015 Zammad Foundation, http://zammad-foundation.org/
- require 'facebook'
- class Channel::Driver::Facebook
- def fetch (options, channel)
- @channel = channel
- @sync = options['sync']
- @pages = options['pages']
- Rails.logger.debug 'facebook fetch started'
- fetch_feed
- disconnect
- Rails.logger.debug 'facebook fetch completed'
- notice = ''
- {
- result: 'ok',
- notice: notice,
- }
- end
- def send(options, fb_object_id, article, _notification = false)
- access_token = nil
- options['pages'].each {|page|
- next if page['id'].to_s != fb_object_id.to_s
- access_token = page['access_token']
- }
- if !access_token
- raise "No access_token found for fb_object_id: #{fb_object_id}"
- end
- client = Facebook.new(access_token)
- client.from_article(article)
- end
- =begin
- instance = Channel::Driver::Facebook.new
- instance.fetchable?(channel)
- =end
- def fetchable?(_channel)
- true
- end
- def disconnect
- end
- private
- def get_page(page_id)
- @pages.each {|page|
- return page if page['id'].to_s == page_id.to_s
- }
- nil
- end
- def fetch_feed
- return if !@sync
- return if !@sync['pages']
- @sync['pages'].each {|page_to_sync_id, page_to_sync_params|
- page = get_page(page_to_sync_id)
- next if !page
- next if !page_to_sync_params['group_id']
- next if page_to_sync_params['group_id'].empty?
- page_client = Facebook.new(page['access_token'])
- posts = page_client.client.get_connection('me', 'feed', fields: 'id,from,to,message,created_time,comments')
- posts.each {|post|
- page_client.to_group(post, page_to_sync_params['group_id'], @channel, page)
- }
- }
- true
- end
- end
|