add REDISQL.V2.STATEMENT db LIST NOW

Author: siscia

src/v2/statement.rs

@@ -5,6 +5,8 @@ use parser::statement::Statement;
 use redisql_lib::redis as r;
 use redisql_lib::redis::LoopData;
 use redisql_lib::redis::RedisReply;
+use redisql_lib::redis::ReturnMethod;
+use redisql_lib::redis::Returner;
 use redisql_lib::redis::StatementCache;
 use redisql_lib::redis_type::BlockedClient;
 use redisql_lib::redis_type::ReplicateVerbatim;
@@ -111,7 +113,15 @@ pub extern "C" fn Statement_v2(
                     .list_statements();
                 match result {
                     Err(mut e) => e.reply_v2(&context),
-                    Ok(mut q) => q.reply_v2(&context),
+                    Ok(q) => {
+                        let mut to_return = q.create_data_to_return(
+                            &context,
+                            &ReturnMethod::ReplyWithHeader,
+                            std::time::Instant::now()
+                                + std::time::Duration::from_secs(10),
+                        );
+                        to_return.reply_v2(&context)
+                    }
                 }
             }
             _ => todo!(),

test/correctness/test_v2.py

@@ -674,6 +674,15 @@ def test_list_one(self):
           ['insert_ntimes', "insert into t1 values(?1); insert into t1 values(?2); select ?3;", 3, 0],
           ['select_all', 'SELECT * from t1', 0, 1],
           ['select_multiples', "select ?1; select ?2; select ?3;", 3, 1]])
+      result = self.exec_naked("REDISQL.v2.STATEMENT", "A", "LIST", "NOW")
+      self.compare_results(result, [['RESULT'],
+          ["identifier", 'SQL', 'parameters_count', 'read_only'],
+          ['TEXT', 'TEXT', 'INT', 'INT'],
+          ['insert', 'insert into t1 values(?1);', 1, 0],
+          ['insert_twice', "insert into t1 values(?1); insert into t1 values(?1 * 10)", 1, 0],
+          ['insert_ntimes', "insert into t1 values(?1); insert into t1 values(?2); select ?3;", 3, 0],
+          ['select_all', 'SELECT * from t1', 0, 1],
+          ['select_multiples', "select ?1; select ?2; select ?3;", 3, 1]])
 
 
 if __name__ == '__main__':