Spaces:
Running
Running
// Licensed to the Apache Software Foundation (ASF) under one | |
// or more contributor license agreements. See the NOTICE file | |
// distributed with this work for additional information | |
// regarding copyright ownership. The ASF licenses this file | |
// to you under the Apache License, Version 2.0 (the | |
// "License"); you may not use this file except in compliance | |
// with the License. You may obtain a copy of the License at | |
// | |
// http://www.apache.org/licenses/LICENSE-2.0 | |
// | |
// Unless required by applicable law or agreed to in writing, | |
// software distributed under the License is distributed on an | |
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | |
// KIND, either express or implied. See the License for the | |
// specific language governing permissions and limitations | |
// under the License. | |
import { DataType, TypeMap } from './type.js'; | |
export class Schema<T extends TypeMap = any> { | |
public readonly fields: Field<T[keyof T]>[]; | |
public readonly metadata: Map<string, string>; | |
public readonly dictionaries: Map<number, DataType>; | |
constructor( | |
fields: Field<T[keyof T]>[] = [], | |
metadata?: Map<string, string> | null, | |
dictionaries?: Map<number, DataType> | null) { | |
this.fields = (fields || []) as Field<T[keyof T]>[]; | |
this.metadata = metadata || new Map(); | |
if (!dictionaries) { | |
dictionaries = generateDictionaryMap(fields); | |
} | |
this.dictionaries = dictionaries; | |
} | |
public get [Symbol.toStringTag]() { return 'Schema'; } | |
public get names(): (keyof T)[] { return this.fields.map((f) => f.name); } | |
public toString() { | |
return `Schema<{ ${this.fields.map((f, i) => `${i}: ${f}`).join(', ')} }>`; | |
} | |
/** | |
* Construct a new Schema containing only specified fields. | |
* | |
* @param fieldNames Names of fields to keep. | |
* @returns A new Schema of fields matching the specified names. | |
*/ | |
public select<K extends keyof T = any>(fieldNames: K[]) { | |
const names = new Set<string | K>(fieldNames); | |
const fields = this.fields.filter((f) => names.has(f.name)) as Field<T[K]>[]; | |
return new Schema<{ [P in K]: T[P] }>(fields, this.metadata); | |
} | |
/** | |
* Construct a new Schema containing only fields at the specified indices. | |
* | |
* @param fieldIndices Indices of fields to keep. | |
* @returns A new Schema of fields at the specified indices. | |
*/ | |
public selectAt<K extends T = any>(fieldIndices: number[]) { | |
const fields = fieldIndices.map((i) => this.fields[i]).filter(Boolean) as Field<K[keyof K]>[]; | |
return new Schema<K>(fields, this.metadata); | |
} | |
public assign<R extends TypeMap = any>(schema: Schema<R>): Schema<T & R>; | |
public assign<R extends TypeMap = any>(...fields: (Field<R[keyof R]> | Field<R[keyof R]>[])[]): Schema<T & R>; | |
public assign<R extends TypeMap = any>(...args: (Schema<R> | Field<R[keyof R]> | Field<R[keyof R]>[])[]) { | |
const other = (args[0] instanceof Schema | |
? args[0] as Schema<R> | |
: Array.isArray(args[0]) | |
? new Schema<R>(<Field<R[keyof R]>[]>args[0]) | |
: new Schema<R>(<Field<R[keyof R]>[]>args)); | |
const curFields = [...this.fields] as Field[]; | |
const metadata = mergeMaps(mergeMaps(new Map(), this.metadata), other.metadata); | |
const newFields = other.fields.filter((f2) => { | |
const i = curFields.findIndex((f) => f.name === f2.name); | |
return ~i ? (curFields[i] = f2.clone({ | |
metadata: mergeMaps(mergeMaps(new Map(), curFields[i].metadata), f2.metadata) | |
})) && false : true; | |
}) as Field[]; | |
const newDictionaries = generateDictionaryMap(newFields, new Map()); | |
return new Schema<T & R>( | |
[...curFields, ...newFields], metadata, | |
new Map([...this.dictionaries, ...newDictionaries]) | |
); | |
} | |
} | |
// Add these here so they're picked up by the externs creator | |
// in the build, and closure-compiler doesn't minify them away | |
(Schema.prototype as any).fields = <any>null; | |
(Schema.prototype as any).metadata = <any>null; | |
(Schema.prototype as any).dictionaries = <any>null; | |
export class Field<T extends DataType = any> { | |
public static new<T extends DataType = any>(props: { name: string | number; type: T; nullable?: boolean; metadata?: Map<string, string> | null }): Field<T>; | |
public static new<T extends DataType = any>(name: string | number | Field<T>, type: T, nullable?: boolean, metadata?: Map<string, string> | null): Field<T>; | |
/** @nocollapse */ | |
public static new<T extends DataType = any>(...args: any[]) { | |
let [name, type, nullable, metadata] = args; | |
if (args[0] && typeof args[0] === 'object') { | |
({ name } = args[0]); | |
(type === undefined) && (type = args[0].type); | |
(nullable === undefined) && (nullable = args[0].nullable); | |
(metadata === undefined) && (metadata = args[0].metadata); | |
} | |
return new Field<T>(`${name}`, type, nullable, metadata); | |
} | |
public readonly type: T; | |
public readonly name: string; | |
public readonly nullable: boolean; | |
public readonly metadata: Map<string, string>; | |
constructor(name: string, type: T, nullable = false, metadata?: Map<string, string> | null) { | |
this.name = name; | |
this.type = type; | |
this.nullable = nullable; | |
this.metadata = metadata || new Map(); | |
} | |
public get typeId() { return this.type.typeId; } | |
public get [Symbol.toStringTag]() { return 'Field'; } | |
public toString() { return `${this.name}: ${this.type}`; } | |
public clone<R extends DataType = T>(props: { name?: string | number; type?: R; nullable?: boolean; metadata?: Map<string, string> | null }): Field<R>; | |
public clone<R extends DataType = T>(name?: string | number | Field<T>, type?: R, nullable?: boolean, metadata?: Map<string, string> | null): Field<R>; | |
public clone<R extends DataType = T>(...args: any[]) { | |
let [name, type, nullable, metadata] = args; | |
(!args[0] || typeof args[0] !== 'object') | |
? ([name = this.name, type = this.type, nullable = this.nullable, metadata = this.metadata] = args) | |
: ({ name = this.name, type = this.type, nullable = this.nullable, metadata = this.metadata } = args[0]); | |
return Field.new<R>(name, type, nullable, metadata); | |
} | |
} | |
// Add these here so they're picked up by the externs creator | |
// in the build, and closure-compiler doesn't minify them away | |
(Field.prototype as any).type = null; | |
(Field.prototype as any).name = null; | |
(Field.prototype as any).nullable = null; | |
(Field.prototype as any).metadata = null; | |
/** @ignore */ | |
function mergeMaps<TKey, TVal>(m1?: Map<TKey, TVal> | null, m2?: Map<TKey, TVal> | null): Map<TKey, TVal> { | |
return new Map([...(m1 || new Map()), ...(m2 || new Map())]); | |
} | |
/** @ignore */ | |
function generateDictionaryMap(fields: Field[], dictionaries = new Map<number, DataType>()): Map<number, DataType> { | |
for (let i = -1, n = fields.length; ++i < n;) { | |
const field = fields[i]; | |
const type = field.type; | |
if (DataType.isDictionary(type)) { | |
if (!dictionaries.has(type.id)) { | |
dictionaries.set(type.id, type.dictionary); | |
} else if (dictionaries.get(type.id) !== type.dictionary) { | |
throw new Error(`Cannot create Schema containing two different dictionaries with the same Id`); | |
} | |
} | |
if (type.children && type.children.length > 0) { | |
generateDictionaryMap(type.children, dictionaries); | |
} | |
} | |
return dictionaries; | |
} | |