remove everything eventsourcing (#16)

Author: jamil7

src/Append.fs

@@ -29,23 +29,3 @@ module Append =
 
     let streamMessages (messages: NewStreamMessage list) : Stream -> AsyncResult<AppendResult, exn> =
         streamMessages' messages []
-
-namespace SqlStreamStore.FSharp.EventSourcing
-
-open FSharp.Prelude
-open SqlStreamStore.FSharp
-open SqlStreamStore.Streams
-
-module Append =
-    let streamEvents'
-        (events: NewStreamEvent<'event> list)
-        (appendOptions: AppendOption list)
-        : Stream -> AsyncResult<AppendResult, exn> =
-
-        fun stream ->
-            List.traverseResultM NewStreamEvent.toNewStreamMessage events
-            |> Async.singleton
-            |> AsyncResult.bind (fun messages -> Append.streamMessages' messages appendOptions stream)
-
-    let streamEvents (events: NewStreamEvent<'a> list) : Stream -> AsyncResult<AppendResult, exn> =
-        streamEvents' events []

src/Get.fs

@@ -70,63 +70,3 @@ module GetAll =
 
     let nextAllStreamPage =
         AsyncResult.bind (fun (page: ReadAllPage) -> page.ReadNext |> AsyncResult.ofTask)
-
-
-namespace SqlStreamStore.FSharp.EventSourcing
-
-open FSharp.Prelude
-open SqlStreamStore.FSharp
-open SqlStreamStore.Streams
-
-module Get =
-
-    let events<'event> =
-        Get.messages
-        >> Async.map (
-            Result.bind (
-                List.filter (fun msg -> msg.Type.Contains eventPrefix)
-                >> List.traverseResultM StreamEvent.ofStreamMessage<'event>
-            )
-        )
-
-    let eventsData<'event> =
-        events<'event>
-        >> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.data))
-
-    let eventDataAsString<'event> =
-        events<'event>
-        >> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.dataAsString))
-
-    let eventsAndEventsData<'event> =
-        fun (page: AsyncResult<ReadStreamPage, exn>) ->
-            asyncResult {
-                let! events' = events<'event> page
-                let! data = List.traverseAsyncResultM (fun event -> event.data) events'
-                return List.zip events' data
-            }
-
-module GetAll =
-    let events<'event> =
-        GetAll.messages
-        >> Async.map (
-            Result.bind (
-                List.filter (fun msg -> Seq.contains msg.Type (getEventUnionCases<'event> ()))
-                >> List.traverseResultM StreamEvent.ofStreamMessage<'event>
-            )
-        )
-
-    let eventsData<'event> =
-        events<'event>
-        >> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.data))
-
-    let eventDataAsString<'event> =
-        events<'event>
-        >> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.dataAsString))
-
-    let eventsAndEventsData<'event> =
-        fun (page: AsyncResult<ReadAllPage, exn>) ->
-            asyncResult {
-                let! events' = events<'event> page
-                let! data = List.traverseAsyncResultM (fun event -> event.data) events'
-                return List.zip events' data
-            }

src/Infrastructure.fs

@@ -12,24 +12,22 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Update="FSharp.Core" Version="5.0.0"/>
-        <PackageReference Include="FSharp.Prelude" Version="3.0.0"/>
-        <PackageReference Include="FSharp.SystemTextJson" Version="0.16.6"/>
-        <PackageReference Include="Npgsql" Version="5.0.4"/>
-        <PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8"/>
-        <PackageReference Include="SqlStreamStore.Postgres" Version="1.2.0-beta.8"/>
+        <PackageReference Update="FSharp.Core" Version="5.0.0" />
+        <PackageReference Include="FSharp.Prelude" Version="3.0.0" />
+        <PackageReference Include="FSharp.SystemTextJson" Version="0.16.6" />
+        <PackageReference Include="Npgsql" Version="5.0.4" />
+        <PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8" />
+        <PackageReference Include="SqlStreamStore.Postgres" Version="1.2.0-beta.8" />
     </ItemGroup>
 
     <ItemGroup>
-        <Compile Include="Infrastructure.fs"/>
-        <Compile Include="SqlStreamStoreExtensions.fs"/>
-        <Compile Include="StreamEvent.fs"/>
-        <Compile Include="Create.fs"/>
-        <Compile Include="Connect.fs"/>
-        <Compile Include="Append.fs"/>
-        <Compile Include="Read.fs"/>
-        <Compile Include="Get.fs"/>
-        <Compile Include="Subscribe.fs"/>
+        <Compile Include="SqlStreamStoreExtensions.fs" />
+        <Compile Include="Create.fs" />
+        <Compile Include="Connect.fs" />
+        <Compile Include="Append.fs" />
+        <Compile Include="Read.fs" />
+        <Compile Include="Get.fs" />
+        <Compile Include="Subscribe.fs" />
     </ItemGroup>
 
 </Project>

src/SqlStreamStore.FSharp.fsproj

@@ -15,10 +15,7 @@ module SqlStreamExtensions =
         asyncResult { return! streamMessage.GetJsonData() }
 
     let private getJsonDataAs<'a> (streamMessage: StreamMessage) =
-        asyncResult {
-            let! json = getJsonData streamMessage
-            return! JayJson.decode<'a> json
-        }
+        asyncResult { return! streamMessage.GetJsonDataAs<'a>() }
 
     type StreamMessage with
         /// Gets the Json Data of the message. If prefetch is enabled, this will be a fast operation.