refactor(core): remove unused code exports

Author: carderne

packages/core/src/debounce.ts

@@ -89,7 +89,7 @@ export type RunShapeStreamOptions = {
   onFetchError?: (e: Error) => void;
 };
 
-export type StreamPartResult<TRun, TStreams extends Record<string, any>> = {
+type StreamPartResult<TRun, TStreams extends Record<string, any>> = {
   [K in keyof TStreams]: {
     type: K;
     chunk: TStreams[K];
@@ -665,7 +665,7 @@ export class SSEStreamSubscriptionFactory implements StreamSubscriptionFactory {
   }
 }
 
-export interface RunShapeProvider {
+interface RunShapeProvider {
   onShape(callback: (shape: SubscribeRunRawShape) => Promise<void>): Promise<() => void>;
 }
 

packages/core/src/v3/apiClient/runStream.ts

@@ -225,7 +225,7 @@ class ReadableShapeStream<T extends Row<unknown> = Row> {
   }
 }
 
-export class LineTransformStream extends TransformStream<string, string[]> {
+class LineTransformStream extends TransformStream<string, string[]> {
   private buffer = "";
 
   constructor() {

packages/core/src/v3/apiClient/stream.ts

@@ -17,7 +17,7 @@ function getDevBranchEnvVar(): string | undefined {
   return value && !isDefaultDevBranch(value) ? value : undefined;
 }
 
-export class ApiClientMissingError extends Error {
+class ApiClientMissingError extends Error {
   constructor(message: string) {
     super(message);
     this.name = "ApiClientMissingError";

packages/core/src/v3/apiClientManager/index.ts

@@ -1,7 +1,7 @@
 import { PreciseDate } from "@google-cloud/precise-date";
 import type { Clock, ClockTime } from "./clock.js";
 
-export type PreciseWallClockOptions = {
+type PreciseWallClockOptions = {
   origin?: ClockTime;
   now?: PreciseDate;
 };

packages/core/src/v3/clock/preciseWallClock.ts

@@ -33,7 +33,7 @@ export type OnStartHookFunction<TPayload, TInitOutput extends TaskInitOutput = T
 
 export type AnyOnStartHookFunction = OnStartHookFunction<unknown, TaskInitOutput>;
 
-export type TaskStartAttemptHookParams<TPayload = unknown> = {
+type TaskStartAttemptHookParams<TPayload = unknown> = {
   ctx: TaskRunContext;
   payload: TPayload;
   task: string;
@@ -142,12 +142,12 @@ export type OnSuccessHookFunction<
 
 export type AnyOnSuccessHookFunction = OnSuccessHookFunction<unknown, unknown, TaskInitOutput>;
 
-export type TaskCompleteSuccessResult<TOutput> = {
+type TaskCompleteSuccessResult<TOutput> = {
   ok: true;
   data: TOutput;
 };
 
-export type TaskCompleteErrorResult = {
+type TaskCompleteErrorResult = {
   ok: false;
   error: unknown;
 };

packages/core/src/v3/lifecycleHooks/types.ts

@@ -13,7 +13,7 @@ export type LogLevel = "none" | "error" | "warn" | "info" | "debug" | "log";
 
 export const logLevels: Array<LogLevel> = ["none", "error", "warn", "info", "debug"];
 
-export type TaskLoggerConfig = {
+type TaskLoggerConfig = {
   logger: Logger;
   tracer: TriggerTracer;
   level: LogLevel;

packages/core/src/v3/logger/taskLogger.ts

@@ -656,7 +656,7 @@ function isValidAndNotEmpty(name: string | undefined): boolean {
   return isValid(name) && name.length > 0;
 }
 
-export function parseOtelResourceAttributes(
+function parseOtelResourceAttributes(
   rawEnvAttributes: string | undefined | null
 ): Record<string, string> {
   if (!rawEnvAttributes) return {};

packages/core/src/v3/otel/tracingSDK.ts

@@ -9,17 +9,9 @@ import type {
 // Re-export the session-scoped stream instance so the SDK's
 // `SessionOutputChannel.pipe` / `.writer` can construct it without reaching
 // into the core package's internals.
-export { SessionStreamInstance } from "./sessionStreamInstance.js";
-export type {
-  SessionStreamInstanceOptions,
-  InitializeSessionStreamResponseLike,
-} from "./sessionStreamInstance.js";
-export {
-  trimSessionStream,
-  writeSessionControlRecord,
-  writeTurnCompleteRecord,
-  writeUpgradeRequiredRecord,
-} from "./sessionStreamOneshot.js";
+;
+;
+;
 
 const API_NAME = "realtime-streams";
 

packages/core/src/v3/realtimeStreams/index.ts

@@ -50,4 +50,4 @@ export type WorkerEvents = {
   ];
 };
 
-export type WorkerEventArgs<T extends keyof WorkerEvents> = WorkerEvents[T];
+type WorkerEventArgs<T extends keyof WorkerEvents> = WorkerEvents[T];