-
Notifications
You must be signed in to change notification settings - Fork 0
/
instance.go
59 lines (45 loc) · 1.56 KB
/
instance.go
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
package ocpp
import (
"sync"
"time"
ocpp16 "github.com/lorenzodonini/ocpp-go/ocpp1.6"
"github.com/lorenzodonini/ocpp-go/ocpp1.6/core"
"github.com/lorenzodonini/ocpp-go/ocpp1.6/firmware"
"github.com/lorenzodonini/ocpp-go/ocpp1.6/localauth"
"github.com/lorenzodonini/ocpp-go/ocpp1.6/remotetrigger"
"github.com/lorenzodonini/ocpp-go/ocpp1.6/reservation"
"github.com/lorenzodonini/ocpp-go/ocpp1.6/smartcharging"
"github.com/lorenzodonini/ocpp-go/ocppj"
"github.com/lorenzodonini/ocpp-go/ws"
"github.com/thommyho/robotui/util"
)
var (
once sync.Once
instance *CS
)
func Instance() *CS {
once.Do(func() {
timeoutConfig := ws.NewServerTimeoutConfig()
timeoutConfig.PingWait = 90 * time.Second
server := ws.NewServer()
server.SetTimeoutConfig(timeoutConfig)
dispatcher := ocppj.NewDefaultServerDispatcher(ocppj.NewFIFOQueueMap(0))
dispatcher.SetTimeout(time.Minute)
endpoint := ocppj.NewServer(server, dispatcher, nil, core.Profile, localauth.Profile, firmware.Profile, reservation.Profile, remotetrigger.Profile, smartcharging.Profile)
cs := ocpp16.NewCentralSystem(endpoint, server)
instance = &CS{
log: util.NewLogger("ocpp"),
cps: make(map[string]*CP),
CentralSystem: cs,
}
ocppj.SetLogger(instance)
cs.SetCoreHandler(instance)
cs.SetNewChargePointHandler(instance.NewChargePoint)
cs.SetChargePointDisconnectedHandler(instance.ChargePointDisconnected)
cs.SetFirmwareManagementHandler(instance)
go instance.errorHandler(cs.Errors())
go cs.Start(8887, "/{ws}")
time.Sleep(time.Second)
})
return instance
}