@temporalio/client - npm Package Compare versions

Comparing version 0.19.0-rc.0 to 0.19.0-rc.1

lib/async-completion-client.d.ts

@@ -1,2 +0,2 @@
-import { DataConverter } from '@temporalio/common';
+import { DataConverter, LoadedDataConverter } from '@temporalio/common';
 import { WorkflowService } from './connection';
@@ -65,2 +65,3 @@ /**
     readonly options: AsyncCompletionClientOptionsWithDefaults;
+    protected readonly dataConverter: LoadedDataConverter;
     constructor(service?: WorkflowService, options?: AsyncCompletionClientOptions);
@@ -67,0 +68,0 @@ /**

lib/async-completion-client.js

@@ -7,5 +7,6 @@ "use strict";
 exports.AsyncCompletionClient = exports.defaultAsyncCompletionClientOptions = exports.ActivityCancelledError = exports.ActivityCompletionError = exports.ActivityNotFoundError = void 0;
-const os_1 = __importDefault(require("os"));
 const constants_1 = require("@grpc/grpc-js/build/src/constants");
 const common_1 = require("@temporalio/common");
+const internal_non_workflow_common_1 = require("@temporalio/internal-non-workflow-common");
+const os_1 = __importDefault(require("os"));
 const connection_1 = require("./connection");
@@ -48,3 +49,3 @@ const errors_1 = require("./errors");
     return {
-        dataConverter: common_1.defaultDataConverter,
+        dataConverter: {},
         identity: `${process.pid}@${os_1.default.hostname()}`,
@@ -61,3 +62,4 @@ namespace: 'default',
         this.service = service;
-        this.options = { ...defaultAsyncCompletionClientOptions(), ...(0, common_1.filterNullAndUndefined)(options ?? {}) };
+        this.dataConverter = (0, internal_non_workflow_common_1.loadDataConverter)(options?.dataConverter);
+        this.options = { ...defaultAsyncCompletionClientOptions(), ...(0, internal_non_workflow_common_1.filterNullAndUndefined)(options ?? {}) };
     }
@@ -74,3 +76,3 @@ /**
         }
-        throw new ActivityCompletionError('Unexpeced failure');
+        throw new ActivityCompletionError('Unexpected failure');
     }
@@ -84,3 +86,3 @@ async complete(taskTokenOrFullActivityId, result) {
                     taskToken: taskTokenOrFullActivityId,
-                    result: { payloads: await this.options.dataConverter.toPayloads(result) },
+                    result: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.dataConverter, result) },
                 });
@@ -93,3 +95,3 @@ }
                     ...taskTokenOrFullActivityId,
-                    result: { payloads: await this.options.dataConverter.toPayloads(result) },
+                    result: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.dataConverter, result) },
                 });
@@ -109,3 +111,3 @@ }
                     taskToken: taskTokenOrFullActivityId,
-                    failure: await (0, common_1.errorToFailure)((0, common_1.ensureTemporalFailure)(err), this.options.dataConverter),
+                    failure: await (0, internal_non_workflow_common_1.encodeErrorToFailure)(this.dataConverter, (0, common_1.ensureTemporalFailure)(err)),
                 });
@@ -118,3 +120,3 @@ }
                     ...taskTokenOrFullActivityId,
-                    failure: await (0, common_1.errorToFailure)(err, this.options.dataConverter),
+                    failure: await (0, internal_non_workflow_common_1.encodeErrorToFailure)(this.dataConverter, err),
                 });
@@ -134,3 +136,3 @@ }
                     taskToken: taskTokenOrFullActivityId,
-                    details: { payloads: await this.options.dataConverter.toPayloads(details) },
+                    details: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.dataConverter, details) },
                 });
@@ -143,3 +145,3 @@ }
                     ...taskTokenOrFullActivityId,
-                    details: { payloads: await this.options.dataConverter.toPayloads(details) },
+                    details: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.dataConverter, details) },
                 });
@@ -159,3 +161,3 @@ }
                     taskToken: taskTokenOrFullActivityId,
-                    details: { payloads: await this.options.dataConverter.toPayloads(details) },
+                    details: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.dataConverter, details) },
                 });
@@ -171,3 +173,3 @@ if (cancelRequested) {
                     ...taskTokenOrFullActivityId,
-                    details: { payloads: await this.options.dataConverter.toPayloads(details) },
+                    details: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.dataConverter, details) },
                 });
@@ -174,0 +176,0 @@ if (cancelRequested) {

lib/connection.d.ts

 import * as grpc from '@grpc/grpc-js';
 import { temporal } from '@temporalio/proto';
-import { TLSConfig } from '@temporalio/common';
+import { TLSConfig } from '@temporalio/internal-non-workflow-common';
 export declare type WorkflowService = temporal.api.workflowservice.v1.WorkflowService;
@@ -5,0 +5,0 @@ export declare const WorkflowService: typeof temporal.api.workflowservice.v1.WorkflowService;

lib/connection.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -25,3 +29,3 @@ if (k2 === undefined) k2 = k;
 const proto_1 = require("@temporalio/proto");
-const common_1 = require("@temporalio/common");
+const internal_non_workflow_common_1 = require("@temporalio/internal-non-workflow-common");
 const grpc_retry_1 = require("./grpc-retry");
@@ -52,3 +56,3 @@ exports.WorkflowService = proto_1.temporal.api.workflowservice.v1.WorkflowService;
     }
-    const tls = (0, common_1.normalizeTlsConfig)(tlsFromConfig);
+    const tls = (0, internal_non_workflow_common_1.normalizeTlsConfig)(tlsFromConfig);
     if (tls) {
@@ -55,0 +59,0 @@ if (credentials) {

lib/grpc-retry.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k;

lib/index.d.ts

@@ -11,9 +11,10 @@ /**
  */
