1 files changed, 4 insertions, 4 deletions
diff --git a/main.go b/main.go
index 05bbac3..ac004de 100644
--- a/main.go
+++ b/main.go
@@ -18,9 +18,9 @@ func main() {
 
 	switch cfg.DataSource {
 	case "stdin":
-		processFromStdin()
+		processFromStdin(cfg)
 	case "mysq":
-		pricessFromDB()
+		processFromDB(cfg)
 	default:
 		log.Println("Invalid dataSource in config. Needs to be either 'stdin' or 'mysql'.")
 	}
@@ -28,14 +28,14 @@ func main() {
 	log.Println("Finished processing, now exiting")
 }
 
-func processFromStdin() {
+func processFromStdin(cfg *Config) {
 	log.Println("Starting to process from stdin...")
 	input := readFromStdin()
 	rDatChan := parseRawData(input, cfg)
 	cleanFromStdin(rDatChan, cfg)
 }
 
-func processFromDB() {
+func processFromDB(cfg *Config) {
 	log.Print("Cleaning data...")
 	starttime := time.Now()
 	numOfRowsNotCleaned, err := cleanFromDB(cfg)