import {Injectable} from '@angular/core'; import {BehaviorSubject, Observable} from 'rxjs'; import {HttpClient, HttpHeaders, HttpParams} from '@angular/common/http'; import {environment} from '@src/environments/environment'; import {first} from 'rxjs/operators'; import {AccountIndex, MutableKeyStore, MutablePgpKeyStore, PGPSigner, Registry, Signer} from '@app/_helpers'; import {ArgPair, Envelope, Syncable, User} from 'cic-client-meta'; import {MetaResponse} from '@app/_models'; import {LoggingService} from '@app/_services/logging.service'; import {HttpWrapperService} from '@app/_services/http-wrapper.service'; const vCard = require('vcard-parser'); @Injectable({ providedIn: 'root' }) export class UserService { headers: HttpHeaders = new HttpHeaders({'x-cic-automerge': 'client'}); keystore: MutableKeyStore = new MutablePgpKeyStore(); signer: Signer = new PGPSigner(this.keystore); registry = new Registry(environment.registryAddress); accountsMeta = []; accounts: any = []; private accountsList = new BehaviorSubject(this.accounts); accountsSubject = this.accountsList.asObservable(); actions: any = ''; private actionsList = new BehaviorSubject(this.actions); actionsSubject = this.actionsList.asObservable(); staff: any = ''; private staffList = new BehaviorSubject(this.staff); staffSubject = this.staffList.asObservable(); constructor( private http: HttpClient, private httpWrapperService: HttpWrapperService, private loggingService: LoggingService ) { } resetPin(phone: string): Observable { const params = new HttpParams().set('phoneNumber', phone); return this.httpWrapperService.get(`${environment.cicUssdUrl}/pin`, {params}); } getAccountStatus(phone: string): any { const params = new HttpParams().set('phoneNumber', phone); return this.httpWrapperService.get(`${environment.cicUssdUrl}/pin`, {params}); } getLockedAccounts(offset: number, limit: number): any { return this.httpWrapperService.get(`${environment.cicUssdUrl}/accounts/locked/${offset}/${limit}`); } async changeAccountInfo(address: string, name: string, phoneNumber: string, age: string, type: string, bio: string, gender: string, businessCategory: string, userLocation: string, location: string, locationType: string, metaAccount: MetaResponse ): Promise { let reqBody = metaAccount; let accountInfo = reqBody.m.data; accountInfo.vcard.fn[0].value = name; accountInfo.vcard.n[0].value = name.split(' '); accountInfo.vcard.tel[0].value = phoneNumber; accountInfo.products = [bio]; accountInfo.gender = gender; accountInfo.age = age; accountInfo.type = type; accountInfo.category = businessCategory; accountInfo.location.area = location; accountInfo.location.area_name = userLocation; accountInfo.location.area_type = locationType; accountInfo.vcard = vCard.generate(accountInfo.vcard); reqBody.m.data = accountInfo; const accountKey = await User.toKey(address); this.httpWrapperService.get(`${environment.cicMetaUrl}/${accountKey}`, { headers: this.headers }).pipe(first()).subscribe(async res => { const syncableAccount: Syncable = Envelope.fromJSON(JSON.stringify(res.body)).unwrap(); let update = []; for (const prop in reqBody) { update.push(new ArgPair(prop, reqBody[prop])); } syncableAccount.update(update, 'client-branch'); await this.updateMeta(syncableAccount, accountKey, this.headers); }, async error => { this.loggingService.sendErrorLevelMessage('Can\'t find account info in meta service', this, {error}); const syncableAccount: Syncable = new Syncable(accountKey, accountInfo); await this.updateMeta(syncableAccount, accountKey, this.headers); }); return accountKey; } async updateMeta(syncableAccount: Syncable, accountKey: string, headers: HttpHeaders): Promise { const envelope = await this.wrap(syncableAccount , this.signer); const reqBody = envelope.toJSON(); this.httpWrapperService.put(`${environment.cicMetaUrl}/${accountKey}`, reqBody , { headers }).pipe(first()).subscribe(res => { this.loggingService.sendInfoLevelMessage(`Response: ${res.body}`); }); } getAccounts(): void { this.httpWrapperService.get(`${environment.cicCacheUrl}/accounts`).pipe(first()).subscribe(res => this.accountsList.next(res.body)); } getAccountById(id: number): Observable { return this.httpWrapperService.get(`${environment.cicCacheUrl}/accounts/${id}`); } getActions(): void { this.httpWrapperService.get(`${environment.cicCacheUrl}/actions`).pipe(first()).subscribe(res => this.actionsList.next(res.body)); } getActionById(id: string): any { return this.httpWrapperService.get(`${environment.cicCacheUrl}/actions/${id}`); } approveAction(id: string): Observable { return this.httpWrapperService.post(`${environment.cicCacheUrl}/actions/${id}`, { approval: true }); } revokeAction(id: string): Observable { return this.httpWrapperService.post(`${environment.cicCacheUrl}/actions/${id}`, { approval: false }); } getHistoryByUser(id: string): Observable { return this.httpWrapperService.get(`${environment.cicCacheUrl}/history/${id}`); } getStaff(): void { this.httpWrapperService.get(`${environment.cicCacheUrl}/staff`).pipe(first()).subscribe(res => this.staffList.next(res.body)); } getStaffById(id: string): Observable { return this.httpWrapperService.get(`${environment.cicCacheUrl}/staff/${id}`); } activateStaff(id: string): Observable { return this.httpWrapperService.post(`${environment.cicCacheUrl}/staff/${id}`, {status: 'activated'}); } deactivateStaff(id: string): Observable { return this.httpWrapperService.post(`${environment.cicCacheUrl}/staff/${id}`, {status: 'deactivated'}); } changeStaffType(id: string, type: string): Observable { return this.httpWrapperService.post(`${environment.cicCacheUrl}/staff/${id}`, {accountType: type}); } getAccountDetailsFromMeta(userKey: string): Observable { return this.httpWrapperService.get(`${environment.cicMetaUrl}/${userKey}`, { headers: this.headers }); } getUser(userKey: string): any { return this.httpWrapperService.get(`${environment.cicMetaUrl}/${userKey}`, { headers: this.headers }) .pipe(first()).subscribe(async res => { return Envelope.fromJSON(JSON.stringify(res.body)).unwrap(); }); } wrap(syncable: Syncable, signer: Signer): Promise { return new Promise(async (whohoo, doh) => { syncable.setSigner(signer); syncable.onwrap = async (env) => { if (env === undefined) { doh(); return; } whohoo(env); }; await syncable.sign(); }); } async loadAccounts(limit: number, offset: number = 0): Promise { this.resetAccountsList(); const accountIndexAddress = await this.registry.addressOf('AccountRegistry'); const accountIndexQuery = new AccountIndex(accountIndexAddress); const accountAddresses = await accountIndexQuery.last(await accountIndexQuery.totalAccounts()); for (const accountAddress of accountAddresses.slice(offset, offset + limit)) { this.getAccountDetailsFromMeta(await User.toKey(accountAddress)).pipe(first()).subscribe(res => { const account = Envelope.fromJSON(JSON.stringify(res)).unwrap(); this.accountsMeta.push(account); const accountInfo = account.m.data; accountInfo.vcard = vCard.parse(atob(accountInfo.vcard)); this.accounts.unshift(accountInfo); if (this.accounts.length > limit) { this.accounts.length = limit; } this.accountsList.next(this.accounts); }); } } resetAccountsList(): void { this.accounts = []; this.accountsList.next(this.accounts); } }