WebBack/route_explore.go at main · TradingLabXYZ/WebBack · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
package main

import (
	"net/http"
	"strconv"

	"github.com/gorilla/mux"
	log "github.com/sirupsen/logrus"
)

func SelectExplore(w http.ResponseWriter, r *http.Request) {
	offset_string := mux.Vars(r)["offset"]
	offset, err := strconv.Atoi(offset_string)
	if offset%10 != 0 || err != nil {
		log.Warn("Attempted accessing Explore with invalid offset")
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	explore_sql := `
		WITH
			SUBTRADES AS (
				SELECT
					'subtrade' AS eventtype,
					s.tradecode,
					s.updatedat,
					CASE
						WHEN EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60 < 1
							THEN ROUND(EXTRACT(EPOCH FROM (NOW() - s.updatedat)))::TEXT || ' seconds ago'
						WHEN (EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60 > 1) AND (EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60 < 60)
							THEN ROUND(EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60)::TEXT || ' minutes ago'
						WHEN (EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60 >= 60) AND (EXTRACT(EPOCH FROM(NOW() - s.updatedat)) / 60 < 1440)
							THEN ROUND(EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60 / 60)::TEXT || ' hours ago'
						ELSE CEIL(EXTRACT(EPOCH FROM (NOW() - s.updatedat)) / 60 / 60 / 60)::TEXT || ' days ago'
					END AS timeago,
					s.userwallet,
					s.type,
					s.reason,
					CASE
						WHEN s.quantity > 100 THEN TO_CHAR(s.quantity, '999,999,999')
						WHEN s.quantity > 1 THEN RTRIM(RTRIM(TO_CHAR(s.quantity, '999,999,999.00'), '0'), '.')
						ELSE RTRIM(RTRIM(TO_CHAR(s.quantity, '999,999,999.00000'), '0'), '.')
					END as quantity,
					CASE
						WHEN s.avgprice > 100 THEN TO_CHAR(s.avgprice, '999,999,999')
						WHEN s.avgprice > 1 THEN TO_CHAR(s.avgprice, '999,999,999.00')
						ELSE TO_CHAR(s.avgprice, '999,999,999.00000')
					END as avgprice,
					CASE
						WHEN s.total > 100 THEN TO_CHAR(s.total, '999,999,999')
						WHEN s.total > 1 THEN TO_CHAR(s.total, '999,999,999.00')
						ELSE TO_CHAR(s.total, '999,999,999.00000')
					END as total,
					u.profilepicture,
					t.firstpair,
					'https://s2.coinmarketcap.com/static/img/coins/32x32/' || t.firstpair::TEXT || '.png' AS firstpairurlicon,
					c1.symbol AS firstpairsymbol,
					t.secondpair,
					'https://s2.coinmarketcap.com/static/img/coins/32x32/' || t.secondpair::TEXT || '.png' AS secondpairurlicon,
					c2.symbol AS secondpairsymbol,
					CASE
						WHEN (l2.price / l1.price)  > 100 THEN TO_CHAR((l2.price / l1.price), '999,999,999')
						WHEN (l2.price / l1.price)  > 1 THEN TO_CHAR((l2.price / l1.price), '999,999,999.00')
						ELSE TO_CHAR((l2.price / l1.price), '999,999,999.00000')
					END as currentprice,
					ROUND(((((l2.price / l1.price) / s.avgprice) - 1) * 100), 1) AS deltapriceperc
				FROM subtrades s
				LEFT JOIN trades t ON(s.tradecode = t.code)
				LEFT JOIN users u ON(s.userwallet = u.wallet)
				LEFT JOIN lastprices l1 ON(t.firstpair = l1.coinid)
				LEFT JOIN lastprices l2 ON(t.secondpair = l2.coinid)
				LEFT JOIN coins c1 ON(l1.coinid = c1.coinid)
				LEFT JOIN coins c2 ON(l2.coinid = c2.coinid)
				ORDER BY s.updatedat DESC
				LIMIT 10
				OFFSET $1),
			events AS (
				SELECT
					userwallet,
					updatedat,
					ROW_TO_JSON(subtrades) AS row_json
				FROM SUBTRADES)
		SELECT
			json_agg(row_json)
		FROM events c;`

	var explore_json string
	err = Db.QueryRow(explore_sql, offset).Scan(&explore_json)
	if err != nil {
		w.Write([]byte("{}"))
		return
	}
	w.Write([]byte(explore_json))
}