Skip to content

Commit

Permalink
add logging for debugging
Browse files Browse the repository at this point in the history
  • Loading branch information
wendelfabianchinsamy committed Jan 14, 2025
1 parent ef8fc54 commit 1eaebcb
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 12 deletions.
8 changes: 3 additions & 5 deletions app/workers/event_import_worker.rb
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,10 @@ def perform(sqs_msg=nil, data=nil)

Rails.logger.info("[Event Import Worker] - Send request to event service: Start")
response = post_to_event_service(data)
Rails.logger.info("[Event Import Worker] - Response received")
Rails.logger.info(response.inspect)
Rails.logger.info("[Event Import Worker] - Send request to event service: End")
# data = JSON.parse(data)
# prefix = log_prefix(data)
# handle_logging(data, response, prefix)
prefix = log_prefix(data)
handle_logging(data, response, prefix)
Rails.logger.info("[Event Import Worker] - Send request to event service: End")
end

private
Expand Down
14 changes: 7 additions & 7 deletions spec/workers/event_import_worker_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,8 @@
it "logs pushed to event data service message" do
allow(Rails.logger).to(receive(:info))
allow(Maremma).to(receive(:post).and_return(OpenStruct.new(status: 200)))
# expected_log = "[EventImportWorker] #{subj_id} #{relation_type_id} #{obj_id} pushed to the Event Data service."
# expect(Rails.logger).to(receive(:info).with(expected_log))
expected_log = "[EventImportWorker] #{subj_id} #{relation_type_id} #{obj_id} pushed to the Event Data service."
expect(Rails.logger).to(receive(:info).with(expected_log))
EventImportWorker.new.perform(nil, data)
end
end
Expand All @@ -71,8 +71,8 @@
it "logs pushed to event data service message" do
allow(Rails.logger).to(receive(:info))
allow(Maremma).to(receive(:post).and_return(OpenStruct.new(status: 201)))
# expected_log = "[EventImportWorker] #{subj_id} #{relation_type_id} #{obj_id} pushed to the Event Data service."
# expect(Rails.logger).to(receive(:info).with(expected_log))
expected_log = "[EventImportWorker] #{subj_id} #{relation_type_id} #{obj_id} pushed to the Event Data service."
expect(Rails.logger).to(receive(:info).with(expected_log))
EventImportWorker.new.perform(nil, data)
end
end
Expand All @@ -81,8 +81,8 @@
it "logs pushed to event data service message" do
allow(Rails.logger).to(receive(:info))
allow(Maremma).to(receive(:post).and_return(OpenStruct.new(status: 409)))
# expected_log = "[EventImportWorker] #{subj_id} #{relation_type_id} #{obj_id} already pushed to the Event Data service."
# expect(Rails.logger).to(receive(:info).with(expected_log))
expected_log = "[EventImportWorker] #{subj_id} #{relation_type_id} #{obj_id} already pushed to the Event Data service."
expect(Rails.logger).to(receive(:info).with(expected_log))
EventImportWorker.new.perform(nil, data)
end
end
Expand All @@ -101,7 +101,7 @@
it "logs response had an error message" do
allow(Rails.logger).to(receive(:error))
allow(Maremma).to(receive(:post).and_return(response))
# expect(Rails.logger).to(receive(:error)).twice
expect(Rails.logger).to(receive(:error)).twice
EventImportWorker.new.perform(nil, data)
end
end
Expand Down

0 comments on commit 1eaebcb

Please sign in to comment.