chore: lint prefer using nullish coalescing operator

puristajs · Feb 24, 2024 · e542a95 · e542a95
1 parent 2b3b316
commit e542a95
Show file tree

Hide file tree

Showing 70 changed files with 235 additions and 236 deletions.
diff --git a/examples/dapr-example/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts b/examples/dapr-example/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts
@@ -14,8 +14,8 @@ export const getAllUsersCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetAllUsersOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', '/user')
   .setCommandFunction(async function (context, _payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     return users
   })
diff --git a/examples/dapr-example/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts b/examples/dapr-example/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts
@@ -16,8 +16,8 @@ export const getUserByIdCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetUserByIdOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', 'user/:userId')
   .setCommandFunction(async function (context, _payload, parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     const user = users.find((user) => (user.userId = parameter.userId))
 

diff --git a/examples/dapr-example/src/service/user/v1/command/signUp/signUpCommandBuilder.ts b/examples/dapr-example/src/service/user/v1/command/signUp/signUpCommandBuilder.ts
@@ -20,7 +20,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1SignUpOutputPayloadSchema)
   .exposeAsHttpEndpoint('POST', 'user/signup')
   .setCommandFunction(async function (context, payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
 
     if (result.users?.some((user) => user.email === payload.email)) {
       throw new HandledError(StatusCode.BadRequest, 'the user already exists')
@@ -31,7 +31,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
       userId: randomUUID(),
     }
 
-    const users = result.users || []
+    const users = result.users ?? []
     users.push(user)
 
     await context.states.setState(StateStoreKey.Users, users)

diff --git a/examples/fullexample/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts b/examples/fullexample/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts
@@ -14,8 +14,8 @@ export const getAllUsersCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetAllUsersOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', '/user')
   .setCommandFunction(async function (context, _payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     return users
   })
diff --git a/examples/fullexample/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts b/examples/fullexample/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts
@@ -16,8 +16,8 @@ export const getUserByIdCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetUserByIdOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', 'user/:userId')
   .setCommandFunction(async function (context, _payload, parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     const user = users.find((user) => (user.userId = parameter.userId))
 

diff --git a/examples/fullexample/src/service/user/v1/command/signUp/signUpCommandBuilder.ts b/examples/fullexample/src/service/user/v1/command/signUp/signUpCommandBuilder.ts
@@ -20,7 +20,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1SignUpOutputPayloadSchema)
   .exposeAsHttpEndpoint('POST', 'user/signup')
   .setCommandFunction(async function (context, payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
 
     if (result.users?.some((user) => user.email === payload.email)) {
       throw new HandledError(StatusCode.BadRequest, 'the user already exists')
@@ -31,7 +31,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
       userId: randomUUID(),
     }
 
-    const users = result.users || []
+    const users = result.users ?? []
     users.push(user)
 
     await context.states.setState(StateStoreKey.Users, users)

diff --git a/examples/kubernetes/src/index.ts b/examples/kubernetes/src/index.ts
@@ -44,7 +44,7 @@ const main = async () => {
   // set up the eventbridge and start the event bridge
   const eventBridge = new AmqpBridge({
     spanProcessor,
-    instanceId: process.env.HOSTNAME || getNewInstanceId(),
+    instanceId: process.env.HOSTNAME ?? getNewInstanceId(),
     url: process.env.AMQP_URL,
   })
   await eventBridge.start()

diff --git a/examples/mqtt-bridge/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts b/examples/mqtt-bridge/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts
@@ -14,8 +14,8 @@ export const getAllUsersCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetAllUsersOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', '/user')
   .setCommandFunction(async function (context, _payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     return users
   })
diff --git a/examples/mqtt-bridge/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts b/examples/mqtt-bridge/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts
@@ -16,8 +16,8 @@ export const getUserByIdCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetUserByIdOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', 'user/:userId')
   .setCommandFunction(async function (context, _payload, parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     const user = users.find((user) => (user.userId = parameter.userId))
 

diff --git a/examples/mqtt-bridge/src/service/user/v1/command/signUp/signUpCommandBuilder.ts b/examples/mqtt-bridge/src/service/user/v1/command/signUp/signUpCommandBuilder.ts
@@ -20,7 +20,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1SignUpOutputPayloadSchema)
   .exposeAsHttpEndpoint('POST', 'user/signup')
   .setCommandFunction(async function (context, payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
 
     if (result.users?.some((user) => user.email === payload.email)) {
       throw new HandledError(StatusCode.BadRequest, 'the user already exists')
@@ -31,7 +31,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
       userId: randomUUID(),
     }
 
-    const users = result.users || []
+    const users = result.users ?? []
     users.push(user)
 
     await context.states.setState(StateStoreKey.Users, users)

diff --git a/examples/nats-bridge/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts b/examples/nats-bridge/src/service/user/v1/command/getAllUsers/getAllUsersCommandBuilder.ts
@@ -14,8 +14,8 @@ export const getAllUsersCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetAllUsersOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', '/user')
   .setCommandFunction(async function (context, _payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     return users
   })
diff --git a/examples/nats-bridge/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts b/examples/nats-bridge/src/service/user/v1/command/getUserById/getUserByIdCommandBuilder.ts
@@ -16,8 +16,8 @@ export const getUserByIdCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1GetUserByIdOutputPayloadSchema)
   .exposeAsHttpEndpoint('GET', 'user/:userId')
   .setCommandFunction(async function (context, _payload, parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
-    const users = result.users || []
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
+    const users = result.users ?? []
 
     const user = users.find((user) => (user.userId = parameter.userId))
 

diff --git a/examples/nats-bridge/src/service/user/v1/command/signUp/signUpCommandBuilder.ts b/examples/nats-bridge/src/service/user/v1/command/signUp/signUpCommandBuilder.ts
@@ -20,7 +20,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
   .addOutputSchema(userV1SignUpOutputPayloadSchema)
   .exposeAsHttpEndpoint('POST', 'user/signup')
   .setCommandFunction(async function (context, payload, _parameter) {
-    const result: { users?: User[] } = await context.states.getState(StateStoreKey.Users)
+    const result = (await context.states.getState(StateStoreKey.Users)) as { [StateStoreKey.Users]: User[] | undefined }
 
     if (result.users?.some((user) => user.email === payload.email)) {
       throw new HandledError(StatusCode.BadRequest, 'the user already exists')
@@ -31,7 +31,7 @@ export const signUpCommandBuilder = userV1ServiceBuilder
       userId: randomUUID(),
     }
 
-    const users = result.users || []
+    const users = result.users ?? []
     users.push(user)
 
     await context.states.setState(StateStoreKey.Users, users)

diff --git a/examples/nats-bridge/src/types/StateStoreKey.enum.ts b/examples/nats-bridge/src/types/StateStoreKey.enum.ts
@@ -1,3 +1,3 @@
-export enum StateStoreKey {
-  Users = 'users',
-}
+export const StateStoreKey = {
+  Users: 'users',
+} as const
diff --git a/package.json b/package.json
@@ -5,8 +5,8 @@
   "scripts": {
     "start": "npm run dev -w examples/fullexample",
     "build": "npm run build --workspaces --if-present",
-    "lint": "eslint . --cache . --fix",
-    "lint:fix": "eslint . --cache .",
+    "lint": "eslint . --cache .",
+    "lint:fix": "eslint . --cache . --fix",
     "test": "vitest -c vite.config.all.ts",
     "test:unit": "vitest -c vite.config.ts",
     "test:integration": "vitest -c vite.config.integration.ts",

diff --git a/packages/amqpbridge/src/AmqpBridge.impl.ts b/packages/amqpbridge/src/AmqpBridge.impl.ts
@@ -135,7 +135,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
   async start() {
     await super.start()
     try {
-      this.connection = await amqplib.connect(this.config.url || getDefaultConfig().url, this.config.socketOptions)
+      this.connection = await amqplib.connect(this.config.url ?? getDefaultConfig().url, this.config.socketOptions)
     } catch (err) {
       this.emit(EventBridgeEventNames.EventbridgeConnectionError, err)
       this.logger.fatal({ err }, 'unable to connect to broker')
@@ -173,13 +173,13 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
 
     this.logger.debug('ensured: default exchange')
     await this.channel.assertExchange(
-      this.config.exchangeName || getDefaultConfig().exchangeName,
+      this.config.exchangeName ?? getDefaultConfig().exchangeName,
       'headers',
       this.config.exchangeOptions,
     )
     const responseQueue = await this.channel.assertQueue('', { exclusive: true, autoDelete: true, durable: false })
     this.replyQueueName = responseQueue.queue
-    await this.channel.bindQueue(this.replyQueueName, this.config.exchangeName || getDefaultConfig().exchangeName, '', {
+    await this.channel.bindQueue(this.replyQueueName, this.config.exchangeName ?? getDefaultConfig().exchangeName, '', {
       'x-match': 'all',
       replyTo: this.replyQueueName,
     })
@@ -337,7 +337,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
 
       const payload = await this.encodeContent(msg, contentType, contentEncoding)
 
-      await this.channel.publish(this.config.exchangeName || getDefaultConfig().exchangeName, '', payload, {
+      await this.channel.publish(this.config.exchangeName ?? getDefaultConfig().exchangeName, '', payload, {
         messageId: msg.id,
         timestamp: msg.timestamp,
         contentType,
@@ -446,7 +446,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
 
         const content = await this.encodeContent(command, 'application/json', 'utf-8')
 
-        this.channel.publish(this.config.exchangeName || getDefaultConfig().exchangeName, '', content, {
+        this.channel.publish(this.config.exchangeName ?? getDefaultConfig().exchangeName, '', content, {
           messageId: command.id,
           timestamp: command.timestamp,
           correlationId: command.correlationId,
@@ -483,7 +483,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
 
     const channel = await this.connection.createChannel()
 
-    const noAck = eventBridgeConfig.autoacknowledge === undefined ? true : eventBridgeConfig.autoacknowledge
+    const noAck = eventBridgeConfig.autoacknowledge ?? true
 
     channel.on('close', () => {
       this.healthy = false
@@ -498,7 +498,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
     })
 
     const queue = await channel.assertQueue(queueName, { durable: !!eventBridgeConfig.durable, autoDelete: true })
-    await channel.bindQueue(queue.queue, this.config.exchangeName || getDefaultConfig().exchangeName, '', {
+    await channel.bindQueue(queue.queue, this.config.exchangeName ?? getDefaultConfig().exchangeName, '', {
       'x-match': 'all',
       messageType: EBMessageType.Command,
       receiverServiceName: address.serviceName,
@@ -575,7 +575,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
 
                   const payload = await this.encodeContent(responseMessage, contentType, contentEncoding)
 
-                  this.channel?.publish(this.config.exchangeName || getDefaultConfig().exchangeName, '', payload, {
+                  this.channel?.publish(this.config.exchangeName ?? getDefaultConfig().exchangeName, '', payload, {
                     messageId: responseMessage.id,
                     timestamp: responseMessage.timestamp,
                     correlationId: msg.properties.correlationId,
@@ -686,7 +686,7 @@ export class AmqpBridge extends EventBridgeBaseClass<AmqpBridgeConfig> implement
     })
 
     const queue = await channel.assertQueue(queueName, queueOptions)
-    await channel.bindQueue(queue.queue, this.config.exchangeName || getDefaultConfig().exchangeName, '', {
+    await channel.bindQueue(queue.queue, this.config.exchangeName ?? getDefaultConfig().exchangeName, '', {
       'x-match': 'all',
       messageType: subscription.messageType,
       senderServiceName: subscription.sender?.serviceName,

diff --git a/packages/base-http-bridge/src/HttpEventBridge/HttpEventBridge.impl.ts b/packages/base-http-bridge/src/HttpEventBridge/HttpEventBridge.impl.ts
@@ -80,7 +80,7 @@ export class HttpEventBridge<CustomConfig extends HttpEventBridgeConfig>
       ...config,
     }
 
-    super(conf.name || 'HttpEventBridge', conf)
+    super(conf.name ?? 'HttpEventBridge', conf)
 
     this.client = client
 

diff --git a/packages/base-http-bridge/src/HttpEventBridge/getCommandHandler.impl.ts b/packages/base-http-bridge/src/HttpEventBridge/getCommandHandler.impl.ts
@@ -46,7 +46,7 @@ export const getCommandHandler = function (
       { kind: SpanKind.CONSUMER },
       parentContext,
       async (span) => {
-        const hostname = process.env.HOSTNAME || 'unknown'
+        const hostname = process.env.HOSTNAME ?? 'unknown'
         span.setAttribute(SemanticAttributes.HTTP_URL, c.req.url || '')
         span.setAttribute(SemanticAttributes.HTTP_METHOD, c.req.method || '')
         span.setAttribute(SemanticAttributes.HTTP_HOST, hostname)

diff --git a/packages/base-http-bridge/src/HttpEventBridge/getCommandHandlerRestApi.impl.ts b/packages/base-http-bridge/src/HttpEventBridge/getCommandHandlerRestApi.impl.ts
@@ -46,7 +46,7 @@ export const getCommandHandlerRestApi = function (
       { kind: SpanKind.CONSUMER },
       parentContext,
       async (span) => {
-        const hostname = process.env.HOSTNAME || 'unknown'
+        const hostname = process.env.HOSTNAME ?? 'unknown'
         span.setAttribute(SemanticAttributes.HTTP_URL, c.req.url || '')
         span.setAttribute(SemanticAttributes.HTTP_METHOD, c.req.method || '')
         span.setAttribute(SemanticAttributes.HTTP_HOST, hostname)
@@ -67,7 +67,7 @@ export const getCommandHandlerRestApi = function (
 
           let body: unknown
           if (c.req.method === 'POST' || c.req.method === 'PUT' || c.req.method === 'PATCH') {
-            const contentType = metadata.expose.contentTypeRequest || 'application/json'
+            const contentType = metadata.expose.contentTypeRequest ?? 'application/json'
 
             body = contentType.toLowerCase() === 'application/json' ? await c.req.json() : await c.req.text()
           }
@@ -79,8 +79,8 @@ export const getCommandHandlerRestApi = function (
             messageType: EBMessageType.Command,
             correlationId: '',
             timestamp: Date.now(),
-            contentType: metadata.expose.contentTypeResponse || 'application/json',
-            contentEncoding: metadata.expose.contentEncodingResponse || 'utf-8',
+            contentType: metadata.expose.contentTypeResponse ?? 'application/json',
+            contentEncoding: metadata.expose.contentEncodingResponse ?? 'utf-8',
             otp: serializeOtp(),
             receiver: {
               ...address,
@@ -131,7 +131,7 @@ export const getCommandHandlerRestApi = function (
               statusText: getErrorMessageForCode(status),
               headers: {
                 'content-type': `${metadata.expose.contentTypeResponse} || 'application/json'; charset=${
-                  metadata.expose.contentEncodingResponse || 'utf-8'
+                  metadata.expose.contentEncodingResponse ?? 'utf-8'
                 }`,
               },
             })
@@ -154,7 +154,7 @@ export const getCommandHandlerRestApi = function (
             statusText: getErrorMessageForCode(status),
             headers: {
               'content-type': `${metadata.expose.contentTypeResponse} || 'application/json'; charset=${
-                metadata.expose.contentEncodingResponse || 'utf-8'
+                metadata.expose.contentEncodingResponse ?? 'utf-8'
               }`,
             },
           })

diff --git a/packages/base-http-bridge/src/HttpEventBridge/getSubscriptionHandler.impl.ts b/packages/base-http-bridge/src/HttpEventBridge/getSubscriptionHandler.impl.ts
@@ -32,7 +32,7 @@ export const getSubscriptionHandler = function (
       { kind: SpanKind.CONSUMER },
       parentContext,
       async (span) => {
-        const hostname = process.env.HOSTNAME || 'unknown'
+        const hostname = process.env.HOSTNAME ?? 'unknown'
         span.setAttribute(SemanticAttributes.HTTP_URL, c.req.url || '')
         span.setAttribute(SemanticAttributes.HTTP_METHOD, c.req.method || '')
         span.setAttribute(SemanticAttributes.HTTP_HOST, hostname)

diff --git a/packages/cli/src/helper/installInfo.ts b/packages/cli/src/helper/installInfo.ts
@@ -67,8 +67,8 @@ const getServiceVersions = (startFolder: string, serviceName: string) => {
         service.version = parseInt(versionInfo[1])
         service.path = path.join(serviceName, path.basename(file))
 
-        service.builderFile = getBuilderFile(name) || ''
-        service.serviceFile = getServiceFile(name) || ''
+        service.builderFile = getBuilderFile(name) ?? ''
+        service.serviceFile = getServiceFile(name) ?? ''
       }
     } else {
       const infoName = path.basename(file)

diff --git a/packages/core/src/DefaultLogger/DefaultLogger.impl.ts b/packages/core/src/DefaultLogger/DefaultLogger.impl.ts
@@ -62,7 +62,7 @@ export class DefaultLogger extends Logger implements ILogger {
     const parameter: LoggerOptions = {
       ...options,
       name: undefined,
-      module: options.module || options.name || prefix.join('-'),
+      module: options.module ?? options.name ?? prefix.join('-'),
     }
 
     const child = this.log.child(parameter)

diff --git a/packages/core/src/HttpClient/HttpClient.impl.ts b/packages/core/src/HttpClient/HttpClient.impl.ts
@@ -42,7 +42,7 @@ export class HttpClient<CustomConfig extends Record<string, unknown> = {}> imple
     const name = config.name ?? this.name
     this.name = name
 
-    const logger = config.logger?.getChildLogger({ name }) || initLogger(config.logLevel, { name })
+    const logger = config.logger?.getChildLogger({ name }) ?? initLogger(config.logLevel, { name })
 
     this.config = {
       logger,
@@ -137,7 +137,7 @@ export class HttpClient<CustomConfig extends Record<string, unknown> = {}> imple
 
     const url = new URL(fullPath, this.baseUrl)
 
-    for (const [key, value] of Object.entries(options?.query || {})) {
+    for (const [key, value] of Object.entries(options?.query ?? {})) {
       url.searchParams.set(key, value)
     }
 

diff --git a/packages/core/src/SubscriptionDefinitionBuilder/SubscriptionDefinitionBuilder.impl.ts b/packages/core/src/SubscriptionDefinitionBuilder/SubscriptionDefinitionBuilder.impl.ts
@@ -787,11 +787,11 @@ export class SubscriptionDefinitionBuilder<
       throw new Error(`SubscriptionDefinitionBuilder: missing function implementation for ${this.subscriptionName}`)
     }
 
-    const inputPayloadSchema: Schema | undefined = this.hooks.transformInput?.transformInputSchema || this.inputSchema
+    const inputPayloadSchema: Schema | undefined = this.hooks.transformInput?.transformInputSchema ?? this.inputSchema
     const inputParameterSchema: Schema | undefined =
-      this.hooks.transformInput?.transformParameterSchema || this.parameterSchema
+      this.hooks.transformInput?.transformParameterSchema ?? this.parameterSchema
     const outputPayloadSchema: Schema | undefined =
-      this.hooks.transformOutput?.transformOutputSchema || this.outputSchema
+      this.hooks.transformOutput?.transformOutputSchema ?? this.outputSchema
 
     const eventBridgeConfig: Complete<DefinitionEventBridgeConfig> = {
       durable: this.durable,