Merge pull request #1627 from Logflare/staging

Release v1.3.19

VERSION

@@ -1 +1 @@
-1.3.18
+1.3.19

assets/js/interfaces/EndpointEditor.jsx

@@ -15,6 +15,7 @@ const EndpointEditor = ({
   const [queryParams, setQueryParams] = useState({
     name: endpoint?.name || defaultValues?.name || "",
     query: endpoint?.query || "",
+    language: "bq_sql"
   })
   const [testParams, setTestParams] = useState({})
   const handleSubmit = (e) => {

config/test.exs

@@ -28,4 +28,5 @@ config :logflare, Logflare.Repo,
   pool_size: 10,
   pool: Ecto.Adapters.SQL.Sandbox
 
+config :logflare, :postgres_backend_adapter, pool_size: 3
 config :grpc, start_server: false

lib/logflare/backends.ex

@@ -29,6 +29,16 @@ defmodule Logflare.Backends do
     |> Enum.map(fn sb -> typecast_config_string_map_to_atom_map(sb) end)
   end
 
+  @doc """
+  Lists `SourceBackend`s by user
+  """
+  @spec list_source_backends_by_user_id(integer()) :: [SourceBackend.t()]
+  def list_source_backends_by_user_id(id) when is_integer(id) do
+    from(sb in SourceBackend, join: s in Source, on: true, where: s.user_id == ^id)
+    |> Repo.all()
+    |> Enum.map(fn sb -> typecast_config_string_map_to_atom_map(sb) end)
+  end
+
   @doc """
   Creates a SourceBackend for a given source.
   """
@@ -189,6 +199,18 @@ defmodule Logflare.Backends do
     end
   end
 
+  @doc """
+  Ensures that a the SourceSup is started. Only returns error tuple if not alreadt started
+  """
+  @spec ensure_source_sup_started(Source.t()) :: :ok | {:error, term()}
+  def ensure_source_sup_started(%Source{} = source) do
+    case start_source_sup(source) do
+      {:ok, _pid} -> :ok
+      {:error, :already_started} -> :ok
+      {:error, _} = err -> err
+    end
+  end
+
   @doc """
   Stops a given SourceSup for a source. if not started, it will return an error tuple.
   """