Simple import of Slack export into Elasticsearch

slack_to_elasticsearch.rb

require 'date'
require 'json'
require 'logger'
require 'elasticsearch'

class SlackToElasticsearch
  attr_reader :folder

  def initialize(folder)
    @folder = folder
  end

  def process_subfolder(subfolder)
    Dir.foreach("#{folder}/#{subfolder}") do |file|
      next if (file == '.' || file == '..')
      logger.info "Importing File #{folder}/#{subfolder}/#{file}"

      index = 'zadevs-' + file.gsub('-', '.').sub('.json', '')

      items = JSON.parse(File.read("#{folder}/#{subfolder}/#{file}"))
      items.each do |item|
        item['date_time'] = DateTime.strptime(item['ts'], '%s')
        client.index index: index, type: subfolder, body: item
      end
    end
  end

  def process
    logger.info "Importing from #{folder}"
    Dir.foreach(folder) do |subfolder|
      next if (subfolder == '.' || subfolder == '..')
      next unless File.directory?("#{folder}/#{subfolder}")

      logger.info "Importing Channel #{subfolder}"

      process_subfolder(subfolder)
    end
  end

  def client
    @client ||= Elasticsearch::Client.new host: 'http://localhost:9200'
  end

  def logger
    @logger ||= Logger.new($stdout)
  end
end

if __FILE__ == $0 then
  SlackToElasticsearch.new('./slack_export').process
end