Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@temporalio/common

Package Overview
Dependencies
Maintainers
8
Versions
65
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@temporalio/common - npm Package Compare versions

Comparing version 1.9.0-rc.0 to 1.9.0

2

lib/activity-options.js

@@ -12,5 +12,5 @@ "use strict";

ActivityCancellationType[ActivityCancellationType["ABANDON"] = 2] = "ABANDON";
})(ActivityCancellationType = exports.ActivityCancellationType || (exports.ActivityCancellationType = {}));
})(ActivityCancellationType || (exports.ActivityCancellationType = ActivityCancellationType = {}));
(0, type_helpers_1.checkExtends)();
(0, type_helpers_1.checkExtends)();
//# sourceMappingURL=activity-options.js.map

@@ -21,6 +21,6 @@ "use strict";

};
ValueError = __decorate([
exports.ValueError = ValueError;
exports.ValueError = ValueError = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('ValueError')
], ValueError);
exports.ValueError = ValueError;
/**

@@ -31,6 +31,6 @@ * Thrown when a Payload Converter is misconfigured.

};
PayloadConverterError = __decorate([
exports.PayloadConverterError = PayloadConverterError;
exports.PayloadConverterError = PayloadConverterError = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('PayloadConverterError')
], PayloadConverterError);
exports.PayloadConverterError = PayloadConverterError;
/**

@@ -41,6 +41,6 @@ * Used in different parts of the SDK to note that something unexpected has happened.

};
IllegalStateError = __decorate([
exports.IllegalStateError = IllegalStateError;
exports.IllegalStateError = IllegalStateError = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('IllegalStateError')
], IllegalStateError);
exports.IllegalStateError = IllegalStateError;
/**

@@ -61,6 +61,6 @@ * This exception is thrown in the following cases:

};
WorkflowExecutionAlreadyStartedError = __decorate([
exports.WorkflowExecutionAlreadyStartedError = WorkflowExecutionAlreadyStartedError;
exports.WorkflowExecutionAlreadyStartedError = WorkflowExecutionAlreadyStartedError = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowExecutionAlreadyStartedError')
], WorkflowExecutionAlreadyStartedError);
exports.WorkflowExecutionAlreadyStartedError = WorkflowExecutionAlreadyStartedError;
/**

@@ -80,6 +80,6 @@ * Thrown when a Workflow with the given Id is not known to Temporal Server.

};
WorkflowNotFoundError = __decorate([
exports.WorkflowNotFoundError = WorkflowNotFoundError;
exports.WorkflowNotFoundError = WorkflowNotFoundError = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowNotFoundError')
], WorkflowNotFoundError);
exports.WorkflowNotFoundError = WorkflowNotFoundError;
/**

@@ -94,6 +94,6 @@ * Thrown when the specified namespace is not known to Temporal Server.

};
NamespaceNotFoundError = __decorate([
exports.NamespaceNotFoundError = NamespaceNotFoundError;
exports.NamespaceNotFoundError = NamespaceNotFoundError = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('NamespaceNotFoundError')
], NamespaceNotFoundError);
exports.NamespaceNotFoundError = NamespaceNotFoundError;
//# sourceMappingURL=errors.js.map

@@ -21,3 +21,3 @@ "use strict";

TimeoutType[TimeoutType["TIMEOUT_TYPE_HEARTBEAT"] = 4] = "TIMEOUT_TYPE_HEARTBEAT";
})(TimeoutType = exports.TimeoutType || (exports.TimeoutType = {}));
})(TimeoutType || (exports.TimeoutType = TimeoutType = {}));
(0, type_helpers_1.checkExtends)();

@@ -37,3 +37,3 @@ (0, type_helpers_1.checkExtends)();

RetryState[RetryState["RETRY_STATE_CANCEL_REQUESTED"] = 7] = "RETRY_STATE_CANCEL_REQUESTED";
})(RetryState = exports.RetryState || (exports.RetryState = {}));
})(RetryState || (exports.RetryState = RetryState = {}));
(0, type_helpers_1.checkExtends)();

@@ -54,6 +54,6 @@ (0, type_helpers_1.checkExtends)();

};
TemporalFailure = __decorate([
exports.TemporalFailure = TemporalFailure;
exports.TemporalFailure = TemporalFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('TemporalFailure')
], TemporalFailure);
exports.TemporalFailure = TemporalFailure;
/** Exceptions originated at the Temporal service. */

