@@ -57,7 +57,7 @@ def perform(message_draft, bulk_submit: false, upvs_client: UpvsEnvironment.upvs
57
57
message_draft . submitted!
58
58
Govbox ::SyncBoxJob . set ( wait : 3 . minutes ) . perform_later ( box ) unless bulk_submit
59
59
else
60
- handle_submit_fail ( message_draft , response_status , response_body . dig ( "message" ) )
60
+ handle_submit_fail ( message_draft , response_status , response_body )
61
61
end
62
62
end
63
63
@@ -81,7 +81,7 @@ def build_objects(message_draft)
81
81
objects
82
82
end
83
83
84
- def handle_submit_fail ( message_draft , response_status , response_message )
84
+ def handle_submit_fail ( message_draft , response_status , response_body )
85
85
# TODO notification
86
86
message_draft . add_cascading_tag ( message_draft . tenant . submission_error_tag )
87
87
@@ -90,12 +90,16 @@ def handle_submit_fail(message_draft, response_status, response_message)
90
90
message_draft . metadata [ "status" ] = "temporary_submit_fail"
91
91
message_draft . save
92
92
93
- raise TemporarySubmissionError , "Message #{ message_draft . uuid } : #{ response_status } , #{ response_message } "
93
+ raise TemporarySubmissionError , error_message ( message_draft , response_status , response_body )
94
94
else
95
95
message_draft . metadata [ "status" ] = "submit_fail"
96
96
message_draft . save
97
97
98
- raise SubmissionError , "Message #{ message_draft . uuid } : #{ response_status } , #{ response_message } "
98
+ raise SubmissionError , error_message ( message_draft , response_status , response_body )
99
99
end
100
100
end
101
+
102
+ def error_message ( message_draft , response_status , response_body )
103
+ "Box #{ message_draft . box . id } , Message #{ message_draft . uuid } : #{ response_status } , #{ response_body } "
104
+ end
101
105
end
0 commit comments