Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
# CHANGELOG (v0.1.2)
# CHANGELOG (v0.1.3)

## 0.1.2 (2025-08-02)
## 0.1.3 (2025-08-02)

### Backwards incompatible changes for 0.1.0
### Backwards incompatible changes for 0.1.2
* None

### Bug fixes
* None

### Enhancements
* Downgrade Elixir version and Phoenix liveview to allow more projects to hook in this library
* [[`PR-4`](https://github.com/observer_web/deployex/pull/4)] Adding Filtering for tracing modules/functions
* Adjusted Logger messages

# Previous Releases
* [0.1.2 🚀 (2025-01-06)](https://github.com/thiagoesteves/observer_web/blob/v0.1.2/CHANGELOG.md)
* [0.1.0 🚀 (2025-01-06)](https://github.com/thiagoesteves/observer_web/blob/v0.1.0/CHANGELOG.md)
3 changes: 0 additions & 3 deletions lib/observer_web/apps.ex
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,6 @@ defmodule ObserverWeb.Apps do
* https://github.com/shinyscorpion/wobserver
"""

require Logger

alias ObserverWeb.Apps.Helper
alias ObserverWeb.Rpc

Expand Down Expand Up @@ -257,7 +255,6 @@ defmodule ObserverWeb.Apps do
# coveralls-ignore-start
def new(%{id: id} = attrs) do
name = "#{inspect(id)}"
Logger.warning("Entity ID not mapped: #{name}")

struct(
__MODULE__,
Expand Down
2 changes: 0 additions & 2 deletions lib/observer_web/tracer.ex
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,6 @@ defmodule ObserverWeb.Tracer do
* https://github.com/thiagoesteves/deployex/blob/main/lib/deployex/tracer.ex
"""

require Logger

alias ObserverWeb.Rpc
alias ObserverWeb.Tracer.Server, as: TServer

Expand Down
13 changes: 1 addition & 12 deletions lib/observer_web/tracer/server.ex
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@ defmodule ObserverWeb.Tracer.Server do

@impl true
def init(_args) do
Logger.info("Initializing Tracing Server")
{:ok, %Tracer{}}
end

Expand All @@ -33,8 +32,6 @@ defmodule ObserverWeb.Tracer.Server do
session_id: session_id
})
when rcv_session_id == session_id do
Logger.info("The Trace session_id: #{inspect(session_id)} was requested to stop.")

:dbg.stop()

{:reply, :ok, %Tracer{}}
Expand Down Expand Up @@ -71,8 +68,6 @@ defmodule ObserverWeb.Tracer.Server do
) do
Process.monitor(request_pid)

Logger.info("New Trace Session: #{session_id} functions: #{inspect(functions_by_node)}")

tracer_pid = self()
# The local node is always present in the trace list of nodes.
# The following list will indicate to the trace handler whether the node
Expand Down Expand Up @@ -138,8 +133,6 @@ defmodule ObserverWeb.Tracer.Server do
request_pid: request_pid
})
when rcv_session_id == session_id do
Logger.info("The Trace session_id: #{inspect(session_id)} timed out")

:dbg.stop()

send(request_pid, msg)
Expand All @@ -154,12 +147,10 @@ defmodule ObserverWeb.Tracer.Server do
# NOTE: Messages from handle_trace
def handle_info({:stop_tracing, rcv_session_id} = msg, %Tracer{
session_id: session_id,
max_messages: max_messages,
max_messages: _max_messages,
request_pid: request_pid
})
when rcv_session_id == session_id do
Logger.info("Max messages (#{max_messages}) reached for session: #{inspect(session_id)}.")

send(request_pid, msg)

{:noreply, %Tracer{}}
Expand All @@ -175,8 +166,6 @@ defmodule ObserverWeb.Tracer.Server do
%{request_pid: request_pid}
)
when target_pid == request_pid do
Logger.warning("target process was terminated")

:dbg.stop()

{:noreply, %Tracer{}}
Expand Down
6 changes: 0 additions & 6 deletions lib/web/pages/apps/page.ex
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,6 @@ defmodule Observer.Web.Apps.Page do

use Observer.Web, :live_component

require Logger

alias Observer.Web.Apps.Legend
alias Observer.Web.Apps.Port
alias Observer.Web.Apps.Process
Expand Down Expand Up @@ -352,8 +350,6 @@ defmodule Observer.Web.Apps.Page do
|> String.to_charlist()
|> :erlang.list_to_pid()

Logger.info("Retrieving process info for pid: #{request_id}")

%{
info: Apps.Process.info(pid),
id_string: request_id,
Expand All @@ -371,8 +367,6 @@ defmodule Observer.Web.Apps.Page do

node = String.to_existing_atom(service)

Logger.info("Retrieving port info for port: #{request_id}")

%{
info: Apps.Port.info(node, port),
id_string: request_id,
Expand Down
2 changes: 1 addition & 1 deletion mix.exs
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ defmodule ObserverWeb.MixProject do
use Mix.Project

@source_url "https://github.com/thiagoesteves/observer_web"
@version "0.1.2"
@version "0.1.3"

def project do
[
Expand Down
15 changes: 6 additions & 9 deletions test/observer_web/tracer_test.exs
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ defmodule ObserverWeb.TracerTest do
use ExUnit.Case, async: true

import Mox
import ExUnit.CaptureLog

alias ObserverWeb.Tracer
alias ObserverWeb.TracerFixtures
Expand Down Expand Up @@ -307,16 +306,14 @@ defmodule ObserverWeb.TracerTest do
}
]

assert capture_log(fn ->
spawn(fn ->
{:ok, %{session_id: _session_id}} =
Tracer.start_trace(functions, %{max_messages: 20})
end)
spawn(fn ->
{:ok, %{session_id: _session_id}} =
Tracer.start_trace(functions, %{max_messages: 20})
end)

:timer.sleep(50)
:timer.sleep(50)

assert %Tracer{status: :idle} = Tracer.state()
end) =~ "target process was terminated"
assert %Tracer{status: :idle} = Tracer.state()
end

defp terminate_tracing(session_id) do
Expand Down
2 changes: 0 additions & 2 deletions test/observer_web/web/live/tracing_test.exs
Original file line number Diff line number Diff line change
Expand Up @@ -325,8 +325,6 @@ defmodule Observer.Web.TracingLiveTest do
index_live
|> element("#tracing-multi-select-stop", "STOP")
|> render_click()

assert render(index_live) =~ "Enum."
end

test "Observer timing out", %{conn: conn} do
Expand Down