Merge pull request #18 from deveel/16-consider-alternatives-for-the-mongo-data-layer

MongoDB Data Layer Rewrite

Author: tsutomi

.idea/.idea.Deveel.Webhooks/.idea/.gitignore

@@ -35,7 +35,7 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Deveel.Webhooks.Sender.Newt
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Deveel.Webhooks.Signers", "src\Deveel.Webhooks.Signers\Deveel.Webhooks.Signers.csproj", "{6D6057E9-117F-4B13-80E7-4C18B3905AEB}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Deveel.Webhooks.MongoDb.XUnit", "test\Deveel.Webhooks.MongoDb.XUnit\Deveel.Webhooks.MongoDb.XUnit.csproj", "{D61BAD7A-7B8A-4413-A0D0-8F52EE81A0B0}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Deveel.Webhooks.MongoDb.XUnit", "test\Deveel.Webhooks.MongoDb.XUnit\Deveel.Webhooks.MongoDb.XUnit.csproj", "{D61BAD7A-7B8A-4413-A0D0-8F52EE81A0B0}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution

.idea/.idea.Deveel.Webhooks/.idea/.name

@@ -0,0 +1,7 @@
+{
+  "sdk": {
+    "version": "7.0.0",
+    "rollForward": "latestMajor",
+    "allowPrerelease": true
+  }
+}

.idea/.idea.Deveel.Webhooks/.idea/encodings.xml

@@ -38,7 +38,7 @@ private Func<object, bool> Compile(Type objType, string filter) {
 					Expression.Parameter(objType, "hook")
 				};
 				var parsed = DynamicExpressionParser.ParseLambda(config, parameters, typeof(bool), filter).Compile();
-				compiled = hook => (bool)parsed.DynamicInvoke(hook);
+				compiled = hook => (bool)(parsed.DynamicInvoke(hook)!);
 				filterCache[filter] = compiled;
 			}
 
@@ -66,19 +66,26 @@ public async Task<bool> MatchesAsync(WebhookSubscriptionFilter filter, TWebhook
 			if (filter.IsWildcard)
 				return true;
 
-			var obj = await jsonSerializer.SerializeToObjectAsync(webhook, cancellationToken);
+			try {
+				var obj = await jsonSerializer.SerializeToObjectAsync(webhook, cancellationToken);
 
-			if (obj is null)
-				return false;
+				if (obj is null)
+					return false;
 
-			var evalFilter = Compile(obj.GetType(), filter.Filters);
+				var evalFilter = Compile(obj.GetType(), filter.Filters);
 
-			if (evalFilter == null)
-				return false;
+				if (evalFilter == null)
+					return false;
 
-			var result = evalFilter(obj);
+				var result = evalFilter(obj);
+
+				return result;
+			} catch (WebhookSerializationException ex) {
+				throw new WebhookException("The webhook object is invalid", ex);
+			} catch(Exception ex) {
+				throw new WebhookException("Unable to evaluate the filter", ex);
+			}
 
-			return result;
 		}
 	}
 }

.idea/.idea.Deveel.Webhooks/.idea/indexLayout.xml

@@ -26,18 +26,6 @@ public interface IWebhook {
 		/// </summary>
 		string Id { get; }
 
-		/// <summary>
-		/// If the webhook was originated by a subscription,
-		/// this gets its unique identifier.
-		/// </summary>
-		string? SubscriptionId { get; }
-
-		/// <summary>
-		/// If the webhook was originated by a subscription,
-		/// this is its name.
-		/// </summary>
-		string? SubscriptionName { get; }
-
 		/// <summary>
 		/// Gets the exact time of the event occurrence.
 		/// </summary>

.idea/.idea.Deveel.Webhooks/.idea/vcs.xml

@@ -18,7 +18,7 @@ namespace Deveel.Webhooks {
 	public interface IWebhookDeliveryAttempt {
 		int? ResponseStatusCode { get; }
 
-		string ResponseMessage { get; }
+		string? ResponseMessage { get; }
 
 		DateTimeOffset StartedAt { get; }