Merge pull request #9 from notion-dotnet/add-database-object-api-client

Add database object API client

Author: KoditkarVedant

Src/Notion.Client/Constants.cs

@@ -1,9 +1,8 @@
-using System;
-
-namespace Notion.Client
+namespace Notion.Client
 {
     internal class Constants
     {
-        internal static Uri BASE_URL = new Uri("https://api.notion.com/v1/");
+        internal static string BASE_URL = "https://api.notion.com/v1/";
+        internal static string DEFAULT_NOTION_VERSION = "2021-05-13";
     }
 }

Src/Notion.Client/DatabasesClient.cs

@@ -0,0 +1,69 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Notion.Client
+{
+    public interface IDatabasesClient
+    {
+        Task<Database> RetrieveAsync(string databaseId);
+        Task<PaginatedList<Page>> QueryAsync(string databaseId, DatabasesQueryParameters databasesQueryParameters);
+        Task<PaginatedList<Database>> ListAsync(DatabasesListParameters databasesListParameters = null);
+    }
+
+    public class DatabasesClient : IDatabasesClient
+    {
+        private readonly IRestClient _client;
+
+        public DatabasesClient(IRestClient client)
+        {
+            _client = client;
+        }
+
+        public async Task<Database> RetrieveAsync(string databaseId)
+        {
+            try
+            {
+                return await _client.GetAsync<Database>($"databases/{databaseId}");
+            }
+            catch (Exception e)
+            {
+                // Todo: Throw Custom Exception
+                return null;
+            }
+        }
+
+        public async Task<PaginatedList<Database>> ListAsync(DatabasesListParameters databasesListParameters = null)
+        {
+            try
+            {
+                var databasesListQueryParmaters = (IDatabasesListQueryParmaters)databasesListParameters;
+                var queryParams = new Dictionary<string, string>()
+                {
+                    { "start_cursor", databasesListQueryParmaters?.StartCursor },
+                    { "page_size", databasesListQueryParmaters?.PageSize }
+                };
+
+                return await _client.GetAsync<PaginatedList<Database>>("databases", queryParams);
+            }
+            catch (Exception e)
+            {
+                // Todo: Throw Custom Exception
+                return null;
+            }
+        }
+
+        public async Task<PaginatedList<Page>> QueryAsync(string databaseId, DatabasesQueryParameters databasesQueryParameters)
+        {
+            try
+            {
+                var body = (IDatabaseQueryBodyParameters)databasesQueryParameters;
+                return await _client.PostAsync<PaginatedList<Page>>($"databases/{databaseId}/query", body);
+            }
+            catch (Exception e)
+            {
+                return null;
+            }
+        }
+    }
+}