Graham/angular-cli
1
0
Fork 0
mirror of https://github.com/angular/angular-cli.git synced 2025-05-20 21:42:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(@angular-devkit/core): cleanup ajv initialization

Browse Source
This commit is contained in:
Charles Lyding 2018-08-08 11:39:38 -04:00 committed by vikerman
parent 7eb080362f
commit 2dcf0b9901
1 changed files with 9 additions and 14 deletions

23
packages/angular_devkit/core/src/json/schema/registry.ts

@ -7,7 +7,7 @@
*/
import * as ajv from 'ajv';
import * as http from 'http';
import { Observable, from, of as observableOf } from 'rxjs';
import { Observable, from, of as observableOf, throwError } from 'rxjs';
import { concatMap, map, switchMap, tap } from 'rxjs/operators';
import { BaseException } from '../../exception/exception';
import { PartiallyOrderedSet, isObservable } from '../../utils';
@ -176,7 +176,7 @@ export class CoreSchemaRegistry implements SchemaRegistry {
validate = (validate.refVal as any)[(validate.refs as any)['#' + refHash]];
}
return { context: validate, schema: validate && validate.schema as JsonObject };
return { context: validate, schema: validate.schema as JsonObject };
}
compile(schema: JsonObject): Observable<SchemaValidator> {
@ -186,23 +186,18 @@ export class CoreSchemaRegistry implements SchemaRegistry {
// in synchronous (if available).
let validator: Observable<ajv.ValidateFunction>;
try {
const maybeFnValidate = this._ajv.compile(schema);
validator = observableOf(maybeFnValidate);
validator = observableOf(this._ajv.compile(schema));
} catch (e) {
// Propagate the error.
if (!(e instanceof (ajv.MissingRefError as {} as Function))) {
throw e;
return throwError(e);
}
validator = new Observable(obs => {
this._ajv.compileAsync(schema)
.then(validate => {
obs.next(validate);
obs.complete();
}, err => {
obs.error(err);
});
});
try {
validator = from(this._ajv.compileAsync(schema));
} catch (e) {
return throwError(e);
}
}
return validator