diff --git a/modules/nixos/services/communication/matrix/default.nix b/modules/nixos/services/communication/matrix/default.nix
index 607fa72..cd5aff2 100644
--- a/modules/nixos/services/communication/matrix/default.nix
+++ b/modules/nixos/services/communication/matrix/default.nix
@@ -112,10 +112,9 @@ in {
       (mkMautrix "mautrix-telegram" 2 {})
       (mkMautrix "mautrix-whatsapp" 3 {})
       (mkMautrix "arrtrix" 4 {
-        settings.network.webhooks.radarr = {
-          enabled = true;
-          path = "/_arrtrix/webhooks/radarr";
-          secret = "";
+        settings.observability = {
+          otlp_grpc_endpoint = "http://[::1]:1000";
+          service_name = "arrtrix";
         };
       })
       {
diff --git a/modules/nixos/services/media/servarr/default.nix b/modules/nixos/services/media/servarr/default.nix
index ae0e3b0..23255c0 100644
--- a/modules/nixos/services/media/servarr/default.nix
+++ b/modules/nixos/services/media/servarr/default.nix
@@ -212,6 +212,18 @@ in {
 
                   resource =
                     {
+                      "${service}_notification_webhook" = mkIf (lib.elem service ["radarr" "sonarr" "whisparr" "lidarr" "readarr"]) {
+                        "arrtrix" =
+                          {
+                            method = 1; # HTTP METHOD 1=POST, 2=PUT
+                            name = "Arrtrix";
+                            url = "http://[::1]${config'.services.arrtrix.settings.appservice.port}";
+                          }
+                          // (lib.optionalAttrs (lib.elem service ["radarr" "whisparr"]) {
+                            onMovieDelete = true;
+                          });
+                      };
+
                       "${service}_root_folder" = mkIf (lib.elem service ["radarr" "sonarr" "whisparr"]) (
                         rootFolders
                         |> lib.imap (i: f: lib.nameValuePair "local${toString i}" {path = f;})
diff --git a/modules/nixos/temp/services/arrtrix/default.nix b/modules/nixos/temp/services/arrtrix/default.nix
index 618de39..b8c7457 100644
--- a/modules/nixos/temp/services/arrtrix/default.nix
+++ b/modules/nixos/temp/services/arrtrix/default.nix
@@ -48,6 +48,11 @@
         time_format = " ";
       };
     };
+    observability = {
+      otlp_grpc_endpoint = "";
+      service_name = "arrtrix";
+      resource_attributes = {};
+    };
   };
 in {
   options.services.arrtrix = {
diff --git a/packages/arrtrix/go.mod b/packages/arrtrix/go.mod
index eed27b5..81a6c93 100644
--- a/packages/arrtrix/go.mod
+++ b/packages/arrtrix/go.mod
@@ -3,41 +3,58 @@ module sneeuwvlok/packages/arrtrix
 go 1.25.0
 
 require (
+	github.com/rs/zerolog v1.34.0
 	go.mau.fi/util v0.9.7
+	go.mau.fi/zeroconfig v0.2.0
+	go.opentelemetry.io/otel v1.43.0
+	go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc v0.19.0
+	go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v1.43.0
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0
+	go.opentelemetry.io/otel/log v0.19.0
+	go.opentelemetry.io/otel/metric v1.43.0
+	go.opentelemetry.io/otel/sdk v1.43.0
+	go.opentelemetry.io/otel/sdk/log v0.19.0
+	go.opentelemetry.io/otel/sdk/metric v1.43.0
+	go.opentelemetry.io/otel/trace v1.43.0
+	gopkg.in/yaml.v3 v3.0.1
+	maunium.net/go/mauflag v1.0.0
 	maunium.net/go/mautrix v0.26.4
 )
 
-require (
-	github.com/kr/pretty v0.3.1 // indirect
-	github.com/rogpeppe/go-internal v1.10.0 // indirect
-	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
-)
-
 require (
 	filippo.io/edwards25519 v1.2.0 // indirect
+	github.com/cenkalti/backoff/v5 v5.0.3 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/coder/websocket v1.8.14 // indirect
 	github.com/coreos/go-systemd/v22 v22.6.0 // indirect
+	github.com/go-logr/logr v1.4.3 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0 // indirect
 	github.com/lib/pq v1.11.2 // indirect
 	github.com/mattn/go-colorable v0.1.14 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/mattn/go-sqlite3 v1.14.34 // indirect
 	github.com/petermattis/goid v0.0.0-20260226131333-17d1149c6ac6 // indirect
 	github.com/rs/xid v1.6.0 // indirect
-	github.com/rs/zerolog v1.34.0 // indirect
 	github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e // indirect
 	github.com/tidwall/gjson v1.18.0 // indirect
 	github.com/tidwall/match v1.2.0 // indirect
 	github.com/tidwall/pretty v1.2.1 // indirect
 	github.com/tidwall/sjson v1.2.5 // indirect
 	github.com/yuin/goldmark v1.7.16 // indirect
-	go.mau.fi/zeroconfig v0.2.0 // indirect
+	go.opentelemetry.io/auto/sdk v1.2.1 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0 // indirect
+	go.opentelemetry.io/proto/otlp v1.10.0 // indirect
 	golang.org/x/crypto v0.49.0 // indirect
 	golang.org/x/exp v0.0.0-20260312153236-7ab1446f8b90 // indirect
 	golang.org/x/net v0.52.0 // indirect
 	golang.org/x/sync v0.20.0 // indirect
 	golang.org/x/sys v0.42.0 // indirect
 	golang.org/x/text v0.35.0 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9 // indirect
+	google.golang.org/grpc v1.80.0 // indirect
+	google.golang.org/protobuf v1.36.11 // indirect
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
-	maunium.net/go/mauflag v1.0.0 // indirect
 )
diff --git a/packages/arrtrix/go.sum b/packages/arrtrix/go.sum
index d8e9404..8d8f5ab 100644
--- a/packages/arrtrix/go.sum
+++ b/packages/arrtrix/go.sum
@@ -2,20 +2,33 @@ filippo.io/edwards25519 v1.2.0 h1:crnVqOiS4jqYleHd9vaKZ+HKtHfllngJIiOpNpoJsjo=
 filippo.io/edwards25519 v1.2.0/go.mod h1:xzAOLCNug/yB62zG1bQ8uziwrIqIuxhctzJT18Q77mc=
 github.com/DATA-DOG/go-sqlmock v1.5.2 h1:OcvFkGmslmlZibjAjaHm3L//6LiuBgolP7OputlJIzU=
 github.com/DATA-DOG/go-sqlmock v1.5.2/go.mod h1:88MAG/4G7SMwSE3CeA0ZKzrT5CiOU3OJ+JlNzwDqpNU=
+github.com/cenkalti/backoff/v5 v5.0.3 h1:ZN+IMa753KfX5hd8vVaMixjnqRZ3y8CuJKRKj1xcsSM=
+github.com/cenkalti/backoff/v5 v5.0.3/go.mod h1:rkhZdG3JZukswDf7f0cwqPNk4K0sa+F97BxZthm/crw=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/coder/websocket v1.8.14 h1:9L0p0iKiNOibykf283eHkKUHHrpG7f65OE3BhhO7v9g=
 github.com/coder/websocket v1.8.14/go.mod h1:NX3SzP+inril6yawo5CQXx8+fk145lPDC6pumgx0mVg=
 github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
 github.com/coreos/go-systemd/v22 v22.6.0 h1:aGVa/v8B7hpb0TKl0MWoAavPDmHvobFe5R5zn0bCJWo=
 github.com/coreos/go-systemd/v22 v22.6.0/go.mod h1:iG+pp635Fo7ZmV/j14KUcmEyWF+0X7Lua8rrTWzYgWU=
-github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
+github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
 github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
-github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
+github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
+github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
+github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
+github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0 h1:HWRh5R2+9EifMyIHV7ZV+MIZqgz+PMpZ14Jynv3O2Zs=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0/go.mod h1:JfhWUomR1baixubs02l85lZYYOm7LV6om4ceouMv45c=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
-github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
-github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/lib/pq v1.11.2 h1:x6gxUeu39V0BHZiugWe8LXZYZ+Utk7hSJGThs8sdzfs=
@@ -31,13 +44,11 @@ github.com/mattn/go-sqlite3 v1.14.34 h1:3NtcvcUnFBPsuRcno8pUtupspG/GM+9nZ88zgJcp
 github.com/mattn/go-sqlite3 v1.14.34/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
 github.com/petermattis/goid v0.0.0-20260226131333-17d1149c6ac6 h1:rh2lKw/P/EqHa724vYH2+VVQ1YnW4u6EOXl0PMAovZE=
 github.com/petermattis/goid v0.0.0-20260226131333-17d1149c6ac6/go.mod h1:pxMtw7cyUw6B2bRH0ZBANSPg+AoSud1I1iyJHI69jH4=
-github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
-github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ=
-github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
+github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
 github.com/rs/xid v1.6.0 h1:fV591PaemRlL6JfRxGDEPl69wICngIQ3shQtzfy2gxU=
 github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0=
 github.com/rs/zerolog v1.34.0 h1:k43nTLIwcTVQAncfCw4KZ2VY6ukYoZaBPNOE8txlOeY=
@@ -63,6 +74,36 @@ go.mau.fi/util v0.9.7 h1:AWGNbJfz1zRcQOKeOEYhKUG2fT+/26Gy6kyqcH8tnBg=
 go.mau.fi/util v0.9.7/go.mod h1:5T2f3ZWZFAGgmFwg3dGw7YK6kIsb9lryDzvynoR98pE=
 go.mau.fi/zeroconfig v0.2.0 h1:e/OGEERqVRRKlgaro7E6bh8xXiKFSXB3eNNIud7FUjU=
 go.mau.fi/zeroconfig v0.2.0/go.mod h1:J0Vn0prHNOm493oZoQ84kq83ZaNCYZnq+noI1b1eN8w=
+go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
+go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
+go.opentelemetry.io/otel v1.43.0 h1:mYIM03dnh5zfN7HautFE4ieIig9amkNANT+xcVxAj9I=
+go.opentelemetry.io/otel v1.43.0/go.mod h1:JuG+u74mvjvcm8vj8pI5XiHy1zDeoCS2LB1spIq7Ay0=
+go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc v0.19.0 h1:Dn8rkudDzY6KV9dr/D/bTUuWgqDf9xe0rr4G2elrn0Y=
+go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc v0.19.0/go.mod h1:gMk9F0xDgyN9M/3Ed5Y1wKcx/9mlU91NXY2SNq7RQuU=
+go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v1.43.0 h1:8UQVDcZxOJLtX6gxtDt3vY2WTgvZqMQRzjsqiIHQdkc=
+go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v1.43.0/go.mod h1:2lmweYCiHYpEjQ/lSJBYhj9jP1zvCvQW4BqL9dnT7FQ=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0 h1:88Y4s2C8oTui1LGM6bTWkw0ICGcOLCAI5l6zsD1j20k=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0/go.mod h1:Vl1/iaggsuRlrHf/hfPJPvVag77kKyvrLeD10kpMl+A=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0 h1:RAE+JPfvEmvy+0LzyUA25/SGawPwIUbZ6u0Wug54sLc=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0/go.mod h1:AGmbycVGEsRx9mXMZ75CsOyhSP6MFIcj/6dnG+vhVjk=
+go.opentelemetry.io/otel/log v0.19.0 h1:KUZs/GOsw79TBBMfDWsXS+KZ4g2Ckzksd1ymzsIEbo4=
+go.opentelemetry.io/otel/log v0.19.0/go.mod h1:5DQYeGmxVIr4n0/BcJvF4upsraHjg6vudJJpnkL6Ipk=
+go.opentelemetry.io/otel/metric v1.43.0 h1:d7638QeInOnuwOONPp4JAOGfbCEpYb+K6DVWvdxGzgM=
+go.opentelemetry.io/otel/metric v1.43.0/go.mod h1:RDnPtIxvqlgO8GRW18W6Z/4P462ldprJtfxHxyKd2PY=
+go.opentelemetry.io/otel/sdk v1.43.0 h1:pi5mE86i5rTeLXqoF/hhiBtUNcrAGHLKQdhg4h4V9Dg=
+go.opentelemetry.io/otel/sdk v1.43.0/go.mod h1:P+IkVU3iWukmiit/Yf9AWvpyRDlUeBaRg6Y+C58QHzg=
+go.opentelemetry.io/otel/sdk/log v0.19.0 h1:scYVLqT22D2gqXItnWiocLUKGH9yvkkeql5dBDiXyko=
+go.opentelemetry.io/otel/sdk/log v0.19.0/go.mod h1:vFBowwXGLlW9AvpuF7bMgnNI95LiW10szrOdvzBHlAg=
+go.opentelemetry.io/otel/sdk/log/logtest v0.19.0 h1:BEbF7ZBB6qQloV/Ub1+3NQoOUnVtcGkU3XX4Ws3GQfk=
+go.opentelemetry.io/otel/sdk/log/logtest v0.19.0/go.mod h1:Lua81/3yM0wOmoHTokLj9y9ADeA02v1naRrVrkAZuKk=
+go.opentelemetry.io/otel/sdk/metric v1.43.0 h1:S88dyqXjJkuBNLeMcVPRFXpRw2fuwdvfCGLEo89fDkw=
+go.opentelemetry.io/otel/sdk/metric v1.43.0/go.mod h1:C/RJtwSEJ5hzTiUz5pXF1kILHStzb9zFlIEe85bhj6A=
+go.opentelemetry.io/otel/trace v1.43.0 h1:BkNrHpup+4k4w+ZZ86CZoHHEkohws8AY+WTX09nk+3A=
+go.opentelemetry.io/otel/trace v1.43.0/go.mod h1:/QJhyVBUUswCphDVxq+8mld+AvhXZLhe+8WVFxiFff0=
+go.opentelemetry.io/proto/otlp v1.10.0 h1:IQRWgT5srOCYfiWnpqUYz9CVmbO8bFmKcwYxpuCSL2g=
+go.opentelemetry.io/proto/otlp v1.10.0/go.mod h1:/CV4QoCR/S9yaPj8utp3lvQPoqMtxXdzn7ozvvozVqk=
+go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
+go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
 golang.org/x/crypto v0.49.0 h1:+Ng2ULVvLHnJ/ZFEq4KdcDd/cfjrrjjNSXNzxg0Y4U4=
 golang.org/x/crypto v0.49.0/go.mod h1:ErX4dUh2UM+CFYiXZRTcMpEcN8b/1gxEuv3nODoYtCA=
 golang.org/x/exp v0.0.0-20260312153236-7ab1446f8b90 h1:jiDhWWeC7jfWqR9c/uplMOqJ0sbNlNWv0UkzE0vX1MA=
@@ -78,6 +119,16 @@ golang.org/x/sys v0.42.0 h1:omrd2nAlyT5ESRdCLYdm3+fMfNFE/+Rf4bDIQImRJeo=
 golang.org/x/sys v0.42.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
 golang.org/x/text v0.35.0 h1:JOVx6vVDFokkpaq1AEptVzLTpDe9KGpj5tR4/X+ybL8=
 golang.org/x/text v0.35.0/go.mod h1:khi/HExzZJ2pGnjenulevKNX1W67CUy0AsXcNubPGCA=
+gonum.org/v1/gonum v0.17.0 h1:VbpOemQlsSMrYmn7T2OUvQ4dqxQXU+ouZFQsZOx50z4=
+gonum.org/v1/gonum v0.17.0/go.mod h1:El3tOrEuMpv2UdMrbNlKEh9vd86bmQ6vqIcDwxEOc1E=
+google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9 h1:VPWxll4HlMw1Vs/qXtN7BvhZqsS9cdAittCNvVENElA=
+google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9/go.mod h1:7QBABkRtR8z+TEnmXTqIqwJLlzrZKVfAUm7tY3yGv0M=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9 h1:m8qni9SQFH0tJc1X0vmnpw/0t+AImlSvp30sEupozUg=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
+google.golang.org/grpc v1.80.0 h1:Xr6m2WmWZLETvUNvIUmeD5OAagMw3FiKmMlTdViWsHM=
+google.golang.org/grpc v1.80.0/go.mod h1:ho/dLnxwi3EDJA4Zghp7k2Ec1+c2jqup0bFkw07bwF4=
+google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
+google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
diff --git a/packages/arrtrix/pkg/config/config.go b/packages/arrtrix/pkg/config/config.go
index c3b11b8..ff97e98 100644
--- a/packages/arrtrix/pkg/config/config.go
+++ b/packages/arrtrix/pkg/config/config.go
@@ -6,6 +6,8 @@ import (
 	"gopkg.in/yaml.v3"
 
 	"maunium.net/go/mautrix/bridgev2/bridgeconfig"
+
+	"sneeuwvlok/packages/arrtrix/pkg/observability"
 )
 
 type Config struct {
@@ -17,6 +19,7 @@ type Config struct {
 	AppService bridgeconfig.AppserviceConfig `yaml:"appservice"`
 	Logging    zeroconfig.Config             `yaml:"logging"`
 
+	Observability   observability.Config             `yaml:"observability"`
 	EnvConfigPrefix string                           `yaml:"env_config_prefix"`
 	ManagementTexts bridgeconfig.ManagementRoomTexts `yaml:"management_room_texts"`
 }
@@ -34,6 +37,7 @@ func (c *Config) applyDefaults() {
 	if c.Homeserver.Software == "" {
 		c.Homeserver.Software = bridgeconfig.SoftwareStandard
 	}
+	c.Observability.ApplyDefaults()
 }
 
 func (c *Config) Compile() bridgeconfig.Config {
diff --git a/packages/arrtrix/pkg/matrixcmd/processor.go b/packages/arrtrix/pkg/matrixcmd/processor.go
index 1dabfd6..a4f15df 100644
--- a/packages/arrtrix/pkg/matrixcmd/processor.go
+++ b/packages/arrtrix/pkg/matrixcmd/processor.go
@@ -8,6 +8,8 @@ import (
 	"strings"
 
 	"github.com/rs/zerolog"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/codes"
 
 	"maunium.net/go/mautrix/bridgev2"
 	"maunium.net/go/mautrix/bridgev2/bridgeconfig"
@@ -15,6 +17,8 @@ import (
 	"maunium.net/go/mautrix/event"
 	"maunium.net/go/mautrix/format"
 	"maunium.net/go/mautrix/id"
+
+	"sneeuwvlok/packages/arrtrix/pkg/observability"
 )
 
 type Handler interface {
@@ -110,6 +114,9 @@ func (p *Processor) Handlers() []Handler {
 }
 
 func (p *Processor) Handle(ctx context.Context, roomID id.RoomID, eventID id.EventID, user *bridgev2.User, message string, replyTo id.EventID) {
+	ctx, span := observability.StartSpan(ctx, "arrtrix.matrix.command")
+	defer span.End()
+
 	ms := &bridgev2.MessageStatus{
 		Step:   status.MsgStepCommand,
 		Status: event.MessageStatusSuccess,
@@ -117,6 +124,8 @@ func (p *Processor) Handle(ctx context.Context, roomID id.RoomID, eventID id.Eve
 
 	logCopy := zerolog.Ctx(ctx).With().Logger()
 	log := &logCopy
+	outcome := "success"
+	commandName := "unknown-command"
 
 	defer func() {
 		statusInfo := &bridgev2.MessageStatusEventInfo{
@@ -131,16 +140,21 @@ func (p *Processor) Handle(ctx context.Context, roomID id.RoomID, eventID id.Eve
 			if err, ok := recovered.(error); ok {
 				logEvt = logEvt.Err(err)
 				ms.InternalError = err
+				span.RecordError(err)
+				span.SetStatus(codes.Error, err.Error())
 			} else {
 				logEvt = logEvt.Any(zerolog.ErrorFieldName, recovered)
 				ms.InternalError = fmt.Errorf("%v", recovered)
+				span.SetStatus(codes.Error, "panic")
 			}
 			logEvt.Msg("Panic in arrtrix Matrix command handler")
 			ms.Status = event.MessageStatusFail
 			ms.IsCertain = true
 			ms.ErrorAsMessage = true
+			outcome = "panic"
 		}
 
+		observability.RecordCommand(ctx, commandName, outcome)
 		p.bridge.Matrix.SendMessageStatus(ctx, ms, statusInfo)
 	}()
 
@@ -149,10 +163,14 @@ func (p *Processor) Handle(ctx context.Context, roomID id.RoomID, eventID id.Eve
 		args = []string{"unknown-command"}
 	}
 
-	commandName := strings.ToLower(args[0])
+	commandName = strings.ToLower(args[0])
 	if actual, ok := p.alias[commandName]; ok {
 		commandName = actual
 	}
+	span.SetAttributes(
+		attribute.String("arrtrix.matrix.command.name", commandName),
+		attribute.String("matrix.room_id", roomID.String()),
+	)
 
 	portal, err := p.bridge.GetPortalByMXID(ctx, roomID)
 	if err != nil {
@@ -179,6 +197,8 @@ func (p *Processor) Handle(ctx context.Context, roomID id.RoomID, eventID id.Eve
 	handler, ok := p.command[commandName]
 	if !ok {
 		log.Debug().Str("mx_command", commandName).Msg("Received unknown Matrix room command")
+		span.SetStatus(codes.Error, "unknown command")
+		outcome = "unknown"
 		commandCtx.Reply("Unknown command, use the `help` command for help.")
 		return
 	}
@@ -188,6 +208,7 @@ func (p *Processor) Handle(ctx context.Context, roomID id.RoomID, eventID id.Eve
 	})
 	log.Debug().Msg("Received Matrix room command")
 	handler.Run(commandCtx)
+	span.SetStatus(codes.Ok, "")
 }
 
 func (c *Context) Reply(message string, args ...any) {
diff --git a/packages/arrtrix/pkg/onboarding/welcome.go b/packages/arrtrix/pkg/onboarding/welcome.go
index 14860c1..e96ea7a 100644
--- a/packages/arrtrix/pkg/onboarding/welcome.go
+++ b/packages/arrtrix/pkg/onboarding/welcome.go
@@ -6,12 +6,16 @@ import (
 	"strings"
 
 	"github.com/rs/zerolog"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/codes"
 
 	"maunium.net/go/mautrix/bridgev2"
 	"maunium.net/go/mautrix/bridgev2/bridgeconfig"
 	"maunium.net/go/mautrix/event"
 	"maunium.net/go/mautrix/format"
 	"maunium.net/go/mautrix/id"
+
+	"sneeuwvlok/packages/arrtrix/pkg/observability"
 )
 
 const handledInviteEventType = "com.arrtrix.handled_invite"
@@ -23,27 +27,49 @@ func HandleBotInvite(ctx context.Context, bridge *bridgev2.Bridge, texts bridgec
 		return
 	}
 
+	ctx, span := observability.StartSpan(ctx, "arrtrix.matrix.invite")
+	defer span.End()
+	span.SetAttributes(
+		attribute.String("matrix.room_id", evt.RoomID.String()),
+		attribute.String("matrix.sender", evt.Sender.String()),
+	)
+	outcome := "ignored"
+	defer observability.RecordInvite(ctx, outcome)
+
 	log := zerolog.Ctx(ctx)
 	sender, err := bridge.GetUserByMXID(ctx, evt.Sender)
 	if err != nil {
+		outcome = "user_lookup_failed"
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		log.Err(err).Msg("Failed to load sender for bot invite")
 		return
 	}
 	if !sender.Permissions.Commands {
+		outcome = "permission_denied"
+		span.SetStatus(codes.Error, "sender lacks command permission")
 		return
 	}
 
 	if err = bridge.Bot.EnsureJoined(ctx, evt.RoomID); err != nil {
+		outcome = "join_failed"
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		log.Err(err).Msg("Failed to accept invite to room")
 		return
 	}
 
 	members, err := bridge.Matrix.GetMembers(ctx, evt.RoomID)
 	if err != nil {
+		outcome = "member_lookup_failed"
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		log.Err(err).Msg("Failed to get members of room after accepting invite")
 		return
 	}
 	if len(members) != 2 {
+		outcome = "non_management_room"
+		span.SetStatus(codes.Error, "invite room is not a direct management room")
 		return
 	}
 
@@ -51,6 +77,9 @@ func HandleBotInvite(ctx context.Context, bridge *bridgev2.Bridge, texts bridgec
 	if assignedManagementRoom {
 		sender.ManagementRoom = evt.RoomID
 		if err = sender.Save(ctx); err != nil {
+			outcome = "management_room_save_failed"
+			span.RecordError(err)
+			span.SetStatus(codes.Error, err.Error())
 			log.Err(err).Msg("Failed to update user's management room in database")
 			return
 		}
@@ -59,10 +88,15 @@ func HandleBotInvite(ctx context.Context, bridge *bridgev2.Bridge, texts bridgec
 	message := buildWelcomeMessage(bridge, texts, sender, assignedManagementRoom)
 	content := format.RenderMarkdown(message, true, false)
 	if _, err = bridge.Bot.SendMessage(ctx, evt.RoomID, event.EventMessage, &event.Content{Parsed: &content}, nil); err != nil {
+		outcome = "welcome_send_failed"
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		log.Err(err).Msg("Failed to send welcome message to room")
 		return
 	}
 
+	outcome = "welcomed"
+	span.SetStatus(codes.Ok, "")
 	evt.Type = event.Type{Type: handledInviteEventType}
 }
 
diff --git a/packages/arrtrix/pkg/runtime/example.go b/packages/arrtrix/pkg/runtime/example.go
index 1cba7b6..c8d7ca4 100644
--- a/packages/arrtrix/pkg/runtime/example.go
+++ b/packages/arrtrix/pkg/runtime/example.go
@@ -56,6 +56,13 @@ logging:
     - type: stdout
       format: pretty-colored
 
+observability:
+  # OTLP/gRPC endpoint for logs, traces, and metrics.
+  # Set to e.g. http://127.0.0.1:4317 to enable export.
+  otlp_grpc_endpoint: ""
+  service_name: arrtrix
+  resource_attributes: {}
+
 management_room_texts:
   welcome: ""
   welcome_connected: ""
diff --git a/packages/arrtrix/pkg/runtime/main.go b/packages/arrtrix/pkg/runtime/main.go
index 42e1495..5352c54 100644
--- a/packages/arrtrix/pkg/runtime/main.go
+++ b/packages/arrtrix/pkg/runtime/main.go
@@ -18,6 +18,7 @@ import (
 	"go.mau.fi/util/exerrors"
 	"go.mau.fi/util/exzerolog"
 	"go.mau.fi/util/progver"
+	"go.opentelemetry.io/otel/codes"
 	"gopkg.in/yaml.v3"
 	flag "maunium.net/go/mauflag"
 	"maunium.net/go/mautrix/appservice"
@@ -31,6 +32,7 @@ import (
 
 	arrconfig "sneeuwvlok/packages/arrtrix/pkg/config"
 	"sneeuwvlok/packages/arrtrix/pkg/matrixcmd"
+	"sneeuwvlok/packages/arrtrix/pkg/observability"
 	"sneeuwvlok/packages/arrtrix/pkg/onboarding"
 )
 
@@ -62,6 +64,7 @@ type Main struct {
 	Config       *bridgeconfig.Config
 	Matrix       *matrix.Connector
 	Bridge       *bridgev2.Bridge
+	OTEL         *observability.Runtime
 
 	ConfigPath       string
 	RegistrationPath string
@@ -251,6 +254,8 @@ func (m *Main) loadRegistrationTokens(cfg *bridgeconfig.Config) error {
 }
 
 func (m *Main) Init() {
+	start := time.Now()
+	ctx := context.Background()
 	var err error
 	m.Log, err = m.Config.Logging.Compile()
 	if err != nil {
@@ -265,6 +270,33 @@ func (m *Main) Init() {
 		os.Exit(11)
 	}
 
+	otelCtx, cancel := context.WithTimeout(ctx, 10*time.Second)
+	m.OTEL, err = observability.Setup(otelCtx, m.PublicConfig.Observability, m.Version)
+	cancel()
+	if err != nil {
+		m.Log.WithLevel(zerolog.FatalLevel).Err(err).Msg("Failed to initialize observability")
+		os.Exit(15)
+	}
+	if hook := m.OTEL.LoggerHook(); hook != nil {
+		logger := m.Log.Hook(hook)
+		m.Log = &logger
+		exzerolog.SetupDefaults(m.Log)
+	}
+
+	ctx = m.Log.WithContext(context.Background())
+	ctx, span := observability.StartSpan(ctx, "arrtrix.runtime.init")
+	defer func() {
+		if err != nil {
+			span.RecordError(err)
+			span.SetStatus(codes.Error, err.Error())
+			observability.RecordStartupPhase(ctx, "init", "error", time.Since(start))
+			return
+		}
+		span.SetStatus(codes.Ok, "")
+		observability.RecordStartupPhase(ctx, "init", "ok", time.Since(start))
+	}()
+	defer span.End()
+
 	m.Log.Info().
 		Str("name", m.Name).
 		Str("version", m.ver.FormattedVersion).
@@ -306,17 +338,48 @@ func (m *Main) Init() {
 }
 
 func (m *Main) Start() {
+	start := time.Now()
 	ctx := m.Log.WithContext(context.Background())
+	ctx, span := observability.StartSpan(ctx, "arrtrix.runtime.start")
+	defer func() {
+		if r := recover(); r != nil {
+			span.SetStatus(codes.Error, "panic")
+			observability.RecordStartupPhase(ctx, "start", "panic", time.Since(start))
+			span.End()
+			panic(r)
+		}
+		span.End()
+	}()
 	if err := m.Bridge.Start(ctx); err != nil {
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
+		observability.RecordStartupPhase(ctx, "start", "error", time.Since(start))
 		m.Log.Fatal().Err(err).Msg("Failed to start bridge")
 	}
+	span.SetStatus(codes.Ok, "")
+	observability.RecordStartupPhase(ctx, "start", "ok", time.Since(start))
 	if m.PostStart != nil {
 		m.PostStart()
 	}
 }
 
 func (m *Main) Stop() {
+	start := time.Now()
+	ctx := m.Log.WithContext(context.Background())
+	ctx, span := observability.StartSpan(ctx, "arrtrix.runtime.stop")
+	defer span.End()
+
 	m.Bridge.StopWithTimeout(5 * time.Second)
+	span.SetStatus(codes.Ok, "")
+	observability.RecordStartupPhase(ctx, "stop", "ok", time.Since(start))
+
+	if m.OTEL != nil {
+		shutdownCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		defer cancel()
+		if err := m.OTEL.Shutdown(shutdownCtx); err != nil && m.Log != nil {
+			m.Log.Error().Err(err).Msg("Failed to shut down observability")
+		}
+	}
 }
 
 func (m *Main) WaitForInterrupt() int {
diff --git a/packages/arrtrix/pkg/webhook/arr.go b/packages/arrtrix/pkg/webhook/arr.go
index 42e350c..eb7540c 100644
--- a/packages/arrtrix/pkg/webhook/arr.go
+++ b/packages/arrtrix/pkg/webhook/arr.go
@@ -7,11 +7,17 @@ import (
 	"fmt"
 	"net/http"
 	"strings"
+	"time"
 
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/codes"
+	"go.opentelemetry.io/otel/trace"
 	"maunium.net/go/mautrix/bridgev2"
 	"maunium.net/go/mautrix/event"
 	"maunium.net/go/mautrix/format"
 	"maunium.net/go/mautrix/id"
+
+	"sneeuwvlok/packages/arrtrix/pkg/observability"
 )
 
 const ArrWebhookPath = "/_arrtrix/webhook"
@@ -69,32 +75,65 @@ func MountArr(router *http.ServeMux, bridge *bridgev2.Bridge) error {
 }
 
 func (h *ArrHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
+	start := time.Now()
+	ctx, span := observability.StartSpan(r.Context(), "arrtrix.webhook.handle", trace.WithSpanKind(trace.SpanKindServer))
+	defer span.End()
+
+	statusCode := http.StatusAccepted
+	outcome := "ok"
+	eventType := ""
+	defer func() {
+		observability.RecordWebhook(ctx, eventType, outcome, statusCode, time.Since(start))
+	}()
+
 	var body payload
 	if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
+		statusCode = http.StatusBadRequest
+		outcome = "invalid_payload"
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		http.Error(w, "invalid webhook payload", http.StatusBadRequest)
 		return
 	}
 	if strings.TrimSpace(body.EventType) == "" {
+		statusCode = http.StatusBadRequest
+		outcome = "missing_event_type"
+		span.SetStatus(codes.Error, "missing eventType")
 		http.Error(w, "missing eventType", http.StatusBadRequest)
 		return
 	}
+	eventType = body.EventType
+	span.SetAttributes(
+		attribute.String("arrtrix.webhook.event_type", body.EventType),
+		attribute.String("http.method", r.Method),
+		attribute.String("http.route", ArrWebhookPath),
+	)
 
-	roomID, err := h.resolver.ResolveManagementRoom(r.Context())
+	roomID, err := h.resolver.ResolveManagementRoom(ctx)
 	if err != nil {
-		status := http.StatusInternalServerError
+		statusCode = http.StatusInternalServerError
+		outcome = "resolve_failed"
 		if errors.Is(err, ErrNoManagementRoom) || errors.Is(err, ErrAmbiguousManagementRoom) {
-			status = http.StatusConflict
+			statusCode = http.StatusConflict
+			outcome = "routing_conflict"
 		}
-		http.Error(w, err.Error(), status)
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
+		http.Error(w, err.Error(), statusCode)
 		return
 	}
 
-	if err = h.sender.SendNotice(r.Context(), roomID, renderNotice(body)); err != nil {
+	if err = h.sender.SendNotice(ctx, roomID, renderNotice(body)); err != nil {
+		statusCode = http.StatusBadGateway
+		outcome = "delivery_failed"
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		http.Error(w, "failed to deliver webhook", http.StatusBadGateway)
 		return
 	}
 
-	w.WriteHeader(http.StatusAccepted)
+	span.SetStatus(codes.Ok, "")
+	w.WriteHeader(statusCode)
 }
 
 type bridgeRoomResolver struct {
@@ -102,8 +141,13 @@ type bridgeRoomResolver struct {
 }
 
 func (r bridgeRoomResolver) ResolveManagementRoom(ctx context.Context) (id.RoomID, error) {
+	ctx, span := observability.StartSpan(ctx, "arrtrix.webhook.resolve_management_room")
+	defer span.End()
+
 	rows, err := r.bridge.DB.Query(ctx, `SELECT mxid, management_room FROM "user" WHERE bridge_id=$1 AND management_room IS NOT NULL AND management_room <> ''`, r.bridge.ID)
 	if err != nil {
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		return "", fmt.Errorf("failed to query management rooms: %w", err)
 	}
 	defer rows.Close()
@@ -113,6 +157,8 @@ func (r bridgeRoomResolver) ResolveManagementRoom(ctx context.Context) (id.RoomI
 	for rows.Next() {
 		var mxid, managementRoom string
 		if err = rows.Scan(&mxid, &managementRoom); err != nil {
+			span.RecordError(err)
+			span.SetStatus(codes.Error, err.Error())
 			return "", fmt.Errorf("failed to scan management room: %w", err)
 		}
 		owners = append(owners, id.UserID(mxid))
@@ -121,15 +167,22 @@ func (r bridgeRoomResolver) ResolveManagementRoom(ctx context.Context) (id.RoomI
 		}
 	}
 	if err = rows.Err(); err != nil {
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		return "", fmt.Errorf("failed to iterate management rooms: %w", err)
 	}
 
 	switch len(owners) {
 	case 0:
+		span.SetStatus(codes.Error, ErrNoManagementRoom.Error())
 		return "", ErrNoManagementRoom
 	case 1:
+		span.SetAttributes(attribute.Int("arrtrix.management_room.count", 1))
+		span.SetStatus(codes.Ok, "")
 		return roomID, nil
 	default:
+		span.SetAttributes(attribute.Int("arrtrix.management_room.count", len(owners)))
+		span.SetStatus(codes.Error, ErrAmbiguousManagementRoom.Error())
 		return "", fmt.Errorf("%w: %s", ErrAmbiguousManagementRoom, strings.Join(convertUserIDs(owners), ", "))
 	}
 }
@@ -139,11 +192,23 @@ type bridgeNoticeSender struct {
 }
 
 func (s bridgeNoticeSender) SendNotice(ctx context.Context, roomID id.RoomID, markdown string) error {
+	ctx, span := observability.StartSpan(ctx, "arrtrix.webhook.send_notice")
+	defer span.End()
+	span.SetAttributes(attribute.String("matrix.room_id", roomID.String()))
+
 	if err := s.bridge.Bot.EnsureJoined(ctx, roomID); err != nil {
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
 		return err
 	}
 	content := format.RenderMarkdown(markdown, true, false)
 	_, err := s.bridge.Bot.SendMessage(ctx, roomID, event.EventMessage, &event.Content{Parsed: &content}, nil)
+	if err != nil {
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
+		return err
+	}
+	span.SetStatus(codes.Ok, "")
 	return err
 }