Apply value transforms before serialization

Author: karlhorky

cf/src/connection.js

@@ -958,8 +958,9 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
         return b.i32(0xFFFFFFFF)
 
       type = types[i]
+      x = options.transform.value.to ? options.transform.value.to(x, { type }) : x
       parameters[i] = x = type in options.serializers
-        ? options.serializers[type](x, options, type)
+        ? options.serializers[type](x)
         : '' + x
 
       prev = b.i

cf/src/types.js

@@ -17,7 +17,7 @@ export const types = {
   json: {
     to: 114,
     from: [114, 3802],
-    serialize: (x, options, type) => JSON.stringify(options && options.transform.value.to ? options.transform.value.to(x, { type }) : x),
+    serialize: x => JSON.stringify(x),
     parse: x => JSON.parse(x)
   },
   boolean: {

cjs/src/connection.js

@@ -956,8 +956,9 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
         return b.i32(0xFFFFFFFF)
 
       type = types[i]
+      x = options.transform.value.to ? options.transform.value.to(x, { type }) : x
       parameters[i] = x = type in options.serializers
-        ? options.serializers[type](x, options, type)
+        ? options.serializers[type](x)
         : '' + x
 
       prev = b.i

cjs/src/types.js

@@ -16,7 +16,7 @@ const types = module.exports.types = {
   json: {
     to: 114,
     from: [114, 3802],
-    serialize: (x, options, type) => JSON.stringify(options && options.transform.value.to ? options.transform.value.to(x, { type }) : x),
+    serialize: x => JSON.stringify(x),
     parse: x => JSON.parse(x)
   },
   boolean: {

deno/src/connection.js

@@ -959,8 +959,9 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
         return b.i32(0xFFFFFFFF)
 
       type = types[i]
+      x = options.transform.value.to ? options.transform.value.to(x, { type }) : x
       parameters[i] = x = type in options.serializers
-        ? options.serializers[type](x, options, type)
+        ? options.serializers[type](x)
         : '' + x
 
       prev = b.i

deno/src/types.js

@@ -17,7 +17,7 @@ export const types = {
   json: {
     to: 114,
     from: [114, 3802],
-    serialize: (x, options, type) => JSON.stringify(options && options.transform.value.to ? options.transform.value.to(x, { type }) : x),
+    serialize: x => JSON.stringify(x),
     parse: x => JSON.parse(x)
   },
   boolean: {

deno/types/index.d.ts

@@ -333,7 +333,7 @@ declare namespace postgres {
   interface PostgresType<T = any> {
     to: number;
     from: number[];
-    serialize: (value: T, options?: ParsedOptions, type?: number) => unknown;
+    serialize: (value: T) => unknown;
     parse: (raw: any) => T;
   }
 
@@ -398,7 +398,7 @@ declare namespace postgres {
     pass: null;
     /** @inheritdoc */
     transform: Transform;
-    serializers: Record<number, (value: any, options?: ParsedOptions, type?: number) => unknown>;
+    serializers: Record<number, (value: any) => unknown>;
     parsers: Record<number, (value: any) => unknown>;
   }
 

src/connection.js

@@ -956,8 +956,9 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
         return b.i32(0xFFFFFFFF)
 
       type = types[i]
+      x = options.transform.value.to ? options.transform.value.to(x, { type }) : x
       parameters[i] = x = type in options.serializers
-        ? options.serializers[type](x, options, type)
+        ? options.serializers[type](x)
         : '' + x
 
       prev = b.i

src/types.js

@@ -16,7 +16,7 @@ export const types = {
   json: {
     to: 114,
     from: [114, 3802],
-    serialize: (x, options, type) => JSON.stringify(options && options.transform.value.to ? options.transform.value.to(x, { type }) : x),
+    serialize: x => JSON.stringify(x),
     parse: x => JSON.parse(x)
   },
   boolean: {

types/index.d.ts

@@ -331,7 +331,7 @@ declare namespace postgres {
   interface PostgresType<T = any> {
     to: number;
     from: number[];
-    serialize: (value: T, options?: ParsedOptions, type?: number) => unknown;
+    serialize: (value: T) => unknown;
     parse: (raw: any) => T;
   }
 
@@ -396,7 +396,7 @@ declare namespace postgres {
     pass: null;
     /** @inheritdoc */
     transform: Transform;
-    serializers: Record<number, (value: any, options?: ParsedOptions, type?: number) => unknown>;
+    serializers: Record<number, (value: any) => unknown>;
     parsers: Record<number, (value: any) => unknown>;
   }