Skip to content

Commit f7a95d9

Browse files
committed
refactored getMessagesFromRequest
1 parent 91fee2f commit f7a95d9

File tree

1 file changed

+9
-17
lines changed

1 file changed

+9
-17
lines changed

lib/instrumentation/openai.js

Lines changed: 9 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -60,30 +60,22 @@ function getMessagesFromRequest(request, shim) {
6060
// For `responses.create`, messages are passed as an array of objects
6161
// with `content` and `role` properties OR as a single string (implied
6262
// to be a user message) to the `input` field of the request.
63+
let messages = []
6364

6465
if (Array.isArray(request?.input)) {
65-
return request.input
66-
.filter(msg => msg?.content && msg?.role)
67-
.map(msg => ({
68-
content: msg.content,
69-
role: msg.role
70-
}))
66+
// Handle array of input messages
67+
messages = request.input.filter(msg => msg?.content && msg?.role)
7168
} else if (typeof request?.input === 'string') {
72-
return [{
73-
content: request.input,
74-
role: 'user'
75-
}]
69+
// Handle single string input as a user message
70+
messages = [{ content: request.input, role: 'user' }]
7671
} else if (Array.isArray(request?.messages)) {
77-
return request.messages
78-
.filter(msg => msg?.content && msg?.role)
79-
.map(msg => ({
80-
content: msg.content,
81-
role: msg.role
82-
}))
72+
// Handle array of messages
73+
messages = request.messages.filter(msg => msg?.content && msg?.role)
8374
} else {
8475
shim.logger.warn('No valid messages found in OpenAI request object.')
85-
return []
8676
}
77+
78+
return messages
8779
}
8880

8981
/**

0 commit comments

Comments
 (0)