Notify Bitcoin Asset Status to Slack Using bitFlyer's Private API Part 2

#bitflyer #api #async #bitcoin

This article was originally published on bmf-tech.com.

Last time, I just hit the bitFlyer API and left it at that, so this time I'll format the response data and send it to Slack as asset information data.

Asynchronous Processing with async

Since I needed to hit multiple APIs, I used async. The error handling part is mimicked from a reference site (which I forgot). The code has become somewhat hard to read...

var request = require('request');
var crypto = require('crypto');
var async = require('async');

var key = 'YOUR_KEY';
var secret = 'YOUR_SECRET';

var timestamp = Date.now().toString();
var sign = crypto.createHmac('sha256', secret).update(timestamp + 'GET' + '/v1/me/getbalance').digest('hex');

var requests = [{
    url: 'https://api.bitflyer.jp/v1/me/getbalance',
    headers: {
        'ACCESS-KEY': key,
        'ACCESS-TIMESTAMP': timestamp,
        'ACCESS-SIGN': sign,
        'Content-Type': 'application/json'
    }
}, {
    url: 'https://api.bitflyer.jp/v1/getexecutions'
}];

async.map(requests, function(obj, callback) {
    request(obj, function(error, response, body) {
        if (!error && response.statusCode == 200) {
            var body = JSON.parse(body);
            callback(null, body);
        } else {
            callback(error || response.statusCode);
        }
    });
}, function(err, results) {
    if (err) {
        console.log(err);
    } else {
        var jpy_available = parseInt(results[0][0]['available']);
        var btc_available = results[0][1]['available'];
        var price = parseInt(results[1][1]['price']);
        var total_assets = Math.floor(btc_available*price);

        var data = JSON.stringify({
            "attachments": [{
                "fallback": "bitflyer Asset Information",
                "color": "danger",
                "title": "bitflyer Asset Information",
                "text": "The BTC you currently hold is " + btc_available + ".",
                "fields": [{
                    "title": "Total BTC Assets",
                    "value": total_assets,
                    "short": true
                }, {
                    "title": "JPY (Balance)",
                    "value": jpy_available + ' yen',
                    "short": true
                }]
            }],
            "username": "your-bot-name",
            "icon_url": "/path/to/img",
            "channel": "#yourslackchannel"
        });

        var options = {
            url: 'https://hooks.slack.com/services/WEBHOOK_TOKEN',
            form: 'payload=' + data,
            json: true
        };

        request.post(options, function(error, response, body) {
            if (!error && response.statusCode == 200) {
                console.log(body.name);
            } else {
                console.log('error: ' + response.statusCode + body);
            }
        });
    }
});