FilesExpand file tree

 master

/

RescriptApiNgClient.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

213 lines (177 loc) · 7.71 KB

 master

/

RescriptApiNgClient.js

Copy path

Top

File metadata and controls

• Code
• Blame

213 lines (177 loc) · 7.71 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

var https = require('https');

// Start the app

DemoApiNgClient();

// Main class that contains all operations

function DemoApiNgClient(){

// Retrieve command line args

var myArgs = process.argv.slice(2);

// App key

var appkey = myArgs[0];

// Session token

var ssid = myArgs[1];

var FIRST_INDEX = 0;

var DEFAULT_ENCODING = 'utf-8';

var DEFAULT_JSON_FORMAT = '\t';

function updateHeaders(operationName) {

return {

port: 443,

hostname: 'api.betfair.com/exchange/betting',

path: '/rest/v1.0/' + operationName + '/',

method: 'POST',

headers: {

'X-Application' : appkey,

'Accept': 'application/json',

'Content-type' : 'application/json',

'X-Authentication' : ssid

}

}

}

start();

// Start by finding the horse race event type id

function start() {

findHorseRaceId(updateHeaders('listEventTypes'));

}

// Construct request and POST it to API-NG

function findHorseRaceId(options) {

console.log("Get horse racing event id");

var str = '';

// Define Horse Racing in filter object

var requestFilters = '{"filter":{}}';

var req = https.request(options,function (res){

res.setEncoding(DEFAULT_ENCODING);

res.on('data', function (chunk) {

str += chunk;

});

res.on('end', function (chunk) {

// On resposne parse Json and check for errors

var response = JSON.parse(str);

handleError(res.statusCode, response);

// Retrieve id from response and get next available horse race

getNextAvailableHorseRace(updateHeaders('listMarketCatalogue'), response);

});

});

// Send Json request object

req.write(requestFilters, DEFAULT_ENCODING);

req.end();

req.on('error', function(e) {

console.log('Problem with request: ' + e.message);

});

}

// Get next horse race based on current date

function getNextAvailableHorseRace(options, response) {

// Retrieve event id from previous response

var eventId = retrieveEventId(response);

var jsonDate = new Date().toJSON();

console.log("Get next available horse race starting from date: " + jsonDate);

var str = '';

var requestFilters = '{"filter":{"eventTypeIds": [' + eventId + '],"marketCountries":["GB"],"marketTypeCodes":["WIN"],"marketStartTime":{"from":"'+jsonDate+'"}},"sort":"FIRST_TO_START","maxResults":"1","marketProjection":["RUNNER_DESCRIPTION"]}}';

var req = https.request(options,function (res){

res.setEncoding(DEFAULT_ENCODING);

res.on('data', function (chunk) {

str += chunk;

});

res.on('end', function (chunk) {

var response = JSON.parse(str);

handleError(res.statusCode, response);

// Get list of runners that are available in that race

getListOfRunners(updateHeaders('listMarketBook'), response);

});

});

req.write(requestFilters, DEFAULT_ENCODING);

req.end();

req.on('error', function(e) {

console.log('Problem with request: ' + e.message);

});

}

// Get next horse race based on current date

function getListOfRunners(options, response) {

var marketId = retrieveMarketId(response);

console.log("Get list of runners for market Id: " + marketId);

var str = '';

var requestFilters = '{"marketIds":["' + marketId + '"],"priceProjection":{"priceData":["EX_BEST_OFFERS"],"exBestOfferOverRides":{"bestPricesDepth":2,"rollupModel":"STAKE","rollupLimit":20},"virtualise":false,"rolloverStakes":false},"orderProjection":"ALL","matchProjection":"ROLLED_UP_BY_PRICE"}}';

var req = https.request(options,function (res){

res.setEncoding(DEFAULT_ENCODING);

res.on('data', function (chunk) {

str += chunk;

});

res.on('end', function (chunk) {

var response = JSON.parse(str);

handleError(res.statusCode, response);

// Place bet on first runner

placeBet(updateHeaders('placeOrders'), response, marketId);

});

});

req.write(requestFilters, DEFAULT_ENCODING);

req.end();

req.on('error', function(e) {

console.log('Problem with request: ' + e.message);

});

}

function placeBet(options, response, marketId) {

var selectionId = retrieveSelectionId(response);

console.log("Place bet on runner with selection Id: " + selectionId);

var str = '';

// Invalid price and size, change that to minimum price of 2.0

var price = '2';

var size = '0.01';

var customerRef = new Date().getMilliseconds();

var requestFilters = '{"marketId":"'+ marketId+'","instructions":[{"selectionId":"' + selectionId + '","handicap":"0","side":"BACK","orderType":"LIMIT","limitOrder":{"size":"' + size + '","price":"' + price + '","persistenceType":"LAPSE"}}],"customerRef":"'+customerRef+'"}}';

var req = https.request(options,function (res){

res.setEncoding(DEFAULT_ENCODING);

res.on('data', function (chunk) {

str += chunk;

});

res.on('end', function (chunk) {

var response = JSON.parse(str);

handleError(res.statusCode, response);

console.log(JSON.stringify(response, null, DEFAULT_JSON_FORMAT));

});

});

req.write(requestFilters, DEFAULT_ENCODING);

req.end();

req.on('error', function(e) {

console.log('Problem with request: ' + e.message);

});

}

// get selection id from the response

function retrieveSelectionId(response) {

return response[FIRST_INDEX].runners[FIRST_INDEX].selectionId;

}

// get event id from the response

function retrieveEventId(response) {

for (var i = 0; i<= response.length; i++ ) {

if (response[i].eventType.name == 'Horse Racing'){

return response[i].eventType.id;

}

}

}

// get market id from the response

function retrieveMarketId(response) {

return response[FIRST_INDEX].marketId;

}

// Handle Api-NG errors, exception details are wrapped within response object

function handleError(statusCode, response) {

// check for status code of the response

if(statusCode != 200) {

// if response contains exception retrieve details and log

if (Object.keys(response.detail).length != 0) {

console.log("Error with request: ");

console.log(JSON.stringify(response, null, DEFAULT_JSON_FORMAT));

console.log("Exception Details: ");

console.log(JSON.stringify(retrieveExceptionDetails(response), null, DEFAULT_JSON_FORMAT));

console.log("Exception Error Code: ");

console.log(JSON.stringify(retrieveExceptionErrorCode(response), null, DEFAULT_JSON_FORMAT));

}

// if error is thrown stop the app

process.exit(1);

}

}

// Get exception message out of a response object

function retrieveExceptionDetails(response) {

return response.detail.APINGException.errorDetails;

}

// Get exception error code out of a response object

function retrieveExceptionErrorCode(response) {

return response.detail.APINGException.errorCode;

}

}