@@ -91,20 +91,6 @@ function resetBodyChanges() {
91
91
localMessage .value .isBodyChanged = false ;
92
92
}
93
93
94
- function findHeadersByKey(key : string ) {
95
- return localMessage .value .headers .find ((header : HeaderWithEditing ) => header .key === key );
96
- }
97
-
98
- function getContentType() {
99
- const header = findHeadersByKey (" NServiceBus.ContentType" );
100
- return header ?.value ;
101
- }
102
-
103
- function getMessageIntent() {
104
- const intent = findHeadersByKey (" NServiceBus.MessageIntent" );
105
- return intent ?.value ;
106
- }
107
-
108
94
function removeHeadersMarkedAsRemoved() {
109
95
localMessage .value .headers = localMessage .value .headers .filter ((header : HeaderWithEditing ) => ! header .isMarkedAsRemoved );
110
96
}
@@ -122,6 +108,11 @@ async function retryEditedMessage() {
122
108
}
123
109
124
110
function initializeMessageBodyAndHeaders() {
111
+ function getHeaderValue(key : string ) {
112
+ const header = local .headers .find ((header : HeaderWithEditing ) => header .key === key );
113
+ return header ?.value ;
114
+ }
115
+
125
116
origMessageBody = body .value .data .value ?? " " ;
126
117
const local = <LocalMessageState >{
127
118
isBodyChanged: false ,
@@ -135,13 +126,13 @@ function initializeMessageBodyAndHeaders() {
135
126
messageBody: body .value .data .value ?? " " ,
136
127
};
137
128
138
- const contentType = getContentType ( );
129
+ const contentType = getHeaderValue ( " NServiceBus.ContentType " );
139
130
local .bodyContentType = contentType ;
140
131
const parsedContentType = parseContentType (contentType );
141
132
local .isContentTypeSupported = parsedContentType .isSupported ;
142
133
local .language = parsedContentType .language ;
143
134
144
- const messageIntent = getMessageIntent ( );
135
+ const messageIntent = getHeaderValue ( " NServiceBus.MessageIntent " );
145
136
local .isEvent = messageIntent === " Publish" ;
146
137
147
138
for (let index = 0 ; index < headers .value .data .length ; index ++ ) {
0 commit comments