59 lines
1.7 KiB
TypeScript
59 lines
1.7 KiB
TypeScript
import { combineLatest, Observable } from "rxjs"
|
|
import { map } from "rxjs/operators"
|
|
import { HoppRESTRequest } from "../types/HoppRESTRequest"
|
|
import { Environment } from "~/newstore/environments"
|
|
|
|
export interface EffectiveHoppRESTRequest extends HoppRESTRequest {
|
|
/**
|
|
* The effective final URL.
|
|
*
|
|
* This contains path, params and environment variables all applied to it
|
|
*/
|
|
effectiveFinalURL: string
|
|
effectiveFinalHeaders: { key: string; value: string }[]
|
|
}
|
|
|
|
/**
|
|
* Outputs an executable request format with environment variables applied
|
|
*
|
|
* @param request The request to source from
|
|
* @param environment The environment to apply
|
|
*
|
|
* @returns An object with extra fields defining a complete request
|
|
*/
|
|
export function getEffectiveRESTRequest(
|
|
request: HoppRESTRequest,
|
|
_environment: Environment
|
|
) {
|
|
// TODO: Change this
|
|
return {
|
|
...request,
|
|
effectiveFinalURL: request.endpoint,
|
|
effectiveFinalHeaders: request.headers.filter(
|
|
(x) =>
|
|
x.key !== "" && // Remove empty keys
|
|
x.active // Only active
|
|
),
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Creates an Observable Stream that emits HoppRESTRequests whenever
|
|
* the input streams emit a value
|
|
*
|
|
* @param request$ The request stream containing request data
|
|
* @param environment$ The environment stream containing environment data to apply
|
|
*
|
|
* @returns Observable Stream for the Effective Request Object
|
|
*/
|
|
export function getEffectiveRESTRequestStream(
|
|
request$: Observable<HoppRESTRequest>,
|
|
environment$: Observable<Environment>
|
|
): Observable<EffectiveHoppRESTRequest> {
|
|
return combineLatest([request$, environment$]).pipe(
|
|
map(([request, env]) => {
|
|
return getEffectiveRESTRequest(request, env)
|
|
})
|
|
)
|
|
}
|