v3

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2018 Validator.Center
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,5 @@
+# PRS3R - Parser the Minter in DB:ClickHouse/Redis
+
+## About
+
+Actual for [Minter Blockchain](https://minter.network) version 0.18.x.

app_block.go

@@ -0,0 +1,75 @@
+package main
+
+import (
+	"fmt"
+)
+
+// получение сколько всего блоков в блокчейне
+func MinterLatestBlock() (int, error) {
+	sts, err := sdk.GetStatus()
+	if err != nil {
+		return 0, err
+	}
+	log("INF", "INIT", fmt.Sprintf("Последний блок в Minter.Network: %d", sts.LatestBlockHeight))
+
+	return sts.LatestBlockHeight, nil
+}
+
+// Модуль обработки БЛОКОВ
+func appBlocks() {
+	var err error
+	amntN_block, err = MinterLatestBlock()
+	if err != nil {
+		log("ERR", fmt.Sprint("[app_block.go] appBlocks(MinterLatestBlock) - ", err), "")
+		// Прерывать, скорее всего количество запросов к API превысили!!!
+		// FIXME: надо как-то более корректно обрабатывать, чтобы не вылетало а просто ждало!
+		return
+	}
+
+	// получаем системуную коллекцию
+	st0 := srchSysSql(dbSys)
+	log("INF", "INIT", fmt.Sprintf("Последний блок в БД: %d", st0.LatestBlockSave))
+	actN_block := st0.LatestBlockSave + 1 // загружаем следующий блок!
+
+	for i := actN_block; i <= amntN_block; i++ {
+		log("INF", "LOAD", fmt.Sprintf("=== БЛОК %d из %d", i, amntN_block))
+
+		// получаем блок по номеру i с блокчейна
+		retBlck, err := sdk.GetBlock(i)
+		if err != nil {
+			log("ERR", fmt.Sprint("[app_block.go] appBlocks(sdk.GetBlock) - ", err), "")
+			panic(err)
+		}
+
+		if retBlck.Hash == "" {
+			log("ERR", fmt.Sprint("[app_block.go] appBlocks(retBlck.Hash) => ПУСТО!"), "")
+			//return false
+			continue
+		}
+
+		// Отправляем воркеру на отработку Блока (там - же: Транзакция и Валидаторы-пропуск)
+		worketInputBlock <- retBlck
+
+		// Цикл по транзакциям...
+		for _, retTrx := range retBlck.Transactions {
+			// нужно передовать ДатуБлока(+),НомерБлока(+) и тело одной транзакции(+)
+			if retTrx.Hash != "" {
+				oneTrxX := TrxExt{TransResponse: retTrx}
+				oneTrxX.Height = retBlck.Height // высота блока
+				oneTrxX.Created = retBlck.Time
+
+				worketInputTrx <- oneTrxX
+			}
+		}
+
+		// Цикл по валидаторам, проверка пропуска и запись в node_blockstory
+		for _, retB1node := range retBlck.Validators {
+			oneBlockNodeX := B1NExt{BlockValidatorsResponse: retB1node}
+			oneBlockNodeX.Height = uint32(retBlck.Height) // высота блока
+			worketInputBNode <- oneBlockNodeX
+		}
+
+		// Обработка событий по номеру блока
+		worketInputBEvnt <- uint32(retBlck.Height)
+	}
+}

app_coin.go

@@ -0,0 +1,201 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"time"
+
+	ms "github.com/ValidatorCenter/minter-go-sdk"
+	s "github.com/ValidatorCenter/prs3r/strc"
+)
+
+// Обработка транзакции создания Монеты
+func trxCreateCoin(retTrns *TrxExt) {
+	dt5CrtCoin := s.Tx5CreateCoinData{}
+	jsonBytes, _ := json.Marshal(retTrns.Data)
+	json.Unmarshal(jsonBytes, &dt5CrtCoin)
+
+	coinMCD := s.CoinMarketCapData{
+		Name:                 dt5CrtCoin.Name,
+		CoinSymbol:           dt5CrtCoin.CoinSymbol,
+		Time:                 retTrns.Created,
+		Creator:              retTrns.From,
+		InitialAmount:        dt5CrtCoin.InitialAmount,
+		InitialReserve:       dt5CrtCoin.InitialReserve,
+		ConstantReserveRatio: dt5CrtCoin.ConstantReserveRatio,
+	}
+
+	// добавляем монету в SQL
+	if !addCoinSql(dbSQL, &coinMCD) {
+		log("ERR", "[app_coin.go] startWorkerTrx(addCoinSql)", "")
+	}
+	// добавляем монету в Redis
+	if !updCoinInfoRds(dbSys, &coinMCD) {
+		log("ERR", "[app_coin.go] startWorkerTrx(updCoinInfoRds)", "")
+	}
+	log("OK", fmt.Sprintf("Монета: %s (%s)", dt5CrtCoin.CoinSymbol, dt5CrtCoin.Name), "")
+}
+
+// Обработка транзакций покупки/продажи Монет
+func trxSellBuyCoin(retTrns *TrxExt) {
+	addCoin := s.CoinActionpData{
+		Hash: retTrns.Hash,    // Хэш транзакции
+		Time: retTrns.Created, // дата движения
+		Type: retTrns.Type,    // type: продажа или покупка
+	}
+
+	// разбор движения для пары: монета и фиат(mnt)
+	if addCoin.Type == ms.TX_SellCoinData { //SELL
+		dtS := s.Tx2SellCoinData{}
+		jsonBytes, _ := json.Marshal(retTrns.Data)
+		json.Unmarshal(jsonBytes, &dtS)
+
+		addCoin.CoinToBuy = dtS.CoinToBuy   // Монета покупки
+		addCoin.CoinToSell = dtS.CoinToSell // Монета продажи
+		addCoin.ValueToSell = dtS.ValueToSell
+		addCoin.ValueToBuy = retTrns.Tags.TxReturn
+
+	} else if addCoin.Type == ms.TX_BuyCoinData { //BUY
+		dtS := s.Tx4BuyCoinData{}
+		jsonBytes, _ := json.Marshal(retTrns.Data)
+		json.Unmarshal(jsonBytes, &dtS)
+
+		addCoin.CoinToBuy = dtS.CoinToBuy   // Монета покупки
+		addCoin.CoinToSell = dtS.CoinToSell // Монета продажи
+		addCoin.ValueToBuy = dtS.ValueToBuy
+		addCoin.ValueToSell = retTrns.Tags.TxReturn
+
+	} else { //ms.TX_SellAllCoinData (как ms.TX_SellCoinData) SELL_ALL
+		dtS := s.Tx3SellAllCoinData{}
+		jsonBytes, _ := json.Marshal(retTrns.Data)
+		json.Unmarshal(jsonBytes, &dtS)
+
+		addCoin.CoinToBuy = dtS.CoinToBuy   // Монета покупки
+		addCoin.CoinToSell = dtS.CoinToSell // Монета продажи
+		addCoin.ValueToBuy = retTrns.Tags.TxReturn
+		addCoin.ValueToSell = retTrns.Tags.TxSellAmount
+	}
+
+	calcCoin(&addCoin)
+
+	if !addCoinTrxSql(dbSQL, &addCoin) {
+		log("ERR", "[app_coin.go] startWorkerTrx(addCoinTrxSql)", "")
+	}
+
+	// Пересчет с2с
+	calcCoin2Coin(addCoin.CoinToSell, addCoin.CoinToBuy)
+}
+
+// Расчет движения за 24ч для пары монет
+func calcCoin2Coin(tickerS, tickerB string) {
+	var mPCL s.PairCoins
+	// 1) Запос с базы coin_trx движения за последние 24ч пары монет, не
+	// зависемо от направления пары
+	now := time.Now()
+	lt24 := now.Add(-time.Duration(24) * time.Hour)
+	allC2cTrx, err := srchCoin2CoinTrxSql(dbSQL, tickerS, tickerB, lt24, now)
+	if err != nil {
+		log("ERR", fmt.Sprint("[w_trx.go] calcCoin2Coin(srchCoin2CoinTrxSql) -", err), "")
+		return
+	}
+
+	// 2) Расчет
+	mPCL.CoinToSell = tickerS
+	mPCL.CoinToBuy = tickerB
+	mPCL.TimeUpdate = time.Now()
+	mPCL.PriceBuy, mPCL.PriceSell = CoinPriceNow(mPCL.CoinToBuy, mPCL.CoinToSell)
+
+	for _, tr1 := range allC2cTrx {
+		mPCL.Volume24 += tr1.Volume
+		// т.к. отсортированы по дате, то первая цена нам и нужна
+		if mPCL.PriceBuyOld == 0.0 {
+			mPCL.PriceBuyOld = tr1.Price
+		}
+	}
+
+	// Как регулируется первая продажа??? старая 0, новая 20 => 100%??? НЕТ,
+	// будет считаться как установка цены значит должен быть 0%
+	if mPCL.PriceBuyOld != 0.0 {
+		mPCL.Change24 = ((mPCL.PriceBuy - mPCL.PriceBuyOld) / mPCL.PriceBuyOld) * 100
+	} else {
+		mPCL.Change24 = 0
+	}
+
+	// 3) Заносим в MEM
+	if !updCoin2Redis(dbSys, &mPCL) {
+		log("ERR", "[w_trx.go] calcCoin2Coin(updCoin2Redis)", "")
+	}
+
+	////////////////////////////////////////////////////////////////////////////
+	// получаем информацию о монете с блокчейна - а точнее нас интересует
+	// текущий из БЧейна: объем и баланс резерва
+	for _, tickerX := range []string{tickerB, tickerS} {
+		if tickerX != CoinMinter { // за исключением дефолтной монеты системы
+			coin1 := s.CoinMarketCapData{CoinSymbol: tickerX}
+			iCn, err := sdk.GetCoinInfo(coin1.CoinSymbol)
+			if err != nil {
+				log("ERR", fmt.Sprint("[w_trx.go] calcCoin2Coin(GetCoinInfo)", coin1.CoinSymbol, " - ERR:", err), "")
+				continue
+			}
+
+			coin1.TimeUpdate = time.Now()
+			coin1.VolumeNow = iCn.Volume
+			coin1.ReserveBalanceNow = iCn.ReserveBalance
+
+			if !updCoinInfoRds_3(dbSys, &coin1) {
+				log("ERR", "[w_trx.go] calcCoin2Coin(updCoinInfoRds_3)", "")
+			}
+		}
+	}
+}
+
+// получение "текущей" стоимости монеты: покупки, продажи (TODO: относительно другой монеты)
+func CoinPriceNow(coinSmbl string, coinSmbl2 string) (float32, float32) {
+	dataB, err := sdk.EstimateCoinBuy(coinSmbl, coinSmbl2, 1)
+	if err != nil {
+		log("ERR", fmt.Sprint("[coin2coin_mdb.go] sdk.EstimateCoinBuy ", coinSmbl, "/", coinSmbl2, " - ", err), "")
+		//panic(err)
+	}
+	dataS, err := sdk.EstimateCoinSell(coinSmbl, coinSmbl2, 1)
+	if err != nil {
+		log("ERR", fmt.Sprint("[coin2coin_mdb.go] sdk.EstimateCoinSell ", coinSmbl, "/", coinSmbl2, " - ", err), "")
+		//panic(err)
+	}
+	return dataB.WillPay, dataS.WillGet
+}
+
+// Расчет стоимости монеты
+func calcCoin(addCoin *s.CoinActionpData) {
+	// FIXME: реализовано движение для монета и фиат(mnt) А НУЖНО ДЛЯ ВСЕХ!
+	// в коде идет проверка для кастомной-монеты к MNT/BIP(CoinMinter)
+	// хотя код не совсем корректен, т.к. если первая не MNT то она будет
+	// второй монетой точно, хотя это не так, может быть ETH/BTC, а не ETH/MNT
+	var fAmntMNT float32 = 0.0
+	var fAmntToken float32 = 0.0
+
+	if addCoin.Type == ms.TX_SellCoinData { //SELL
+		if addCoin.CoinToBuy == CoinMinter {
+			fAmntMNT = addCoin.ValueToBuy
+			fAmntToken = addCoin.ValueToSell
+		} else {
+			fAmntMNT = addCoin.ValueToSell
+			fAmntToken = addCoin.ValueToBuy
+		}
+
+	} else if addCoin.Type == ms.TX_BuyCoinData { //BUY
+		fAmntMNT = addCoin.ValueToSell
+		fAmntToken = addCoin.ValueToBuy
+
+	} else { //ms.TX_SellAllCoinData (как ms.TX_SellCoinData) SELL_ALL
+		if addCoin.CoinToBuy == CoinMinter {
+			fAmntMNT = addCoin.ValueToBuy
+			fAmntToken = addCoin.ValueToSell
+		} else {
+			fAmntMNT = addCoin.ValueToSell
+			fAmntToken = addCoin.ValueToBuy
+		}
+	}
+	// вычесляем цену одной монеты
+	addCoin.Price = fAmntMNT / fAmntToken // сумма/количесво
+	addCoin.Volume = fAmntMNT
+}