Runtime: Expose readonly directly off the datastore runtime

packages/framework/aqueduct/package.json

@@ -154,7 +154,11 @@
 		"typescript": "~5.4.5"
 	},
 	"typeValidation": {
-		"broken": {},
+		"broken": {
+			"Interface_IDataObjectProps": {
+				"forwardCompat": false
+			}
+		},
 		"entrypoint": "legacy"
 	}
 }

packages/framework/aqueduct/src/test/types/validateAqueductPrevious.generated.ts

@@ -238,6 +238,7 @@ declare type current_as_old_for_Interface_DataObjectTypes = requireAssignableTo<
  * typeValidation.broken:
  * "Interface_IDataObjectProps": {"forwardCompat": false}
  */
+// @ts-expect-error compatibility expected to be broken
 declare type old_as_current_for_Interface_IDataObjectProps = requireAssignableTo<TypeOnly<old.IDataObjectProps>, TypeOnly<current.IDataObjectProps>>
 
 /*

packages/runtime/container-runtime/src/channelCollection.ts

@@ -149,6 +149,9 @@ export function wrapContext(context: IFluidParentContext): IFluidParentContext {
 		get attachState() {
 			return context.attachState;
 		},
+		get readonly() {
+			return context.readonly;
+		},
 		containerRuntime: context.containerRuntime,
 		scope: context.scope,
 		gcThrowOnTombstoneUsage: context.gcThrowOnTombstoneUsage,
@@ -1116,6 +1119,28 @@ export class ChannelCollection implements IFluidDataStoreChannel, IDisposable {
 		}
 	}
 
+	public setReadOnlyState(readonly: boolean): void {
+		for (const [fluidDataStoreId, context] of this.contexts) {
+			try {
+				context.setReadOnlyState(readonly);
+			} catch (error) {
+				this.mc.logger.sendErrorEvent(
+					{
+						eventName: "SetReadOnlyStateError",
+						...tagCodeArtifacts({
+							fluidDataStoreId,
+						}),
+						details: {
+							runtimeReadonly: this.parentContext.readonly,
+							readonly,
+						},
+					},
+					error,
+				);
+			}
+		}
+	}
+
 	public setAttachState(attachState: AttachState.Attaching | AttachState.Attached): void {
 		for (const [, context] of this.contexts) {
 			// Fire only for bounded stores.

packages/runtime/container-runtime/src/containerRuntime.ts

@@ -255,7 +255,6 @@ import {
 	idCompressorBlobName,
 	metadataBlobName,
 	rootHasIsolatedChannels,
-	summarizerClientType,
 	wrapSummaryInChannelsTree,
 	formCreateSummarizerFn,
 	summarizerRequestUrl,
@@ -267,6 +266,7 @@ import {
 	ISummaryConfiguration,
 	DefaultSummaryConfiguration,
 	isSummariesDisabled,
+	summarizerClientType,
 } from "./summary/index.js";
 import { Throttler, formExponentialFn } from "./throttler.js";
 
@@ -1119,6 +1119,10 @@ export class ContainerRuntime
 		return this._getAttachState();
 	}
 
+	public get readonly(): boolean {
+		return this.deltaManager.readOnlyInfo.readonly === true;
+	}
+
 	/**
 	 * Current session schema - defines what options are on & off.
 	 * It's overlap of document schema (controlled by summary & ops) and options controlling this session.
@@ -1733,6 +1737,7 @@ export class ContainerRuntime
 			new Map<string, string>(dataStoreAliasMap),
 			async (runtime: ChannelCollection) => provideEntryPoint,
 		);
+		this._deltaManager.on("readonly", (readonly) => this.setReadOnlyState(readonly));
 
 		this.blobManager = new BlobManager({
 			routeContext: this.handleContext,
@@ -2574,6 +2579,10 @@ export class ContainerRuntime
 		return this._loadIdCompressor;
 	}
 
+	public setReadOnlyState(readonly: boolean): void {
+		this.channelCollection.setReadOnlyState(readonly);
+	}
+
 	public setConnectionState(connected: boolean, clientId?: string): void {
 		// Validate we have consistent state
 		const currentClientId = this._audience.getSelf()?.clientId;

packages/runtime/container-runtime/src/dataStoreContext.ts

@@ -5,11 +5,17 @@
 
 import { TypedEventEmitter, type ILayerCompatDetails } from "@fluid-internal/client-utils";
 import { AttachState, IAudience } from "@fluidframework/container-definitions";
-import { IDeltaManager } from "@fluidframework/container-definitions/internal";
+import {
+	IDeltaManager,
+	isIDeltaManagerFull,
+	type IDeltaManagerFull,
+	type ReadOnlyInfo,
+} from "@fluidframework/container-definitions/internal";
 import {
 	FluidObject,
 	IDisposable,
 	ITelemetryBaseProperties,
+	type IErrorBase,
 	type IEvent,
 } from "@fluidframework/core-interfaces";
 import {
@@ -75,6 +81,7 @@ import {
 	tagCodeArtifacts,
 } from "@fluidframework/telemetry-utils/internal";
 
+import { BaseDeltaManagerProxy } from "./deltaManagerProxies.js";
 import {
 	runtimeCompatDetailsForDataStore,
 	validateDatastoreCompatibility,
@@ -188,6 +195,50 @@ export interface IFluidDataStoreContextEvents extends IEvent {
 	(event: "attaching" | "attached", listener: () => void);
 }
 
+/**
+ * Eventually we should remove the delta manger from being exposed to Datastore runtimes via the context. However to remove that exposure we need to add new
+ * features, and those features themselves need forward and back compat. This proxy is here to enable that back compat. Each feature this proxy is used to
+ * support should be listed below, and as layer compat support goes away for those feature, we should also remove them from this proxy, with the eventual goal
+ * of completely remove this proxy.
+ *
+ * - Everything regarding readonly is to support older datastore runtimes which do not have the setReadonly function, so must get their readonly state via the delta manager.
+ *
+ */
+class ContextDeltaManagerProxy extends BaseDeltaManagerProxy {
+	constructor(base: IDeltaManagerFull) {
+		super(base, {
+			onReadonly: (readonly, reason): void => this.setReadonly(readonly, reason),
+		});
+		this._readonly = base.readOnlyInfo.readonly;
+	}
+
+	public get readOnlyInfo(): ReadOnlyInfo {
+		if (this._readonly === this.deltaManager.readOnlyInfo.readonly) {
+			return this.deltaManager.readOnlyInfo;
+		} else {
+			return this._readonly === true
+				? {
+						readonly: true,
+						forced: false,
+						permissions: undefined,
+						storageOnly: false,
+					}
+				: { readonly: this._readonly };
+		}
+	}
+
+	private _readonly: boolean | undefined;
+	public setReadonly(
+		readonly: boolean,
+		readonlyConnectionReason?: { reason: string; error?: IErrorBase },
+	): void {
+		if (this._readonly !== readonly) {
+			this._readonly = readonly;
+			this.emit("readonly", readonly, readonlyConnectionReason);
+		}
+	}
+}
+
 /**
  * Represents the context for the store. This context is passed to the store runtime.
  * @internal
@@ -217,8 +268,13 @@ export abstract class FluidDataStoreContext
 		return this.parentContext.baseLogger;
 	}
 
+	private readonly _deltaManager: ContextDeltaManagerProxy;
 	public get deltaManager(): IDeltaManager<ISequencedDocumentMessage, IDocumentMessage> {
-		return this.parentContext.deltaManager;
+		return this._deltaManager;
+	}
+
+	public get readonly(): boolean | undefined {
+		return this.parentContext.readonly;
 	}
 
 	public get connected(): boolean {
@@ -420,6 +476,10 @@ export abstract class FluidDataStoreContext
 		// By default, a data store can log maximum 10 local changes telemetry in summarizer.
 		this.localChangesTelemetryCount =
 			this.mc.config.getNumber("Fluid.Telemetry.LocalChangesTelemetryCount") ?? 10;
+
+		assert(isIDeltaManagerFull(this.parentContext.deltaManager), "Invalid delta manager");
+
+		this._deltaManager = new ContextDeltaManagerProxy(this.parentContext.deltaManager);
 	}
 
 	public dispose(): void {
@@ -615,6 +675,13 @@ export abstract class FluidDataStoreContext
 		this.channel!.setConnectionState(connected, clientId);
 	}
 
+	public setReadOnlyState(readonly: boolean): void {
+		this.verifyNotClosed("setReadOnlyState", false /* checkTombstone */);
+
+		this.channel?.setReadOnlyState?.(readonly);
+		this._deltaManager.setReadonly(readonly);
+	}
+
 	/**
 	 * Process messages for this data store. The messages here are contiguous messages for this data store in a batch.
 	 * @param messageCollection - The collection of messages to process.

packages/runtime/container-runtime/src/runtimeLayerCompatState.ts

@@ -9,7 +9,10 @@ import {
 	type ILayerCompatSupportRequirements,
 } from "@fluid-internal/client-utils";
 import type { ICriticalContainerError } from "@fluidframework/container-definitions";
-import { encodeHandlesInContainerRuntime } from "@fluidframework/runtime-definitions/internal";
+import {
+	encodeHandlesInContainerRuntime,
+	setReadonly,
+} from "@fluidframework/runtime-definitions/internal";
 import { UsageError } from "@fluidframework/telemetry-utils/internal";
 
 import { pkgVersion } from "./packageVersion.js";
@@ -66,7 +69,7 @@ export const runtimeCompatDetailsForDataStore: ILayerCompatDetails = {
 	/**
 	 * The features supported by the Runtime layer across the Runtime / DataStore boundary.
 	 */
