revert search streams and debug experiments

contrib/ruby_event_store-rom/lib/ruby_event_store/rom/event_repository.rb

@@ -94,10 +94,6 @@ def streams_of(event_id)
         @stream_entries.streams_of(event_id).map { |name| Stream.new(name) }
       end
 
-      def search_streams(stream_name)
-        @stream_entries.search_streams(stream_name)
-      end
-
       private
 
       def validate_event_ids(event_ids)

contrib/ruby_event_store-rom/lib/ruby_event_store/rom/repositories/stream_entries.rb

@@ -46,16 +46,6 @@ def position_in_stream(event_id, stream)
         def event_in_stream?(event_id, stream)
           stream_entries.by_stream(stream).by_event_id(event_id).exist?
         end
-
-        def search_streams(stream_name)
-          stream_entries
-            .where { stream.like("#{stream_name}%") }
-            .distinct
-            .limit(10)
-            .order(:stream)
-            .pluck(:stream)
-            .map { |name| Stream.new(name) }
-        end
       end
     end
   end

contrib/ruby_event_store-sequel/lib/ruby_event_store/sequel/event_repository.rb

@@ -172,14 +172,6 @@ def streams_of(event_id)
         @db[:event_store_events_in_streams].where(event_id: event_id).map { |h| Stream.new(h[:stream]) }
       end
 
-      def search_streams(stream_name)
-        @db[:event_store_events_in_streams]
-          .where(::Sequel.like(:stream, "#{stream_name}%"))
-          .select(:stream)
-          .limit(10)
-          .map { |h| Stream.new(h[:stream]) }
-      end
-
       private
 
       def optimize_timestamp(valid_at, created_at)

ruby_event_store-active_record/lib/ruby_event_store/active_record/event_repository.rb

@@ -47,10 +47,6 @@ def count(specification)
         @repo_reader.count(specification)
       end
 
-      def search_streams(stream_name)
-        @repo_reader.search_streams(stream_name)
-      end
-
       def update_messages(records)
         hashes = records.map { |record| upsert_hash(record, record.serialize(serializer)) }
         for_update = records.map(&:event_id)
@@ -85,10 +81,6 @@ def event_in_stream?(event_id, stream)
         @repo_reader.event_in_stream?(event_id, stream)
       end
 
-      def inspect
-        "#{self.class} with #{::ActiveRecord::Base.connection.adapter_name} db adapter"
-      end
-
       private
 
       attr_reader :serializer

ruby_event_store-active_record/lib/ruby_event_store/active_record/event_repository_reader.rb

@@ -57,14 +57,6 @@ def event_in_stream?(event_id, stream)
         @stream_klass.where(event_id: event_id, stream: stream.name).exists?
       end
 
-      def search_streams(stream)
-        @stream_klass
-          .where("stream LIKE ?", "#{stream}%")
-          .limit(10)
-          .pluck("distinct stream")
-          .map { |name| Stream.new(name) }
-      end
-
       private
 
       attr_reader :serializer

ruby_event_store-active_record/spec/event_repository_spec.rb

@@ -183,65 +183,6 @@ module ActiveRecord
         expect(event_record.valid_at).to eq(t2)
       end
 
-      specify "finds streams that match the search phrase" do
-        repository.append_to_stream(
-          [SRecord.new(event_id: e1 = SecureRandom.uuid)],
-          s1 = Stream.new("Dummy$#{e1}"),
-          ExpectedVersion.any
-        )
-        repository.append_to_stream(
-          [SRecord.new(event_id: e2 = SecureRandom.uuid)],
-          s2 = Stream.new("Dummy$#{e2}"),
-          ExpectedVersion.any
-        )
-        repository.append_to_stream(
-          [SRecord.new(event_id: e3 = SecureRandom.uuid)],
-          s3 = Stream.new("Dummy$#{e3}"),
-          ExpectedVersion.any
-        )
-
-        expect(repository.search_streams("Du")).to contain_exactly(s3, s2, s1)
-        expect(repository.search_streams("Dummy")).to contain_exactly(s3, s2, s1)
-      end
-
-      specify "limits searched streams to 10" do
-        11.times do |index|
-        repository.append_to_stream(
-          [SRecord.new(event_id: e1 = SecureRandom.uuid)],
-          Stream.new("Dummy$#{e1}"),
-          ExpectedVersion.any
-        )
-        end
-
-        expect(repository.search_streams("Du").size).to eq 10
-      end
-
-      specify "finds no streams when search phrase doesn't match anything" do
-        repository.append_to_stream(
-          [SRecord.new(event_id: e1 = SecureRandom.uuid)],
-          Stream.new("Dummy$#{e1}"),
-          ExpectedVersion.any
-        )
-        repository.append_to_stream(
-          [SRecord.new(event_id: e2 = SecureRandom.uuid)],
-          Stream.new("Dummy$#{e2}"),
-          ExpectedVersion.any
-        )
-        repository.append_to_stream(
-          [SRecord.new(event_id: e3 = SecureRandom.uuid)],
-          Stream.new("Dummy$#{e3}"),
-          ExpectedVersion.any
-        )
-
-        expect(repository.search_streams("Da")).to eq([])
-        expect(repository.search_streams("da")).to eq([])
-        expect(repository.search_streams("dam")).to eq([])
-        expect(repository.search_streams("damm")).to eq([])
-        expect(repository.search_streams("dammy")).to eq([])
-        expect(repository.search_streams("Dammy")).to eq([])
-      end
-
-
       specify "with batches and bi-temporal queries use offset + limit" do
         repository.append_to_stream(
           [
@@ -378,12 +319,6 @@ module ActiveRecord
         }x
       end
 
-      describe "#inspect" do
-        specify "returns string representation" do
-          expect(repository.inspect).to eq("RubyEventStore::ActiveRecord::EventRepository with #{::ActiveRecord::Base.connection.adapter_name} db adapter")
-        end
-      end
-
       private
 
       def with_precision(time)

ruby_event_store-browser/elm/src/Api.elm

@@ -1,9 +1,9 @@
-module Api exposing (Event, PaginatedList, PaginationLink, PaginationLinks, RemoteResource(..), SearchStream, Stats, Stream, emptyPaginatedList, eventDecoder, eventsDecoder, getEvent, getEvents, getSearchStreams, getStats, getStream, searchStreamsDecoder)
+module Api exposing (Event, PaginatedList, PaginationLink, PaginationLinks, RemoteResource(..), Stream, emptyPaginatedList, eventDecoder, eventsDecoder, getEvent, getEvents, getStream)
 
 import Flags exposing (Flags)
 import Http
 import Iso8601
-import Json.Decode exposing (Decoder, field, int, list, maybe, string, succeed, value)
+import Json.Decode exposing (Decoder, field, list, maybe, string, succeed, value)
 import Json.Decode.Pipeline exposing (optional, optionalAt, required, requiredAt)
 import Json.Encode exposing (encode)
 import Maybe.Extra
@@ -38,15 +38,6 @@ type alias Event =
     }
 
 
