/*!
 * Copyright (c) Microsoft Corporation and contributors. All rights reserved.
 * Licensed under the MIT License.
 */

/* eslint-disable @typescript-eslint/no-non-null-assertion */

import type { IFluidHandle } from "@fluidframework/core-interfaces";
import type { IFluidSerializer } from "@fluidframework/shared-object-base/internal";
import type { TelemetryLoggerExt } from "@fluidframework/telemetry-utils/internal";

import type { SerializedAttributionCollection } from "./attributionCollection.js";
import type { IJSONSegment } from "./ops.js";
import type { PropertySet } from "./properties.js";
import { SnapshotLegacy } from "./snapshotlegacy.js";

export interface VersionedMergeTreeChunk {
	version: undefined | "1";
}

export type JsonSegmentSpecs = IJSONSegment | IJSONSegmentWithMergeInfo;

export interface MergeTreeChunkLegacy extends VersionedMergeTreeChunk {
	version: undefined;
	chunkStartSegmentIndex: number;
	chunkSegmentCount: number;
	chunkLengthChars: number;
	totalLengthChars?: number;
	totalSegmentCount?: number;
	chunkSequenceNumber?: number;
	chunkMinSequenceNumber?: number;
	segmentTexts: JsonSegmentSpecs[];
	headerMetadata?: MergeTreeHeaderMetadata;
	attribution?: SerializedAttributionCollection;
}

export interface MergeTreeHeaderChunkMetadata {
	id: string;
}

export interface MergeTreeHeaderMetadata {
	totalLength: number;
	totalSegmentCount: number;
	orderedChunkMetadata: MergeTreeHeaderChunkMetadata[];
	sequenceNumber: number;
	minSequenceNumber: number;
}

export interface MergeTreeChunkV1 extends VersionedMergeTreeChunk {
	version: "1";
	startIndex: number;
	segmentCount: number;
	length: number;
	segments: JsonSegmentSpecs[];
	headerMetadata: MergeTreeHeaderMetadata | undefined;
	attribution?: SerializedAttributionCollection;
}

/**
 * Used during snapshotting to record the metadata required to merge segments above the MSN
 * to the raw output of `ISegment.toJSONObject()`.  (Note that IJSONSegment may be a raw
 * string or array, which is why this interface wraps the original IJSONSegment instead of
 * extending it.)
 */
export interface IJSONSegmentWithMergeInfo {
	json: IJSONSegment;
	client?: string;
	seq?: number;
	removedClientIds?: string[];
	removedSeq?: number;
	movedClientIds?: string[];
	movedSeq?: number;
	movedSeqs?: number[];
}

/**
 * Returns true if the given 'spec' is an IJSONSegmentWithMergeInfo.
 */
export function hasMergeInfo(
	spec: IJSONSegment | IJSONSegmentWithMergeInfo,
): spec is IJSONSegmentWithMergeInfo {
	return !!spec && typeof spec === "object" && "json" in spec;
}

export function serializeAsMinSupportedVersion(
	path: string,
	chunk: VersionedMergeTreeChunk,
	logger: TelemetryLoggerExt,
	options: PropertySet | undefined,
	serializer: IFluidSerializer,
	bind: IFluidHandle,
): string {
	let targetChuck: MergeTreeChunkLegacy;

	if (chunk.version !== undefined) {
		logger.send({
			eventName: "MergeTreeChunk:serializeAsMinSupportedVersion",
			category: "generic",
			fromChunkVersion: chunk.version,
			toChunkVersion: undefined,
		});
	}

	switch (chunk.version) {
		case undefined: {
			targetChuck = chunk as MergeTreeChunkLegacy;
			targetChuck.headerMetadata = buildHeaderMetadataForLegacyChunk(
				path,
				targetChuck,
				options,
			);
			break;
		}

		case "1": {
			const chunkV1 = chunk as MergeTreeChunkV1;
			const headerMetadata =
				path === SnapshotLegacy.header ? chunkV1.headerMetadata : undefined;
			targetChuck = {
				version: undefined,
				chunkStartSegmentIndex: chunkV1.startIndex,
				chunkLengthChars: chunkV1.length,
				chunkSegmentCount: chunkV1.segmentCount,
				segmentTexts: chunkV1.segments,
				totalLengthChars: headerMetadata?.totalLength,
				totalSegmentCount: headerMetadata?.totalSegmentCount,
				chunkSequenceNumber: headerMetadata?.sequenceNumber,
				chunkMinSequenceNumber: headerMetadata?.minSequenceNumber,
				headerMetadata,
			};
			break;
		}

		default: {
			throw new Error(`Unsupported chunk path: ${path} version: ${chunk.version}`);
		}
	}
	return serializer.stringify(targetChuck, bind);
}

export function serializeAsMaxSupportedVersion(
	path: string,
	chunk: VersionedMergeTreeChunk,
	logger: TelemetryLoggerExt,
	options: PropertySet | undefined,
	serializer: IFluidSerializer,
	bind: IFluidHandle,
): string {
	const targetChuck = toLatestVersion(path, chunk, logger, options);
	return serializer.stringify(targetChuck, bind);
}

export function toLatestVersion(
	path: string,
	chunk: VersionedMergeTreeChunk,
	logger: TelemetryLoggerExt,
	options: PropertySet | undefined,
): MergeTreeChunkV1 {
	switch (chunk.version) {
		case undefined: {
			const chunkLegacy = chunk as MergeTreeChunkLegacy;
			return {
				version: "1",
				length: chunkLegacy.chunkLengthChars,
				segmentCount: chunkLegacy.chunkSegmentCount,
				headerMetadata: buildHeaderMetadataForLegacyChunk(path, chunkLegacy, options),
				segments: chunkLegacy.segmentTexts,
				startIndex: chunkLegacy.chunkStartSegmentIndex,
				attribution: chunkLegacy.attribution,
			};
		}
		case "1": {
			return chunk as MergeTreeChunkV1;
		}

		default: {
			throw new Error(`Unsupported chunk path: ${path} version: ${chunk.version}`);
		}
	}
}

function buildHeaderMetadataForLegacyChunk(
	path: string,
	chunk: MergeTreeChunkLegacy,
	options: PropertySet | undefined,
): MergeTreeHeaderMetadata | undefined {
	if (path === SnapshotLegacy.header) {
		if (chunk.headerMetadata !== undefined) {
			return chunk.headerMetadata;
		}
		const chunkIds: MergeTreeHeaderChunkMetadata[] = [{ id: SnapshotLegacy.header }];
		if (chunk.chunkLengthChars < chunk.totalLengthChars!) {
			chunkIds.push({ id: SnapshotLegacy.body });
		}
		return {
			orderedChunkMetadata: chunkIds,
			minSequenceNumber: chunk.chunkMinSequenceNumber!,
			sequenceNumber: chunk.chunkSequenceNumber!,
			totalLength: chunk.totalLengthChars!,
			totalSegmentCount: chunk.totalSegmentCount!,
		};
	}
	return undefined;
}