ignore: mix format.

Author: thruflo

packages/sync-service/lib/electric/shapes/api.ex

@@ -517,6 +517,7 @@ defmodule Electric.Shapes.Api do
   defp handle_live_request(%Request{params: %{experimental_live_sse: true}} = request) do
     stream_sse_events(request)
   end
+
   defp handle_live_request(%Request{} = request) do
     hold_until_change(request)
   end
@@ -742,7 +743,10 @@ defmodule Electric.Shapes.Api do
     encode(api, :message, message)
   end
 
-  def encode_message(%Request{api: api, params: %{live: true, experimental_live_sse: true}}, message) do
+  def encode_message(
+        %Request{api: api, params: %{live: true, experimental_live_sse: true}},
+        message
+      ) do
     encode_sse(api, :message, message)
   end
 

packages/sync-service/lib/electric/shapes/api/params.ex

@@ -161,7 +161,9 @@ defmodule Electric.Shapes.Api.Params do
     if live do
       changeset
     else
-      validate_exclusion(changeset, @tmp_sse_flag, [true], message: "can't be true unless live is also true")
+      validate_exclusion(changeset, @tmp_sse_flag, [true],
+        message: "can't be true unless live is also true"
+      )
     end
   end
 

packages/sync-service/test/electric/plug/serve_shape_plug_test.exs

@@ -821,7 +821,8 @@ defmodule Electric.Plug.ServeShapePlugTest do
       :ok
     end
 
-    test "returns proper SSE format response when experimental_live_sse=true and live=true", ctx do
+    test "returns proper SSE format response when experimental_live_sse=true and live=true",
+         ctx do
       Mock.ShapeCache
       |> expect(:get_shape, fn @test_shape, _opts ->
         {@test_shape_handle, @test_offset}
@@ -858,6 +859,7 @@ defmodule Electric.Plug.ServeShapePlugTest do
           {"cache-control", value} -> value
           _ -> nil
         end)
+
       assert cache_control =~ "public"
       assert cache_control =~ "max-age="
 
@@ -880,12 +882,13 @@ defmodule Electric.Plug.ServeShapePlugTest do
         |> call_serve_shape_plug(ctx)
 
       assert conn.status == 400
+
       assert Jason.decode!(conn.resp_body) == %{
-        "message" => "Invalid request",
-        "errors" => %{
-          "experimental_live_sse" => ["can't be true unless live is also true"]
-        }
-      }
+               "message" => "Invalid request",
+               "errors" => %{
+                 "experimental_live_sse" => ["can't be true unless live is also true"]
+               }
+             }
     end
 
     test "sends properly formatted SSE events", ctx do