fmpcloud-go/alternative_data.go at master · spacecodewor/fmpcloud-go · 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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
package fmpcloud

import (
	"fmt"
	"time"

	jsoniter "github.com/json-iterator/go"
	"github.com/spacecodewor/fmpcloud-go/objects"
)

// Url const for request
const (
	urlAPIAlternativeDataCommitmentOfTradersReportPeriod         = "/v4/commitment_of_traders_report"
	urlAPIAlternativeDataCommitmentOfTradersReportSymbol         = "/v4/commitment_of_traders_report/%s"
	urlAPIAlternativeDataCommitmentOfTradersReportPeriodAnalysis = "/v4/commitment_of_traders_report_analysis"
	urlAPIAlternativeDataCommitmentOfTradersReportSymbolAnalysis = "/v4/commitment_of_traders_report_analysis/%s"
	urlAPIAlternativeDataCommitmentOfTradersReportList           = "/v4/commitment_of_traders_report/list"
)

// AlternativeData client
type AlternativeData struct {
	Client *HTTPClient
}

// COTSymbolList - COT Trading Symbols List
func (a *AlternativeData) COTSymbolList() (sList []objects.COTSymbol, err error) {
	data, err := a.Client.Get(urlAPIAlternativeDataCommitmentOfTradersReportList, nil)
	if err != nil {
		return nil, err
	}

	err = jsoniter.Unmarshal(data.Body(), &sList)
	if err != nil {
		return nil, err
	}

	return sList, nil
}

// COTReportBySymbol - List of reports for specific symbol
func (a *AlternativeData) COTReportListBySymbol(symbol string) (rList []objects.COTReport, err error) {
	data, err := a.Client.Get(fmt.Sprintf(urlAPIAlternativeDataCommitmentOfTradersReportSymbol, symbol), nil)
	if err != nil {
		return nil, err
	}

	err = jsoniter.Unmarshal(data.Body(), &rList)
	if err != nil {
		return nil, err
	}

	return rList, nil
}

// COTReportListByPeriod - List of reports for period of time
func (a *AlternativeData) COTReportListByPeriod(from, to *time.Time) (rList []objects.COTReport, err error) {
	reqParam := make(map[string]string)
	if from != nil {
		reqParam["from"] = from.Format("2006-01-02")
	}

	if to != nil {
		reqParam["to"] = to.Format("2006-01-02")
	}

	data, err := a.Client.Get(urlAPIAlternativeDataCommitmentOfTradersReportPeriod, reqParam)
	if err != nil {
		return nil, err
	}

	err = jsoniter.Unmarshal(data.Body(), &rList)
	if err != nil {
		return nil, err
	}

	return rList, nil
}

// COTAnalysisListBySymbol - Analysis of reports for trading symbol
func (a *AlternativeData) COTAnalysisListBySymbol(symbol string) (aList []objects.COTAnalysis, err error) {
	data, err := a.Client.Get(fmt.Sprintf(urlAPIAlternativeDataCommitmentOfTradersReportSymbolAnalysis, symbol), nil)
	if err != nil {
		return nil, err
	}

	err = jsoniter.Unmarshal(data.Body(), &aList)
	if err != nil {
		return nil, err
	}

	return aList, nil
}

// COTAnalysisListByPeriod - Analysis of reports for time period
func (a *AlternativeData) COTAnalysisListByPeriod(from, to *time.Time) (aList []objects.COTAnalysis, err error) {
	reqParam := make(map[string]string)
	if from != nil {
		reqParam["from"] = from.Format("2006-01-02")
	}

	if to != nil {
		reqParam["to"] = to.Format("2006-01-02")
	}

	data, err := a.Client.Get(urlAPIAlternativeDataCommitmentOfTradersReportPeriodAnalysis, reqParam)
	if err != nil {
		return nil, err
	}

	err = jsoniter.Unmarshal(data.Body(), &aList)
	if err != nil {
		return nil, err
	}

	return aList, nil
}