re-extract tags and text

src/main/kotlin/com/tryformation/pgdocstore/DocStore.kt

@@ -107,7 +107,6 @@ class DocStore<T : Any>(
                 VALUES (?,?,?,?,?,to_tsvector(coalesce(?)))
             """.trimIndent(), listOf(id, timestamp, timestamp, txt, tags, text)
         )
-
     }
 
     suspend fun getById(id: String): T? {
@@ -410,5 +409,9 @@ class DocStore<T : Any>(
             }
         }
     }
+
+    suspend fun reExtract() {
+        bulkInsert(documentsByRecencyScrolling())
+    }
 }
 

src/test/kotlin/com/tryformation/pgdocstore/RetagTest.kt

@@ -0,0 +1,25 @@
+package com.tryformation.pgdocstore
+
+import io.kotest.matchers.shouldBe
+import kotlinx.coroutines.flow.count
+import kotlinx.coroutines.flow.flow
+import org.junit.jupiter.api.Test
+
+class RetagTest: DbTestBase() {
+    @Test
+    fun `should retag everything with updated tag extractor`() = coRun {
+        val ds = DocStore(db, TaggedModel.serializer(), tableName)
+
+        flow {
+            repeat(200) {
+                emit(TaggedModel(title = "doc $it", tags = listOf("foo")))
+            }
+        }.let {
+            ds.bulkInsert(it)
+        }
+        ds.documentsByRecencyScrolling(tags = listOf("foo")).count()  shouldBe 0
+        val ds2 = DocStore(db, TaggedModel.serializer(), tableName, tagExtractor = TaggedModel::tags)
+        ds2.reExtract()
+        ds2.documentsByRecencyScrolling(tags = listOf("foo")).count()  shouldBe 200
+    }
+}

src/test/kotlin/com/tryformation/pgdocstore/TaggingTest.kt

@@ -7,7 +7,7 @@ import org.junit.jupiter.api.Test
 import java.util.UUID
 
 @Serializable
-data class TaggedModel(val title: String, val tags: List<String>, val id:String = UUID.randomUUID().toString())
+data class TaggedModel(val title: String, val tags: List<String> = listOf(), val id:String = UUID.randomUUID().toString())
 
 class TaggingTest : DbTestBase() {
     @Test

src/test/kotlin/com/tryformation/pgdocstore/docs/DocGenerationTest.kt

@@ -2,20 +2,18 @@ package com.tryformation.pgdocstore.docs
 
 import com.github.jasync.sql.db.ConnectionPoolConfiguration
 import com.github.jasync.sql.db.asSuspending
-import com.github.jasync.sql.db.interceptor.LoggingInterceptorSupplier
 import com.github.jasync.sql.db.postgresql.PostgreSQLConnectionBuilder
 import com.jillesvangurp.kotlin4example.SourceRepository
-import com.tryformation.pgdocstore.*
-import kotlinx.coroutines.Dispatchers
+import com.tryformation.pgdocstore.DocStore
+import com.tryformation.pgdocstore.db
+import com.tryformation.pgdocstore.reCreateDocStoreSchema
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.count
 import kotlinx.coroutines.flow.flow
 import kotlinx.serialization.Serializable
 import org.junit.jupiter.api.Test
 import java.io.File
 import java.util.*
-import kotlin.random.Random
-import kotlin.random.nextULong
 import kotlin.time.Duration.Companion.milliseconds
 
 const val githubLink = "https://github.com/formation-res/pg-docstore"
@@ -101,9 +99,6 @@ val readmeMd = sourceGitRepository.md {
             store.getById(doc1.id)?.let {
                 println("Retrieved ${it.title}")
             }
-            // delete it
-            store.delete(doc1)
-            println("now it's gone: ${store.getById(doc1.id)}")
 
             // you can also do bulk inserts using flows or lists
             flow {
@@ -147,6 +142,11 @@ val readmeMd = sourceGitRepository.md {
                 }"
             )
 
+            // delete a document
+            store.delete(doc1)
+            println("now it's gone: ${store.getById(doc1.id)}")
+
+
             store.create(MyModel("The quick brown fox"))
             // or search on the extracted text
             println(
@@ -155,15 +155,6 @@ val readmeMd = sourceGitRepository.md {
                 }"
             )
 
-            // if you like sql, just use the connection
-            store.connection
-                .sendQuery("SELECT COUNT(*) as total FROM docs")
-                .let { res ->
-                    res.rows.first().let { row ->
-                        println("Count query total: ${row["total"]}")
-                    }
-                }
-
             // the whole point of dbs is transactions
             store.transact { tStore ->
                 // everything you do with tStore is
@@ -211,8 +202,23 @@ val readmeMd = sourceGitRepository.md {
             }
             // prints null because the transaction was rolled back
             println("after the rollback ${store.getById(another.id)?.title}")
+
+            // if you like sql, just use the connection
+            store.connection
+                .sendQuery("SELECT COUNT(*) as total FROM docs")
+                .let { res ->
+                    res.rows.first().let { row ->
+                        println("Count query total: ${row["total"]}")
+                    }
+                }
+
         }
     }
+    +"""
+        This shows off most of the features. And more importantly, it shows how 
+        simple interactions with the database are. Mostly, it's just simple idiomatic Kotlin; nice
+        little one liners.
+    """.trimIndent()
 
     includeMdFile("outro.md")