Merge pull request #405 from zazuko/server-timing

Send Server-Timing responses for SPARQL query responses

.changeset/late-papayas-smell.md

@@ -0,0 +1,5 @@
+---
+"@zazuko/trifid-plugin-sparql-proxy": minor
+---
+
+Returns `Server-Timing` as response header containing the duration of the request to the configured endpoint.

.changeset/sweet-ducks-worry.md

@@ -0,0 +1,5 @@
+---
+"trifid-handler-fetch": minor
+---
+
+Returns `Server-Timing` as response header containing the duration of the request to perform.

packages/handler-fetch/index.js

@@ -1,6 +1,7 @@
 // @ts-check
 
 import { Worker } from 'node:worker_threads'
+import { performance } from 'node:perf_hooks'
 import { v4 as uuidv4 } from 'uuid'
 import { waitForVariableToBeTrue } from './lib/utils.js'
 
@@ -160,8 +161,12 @@ export const factory = async (trifid) => {
         logger.debug(`Received query: ${query}`)
 
         try {
+          const start = performance.now()
           const { response, contentType } = await handleQuery(query)
+          const end = performance.now()
+          const duration = end - start
           reply.type(contentType)
+          reply.header('Server-Timing', `handler-fetch;dur=${duration};desc="Query execution time"`)
           logger.debug(`Sending the following ${contentType} response:\n${response}`)
           reply.status(200).send(response)
         } catch (error) {

packages/sparql-proxy/index.js

@@ -1,6 +1,7 @@
 // @ts-check
 
 import { Readable } from 'node:stream'
+import { performance } from 'node:perf_hooks'
 import { sparqlGetRewriteConfiguration } from 'trifid-core'
 import replaceStream from 'string-replace-stream'
 
@@ -155,11 +156,15 @@ const factory = async (trifid) => {
           if (authorizationHeader) {
             headers.Authorization = authorizationHeader
           }
+
+          const start = performance.now()
           const response = await fetch(options.endpointUrl, {
             method: 'POST',
             headers,
             body: new URLSearchParams({ query }),
           })
+          const end = performance.now()
+          const duration = end - start
 
           const contentType = response.headers.get('content-type')
 
@@ -175,6 +180,7 @@ const factory = async (trifid) => {
 
           return reply
             .status(response.status)
+            .header('Server-Timing', `sparql-proxy;dur=${duration};desc="Querying the endpoint"`)
             .header('content-type', contentType)
             .send(responseStream)
         } catch (error) {