@@ -66,6 +66,6 @@ let ServerFailure = class ServerFailure extends TemporalFailure {

};
ServerFailure = __decorate([
exports.ServerFailure = ServerFailure;
exports.ServerFailure = ServerFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('ServerFailure')
], ServerFailure);
exports.ServerFailure = ServerFailure;
/**

@@ -148,6 +148,6 @@ * `ApplicationFailure`s are used to communicate application-specific failures in Workflows and Activities.

};
ApplicationFailure = __decorate([
exports.ApplicationFailure = ApplicationFailure;
exports.ApplicationFailure = ApplicationFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('ApplicationFailure')
], ApplicationFailure);
exports.ApplicationFailure = ApplicationFailure;
/**

@@ -166,6 +166,6 @@ * This error is thrown when Cancellation has been requested. To allow Cancellation to happen, let it propagate. To

};
CancelledFailure = __decorate([
exports.CancelledFailure = CancelledFailure;
exports.CancelledFailure = CancelledFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('CancelledFailure')
], CancelledFailure);
exports.CancelledFailure = CancelledFailure;
/**

@@ -179,6 +179,6 @@ * Used as the `cause` when a Workflow has been terminated

};
TerminatedFailure = __decorate([
exports.TerminatedFailure = TerminatedFailure;
exports.TerminatedFailure = TerminatedFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('TerminatedFailure')
], TerminatedFailure);
exports.TerminatedFailure = TerminatedFailure;
/**

@@ -194,6 +194,6 @@ * Used to represent timeouts of Activities and Workflows

};
TimeoutFailure = __decorate([
exports.TimeoutFailure = TimeoutFailure;
exports.TimeoutFailure = TimeoutFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('TimeoutFailure')
], TimeoutFailure);
exports.TimeoutFailure = TimeoutFailure;
/**

@@ -214,6 +214,6 @@ * Contains information about an Activity failure. Always contains the original reason for the failure as its `cause`.

};
ActivityFailure = __decorate([
exports.ActivityFailure = ActivityFailure;
exports.ActivityFailure = ActivityFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('ActivityFailure')
], ActivityFailure);
exports.ActivityFailure = ActivityFailure;
/**

@@ -234,6 +234,6 @@ * Contains information about a Child Workflow failure. Always contains the reason for the failure as its {@link cause}.

};
ChildWorkflowFailure = __decorate([
exports.ChildWorkflowFailure = ChildWorkflowFailure;
exports.ChildWorkflowFailure = ChildWorkflowFailure = __decorate([
(0, type_helpers_1.SymbolBasedInstanceOfError)('ChildWorkflowFailure')
], ChildWorkflowFailure);
exports.ChildWorkflowFailure = ChildWorkflowFailure;
/**

@@ -240,0 +240,0 @@ * If `error` is already an `ApplicationFailure`, returns `error`.

@@ -17,3 +17,3 @@ "use strict";

VersioningIntent[VersioningIntent["DEFAULT"] = 2] = "DEFAULT";
})(VersioningIntent = exports.VersioningIntent || (exports.VersioningIntent = {}));
})(VersioningIntent || (exports.VersioningIntent = VersioningIntent = {}));
(0, type_helpers_1.checkExtends)();

@@ -20,0 +20,0 @@ (0, type_helpers_1.checkExtends)();

@@ -39,3 +39,3 @@ "use strict";

WorkflowIdReusePolicy[WorkflowIdReusePolicy["WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING"] = 4] = "WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING";
})(WorkflowIdReusePolicy = exports.WorkflowIdReusePolicy || (exports.WorkflowIdReusePolicy = {}));
})(WorkflowIdReusePolicy || (exports.WorkflowIdReusePolicy = WorkflowIdReusePolicy = {}));
(0, type_helpers_1.checkExtends)();

@@ -42,0 +42,0 @@ (0, type_helpers_1.checkExtends)();

{
"name": "@temporalio/common",
"version": "1.9.0-rc.0",
"version": "1.9.0",
"description": "Common library for code that's used across the Client, Worker, and/or Workflow",

@@ -15,6 +15,8 @@ "main": "lib/index.js",

"dependencies": {
"@temporalio/proto": "1.9.0-rc.0",
"long": "^5.2.0",
"@temporalio/proto": "1.9.0",
"long": "^5.2.3",
"ms": "^3.0.0-canary.1",
"proto3-json-serializer": "^1.0.3",
"proto3-json-serializer": "^2.0.0"
},
"devDependencies": {
"protobufjs": "^7.2.5"

@@ -38,3 +40,3 @@ },

],
"gitHead": "ca3e508e62de02b2c9bb40d0d889003cebba282d"
"gitHead": "5096976287616207edcd3e4281a2a5e1f7393e33"
}

@@ -9,3 +9,6 @@ import { TemporalFailure } from './failure';

export class ValueError extends Error {
constructor(message: string | undefined, public readonly cause?: unknown) {
constructor(
message: string | undefined,
public readonly cause?: unknown
) {
super(message ?? undefined);

@@ -37,3 +40,7 @@ }

export class WorkflowExecutionAlreadyStartedError extends TemporalFailure {
constructor(message: string, public readonly workflowId: string, public readonly workflowType: string) {
constructor(
message: string,
public readonly workflowId: string,
public readonly workflowType: string
) {
super(message);

@@ -52,3 +59,7 @@ }

export class WorkflowNotFoundError extends Error {
constructor(message: string, public readonly workflowId: string, public readonly runId: string | undefined) {
constructor(
message: string,
public readonly workflowId: string,
public readonly runId: string | undefined
) {
super(message);

@@ -55,0 +66,0 @@ }

@@ -54,3 +54,6 @@ import type { temporal } from '@temporalio/proto';

constructor(message?: string | undefined | null, public readonly cause?: Error) {
constructor(
message?: string | undefined | null,
public readonly cause?: Error
) {
super(message ?? undefined);

@@ -63,3 +66,7 @@ }

export class ServerFailure extends TemporalFailure {
constructor(message: string | undefined, public readonly nonRetryable: boolean, cause?: Error) {
constructor(
message: string | undefined,
public readonly nonRetryable: boolean,
cause?: Error
) {
super(message, cause);

@@ -193,3 +200,7 @@ }

export class CancelledFailure extends TemporalFailure {
constructor(message: string | undefined, public readonly details: unknown[] = [], cause?: Error) {
constructor(
message: string | undefined,
public readonly details: unknown[] = [],
cause?: Error
) {
super(message, cause);

@@ -196,0 +207,0 @@ }

@@ -25,11 +25,11 @@ import type { Payload } from '../interfaces';

: [keyof T] extends [never]
? T
: T extends { [k: string]: ToReplace }
? {
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>;
}
: T extends ToReplace
? ReplaceWith | Exclude<T, ToReplace>
: {
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>;
};
? T
: T extends { [k: string]: ToReplace }
? {
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>;
}
: T extends ToReplace
? ReplaceWith | Exclude<T, ToReplace>
: {
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>;
};

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc