crypto-ussd/raiden.go at master · Dev43/crypto-ussd · 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
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
package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net/http"
)

func doHttpCall(method string, url string, body []byte) ([]byte, error) {
	defaultURL := "http://localhost:5001/api/v1/"
	fullURL := defaultURL + url
	b := bytes.NewReader(body)
	req, err := http.NewRequest(method, fullURL, b)
	if err != nil {
		return nil, err
	}
	req.Header.Add("Content-Type", "application/json")
	res, err := http.DefaultClient.Do(req)
	if err != nil {
		return nil, err
	}
	defer res.Body.Close()
	fmt.Println(res.Body)
	respBody, err := ioutil.ReadAll(res.Body)
	if err != nil {
		return nil, err
	}

	return respBody, nil
}

func registerToken(tokenAddress string) error {
	resp, err := doHttpCall("PUT", fmt.Sprintf("%s/%s", "tokens", tokenAddress), nil)
	if err != nil {
		return err
	}
	fmt.Println(string(resp))
	return nil
}

func openChannel(partnerAddress string, tokenAddress string, totalDeposit int) (*OpenChannelResponse, error) {
	// default partner address 0x0bae0289AAA26845224F528F9B9DefE69e01606E
	body := OpenChannelRequest{
		PartnerAddress: partnerAddress,
		TokenAddress:   tokenAddress,
		TotalDeposit:   totalDeposit,
		SettleTimeout:  500,
	}
	b, err := json.Marshal(body)
	if err != nil {
		return nil, err
	}
	fmt.Println(b)
	resp, err := doHttpCall("PUT", fmt.Sprintf("%s", "channels"), b)
	if err != nil {
		return nil, err
	}
	data := OpenChannelResponse{}
	err = json.Unmarshal(resp, &data)
	if err != nil {
		return nil, err
	}
	// need to save the channel here somewhere
	fmt.Println(string(resp))
	return &data, nil
}

func getChannelInformation() ([]ChannelInformation, error) {
	// default partner address 0x0bae0289AAA26845224F528F9B9DefE69e01606E
	resp, err := doHttpCall("GET", fmt.Sprintf("%s", "channels"), nil)
	if err != nil {
		return nil, err
	}
	data := []ChannelInformation{}
	err = json.Unmarshal(resp, &data)
	if err != nil {
		return nil, err
	}
	// need to save the channel here somewhere
	fmt.Println(string(resp))
	return data, nil
}

func topUpChannel(partnerAddress string, tokenAddress string, totalDeposit int) (*TopUpChannelResponse, error) {
	// default partner address 0x0bae0289AAA26845224F528F9B9DefE69e01606E
	body := TopUpChannelRequest{
		TotalDeposit: totalDeposit,
	}
	b, err := json.Marshal(body)
	if err != nil {
		return nil, err
	}
	resp, err := doHttpCall("PATCH", fmt.Sprintf("%s/%s/%s", "channels", tokenAddress, partnerAddress), b)
	if err != nil {
		return nil, err
	}
	data := TopUpChannelResponse{}
	err = json.Unmarshal(resp, &data)
	if err != nil {
		return nil, err
	}
	// need to save the channel here somewhere
	fmt.Println(string(resp))
	return &data, nil
}

func closeChannel(partnerAddress string, tokenAddress string, totalDeposit int) (*CloseChannelRequest, error) {
	// default partner address 0x0bae0289AAA26845224F528F9B9DefE69e01606E
	body := CloseChannelRequest{
		State: "closed",
	}
	b, err := json.Marshal(body)
	if err != nil {
		return nil, err
	}
	resp, err := doHttpCall("PATCH", fmt.Sprintf("%s/%s/%s", "channels", tokenAddress, partnerAddress), b)
	if err != nil {
		return nil, err
	}
	data := CloseChannelRequest{}
	err = json.Unmarshal(resp, &data)
	if err != nil {
		return nil, err
	}
	// need to save the channel here somewhere
	fmt.Println(string(resp))
	return &data, nil
}

func makePayment(targetAddress string, tokenAddress string, amount int, identifier int) (*PaymentResponse, error) {
	// default partner address 0x0bae0289AAA26845224F528F9B9DefE69e01606E
	body := PaymentRequest{
		Amount:     amount,
		Identifier: identifier,
	}
	b, err := json.Marshal(body)
	if err != nil {
		return nil, err
	}
	fmt.Println(string(b))
	resp, err := doHttpCall("POST", fmt.Sprintf("%s/%s/%s", "payments", tokenAddress, targetAddress), b)
	if err != nil {
		return nil, err
	}
	data := PaymentResponse{}
	err = json.Unmarshal(resp, &data)

	if err != nil {
		return nil, err
	}
	// need to save the channel here somewhere
	fmt.Println(string(resp))
	return &data, nil
}