//> using scala 3.3.7
//> using dep "ma.chinespirit::qdrant4s:$VERSION$"

// build.sbt
libraryDependencies += "ma.chinespirit" %% "qdrant4s" % "<version>"

// or for Scala Native
libraryDependencies += "ma.chinespirit" %%% "qdrant4s" % "<version>"

// Synchronous (JVM) — uses JDK's built-in HttpClient, no extra deps needed
// DefaultSyncBackend() is available from sttp core

// cats-effect
"com.softwaremill.sttp.client4" %% "cats" % "4.0.7"

// ZIO
"com.softwaremill.sttp.client4" %% "zio" % "4.0.7"

// Pekko / Akka Streams
"com.softwaremill.sttp.client4" %% "pekko-http-backend" % "4.0.7"

// ... and many more — see sttp docs

//> using scala 3.3.7
//> using dep "ma.chinespirit::qdrant4s:$VERSION$"

import sttp.client4.*
import io.qdrant.client.api.*
import io.qdrant.client.model.*

val backend = DefaultSyncBackend()

// Create API instances pointing to your Qdrant instance
val collections = CollectionsApi.withApiKeyAuth("http://localhost:6333", "your-api-key")
val points      = PointsApi.withApiKeyAuth("http://localhost:6333", "your-api-key")
val search      = SearchApi.withApiKeyAuth("http://localhost:6333", "your-api-key")

// Create a collection
val createResponse = backend.send(collections.createCollection(
  "my_collection",
  createCollection = Some(CreateCollection(
    vectors = Some(VectorsConfig.VectorParamsValue(
      VectorParams(size = 4, distance = Distance.Cosine)
    ))
  ))
))

// Upsert points
val upsertResponse = backend.send(points.upsertPoints(
  "my_collection",
  wait = Some(true),
  pointInsertOperations = Some(PointInsertOperations.PointsListValue(PointsList(
    points = Seq(
      PointStruct(
        id = ExtendedPointId.LongValue(1),
        vector = VectorStruct.SeqFloatValue(Seq(0.05f, 0.61f, 0.76f, 0.74f)),
        payload = Some(Map("city" -> io.circe.Json.fromString("Berlin")))
      ),
      PointStruct(
        id = ExtendedPointId.LongValue(2),
        vector = VectorStruct.SeqFloatValue(Seq(0.19f, 0.81f, 0.75f, 0.11f)),
        payload = Some(Map("city" -> io.circe.Json.fromString("London")))
      ),
    )
  )))
))

// Search for nearest neighbors
val searchResponse = backend.send(search.searchPoints(
  "my_collection",
  searchRequest = Some(SearchRequest(
    vector = NamedVectorStruct.SeqFloatValue(Seq(0.2f, 0.1f, 0.9f, 0.7f)),
    limit = 3,
    withPayload = Some(WithPayloadInterface.BooleanValue(true))
  ))
))

searchResponse.body match {
  case Right(result) => println(result.result)
  case Left(error)   => println(s"Error: $error")
}