The mercury binary is now deployable and *should* run every morning at 2am

build.sh

@@ -6,6 +6,6 @@ rm build/*
 
 go build -o ./build/mercury ./src
 
-mercury_qb_path="/home/dtookey/work/clarity-reporting/qb/" ./build/mercury
+mercury_qb_path="/home/dtookey/work/clarity-reporting/qb/" DB_CREDS="$(cat /home/dtookey/work/datastudio-db-creds.txt)" DB_HOST=data-connect.carolina.engineering ./build/mercury
 
 

deploy.sh

@@ -0,0 +1,11 @@
+#! /bin/bash
+
+cd /opt/go/src/mercury || exit
+
+rm build/*
+
+go build -o ./build/mercury ./src
+
+rsync -avP ./build/mercury data-connect.carolina.engineering:/home/dtookey/
+ssh data-connect.carolina.engineering "sudo mv /home/dtookey/mercury /usr/local/bin/"
+

src/insight/insight-connect.go

@@ -125,15 +125,15 @@ func (ic *Interconnect) UpdateTimeEntries() {
 	for _, userPtr := range *users {
 		go ic.Client.GetTimeAllTimeEntriesForUserThroughDate(userPtr.Id, "2022-04-28", entryChan)
 		coroutineCount++
-		time.Sleep(200 * time.Millisecond)
+		time.Sleep(1000 * time.Millisecond)
 	}
 
-	log.Printf("Currently working goroutines: %d\n", coroutineCount)
+	log.Printf("Currently pending goroutines: %d\n", coroutineCount)
 	for coroutineCount > 0 {
 		entries := <-entryChan
 		ic.DBConnector.UpdateTimeEntries(entries)
 		coroutineCount--
-		log.Printf("Currently working goroutines: %d\n", coroutineCount)
+		log.Printf("Currently pending goroutines: %d\n", coroutineCount)
 	}
 	ic.DBConnector.ExecuteSqlScript("insight", "create-insight-contribution-table.sql")
 }

src/insight/insight-database.go

@@ -149,9 +149,10 @@ func (c *DBConnector) returnConnection(db *sql.DB) {
 ======================================================================================*/
 
 func createDbConnection(database string) *sql.DB {
-	secret := getSecret("/home/dtookey/work/datastudio-db-creds.txt")
+	cred := os.Getenv("DB_CREDS")
-	dbString := "clarity:%s@tcp(data-connect.carolina.engineering)/%s"
+	host := os.Getenv("DB_HOST")
-	connectString := fmt.Sprintf(dbString, *secret, database)
+	dbString := "clarity:%s@tcp(%s)/%s"
+	connectString := fmt.Sprintf(dbString, cred, host, database)
 
 	db, err := sql.Open("mysql", connectString)
 	if err != nil {