-
Notifications
You must be signed in to change notification settings - Fork 5
/
Copy pathmain.go
177 lines (147 loc) · 5.29 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
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
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
package main
import (
"flag"
"fmt"
"log"
"os"
"os/signal"
"syscall"
"github.com/asdine/storm"
"github.com/bwmarrin/discordgo"
"io/ioutil"
"net/http"
_ "net/http/pprof"
)
// Variables used for command line parameters
var (
ConfPath string
)
func init() {
// Read our command line options
flag.StringVar(&ConfPath, "c", "du-bot.conf", "Path to Config File")
flag.Parse()
_, err := os.Stat(ConfPath)
if err != nil {
log.Fatal("Config file is missing: ", ConfPath)
//flag.Usage()
//os.Exit(1)
}
}
func main() {
fmt.Println("\n\n|| Starting du-discordbot ||")
log.SetOutput(ioutil.Discard)
// Setup our tmp directory
_, err := os.Stat("tmp")
if err != nil {
if os.IsNotExist(err) {
err = os.Mkdir("tmp", os.FileMode(0777))
if err != nil {
fmt.Println("Could not make tmp directory! " + err.Error())
return
}
}
}
// Verify we can actually read our config file
conf, err := ReadConfig(ConfPath)
if err != nil {
fmt.Println("error reading config file at: ", ConfPath)
return
}
// Create / open our embedded database
db, err := storm.Open(conf.DBConfig.DBFile)
if err != nil {
log.Fatal(err)
return
}
defer db.Close()
// Run a quick first time db configuration to verify that it is working properly
fmt.Println("Checking Database")
dbhandler := DBHandler{conf: &conf, rawdb: db}
err = dbhandler.FirstTimeSetup()
if err != nil {
log.Fatal(err)
return
}
// Create a new Discord session using the provided bot token.
dg, err := discordgo.New("Bot " + conf.DiscordConfig.Token)
if err != nil {
fmt.Println("error creating Discord session,", err)
return
}
defer dg.Close()
logchannel := make(chan string)
logger := Logger{logchan: logchannel}
// Create a callback handler and add it to our Handler Queue
fmt.Println("Adding Callback Handler")
callbackhandler := CallbackHandler{dg: dg, logger: &logger}
dg.AddHandler(callbackhandler.Read)
fmt.Println("Adding Info Callback Handler")
infocallbackhandler := InfoCallbackHandler{dg: dg, logger: &logger}
dg.AddHandler(infocallbackhandler.Read)
fmt.Println("Adding Reactions Handler")
reactionshandler := ReactionsHandler{dg: dg, logger: &logger, conf: &conf}
dg.AddHandler(reactionshandler.ReadReactionAdd)
dg.AddHandler(reactionshandler.ReadReactionRemove)
fmt.Println("Adding Info Reactions Handler")
inforeactionshandler := InfoReactionsHandler{dg: dg, logger: &logger, conf: &conf}
dg.AddHandler(inforeactionshandler.ReadReactionAdd)
dg.AddHandler(inforeactionshandler.ReadReactionRemove)
// Create our user handler
fmt.Println("Adding User Handler")
userhandler := UserHandler{conf: &conf, db: &dbhandler, logchan: logchannel}
userhandler.Init()
dg.AddHandler(userhandler.Read)
// Create our permissions handler
fmt.Println("Adding Permissions Handler")
permissionshandler := PermissionsHandler{dg: dg, conf: &conf, callback: &callbackhandler, db: &dbhandler,
user: &userhandler, logchan: logchannel}
dg.AddHandler(permissionshandler.Read)
// Create our command handler
fmt.Println("Adding Command Registry Handler")
commandhandler := CommandHandler{dg: dg, db: &dbhandler, callback: &callbackhandler,
user: &userhandler, conf: &conf, perm: &permissionshandler, logchan: logchannel}
// Create our permissions handler
fmt.Println("Adding Channel Permissions Handler")
channelhandler := ChannelHandler{db: &dbhandler, conf: &conf, registry: commandhandler.registry,
user: &userhandler, logchan: logchannel}
channelhandler.Init()
dg.AddHandler(channelhandler.Read)
// Don't forget to initialize the command handler -AFTER- the Channel Handler!
commandhandler.Init(&channelhandler)
dg.AddHandler(commandhandler.Read)
// Setup and initialize our Central Bank
fmt.Println("Setting Up Bank")
centralbank := Bank{db: &dbhandler, conf: &conf, user: &userhandler}
centralbank.Init()
// Create our Wallet Handler
fmt.Println("Adding User Wallet Handler")
wallethandler := WalletHandler{db: &dbhandler, conf: &conf, user: &userhandler, logchan: logchannel}
dg.AddHandler(wallethandler.Read)
// Create our Bank handler
fmt.Println("Adding Bank Handler")
bankhandler := BankHandler{db: &dbhandler, conf: centralbank.conf, com: &commandhandler, logchan: logchannel,
user: &userhandler, callback: &callbackhandler, bank: ¢ralbank, wallet: &wallethandler}
dg.AddHandler(bankhandler.Read)
// Initalize our Logger
fmt.Println("Initializing Logger")
logger.Init(&channelhandler, logchannel, dg)
// Now we create and initialize our main handler
fmt.Println("\n|| Initializing Main Handler ||")
handler := PrimaryHandler{db: &dbhandler, conf: &conf, dg: dg, callback: &callbackhandler, perm: &permissionshandler,
command: &commandhandler, logchan: logchannel, bankhandler: &bankhandler, user: &userhandler, channel: &channelhandler,
reactions: &reactionshandler, inforeactions: &inforeactionshandler, infocallback: &infocallbackhandler}
err = handler.Init()
if err != nil {
fmt.Println("error in mainHandler.init", err)
return
}
fmt.Println("\n|| Main Handler Initialized ||")
if conf.DUBotConfig.Profiler {
_ = http.ListenAndServe(":8080", http.DefaultServeMux)
}
// Wait here until CTRL-C or other term signal is received.
fmt.Println("Bot is now running. Press CTRL-C to exit.")
sc := make(chan os.Signal, 1)
signal.Notify(sc, syscall.SIGINT, syscall.SIGTERM, os.Interrupt, os.Kill)
<-sc
}