@temporalio/core-bridge - npm Package Compare versions

Comparing version 1.9.3 to 1.10.0

lib/index.d.ts

 import { LogLevel, Duration } from '@temporalio/common';
-import type { TLSConfig } from '@temporalio/common/lib/internal-non-workflow';
-export { TLSConfig };
+import type { TLSConfig, ProxyConfig, HttpConnectProxyConfig } from '@temporalio/common/lib/internal-non-workflow';
+export type { TLSConfig, ProxyConfig, HttpConnectProxyConfig };
 /** @deprecated Import from @temporalio/common instead */
@@ -41,2 +41,8 @@ export { LogLevel };
     /**
+     * Proxying configuration.
+     *
+     * @experimental
+     */
+    proxy?: ProxyConfig;
+    /**
      * Optional retry options for server requests.
@@ -51,2 +57,9 @@ */
     metadata?: Record<string, string>;
+    /**
+     * API key for Temporal. This becomes the "Authorization" HTTP header with "Bearer " prepended.
+     * This is only set if RPC metadata doesn't already have an "authorization" key.
+     *
+     * Set statically at connection time, can be replaced later using {@link clientUpdateApiKey}.
+     */
+    apiKey?: string;
 }
@@ -104,2 +117,6 @@ /**
         metricsExportInterval?: Duration;
+        /**
+         * If set to true, the exporter will use seconds for durations instead of milliseconds.
+         */
+        useSecondsForDurations?: boolean;
     };
@@ -127,2 +144,15 @@ }
         bindAddress: string;
+        /**
+         * If set to true, all counter names will include a "_total" suffix.
+         */
+        countersTotalSuffix?: boolean;
+        /**
+         * If set to true, all histograms will include the unit in their name as a suffix.
+         * EX: "_milliseconds"
+         */
+        unitSuffix?: boolean;
+        /**
+         * If set to true, the exporter will use seconds for durations instead of milliseconds.
+         */
+        useSecondsForDurations?: boolean;
     };
@@ -423,2 +453,3 @@ }
 export declare function clientUpdateHeaders(client: Client, headers: Record<string, string>, callback: VoidCallback): void;
+export declare function clientUpdateApiKey(client: Client, apiKey: string, callback: VoidCallback): void;
 export declare function clientClose(client: Client): void;
@@ -425,0 +456,0 @@ export declare function runtimeShutdown(runtime: Runtime, callback: VoidCallback): void;

package.json

 {
   "name": "@temporalio/core-bridge",
-  "version": "1.9.3",
+  "version": "1.10.0",
   "description": "Temporal.io SDK Core<>Node bridge",
@@ -13,3 +13,3 @@ "main": "index.js",
     "format": "cargo fmt",
-    "lint": "cargo clippy --fix",
+    "lint": "cargo clippy --fix --allow-staged",
     "lint.check": "cargo clippy"
@@ -26,3 +26,3 @@ },
   "dependencies": {
-    "@temporalio/common": "1.9.3",
+    "@temporalio/common": "1.10.0",
     "arg": "^5.0.2",
@@ -57,3 +57,3 @@ "cargo-cp-artifact": "^0.1.8",
   },
-  "gitHead": "e7e46639c1ba23b86f367a051fb54d736c5f21ce"
+  "gitHead": "39d702af7ae5d7e33ee90651292aa77fa07d33ca"
 }

scripts/build.js

@@ -85,7 +85,8 @@ const path = require('path');
   console.log('Running', cmd, argv);
