Implement flexible currency

This commit is contained in:
Rene Vergara 2021-11-22 14:37:45 -06:00
parent 078916f92d
commit 2596c36289
18 changed files with 177 additions and 38 deletions

View file

@ -100,12 +100,14 @@ var blockInterval = setInterval( function() {
var re = /.*ZGO::(.*)\sReply-To:\s(z\w+)/; var re = /.*ZGO::(.*)\sReply-To:\s(z\w+)/;
async.each (txs, function(txData, callback) { async.each (txs, function(txData, callback) {
var memo = hexToString(txData.memo).replace(/\0/g, ''); var memo = hexToString(txData.memo).replace(/\0/g, '');
if (!txData.change) {
zecTxModel.updateOne({txid: txData.txid}, { txid: txData.txid, confirmations: txData.confirmations, amount:txData.amount, memo: memo}, {new:true, upsert:true}, function(err,docs) { zecTxModel.updateOne({txid: txData.txid}, { txid: txData.txid, confirmations: txData.confirmations, amount:txData.amount, memo: memo}, {new:true, upsert:true}, function(err,docs) {
if (err) { if (err) {
console.log(err); console.log(err);
} }
}); });
if (re.test(memo)) { }
if (re.test(memo) && txData.confirmations < 100) {
//console.log('Processing tx:', memo); //console.log('Processing tx:', memo);
var match = re.exec(memo); var match = re.exec(memo);
if (match != null) { if (match != null) {
@ -180,7 +182,7 @@ var blockInterval = setInterval( function() {
}); });
}); });
}, 90000); }, 75000);
app.use(cors()); app.use(cors());
app.options('*', cors()); app.options('*', cors());
@ -346,6 +348,7 @@ app.post('/api/updateowner', (req, res, next) => {
if (err) { if (err) {
console.log(err); console.log(err);
} else { } else {
console.log(docs);
res.status(201).json({ res.status(201).json({
message: 'Owner updated', message: 'Owner updated',
owner: docs owner: docs
@ -418,7 +421,7 @@ app.delete('/api/item/:id', (req, res, next) => {
app.get('/api/price', (req, res, next) => { app.get('/api/price', (req, res, next) => {
console.log('Get /api/price'); console.log('Get /api/price');
const price = pricemodel.findOne({currency: 'usd'}).then((document) => { const price = pricemodel.findOne({currency: req.query.currency}).then((document) => {
if (document != null) { if (document != null) {
res.status(200).json({ res.status(200).json({
message: 'price found!', message: 'price found!',
@ -492,6 +495,7 @@ app.post('/api/order', (req, res, next) => {
session: req.body.order.session, session: req.body.order.session,
price: req.body.order.price, price: req.body.order.price,
total: req.body.order.total, total: req.body.order.total,
currency: req.body.order.currency,
totalZec: req.body.order.totalZec, totalZec: req.body.order.totalZec,
closed: req.body.order.closed closed: req.body.order.closed
}, function(err, docs) { }, function(err, docs) {

View file

@ -6,6 +6,7 @@ const orderSchema = mongoose.Schema({
timestamp: {type: Date, required: true, default: Date.now}, timestamp: {type: Date, required: true, default: Date.now},
closed: { type: Boolean, required: true, default:false }, closed: { type: Boolean, required: true, default:false },
price: { type: Number, required: true}, price: { type: Number, required: true},
currency: {type: String, required: true},
total: { type: Number}, total: { type: Number},
totalZec: {type: Number}, totalZec: {type: Number},
lines: [{ lines: [{

View file

@ -2,7 +2,12 @@ const mongoose = require('mongoose');
const ownerSchema = mongoose.Schema({ const ownerSchema = mongoose.Schema({
address: {type: String, required:true, unique:true}, address: {type: String, required:true, unique:true},
name: {type: String, required:true} name: {type: String, required:true},
currency: {type: String, required:true, default: 'usd'},
tax: {type: Boolean, required: true, default: false},
taxValue: {type: Number },
vat: {type: Boolean, required:true, default: false},
vatValue: {type: Number }
}); });
module.exports = mongoose.model('Owner', ownerSchema); module.exports = mongoose.model('Owner', ownerSchema);

View file

@ -2,6 +2,7 @@ import {Injectable} from '@angular/core';
import {Subject, Subscription, BehaviorSubject, Observable} from 'rxjs'; import {Subject, Subscription, BehaviorSubject, Observable} from 'rxjs';
import {HttpClient, HttpParams, HttpHeaders} from '@angular/common/http'; import {HttpClient, HttpParams, HttpHeaders} from '@angular/common/http';
import {UserService} from './user.service'; import {UserService} from './user.service';
import { Owner } from './owner.model';
//import {User} from './user.model'; //import {User} from './user.model';
@ -17,15 +18,30 @@ export class FullnodeService{
public readonly heightUpdate: Observable<number> = this._heightUpdated.asObservable(); public readonly heightUpdate: Observable<number> = this._heightUpdated.asObservable();
public readonly memoUpdate: Observable<string[]> = this._memoUpdated.asObservable(); public readonly memoUpdate: Observable<string[]> = this._memoUpdated.asObservable();
public readonly priceUpdate: Observable<number> = this._priceUpdated.asObservable(); public readonly priceUpdate: Observable<number> = this._priceUpdated.asObservable();
public readonly ownerUpdate: Observable<Owner>;
private UserSub: Subscription = new Subscription(); private UserSub: Subscription = new Subscription();
private apiKey = 'Le2adeic8Thah4Aeng4daem6i'; private apiKey = 'Le2adeic8Thah4Aeng4daem6i';
private reqHeaders: HttpHeaders; private reqHeaders: HttpHeaders;
private owner: Owner = {
_id: '',
name: '',
address: '',
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
};
constructor(private http: HttpClient, public userService: UserService){ constructor(private http: HttpClient, public userService: UserService){
this.reqHeaders = new HttpHeaders().set('Authorization', this.apiKey); this.reqHeaders = new HttpHeaders().set('Authorization', this.apiKey);
this.ownerUpdate = userService.ownerUpdate;
this.getAddr(); this.getAddr();
this.getHeight(); this.getHeight();
this.getPrice(); this.ownerUpdate.subscribe((owner) => {
this.owner = owner;
this.getPrice(this.owner.currency);
});
} }
getHeight(){ getHeight(){
@ -38,8 +54,8 @@ export class FullnodeService{
return obs; return obs;
} }
getPrice(){ getPrice(currency: string){
var currency = 'usd'; //var currency = 'usd';
const params = new HttpParams().append('currency', currency); const params = new HttpParams().append('currency', currency);
let obs = this.http.get<{message: string, price: any}>(this.beUrl+'api/price', { headers:this.reqHeaders, params: params, observe: 'response'}); let obs = this.http.get<{message: string, price: any}>(this.beUrl+'api/price', { headers:this.reqHeaders, params: params, observe: 'response'});
obs.subscribe((PriceData) => { obs.subscribe((PriceData) => {
@ -55,16 +71,6 @@ export class FullnodeService{
return obs; return obs;
} }
hexToString(hexString: string) {
var str = '';
for (var n=0; n < hexString.length; n +=2) {
str += String.fromCharCode(parseInt(hexString.substr(n, 2), 16));
}
return str;
}
getAddr() { getAddr() {
let obs = this.http.get<{message: string, addr: string}>(this.beUrl+'api/getaddr', { headers: this.reqHeaders }); let obs = this.http.get<{message: string, addr: string}>(this.beUrl+'api/getaddr', { headers: this.reqHeaders });

View file

@ -4,6 +4,7 @@
</span> </span>
<span class="spacer"></span> <span class="spacer"></span>
<span align="center"> <span align="center">
<p class="mini text">Currency: {{ getCurrency() }}</p>
<p class="mini text">Last block:</p> <p class="mini text">Last block:</p>
<p class="mini text">{{heightUpdate | async}}</p> <p class="mini text">{{heightUpdate | async}}</p>
</span> </span>

View file

@ -15,7 +15,16 @@ import {Owner} from '../owner.model';
export class HeaderComponent implements OnInit, OnDestroy { export class HeaderComponent implements OnInit, OnDestroy {
public height = 0; public height = 0;
private owner: Owner= {_id:'', address: 'none', name:''}; private owner: Owner= {
_id:'',
address: 'none',
name:'',
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
};
private session: string | null = ''; private session: string | null = '';
public heightUpdate: Observable<number>; public heightUpdate: Observable<number>;
public ownerUpdate: Observable<Owner>; public ownerUpdate: Observable<Owner>;
@ -41,6 +50,7 @@ export class HeaderComponent implements OnInit, OnDestroy {
ngOnDestroy(){ ngOnDestroy(){
} }
getCurrency(){
return this.owner.currency.toUpperCase();
}
} }

View file

@ -5,7 +5,7 @@
<tr> <tr>
<td>{{item.name}}</td> <td>{{item.name}}</td>
<td align="right"> <td align="right">
<p class="price">{{item.cost | currency: 'USD'}}</p> <p class="price">{{item.cost | currency: getCurrency() }}</p>
<p class="price"><img class="icon" src="/assets/zec-roboto.png" width="10px" />{{(item.cost/price) | number: '1.0-6'}}</p> <p class="price"><img class="icon" src="/assets/zec-roboto.png" width="10px" />{{(item.cost/price) | number: '1.0-6'}}</p>
</td> </td>
</tr> </tr>

View file

@ -20,7 +20,16 @@ import { ItemAddComponent } from '../item-add/item-add.component';
export class ItemListComponent implements OnInit{ export class ItemListComponent implements OnInit{
public items: Item[] = []; public items: Item[] = [];
private owner: Owner = {_id: '', name: '', address: ''}; private owner: Owner = {
_id: '',
name: '',
address: '',
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
};
public price: number = 1; public price: number = 1;
public ownerUpdate: Observable<Owner>; public ownerUpdate: Observable<Owner>;
public itemsUpdate: Observable<Item[]>; public itemsUpdate: Observable<Item[]>;
@ -38,7 +47,7 @@ export class ItemListComponent implements OnInit{
this.priceUpdate = fullnodeService.priceUpdate; this.priceUpdate = fullnodeService.priceUpdate;
this.ownerUpdate.subscribe((owner) => { this.ownerUpdate.subscribe((owner) => {
this.owner = owner; this.owner = owner;
console.log('owner address', this.owner.address); fullnodeService.getPrice(this.owner.currency);
itemService.getItems(this.owner.address); itemService.getItems(this.owner.address);
this.itemsUpdate.subscribe((items) => { this.itemsUpdate.subscribe((items) => {
this.items = items; this.items = items;
@ -151,5 +160,9 @@ export class ItemListComponent implements OnInit{
this.itemService.getItems(this.owner.address); this.itemService.getItems(this.owner.address);
}); });
} }
getCurrency(){
return this.owner.currency.toUpperCase();
}
} }

View file

@ -32,7 +32,7 @@
</mat-panel-description> </mat-panel-description>
</mat-expansion-panel-header> </mat-expansion-panel-header>
<p class="text">Order: {{order._id}}</p> <p class="text">Order: {{order._id}}</p>
<p class="text">Zcash price: {{order.price | currency: 'USD'}}</p> <p class="text">Zcash price: {{order.price | currency: order.currency.toUpperCase()}}</p>
<mat-list> <mat-list>
<mat-list-item class="text small" *ngFor="let item of order.lines">{{item.qty}} x {{item.name}}</mat-list-item> <mat-list-item class="text small" *ngFor="let item of order.lines">{{item.qty}} x {{item.name}}</mat-list-item>
</mat-list> </mat-list>

View file

@ -8,7 +8,7 @@
<tr> <tr>
<td>Order Total:</td> <td>Order Total:</td>
<td align="right"> <td align="right">
<p class="number">{{total | currency: 'USD'}}</p> <p class="number">{{total | currency: getCurrency()}}</p>
<p class="number"><img class="icon" src="/assets/zec-roboto.png" width="14px" />{{(total/price) | number: '1.0-6'}}</p> <p class="number"><img class="icon" src="/assets/zec-roboto.png" width="14px" />{{(total/price) | number: '1.0-6'}}</p>
</td> </td>
</tr> </tr>

View file

@ -15,7 +15,23 @@ import { CheckoutComponent} from '../checkout/checkout.component';
}) })
export class OrderComponent implements OnInit{ export class OrderComponent implements OnInit{
public order: Order = {address: '', session: '', timestamp: '', closed: false, price:0, total:0, totalZec: 0, lines: [{qty: 1, name: '', cost: 0}]}; public order: Order = {
address: '',
session: '',
timestamp: '',
closed: false,
currency: '',
price:0,
total:0,
totalZec: 0,
lines: [
{
qty: 1,
name: '',
cost: 0
}
]
};
public price: number = 1; public price: number = 1;
public total: number = 0; public total: number = 0;
public orderUpdate: Observable<Order>; public orderUpdate: Observable<Order>;
@ -87,4 +103,8 @@ export class OrderComponent implements OnInit{
} }
}); });
} }
getCurrency(){
return this.order.currency.toUpperCase();
}
} }

View file

@ -6,6 +6,7 @@ export interface Order {
session: string, session: string,
timestamp?: string, timestamp?: string,
closed: boolean, closed: boolean,
currency: string,
price?: number, price?: number,
total: number, total: number,
totalZec: number, totalZec: number,

View file

@ -5,13 +5,14 @@ import { Order } from './order.model';
import { UserService } from '../user.service'; import { UserService } from '../user.service';
import { FullnodeService } from '../fullnode.service'; import { FullnodeService } from '../fullnode.service';
import { User } from '../user.model'; import { User } from '../user.model';
import { Owner } from '../owner.model';
import { LineItem} from '../items/lineitem.model'; import { LineItem} from '../items/lineitem.model';
@Injectable({providedIn: 'root'}) @Injectable({providedIn: 'root'})
export class OrderService { export class OrderService {
beUrl = 'http://localhost:3000/'; beUrl = 'http://localhost:3000/';
private dataStore: {allOrders: Order[], user: User, order: Order } = { private dataStore: {allOrders: Order[], user: User, order: Order, owner: Owner } = {
allOrders: [], allOrders: [],
user:{ user:{
address: '', address: '',
@ -21,11 +22,22 @@ export class OrderService {
pin: '', pin: '',
validated: false validated: false
}, },
owner: {
_id: '',
name: '',
address: '',
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
},
order: { order: {
address: '', address: '',
session: '', session: '',
timestamp: '', timestamp: '',
closed: false, closed: false,
currency: '',
price: 0, price: 0,
total: 0, total: 0,
totalZec: 0, totalZec: 0,
@ -45,6 +57,7 @@ export class OrderService {
private _allOrdersUpdated: BehaviorSubject<Order[]> = new BehaviorSubject(this.dataStore.allOrders); private _allOrdersUpdated: BehaviorSubject<Order[]> = new BehaviorSubject(this.dataStore.allOrders);
public readonly allOrdersUpdate: Observable<Order[]> = this._allOrdersUpdated.asObservable(); public readonly allOrdersUpdate: Observable<Order[]> = this._allOrdersUpdated.asObservable();
public userUpdate: Observable<User>; public userUpdate: Observable<User>;
public ownerUpdate: Observable<Owner>;
private apiKey = 'Le2adeic8Thah4Aeng4daem6i'; private apiKey = 'Le2adeic8Thah4Aeng4daem6i';
private reqHeaders: HttpHeaders; private reqHeaders: HttpHeaders;
@ -55,11 +68,15 @@ export class OrderService {
) { ) {
this.reqHeaders = new HttpHeaders().set('Authorization', this.apiKey); this.reqHeaders = new HttpHeaders().set('Authorization', this.apiKey);
this.userUpdate = userService.userUpdate; this.userUpdate = userService.userUpdate;
this.ownerUpdate = userService.ownerUpdate;
this.userUpdate.subscribe((user) => { this.userUpdate.subscribe((user) => {
this.dataStore.user = user; this.dataStore.user = user;
//console.log('OS: const', user); //console.log('OS: const', user);
this.getOrder(); this.getOrder();
}); });
this.ownerUpdate.subscribe((owner) => {
this.dataStore.owner = owner;
});
} }
getOrder() { getOrder() {
@ -116,6 +133,7 @@ export class OrderService {
var order:Order = { var order:Order = {
address: this.dataStore.user.address, address: this.dataStore.user.address,
session: this.dataStore.user.session, session: this.dataStore.user.session,
currency: this.dataStore.owner.currency,
closed: false, closed: false,
totalZec: 0, totalZec: 0,
price: 0, price: 0,
@ -144,6 +162,7 @@ export class OrderService {
session: '', session: '',
timestamp: '', timestamp: '',
closed: false, closed: false,
currency: '',
total: 0, total: 0,
totalZec: 0, totalZec: 0,
price: 0, price: 0,
@ -174,6 +193,7 @@ export class OrderService {
session: '', session: '',
timestamp: '', timestamp: '',
closed: false, closed: false,
currency: '',
price: 0, price: 0,
total: 0, total: 0,
totalZec: 0, totalZec: 0,

View file

@ -2,4 +2,9 @@ export interface Owner {
_id?: string; _id?: string;
address: string; address: string;
name: string; name: string;
currency: string;
tax: boolean;
taxValue: number;
vat: boolean;
vatValue: number;
} }

View file

@ -1,9 +1,18 @@
<h2 mat-dialog-title class="text">Settings</h2> <h2 mat-dialog-title class="text">Settings</h2>
<mat-dialog-content [formGroup]="settingsForm"> <mat-dialog-content [formGroup]="settingsForm">
<mat-form-field> <mat-form-field appearance="outline">
<mat-label>Name</mat-label>
<input matInput placeholder="Name" formControlName="name"> <input matInput placeholder="Name" formControlName="name">
</mat-form-field> </mat-form-field>
<mat-form-field appearance="outline">
<mat-label>Currency</mat-label>
<mat-select formControlName="currency">
<mat-option *ngFor="let coin of coins" [value]="coin.symbol">
{{coin.label}}
</mat-option>
</mat-select>
</mat-form-field>
</mat-dialog-content> </mat-dialog-content>
<mat-dialog-actions> <mat-dialog-actions>

View file

@ -14,6 +14,24 @@ export class SettingsComponent implements OnInit {
settingsForm: FormGroup; settingsForm: FormGroup;
owner: Owner; owner: Owner;
coins = [
{
label: 'US Dollar',
symbol: 'usd'
},{
label: 'Euro',
symbol: 'eur'
},{
label: 'British Pound',
symbol: 'gbp'
},{
label: 'Canadian Dollar',
symbol: 'cad'
},{
label: 'Australian Dollar',
symbol: 'aud'
}
];
constructor( constructor(
private fb: FormBuilder, private fb: FormBuilder,
@ -21,7 +39,8 @@ export class SettingsComponent implements OnInit {
@Inject(MAT_DIALOG_DATA) public data: Owner @Inject(MAT_DIALOG_DATA) public data: Owner
) { ) {
this.settingsForm = fb.group({ this.settingsForm = fb.group({
name: [data.name, Validators.required] name: [data.name, Validators.required],
currency: [data.currency, Validators.required]
}); });
this.owner = data; this.owner = data;
} }
@ -35,6 +54,7 @@ export class SettingsComponent implements OnInit {
save() { save() {
this.owner.name = this.settingsForm.value.name; this.owner.name = this.settingsForm.value.name;
this.owner.currency = this.settingsForm.value.currency;
this.dialogRef.close(this.owner); this.dialogRef.close(this.owner);
} }
} }

View file

@ -20,7 +20,12 @@ export class UserService{
}, },
owner: { owner: {
address: '', address: '',
name: '' name: '',
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
}, },
txs : [] txs : []
}; };
@ -112,7 +117,16 @@ export class UserService{
} }
addOwner(address: string) { addOwner(address: string) {
const owner: Owner={_id: '', address: address, name: 'Zgo-'.concat(address.substring(0,5))}; const owner: Owner={
_id: '',
address: address,
name: 'Zgo-'.concat(address.substring(0,5)),
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
};
let obs = this.http.post<{message: string}>(this.beUrl+'api/addowner', {address: owner.address, name: owner.name}, {headers: this.reqHeaders}); let obs = this.http.post<{message: string}>(this.beUrl+'api/addowner', {address: owner.address, name: owner.name}, {headers: this.reqHeaders});
obs.subscribe((responseData) => { obs.subscribe((responseData) => {

View file

@ -28,7 +28,16 @@ export class ViewerComponent implements OnInit {
pin: '', pin: '',
validated: false validated: false
}; };
private owner: Owner= {_id:'', address: 'none', name:''}; private owner: Owner= {
_id:'',
address: 'none',
name:'',
currency: 'usd',
tax: false,
taxValue: 0,
vat: false,
vatValue: 0
};
public addrUpdate: Observable<string>; public addrUpdate: Observable<string>;
public ownerUpdate: Observable<Owner>; public ownerUpdate: Observable<Owner>;
public userUpdate: Observable<User>; public userUpdate: Observable<User>;
@ -87,8 +96,9 @@ export class ViewerComponent implements OnInit {
const dialogRef = this.dialog.open(SettingsComponent, dialogConfig); const dialogRef = this.dialog.open(SettingsComponent, dialogConfig);
dialogRef.afterClosed().subscribe((val) => { dialogRef.afterClosed().subscribe((val) => {
if (val != null) { if (val != null) {
console.log('Saving settings'); //console.log('Saving settings', val);
this.userService.updateOwner(val); this.userService.updateOwner(val);
this.fullnodeService.getPrice(val.currency);
} }
}); });
} }