-export * from './workflow-client';
+export { ActivityFailure, ApplicationFailure, CancelledFailure, ChildWorkflowFailure, DataConverter, defaultPayloadConverter, ProtoFailure, ServerFailure, TemporalFailure, TerminatedFailure, TimeoutFailure, } from '@temporalio/common';
+export { RetryPolicy } from '@temporalio/internal-workflow-common';
 export * from './async-completion-client';
 export * from './connection';
+export * from './errors';
+export * from './interceptors';
 export * from './types';
-export * from './errors';
+export * from './workflow-client';
 export * from './workflow-options';
-export * from './interceptors';
-export { DataConverter, defaultDataConverter, ActivityFailure, ApplicationFailure, ChildWorkflowFailure, CancelledFailure, ServerFailure, TemporalFailure, TerminatedFailure, TimeoutFailure, ProtoFailure, RetryPolicy, } from '@temporalio/common';

lib/index.js

@@ -14,3 +14,7 @@ "use strict";
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -24,16 +28,9 @@ if (k2 === undefined) k2 = k;
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.TimeoutFailure = exports.TerminatedFailure = exports.TemporalFailure = exports.ServerFailure = exports.CancelledFailure = exports.ChildWorkflowFailure = exports.ApplicationFailure = exports.ActivityFailure = exports.defaultDataConverter = void 0;
-__exportStar(require("./workflow-client"), exports);
-__exportStar(require("./async-completion-client"), exports);
-__exportStar(require("./connection"), exports);
-__exportStar(require("./types"), exports);
-__exportStar(require("./errors"), exports);
-__exportStar(require("./workflow-options"), exports);
-__exportStar(require("./interceptors"), exports);
+exports.TimeoutFailure = exports.TerminatedFailure = exports.TemporalFailure = exports.ServerFailure = exports.defaultPayloadConverter = exports.ChildWorkflowFailure = exports.CancelledFailure = exports.ApplicationFailure = exports.ActivityFailure = void 0;
 var common_1 = require("@temporalio/common");
