mix format

Author: alco

packages/sync-service/lib/electric/shape_cache/pure_file_storage/chunk_index.ex

@@ -294,8 +294,7 @@ defmodule Electric.ShapeCache.PureFileStorage.ChunkIndex do
 
     {:ok,
      <<min_tx::64, min_op::64, start_pos::64, key_start_pos::64, max_tx::64, max_op::64,
-       end_pos::64,
-       key_end_pos::64>>} =
+       end_pos::64, key_end_pos::64>>} =
       :file.pread(file, mid * @full_record_width, @full_record_width)
 
     max_offset = LogOffset.new(max_tx, max_op)

packages/sync-service/lib/electric/shape_cache/pure_file_storage/key_index.ex

@@ -28,8 +28,8 @@ defmodule Electric.ShapeCache.PureFileStorage.KeyIndex do
     File.open!(path, [:read, :raw, :read_ahead], fn file ->
       Stream.unfold({file, 0}, fn {file, pos} ->
         with <<total_size::32, _label::8, tx_offset::64, op_offset::64, op_type::8,
-               log_file_entry_start_pos::64,
-               json_size::64>> <- IO.binread(file, @key_index_full_size),
+               log_file_entry_start_pos::64, json_size::64>> <-
+               IO.binread(file, @key_index_full_size),
              <<key::binary-size(^total_size - @key_index_entry_size)>> <-
                IO.binread(file, total_size - @key_index_entry_size) do
           {{key, LogOffset.new(tx_offset, op_offset), op_type, log_file_entry_start_pos,
@@ -98,8 +98,8 @@ defmodule Electric.ShapeCache.PureFileStorage.KeyIndex do
       end,
       fn {file, pos} ->
         with <<total_size::32, label::8, tx_offset::64, op_offset::64, op_type::8,
-               log_file_entry_start_pos::64,
-               json_size::64>> <- IO.binread(file, @key_index_full_size),
+               log_file_entry_start_pos::64, json_size::64>> <-
+               IO.binread(file, @key_index_full_size),
              <<key::binary-size(^total_size - @key_index_entry_size)>> <-
                IO.binread(file, total_size - @key_index_entry_size) do
           {[

packages/sync-service/test/electric/postgres/replication_client_test.exs

@@ -597,8 +597,7 @@ defmodule Electric.Postgres.ReplicationClientTest do
     pg_wal = lsn_to_wal("0/10")
 
     assert {:noreply,
-            [<<?r, received_wal::64, flushed_wal::64, flushed_wal::64, _time::64, 0::8>>],
-            state} =
+            [<<?r, received_wal::64, flushed_wal::64, flushed_wal::64, _time::64, 0::8>>], state} =
              ReplicationClient.handle_data(<<?k, pg_wal::64, 0::64, 1::8>>, state)
 
     assert state.received_wal == pg_wal