idobata2es.rb

require 'elasticsearch'
require 'json'
es = Elasticsearch::Client.new(hosts: "localhost:9200")
message_id = ARGV[0]
api_url = if message_id
  "https://idobata.io/api/messages?room_id=&older_than=#{message_id}"
else
  "https://idobata.io/api/messages?room_id="
end
messages = JSON.parse(`curl '#{api_url}' -H "X-API-Token: "`)['messages']

#puts messages?
messages.reverse.each do |message|
  if message['sender_type'] == "User"
    es.index index: "idobata-tmix", type: "idodobata-messages", body: {
      id: message['id'],
      sender_name: message['sender_name'],
      body: message['body'],
      images_urls: message['images_urls'],
      created_at: message['created_at']
    }
  end
  puts message['id']
end