-Object.defineProperty(exports, "defaultDataConverter", { enumerable: true, get: function () { return common_1.defaultDataConverter; } });
 Object.defineProperty(exports, "ActivityFailure", { enumerable: true, get: function () { return common_1.ActivityFailure; } });
 Object.defineProperty(exports, "ApplicationFailure", { enumerable: true, get: function () { return common_1.ApplicationFailure; } });
+Object.defineProperty(exports, "CancelledFailure", { enumerable: true, get: function () { return common_1.CancelledFailure; } });
 Object.defineProperty(exports, "ChildWorkflowFailure", { enumerable: true, get: function () { return common_1.ChildWorkflowFailure; } });
-Object.defineProperty(exports, "CancelledFailure", { enumerable: true, get: function () { return common_1.CancelledFailure; } });
+Object.defineProperty(exports, "defaultPayloadConverter", { enumerable: true, get: function () { return common_1.defaultPayloadConverter; } });
 Object.defineProperty(exports, "ServerFailure", { enumerable: true, get: function () { return common_1.ServerFailure; } });
@@ -43,2 +40,9 @@ Object.defineProperty(exports, "TemporalFailure", { enumerable: true, get: function () { return common_1.TemporalFailure; } });
 Object.defineProperty(exports, "TimeoutFailure", { enumerable: true, get: function () { return common_1.TimeoutFailure; } });
+__exportStar(require("./async-completion-client"), exports);
+__exportStar(require("./connection"), exports);
+__exportStar(require("./errors"), exports);
+__exportStar(require("./interceptors"), exports);
+__exportStar(require("./types"), exports);
+__exportStar(require("./workflow-client"), exports);
+__exportStar(require("./workflow-options"), exports);
 //# sourceMappingURL=index.js.map

lib/interceptors.d.ts

@@ -6,3 +6,3 @@ /**
  */
-import { Next, Headers } from '@temporalio/common';
+import { Next, Headers } from '@temporalio/internal-workflow-common';
 import { temporal } from '@temporalio/proto';
@@ -9,0 +9,0 @@ import { CompiledWorkflowOptions } from './workflow-options';

lib/workflow-client.d.ts

@@ -0,8 +1,8 @@
+import { DataConverter, LoadedDataConverter } from '@temporalio/common';
+import { BaseWorkflowHandle, QueryDefinition, WithWorkflowArgs, Workflow, WorkflowResultType } from '@temporalio/internal-workflow-common';
 import { temporal } from '@temporalio/proto';
-import { WorkflowClientInterceptors } from './interceptors';
-import { DataConverter, Workflow, BaseWorkflowHandle, QueryDefinition, WorkflowResultType, WithWorkflowArgs } from '@temporalio/common';
+import { WorkflowService } from './connection';
+import { WorkflowCancelInput, WorkflowClientCallsInterceptor, WorkflowClientInterceptors, WorkflowQueryInput, WorkflowSignalInput, WorkflowSignalWithStartInput, WorkflowStartInput, WorkflowTerminateInput } from './interceptors';
+import { DescribeWorkflowExecutionResponse, RequestCancelWorkflowExecutionResponse, TerminateWorkflowExecutionResponse, WorkflowExecution } from './types';
 import { WorkflowOptions, WorkflowSignalWithStartOptions } from './workflow-options';
