Fixes #724: Push search data to server using api/push.json

src/app/effects/api-search.effects.ts

@@ -14,7 +14,7 @@ import {
 	skip
 } from 'rxjs/operators';
 
-import { SearchService, SearchServiceConfig } from '../services';
+import { SearchService, SearchServiceConfig, PushService } from '../services';
 import * as fromRoot from '../reducers';
 import * as apiAction from '../actions/api';
 import * as queryAction from '../actions/query';
@@ -118,6 +118,7 @@ export class ApiSearchEffects {
 				),
 				withLatestFrom(this.store$),
 				map(([action, state]) => {
+					this.pushService.postData(action['payload']);
 					return {
 						doRelocate: state.query.relocateAfter,
 						relocateTo: state.query.routerString
@@ -227,6 +228,7 @@ export class ApiSearchEffects {
 		private store$: Store<fromRoot.State>,
 		private actions$: Actions,
 		private apiSearchService: SearchService,
+		private pushService: PushService,
 		private location: Location,
 		private titleService: Title
 	) { }

src/app/models/index.ts

@@ -9,3 +9,4 @@ export * from './time-bound';
 export * from './media-wall-custom';
 export * from './media-wall-filters';
 export * from './media-wall-direct-url';
+export * from './push';

src/app/models/push.ts

@@ -0,0 +1,6 @@
+export interface PushApiResponse {
+	status: string;
+	records: number;
+	mps: number;
+	message: string;
+}

src/app/services/index.ts

@@ -3,3 +3,4 @@ export * from './search.service';
 export * from './suggest.service';
 export * from './user.service';
 export * from './speech.service';
+export * from './push.service';

src/app/services/push.service.spec.ts

@@ -0,0 +1,21 @@
+import { TestBed, inject } from '@angular/core/testing';
+import { HttpClientModule, HttpClient } from '@angular/common/http';
+import { PushService } from './push.service';
+
+describe('PushService', () => {
+	beforeEach(() => {
+		TestBed.configureTestingModule({
+			imports: [
+				HttpClientModule
+			],
+			providers: [
+				PushService,
+				HttpClient
+			]
+		});
+	});
+
+	it('should be created', inject([PushService], (service: PushService) => {
+		expect(service).toBeTruthy();
+	}));
+});

src/app/services/push.service.ts

@@ -0,0 +1,48 @@
+import { Injectable } from '@angular/core';
+import {
+	HttpClient,
+	HttpHeaders,
+	HttpParams
+} from '@angular/common/http';
+import { Observable } from 'rxjs';
+import { ApiResponse, PushApiResponse } from '../models';
+@Injectable({
+	providedIn: 'root'
+})
+/*
+* The PushService is called on SEARCH_COMPLETE_SUCCESS
+* to push the result data back to server in the same
+* search result object format obtained from server.
+**/
+export class PushService {
+
+	constructor( private http: HttpClient ) { }
+
+	// Returns an Observable of PushApiResponse.
+	public postData(data: ApiResponse): Observable<PushApiResponse> {
+
+		// End point to make a Post to.
+		const httpUrl = 'https://api.loklak.org/api/push.json';
+
+		const headers = new HttpHeaders({
+			'Content-Type': 'application/x-www-form-urlencoded',
+			'Accept': 'application/json',
+			'cache-control': 'no-cache'
+		});
+		// Extracting search_metadata and statuses
+		// from the data obtained from search result.
+		const {search_metadata, statuses} = data;
+
+		// Converting the object to JSON string.
+		const dataToSend = JSON.stringify({search_metadata: search_metadata, statuses});
+
+		// Setting the data to send in HttpParams()
+		// with key as 'data'
+		const body = new HttpParams().set('data', dataToSend);
+
+		// Making a Post request to api/push.json endpoint
+		// of server with required header and data body.
+		// Response Object is converted to PushApiResponse type.
+		return this.http.post<PushApiResponse>(httpUrl, body, {headers: headers});
+	}
+}