/
main.go
110 lines (90 loc) · 3 KB
/
main.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
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
package main
import (
"fmt"
"log"
"log/syslog"
"os"
"sync"
"github.com/alexcesaro/statsd"
"github.com/facebookgo/inject"
"github.com/nicholasjackson/sorcery/data"
"github.com/nicholasjackson/sorcery/global"
"github.com/nicholasjackson/sorcery/handlers"
"github.com/nicholasjackson/sorcery/logging"
"github.com/nicholasjackson/sorcery/queue"
"github.com/nicholasjackson/sorcery/workers"
)
func main() {
config := os.Args[1]
rootfolder := os.Args[2]
global.LoadConfig(config, rootfolder)
var wg sync.WaitGroup
wg.Add(2)
setupInjection()
go startApiServer(&wg)
go startClient(&wg)
wg.Wait()
}
func setupInjection() {
err := global.SetupInjection(
&inject.Object{Value: handlers.HealthHandlerDependencies},
&inject.Object{Value: handlers.RegisterHandlerDependencies},
&inject.Object{Value: handlers.EventHandlerDependencies},
&inject.Object{Value: ClientDeps},
&inject.Object{Value: createLogger()},
&inject.Object{Value: createStatsDClient(), Name: "statsd"},
&inject.Object{Value: createMongoClient(), Name: "dal"},
&inject.Object{Value: createEventQueueClient(), Name: "eventqueue"},
&inject.Object{Value: createDeadLetterQueueClient(), Name: "deadletterqueue"},
&inject.Object{Value: createEventDispatcher(), Name: "eventdispatcher"},
&inject.Object{Value: createEventQueueWorkerFactory(), Name: "eventqueueworkerfactory"},
&inject.Object{Value: createDeadLetterQueueWorkerFactory(), Name: "deadletterqueueworkerfactory"},
)
if err != nil {
panic(fmt.Sprintln("Unable to create injection framework: ", err))
}
}
func createStatsDClient() logging.StatsD {
statsDClient, err := statsd.New(statsd.Address(global.Config.StatsDServerIP)) // reference to a statsd client
if err != nil {
panic(fmt.Sprintln("Unable to create StatsD Client: ", err))
}
return statsDClient
}
func createMongoClient() *data.MongoDal {
dal, err := data.New(global.Config.Data.ConnectionString, global.Config.Data.DataBaseName)
if err != nil {
panic(fmt.Sprintln("Unable to create DataBase: ", err))
}
return dal
}
func createEventDispatcher() workers.EventDispatcher {
return &workers.HTTPEventDispatcher{}
}
func createEventQueueClient() *queue.RedisQueue {
queue, err := queue.NewRedisQueue(global.Config.Queue.ConnectionString, global.Config.Queue.EventQueue)
if err != nil {
panic(fmt.Sprintln("Unable to create Queue: ", err))
}
return queue
}
func createEventQueueWorkerFactory() workers.WorkerFactory {
return &workers.EventQueueWorkerFactory{}
}
func createDeadLetterQueueClient() *queue.DeadLetterQueue {
queue, err := queue.NewDeadLetterQueue(createMongoClient())
if err != nil {
panic(fmt.Sprintln("Unable to create Queue: ", err))
}
return queue
}
func createDeadLetterQueueWorkerFactory() workers.WorkerFactory {
return &workers.DeadLetterQueueWorkerFactory{}
}
func createLogger() *log.Logger {
syslogWriter, err := syslog.Dial("udp", global.Config.SysLogIP, syslog.LOG_SYSLOG, "sorcery")
if err != nil {
panic(err)
}
return log.New(syslogWriter, "EventSauce: ", log.Lshortfile)
}