# == Schema Information # # Table name: channel_twitter_profiles # # id :bigint not null, primary key # twitter_access_token :string not null # twitter_access_token_secret :string not null # created_at :datetime not null # updated_at :datetime not null # account_id :integer not null # profile_id :string not null # # Indexes # # index_channel_twitter_profiles_on_account_id_and_profile_id (account_id,profile_id) UNIQUE # class Channel::TwitterProfile < ApplicationRecord include Channelable self.table_name = 'channel_twitter_profiles' validates :profile_id, uniqueness: { scope: :account_id } before_destroy :unsubscribe def name 'Twitter' end def create_contact_inbox(profile_id, name, additional_attributes) ActiveRecord::Base.transaction do contact = inbox.account.contacts.create!(additional_attributes: additional_attributes, name: name) ::ContactInbox.create!( contact_id: contact.id, inbox_id: inbox.id, source_id: profile_id ) rescue StandardError => e Rails.logger.info e end end def twitter_client Twitty::Facade.new do |config| config.consumer_key = ENV.fetch('TWITTER_CONSUMER_KEY', nil) config.consumer_secret = ENV.fetch('TWITTER_CONSUMER_SECRET', nil) config.access_token = twitter_access_token config.access_token_secret = twitter_access_token_secret config.base_url = 'https://api.twitter.com' config.environment = ENV.fetch('TWITTER_ENVIRONMENT', '') end end private def unsubscribe ### Fix unsubscription with new endpoint unsubscribe_response = twitter_client.remove_subscription(user_id: profile_id) Rails.logger.info "TWITTER_UNSUBSCRIBE: #{unsubscribe_response.body}" rescue StandardError => e Rails.logger.info e end end