working through failing test issue

Author: amokan

lib/logflare/endpoints.ex

@@ -165,11 +165,25 @@ defmodule Logflare.Endpoints do
       {endpoint, query_string} =
         if SingleTenant.supabase_mode?() and SingleTenant.postgres_backend?() and
              endpoint_query.language != :pg_sql do
+          IO.puts("single tenant postgres backend")
+
           # translate the query
           schema_prefix = Keyword.get(SingleTenant.postgres_backend_adapter_opts(), :schema)
 
+          IO.inspect(transformed_query,
+            label: "transformed_query",
+            limit: :infinity,
+            pretty: true
+          )
+
           {:ok, q} = Logflare.Sql.translate(:bq_sql, :pg_sql, transformed_query, schema_prefix)
 
+          IO.inspect(q,
+            label: "translated_query",
+            limit: :infinity,
+            pretty: true
+          )
+
           {Map.put(endpoint_query, :language, :pg_sql), q}
         else
           {endpoint_query, transformed_query}
@@ -216,9 +230,12 @@ defmodule Logflare.Endpoints do
   """
   @spec run_cached_query(Query.t(), map()) :: run_query_return()
   def run_cached_query(query, params \\ %{}) do
+    IO.inspect(query, label: "query", limit: :infinity, pretty: true)
+
     if query.cache_duration_seconds > 0 do
       query
       |> Resolver.resolve(params)
+      |> IO.inspect(label: "resolver results", limit: :infinity, pretty: true)
       |> ResultsCache.query()
     else
       # execute the query directly

lib/logflare/endpoints/query.ex

@@ -77,7 +77,7 @@ defmodule Logflare.Endpoints.Query do
       :backend_id
     ])
     |> infer_language_from_backend()
-    |> validate_required([:name, :query, :language, :backend_id])
+    |> validate_required([:name, :query, :language])
   end
 
   def update_by_user_changeset(query, attrs) do
@@ -103,7 +103,7 @@ defmodule Logflare.Endpoints.Query do
 
   def default_validations(changeset) do
     changeset
-    |> validate_required([:name, :query, :user, :language, :backend_id])
+    |> validate_required([:name, :query, :user, :language])
     |> unique_constraint(:name, name: :endpoint_queries_name_index)
     |> unique_constraint(:token)
     |> validate_number(:max_limit, greater_than: 0, less_than: 10_001)

lib/logflare_web/controllers/endpoints_controller.ex

@@ -55,8 +55,12 @@ defmodule LogflareWeb.EndpointsController do
   def query(%{assigns: %{endpoint: endpoint}} = conn, params) do
     endpoint_query = Endpoints.map_query_sources(endpoint)
 
+    IO.inspect(endpoint_query, label: "endpoint query")
+
     case Endpoints.run_cached_query(endpoint_query, params) do
       {:ok, result} ->
+        IO.inspect(result, label: "cached_query_result")
+
         Logger.debug("Endpoint cache result, #{inspect(result, pretty: true)}")
         render(conn, "query.json", result: result.rows)
 

test/support/factory.ex

@@ -223,8 +223,8 @@ defmodule Logflare.Factory do
 
   def endpoint_factory(attrs \\ %{}) do
     user = attrs[:user] || insert(:user)
-    backend = attrs[:backend] || insert(:backend, user: user, type: :bigquery)
-    language = attrs[:language] || :bq_sql
+    backend = Map.get(attrs, :backend)
+    language = Map.get(attrs, :language, :bq_sql)
 
     %Query{
       user: user,