Function applyVersionedAck

cli/src/api/versionedUpdate.ts:23–65

(
    ack: unknown,
    options: VersionedAckOptions<TValue, ValueKey>
)

}

export const applyVersionedAck = <TValue, ValueKey extends string>(
    ack: unknown,
    options: VersionedAckOptions<TValue, ValueKey>
): void => {
    if (!isRecord(ack)) {
        throw new Error(options.invalidResponseMessage)
    }

    const result = ack.result
    if (result === 'success' || result === 'version-mismatch') {
        const version = ack.version
        if (typeof version !== 'number') {
            throw new Error(options.invalidResponseMessage)
        }

        const rawValue = ack[options.valueKey]
        if (rawValue == null) {
            options.applyValue(null)
        } else {
            const parsed = options.parseValue(rawValue)
            if (parsed === null) {
                options.logInvalidValue(result, version)
            } else {
                options.applyValue(parsed)
            }
        }

        options.applyVersion(version)

        if (result === 'version-mismatch') {
            throw new Error(options.versionMismatchMessage)
        }

        return
    }

    if (result === 'error') {
        const reason = typeof ack.reason === 'string' ? ack.reason : 'unknown'
        throw new Error(`${options.errorMessage} (${reason})`)
    }

    throw new Error(options.invalidResponseMessage)
}