Creating an actions for successful calls

app/models/call.rb

@@ -23,6 +23,7 @@ class Call < ApplicationRecord
   enum status: %i[unstarted started connected failed]
   belongs_to :page
   belongs_to :member
+  belongs_to :action
 
   validates :page, presence: true
   validates :member_phone_number, presence: true

app/services/call_creator.rb

@@ -23,6 +23,7 @@ def run
       end
 
       if @call.persisted? && !@call.failed?
+        create_action
         publish_event
       end
     end
@@ -97,6 +98,11 @@ def place_call
     end
   end
 
+  def create_action
+    @action = Action.create!(page: @page, member: @call.member)
+    @call.update!(action: @action)
+  end
+
   def publish_event
     return if @call.member.blank? # handle this in worker
     CallEvent::New.publish(@call, @extra_params)

app/services/call_event.rb

@@ -25,7 +25,10 @@ def payload
           action_target_call_status: @call.target_call_status,
           action_target: @call.target.to_hash
         },
-        meta: { call_id: @call.id }
+        meta: {
+          call_id: @call.id,
+          action_id: @call.action.id
+        }
       }
     end
   end

db/migrate/20170713183132_add_action_id_to_calls.rb

@@ -0,0 +1,5 @@
+class AddActionIdToCalls < ActiveRecord::Migration[5.1]
+  def change
+    add_column :calls, :action_id, :integer, index: true
+  end
+end

db/schema.rb

@@ -10,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema.define(version: 20170626194936) do
+ActiveRecord::Schema.define(version: 20170713183132) do
 
   # These are extensions that must be enabled in order to support this database
   enable_extension "plpgsql"
@@ -74,6 +74,7 @@
     t.integer "twilio_error_code"
     t.json "target"
     t.integer "status", default: 0
+    t.integer "action_id"
     t.index ["target_call_info"], name: "index_calls_on_target_call_info", using: :gin
   end
 

spec/services/call_creator_spec.rb

@@ -51,6 +51,11 @@
       expect(CallEvent::New).to receive(:publish).with(an_instance_of(Call), an_instance_of(Hash))
       CallCreator.new(params).run
     end
+
+    it 'creates an action' do
+      CallCreator.new(params).run
+      expect(Call.last.action).to be_an_instance_of(Action)
+    end
   end
 
   context 'given valid params' do