Skip to content

Commit 57c29cd

Browse files
jamil7jamil7
authored
remove everything eventsourcing (#16)
1 parent fb53d41 commit 57c29cd

7 files changed

Lines changed: 14 additions & 384 deletions

File tree

‎src/Append.fs‎

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -29,23 +29,3 @@ module Append =
2929

3030
let streamMessages (messages: NewStreamMessage list) : Stream -> AsyncResult<AppendResult, exn> =
3131
streamMessages' messages []
32-
33-
namespace SqlStreamStore.FSharp.EventSourcing
34-
35-
open FSharp.Prelude
36-
open SqlStreamStore.FSharp
37-
open SqlStreamStore.Streams
38-
39-
module Append =
40-
let streamEvents'
41-
(events: NewStreamEvent<'event> list)
42-
(appendOptions: AppendOption list)
43-
: Stream -> AsyncResult<AppendResult, exn> =
44-
45-
fun stream ->
46-
List.traverseResultM NewStreamEvent.toNewStreamMessage events
47-
|> Async.singleton
48-
|> AsyncResult.bind (fun messages -> Append.streamMessages' messages appendOptions stream)
49-
50-
let streamEvents (events: NewStreamEvent<'a> list) : Stream -> AsyncResult<AppendResult, exn> =
51-
streamEvents' events []

‎src/Get.fs‎

Lines changed: 0 additions & 60 deletions
Original file line numberDiff line numberDiff line change
@@ -70,63 +70,3 @@ module GetAll =
7070

7171
let nextAllStreamPage =
7272
AsyncResult.bind (fun (page: ReadAllPage) -> page.ReadNext |> AsyncResult.ofTask)
73-
74-
75-
namespace SqlStreamStore.FSharp.EventSourcing
76-
77-
open FSharp.Prelude
78-
open SqlStreamStore.FSharp
79-
open SqlStreamStore.Streams
80-
81-
module Get =
82-
83-
let events<'event> =
84-
Get.messages
85-
>> Async.map (
86-
Result.bind (
87-
List.filter (fun msg -> msg.Type.Contains eventPrefix)
88-
>> List.traverseResultM StreamEvent.ofStreamMessage<'event>
89-
)
90-
)
91-
92-
let eventsData<'event> =
93-
events<'event>
94-
>> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.data))
95-
96-
let eventDataAsString<'event> =
97-
events<'event>
98-
>> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.dataAsString))
99-
100-
let eventsAndEventsData<'event> =
101-
fun (page: AsyncResult<ReadStreamPage, exn>) ->
102-
asyncResult {
103-
let! events' = events<'event> page
104-
let! data = List.traverseAsyncResultM (fun event -> event.data) events'
105-
return List.zip events' data
106-
}
107-
108-
module GetAll =
109-
let events<'event> =
110-
GetAll.messages
111-
>> Async.map (
112-
Result.bind (
113-
List.filter (fun msg -> Seq.contains msg.Type (getEventUnionCases<'event> ()))
114-
>> List.traverseResultM StreamEvent.ofStreamMessage<'event>
115-
)
116-
)
117-
118-
let eventsData<'event> =
119-
events<'event>
120-
>> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.data))
121-
122-
let eventDataAsString<'event> =
123-
events<'event>
124-
>> AsyncResult.bind (List.traverseAsyncResultM (fun event -> event.dataAsString))
125-
126-
let eventsAndEventsData<'event> =
127-
fun (page: AsyncResult<ReadAllPage, exn>) ->
128-
asyncResult {
129-
let! events' = events<'event> page
130-
let! data = List.traverseAsyncResultM (fun event -> event.data) events'
131-
return List.zip events' data
132-
}

‎src/Infrastructure.fs‎

Lines changed: 0 additions & 84 deletions
This file was deleted.

‎src/SqlStreamStore.FSharp.fsproj‎

Lines changed: 13 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -12,24 +12,22 @@
1212
</PropertyGroup>
1313

1414
<ItemGroup>
15-
<PackageReference Update="FSharp.Core" Version="5.0.0"/>
16-
<PackageReference Include="FSharp.Prelude" Version="3.0.0"/>
17-
<PackageReference Include="FSharp.SystemTextJson" Version="0.16.6"/>
18-
<PackageReference Include="Npgsql" Version="5.0.4"/>
19-
<PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8"/>
20-
<PackageReference Include="SqlStreamStore.Postgres" Version="1.2.0-beta.8"/>
15+
<PackageReference Update="FSharp.Core" Version="5.0.0" />
16+
<PackageReference Include="FSharp.Prelude" Version="3.0.0" />
17+
<PackageReference Include="FSharp.SystemTextJson" Version="0.16.6" />
18+
<PackageReference Include="Npgsql" Version="5.0.4" />
19+
<PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8" />
20+
<PackageReference Include="SqlStreamStore.Postgres" Version="1.2.0-beta.8" />
2121
</ItemGroup>
2222

2323
<ItemGroup>
24-
<Compile Include="Infrastructure.fs"/>
25-
<Compile Include="SqlStreamStoreExtensions.fs"/>
26-
<Compile Include="StreamEvent.fs"/>
27-
<Compile Include="Create.fs"/>
28-
<Compile Include="Connect.fs"/>
29-
<Compile Include="Append.fs"/>
30-
<Compile Include="Read.fs"/>
31-
<Compile Include="Get.fs"/>
32-
<Compile Include="Subscribe.fs"/>
24+
<Compile Include="SqlStreamStoreExtensions.fs" />
25+
<Compile Include="Create.fs" />
26+
<Compile Include="Connect.fs" />
27+
<Compile Include="Append.fs" />
28+
<Compile Include="Read.fs" />
29+
<Compile Include="Get.fs" />
30+
<Compile Include="Subscribe.fs" />
3331
</ItemGroup>
3432

3533
</Project>

‎src/SqlStreamStoreExtensions.fs‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,7 @@ module SqlStreamExtensions =
1515
asyncResult { return! streamMessage.GetJsonData() }
1616

1717
let private getJsonDataAs<'a> (streamMessage: StreamMessage) =
18-
asyncResult {
19-
let! json = getJsonData streamMessage
20-
return! JayJson.decode<'a> json
21-
}
18+
asyncResult { return! streamMessage.GetJsonDataAs<'a>() }
2219

2320
type StreamMessage with
2421
/// Gets the Json Data of the message. If prefetch is enabled, this will be a fast operation.

‎src/StreamEvent.fs‎

Lines changed: 0 additions & 135 deletions
This file was deleted.

0 commit comments

Comments
 (0)