({
app,
framework,
event,
context,
resolver,
eventSourceName,
binarySettings,
eventSource = getEventSource({ eventSourceName }),
eventSourceRoutes,
log
})
| 142 | }) |
| 143 | } |
| 144 | async function forwardRequestToNodeServer ({ |
| 145 | app, |
| 146 | framework, |
| 147 | event, |
| 148 | context, |
| 149 | resolver, |
| 150 | eventSourceName, |
| 151 | binarySettings, |
| 152 | eventSource = getEventSource({ eventSourceName }), |
| 153 | eventSourceRoutes, |
| 154 | log |
| 155 | }) { |
| 156 | const requestValues = eventSource.getRequest({ event, context, log }) |
| 157 | |
| 158 | if (!requestValues.path && eventSourceRoutes[eventSourceName]) { |
| 159 | requestValues.path = eventSourceRoutes[eventSourceName] |
| 160 | } |
| 161 | |
| 162 | log.debug('SERVERLESS_EXPRESS:FORWARD_REQUEST_TO_NODE_SERVER:REQUEST_VALUES', { requestValues }) |
| 163 | const { request, response } = await getRequestResponse(requestValues) |
| 164 | await framework.sendRequest({ app, request, response }) |
| 165 | markHttpRequestAsCompleted(request) |
| 166 | await waitForStreamComplete(response) |
| 167 | log.debug('SERVERLESS_EXPRESS:FORWARD_REQUEST_TO_NODE_SERVER:RESPONSE', { response }) |
| 168 | forwardResponse({ |
| 169 | binarySettings, |
| 170 | response, |
| 171 | resolver, |
| 172 | eventSource, |
| 173 | event, |
| 174 | log |
| 175 | }) |
| 176 | return response |
| 177 | } |
| 178 | |
| 179 | module.exports = { |
| 180 | forwardResponse, |
no test coverage detected
searching dependent graphs…