From cb70f03523326c19e033c2115684aa1015fb8d1d Mon Sep 17 00:00:00 2001
From: "M. J. Fromberger" <fromberger@interchain.io>
Date: Fri, 27 Aug 2021 07:55:05 -0700
Subject: [PATCH] WIP update verifyTimeStamp

---
 state/indexer/sink/psql/psql_test.go | 27 ++++++---------------------
 1 file changed, 6 insertions(+), 21 deletions(-)

diff --git a/state/indexer/sink/psql/psql_test.go b/state/indexer/sink/psql/psql_test.go
index 51bd9ea6a..0c6578baa 100644
--- a/state/indexer/sink/psql/psql_test.go
+++ b/state/indexer/sink/psql/psql_test.go
@@ -240,27 +240,12 @@ func verifyTx(hash []byte) (*abci.TxResult, error) {
 	return nil, nil
 }
 
-func verifyTimeStamp(tb string) error {
-
-	// We assume the tx indexing time would not exceed 2 second from now
-	sqlStmt := sq.
-		Select(fmt.Sprintf("%s.created_at", tb)).
-		Distinct().From(tb).
-		Where(fmt.Sprintf("%s.created_at >= $1", tb), time.Now().Add(-2*time.Second))
-
-	rows, err := sqlStmt.RunWith(db).Query()
-	if err != nil {
-		return err
-	}
-
-	defer rows.Close()
-
-	if rows.Next() {
-		var ts string
-		return rows.Scan(&ts)
-	}
-
-	return errors.New("no result")
+func verifyTimeStamp(tableName string) error {
+	return db.QueryRow(fmt.Sprintf(`
+SELECT DISTINCT %[1]s.created_at
+  FROM %[1]s
+  WHERE %[1]s.created_at >= ?;
+`, tableName), time.Now().Add(-2*time.Second)).Err()
 }
 
 func verifyBlock(h int64) (bool, error) {