Need to sync inside hold

Stephen Paul Weber created 2 years ago

Change summary

sgx_jmp.rb | 18 ++++++++++--------
1 file changed, 10 insertions(+), 8 deletions(-)

Detailed changes

sgx_jmp.rb

@@ -223,14 +223,16 @@ when_ready do
 	DB = Postgres.connect(dbname: "jmp", size: 5)
 	TEL_SELECTIONS = TelSelections.new
 
-	DB.hold do |conn|
-		conn.query("LISTEN low_balance")
-		conn.query("LISTEN possible_renewal")
-		catchup_notify_low_balance(conn)
-		catchup_notify_possible_renewal(conn)
-
-		repo = CustomerRepo.new(sgx_repo: Bwmsgsv2Repo.new)
-		poll_for_notify(conn, repo)
+	EMPromise.resolve(nil).then do
+		DB.hold do |conn|
+			conn.query("LISTEN low_balance")
+			conn.query("LISTEN possible_renewal")
+			catchup_notify_low_balance(conn)
+			catchup_notify_possible_renewal(conn)
+
+			repo = CustomerRepo.new(sgx_repo: Bwmsgsv2Repo.new)
+			poll_for_notify(conn, repo).sync
+		end
 	end
 
 	load_plans_to_db!