2
0
mirror of https://github.com/tenrok/event-scheduling.git synced 2026-06-20 20:00:38 +03:00

refactor: clean up un-necessary code

This commit is contained in:
Dipesh Dulal
2021-01-16 10:34:57 +05:45
parent 3cba4a113e
commit 6ce4db5321
+15 -21
View File
@@ -7,42 +7,36 @@ import (
"os/signal" "os/signal"
"github.com/joho/godotenv" "github.com/joho/godotenv"
"github.com/dipeshdulal/event-scheduling/customevents"
) )
// Test structure // Event structure
type Test struct { type Event struct {
ID uint ID uint
Name string Name string
Payload string
Locked string
}
var eventListeners = map[string]func(d interface{}){
"SendEmail": customevents.SendEmail,
"PayBills": customevents.PayBills,
} }
func main() { func main() {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
interrupt := make(chan os.Signal, 1) interrupt := make(chan os.Signal, 1)
signal.Notify(interrupt, os.Interrupt)
if err := godotenv.Load(); err != nil { if err := godotenv.Load(); err != nil {
log.Fatal("Error loading .env file ", err) log.Fatal("Error loading .env file ", err)
} }
db := initDBConnection() db := initDBConnection()
seedDB(db) seedDB(db)
rows, err := db.Query("SELECT id, name FROM public.test")
if err != nil {
log.Panic(err)
}
go func() {
for rows.Next() {
var test Test
rows.Scan(&test.ID, &test.Name)
log.Printf("test: %v\n", test)
}
}()
signal.Notify(interrupt, os.Interrupt)
go func() { go func() {
for range interrupt { for range interrupt {
log.Println("\n❌ Interrupt received closing...") log.Println("\n❌ Interrupt received closing...")