-import { WorkflowCancelInput, WorkflowClientCallsInterceptor, WorkflowQueryInput, WorkflowSignalInput, WorkflowSignalWithStartInput, WorkflowStartInput, WorkflowTerminateInput } from './interceptors';
-import { DescribeWorkflowExecutionResponse, TerminateWorkflowExecutionResponse, RequestCancelWorkflowExecutionResponse, WorkflowExecution } from './types';
-import { WorkflowService } from './connection';
 /**
@@ -105,2 +105,5 @@ * A client side handle to a single Workflow instance.
 export declare type WorkflowClientOptionsWithDefaults = Required<WorkflowClientOptions>;
+export declare type LoadedWorkflowClientOptions = WorkflowClientOptionsWithDefaults & {
+    loadedDataConverter: LoadedDataConverter;
+};
 export declare function defaultWorkflowClientOptions(): WorkflowClientOptionsWithDefaults;
@@ -153,3 +156,3 @@ /**
     readonly service: WorkflowService;
-    readonly options: WorkflowClientOptionsWithDefaults;
+    readonly options: LoadedWorkflowClientOptions;
     constructor(service?: WorkflowService, options?: WorkflowClientOptions);
@@ -156,0 +159,0 @@ /**

lib/workflow-client.js

@@ -7,13 +7,15 @@ "use strict";
 exports.QueryRejectedError = exports.WorkflowClient = exports.defaultWorkflowClientOptions = void 0;
-const os_1 = __importDefault(require("os"));
 const grpc_js_1 = require("@grpc/grpc-js");
+const common_1 = require("@temporalio/common");
+const internal_non_workflow_common_1 = require("@temporalio/internal-non-workflow-common");
+const internal_workflow_common_1 = require("@temporalio/internal-workflow-common");
 const proto_1 = require("@temporalio/proto");
+const os_1 = __importDefault(require("os"));
 const uuid_1 = require("uuid");
-const common_1 = require("@temporalio/common");
+const connection_1 = require("./connection");
+const errors_1 = require("./errors");
 const workflow_options_1 = require("./workflow-options");
-const errors_1 = require("./errors");
-const connection_1 = require("./connection");
 function defaultWorkflowClientOptions() {
     return {
-        dataConverter: common_1.defaultDataConverter,
+        dataConverter: {},
         // The equivalent in Java is ManagementFactory.getRuntimeMXBean().getName()
@@ -45,3 +47,7 @@ identity: `${process.pid}@${os_1.default.hostname()}`,
         this.service = service;
-        this.options = { ...defaultWorkflowClientOptions(), ...options };
+        this.options = {
+            ...defaultWorkflowClientOptions(),
+            ...options,
+            loadedDataConverter: (0, internal_non_workflow_common_1.loadDataConverter)(options?.dataConverter),
+        };
     }
@@ -57,3 +63,3 @@ /**
         const compiledOptions = (0, workflow_options_1.compileWorkflowOptions)(ensureArgs(options));
-        const start = (0, common_1.composeInterceptors)(interceptors, 'start', this._startWorkflowHandler.bind(this));
+        const start = (0, internal_workflow_common_1.composeInterceptors)(interceptors, 'start', this._startWorkflowHandler.bind(this));
         return start({
@@ -76,3 +82,3 @@ options: compiledOptions,
         const compiledOptions = (0, workflow_options_1.compileWorkflowOptions)(ensureArgs(rest));
-        const signalWithStart = (0, common_1.composeInterceptors)(interceptors, 'signalWithStart', this._signalWithStartWorkflowHandler.bind(this));
+        const signalWithStart = (0, internal_workflow_common_1.composeInterceptors)(interceptors, 'signalWithStart', this._signalWithStartWorkflowHandler.bind(this));
         return signalWithStart({
@@ -192,3 +198,3 @@ options: compiledOptions,
                 // Ignore any other payloads in result
-                const [result] = await (0, common_1.arrayFromPayloads)(this.options.dataConverter, ev.workflowExecutionCompletedEventAttributes.result?.payloads);
+                const [result] = await (0, internal_non_workflow_common_1.decodeArrayFromPayloads)(this.options.loadedDataConverter, ev.workflowExecutionCompletedEventAttributes.result?.payloads);
                 return result;
@@ -203,6 +209,6 @@ }
                 const { failure, retryState } = ev.workflowExecutionFailedEventAttributes;
-                throw new errors_1.WorkflowFailedError('Workflow execution failed', await (0, common_1.optionalFailureToOptionalError)(failure, this.options.dataConverter), retryState ?? common_1.RetryState.RETRY_STATE_UNSPECIFIED);
+                throw new errors_1.WorkflowFailedError('Workflow execution failed', await (0, internal_non_workflow_common_1.decodeOptionalFailureToOptionalError)(this.options.loadedDataConverter, failure), retryState ?? common_1.RetryState.RETRY_STATE_UNSPECIFIED);
             }
             else if (ev.workflowExecutionCanceledEventAttributes) {
-                const failure = new common_1.CancelledFailure('Workflow canceled', await (0, common_1.arrayFromPayloads)(this.options.dataConverter, ev.workflowExecutionCanceledEventAttributes.details?.payloads));
+                const failure = new common_1.CancelledFailure('Workflow canceled', await (0, internal_non_workflow_common_1.decodeArrayFromPayloads)(this.options.loadedDataConverter, ev.workflowExecutionCanceledEventAttributes.details?.payloads));
                 failure.stack = '';
@@ -243,7 +249,7 @@ throw new errors_1.WorkflowFailedError('Workflow execution cancelled', failure, common_1.RetryState.RETRY_STATE_NON_RETRYABLE_FAILURE);
             if (err.code === grpc_js_1.status.NOT_FOUND) {
-                throw new common_1.WorkflowNotFoundError(err.details ?? 'Workflow not found', workflowExecution.workflowId, workflowExecution.runId);
+                throw new internal_workflow_common_1.WorkflowNotFoundError(err.details ?? 'Workflow not found', workflowExecution.workflowId, workflowExecution.runId);
             }
             throw new errors_1.ServiceError(fallbackMessage, { cause: err });
         }
-        throw new errors_1.ServiceError('Unexpeced error while making gRPC request');
+        throw new errors_1.ServiceError('Unexpected error while making gRPC request');
     }
@@ -264,3 +270,3 @@ /**
                     queryType: input.queryType,
-                    queryArgs: { payloads: await this.options.dataConverter.toPayloads(...input.args) },
+                    queryArgs: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.options.loadedDataConverter, ...input.args) },
                 },
@@ -282,3 +288,3 @@ });
         // We ignore anything but the first result
-        return this.options.dataConverter.fromPayloads(0, response.queryResult?.payloads);
+        return await (0, internal_non_workflow_common_1.decodeFromPayloadsAtIndex)(this.options.loadedDataConverter, 0, response.queryResult?.payloads);
     }
@@ -299,3 +305,3 @@ /**
                 signalName: input.signalName,
-                input: { payloads: await this.options.dataConverter.toPayloads(...input.args) },
+                input: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.options.loadedDataConverter, ...input.args) },
             });
@@ -313,3 +319,3 @@ }
     async _signalWithStartWorkflowHandler(input) {
-        const { identity, dataConverter } = this.options;
+        const { identity } = this.options;
         const { options, workflowType, signalName, signalArgs, headers } = input;
@@ -324,5 +330,5 @@ try {
                 workflowType: { name: workflowType },
-                input: { payloads: await dataConverter.toPayloads(...options.args) },
+                input: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.options.loadedDataConverter, ...options.args) },
                 signalName,
-                signalInput: { payloads: await dataConverter.toPayloads(...signalArgs) },
+                signalInput: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.options.loadedDataConverter, ...signalArgs) },
                 taskQueue: {
@@ -335,7 +341,9 @@ kind: proto_1.temporal.api.enums.v1.TaskQueueKind.TASK_QUEUE_KIND_UNSPECIFIED,
                 workflowTaskTimeout: options.workflowTaskTimeout,
-                retryPolicy: options.retry ? (0, common_1.compileRetryPolicy)(options.retry) : undefined,
-                memo: options.memo ? { fields: await (0, common_1.mapToPayloads)(dataConverter, options.memo) } : undefined,
+                retryPolicy: options.retry ? (0, internal_workflow_common_1.compileRetryPolicy)(options.retry) : undefined,
+                memo: options.memo
+                    ? { fields: await (0, internal_non_workflow_common_1.encodeMapToPayloads)(this.options.loadedDataConverter, options.memo) }
+                    : undefined,
                 searchAttributes: options.searchAttributes
                     ? {
-                        indexedFields: await (0, common_1.mapToPayloads)(dataConverter, options.searchAttributes),
+                        indexedFields: await (0, internal_non_workflow_common_1.encodeMapToPayloads)(this.options.loadedDataConverter, options.searchAttributes),
                     }
@@ -359,3 +367,3 @@ : undefined,
         const { options: opts, workflowType, headers } = input;
-        const { identity, dataConverter } = this.options;
+        const { identity } = this.options;
         const req = {
@@ -368,3 +376,3 @@ namespace: this.options.namespace,
             workflowType: { name: workflowType },
-            input: { payloads: await dataConverter.toPayloads(...opts.args) },
+            input: { payloads: await (0, internal_non_workflow_common_1.encodeToPayloads)(this.options.loadedDataConverter, ...opts.args) },
             taskQueue: {
@@ -377,7 +385,7 @@ kind: proto_1.temporal.api.enums.v1.TaskQueueKind.TASK_QUEUE_KIND_UNSPECIFIED,
             workflowTaskTimeout: opts.workflowTaskTimeout,
-            retryPolicy: opts.retry ? (0, common_1.compileRetryPolicy)(opts.retry) : undefined,
-            memo: opts.memo ? { fields: await (0, common_1.mapToPayloads)(dataConverter, opts.memo) } : undefined,
+            retryPolicy: opts.retry ? (0, internal_workflow_common_1.compileRetryPolicy)(opts.retry) : undefined,
+            memo: opts.memo ? { fields: await (0, internal_non_workflow_common_1.encodeMapToPayloads)(this.options.loadedDataConverter, opts.memo) } : undefined,
             searchAttributes: opts.searchAttributes
                 ? {
-                    indexedFields: await (0, common_1.mapToPayloads)(dataConverter, opts.searchAttributes),
+                    indexedFields: await (0, internal_non_workflow_common_1.encodeMapToPayloads)(this.options.loadedDataConverter, opts.searchAttributes),
                 }
@@ -410,3 +418,7 @@ : undefined,
                 ...input,
-                details: { payloads: await this.options.dataConverter.toPayloads(input.details) },
+                details: {
+                    payloads: input.details
+                        ? await (0, internal_non_workflow_common_1.encodeToPayloads)(this.options.loadedDataConverter, ...input.details)
+                        : undefined,
+                },
                 firstExecutionRunId: input.firstExecutionRunId,
@@ -451,3 +463,3 @@ });
                 const next = this.client._terminateWorkflowHandler.bind(this.client);
-                const fn = interceptors.length ? (0, common_1.composeInterceptors)(interceptors, 'terminate', next) : next;
+                const fn = interceptors.length ? (0, internal_workflow_common_1.composeInterceptors)(interceptors, 'terminate', next) : next;
                 return await fn({
@@ -461,3 +473,3 @@ workflowExecution: { workflowId, runId },
                 const next = this.client._cancelWorkflowHandler.bind(this.client);
-                const fn = interceptors.length ? (0, common_1.composeInterceptors)(interceptors, 'cancel', next) : next;
+                const fn = interceptors.length ? (0, internal_workflow_common_1.composeInterceptors)(interceptors, 'cancel', next) : next;
                 return await fn({
@@ -479,3 +491,3 @@ workflowExecution: { workflowId, runId },
                 const next = this.client._signalWorkflowHandler.bind(this.client);
-                const fn = interceptors.length ? (0, common_1.composeInterceptors)(interceptors, 'signal', next) : next;
+                const fn = interceptors.length ? (0, internal_workflow_common_1.composeInterceptors)(interceptors, 'signal', next) : next;
                 await fn({
@@ -489,3 +501,3 @@ workflowExecution: { workflowId, runId },
                 const next = this.client._queryWorkflowHandler.bind(this.client);
-                const fn = interceptors.length ? (0, common_1.composeInterceptors)(interceptors, 'query', next) : next;
+                const fn = interceptors.length ? (0, internal_workflow_common_1.composeInterceptors)(interceptors, 'query', next) : next;
                 return fn({
@@ -492,0 +504,0 @@ workflowExecution: { workflowId, runId },

lib/workflow-options.d.ts

@@ -1,3 +0,3 @@
-import { WithCompiledWorkflowDurationOptions, CommonWorkflowOptions, SignalDefinition } from '@temporalio/common';
-export { WithCompiledWorkflowDurationOptions, compileWorkflowOptions } from '@temporalio/common';
+import { CommonWorkflowOptions, SignalDefinition, WithCompiledWorkflowDurationOptions } from '@temporalio/internal-workflow-common';
+export { compileWorkflowOptions, WithCompiledWorkflowDurationOptions } from '@temporalio/internal-workflow-common';
 export interface CompiledWorkflowOptions extends WithCompiledWorkflowDurationOptions<WorkflowOptions> {
@@ -4,0 +4,0 @@ args: unknown[];

lib/workflow-options.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.compileWorkflowOptions = void 0;
-var common_1 = require("@temporalio/common");
-Object.defineProperty(exports, "compileWorkflowOptions", { enumerable: true, get: function () { return common_1.compileWorkflowOptions; } });
+var internal_workflow_common_1 = require("@temporalio/internal-workflow-common");
+Object.defineProperty(exports, "compileWorkflowOptions", { enumerable: true, get: function () { return internal_workflow_common_1.compileWorkflowOptions; } });
 // export interface WorkflowOptionsWithDefaults<T extends Workflow> extends CommonWorkflowOptionsWithDefaults<T> {
@@ -7,0 +7,0 @@ //   /**

package.json

 {
   "name": "@temporalio/client",
-  "version": "0.19.0-rc.0",
+  "version": "0.19.0-rc.1",
   "description": "Temporal.io SDK Client sub-package",
@@ -17,4 +17,6 @@ "main": "lib/index.js",
     "@grpc/grpc-js": "^1.3.7",
-    "@temporalio/common": "^0.19.0-rc.0",
-    "@temporalio/proto": "^0.18.0",
+    "@temporalio/common": "^0.19.0-rc.1",
+    "@temporalio/internal-non-workflow-common": "^0.19.0-rc.1",
+    "@temporalio/internal-workflow-common": "^0.19.0-rc.1",
+    "@temporalio/proto": "^0.19.0-rc.1",
     "ms": "^2.1.3",
@@ -34,3 +36,3 @@ "protobufjs": "^6.11.2",
   },
-  "gitHead": "f55f02d343ac6db5d556fc1c7316013a8974c559"
+  "gitHead": "186341ed7285e468c145121433f2c239e53934a6"
 }

README.md

@@ -5,6 +5,6 @@ # `@temporalio/client`
 
-Part of the [Temporal](https://temporal.io) [TypeScript SDK](https://www.npmjs.com/package/temporalio).
+Part of [Temporal](https://temporal.io)'s [TypeScript SDK](https://docs.temporal.io/docs/typescript/introduction/).
 
-- See API reference [here](https://typescript.temporal.io/api/namespaces/client)
-- See code samples [here](https://github.com/temporalio/samples-typescript)
-- See full introduction on the [docs site](https://docs.temporal.io/docs/typescript/introduction)
+- [Client docs](https://docs.temporal.io/docs/typescript/clients)
+- [API reference](https://typescript.temporal.io/api/namespaces/client)
+- [Sample projects](https://github.com/temporalio/samples-typescript)

No alert changes

Improved metrics

Total package byte prevSize

105752

increased by3.15%

Lines of code

1722

increased by1.83%

Worsened metrics

Dependency count

8

increased by33.33%

Dependency changes

• + Added@temporalio/internal-non-workflow-common@^0.19.0-rc.1

• + Added@temporalio/internal-workflow-common@^0.19.0-rc.1

• + Added@temporalio/internal-non-workflow-common@0.19.2(transitive)

• - Removed@temporalio/proto@0.18.0(transitive)

• Updated@temporalio/common@^0.19.0-rc.1

• Updated@temporalio/proto@^0.19.0-rc.1