Add item and collection creation endpoints

Author: pomadchin

build.sbt

@@ -217,6 +217,7 @@ lazy val client = crossProject(JSPlatform, JVMPlatform)
       "org.locationtech.geotrellis" %% "geotrellis-vector"   % Versions.GeoTrellisVersion,
       "org.locationtech.jts"         % "jts-core"            % Versions.Jts,
       "org.typelevel"               %% "cats-core"           % Versions.CatsVersion,
+      "com.softwaremill.sttp.client3" %% "core" % "3.0.0-RC13",
       "co.fs2"                      %% "fs2-core"            % "2.4.2",
       "org.http4s"                  %% "http4s-blaze-client" % "0.21.7",
       "org.http4s"                  %% "http4s-circe"        % "0.21.7",

modules/client/shared/src/main/scala/com/azavea/stac4s/api/client/Http4sStacClient.scala

@@ -5,6 +5,7 @@ import com.azavea.stac4s.{StacCollection, StacItem}
 import cats.effect.{ConcurrentEffect, Resource, Sync}
 import cats.syntax.apply._
 import cats.syntax.either._
+import cats.syntax.flatMap._
 import cats.syntax.functor._
 import eu.timepit.refined.types.string.NonEmptyString
 import io.chrisdavenport.log4cats.Logger
@@ -54,6 +55,26 @@ case class Http4sStacClient[F[_]: Sync: Logger](
       client
         .expect(getRequest.withUri(baseUri.withPath(s"/collections/$collectionId/items/$itemId")))
         .map(_.as[Option[StacItem]].bimap(_ => None, identity).merge)
+
+  def itemCreate(collectionId: NonEmptyString, item: StacItem): F[StacItem] =
+    logger.trace(s"createItem: $collectionId, $item") *>
+      client
+        .expect(
+          postRequest
+            .withUri(baseUri.withPath(s"/collections/$collectionId/items"))
+            .withEntity(item.asJson.noSpaces)
+        )
+        .flatMap { json => Sync[F].fromEither(json.as[StacItem].leftMap(_.getCause)) }
+
+  def collectionCreate(collection: StacCollection): F[StacCollection] =
+    logger.trace(s"createCollection: $collection") *>
+      client
+        .expect(
+          postRequest
+            .withUri(baseUri.withPath(s"/collections/"))
+            .withEntity(collection.asJson.noSpaces)
+        )
+        .flatMap { json => Sync[F].fromEither(json.as[StacCollection].leftMap(_.getCause)) }
 }
 
 object Http4sStacClient {

modules/client/shared/src/main/scala/com/azavea/stac4s/api/client/StacClient.scala

@@ -26,4 +26,6 @@ trait StacClient[F[_]] {
   def collection(collectionId: NonEmptyString): F[Option[StacCollection]]
   def items(collectionId: NonEmptyString): F[List[StacItem]]
   def item(collectionId: NonEmptyString, itemId: NonEmptyString): F[Option[StacItem]]
+  def itemCreate(collectionId: NonEmptyString, item: StacItem): F[StacItem]
+  def collectionCreate(collection: StacCollection): F[StacCollection]
 }