<%= yield %>
diff --git a/apps/web/templates/folders/index.html.erb b/apps/web/templates/folders/index.html.erb
index 05c6c95..9a00bb9 100644
--- a/apps/web/templates/folders/index.html.erb
+++ b/apps/web/templates/folders/index.html.erb
@@ -7,4 +7,3 @@
<% end %>
-
diff --git a/apps/web/templates/tickets/show.html.erb b/apps/web/templates/tickets/show.html.erb
index 11e7f15..4cad2fe 100644
--- a/apps/web/templates/tickets/show.html.erb
+++ b/apps/web/templates/tickets/show.html.erb
@@ -2,6 +2,11 @@
#<%= ticket.id %>
+ <%=
+ form_for :ticket, routes.export_ticket_path(id: ticket.id) do
+ submit 'Migrate ticket to Intercom'
+ end
+ %>
<% messages.each do |message| %>
diff --git a/config/initializers/.gitkeep b/config/initializers/.gitkeep
deleted file mode 100644
index 792d600..0000000
--- a/config/initializers/.gitkeep
+++ /dev/null
@@ -1 +0,0 @@
-#
diff --git a/config/initializers/sidekiq.rb b/config/initializers/sidekiq.rb
new file mode 100644
index 0000000..c665c01
--- /dev/null
+++ b/config/initializers/sidekiq.rb
@@ -0,0 +1,7 @@
+Sidekiq.configure_server do |config|
+ config.redis = { url: ENV.fetch("REDIS_URL") }
+end
+
+Sidekiq.configure_client do |config|
+ config.redis = { url: ENV.fetch("REDIS_URL") }
+end
diff --git a/lib/mkdev_hanami/entities/ticket.rb b/lib/mkdev_hanami/entities/ticket.rb
index b4eaa07..2b037bd 100644
--- a/lib/mkdev_hanami/entities/ticket.rb
+++ b/lib/mkdev_hanami/entities/ticket.rb
@@ -1,2 +1,9 @@
class Ticket < Hanami::Entity
+ def migrate
+ ExportTicketsWorker.perform_async(self)
+ end
+
+ def customer
+ CustomerRepository.new.find(customer_id)
+ end
end
diff --git a/lib/mkdev_hanami/interactors/export_to_intercom.rb b/lib/mkdev_hanami/interactors/export_to_intercom.rb
new file mode 100644
index 0000000..ed4e58d
--- /dev/null
+++ b/lib/mkdev_hanami/interactors/export_to_intercom.rb
@@ -0,0 +1,43 @@
+require 'hanami/interactor'
+require 'intercom'
+
+class ExportToIntercom
+ include Hanami::Interactor
+
+ def initialize(ticket)
+ @ticket = ticket
+ @messages = TicketRepository.new.find_with_messages(ticket.id).messages
+ @customer = ticket.customer
+ @client ||= Intercom::Client.new(token: ENV['INTERCOM_ACCESS_TOKEN'])
+ end
+
+ def call
+ export!
+ end
+
+ private
+
+ def export!
+ from = find_or_create_contact(@customer.email)
+ conversation_message = @client.messages.create({ from: from, body: @messages.first.body })
+ conversation = @client.conversations.find_all(email: @customer.email).select do |conversation|
+ conversation.conversation_message.id == conversation_message.id
+ end.first
+ @client.conversations.reply(id: conversation.id, type: 'admin', message_type: 'comment', body: @messages.last.body, admin_id: ENV["INTERCOM_ADMIN_ID"])
+ if @ticket.state == 'closed'
+ @client.conversations.reply(id: conversation.id, type: 'admin', message_type: 'close', admin_id: ENV["INTERCOM_ADMIN_ID"])
+ end
+ rescue
+ fail!
+ end
+
+ def find_or_create_contact(email)
+ contact = @client.users.find(email: email)
+ type = 'user'
+ rescue Intercom::ResourceNotFound
+ contact = @client.contacts.find_all(email: email).first || @client.contacts.create(email: email)
+ type = 'contact'
+ ensure
+ return { type: type, id: contact.id }
+ end
+end
diff --git a/lib/mkdev_hanami/repositories/ticket_repository.rb b/lib/mkdev_hanami/repositories/ticket_repository.rb
index e1f2d1c..ac4eba3 100644
--- a/lib/mkdev_hanami/repositories/ticket_repository.rb
+++ b/lib/mkdev_hanami/repositories/ticket_repository.rb
@@ -1,4 +1,12 @@
class TicketRepository < Hanami::Repository
+ associations do
+ has_many :messages
+ end
+
+ def find_with_messages(id)
+ aggregate(:messages).map_to(Ticket).one
+ end
+
def by_folder(folder_id)
tickets.where("folder_ids @> ARRAY[?]::bigint[]", folder_id)
end
diff --git a/lib/mkdev_hanami/workers/export_tickets_worker.rb b/lib/mkdev_hanami/workers/export_tickets_worker.rb
new file mode 100644
index 0000000..5b1366d
--- /dev/null
+++ b/lib/mkdev_hanami/workers/export_tickets_worker.rb
@@ -0,0 +1,7 @@
+class ExportTicketsWorker
+ include Sidekiq::Worker
+
+ def perform(ticket)
+ Intercom.new(ticket).call
+ end
+end