ditto.http.response: use error level when status >= 500

scripts/deparameterize.ts

@@ -0,0 +1,45 @@
+const decoder = new TextDecoder();
+
+for await (const chunk of Deno.stdin.readable) {
+  const text = decoder.decode(chunk);
+
+  const { sql, parameters } = JSON.parse(text) as { sql: string; parameters: unknown[] };
+
+  let result = sql;
+
+  for (let i = 0; i < parameters.length; i++) {
+    const param = parameters[i];
+
+    result = result.replace(`$${i + 1}`, serializeParameter(param));
+  }
+
+  console.log(result + ';');
+}
+
+function serializeParameter(param: unknown): string {
+  if (param === null) {
+    return 'null';
+  }
+
+  if (typeof param === 'string') {
+    return `'${param}'`;
+  }
+
+  if (typeof param === 'number' || typeof param === 'boolean') {
+    return param.toString();
+  }
+
+  if (param instanceof Date) {
+    return `'${param.toISOString()}'`;
+  }
+
+  if (Array.isArray(param)) {
+    return `'{${param.join(',')}}'`;
+  }
+
+  if (typeof param === 'object') {
+    return `'${JSON.stringify(param)}'`;
+  }
+
+  return JSON.stringify(param);
+}

src/middleware/logiMiddleware.ts

@@ -13,6 +13,7 @@ export const logiMiddleware: MiddlewareHandler = async (c, next) => {
 
   const end = new Date();
   const delta = (end.getTime() - start.getTime()) / 1000;
+  const level = c.res.status >= 500 ? 'error' : 'info';
 
-  logi({ level: 'info', ns: 'ditto.http.response', method, pathname, status: c.res.status, delta });
+  logi({ level, ns: 'ditto.http.response', method, pathname, status: c.res.status, delta });
 };