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

@fluidframework/container-loader

Package Overview
Dependencies
Maintainers
0
Versions
586
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@fluidframework/container-loader - npm Package Compare versions

Comparing version 2.10.0-304831 to 2.10.0-305357

4

dist/deltaManager.d.ts

@@ -6,3 +6,3 @@ /*!

import { ICriticalContainerError } from "@fluidframework/container-definitions";
import { IDeltaManager, IDeltaManagerEvents, IDeltaQueue, type IDeltaSender, type ReadOnlyInfo } from "@fluidframework/container-definitions/internal";
import { IDeltaManagerEvents, IDeltaManagerFull, IDeltaQueue, type IDeltaSender, type ReadOnlyInfo } from "@fluidframework/container-definitions/internal";
import { IEventProvider, ITelemetryBaseProperties } from "@fluidframework/core-interfaces";

@@ -47,3 +47,3 @@ import { IThrottlingWarning } from "@fluidframework/core-interfaces/internal";

*/
export declare class DeltaManager<TConnectionManager extends IConnectionManager> extends EventEmitterWithErrorHandling<IDeltaManagerInternalEvents> implements IDeltaManager<ISequencedDocumentMessage, IDocumentMessage>, IEventProvider<IDeltaManagerInternalEvents> {
export declare class DeltaManager<TConnectionManager extends IConnectionManager> extends EventEmitterWithErrorHandling<IDeltaManagerInternalEvents> implements IDeltaManagerFull, IEventProvider<IDeltaManagerInternalEvents> {
private readonly serviceProvider;

@@ -50,0 +50,0 @@ private readonly logger;

@@ -11,4 +11,4 @@ /*!

export { IProtocolHandler, ProtocolHandlerBuilder } from "./protocol.js";
export { tryParseCompatibleResolvedUrl, IParsedUrl } from "./utils.js";
export { tryParseCompatibleResolvedUrl, IParsedUrl, } from "./utils.js";
export { IBaseProtocolHandler, IScribeProtocolState, IQuorumSnapshot, QuorumClientsSnapshot, QuorumProposalsSnapshot, } from "./protocol/index.js";
//# sourceMappingURL=index.d.ts.map

@@ -9,3 +9,4 @@ "use strict";

const internal_1 = require("@fluidframework/container-definitions/internal");
const internal_2 = require("@fluidframework/telemetry-utils/internal");
const internal_2 = require("@fluidframework/core-utils/internal");
const internal_3 = require("@fluidframework/telemetry-utils/internal");
/* eslint-disable jsdoc/check-indentation */

@@ -53,2 +54,3 @@ /**

const pauseContainer = () => {
(0, internal_2.assert)((0, internal_1.isIDeltaManagerFull)(dm), "Delta manager does not have inbound/outbound queues.");
// eslint-disable-next-line no-void

@@ -68,3 +70,3 @@ void dm.inbound.pause();

if (lastProcessedSequenceNumber > loadToSequenceNumber) {
const error = new internal_2.GenericError("Cannot satisfy request to pause the container at the specified sequence number. Most recent snapshot is newer than the specified sequence number.");
const error = new internal_3.GenericError("Cannot satisfy request to pause the container at the specified sequence number. Most recent snapshot is newer than the specified sequence number.");
container.close(error);

@@ -77,3 +79,3 @@ throw error;

const promise = new Promise((resolve, reject) => {
onAbort = () => reject(new internal_2.GenericError("Canceled due to cancellation request."));
onAbort = () => reject(new internal_3.GenericError("Canceled due to cancellation request."));
onClose = (error) => reject(error);

@@ -80,0 +82,0 @@ // We need to setup a listener to stop op processing once we reach the desired sequence number (if specified).

@@ -8,3 +8,3 @@ /*!

export declare const pkgName = "@fluidframework/container-loader";
export declare const pkgVersion = "2.10.0-304831";
export declare const pkgVersion = "2.10.0-305357";
//# sourceMappingURL=packageVersion.d.ts.map

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

exports.pkgName = "@fluidframework/container-loader";
exports.pkgVersion = "2.10.0-304831";
exports.pkgVersion = "2.10.0-305357";
//# sourceMappingURL=packageVersion.js.map

@@ -6,3 +6,3 @@ /*!

import { ICriticalContainerError } from "@fluidframework/container-definitions";
import { IDeltaManager, IDeltaManagerEvents, IDeltaQueue, type IDeltaSender, type ReadOnlyInfo } from "@fluidframework/container-definitions/internal";
import { IDeltaManagerEvents, IDeltaManagerFull, IDeltaQueue, type IDeltaSender, type ReadOnlyInfo } from "@fluidframework/container-definitions/internal";
import { IEventProvider, ITelemetryBaseProperties } from "@fluidframework/core-interfaces";

@@ -47,3 +47,3 @@ import { IThrottlingWarning } from "@fluidframework/core-interfaces/internal";

*/
export declare class DeltaManager<TConnectionManager extends IConnectionManager> extends EventEmitterWithErrorHandling<IDeltaManagerInternalEvents> implements IDeltaManager<ISequencedDocumentMessage, IDocumentMessage>, IEventProvider<IDeltaManagerInternalEvents> {
export declare class DeltaManager<TConnectionManager extends IConnectionManager> extends EventEmitterWithErrorHandling<IDeltaManagerInternalEvents> implements IDeltaManagerFull, IEventProvider<IDeltaManagerInternalEvents> {
private readonly serviceProvider;

@@ -50,0 +50,0 @@ private readonly logger;

@@ -11,4 +11,4 @@ /*!

export { IProtocolHandler, ProtocolHandlerBuilder } from "./protocol.js";
export { tryParseCompatibleResolvedUrl, IParsedUrl } from "./utils.js";
export { tryParseCompatibleResolvedUrl, IParsedUrl, } from "./utils.js";
export { IBaseProtocolHandler, IScribeProtocolState, IQuorumSnapshot, QuorumClientsSnapshot, QuorumProposalsSnapshot, } from "./protocol/index.js";
//# sourceMappingURL=index.d.ts.map

@@ -10,3 +10,3 @@ /*!

export { isLocationRedirectionError, resolveWithLocationRedirectionHandling, } from "./location-redirection-utilities/index.js";
export { tryParseCompatibleResolvedUrl } from "./utils.js";
export { tryParseCompatibleResolvedUrl, } from "./utils.js";
//# sourceMappingURL=index.js.map

@@ -5,3 +5,4 @@ /*!

*/
import { LoaderHeader, } from "@fluidframework/container-definitions/internal";
import { isIDeltaManagerFull, LoaderHeader, } from "@fluidframework/container-definitions/internal";
import { assert } from "@fluidframework/core-utils/internal";
import { GenericError } from "@fluidframework/telemetry-utils/internal";

@@ -50,2 +51,3 @@ /* eslint-disable jsdoc/check-indentation */

const pauseContainer = () => {
assert(isIDeltaManagerFull(dm), "Delta manager does not have inbound/outbound queues.");
// eslint-disable-next-line no-void

@@ -52,0 +54,0 @@ void dm.inbound.pause();

@@ -8,3 +8,3 @@ /*!

export declare const pkgName = "@fluidframework/container-loader";
export declare const pkgVersion = "2.10.0-304831";
export declare const pkgVersion = "2.10.0-305357";
//# sourceMappingURL=packageVersion.d.ts.map

@@ -8,3 +8,3 @@ /*!

export const pkgName = "@fluidframework/container-loader";
export const pkgVersion = "2.10.0-304831";
export const pkgVersion = "2.10.0-305357";
//# sourceMappingURL=packageVersion.js.map
{
"name": "@fluidframework/container-loader",
"version": "2.10.0-304831",
"version": "2.10.0-305357",
"description": "Fluid container loader",

@@ -122,9 +122,9 @@ "homepage": "https://fluidframework.com",

"dependencies": {
"@fluid-internal/client-utils": "2.10.0-304831",
"@fluidframework/container-definitions": "2.10.0-304831",
"@fluidframework/core-interfaces": "2.10.0-304831",
"@fluidframework/core-utils": "2.10.0-304831",
"@fluidframework/driver-definitions": "2.10.0-304831",
"@fluidframework/driver-utils": "2.10.0-304831",
"@fluidframework/telemetry-utils": "2.10.0-304831",
"@fluid-internal/client-utils": "2.10.0-305357",
"@fluidframework/container-definitions": "2.10.0-305357",
"@fluidframework/core-interfaces": "2.10.0-305357",
"@fluidframework/core-utils": "2.10.0-305357",
"@fluidframework/driver-definitions": "2.10.0-305357",
"@fluidframework/driver-utils": "2.10.0-305357",
"@fluidframework/telemetry-utils": "2.10.0-305357",
"@types/events_pkg": "npm:@types/events@^3.0.0",

@@ -140,5 +140,5 @@ "@ungap/structured-clone": "^1.2.0",

"@biomejs/biome": "~1.9.3",
"@fluid-internal/client-utils": "2.10.0-304831",
"@fluid-internal/mocha-test-setup": "2.10.0-304831",
"@fluid-private/test-loader-utils": "2.10.0-304831",
"@fluid-internal/client-utils": "2.10.0-305357",
"@fluid-internal/mocha-test-setup": "2.10.0-305357",
"@fluid-private/test-loader-utils": "2.10.0-305357",
"@fluid-tools/build-cli": "^0.50.0",

@@ -171,3 +171,7 @@ "@fluidframework/build-common": "^2.0.3",

"typeValidation": {
"broken": {},
"broken": {
"Interface_IContainerExperimental": {
"backCompat": false
}
},
"entrypoint": "legacy"

@@ -174,0 +178,0 @@ },

@@ -8,4 +8,4 @@ /*!

import {
IDeltaManager,
IDeltaManagerEvents,
IDeltaManagerFull,
IDeltaQueue,

@@ -155,5 +155,3 @@ type IDeltaSender,

extends EventEmitterWithErrorHandling<IDeltaManagerInternalEvents>
implements
IDeltaManager<ISequencedDocumentMessage, IDocumentMessage>,
IEventProvider<IDeltaManagerInternalEvents>
implements IDeltaManagerFull, IEventProvider<IDeltaManagerInternalEvents>
{

@@ -160,0 +158,0 @@ public readonly connectionManager: TConnectionManager;

@@ -23,4 +23,7 @@ /*!

export { IProtocolHandler, ProtocolHandlerBuilder } from "./protocol.js";
export { tryParseCompatibleResolvedUrl, IParsedUrl } from "./utils.js";
export {
tryParseCompatibleResolvedUrl,
IParsedUrl,
} from "./utils.js";
export {
IBaseProtocolHandler,

@@ -27,0 +30,0 @@ IScribeProtocolState,

@@ -8,2 +8,3 @@ /*!

ILoader,
isIDeltaManagerFull,
LoaderHeader,

@@ -14,2 +15,3 @@ type IContainer,

import type { IErrorBase } from "@fluidframework/core-interfaces";
import { assert } from "@fluidframework/core-utils/internal";
import { GenericError } from "@fluidframework/telemetry-utils/internal";

@@ -68,2 +70,3 @@

const pauseContainer = (): void => {
assert(isIDeltaManagerFull(dm), "Delta manager does not have inbound/outbound queues.");
// eslint-disable-next-line no-void

@@ -70,0 +73,0 @@ void dm.inbound.pause();

@@ -9,2 +9,2 @@ /*!

export const pkgName = "@fluidframework/container-loader";
export const pkgVersion = "2.10.0-304831";
export const pkgVersion = "2.10.0-305357";

Sorry, the diff of this file is too big to display

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 too big to display

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 too big to display

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