go-midtrans/core.go at master · harymindiar/go-midtrans · 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
package midtrans

import (
    "encoding/json"
    "bytes"
    "io"
    "strings"
)

type CoreGateway struct {
    Client Client
}

func (c *CoreGateway) Call(method, path string, body io.Reader, v interface{}) error {
    if !strings.HasPrefix(path, "/") {
        path = "/" + path
    }

    path = c.Client.ApiEnvType.String() + path
    return c.Client.Call(method, path, body, v)
}

func (g *CoreGateway) Charge(req *ChargeReq) (Response, error) {
    resp := Response{}
    jsonReq, _ := json.Marshal(req)

    err := g.Call("POST", "v2/charge", bytes.NewBuffer(jsonReq), &resp)
    if err != nil {
        g.Client.Logger.Println("Error charging: ", err)
        return resp, err
    }

    if resp.StatusMessage != "" {
        g.Client.Logger.Println(resp.StatusMessage)
    }

    return resp, nil
}

func (g *CoreGateway) PreauthCard(req *ChargeReq) (Response, error) {
    req.CreditCard.Type = "authorize"
    return g.Charge(req)
}

func (g *CoreGateway) CaptureCard(req *CaptureReq) (Response, error) {
    resp := Response{}
    jsonReq, _ := json.Marshal(req)

    err := g.Call("POST", "v2/capture", bytes.NewBuffer(jsonReq), &resp)
    if err != nil {
        g.Client.Logger.Println("Error capturing: ", err)
        return resp, err
    }

    if resp.StatusMessage != "" { g.Client.Logger.Println(resp.StatusMessage) }

    return resp, nil
}

func (g *CoreGateway) Approve(orderId string) (Response, error) {
    resp := Response{}

    err := g.Call("POST", "v2/" + orderId + "/approve", nil, &resp)
    if err != nil {
        g.Client.Logger.Println("Error approving: ", err)
        return resp, err
    }

    if resp.StatusMessage != "" { g.Client.Logger.Println(resp.StatusMessage) }

    return resp, nil
}

func (g *CoreGateway) Cancel(orderId string) (Response, error) {
    resp := Response{}

    err := g.Call("POST", "v2/" + orderId + "/cancel", nil, &resp)
    if err != nil {
        g.Client.Logger.Println("Error approving: ", err)
        return resp, err
    }

    if resp.StatusMessage != "" { g.Client.Logger.Println(resp.StatusMessage) }

    return resp, nil
}

func (g *CoreGateway) Expire(orderId string) (Response, error) {
    resp := Response{}

    err := g.Call("POST", "v2/" + orderId + "/expire", nil, &resp)
    if err != nil {
        g.Client.Logger.Println("Error approving: ", err)
        return resp, err
    }

    if resp.StatusMessage != "" { g.Client.Logger.Println(resp.StatusMessage) }

    return resp, nil
}

func (g *CoreGateway) Status(orderId string) (Response, error) {
    resp := Response{}

    err := g.Call("GET", "v2/" + orderId + "/status", nil, &resp)
    if err != nil {
        g.Client.Logger.Println("Error approving: ", err)
        return resp, err
    }

    if resp.StatusMessage != "" { g.Client.Logger.Println(resp.StatusMessage) }

    return resp, nil
}