Skip to content

Feature cli #20

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
BitHighlander wants to merge 2 commits into
base: master
Choose a base branch
from
Open

Feature cli #20

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
8ec1d04
pre-new desktop miner
BitHighlander Sep 5, 2020
fadc5c5
cli working
BitHighlander Sep 6, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 10 additions & 2 deletions apps/fomo-cli/package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,29 +6,37 @@
"fomobot": "./lib/index.js"
},
"scripts": {
"start": "nodemon --watch 'src/**/*.ts' --exec ts-node src/index.ts run --strategy ta_ultosc --leverage 6",
"start": "nodemon --watch 'src/**/*.ts' --exec ts-node src/index.ts",
"create": "npm run build && npm run test",
"build": "tsc -p .",
"test": "sudo npm i -g && pizza",
"refresh": "rm -rf ./node_modules ./package-lock.json && npm install"
},
"dependencies": {
"@fomobro/fomo-api": "^6.2.6",
"@fomobro/fomo-sim": "^1.0.1",
"@fomobro/fomo-wallet": "0.0.1",
"@fomobro/fomobot": "^1.0.21",
"@fomobro/loggerdog-client": "latest",
"bcryptjs": "^2.4.3",
"bitmex-realtime-api": "^0.4.3",
"chalk": "^4.0.0",
"clear": "^0.1.0",
"commander": "^5.0.0",
"crypto-js": "^4.0.0",
"cryptr": "^4.0.2",
"default-logger": "0.0.2",
"describe-export": "^1.0.0",
"figlet": "^1.3.0",
"find-package-json": "^1.2.0",
"fs-extra": "^9.0.0",
"inquirer": "^7.3.3",
"light-event-bus": "^1.0.1",
"loggerdog-client": "0.0.4",
"monk": "^7.1.2",
"path": "^0.12.7"
"path": "^0.12.7",
"uuid": "^8.3.0",
"vorpal": "^1.12.0"
},
"devDependencies": {
"@types/node": "^13.11.1",
Expand Down
351 changes: 351 additions & 0 deletions apps/fomo-cli/src/app.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,351 @@
/*
Pioneer APP
*/

const TAG = " | app | ";

import axios from "axios";
import {
getConfig,
getWallet, updateConfig,
} from "./modules/config";

let keyTools = require("@fomobro/fomo-wallet")
const Cryptr = require("cryptr");
// const CryptoJS = require("crypto-js");
// const bip39 = require(`bip39`);
//
// const fs = require("fs-extra");
let fomo = require("@fomobro/fomo-api")
const bot = require("@fomobro/fomobot")
const log = require("loggerdog-client")();
const BitMEXClient = require('bitmex-realtime-api');
// let Table = require('cli-table');
// const chalk = require("chalk");
// const figlet = require("figlet");
// const clear = require("clear");
// const request = require('request')
const db = require('monk')('localhost/zenbot4')
const wait = require('wait-promise');
const chalk = require('chalk');
const tradesDB = db.get('trades')
const sleep = wait.sleep;

let USERNAME = ''
let ACCOUNT = ''
let API_KEY = ''
let WALLET_PASSWORD:any = ""
let WALLET_SEED:string
let STRATERGY:string = 'bollinger'
let LAST_PRICE:any
//chingle
// let opts:any = {}
// var player = require('play-sound')(opts = {})

let strategies = [
'forex_analytics',
'bollinger',
'cci_srsi',
'crossover_vwap',
'dema',
'ichimoku_score',
'ichimoku',
'speed',
'wavetrend',
'trust_distrust',
'ta_ultosc',
'stddev',
'trendline',
'renko'
]




module.exports = {
init: function (config: any, wallet: any, password:string) {
return init_wallet(config,wallet,password);
},
setPassword: function (pw: string) {
WALLET_PASSWORD = pw;
return true;
},
run: async function () {
onRun()
return true
},
getInfo: async function () {
return fomo.getInfo()
},
goBull: async function () {
return buy_signal()
},
goBear: async function () {
return sell_signal()
},
newUsername: async function (username:string) {
return change_username(username)
},
getApiKeys: async function () {
return {ACCOUNT,API_KEY}
},
signUp: async function () {
return sign_up()
},
lastPrice: async function () {
return LAST_PRICE
},
currentStrategy: async function () {
return STRATERGY
},
strategys: async function () {
return strategies.toString()
},
makePrediction: async function (coin:string,time:string,price:string) {
return make_prediction(coin,time,price)
},
setStrategy: async function (strategy:string) {
if(strategies.indexOf(strategy) >= 0){
STRATERGY = strategy
return strategy
} else {
return "unknown strategy "+strategies.toString()
}
},
getConfig: function () {
return getConfig();
},
viewSeed: function () {
return WALLET_SEED;
}
};

let sell_signal = async function () {
let tag = " | sell_signal | ";
try {
//predict .001 pct loss in 10min
log.info(tag,"LAST_PRICE: ",LAST_PRICE)
let predictPrice = LAST_PRICE - (LAST_PRICE * 0.001)
let inTenMinutes = new Date().getTime() + (1000 * 60 * 10)
log.info(tag,"predictPrice: ",predictPrice)

let result = await make_prediction("BTC",inTenMinutes.toString(),predictPrice.toString())

return result
} catch (e) {
log.error(tag, "Error: ", e);
throw e;
}
};

let buy_signal = async function () {
let tag = " | make_prediction | ";
try {
//predict .001 pct loss in 10min
log.info(tag,"LAST_PRICE: ",LAST_PRICE)
let predictPrice = LAST_PRICE + (LAST_PRICE * 0.001)
let inTenMinutes = new Date().getTime() + (1000 * 60 * 10)
log.info(tag,"predictPrice: ",predictPrice)

let result = await make_prediction("BTC",inTenMinutes.toString(),predictPrice.toString())

return result
} catch (e) {
log.error(tag, "Error: ", e);
throw e;
}
};

let sign_up = async function () {
let tag = " | make_prediction | ";
try {
log.info(tag, "USERNAME,ACCOUNT: ",{USERNAME,ACCOUNT});

//create account
let signup = await fomo.create(USERNAME,ACCOUNT)
log.info("signup success! ",signup)

return signup;
} catch (e) {
log.error(tag, "Error: ", e);
throw e;
}
};

let change_username = async function (username:string) {
let tag = " | make_prediction | ";
try {
log.info(tag, "username: ",username);

let result = updateConfig({username});

return result;
} catch (e) {
log.error(tag, "Error: ", e);
throw e;
}
};


let make_prediction = async function (coin:string,time:string,price:string) {
let tag = " | make_prediction | ";
try {
log.info(tag, "checkpoint: ");

let prediction = {
coin,
time,
price
}

let predictionResult = await fomo.predict(prediction)
console.log("predictionResult: ",predictionResult)

return predictionResult;
} catch (e) {
log.error(tag, "Error: ", e);
throw e;
}
};


let onRun: (this: any) => Promise<void>;
onRun = async function (this: any) {
let tag = TAG + " | onRun | "
try {
//get strat
log.info(tag, "strategy: ", STRATERGY)
let engine = await bot.init(STRATERGY);
await sleep(4000);

//get recent history
let allTrades = await tradesDB.find({selector: "bitmex.BTC-USD"}, {limit: 10000, sort: {time: -1}})
log.info(tag, "total trades: ", allTrades.length)

//Load trades to engine
chalk.blue(
" Loading trades into the Fomo engine! "
)
bot.load(allTrades)
await sleep(6000);

// @ts-ignore
engine.on('events', async message => {
//event triggerd
log.info("**** Signal event: **** ", message)
if (message.signal === "sell") {
sell_signal()

} else if (message.signal === "buy") {
//goBull
buy_signal()

} else {
log.error("Unknown Signal! message: ", message)
}
});
const client = new BitMEXClient();
//sub to trades
client.addStream('XBTUSD', 'trade', function (data: any, symbol: any, tableName: any) {
log.debug(tag, "Stream: ", data, symbol, tableName)


let clean = []
for (let i = 0; i < data.length; i++) {
let tradeInfo = data[i]
let normalized: any = {}
normalized.trade_id = tradeInfo.trdMatchID
normalized.time = new Date(tradeInfo.timestamp).getTime()
normalized.unix = new Date(tradeInfo.timestamp).getTime()
normalized.size = tradeInfo.size
normalized.side = tradeInfo.side
normalized.price = tradeInfo.price
LAST_PRICE = tradeInfo.price
clean.push(normalized)
}
bot.load(clean)
})
} catch (e) {
log.error(tag, e)
throw Error(e)
}
};

// let onBackfill = async function(){
// let tag = TAG + " | onBackfill | "
// try{
// //get backfill status
//
// //if not done, backfill
//
// }catch(e){
// log.error(tag,e)
// throw Error(e)
// }
// }


let init_wallet = async function (config:any,wallet:any,password:string) {
let tag = " | init_wallet | ";
try {
log.info(tag, "checkpoint: ");
log.info(tag, "config username: ",config.username);
log.info(tag, "password: ",password);
log.info(tag, "wallet: ",wallet);
let output: any = [];
const cryptr = new Cryptr(password);

let walletInfo = await getWallet()
log.debug(tag,"walletInfo: ",walletInfo)
//get seed
let seed = cryptr.decrypt(walletInfo.vault)
WALLET_SEED = seed
log.debug(tag,"seed: ",seed)
//init client
let apiKeys = await keyTools.onBuildWallet(seed);
log.debug(tag,"apiKeys: ",apiKeys)

USERNAME = config.username
ACCOUNT = apiKeys.account
API_KEY = apiKeys.apiKey

let urlSpec = process.env['URL_FOMO_SPEC'] || "https://fomobro.com/spec/swagger.json"
await fomo.init(urlSpec,{apiKey:apiKeys.account})

//health
let health = await fomo.health()
console.log("health: ",health)

//user info
let userInfo = await fomo.getUser(config.username)
console.log("health: ",health)

//if available
if(userInfo.isAvailable){
//signup
//create account
let signup = await fomo.create(config.username,apiKeys.account)
log.info("signup success! ",signup)

} else {
//verify ownership
let userInfoPrivate = await fomo.getInfo()
log.info("userInfoPrivate: ",userInfoPrivate)

if(userInfoPrivate.account === apiKeys.account){
log.info("Account info valid!")
} else {
log.info(tag,"userInfoPrivate.account: ",userInfoPrivate.account)
log.info(tag,"apiKeys.account: ",apiKeys.account)
//if fail/change username
log.error(tag," Account does NOT match username! ERROR! recover or make new username to continue! ")
}
}


return true;
} catch (e) {
log.error(tag, "Error: ", e);
throw e;
}
};
Loading