-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmain.go
48 lines (41 loc) · 985 Bytes
/
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
package main
import (
"sync"
database "github.com/himanshu07070/newsletter/Database"
utils "github.com/himanshu07070/newsletter/Utils"
arc "github.com/himanshu07070/newsletter/ArcReactor"
input "github.com/himanshu07070/newsletter/Input"
routes "github.com/himanshu07070/newsletter/Routes"
"github.com/joho/godotenv"
)
var (
Username = ""
Password = ""
Host = ""
Port = 0
DBName = ""
)
func init() {
utils.InitializeLogger("Logs/log.log")
database.InitializeMongoConnection(Username, Password, Host, Port, DBName)
godotenv.Load(".env")
}
func startserver(data chan input.MetaData, wg *sync.WaitGroup) {
utils.Logger.Info("Starting Server ....")
defer wg.Done()
r := routes.Router(data)
err := r.Run("localhost:8000")
if err != nil {
utils.Logger.Error(err.Error())
return
}
}
func main() {
data := make(chan input.MetaData)
var wg sync.WaitGroup
wg.Add(1)
go arc.ReactorEngine(data, &wg)
wg.Add(1)
go startserver(data, &wg)
wg.Wait()
}