Renaming Command to EndPoint

Author: peterbanda

pinecone-client/src/main/scala/io/cequence/pineconescala/service/Command.scala renamed to pinecone-client/src/main/scala/io/cequence/pineconescala/service/EndPoint.scala

@@ -2,17 +2,17 @@ package  io.cequence.pineconescala.service
 
 import io.cequence.pineconescala.domain.EnumValue
 
-sealed abstract class Command(value: String = "") extends EnumValue(value)
+sealed abstract class EndPoint(value: String = "") extends EnumValue(value)
 
-object Command {
-  case object describe_index_stats extends Command
-  case object query extends Command
-  case object vectors_delete extends Command("vectors/delete")
-  case object vectors_fetch extends Command("vectors/fetch")
-  case object vectors_update extends Command("vectors/update")
-  case object vectors_upsert extends Command("vectors/upsert")
-  case object collections extends Command
-  case object databases extends Command
+object EndPoint {
+  case object describe_index_stats extends EndPoint
+  case object query extends EndPoint
+  case object vectors_delete extends EndPoint("vectors/delete")
+  case object vectors_fetch extends EndPoint("vectors/fetch")
+  case object vectors_update extends EndPoint("vectors/update")
+  case object vectors_upsert extends EndPoint("vectors/upsert")
+  case object collections extends EndPoint
+  case object databases extends EndPoint
 }
 
 sealed abstract class Tag(value: String = "") extends EnumValue(value)

pinecone-client/src/main/scala/io/cequence/pineconescala/service/PineconeIndexServiceImpl.scala

@@ -28,7 +28,7 @@ private class PineconeIndexServiceImpl(
   implicit val ec: ExecutionContext, val materializer: Materializer
 ) extends PineconeIndexService with WSRequestHelper {
 
-  override protected type PEP = Command
+  override protected type PEP = EndPoint
   override protected type PT = Tag
   override protected val coreUrl = s"https://controller.${environment}.pinecone.io/"
 
@@ -41,7 +41,7 @@ private class PineconeIndexServiceImpl(
     )
 
   override def listCollections: Future[Seq[String]] =
-    execGET(Command.collections).map(
+    execGET(EndPoint.collections).map(
       _.asSafe[Seq[String]]
     )
 
@@ -50,7 +50,7 @@ private class PineconeIndexServiceImpl(
     source: String
   ): Future[CreateResponse] =
     execPOSTWithStatus(
-      Command.collections,
+      EndPoint.collections,
       bodyParams = jsonBodyParams(
         Tag.name -> Some(name),
         Tag.source -> Some(source)
@@ -71,7 +71,7 @@ private class PineconeIndexServiceImpl(
     collectionName: String
   ): Future[Option[CollectionInfo]] =
     execGETWithStatus(
-      Command.collections,
+      EndPoint.collections,
       endPointParam = Some(collectionName)
     ).map { response =>
       handleNotFoundAndError(response).map(
@@ -83,7 +83,7 @@ private class PineconeIndexServiceImpl(
     collectionName: String
   ): Future[DeleteResponse] =
     execDELETEWithStatus(
-      Command.collections,
+      EndPoint.collections,
       endPointParam = Some(collectionName),
       acceptableStatusCodes = Nil // don't parse response at all
     ).map { response =>
@@ -97,7 +97,7 @@ private class PineconeIndexServiceImpl(
     }
 
   override def listIndexes: Future[Seq[String]] =
-    execGET(Command.databases).map(
+    execGET(EndPoint.databases).map(
       _.asSafe[Seq[String]]
     )
 
@@ -107,7 +107,7 @@ private class PineconeIndexServiceImpl(
     settings: CreateIndexSettings
   ): Future[CreateResponse] =
     execPOSTWithStatus(
-      Command.databases,
+      EndPoint.databases,
       bodyParams = jsonBodyParams(
         Tag.name -> Some(name),
         Tag.dimension -> Some(dimension),
@@ -134,7 +134,7 @@ private class PineconeIndexServiceImpl(
     indexName: String
   ): Future[Option[IndexInfo]] =
     execGETWithStatus(
-      Command.databases,
+      EndPoint.databases,
       endPointParam = Some(indexName)
     ).map { response =>
       handleNotFoundAndError(response).map(
@@ -146,7 +146,7 @@ private class PineconeIndexServiceImpl(
     indexName: String
   ): Future[DeleteResponse] =
     execDELETEWithStatus(
-      Command.databases,
+      EndPoint.databases,
       endPointParam = Some(indexName),
       acceptableStatusCodes = Nil // don't parse response at all
     ).map { response =>
@@ -165,7 +165,7 @@ private class PineconeIndexServiceImpl(
     pod_type: Option[PodType.Value]
   ): Future[ConfigureIndexResponse] =
     execPATCHWithStatus(
-      Command.databases,
+      EndPoint.databases,
       endPointParam = Some(indexName),
       bodyParams = jsonBodyParams(
         Tag.replicas -> replicas,

pinecone-client/src/main/scala/io/cequence/pineconescala/service/PineconeVectorServiceImpl.scala

@@ -33,7 +33,7 @@ private class PineconeVectorServiceImpl(
   implicit val ec: ExecutionContext, val materializer: Materializer
 ) extends PineconeVectorService with WSRequestHelper {
 
-  override protected type PEP = Command
+  override protected type PEP = EndPoint
   override protected type PT = Tag
 
 //  override protected val coreUrl = s"https://${indexName}-${projectId}.svc.${environment}.pinecone.io/"
@@ -47,7 +47,7 @@ private class PineconeVectorServiceImpl(
     )
 
   override def describeIndexStats: Future[IndexStats] =
-    execGET(Command.describe_index_stats).map(
+    execGET(EndPoint.describe_index_stats).map(
       _.asSafe[IndexStats]
     )
 
@@ -57,7 +57,7 @@ private class PineconeVectorServiceImpl(
     settings: QuerySettings
   ): Future[QueryResponse] =
     execPOST(
-      Command.query,
+      EndPoint.query,
       bodyParams = jsonBodyParams(
         Tag.vector -> Some(vector),
         Tag.namespace -> Some(namespace),
@@ -77,7 +77,7 @@ private class PineconeVectorServiceImpl(
     settings: QuerySettings
   ): Future[QueryResponse] =
     execPOST(
-      Command.query,
+      EndPoint.query,
       bodyParams = jsonBodyParams(
         Tag.id -> Some(id),
         Tag.namespace -> Some(namespace),
@@ -96,7 +96,7 @@ private class PineconeVectorServiceImpl(
     namespace: String
   ): Future[Unit] =
     execPOST(
-      Command.vectors_delete,
+      EndPoint.vectors_delete,
       bodyParams = jsonBodyParams(
         Tag.ids -> Some(ids),
         Tag.namespace -> Some(namespace)
@@ -110,7 +110,7 @@ private class PineconeVectorServiceImpl(
     assert(filter.nonEmpty, "Filter must be defined.")
 
     execPOST(
-      Command.vectors_delete,
+      EndPoint.vectors_delete,
       bodyParams = jsonBodyParams(
         Tag.filter -> Some(filter),
         Tag.namespace -> Some(namespace)
@@ -122,7 +122,7 @@ private class PineconeVectorServiceImpl(
     namespace: String
   ): Future[Unit] =
     execPOST(
-      Command.vectors_delete,
+      EndPoint.vectors_delete,
       bodyParams = jsonBodyParams(
         Tag.deleteAll -> Some(true),
         Tag.namespace -> Some(namespace)
@@ -134,7 +134,7 @@ private class PineconeVectorServiceImpl(
     namespace: String
   ): Future[FetchResponse] =
     execGET(
-      Command.vectors_fetch,
+      EndPoint.vectors_fetch,
       params = Seq(
         Tag.namespace -> Some(namespace)
       ) ++ ids.map(Tag.ids -> Some(_))
@@ -150,7 +150,7 @@ private class PineconeVectorServiceImpl(
     setMetaData: Map[String, String]
   ): Future[Unit] =
     execPOST(
-      Command.vectors_update,
+      EndPoint.vectors_update,
       bodyParams = jsonBodyParams(
         Tag.id -> Some(id),
         Tag.namespace -> Some(namespace),
@@ -165,7 +165,7 @@ private class PineconeVectorServiceImpl(
     namespace: String
   ): Future[Int] =
     execPOST(
-      Command.vectors_upsert,
+      EndPoint.vectors_upsert,
       bodyParams = jsonBodyParams(
         Tag.vectors -> Some(vectors.map(Json.toJson(_))),
         Tag.namespace -> Some(namespace)