plugin.rb

# name: Segment.io
# about: Import your Discourse data to your Segment.io warehouse
# version: 0.0.1
# authors: Kyle Welsby <kyle@mekyle.com>

gem 'commander', '4.4.0' # , require: false # for analytics-ruby
gem 'analytics-ruby', '2.2.2', require: false # 'segment/analytics'

after_initialize do
  require 'segment/analytics'

  SEGMENT_IO_KEY = ENV['SEGMENT_IO_KEY']
  unless SEGMENT_IO_KEY
    raise StandardError, 'Segment.io WriteKey must be defined as an environment variable  `export SEGMENT_IO_KEY={YOUR_KEY_HERE}`'
  end
  Analytics = Segment::Analytics.new(
    write_key: SEGMENT_IO_KEY,
    on_error: proc { |_status, msg| print msg }
  )

  require_dependency 'jobs/base'
  module ::Jobs
    class EmitSegmentUserIdentify < Jobs::Base
      def execute(args)
        user = User.find_by_id(args[:user_id])
        user.emit_segment_user_identify if user
      end
    end
  end

  User.find_each do |user|
    Jobs.enqueue(:emit_segment_user_identify, user_id: user.id)
  end

  require_dependency 'user'
  class ::User
    after_create :emit_segment_user_identify
    after_create :emit_segment_user_created
    def emit_segment_user_identify
      Analytics.identify(
        user_id: id,
        traits: {
          name: name,
          username: username,
          email: email,
          created_at: created_at
        },
        context: {
          ip: ip_address
        }
      )
    end

    def emit_segment_user_created
      Analytics.track(
        user_id: id,
        event: 'Signed Up'
      )
    end
  end

  require_dependency 'application_controller'
  class ::ApplicationController
    before_filter :emit_segment_user_tracker
    def emit_segment_user_tracker
      if current_user && !segment_common_controller_actions?
        Analytics.page(
          user_id: current_user.id,
          name: "#{controller_name}##{action_name}",
          properties: {
            url: request.original_url
          },
          context: {
            ip: request.ip,
            userAgent: request.user_agent
          }
        )
      end
    end

    def segment_common_controller_actions?
      controller_name == 'stylesheets' || controller_name == 'user_avatars' || (controller_name == 'about' && action_name == 'live_post_counts')
    end
  end

  require_dependency 'post'
  class ::Post
    after_create :emit_segment_post_created

    def emit_segment_post_created
      Analytics.track(
        user_id: user_id,
        event: 'Post Created',
        properties: {
          slug: topic.slug,
          title: topic.title,
          url: topic.url
        }
      )
    end
  end

  require_dependency 'topic'
  class ::Topic
    after_create :emit_segment_topic_created

    def emit_segment_topic_created
      Analytics.track(
        user_id: user_id,
        event: 'Topic Created',
        properties: {
          slug: slug,
          title: title,
          url: url
        }
      )
    end
  end
end