zgo/src/app/user.service.ts

import {Injectable} from '@angular/core';
import {Subject, BehaviorSubject, Observable} from 'rxjs';
import {HttpClient, HttpParams, HttpHeaders} from '@angular/common/http';
import {User} from './user.model';
import {Owner} from './owner.model';
import {Tx} from './tx.model';

@Injectable({providedIn: 'root'})

export class UserService{
	beUrl = 'http://localhost:3000/';
	private dataStore: { user: User, owner: Owner, txs: Tx[]} = { 
		user: {
			address: '',
			session: '',
			blocktime: 0,
			expiration: 0,
			pin: '',
			validated: false
		},
		owner: {
			address: '',
			name: ''
		},
		txs : []
	};
	private uZaddr = '';
	private oZaddr = '';
	private uName = '';
	private session: string | null = '';
	private _uZaddrUpdated: BehaviorSubject<string> = new BehaviorSubject(this.uZaddr);
	private _userUpdated: BehaviorSubject<User> = new BehaviorSubject(this.dataStore.user);
	private uNameUpdated = new Subject<string>();
	private _ownerUpdated: BehaviorSubject<Owner> = new BehaviorSubject(this.dataStore.owner);
	private _txsUpdated: BehaviorSubject<Tx[]> = new BehaviorSubject(this.dataStore.txs);
	public readonly uZaddrUpdate: Observable<string> = this._uZaddrUpdated.asObservable();
	public readonly ownerUpdate: Observable<Owner> = this._ownerUpdated.asObservable();
	public readonly userUpdate: Observable<User> = this._userUpdated.asObservable();
	public readonly txUpdate: Observable<Tx[]> = this._txsUpdated.asObservable();
	private reqHeaders: HttpHeaders;
	private apiKey = 'Le2adeic8Thah4Aeng4daem6i';

	constructor(private http: HttpClient){
		this.reqHeaders = new HttpHeaders().set('Authorization', this.apiKey);
		//console.log('US:', this.reqHeaders);
		this.session = localStorage.getItem('s4z_token');
		if (this.session != null) {
			this.findUser();
			this.findPending();
		}
	}

	findUser() {
		this.session = localStorage.getItem('s4z_token');
		if (this.session != null) {
			const params = new HttpParams().append('session', this.session!);
			let obs = this.http.get<{message: string, user: any}>(this.beUrl+'api/getuser', { headers: this.reqHeaders, params: params, observe: 'response'});

			obs.subscribe((UserDataResponse) => {
				console.log(UserDataResponse.status);
				if (UserDataResponse.status == 200){
					this.dataStore.user = UserDataResponse.body!.user[0];
					console.log(`US: Found user, returning it`);
					this._uZaddrUpdated.next(Object.assign({},this.dataStore).user.address);
					this._userUpdated.next(Object.assign({}, this.dataStore).user);
					this.getOwner(Object.assign({},this.dataStore.user).address);
				} else {
					console.log('US: Did not find user');
				}
			});

			return obs;
		} else {
			console.log('No session loaded');
			return null;
		}
	}
	
	findPending() {
		this.session = localStorage.getItem('s4z_token');
		if (this.session != null) {
			const params = new HttpParams().append('session', this.session!);
			let obs = this.http.get<{message: string, txs: any}>(this.beUrl+'api/pending', { headers: this.reqHeaders, params: params, observe: 'response'});

			obs.subscribe((TxDataResponse) => {
				//console.log('US Tx', TxDataResponse);
				if (TxDataResponse.status == 200){
					this.dataStore.txs = TxDataResponse.body!.txs;
					console.log(`US: Pending logins found`);
					this._txsUpdated.next(Object.assign({},this.dataStore).txs);
				} else {
					console.log('US: Did not find pending txs');
					this.dataStore.txs = [];
					this._txsUpdated.next(Object.assign({},this.dataStore).txs);
				}
			});

			return obs;
		} else {
			console.log('No session loaded');
			return null;
		}
	}

	validateUser(){
		var validatedUser: User =  this.dataStore.user;
		validatedUser.validated = true;
		this.http.post<{message: string, user: User}>(this.beUrl+'api/validateuser', {user: validatedUser}, {headers: this.reqHeaders}).
		subscribe((responseData) => {
			console.log(responseData.message);
		});
	}

	addOwner(address: string) {
		const owner: Owner={_id: '', address: address, name: 'Zgo-'.concat(address.substring(0,5))};
		let obs = this.http.post<{message: string}>(this.beUrl+'api/addowner', {address: owner.address, name: owner.name}, {headers: this.reqHeaders});

		obs.subscribe((responseData) => {
			console.log(responseData.message);
		});

		return obs;
	}

	updateOwner(owner: Owner) {
		this.http.post<{message: string, owner: Owner}>(this.beUrl+'api/updateowner', {owner: owner}, {headers: this.reqHeaders}).
		subscribe((responseData) => {
			console.log(responseData.message);
			//this.dataStore.owner = responseData.owner;
			//this._ownerUpdated.next(Object.assign({},this.dataStore).owner);
		});
	}


	getOwner(address: string) {
		console.log('getOwner', address);
		const ownParams = new HttpParams().append('address', address);
		let obs = this.http.get<{message:string, owner: any}>(this.beUrl+'api/getowner', { headers: this.reqHeaders, params: ownParams, observe: 'response'});

		obs.subscribe((OwnerDataResponse) => {
			console.log('api/getowner', OwnerDataResponse.status);
			if (OwnerDataResponse.status == 200) {
				this.dataStore.owner = OwnerDataResponse.body!.owner[0];
				//console.log('getOwner object', this.dataStore.owner);
				this._ownerUpdated.next(Object.assign({},this.dataStore).owner);
			} else {
				console.log("No owner found, adding");
				this.addOwner(address);
			}
		});

		return obs;
	}

	hasOwner() {
		return this.uZaddr === this.oZaddr;
	}

	getNameUpdateListener() {
		return this.uNameUpdated;
	}


}