@@ -57,6 +57,18 @@ type Settings interface {
57
57
IsDevelopment () bool
58
58
}
59
59
60
+ func (ds * Datastore ) TurnOnLogging () {
61
+ dat .SetDebugLogger (ds .Logger .Warnf )
62
+ dat .SetSQLLogger (ds .Logger .Infof )
63
+ dat .SetErrorLogger (ds .Logger .Errorf )
64
+ }
65
+
66
+ func (ds * Datastore ) TurnOffLogging () {
67
+ dat .SetDebugLogger (nil )
68
+ dat .SetSQLLogger (nil )
69
+ dat .SetErrorLogger (nil )
70
+ }
71
+
60
72
// type Logger struct {
61
73
// errLog string
62
74
// }
@@ -103,6 +115,30 @@ type Settings interface {
103
115
func New (logger Logger , ws Websocket ) * Datastore {
104
116
store := Simple ()
105
117
store .Logger = logger
118
+
119
+ logger .Info ("Current IP Addresses" )
120
+ ifaces , err := net .Interfaces ()
121
+ if err != nil {
122
+ logger .Error ("Failed to load interfaces" , err )
123
+ }
124
+ for _ , i := range ifaces {
125
+ addrs , err := i .Addrs ()
126
+ if err != nil {
127
+ logger .Error ("Failed to load addresses" , err )
128
+ }
129
+ // handle err
130
+ for _ , addr := range addrs {
131
+ var ip net.IP
132
+ switch v := addr .(type ) {
133
+ case * net.IPNet :
134
+ ip = v .IP
135
+ case * net.IPAddr :
136
+ ip = v .IP
137
+ }
138
+ logger .Info ("ip: " , ip .String ())
139
+ }
140
+ }
141
+
106
142
store .Cache = getCache (store )
107
143
store .DB = getDBConnection (store )
108
144
return store
@@ -182,11 +218,8 @@ func getDBConnection(store *Datastore) *runner.DB {
182
218
// Should be disabled in production/release builds.
183
219
dat .Strict = true
184
220
185
- dat .SetDebugLogger (store .Logger .Warnf )
186
- dat .SetSQLLogger (store .Logger .Infof )
187
- dat .SetErrorLogger (store .Logger .Errorf )
188
221
// Log any query over 10ms as warnings. (optional)
189
- runner .LogQueriesThreshold = 1 * time .Microsecond // LOG EVERYTHING ON DEV
222
+ // runner.LogQueriesThreshold = 1 * time.Microsecond // LOG EVERYTHING ON DEV // turn it off and on with a flag
190
223
}
191
224
192
225
// db connection
@@ -237,31 +270,6 @@ func getCache(store *Datastore) *Cache {
237
270
}
238
271
}
239
272
240
- // func getS3Connection() *s3.S3 {
241
- // id := os.Getenv("AWS_ACCESS_KEY_ID")
242
- // if id == "" {
243
- // log.Error("AWS_ACCESS_KEY_ID not specified")
244
- // }
245
- // key := os.Getenv("AWS_SECRET_ACCESS_KEY")
246
- // if key == "" {
247
- // log.Error("AWS_SECRET_ACCESS_KEY not specified")
248
- // }
249
- // region := os.Getenv("AWS_REGION")
250
- // if region == "" {
251
- // log.Error("AWS_REGION not specified")
252
- // }
253
- // token := ""
254
-
255
- // creds := credentials.NewStaticCredentials(id, key, token)
256
- // _, err := creds.Get()
257
- // if err != nil {
258
- // log.Error("AWS authentication error")
259
- // }
260
- // cfg := aws.NewConfig().WithRegion(region).WithCredentials(creds)
261
- // s := s3.New(session.New(), cfg)
262
- // return s
263
- // }
264
-
265
273
type Cache struct {
266
274
Client * xredis.Client
267
275
}
0 commit comments