-  const { status } = spawnSync(cmd, argv, {
+  const { status, error } = spawnSync(cmd, argv, {
     stdio: 'inherit',
+    shell: process.platform === 'win32',
   });
-  if (status !== 0) {
-    throw new Error(`Failed to build${target ? ' for ' + target : ''}`);
+  if (status !== 0 || error) {
+    throw new Error(`Failed to build${target ? ' for ' + target : ''}: status code ${status}`, error);
   }
@@ -92,0 +93,0 @@ }

sdk-core/README.md

@@ -1,3 +0,1 @@
-[![Build status](https://badge.buildkite.com/c23f47f4a827f04daece909963bd3a248496f0cdbabfbecee4.svg?branch=master)](https://buildkite.com/temporal/core-sdk?branch=master)
-
 # Temporal Core SDK
@@ -37,3 +35,3 @@
 - rustfsm `./fsm` - Implements a procedural macro used by core for defining state machines
-    (contains subcrates). It is temporal agnostic.
+  (contains subcrates). It is temporal agnostic.
 
@@ -55,3 +53,3 @@ Visualized (dev dependencies are in blue):
 
-Run load tests with `cargo test --features=save_wf_inputs --test heavy_tests`.
+Run load tests with `cargo test --test heavy_tests`.
 
@@ -91,4 +89,4 @@ ## Formatting
 
-This repo uses a subtree for upstream protobuf files. The path `sdk-core-protos/protos/api_upstream` is a
-subtree. To update it, use:
+This repo uses a subtree for upstream protobuf files. The path `sdk-core-protos/protos/api_upstream`
+is a subtree. To update it, use:
 
@@ -95,0 +93,0 @@ `git pull --squash --rebase=false -s subtree ssh://[e-mail]/temporalio/api.git master --allow-unrelated-histories`

sdk-core/sdk-core-protos/protos/api_upstream/.github/PULL_REQUEST_TEMPLATE.md

@@ -12,1 +12,4 @@ <!-- Describe what has changed in this PR -->
 
+
+<!-- If this breaks the Server, please provide the Server PR to merge right after this PR was merged. -->
+**Server PR**

sdk-core/sdk-core-protos/protos/api_upstream/README.md

 # Temporal proto files  
 
+This repository contains both the protobuf descriptors and OpenAPI documentation for the Temporal platform.
+
 ## How to use
@@ -4,0 +6,0 @@

ts/index.ts

 import { LogLevel, Duration } from '@temporalio/common';
-import type { TLSConfig } from '@temporalio/common/lib/internal-non-workflow';
+import type { TLSConfig, ProxyConfig, HttpConnectProxyConfig } from '@temporalio/common/lib/internal-non-workflow';
 
-export { TLSConfig };
+export type { TLSConfig, ProxyConfig, HttpConnectProxyConfig };
 
@@ -59,2 +59,9 @@ /** @deprecated Import from @temporalio/common instead */
   /**
+   * Proxying configuration.
+   *
+   * @experimental
+   */
+  proxy?: ProxyConfig;
+
+  /**
    * Optional retry options for server requests.
@@ -70,2 +77,10 @@ */
   metadata?: Record<string, string>;
+
+  /**
+   * API key for Temporal. This becomes the "Authorization" HTTP header with "Bearer " prepended.
+   * This is only set if RPC metadata doesn't already have an "authorization" key.
+   *
+   * Set statically at connection time, can be replaced later using {@link clientUpdateApiKey}.
+   */
+  apiKey?: string;
 }
@@ -127,2 +142,6 @@
     metricsExportInterval?: Duration;
+    /**
+     * If set to true, the exporter will use seconds for durations instead of milliseconds.
+     */
+    useSecondsForDurations?: boolean;
   };
@@ -132,3 +151,8 @@ }
 /** @experimental */
-export type CompiledOtelMetricsExporter = Shadow<OtelCollectorExporter, { otel: { metricsExportInterval: number } }>;
+export type CompiledOtelMetricsExporter = Shadow<
+  OtelCollectorExporter,
+  {
+    otel: { metricsExportInterval: number };
+  }
+>;
 
@@ -149,2 +173,15 @@ /**
     bindAddress: string;
+    /**
+     * If set to true, all counter names will include a "_total" suffix.
+     */
+    countersTotalSuffix?: boolean;
+    /**
+     * If set to true, all histograms will include the unit in their name as a suffix.
+     * EX: "_milliseconds"
+     */
+    unitSuffix?: boolean;
+    /**
+     * If set to true, the exporter will use seconds for durations instead of milliseconds.
+     */
+    useSecondsForDurations?: boolean;
   };
@@ -438,14 +475,19 @@ }
 }
+
 export interface Runtime {
   type: 'Runtime';
 }
+
 export interface Client {
   type: 'Client';
 }
+
 export interface EphemeralServer {
   type: 'EphemeralServer';
 }
+
 export interface HistoryPusher {
   type: 'HistoryPusher';
 }
+
 export interface ReplayWorker {
@@ -466,4 +508,7 @@ type: 'ReplayWorker';
 export declare function newRuntime(telemOptions: CompiledTelemetryOptions): Runtime;
+
 export declare function newClient(runtime: Runtime, clientOptions: ClientOptions, callback: ClientCallback): void;
+
 export declare function newWorker(client: Client, workerOptions: WorkerOptions, callback: WorkerCallback): void;
+
 export declare function newReplayWorker(
@@ -474,2 +519,3 @@ runtime: Runtime,
 ): void;
+
 export declare function pushHistory(
@@ -481,5 +527,9 @@ pusher: HistoryPusher,
 ): void;
+
 export declare function closeHistoryStream(pusher: HistoryPusher): void;
+
 export declare function workerInitiateShutdown(worker: Worker, callback: VoidCallback): void;
+
 export declare function workerFinalizeShutdown(worker: Worker): void;
+
 export declare function clientUpdateHeaders(
@@ -490,6 +540,13 @@ client: Client,
 ): void;
+
+export declare function clientUpdateApiKey(client: Client, apiKey: string, callback: VoidCallback): void;
+
 export declare function clientClose(client: Client): void;
+
 export declare function runtimeShutdown(runtime: Runtime, callback: VoidCallback): void;
+
 export declare function pollLogs(runtime: Runtime, callback: LogsCallback): void;
+
 export declare function workerPollWorkflowActivation(worker: Worker, callback: PollCallback): void;
+
 export declare function workerCompleteWorkflowActivation(
@@ -500,6 +557,11 @@ worker: Worker,
 ): void;
+
 export declare function workerPollActivityTask(worker: Worker, callback: PollCallback): void;
+
 export declare function workerCompleteActivityTask(worker: Worker, result: ArrayBuffer, callback: VoidCallback): void;
+
 export declare function workerRecordActivityHeartbeat(worker: Worker, heartbeat: ArrayBuffer): void;
+
 export declare function getTimeOfDay(): [number, number];
+
 export declare function startEphemeralServer(
@@ -511,5 +573,7 @@ runtime: Runtime,
 ): void;
+
 export declare function shutdownEphemeralServer(server: EphemeralServer, callback: Callback<EphemeralServer>): void;
+
 export declare function getEphemeralServerTarget(server: EphemeralServer): string;
 
 export { ShutdownError, TransportError, UnexpectedError } from './errors';

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Native code

Supply chain risk

Contains native code (e.g., compiled binaries or shared libraries). Including native code can obscure malicious behavior.

Found 2 instances in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

111597020

increased by8.37%

Number of package files

297

increased by1.37%

Lines of code

11082

increased by818.14%

Worsened metrics

Number of medium supply chain risk alerts

11

increased by37.5%

Dependency changes

• + Added@temporalio/common@1.10.0(transitive)

• + Added@temporalio/proto@1.10.0(transitive)

• - Removed@temporalio/common@1.9.3(transitive)

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

• Updated@temporalio/common@1.10.0