mirror of
https://github.com/sasjs/adapter.git
synced 2026-01-19 01:50:06 +00:00
refactor(session): improve waitForSession method
This commit is contained in:
@@ -153,14 +153,13 @@ export class SessionManager {
|
|||||||
session: Session,
|
session: Session,
|
||||||
etag: string | null,
|
etag: string | null,
|
||||||
accessToken?: string
|
accessToken?: string
|
||||||
) {
|
): Promise<string> {
|
||||||
const logger = process.logger || console
|
const logger = process.logger || console
|
||||||
|
|
||||||
let sessionState = session.state
|
let sessionState = session.state
|
||||||
|
|
||||||
const stateLink = session.links.find((l: any) => l.rel === 'state')
|
const stateLink = session.links.find((l: any) => l.rel === 'state')
|
||||||
|
|
||||||
return new Promise(async (resolve) => {
|
|
||||||
if (
|
if (
|
||||||
sessionState === 'pending' ||
|
sessionState === 'pending' ||
|
||||||
sessionState === 'running' ||
|
sessionState === 'running' ||
|
||||||
@@ -209,15 +208,16 @@ export class SessionManager {
|
|||||||
logger.info(stateError.message)
|
logger.info(stateError.message)
|
||||||
}
|
}
|
||||||
|
|
||||||
resolve(this.waitForSession(session, etag, accessToken))
|
return await this.waitForSession(session, etag, accessToken)
|
||||||
}
|
}
|
||||||
|
|
||||||
resolve(sessionState)
|
return sessionState
|
||||||
|
} else {
|
||||||
|
throw 'Error while getting session state link.'
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
resolve(sessionState)
|
return sessionState
|
||||||
}
|
}
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private async getSessionState(
|
private async getSessionState(
|
||||||
|
|||||||
Reference in New Issue
Block a user