868 lines
31 KiB
HTML
868 lines
31 KiB
HTML
<!doctype html>
|
|
<html class="no-js" lang="">
|
|
<head>
|
|
<meta charset="utf-8">
|
|
<meta http-equiv="x-ua-compatible" content="ie=edge">
|
|
<title>hometask documentation</title>
|
|
<meta name="description" content="">
|
|
<meta name="viewport" content="width=device-width, initial-scale=1">
|
|
|
|
<link rel="icon" type="image/x-icon" href="../images/favicon.ico">
|
|
<link rel="stylesheet" href="../styles/style.css">
|
|
<link rel="stylesheet" href="../styles/dark.css">
|
|
<link rel="stylesheet" href="../styles/readthedocs.css">
|
|
</head>
|
|
<body>
|
|
|
|
<div class="navbar navbar-default navbar-fixed-top visible-xs">
|
|
<a href="../" class="navbar-brand">hometask documentation</a>
|
|
<button type="button" class="btn btn-default btn-menu ion-ios-menu" id="btn-menu"></button>
|
|
</div>
|
|
|
|
<div class="xs-menu menu" id="mobile-menu">
|
|
<div id="book-search-input" role="search"><input type="text" placeholder="Type to search"></div> <compodoc-menu></compodoc-menu>
|
|
</div>
|
|
|
|
<div class="container-fluid main">
|
|
<div class="row main">
|
|
<div class="hidden-xs menu">
|
|
<compodoc-menu mode="normal"></compodoc-menu>
|
|
</div>
|
|
<!-- START CONTENT -->
|
|
<div class="content injectable">
|
|
<div class="content-data">
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
<ol class="breadcrumb">
|
|
<li>Injectables</li>
|
|
<li >PageInterceptor</li>
|
|
</ol>
|
|
|
|
<ul class="nav nav-tabs" role="tablist">
|
|
<li class="active">
|
|
<a href="#info" role="tab" id="info-tab" data-toggle="tab" data-link="info">Info</a>
|
|
</li>
|
|
<li >
|
|
<a href="#source" role="tab" id="source-tab" data-toggle="tab" data-link="source">Source</a>
|
|
</li>
|
|
</ul>
|
|
|
|
<div class="tab-content">
|
|
<div class="tab-pane fade active in" id="c-info">
|
|
<p class="comment">
|
|
<h3>File</h3>
|
|
</p>
|
|
<p class="comment">
|
|
<code>src/core/interceptors/page.interceptor.ts</code>
|
|
</p>
|
|
|
|
|
|
<p class="comment">
|
|
<h3>Description</h3>
|
|
</p>
|
|
<p class="comment">
|
|
<p>Pagination-implementing interceptor</p>
|
|
|
|
</p>
|
|
|
|
|
|
|
|
<section>
|
|
<h3 id="index">Index</h3>
|
|
<table class="table table-sm table-bordered index-table">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<h6><b>Properties</b></h6>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<ul class="index-list">
|
|
<li>
|
|
<span class="modifier">Private</span>
|
|
<span class="modifier">Readonly</span>
|
|
<a href="#ES_IP" >ES_IP</a>
|
|
</li>
|
|
<li>
|
|
<span class="modifier">Private</span>
|
|
<span class="modifier">Readonly</span>
|
|
<a href="#ES_PORT" >ES_PORT</a>
|
|
</li>
|
|
<li>
|
|
<span class="modifier">Private</span>
|
|
<a href="#prevSearch" >prevSearch</a>
|
|
</li>
|
|
</ul>
|
|
</td>
|
|
</tr>
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<h6><b>Methods</b></h6>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<ul class="index-list">
|
|
<li>
|
|
<span class="modifier">Async</span>
|
|
<a href="#deletePIT" >deletePIT</a>
|
|
</li>
|
|
<li>
|
|
<span class="modifier">Public</span>
|
|
<span class="modifier">Async</span>
|
|
<a href="#getPIT" >getPIT</a>
|
|
</li>
|
|
<li>
|
|
<span class="modifier">Async</span>
|
|
<a href="#intercept" >intercept</a>
|
|
</li>
|
|
</ul>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
|
|
|
|
|
|
</tbody>
|
|
</table>
|
|
</section>
|
|
|
|
<section>
|
|
<h3 id="constructor">Constructor</h3>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<code>constructor(httpService: HttpService)</code>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="73" class="link-to-prism">src/core/interceptors/page.interceptor.ts:73</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Injects needed dependencies and instantiates the storage object</p>
|
|
</div>
|
|
<div>
|
|
<b>Parameters :</b>
|
|
<table class="params">
|
|
<thead>
|
|
<tr>
|
|
<td>Name</td>
|
|
<td>Type</td>
|
|
<td>Optional</td>
|
|
</tr>
|
|
</thead>
|
|
<tbody>
|
|
<tr>
|
|
<td>httpService</td>
|
|
|
|
<td>
|
|
<code>HttpService</code>
|
|
</td>
|
|
|
|
<td>
|
|
No
|
|
</td>
|
|
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</section>
|
|
|
|
<section>
|
|
|
|
<h3 id="methods">
|
|
Methods
|
|
</h3>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<a name="deletePIT"></a>
|
|
<span class="name">
|
|
<span class="modifier">Async</span>
|
|
<span ><b>deletePIT</b></span>
|
|
<a href="#deletePIT"><span class="icon ion-ios-link"></span></a>
|
|
</span>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<span class="modifier-icon icon ion-ios-reset"></span>
|
|
<code>deletePIT(pitID: <a href="https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/string" target="_blank">string</a>)</code>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="206"
|
|
class="link-to-prism">src/core/interceptors/page.interceptor.ts:206</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Deletes the PIT specified by provided ID</p>
|
|
</div>
|
|
|
|
<div class="io-description">
|
|
<b>Parameters :</b>
|
|
|
|
<table class="params">
|
|
<thead>
|
|
<tr>
|
|
<td>Name</td>
|
|
<td>Type</td>
|
|
<td>Optional</td>
|
|
<td>Description</td>
|
|
</tr>
|
|
</thead>
|
|
<tbody>
|
|
<tr>
|
|
<td>pitID</td>
|
|
<td>
|
|
<code><a href="https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/string" target="_blank" >string</a></code>
|
|
</td>
|
|
|
|
<td>
|
|
No
|
|
</td>
|
|
|
|
|
|
<td>
|
|
<p>, ID of the PIT, that would be deleted</p>
|
|
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</div>
|
|
<div>
|
|
</div>
|
|
<div class="io-description">
|
|
<b>Returns : </b> <code>Promise<boolean></code>
|
|
|
|
</div>
|
|
<div class="io-description">
|
|
<p>true/false, depending on the result of deletion of the PIT</p>
|
|
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<a name="getPIT"></a>
|
|
<span class="name">
|
|
<span class="modifier">Public</span>
|
|
<span class="modifier">Async</span>
|
|
<span ><b>getPIT</b></span>
|
|
<a href="#getPIT"><span class="icon ion-ios-link"></span></a>
|
|
</span>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<span class="modifier-icon icon ion-ios-reset"></span>
|
|
<code>getPIT(alive: <a href="https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/number" target="_blank">number</a>, unit: <a href="../undefineds/EsTime.html" target="_self">EsTime</a>)</code>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="186"
|
|
class="link-to-prism">src/core/interceptors/page.interceptor.ts:186</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Acquires a PIT ID from Elasticsearch, needed for a request</p>
|
|
</div>
|
|
|
|
<div class="io-description">
|
|
<b>Parameters :</b>
|
|
|
|
<table class="params">
|
|
<thead>
|
|
<tr>
|
|
<td>Name</td>
|
|
<td>Type</td>
|
|
<td>Optional</td>
|
|
<td>Default value</td>
|
|
<td>Description</td>
|
|
</tr>
|
|
</thead>
|
|
<tbody>
|
|
<tr>
|
|
<td>alive</td>
|
|
<td>
|
|
<code><a href="https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/number" target="_blank" >number</a></code>
|
|
</td>
|
|
|
|
<td>
|
|
No
|
|
</td>
|
|
|
|
<td>
|
|
</td>
|
|
|
|
<td>
|
|
<p>, amount of time in minutes (defaults to 1). If time unit is not specified - defaults to minutes.</p>
|
|
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td>unit</td>
|
|
<td>
|
|
<code><a href="../miscellaneous/enumerations.html#EsTime" target="_self" >EsTime</a></code>
|
|
</td>
|
|
|
|
<td>
|
|
No
|
|
</td>
|
|
|
|
<td>
|
|
<code>EsTime.min</code>
|
|
</td>
|
|
|
|
<td>
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</div>
|
|
<div>
|
|
</div>
|
|
<div class="io-description">
|
|
<b>Returns : </b> <code><a href="../interfaces/EsPit.html" target="_self" >Promise<EsPit></a></code>
|
|
|
|
</div>
|
|
<div class="io-description">
|
|
<p>PIT object <EsPit> containing PIT ID and keep_alive value</p>
|
|
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<a name="intercept"></a>
|
|
<span class="name">
|
|
<span class="modifier">Async</span>
|
|
<span ><b>intercept</b></span>
|
|
<a href="#intercept"><span class="icon ion-ios-link"></span></a>
|
|
</span>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<span class="modifier-icon icon ion-ios-reset"></span>
|
|
<code>intercept(context: ExecutionContext, next: CallHandler<any>)</code>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="89"
|
|
class="link-to-prism">src/core/interceptors/page.interceptor.ts:89</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Override of intercept() method, specified in NestInterceptor interface</p>
|
|
</div>
|
|
|
|
<div class="io-description">
|
|
<b>Parameters :</b>
|
|
|
|
<table class="params">
|
|
<thead>
|
|
<tr>
|
|
<td>Name</td>
|
|
<td>Type</td>
|
|
<td>Optional</td>
|
|
</tr>
|
|
</thead>
|
|
<tbody>
|
|
<tr>
|
|
<td>context</td>
|
|
<td>
|
|
<code>ExecutionContext</code>
|
|
</td>
|
|
|
|
<td>
|
|
No
|
|
</td>
|
|
|
|
|
|
</tr>
|
|
<tr>
|
|
<td>next</td>
|
|
<td>
|
|
<code>CallHandler<any></code>
|
|
</td>
|
|
|
|
<td>
|
|
No
|
|
</td>
|
|
|
|
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</div>
|
|
<div>
|
|
</div>
|
|
<div class="io-description">
|
|
<b>Returns : </b> <code><a href="../classes/PageDto.html" target="_self" >Promise<Observable<PageDto>></a></code>
|
|
|
|
</div>
|
|
<div class="io-description">
|
|
<p>Page with content and metadata</p>
|
|
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
</tbody>
|
|
</table>
|
|
</section>
|
|
<section>
|
|
|
|
<h3 id="inputs">
|
|
Properties
|
|
</h3>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<a name="ES_IP"></a>
|
|
<span class="name">
|
|
<span class="modifier">Private</span>
|
|
<span class="modifier">Readonly</span>
|
|
<span ><b>ES_IP</b></span>
|
|
<a href="#ES_IP"><span class="icon ion-ios-link"></span></a>
|
|
</span>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<i>Default value : </i><code>process.env.ES_CONTAINER_NAME</code>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="174" class="link-to-prism">src/core/interceptors/page.interceptor.ts:174</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Elastichsearch IP address</p>
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
|
|
</tbody>
|
|
</table>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<a name="ES_PORT"></a>
|
|
<span class="name">
|
|
<span class="modifier">Private</span>
|
|
<span class="modifier">Readonly</span>
|
|
<span ><b>ES_PORT</b></span>
|
|
<a href="#ES_PORT"><span class="icon ion-ios-link"></span></a>
|
|
</span>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<i>Default value : </i><code>process.env.ES_PORT</code>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="169" class="link-to-prism">src/core/interceptors/page.interceptor.ts:169</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Elastichsearch server port-number</p>
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
|
|
</tbody>
|
|
</table>
|
|
<table class="table table-sm table-bordered">
|
|
<tbody>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<a name="prevSearch"></a>
|
|
<span class="name">
|
|
<span class="modifier">Private</span>
|
|
<span ><b>prevSearch</b></span>
|
|
<a href="#prevSearch"><span class="icon ion-ios-link"></span></a>
|
|
</span>
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<i>Type : </i> <code><a href="../classes/PrevSearch.html" target="_self" >PrevSearch</a></code>
|
|
|
|
</td>
|
|
</tr>
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-line">Defined in <a href="" data-line="179" class="link-to-prism">src/core/interceptors/page.interceptor.ts:179</a></div>
|
|
</td>
|
|
</tr>
|
|
|
|
<tr>
|
|
<td class="col-md-4">
|
|
<div class="io-description"><p>Info about previously completed search</p>
|
|
</div>
|
|
</td>
|
|
</tr>
|
|
|
|
</tbody>
|
|
</table>
|
|
</section>
|
|
|
|
</div>
|
|
|
|
|
|
<div class="tab-pane fade tab-source-code" id="c-source">
|
|
<pre class="line-numbers compodoc-sourcecode"><code class="language-typescript">import { HttpService } from "@nestjs/axios";
|
|
import { CallHandler, ExecutionContext, Injectable, NestInterceptor } from "@nestjs/common";
|
|
import { Observable, map, take } from "rxjs";
|
|
import { PageDto } from "../domain/dtos";
|
|
import { EsQueryDto } from "../domain/dtos/elastic/es-query.dto";
|
|
import { RequestDto } from "../domain/dtos/request.dto";
|
|
import { SearchQueryDto } from "../domain/dtos/search-q.dto";
|
|
import { EsTime } from "../domain/enums/es-time.enum";
|
|
import { Order } from "../domain/enums/page-order.enum";
|
|
import { PageMeta } from "../domain/interfaces";
|
|
import { EsPit } from "../domain/interfaces/elastic/es-pit.interface";
|
|
|
|
/**
|
|
* Previous search data storage
|
|
*/
|
|
class PrevSearch {
|
|
/**
|
|
* Constructs an uninitialized object
|
|
*/
|
|
constructor() {
|
|
this.pit = undefined;
|
|
this.tiebreaker = undefined;
|
|
this.prevPage = -1;
|
|
}
|
|
|
|
/**
|
|
* PIT object of the previous search
|
|
*/
|
|
private pit: EsPit;
|
|
set _pit(pit: EsPit) {
|
|
this.pit = pit;
|
|
}
|
|
get _pit(): EsPit {
|
|
return this.pit;
|
|
}
|
|
|
|
/**
|
|
* Tiebreaker and sort parameters
|
|
*/
|
|
private tiebreaker: unknown[];
|
|
set _tiebreaker(tiebreaker: unknown[]) {
|
|
this.tiebreaker = tiebreaker;
|
|
}
|
|
get _tiebreaker(): unknown[] {
|
|
return this.tiebreaker;
|
|
}
|
|
|
|
/**
|
|
* Number of the previous page
|
|
*/
|
|
private prevPage: number;
|
|
set _prevPage(page: number) {
|
|
this.prevPage = page;
|
|
}
|
|
get _prevPage(): number {
|
|
return this.prevPage;
|
|
}
|
|
|
|
/**
|
|
* Checks if there was the search before current one
|
|
* @returns true/false, showing whether or not there was another search before
|
|
*/
|
|
public isSet(): boolean {
|
|
if (this.pit && this.tiebreaker && this.prevPage !== -1) return true;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Pagination-implementing interceptor
|
|
*/
|
|
@Injectable()
|
|
export class PageInterceptor implements NestInterceptor {
|
|
/**
|
|
* Injects needed dependencies and instantiates the storage object
|
|
* @param httpService
|
|
* @param searchService
|
|
*/
|
|
constructor(private readonly httpService: HttpService) {
|
|
this.prevSearch = new PrevSearch;
|
|
}
|
|
|
|
/**
|
|
* Override of intercept() method, specified in NestInterceptor interface
|
|
* @param context
|
|
* @param next
|
|
* @returns Page with content and metadata
|
|
*/
|
|
async intercept(context: ExecutionContext, next: CallHandler<any>): Promise<Observable<PageDto>> {
|
|
let request: RequestDto = context.switchToHttp().getRequest<RequestDto>();
|
|
const query: SearchQueryDto = request.query;
|
|
let reverse: boolean = false;
|
|
|
|
request.es_query = new EsQueryDto();
|
|
|
|
request.es_query.query = {
|
|
query_string: {
|
|
query: query.query,
|
|
default_field: 'content',
|
|
}
|
|
};
|
|
request.es_query.sort = [
|
|
{ _score: { order: !query?.order ? Order.DESC : query.order } },
|
|
{ _shard_doc: 'desc' }
|
|
];
|
|
|
|
if (this.prevSearch.isSet()) {
|
|
request.es_query.pit = this.prevSearch._pit;
|
|
request.es_query.search_after = this.prevSearch._tiebreaker;
|
|
|
|
let limit = !query?.limit ? 10 : query.limit;
|
|
request.es_query.size = limit * Math.abs(query.page - this.prevSearch._prevPage);
|
|
|
|
if (query.page < this.prevSearch._prevPage) {
|
|
request.es_query.sort = [{ _score: { order: 'asc' } }];
|
|
request.es_query.size += limit - 1;
|
|
reverse = true;
|
|
} else if (query.page == this.prevSearch._prevPage) {
|
|
// Caching should be HERE
|
|
request.es_query.sort = [{ _score: { order: 'asc' } }];
|
|
reverse = true;
|
|
}
|
|
} else {
|
|
this.prevSearch._pit = request.es_query.pit = await this.getPIT(1);
|
|
|
|
let limit = !query?.limit ? 10 : query.limit;
|
|
request.es_query.size = limit * query.page;
|
|
}
|
|
|
|
return next.handle().pipe(
|
|
map((res) => {
|
|
// Setting the page meta-data
|
|
let meta: PageMeta = {
|
|
total: res.hits.total.value,
|
|
pagenum: !query?.page ? 1 : +query.page,
|
|
order: query?.order?.toUpperCase() === Order.ASC ? Order.ASC : Order.DESC,
|
|
pagesize: !query?.limit ? 10 : query.limit,
|
|
hasNext: undefined,
|
|
hasPrev: undefined,
|
|
};
|
|
meta.hasNext = meta.pagenum * meta.pagesize < meta.total ? true : false;
|
|
meta.hasPrev = meta.pagenum != 1 ? true : false;
|
|
|
|
// Saving the search info
|
|
this.prevSearch._pit.id = res.pit_id;
|
|
this.prevSearch._tiebreaker = res.hits.hits[res.hits.hits.length - 1]?.sort;
|
|
this.prevSearch._prevPage = query.page;
|
|
|
|
// Check if the performed search is a backwards search
|
|
let data = res.hits.hits.slice(-meta.pagesize);
|
|
if (reverse) {
|
|
this.prevSearch._tiebreaker = data[0]?.sort;
|
|
data.reverse();
|
|
reverse = false;
|
|
}
|
|
|
|
// Omitting the redundant info and leaving only the document
|
|
data = data.map((el) => el._source);
|
|
|
|
// Return the page
|
|
return new PageDto(data, meta);
|
|
})
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Elastichsearch server port-number
|
|
*/
|
|
private readonly ES_PORT = process.env.ES_PORT;
|
|
|
|
/**
|
|
* Elastichsearch IP address
|
|
*/
|
|
private readonly ES_IP = process.env.ES_CONTAINER_NAME;
|
|
|
|
/**
|
|
* Info about previously completed search
|
|
*/
|
|
private prevSearch: PrevSearch;
|
|
|
|
/**
|
|
* Acquires a PIT ID from Elasticsearch, needed for a request
|
|
* @param alive, amount of time in minutes (defaults to 1). If time unit is not specified - defaults to minutes.
|
|
* @returns PIT object <EsPit> containing PIT ID and keep_alive value
|
|
*/
|
|
public async getPIT(alive: number, unit: EsTime = EsTime.min): Promise<EsPit> {
|
|
return new Promise((resolve, reject) => {
|
|
try {
|
|
this.httpService.post<EsPit>(`http://${this.ES_IP}:${this.ES_PORT}/papers/_pit?keep_alive=${alive+unit}`)
|
|
.pipe(take(1), map(axiosRes => axiosRes.data))
|
|
.subscribe((res: EsPit) => {
|
|
res.keep_alive = alive + unit;
|
|
resolve(res);
|
|
});
|
|
} catch (error) {
|
|
reject(error);
|
|
}
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Deletes the PIT specified by provided ID
|
|
* @param pitID, ID of the PIT, that would be deleted
|
|
* @returns true/false, depending on the result of deletion of the PIT
|
|
*/
|
|
async deletePIT(pitID: string): Promise<boolean> {
|
|
return new Promise((resolve, reject) => {
|
|
try {
|
|
this.httpService.delete(`http://${this.ES_IP}:${this.ES_PORT}/_pit`, {
|
|
data: { id: pitID },
|
|
headers: { 'Content-Type': 'application/json' },
|
|
})
|
|
.pipe(take(1), map(axiosRes => axiosRes.data))
|
|
.subscribe((res) => {
|
|
resolve(res.succeeded);
|
|
});
|
|
} catch (error) {
|
|
reject(error);
|
|
}
|
|
})
|
|
}
|
|
}</code></pre>
|
|
</div>
|
|
|
|
</div>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
</div><div class="search-results">
|
|
<div class="has-results">
|
|
<h1 class="search-results-title"><span class='search-results-count'></span> results matching "<span class='search-query'></span>"</h1>
|
|
<ul class="search-results-list"></ul>
|
|
</div>
|
|
<div class="no-results">
|
|
<h1 class="search-results-title">No results matching "<span class='search-query'></span>"</h1>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
<!-- END CONTENT -->
|
|
</div>
|
|
</div>
|
|
|
|
<label class="dark-mode-switch">
|
|
<input type="checkbox">
|
|
<span class="slider">
|
|
<svg class="slider-icon" viewBox="0 0 24 24" fill="none" height="20" stroke="#000" stroke-linecap="round" stroke-linejoin="round" stroke-width="2" width="20" xmlns="http://www.w3.org/2000/svg">
|
|
<path d="M21 12.79A9 9 0 1111.21 3 7 7 0 0021 12.79z"></path>
|
|
</svg>
|
|
</span>
|
|
</label>
|
|
|
|
<script>
|
|
var COMPODOC_CURRENT_PAGE_DEPTH = 1;
|
|
var COMPODOC_CURRENT_PAGE_CONTEXT = 'injectable';
|
|
var COMPODOC_CURRENT_PAGE_URL = 'PageInterceptor.html';
|
|
var MAX_SEARCH_RESULTS = 15;
|
|
</script>
|
|
|
|
<script src="../js/libs/custom-elements.min.js"></script>
|
|
<script src="../js/libs/lit-html.js"></script>
|
|
|
|
<script src="../js/menu-wc.js" defer></script>
|
|
<script nomodule src="../js/menu-wc_es5.js" defer></script>
|
|
|
|
<script src="../js/libs/bootstrap-native.js"></script>
|
|
|
|
<script src="../js/libs/es6-shim.min.js"></script>
|
|
<script src="../js/libs/EventDispatcher.js"></script>
|
|
<script src="../js/libs/promise.min.js"></script>
|
|
<script src="../js/libs/zepto.min.js"></script>
|
|
|
|
<script src="../js/compodoc.js"></script>
|
|
|
|
<script src="../js/tabs.js"></script>
|
|
<script src="../js/menu.js"></script>
|
|
<script src="../js/libs/clipboard.min.js"></script>
|
|
<script src="../js/libs/prism.js"></script>
|
|
<script src="../js/sourceCode.js"></script>
|
|
<script src="../js/search/search.js"></script>
|
|
<script src="../js/search/lunr.min.js"></script>
|
|
<script src="../js/search/search-lunr.js"></script>
|
|
<script src="../js/search/search_index.js"></script>
|
|
<script src="../js/lazy-load-graphs.js"></script>
|
|
|
|
|
|
</body>
|
|
</html>
|