Spaces:
Sleeping
Sleeping
// 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 { Data } from '../data.js'; | |
import { Field } from '../schema.js'; | |
import { Struct, TypeMap } from '../type.js'; | |
import { valueToString } from '../util/pretty.js'; | |
import { instance as getVisitor } from '../visitor/get.js'; | |
import { instance as setVisitor } from '../visitor/set.js'; | |
/** @ignore */ const kParent = Symbol.for('parent'); | |
/** @ignore */ const kRowIndex = Symbol.for('rowIndex'); | |
export type StructRowProxy<T extends TypeMap = any> = StructRow<T> & { | |
[P in keyof T]: T[P]['TValue']; | |
} & { | |
[key: symbol]: any; | |
}; | |
export class StructRow<T extends TypeMap = any> { | |
declare private [kRowIndex]: number; | |
declare private [kParent]: Data<Struct<T>>; | |
constructor(parent: Data<Struct<T>>, rowIndex: number) { | |
this[kParent] = parent; | |
this[kRowIndex] = rowIndex; | |
return new Proxy(this, new StructRowProxyHandler()); | |
} | |
public toArray() { return Object.values(this.toJSON()); } | |
public toJSON() { | |
const i = this[kRowIndex]; | |
const parent = this[kParent]; | |
const keys = parent.type.children; | |
const json = {} as { [P in string & keyof T]: T[P]['TValue'] }; | |
for (let j = -1, n = keys.length; ++j < n;) { | |
json[keys[j].name as string & keyof T] = getVisitor.visit(parent.children[j], i); | |
} | |
return json; | |
} | |
public toString() { | |
return `{${[...this].map(([key, val]) => | |
`${valueToString(key)}: ${valueToString(val)}` | |
).join(', ') | |
}}`; | |
} | |
public [Symbol.for('nodejs.util.inspect.custom')]() { | |
return this.toString(); | |
} | |
[Symbol.iterator](): IterableIterator<[ | |
keyof T, { [P in keyof T]: T[P]['TValue'] | null }[keyof T] | |
]> { | |
return new StructRowIterator(this[kParent], this[kRowIndex]); | |
} | |
} | |
class StructRowIterator<T extends TypeMap = any> | |
implements IterableIterator<[ | |
keyof T, { [P in keyof T]: T[P]['TValue'] | null }[keyof T] | |
]> { | |
declare private rowIndex: number; | |
declare private childIndex: number; | |
declare private numChildren: number; | |
declare private children: Data<any>[]; | |
declare private childFields: Field<T[keyof T]>[]; | |
constructor(data: Data<Struct<T>>, rowIndex: number) { | |
this.childIndex = 0; | |
this.children = data.children; | |
this.rowIndex = rowIndex; | |
this.childFields = data.type.children; | |
this.numChildren = this.childFields.length; | |
} | |
[Symbol.iterator]() { return this; } | |
next() { | |
const i = this.childIndex; | |
if (i < this.numChildren) { | |
this.childIndex = i + 1; | |
return { | |
done: false, | |
value: [ | |
this.childFields[i].name, | |
getVisitor.visit(this.children[i], this.rowIndex) | |
] | |
} as IteratorYieldResult<[any, any]>; | |
} | |
return { done: true, value: null } as IteratorReturnResult<null>; | |
} | |
} | |
Object.defineProperties(StructRow.prototype, { | |
[Symbol.toStringTag]: { enumerable: false, configurable: false, value: 'Row' }, | |
[kParent]: { writable: true, enumerable: false, configurable: false, value: null }, | |
[kRowIndex]: { writable: true, enumerable: false, configurable: false, value: -1 }, | |
}); | |
class StructRowProxyHandler<T extends TypeMap = any> implements ProxyHandler<StructRow<T>> { | |
isExtensible() { return false; } | |
deleteProperty() { return false; } | |
preventExtensions() { return true; } | |
ownKeys(row: StructRow<T>) { | |
return row[kParent].type.children.map((f) => f.name); | |
} | |
has(row: StructRow<T>, key: string) { | |
return row[kParent].type.children.findIndex((f) => f.name === key) !== -1; | |
} | |
getOwnPropertyDescriptor(row: StructRow<T>, key: string) { | |
if (row[kParent].type.children.findIndex((f) => f.name === key) !== -1) { | |
return { writable: true, enumerable: true, configurable: true }; | |
} | |
return; | |
} | |
get(row: StructRow<T>, key: string) { | |
// Look up key in row first | |
if (Reflect.has(row, key)) { | |
return (row as any)[key]; | |
} | |
const idx = row[kParent].type.children.findIndex((f) => f.name === key); | |
if (idx !== -1) { | |
const val = getVisitor.visit(row[kParent].children[idx], row[kRowIndex]); | |
// Cache key/val lookups | |
Reflect.set(row, key, val); | |
return val; | |
} | |
} | |
set(row: StructRow<T>, key: string, val: any) { | |
const idx = row[kParent].type.children.findIndex((f) => f.name === key); | |
if (idx !== -1) { | |
setVisitor.visit(row[kParent].children[idx], row[kRowIndex], val); | |
// Cache key/val lookups | |
return Reflect.set(row, key, val); | |
} else if (Reflect.has(row, key) || typeof key === 'symbol') { | |
return Reflect.set(row, key, val); | |
} | |
return false; | |
} | |
} | |