chore: add install_all_deps.sh; upgrade sqlx; change persist policy t…

…o MQ only (#72)

Cargo.toml

@@ -26,7 +26,7 @@ crossbeam-channel = "0.5.0"
 rdkafka = { version = "0.25.0", features = ["cmake-build"] }
 nix = "0.19.1"
 anyhow = "1.0.38"
-sqlx = { git = "https://github.com/launchbadge/sqlx.git", features=["runtime-tokio-rustls", "postgres", "chrono", "decimal", "json", "migrate" ]  }
+sqlx = { version = "0.5.1", features=["runtime-tokio-rustls", "postgres", "chrono", "decimal", "json", "migrate" ]  }
 chrono = { version = "0.4.19", features = ["serde"] }
 rust_decimal = { version = "1.10.1", features = ["postgres", "bytes", "byteorder"] }
 rust_decimal_macros = "1.10.1"

scripts/install_all_deps.sh

@@ -0,0 +1,48 @@
+#!/bin/bash
+set -xu
+
+function install_rust() {
+	echo 'install rust'
+	curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
+}
+
+function install_docker() {
+	echo 'install docker'
+	curl -fsSL https://get.docker.com | bash
+	sudo groupadd docker
+	sudo usermod -aG docker $USER
+	newgrp docker
+	sudo systemctl start docker
+	sudo systemctl enable docker
+}
+
+function install_docker_compose() {
+	echo 'install docker compose'
+	sudo curl -L "https://github.com/docker/compose/releases/download/1.28.2/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
+	sudo chmod +x /usr/local/bin/docker-compose
+}
+
+function install_node() {
+	echo 'install node'
+	curl -o- https://raw.githubusercontent.com/nvm-sh/nvm/v0.37.2/install.sh | bash
+	export NVM_DIR="$HOME/.nvm"
+	[ -s "$NVM_DIR/nvm.sh" ] && \. "$NVM_DIR/nvm.sh"  # This loads nvm
+	nvm install 'lts/*'
+	nvm use 'lts/*'
+	npm install --global yarn
+}
+
+function install_sys_deps() {
+	echo 'install system deps'
+	sudo apt install libpq-dev cmake gcc g++ postgresql-client-12
+}
+
+function install_all() {
+	install_sys_deps
+	install_rust
+	install_docker
+	install_docker_compose
+	install_node
+}
+
+install_all

src/config.rs

@@ -96,7 +96,7 @@ impl Default for Settings {
             debug: false,
             db_log: Default::default(),
             db_history: Default::default(),
-            history_persist_policy: PersistPolicy::Both,
+            history_persist_policy: PersistPolicy::ToMessage,
             assets: Vec::new(),
             markets: Vec::new(),
             consumer_group: "kline_data_fetcher".to_string(),