cleanips

Author: penberg

src/lib.rs

@@ -696,11 +696,7 @@ impl Statement {
             Ok::<_, napi::Error>(rows)
         };
         env.execute_tokio_future(future, move |&mut _env, result| {
-            let mut column_names = Vec::new();
-            for i in 0..result.column_count() {
-                let column_name = result.column_name(i).unwrap().to_string();
-                column_names.push(std::ffi::CString::new(column_name).unwrap());
-            }
+            let column_names = Self::get_column_names(&result)?;
             Ok(RowsIterator::new(
                 Arc::new(tokio::sync::Mutex::new(result)),
                 column_names,
@@ -806,7 +802,7 @@ impl Statement {
             stmt.reset();
             let params = map_params(&stmt, params)?;
             let mut rows = stmt.query(params).await.map_err(Error::from)?;
-            let column_names = self.get_column_names(&rows)?;
+            let column_names = Self::get_column_names(&rows)?;
             let row = rows.next().await.map_err(Error::from)?;
             let duration = start.elapsed().as_secs_f64();
             let result = match row {
@@ -853,7 +849,7 @@ impl Statement {
         Ok(())
     }
 
-    fn get_column_names(&self, rows: &libsql::Rows) -> Result<Vec<std::ffi::CString>> {
+    fn get_column_names(rows: &libsql::Rows) -> Result<Vec<std::ffi::CString>> {
         let mut column_names = Vec::new();
         for i in 0..rows.column_count() {
             let column_name = match rows.column_name(i) {