-type alias SearchStream =
-    { streamId : String
-    }
-
-
-type alias Stats =
-    { eventsInTotal : Int
-    }
-
 
 type alias PaginatedList a =
     { pagination : Pagination.Specification
@@ -94,15 +85,6 @@ streamUrl flags streamId =
     buildUrl (Url.toString flags.apiUrl ++ "/streams") streamId
 
 
-searchStreamsUrl : Flags -> String -> String
-searchStreamsUrl flags query =
-    buildUrl (Url.toString flags.apiUrl ++ "/search_streams") query
-
-
-getStatsUrl : Flags -> String
-getStatsUrl flags =
-    Url.toString flags.apiUrl ++ "/stats"
-
 
 getEvent : (Result Http.Error Event -> msg) -> Flags -> String -> Cmd msg
 getEvent msgBuilder flags eventId =
@@ -120,21 +102,6 @@ getStream msgBuilder flags streamId =
         }
 
 
-getSearchStreams : (Result Http.Error (List SearchStream) -> msg) -> Flags -> String -> Cmd msg
-getSearchStreams msgBuilder flags query =
-    Http.get
-        { url = searchStreamsUrl flags query
-        , expect = Http.expectJson msgBuilder searchStreamsDecoder
-        }
-
-
-getStats : (Result Http.Error Stats -> msg) -> Flags -> Cmd msg
-getStats msgBuilder flags =
-    Http.get
-        { url = getStatsUrl flags
-        , expect = Http.expectJson msgBuilder statsDecoder
-        }
-
 
 eventDecoder : Decoder Event
 eventDecoder =
@@ -190,29 +157,6 @@ eventsDecoder pagination =
         |> required "links" linksDecoder
 
 
-searchStreamDecoder : Decoder SearchStream
-searchStreamDecoder =
-    succeed SearchStream
-        |> required "id" string
-
-
-searchStreamsDecoder : Decoder (List SearchStream)
-searchStreamsDecoder =
-    list searchStreamDecoder
-        |> field "data"
-
-
-statsDecoder : Decoder Stats
-statsDecoder =
-    statsDecoder_
-        |> field "meta"
-
-
-statsDecoder_ : Decoder Stats
-statsDecoder_ =
-    succeed Stats
-        |> required "events_in_total" int
-
 
 linksDecoder : Decoder PaginationLinks
 linksDecoder =

ruby_event_store-browser/elm/src/Flags.elm

@@ -7,7 +7,6 @@ type alias RawFlags =
     { rootUrl : String
     , apiUrl : String
     , resVersion : String
-    , repositoryAdapter : String
     , platform : String
     }
 
@@ -16,11 +15,10 @@ type alias Flags =
     { rootUrl : Url.Url
     , apiUrl : Url.Url
     , resVersion : String
-    , repositoryAdapter : String
     , platform : String
     }
 
 
 buildFlags : RawFlags -> Maybe Flags
-buildFlags { rootUrl, apiUrl, resVersion, repositoryAdapter, platform } =
-    Maybe.map5 Flags (Url.fromString rootUrl) (Url.fromString apiUrl) (Just resVersion) (Just repositoryAdapter) (Just platform)
+buildFlags { rootUrl, apiUrl, resVersion, platform } =
+    Maybe.map4 Flags (Url.fromString rootUrl) (Url.fromString apiUrl) (Just resVersion) (Just platform)