handing the sample create DB and container

Also, added a createDatabase operation

Author: aaronpowell

samples/FSharp.CosmosDb.Samples/Program.fs

@@ -53,11 +53,6 @@ let deleteFamily conn id pk =
 
 [<EntryPoint>]
 let main argv =
-    ServicePointManager.ServerCertificateValidationCallback <-
-        fun sender certs chain errors ->
-            printfn "%A" sender
-            true
-
     let environmentName =
         System.Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT")
 
@@ -91,6 +86,19 @@ let main argv =
 
         printfn "Getting ready to do some Cosmos operations"
 
+        do!
+            conn
+            |> Cosmos.createDatabaseIfNotExists
+            |> Cosmos.execAsync
+            |> AsyncSeq.iter (fun _ -> ())
+
+        do!
+            conn
+            |> Cosmos.createContainerIfNotExists<Family>
+            |> Cosmos.execAsync
+            |> AsyncSeq.iter (fun _ -> ())
+
+
         let families =
             [| { Id = "Powell.1"
                  LastName = "Powell"
@@ -146,7 +154,6 @@ let main argv =
 
         do!
             conn
-            |> Cosmos.container "Family"
             |> Cosmos.deleteContainerIfExists
             |> Cosmos.execAsync
             |> Async.Ignore

src/FSharp.CosmosDb/Cosmos.fs

@@ -58,6 +58,12 @@ module Cosmos =
     let databaseExists<'T> op =
         { CheckIfDatabaseExistsOp.Connection = op }
 
+    // --- CREATE DATABASE --- //
+    let createDatabase op = { CreateDatabaseOp.Connection = op }
+
+    let createDatabaseIfNotExists op =
+        { CreateDatabaseIfNotExistsOp.Connection = op }
+
     // --- INSERT --- //
 
     let insertMany<'T> (values: 'T list) op =
@@ -282,3 +288,9 @@ type Cosmos =
 
     static member execAsync op =
         OperationHandling.execCreateContainerIfNotExists Cosmos.getClient op
+
+    static member execAsync op =
+        OperationHandling.execCreateDatabase Cosmos.getClient op
+
+    static member execAsync op =
+        OperationHandling.execCreateDatabaseIfNotExists Cosmos.getClient op

src/FSharp.CosmosDb/OperationHandling.fs

@@ -425,3 +425,51 @@ let execCreateContainerIfNotExists
     | None ->
         failwith
             "Unable to create the container. Ensure the name is valid and there is a partition key defined on the type"
+
+let execCreateDatabase (getClient: ConnectionOperation -> CosmosClient) (op: CreateDatabaseOp) =
+    let connInfo = op.Connection
+    let client = getClient connInfo
+
+    let result =
+        maybe {
+            let! databaseId = connInfo.DatabaseId
+
+            return
+                client.CreateDatabaseAsync databaseId
+                |> Async.AwaitTask
+        }
+
+    match result with
+    | Some result ->
+        [ async {
+              let! res = result
+              return res.Resource
+          } ]
+        |> AsyncSeq.ofSeqAsync
+    | None ->
+        failwith
+            "Unable to create the database. Ensure the database does not already exist and that your connection info is valid"
+
+let execCreateDatabaseIfNotExists (getClient: ConnectionOperation -> CosmosClient) (op: CreateDatabaseIfNotExistsOp) =
+    let connInfo = op.Connection
+    let client = getClient connInfo
+
+    let result =
+        maybe {
+            let! databaseId = connInfo.DatabaseId
+
+            return
+                client.CreateDatabaseIfNotExistsAsync databaseId
+                |> Async.AwaitTask
+        }
+
+    match result with
+    | Some result ->
+        [ async {
+              let! res = result
+              return res.Resource
+          } ]
+        |> AsyncSeq.ofSeqAsync
+    | None ->
+        failwith
+            "Unable to create the database. Ensure the database does not already exist and that your connection info is valid"

src/FSharp.CosmosDb/Types.fs

@@ -109,6 +109,10 @@ type GetContainerPropertiesOp = { Connection: ConnectionOperation }
 
 type CheckIfContainerExistsOp = { Connection: ConnectionOperation }
 
+type CreateDatabaseOp = { Connection: ConnectionOperation }
+
+type CreateDatabaseIfNotExistsOp = { Connection: ConnectionOperation }
+
 type CreateContainerOp<'T> = { Connection: ConnectionOperation }
 
 type CreateContainerIfNotExistsOp<'T> = { Connection: ConnectionOperation }