]>
Commit | Line | Data |
---|---|---|
1 | package api | |
2 | ||
3 | import ( | |
4 | "fmt" | |
5 | ||
6 | "git.immae.eu/Cryptoportfolio/Front.git/db" | |
7 | ) | |
8 | ||
9 | type GetAllPortfoliosQuery struct { | |
10 | In struct { | |
11 | Market string | |
12 | } | |
13 | Out map[string]Portfolio | |
14 | } | |
15 | ||
16 | func (q GetAllPortfoliosQuery) ValidateParams() *Error { | |
17 | if q.In.Market != "poloniex" { | |
18 | return &Error{BadRequest, "invalid market name", fmt.Errorf("'%v' is not a valid market name", q.In.Market)} | |
19 | } | |
20 | ||
21 | return nil | |
22 | } | |
23 | ||
24 | func (q GetAllPortfoliosQuery) Run() (interface{}, *Error) { | |
25 | u, err := db.GetActiveUsers() | |
26 | if err != nil { | |
27 | return nil, NewInternalError(err) | |
28 | } | |
29 | ||
30 | q.Out = make(map[string]Portfolio) | |
31 | ||
32 | for _, marketConfig := range u { | |
33 | report, err := GetWeekPortfolio(marketConfig) | |
34 | if ErrorIs(err, NotFound) { | |
35 | continue | |
36 | } | |
37 | ||
38 | if err != nil { | |
39 | return nil, NewInternalError(err) | |
40 | } | |
41 | ||
42 | q.Out[marketConfig.User.Email] = report.Round() | |
43 | } | |
44 | ||
45 | return q.Out, nil | |
46 | } |