-	supportedFeatures: new Set<string>([encodeHandlesInContainerRuntime]),
+	supportedFeatures: new Set<string>([encodeHandlesInContainerRuntime, setReadonly]),
 };
 
 /**

packages/runtime/container-runtime/src/test/createChildDataStoreSync.spec.ts

@@ -18,7 +18,10 @@ import {
 	type ISummarizerNodeWithGC,
 } from "@fluidframework/runtime-definitions/internal";
 import { isFluidError } from "@fluidframework/telemetry-utils/internal";
-import { MockFluidDataStoreRuntime } from "@fluidframework/test-runtime-utils/internal";
+import {
+	MockDeltaManager,
+	MockFluidDataStoreRuntime,
+} from "@fluidframework/test-runtime-utils/internal";
 
 import {
 	FluidDataStoreContext,
@@ -89,6 +92,7 @@ describe("createChildDataStore", () => {
 					});
 				},
 			} satisfies Partial<IContainerRuntimeBase> as unknown as IContainerRuntimeBase,
+			deltaManager: new MockDeltaManager(),
 		} satisfies Partial<IFluidParentContext> as unknown as IFluidParentContext;
 
 		const context = new testContext(

packages/runtime/container-runtime/src/test/dataStoreContext.spec.ts

@@ -47,6 +47,7 @@ import {
 	isFluidError,
 } from "@fluidframework/telemetry-utils/internal";
 import {
+	MockDeltaManager,
 	MockFluidDataStoreRuntime,
 	validateAssertionError,
 } from "@fluidframework/test-runtime-utils/internal";
@@ -245,6 +246,7 @@ describe("Data Store Context Tests", () => {
 				parentContext = {
 					IFluidDataStoreRegistry: registryWithSubRegistries,
 					clientDetails: {} as unknown as IFluidParentContext["clientDetails"],
+					deltaManager: new MockDeltaManager(),
 				} satisfies Partial<IFluidParentContext> as unknown as IFluidParentContext;
 				localDataStoreContext = new LocalFluidDataStoreContext({
 					id: dataStoreId,
@@ -541,6 +543,7 @@ describe("Data Store Context Tests", () => {
 				IFluidDataStoreRegistry: registry,
 				clientDetails: {} as unknown as IFluidParentContext["clientDetails"],
 				containerRuntime: parentContext as unknown as IContainerRuntimeBase,
+				deltaManager: new MockDeltaManager(),
 			} satisfies Partial<IFluidParentContext> as unknown as IFluidParentContext;
 		});
 
@@ -1036,6 +1039,7 @@ describe("Data Store Context Tests", () => {
 				IFluidDataStoreRegistry: registry,
 				baseLogger: createChildLogger(),
 				clientDetails: {} as unknown as IFluidParentContext["clientDetails"],
+				deltaManager: new MockDeltaManager(),
 			} satisfies Partial<IFluidParentContext> as unknown as IFluidParentContext;
 		});
 

packages/runtime/container-runtime/src/test/dataStoreCreation.spec.ts

@@ -19,7 +19,10 @@ import {
 	SummarizeInternalFn,
 } from "@fluidframework/runtime-definitions/internal";
 import { createChildLogger } from "@fluidframework/telemetry-utils/internal";
-import { MockFluidDataStoreRuntime } from "@fluidframework/test-runtime-utils/internal";
+import {
+	MockDeltaManager,
+	MockFluidDataStoreRuntime,
+} from "@fluidframework/test-runtime-utils/internal";
 
 import { LocalFluidDataStoreContext } from "../dataStoreContext.js";
 import { createRootSummarizerNodeWithGC } from "../summary/index.js";
@@ -111,6 +114,7 @@ describe("Data Store Creation Tests", () => {
 				IFluidDataStoreRegistry: globalRegistry,
 				baseLogger: createChildLogger(),
 				clientDetails: {} as unknown as IFluidParentContext["clientDetails"],
+				deltaManager: new MockDeltaManager(),
 			} satisfies Partial<IFluidParentContext> as unknown as IFluidParentContext;
 			const summarizerNode = createRootSummarizerNodeWithGC(
 				createChildLogger(),

packages/runtime/container-runtime/src/test/dataStoreCreationHelper.ts

@@ -18,7 +18,10 @@ import {
 	type SummarizeInternalFn,
 } from "@fluidframework/runtime-definitions/internal";
 import { createChildLogger } from "@fluidframework/telemetry-utils/internal";
-import { MockFluidDataStoreRuntime } from "@fluidframework/test-runtime-utils/internal";
+import {
+	MockDeltaManager,
+	MockFluidDataStoreRuntime,
+} from "@fluidframework/test-runtime-utils/internal";
 
 import {
 	LocalFluidDataStoreContext,
@@ -58,6 +61,7 @@ export function createParentContext(
 		baseLogger: logger,
 		clientDetails,
 		submitMessage: () => {},
+		deltaManager: new MockDeltaManager(),
 	} satisfies Partial<IFluidParentContext> as unknown as IFluidParentContext;
 }
 

packages/runtime/datastore-definitions/api-report/datastore-definitions.legacy.alpha.api.md

@@ -98,6 +98,8 @@ export interface IFluidDataStoreRuntime extends IEventProvider<IFluidDataStoreRu
     // (undocumented)
     readonly options: Record<string | number, any>;
     // (undocumented)
+    readonly readonly: boolean;
+    // (undocumented)
     readonly rootRoutingContext: IFluidHandleContext;
     submitSignal: (type: string, content: unknown, targetClientId?: string) => void;
     uploadBlob(blob: ArrayBufferLike, signal?: AbortSignal): Promise<IFluidHandle<ArrayBufferLike>>;
@@ -120,6 +122,8 @@ export interface IFluidDataStoreRuntimeEvents extends IEvent {
     (event: "signal", listener: (message: IInboundSignalMessage, local: boolean) => void): any;
     // (undocumented)
     (event: "connected", listener: (clientId: string) => void): any;
+    // (undocumented)
+    (event: "readonly", listener: (isReadOnly: boolean) => void): any;
 }
 
 // @alpha (undocumented)

packages/runtime/datastore-definitions/src/dataStoreRuntime.ts

@@ -34,6 +34,7 @@ export interface IFluidDataStoreRuntimeEvents extends IEvent {
 	(event: "op", listener: (message: ISequencedDocumentMessage) => void);
 	(event: "signal", listener: (message: IInboundSignalMessage, local: boolean) => void);
 	(event: "connected", listener: (clientId: string) => void);
+	(event: "readonly", listener: (isReadOnly: boolean) => void);
 }
 
 /**
@@ -69,6 +70,8 @@ export interface IFluidDataStoreRuntime
 
 	readonly connected: boolean;
 
+	readonly readonly: boolean;
+
 	readonly logger: ITelemetryBaseLogger;
 
 	/**

packages/runtime/datastore/api-report/datastore.legacy.alpha.api.md

@@ -75,6 +75,8 @@ export class FluidDataStoreRuntime extends TypedEventEmitter<IFluidDataStoreRunt
     // (undocumented)
     processSignal(message: IInboundSignalMessage, local: boolean): void;
     // (undocumented)
+    get readonly(): boolean;
+    // (undocumented)
     request(request: IRequest): Promise<IResponse>;
     // (undocumented)
     resolveHandle(request: IRequest): Promise<IResponse>;
@@ -89,6 +91,8 @@ export class FluidDataStoreRuntime extends TypedEventEmitter<IFluidDataStoreRunt
     // (undocumented)
     setConnectionState(connected: boolean, clientId?: string): void;
     // (undocumented)
+    setReadOnlyState(readonly: boolean): void;
+    // (undocumented)
     submitMessage(type: DataStoreMessageType, content: any, localOpMetadata: unknown): void;
     submitSignal(type: string, content: unknown, targetClientId?: string): void;
     summarize(fullTree?: boolean, trackState?: boolean, telemetryContext?: ITelemetryContext): Promise<ISummaryTreeWithStats>;