3 Commits
0.5.1 ... 0.5.2

Author SHA1 Message Date
22cf6aa953 bump version
Some checks failed
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
continuous-integration/drone Build is failing
2021-10-18 13:41:22 -05:00
b35eb8d6a1 Fix error throw
All checks were successful
continuous-integration/drone/push Build is passing
2021-10-18 13:36:59 -05:00
9ee4c42e43 Error type fixes
Some checks failed
continuous-integration/drone/push Build is failing
2021-10-18 13:03:28 -05:00
8 changed files with 50 additions and 21 deletions

View File

@@ -1,6 +1,6 @@
{
"name": "@extollo/lib",
"version": "0.5.1",
"version": "0.5.2",
"description": "The framework library that lifts up your code.",
"main": "lib/index.js",
"types": "lib/index.d.ts",

View File

@@ -169,8 +169,11 @@ export abstract class Directive extends AppClass {
const optionValues = this.parseOptions(options, argv)
this.setOptionValues(optionValues)
await this.handle(argv)
} catch (e) {
this.nativeOutput(e.message)
} catch (e: unknown) {
if ( e instanceof Error ) {
this.nativeOutput(e.message)
}
if ( e instanceof OptionValidationError ) {
// expecting, value, requirements
if ( e.context.expecting ) {
@@ -187,6 +190,7 @@ export abstract class Directive extends AppClass {
this.nativeOutput(` - ${e.context.value}`)
}
}
this.nativeOutput('\nUse --help for more info.')
}
}

View File

@@ -259,8 +259,12 @@ export class Application extends Container {
try {
await this.up()
await this.down()
} catch (e) {
this.errorHandler(e)
} catch (e: unknown) {
if ( e instanceof Error ) {
this.errorHandler(e)
}
throw e
}
}
@@ -306,9 +310,14 @@ export class Application extends Container {
await unit.up()
unit.status = UnitStatus.Started
logging.info(`Started ${unit.constructor.name}.`)
} catch (e) {
} catch (e: unknown) {
unit.status = UnitStatus.Error
throw this.errorWrapContext(e, {unitName: unit.constructor.name})
if ( e instanceof Error ) {
throw this.errorWrapContext(e, {unitName: unit.constructor.name})
}
throw e
}
}
@@ -327,7 +336,12 @@ export class Application extends Container {
logging.info(`Stopped ${unit.constructor.name}.`)
} catch (e) {
unit.status = UnitStatus.Error
throw this.errorWrapContext(e, {unitName: unit.constructor.name})
if ( e instanceof Error ) {
throw this.errorWrapContext(e, {unitName: unit.constructor.name})
}
throw e
}
}
}

View File

@@ -79,10 +79,13 @@ ${contextDisplay}
}
this.logging.error(errorString, true)
} catch (displayError) {
// The error display encountered an error...
// just throw the original so it makes it out
console.error('RunLevelErrorHandler encountered an error:', displayError.message) // eslint-disable-line no-console
} catch (displayError: unknown) {
if ( displayError instanceof Error ) {
// The error display encountered an error...
// just throw the original so it makes it out
console.error('RunLevelErrorHandler encountered an error:', displayError.message) // eslint-disable-line no-console
}
throw operativeError
}
}

View File

@@ -63,10 +63,14 @@ export class PostgresConnection extends Connection {
rowCount: result.rowCount,
}
} catch (e) {
throw this.app().errorWrapContext(e, {
query,
connection: this.name,
})
if ( e instanceof Error ) {
throw this.app().errorWrapContext(e, {
query,
connection: this.name,
})
}
throw e
}
}

View File

@@ -1,5 +1,5 @@
import {Inject, Singleton} from '../di'
import {HTTPStatus, withTimeout} from '../util'
import {ErrorWithContext, HTTPStatus, withTimeout} from '../util'
import {Unit} from '../lifecycle/Unit'
import {createServer, IncomingMessage, RequestListener, Server, ServerResponse} from 'http'
import {Logging} from './Logging'
@@ -114,7 +114,11 @@ export class HTTPServer extends Unit {
try {
await this.kernel.handle(extolloReq)
} catch (e) {
await error(e).write(extolloReq)
if ( e instanceof Error ) {
await error(e).write(extolloReq)
}
await error(new ErrorWithContext('Unknown error occurred.', { e }))
}
await extolloReq.response.send()

View File

@@ -137,7 +137,7 @@ export class BehaviorSubject<T> {
} catch (e) {
if ( e instanceof UnsubscribeError ) {
this.subscribers = this.subscribers.filter(x => x !== subscriber)
} else if (subscriber.error) {
} else if (subscriber.error && e instanceof Error) {
await subscriber.error(e)
} else {
throw e
@@ -181,7 +181,7 @@ export class BehaviorSubject<T> {
try {
await subscriber.complete(finalValue)
} catch (e) {
if ( subscriber.error ) {
if ( subscriber.error && e instanceof Error ) {
await subscriber.error(e)
} else {
throw e

View File

@@ -92,7 +92,7 @@ export class LocalFilesystem extends Filesystem {
isFile: stat.isFile(),
}
} catch (e) {
if ( e?.code === 'ENOENT' ) {
if ( (e as any)?.code === 'ENOENT' ) {
return {
path: new UniversalPath(args.storePath, this),
exists: false,