⬆️ Upgrade nexus to fix bug

♻️ Rebuilt cache with nexus cache
🚚 Rename http package to web
2025-03-29 16:02:10 +08:00 · 2025-03-29 15:02:04 +08:00 · 2025-03-29 14:45:12 +08:00 · 2025-03-23 00:08:10 +08:00 · 2025-03-22 13:11:23 +08:00 · 2025-03-18 00:28:20 +08:00
31 changed files with 397 additions and 338 deletions
--- a/go.mod
+++ b/go.mod
@@ -3,15 +3,13 @@ module git.solsynth.dev/hypernet/messaging
 go 1.23.2

 require (
-	git.solsynth.dev/hypernet/nexus v0.0.0-20250202075200-0f350d00a876
-	git.solsynth.dev/hypernet/passport v0.0.0-20250201110034-ec0048042a84
-	git.solsynth.dev/hypernet/pusher v0.0.0-20241228030233-50ff8304e465
-	github.com/dgraph-io/ristretto v0.2.0
-	github.com/eko/gocache/lib/v4 v4.1.6
-	github.com/eko/gocache/store/ristretto/v4 v4.2.2
+	git.solsynth.dev/hypernet/nexus v0.0.0-20250329075932-d5422ab5b04c
+	git.solsynth.dev/hypernet/paperclip v0.0.0-20250310151112-1d866f317f47
+	git.solsynth.dev/hypernet/passport v0.0.0-20250315083747-32e91e26013c
+	git.solsynth.dev/hypernet/pusher v0.0.0-20250216145944-5fb769823a88
 	github.com/fatih/color v1.18.0
 	github.com/go-playground/validator/v10 v10.22.1
-	github.com/gofiber/fiber/v2 v2.52.5
+	github.com/gofiber/fiber/v2 v2.52.6
 	github.com/golang-jwt/jwt/v5 v5.2.1
 	github.com/google/uuid v1.6.0
 	github.com/json-iterator/go v1.1.12
@@ -36,9 +34,10 @@ require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
-	github.com/dustin/go-humanize v1.0.1 // indirect
 	github.com/eapache/channels v1.1.0 // indirect
 	github.com/eapache/queue v1.1.0 // indirect
+	github.com/eko/gocache/lib/v4 v4.2.0 // indirect
+	github.com/eko/gocache/store/redis/v4 v4.2.2 // indirect
 	github.com/frostbyte73/core v0.0.10 // indirect
 	github.com/fsnotify/fsnotify v1.8.0 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.3 // indirect
@@ -60,7 +59,7 @@ require (
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
 	github.com/jxskiss/base62 v1.1.0 // indirect
-	github.com/klauspost/compress v1.17.11 // indirect
+	github.com/klauspost/compress v1.18.0 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.7 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
 	github.com/lithammer/shortuuid/v4 v4.0.0 // indirect
@@ -69,7 +68,7 @@ require (
 	github.com/livekit/psrpc v0.5.3-0.20240228172457-3724cb4adbc4 // indirect
 	github.com/magefile/mage v1.15.0 // indirect
 	github.com/magiconair/properties v1.8.7 // indirect
-	github.com/mattn/go-colorable v0.1.13 // indirect
+	github.com/mattn/go-colorable v0.1.14 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/mattn/go-runewidth v0.0.16 // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
@@ -96,14 +95,13 @@ require (
 	github.com/pion/transport/v2 v2.2.4 // indirect
 	github.com/pion/turn/v2 v2.1.3 // indirect
 	github.com/pion/webrtc/v3 v3.2.28 // indirect
-	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/prometheus/client_golang v1.19.0 // indirect
-	github.com/prometheus/client_model v0.5.0 // indirect
-	github.com/prometheus/common v0.48.0 // indirect
-	github.com/prometheus/procfs v0.12.0 // indirect
+	github.com/prometheus/client_model v0.6.1 // indirect
+	github.com/prometheus/common v0.52.3 // indirect
+	github.com/prometheus/procfs v0.13.0 // indirect
 	github.com/puzpuzpuz/xsync/v3 v3.1.0 // indirect
-	github.com/redis/go-redis/v9 v9.5.1 // indirect
+	github.com/redis/go-redis/v9 v9.7.3 // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/sagikazarmark/locafero v0.6.0 // indirect
 	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
@@ -114,24 +112,22 @@ require (
 	github.com/stretchr/testify v1.9.0 // indirect
 	github.com/subosito/gotenv v1.6.0 // indirect
 	github.com/thoas/go-funk v0.9.3 // indirect
-	github.com/tinylib/msgp v1.2.4 // indirect
+	github.com/tinylib/msgp v1.2.5 // indirect
 	github.com/twitchtv/twirp v8.1.3+incompatible // indirect
 	github.com/valyala/bytebufferpool v1.0.0 // indirect
-	github.com/valyala/fasthttp v1.57.0 // indirect
-	github.com/valyala/tcplisten v1.0.0 // indirect
-	github.com/vmihailenco/msgpack/v5 v5.3.5 // indirect
-	github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
+	github.com/valyala/fasthttp v1.59.0 // indirect
 	github.com/zeebo/xxh3 v1.0.2 // indirect
 	go.uber.org/atomic v1.11.0 // indirect
+	go.uber.org/mock v0.4.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
 	go.uber.org/zap v1.27.0 // indirect
 	go.uber.org/zap/exp v0.2.0 // indirect
-	golang.org/x/crypto v0.32.0 // indirect
+	golang.org/x/crypto v0.33.0 // indirect
 	golang.org/x/exp v0.0.0-20241009180824-f66d83c29e7c // indirect
-	golang.org/x/net v0.34.0 // indirect
-	golang.org/x/sync v0.10.0 // indirect
-	golang.org/x/sys v0.29.0 // indirect
-	golang.org/x/text v0.21.0 // indirect
+	golang.org/x/net v0.35.0 // indirect
+	golang.org/x/sync v0.11.0 // indirect
+	golang.org/x/sys v0.30.0 // indirect
+	golang.org/x/text v0.22.0 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250127172529-29210b9bc287 // indirect
 	google.golang.org/protobuf v1.36.4 // indirect
 	gopkg.in/ini.v1 v1.67.0 // indirect
--- a/go.sum
+++ b/go.sum
@@ -1,13 +1,15 @@
 filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
-git.solsynth.dev/hypernet/nexus v0.0.0-20241123050605-25ab1371739b h1:8yB9kMwEMY/nIbmDDxrhH5sTypgmK5PIIiIfP5QXx4s=
-git.solsynth.dev/hypernet/nexus v0.0.0-20241123050605-25ab1371739b/go.mod h1:PhLCv2lsNoscPVJbkWnxwQnJ141lc4RIEkVffrHwl4s=
-git.solsynth.dev/hypernet/nexus v0.0.0-20250202075200-0f350d00a876 h1:+uhz0RSIqMoYipVg/M1Lch7i0ZB/+vf34XBPe4ugDyY=
-git.solsynth.dev/hypernet/nexus v0.0.0-20250202075200-0f350d00a876/go.mod h1:v+rpf1ZDRi8moaThTAkj5DMQU+rw96YTHcN8/7n/p2Y=
-git.solsynth.dev/hypernet/passport v0.0.0-20250201110034-ec0048042a84 h1:5nJGgRjePhqHW42Ym5vXJj1jxfImR/fzo7RfOSJ2kpw=
-git.solsynth.dev/hypernet/passport v0.0.0-20250201110034-ec0048042a84/go.mod h1:WIx0+N0BvbsbY/lYxuC2rq6v4EIasoTwg5cnC+ExMeI=
-git.solsynth.dev/hypernet/pusher v0.0.0-20241228030233-50ff8304e465 h1:KFtv9lF0JMUGsq1uHwQvop8PTyqdiLuUQuRrd5WmzPk=
-git.solsynth.dev/hypernet/pusher v0.0.0-20241228030233-50ff8304e465/go.mod h1:XHTqFU/vBe4JiuAjl87GUcL8+w/IizSNoqH6n3WkQFc=
+git.solsynth.dev/hypernet/nexus v0.0.0-20250329053929-488793a2dc56 h1:SnT9NVcXQ1WDka9kKAA+lH/r2UJouND7FDugu4ZZwLc=
+git.solsynth.dev/hypernet/nexus v0.0.0-20250329053929-488793a2dc56/go.mod h1:5tk62VQ1DcbR0EAN2jAOqYxHiegUPEC805JlfQ/G19I=
+git.solsynth.dev/hypernet/nexus v0.0.0-20250329075932-d5422ab5b04c h1:XgdTgJxSAQuCbiG15hN5pY6chzcz8sX3Onm2itS+Ufs=
+git.solsynth.dev/hypernet/nexus v0.0.0-20250329075932-d5422ab5b04c/go.mod h1:5tk62VQ1DcbR0EAN2jAOqYxHiegUPEC805JlfQ/G19I=
+git.solsynth.dev/hypernet/paperclip v0.0.0-20250310151112-1d866f317f47 h1:fvu+bNKPTNtQocssnKbEZ66MqR0iBfAxY3HwlqnmYyE=
+git.solsynth.dev/hypernet/paperclip v0.0.0-20250310151112-1d866f317f47/go.mod h1:jvxq2qftz2v72x+24+cTFJdQKr9eHQTdk3KVR7cx36s=
+git.solsynth.dev/hypernet/passport v0.0.0-20250315083747-32e91e26013c h1:XB8EBX34WB2skmjaVFot5IlxKF2qFZ2SueG/Y9SiJ6Y=
+git.solsynth.dev/hypernet/passport v0.0.0-20250315083747-32e91e26013c/go.mod h1:k7MZQWYBpxlk3g9bx0HTh5C3m+MG/wr0hAiRM/VyAqs=
+git.solsynth.dev/hypernet/pusher v0.0.0-20250216145944-5fb769823a88 h1:2HEENe9KUrdaJeNBzx9lsuXQGyzWqCgnLTKQnr8xFr8=
+git.solsynth.dev/hypernet/pusher v0.0.0-20250216145944-5fb769823a88/go.mod h1:ildzMtLagNsLK0Rkw4Hgk2TrrwqZnjwJIUx0MNZwcDY=
 github.com/andybalholm/brotli v1.1.1 h1:PR2pgnyFznKEugtsUo0xLdDop5SKXd5Qf5ysW+7XdTA=
 github.com/andybalholm/brotli v1.1.1/go.mod h1:05ib4cKhjx3OQYUY22hTVd34Bc8upXjOLL2rKwwZBoA=
 github.com/benbjohnson/clock v1.3.5 h1:VvXlSJBzZpA/zum6Sj74hxwYI2DIxRWuNIoXAzHZz5o=
@@ -27,22 +29,16 @@ github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSs
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/dgraph-io/ristretto v0.2.0 h1:XAfl+7cmoUDWW/2Lx8TGZQjjxIQ2Ley9DSf52dru4WE=
-github.com/dgraph-io/ristretto v0.2.0/go.mod h1:8uBHCU/PBV4Ag0CJrP47b9Ofby5dqWNh4FicAdoqFNU=
-github.com/dgryski/go-farm v0.0.0-20200201041132-a6ae2369ad13 h1:fAjc9m62+UWV/WAFKLNi6ZS0675eEUC9y3AlwSbQu1Y=
-github.com/dgryski/go-farm v0.0.0-20200201041132-a6ae2369ad13/go.mod h1:SqUrOPUnsFjfmXRMNPybcSiG0BgUW2AuFH8PAnS2iTw=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
-github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
-github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
 github.com/eapache/channels v1.1.0 h1:F1taHcn7/F0i8DYqKXJnyhJcVpp2kgFcNePxXtnyu4k=
 github.com/eapache/channels v1.1.0/go.mod h1:jMm2qB5Ubtg9zLd+inMZd2/NUvXgzmWXsDaLyQIGfH0=
 github.com/eapache/queue v1.1.0 h1:YOEu7KNc61ntiQlcEeUIoDTJ2o8mQznoNvUhiigpIqc=
 github.com/eapache/queue v1.1.0/go.mod h1:6eCeP0CKFpHLu8blIFXhExK/dRa7WDZfr6jVFPTqq+I=
-github.com/eko/gocache/lib/v4 v4.1.6 h1:5WWIGISKhE7mfkyF+SJyWwqa4Dp2mkdX8QsZpnENqJI=
-github.com/eko/gocache/lib/v4 v4.1.6/go.mod h1:HFxC8IiG2WeRotg09xEnPD72sCheJiTSr4Li5Ameg7g=
-github.com/eko/gocache/store/ristretto/v4 v4.2.2 h1:lXFzoZ5ck6Gy6ON7f5DHSkNt122qN7KoroCVgVwF7oo=
-github.com/eko/gocache/store/ristretto/v4 v4.2.2/go.mod h1:uIvBVJzqRepr5L0RsbkfQ2iYfbyos2fuji/s4yM+aUM=
+github.com/eko/gocache/lib/v4 v4.2.0 h1:MNykyi5Xw+5Wu3+PUrvtOCaKSZM1nUSVftbzmeC7Yuw=
+github.com/eko/gocache/lib/v4 v4.2.0/go.mod h1:7ViVmbU+CzDHzRpmB4SXKyyzyuJ8A3UW3/cszpcqB4M=
+github.com/eko/gocache/store/redis/v4 v4.2.2 h1:Thw31fzGuH3WzJywsdbMivOmP550D6JS7GDHhvCJPA0=
+github.com/eko/gocache/store/redis/v4 v4.2.2/go.mod h1:LaTxLKx9TG/YUEybQvPMij++D7PBTIJ4+pzvk0ykz0w=
 github.com/fatih/color v1.18.0 h1:S8gINlzdQ840/4pfAwic/ZE0djQEH3wM94VfqLTZcOM=
 github.com/fatih/color v1.18.0/go.mod h1:4FelSpRwEGDpQ12mAdzqdOukCy4u8WUtOY6lkT/6HfU=
 github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
@@ -79,8 +75,8 @@ github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg78
 github.com/goccy/go-json v0.10.3 h1:KZ5WoDbxAIgm2HNbYckL0se1fHD6rz5j4ywS6ebzDqA=
 github.com/goccy/go-json v0.10.3/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
 github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
-github.com/gofiber/fiber/v2 v2.52.5 h1:tWoP1MJQjGEe4GB5TUGOi7P2E0ZMMRx5ZTG4rT+yGMo=
-github.com/gofiber/fiber/v2 v2.52.5/go.mod h1:KEOE+cXMhXG0zHc9d8+E38hoX+ZN7bhOtgeF2oT6jrQ=
+github.com/gofiber/fiber/v2 v2.52.6 h1:Rfp+ILPiYSvvVuIPvxrBns+HJp8qGLDnLJawAu27XVI=
+github.com/gofiber/fiber/v2 v2.52.6/go.mod h1:YEcBbO/FB+5M1IZNBP9FO3J9281zgPAreiI1oqg8nDw=
 github.com/golang-jwt/jwt/v5 v5.2.1 h1:OuVbFODueb089Lh128TAcimifWaLhJwVflnrgM17wHk=
 github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
 github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
@@ -133,8 +129,8 @@ github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnr
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
 github.com/jxskiss/base62 v1.1.0 h1:A5zbF8v8WXx2xixnAKD2w+abC+sIzYJX+nxmhA6HWFw=
 github.com/jxskiss/base62 v1.1.0/go.mod h1:HhWAlUXvxKThfOlZbcuFzsqwtF5TcqS9ru3y5GfjWAc=
-github.com/klauspost/compress v1.17.11 h1:In6xLpyWOi1+C7tXUUWv2ot1QvBjxevKAaI6IXrJmUc=
-github.com/klauspost/compress v1.17.11/go.mod h1:pMDklpSncoRMuLFrf1W9Ss9KT+0rH90U12bZKk7uwG0=
+github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
+github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
 github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM=
 github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws=
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
@@ -162,8 +158,9 @@ github.com/magefile/mage v1.15.0 h1:BvGheCMAsG3bWUDbZ8AyXXpCNwU9u5CB6sM+HNb9HYg=
 github.com/magefile/mage v1.15.0/go.mod h1:z5UZb/iS3GoOSn0JgWuiw7dxlurVYTu+/jHXqQg881A=
 github.com/magiconair/properties v1.8.7 h1:IeQXZAiQcpL9mgcAe1Nu6cX9LLw6ExEHKjN0VQdvPDY=
 github.com/magiconair/properties v1.8.7/go.mod h1:Dhd985XPs7jluiymwWYZ0G4Z61jb3vdS329zhj2hYo0=
-github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
 github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
+github.com/mattn/go-colorable v0.1.14 h1:9A9LHSqF/7dyVVX6g0U9cwm9pG3kP9gSzcuIPHPsaIE=
+github.com/mattn/go-colorable v0.1.14/go.mod h1:6LmQG8QLFO4G5z1gPvYEzlUgJ2wF+stgPZH1UqBm1s8=
 github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
 github.com/mattn/go-isatty v0.0.19/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
@@ -251,16 +248,16 @@ github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRI
 github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/prometheus/client_golang v1.19.0 h1:ygXvpU1AoN1MhdzckN+PyD9QJOSD4x7kmXYlnfbA6JU=
 github.com/prometheus/client_golang v1.19.0/go.mod h1:ZRM9uEAypZakd+q/x7+gmsvXdURP+DABIEIjnmDdp+k=
-github.com/prometheus/client_model v0.5.0 h1:VQw1hfvPvk3Uv6Qf29VrPF32JB6rtbgI6cYPYQjL0Qw=
-github.com/prometheus/client_model v0.5.0/go.mod h1:dTiFglRmd66nLR9Pv9f0mZi7B7fk5Pm3gvsjB5tr+kI=
-github.com/prometheus/common v0.48.0 h1:QO8U2CdOzSn1BBsmXJXduaaW+dY/5QLjfB8svtSzKKE=
-github.com/prometheus/common v0.48.0/go.mod h1:0/KsvlIEfPQCQ5I2iNSAWKPZziNCvRs5EC6ILDTlAPc=
-github.com/prometheus/procfs v0.12.0 h1:jluTpSng7V9hY0O2R9DzzJHYb2xULk9VTR1V1R/k6Bo=
-github.com/prometheus/procfs v0.12.0/go.mod h1:pcuDEFsWDnvcgNzo4EEweacyhjeA9Zk3cnaOZAZEfOo=
+github.com/prometheus/client_model v0.6.1 h1:ZKSh/rekM+n3CeS952MLRAdFwIKqeY8b62p8ais2e9E=
+github.com/prometheus/client_model v0.6.1/go.mod h1:OrxVMOVHjw3lKMa8+x6HeMGkHMQyHDk9E3jmP2AmGiY=
+github.com/prometheus/common v0.52.3 h1:5f8uj6ZwHSscOGNdIQg6OiZv/ybiK2CO2q2drVZAQSA=
+github.com/prometheus/common v0.52.3/go.mod h1:BrxBKv3FWBIGXw89Mg1AeBq7FSyRzXWI3l3e7W3RN5U=
+github.com/prometheus/procfs v0.13.0 h1:GqzLlQyfsPbaEHaQkO7tbDlriv/4o5Hudv6OXHGKX7o=
+github.com/prometheus/procfs v0.13.0/go.mod h1:cd4PFCR54QLnGKPaKGA6l+cfuNXtht43ZKY6tow0Y1g=
 github.com/puzpuzpuz/xsync/v3 v3.1.0 h1:EewKT7/LNac5SLiEblJeUu8z5eERHrmRLnMQL2d7qX4=
 github.com/puzpuzpuz/xsync/v3 v3.1.0/go.mod h1:VjzYrABPabuM4KyBh1Ftq6u8nhwY5tBPKP9jpmh0nnA=
-github.com/redis/go-redis/v9 v9.5.1 h1:H1X4D3yHPaYrkL5X06Wh6xNVM/pX0Ft4RV0vMGvLBh8=
-github.com/redis/go-redis/v9 v9.5.1/go.mod h1:hdY0cQFCN4fnSYT6TkisLufl/4W5UIXyv0b/CLO2V2M=
+github.com/redis/go-redis/v9 v9.7.3 h1:YpPyAayJV+XErNsatSElgRZZVCwXX9QzkKYNvO7x0wM=
+github.com/redis/go-redis/v9 v9.7.3/go.mod h1:bGUrSggJ9X9GUmZpZNEOQKaANxSGgOEBRltRTZHSvrA=
 github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
 github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ=
 github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
@@ -294,7 +291,6 @@ github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpE
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
-github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
@@ -307,20 +303,14 @@ github.com/subosito/gotenv v1.6.0 h1:9NlTDc1FTs4qu0DDq7AEtTPNw6SVm7uBMsUCUjABIf8
 github.com/subosito/gotenv v1.6.0/go.mod h1:Dk4QP5c2W3ibzajGcXpNraDfq2IrhjMIvMSWPKKo0FU=
 github.com/thoas/go-funk v0.9.3 h1:7+nAEx3kn5ZJcnDm2Bh23N2yOtweO14bi//dvRtgLpw=
 github.com/thoas/go-funk v0.9.3/go.mod h1:+IWnUfUmFO1+WVYQWQtIJHeRRdaIyyYglZN7xzUPe4Q=
-github.com/tinylib/msgp v1.2.4 h1:yLFeUGostXXSGW5vxfT5dXG/qzkn4schv2I7at5+hVU=
-github.com/tinylib/msgp v1.2.4/go.mod h1:ykjzy2wzgrlvpDCRc4LA8UXy6D8bzMSuAF3WD57Gok0=
+github.com/tinylib/msgp v1.2.5 h1:WeQg1whrXRFiZusidTQqzETkRpGjFjcIhW6uqWH09po=
+github.com/tinylib/msgp v1.2.5/go.mod h1:ykjzy2wzgrlvpDCRc4LA8UXy6D8bzMSuAF3WD57Gok0=
 github.com/twitchtv/twirp v8.1.3+incompatible h1:+F4TdErPgSUbMZMwp13Q/KgDVuI7HJXP61mNV3/7iuU=
 github.com/twitchtv/twirp v8.1.3+incompatible/go.mod h1:RRJoFSAmTEh2weEqWtpPE3vFK5YBhA6bqp2l1kfCC5A=
 github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw=
 github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc=
-github.com/valyala/fasthttp v1.57.0 h1:Xw8SjWGEP/+wAAgyy5XTvgrWlOD1+TxbbvNADYCm1Tg=
-github.com/valyala/fasthttp v1.57.0/go.mod h1:h6ZBaPRlzpZ6O3H5t2gEk1Qi33+TmLvfwgLLp0t9CpE=
-github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8=
-github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc=
-github.com/vmihailenco/msgpack/v5 v5.3.5 h1:5gO0H1iULLWGhs2H5tbAHIZTV8/cYafcFOr9znI5mJU=
-github.com/vmihailenco/msgpack/v5 v5.3.5/go.mod h1:7xyJ9e+0+9SaZT0Wt1RGleJXzli6Q/V5KbhBonMG9jc=
-github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
-github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
+github.com/valyala/fasthttp v1.59.0 h1:Qu0qYHfXvPk1mSLNqcFtEk6DpxgA26hy6bmydotDpRI=
+github.com/valyala/fasthttp v1.59.0/go.mod h1:GTxNb9Bc6r2a9D0TWNSPwDz78UxnTGBViY3xZNEqyYU=
 github.com/xyproto/randomstring v1.0.5 h1:YtlWPoRdgMu3NZtP45drfy1GKoojuR7hmRcnhZqKjWU=
 github.com/xyproto/randomstring v1.0.5/go.mod h1:rgmS5DeNXLivK7YprL0pY+lTuhNQW3iGxZ18UQApw/E=
 github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
@@ -344,6 +334,8 @@ go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=
 go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
 go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
+go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU=
+go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc=
 go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
 go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
@@ -359,8 +351,8 @@ golang.org/x/crypto v0.11.0/go.mod h1:xgJhtzW8F9jGdVFWZESrid1U1bjeNy4zgy5cRr/CIi
 golang.org/x/crypto v0.12.0/go.mod h1:NF0Gs7EO5K4qLn+Ylc+fih8BSTeIjAP05siRnAh98yw=
 golang.org/x/crypto v0.18.0/go.mod h1:R0j02AL6hcrfOiy9T4ZYp/rcWeMxM3L6QYxlOuEG1mg=
 golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU=
-golang.org/x/crypto v0.32.0 h1:euUpcYgM8WcP71gNpTqQCn6rC2t6ULUPiOzfWaXVVfc=
-golang.org/x/crypto v0.32.0/go.mod h1:ZnnJkOaASj8g0AjIduWNlq2NRxL0PlBrbKVyZ6V/Ugc=
+golang.org/x/crypto v0.33.0 h1:IOBPskki6Lysi0lo9qQvbxiQ+FvsCC/YWOecCHAixus=
+golang.org/x/crypto v0.33.0/go.mod h1:bVdXmD7IV/4GdElGPozy6U7lWdRXA4qyRVGJV57uQ5M=
 golang.org/x/exp v0.0.0-20241009180824-f66d83c29e7c h1:7dEasQXItcW1xKJ2+gg5VOiBnqWrJc+rq0DPKyvvdbY=
 golang.org/x/exp v0.0.0-20241009180824-f66d83c29e7c/go.mod h1:NQtJDoLvd6faHhE7m4T/1IY708gDefGGjR/iUW8yQQ8=
 golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
@@ -383,16 +375,16 @@ golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
 golang.org/x/net v0.13.0/go.mod h1:zEVYFnQC7m/vmpQFELhcD1EWkZlX69l4oqgmer6hfKA=
 golang.org/x/net v0.14.0/go.mod h1:PpSgVXXLK0OxS0F31C1/tv6XNguvCrnXIDrFMspZIUI=
 golang.org/x/net v0.20.0/go.mod h1:z8BVo6PvndSri0LbOE3hAn0apkU+1YvI6E70E9jsnvY=
-golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
-golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
+golang.org/x/net v0.35.0 h1:T5GQRQb2y08kTAByq9L4/bz8cipCdA8FbRTXewonqY8=
+golang.org/x/net v0.35.0/go.mod h1:EglIi67kWsHKlRzzVMUD93VMSWGFOMSZgxFjparz1Qk=
 golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.10.0 h1:3NQrjDixjgGwUOCaF8w2+VYHv0Ve/vGYSbdkTa98gmQ=
-golang.org/x/sync v0.10.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.11.0 h1:GGz8+XQP4FvTTrjZPzNKTMFtSXH80RAzG+5ghFPgK9w=
+golang.org/x/sync v0.11.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -422,8 +414,8 @@ golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.16.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-golang.org/x/sys v0.29.0 h1:TPYlXGxvx1MGTn2GiZDhnjPA9wZzZeGKHHmKhHYvgaU=
-golang.org/x/sys v0.29.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/term v0.1.0/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
@@ -444,8 +436,8 @@ golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
 golang.org/x/text v0.11.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
 golang.org/x/text v0.12.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
 golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
-golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo=
-golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ=
+golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
+golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
--- a/pkg/internal/cache/store.go
+++ b/pkg/internal/cache/store.go
@@ -1,24 +0,0 @@
-package cache
-
-import (
-	"github.com/dgraph-io/ristretto"
-	"github.com/eko/gocache/lib/v4/store"
-	ristrettoCache "github.com/eko/gocache/store/ristretto/v4"
-)
-
-var S store.StoreInterface
-
-func NewStore() error {
-	ristretto, err := ristretto.NewCache(&ristretto.Config{
-		NumCounters: 1000,
-		MaxCost:     100,
-		BufferItems: 64,
-	})
-	if err != nil {
-		return err
-	}
-
-	S = ristrettoCache.NewRistretto(ristretto)
-
-	return nil
-}
--- a/pkg/internal/gap/server.go
+++ b/pkg/internal/gap/server.go
@@ -2,19 +2,25 @@ package gap

 import (
 	"fmt"
+	"strings"
+	"time"
+
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
+	"git.solsynth.dev/hypernet/nexus/pkg/nex/cachekit"
 	"git.solsynth.dev/hypernet/nexus/pkg/proto"
 	"git.solsynth.dev/hypernet/pusher/pkg/pushkit/pushcon"
 	"github.com/samber/lo"
-	"strings"

 	"github.com/rs/zerolog/log"

 	"github.com/spf13/viper"
 )

-var Nx *nex.Conn
-var Px *pushcon.Conn
+var (
+	Nx *nex.Conn
+	Px *pushcon.Conn
+	Ca *cachekit.Conn
+)

 func InitializeToNexus() error {
 	grpcBind := strings.SplitN(viper.GetString("grpc_bind"), ":", 2)
@@ -47,6 +53,10 @@ func InitializeToNexus() error {
 		return fmt.Errorf("error during initialize pushcon: %v", err)
 	}

-	return err
+	Ca, err = cachekit.NewConn(Nx, 3*time.Second)
+	if err != nil {
+		return fmt.Errorf("error during initialize cachekit: %v", err)
+	}

+	return err
 }
--- a/pkg/internal/grpc/services.go
+++ b/pkg/internal/grpc/services.go
@@ -2,15 +2,30 @@ package grpc

 import (
 	"context"
+
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
 	"git.solsynth.dev/hypernet/nexus/pkg/proto"
-	"strconv"
+	jsoniter "github.com/json-iterator/go"
+	"github.com/rs/zerolog/log"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 )

 func (v *Server) BroadcastEvent(ctx context.Context, in *proto.EventInfo) (*proto.EventResponse, error) {
+	log.Debug().Str("event", in.GetEvent()).
+		Msg("Got a broadcasting event...")
+
 	switch in.GetEvent() {
+	// Clear the subscribed channel
+	case "ws.client.unregister":
+		// Update user last seen at
+		data := nex.DecodeMap(in.GetData())
+		id := data["id"].(string)
+		services.UnsubscribeAllWithClient(id)
+		log.Info().Str("client", id).Msg("Client unregistered, cleaning up subscribed channels...")
+	// Account recycle
 	case "deletion":
 		data := nex.DecodeMap(in.GetData())
 		resType, ok := data["type"].(string)
@@ -19,22 +34,34 @@ func (v *Server) BroadcastEvent(ctx context.Context, in *proto.EventInfo) (*prot
 		}
 		switch resType {
 		case "account":
-			id, ok := data["id"].(string)
-			if !ok {
-				break
+			var data struct {
+				ID int `json:"id"`
 			}
-			numericId, err := strconv.Atoi(id)
-			if err != nil {
+			if err := jsoniter.Unmarshal(in.GetData(), &data); err != nil {
 				break
 			}
 			tx := database.C.Begin()
 			for _, model := range database.AutoMaintainRange {
 				switch model.(type) {
 				default:
-					tx.Delete(model, "account_id = ?", numericId)
+					tx.Delete(model, "account_id = ?", data.ID)
 				}
 			}
 			tx.Commit()
+		case "realm":
+			var data struct {
+				ID int `json:"id"`
+			}
+			if err := jsoniter.Unmarshal(in.GetData(), &data); err != nil {
+				break
+			}
+			var channels []models.Channel
+			if err := database.C.Where("realm_id = ?", data.ID).Find(&channels).Error; err != nil {
+				break
+			}
+			for _, channel := range channels {
+				_ = services.DeleteChannel(channel)
+			}
 		}
 	}

--- a/pkg/internal/grpc/stream.go
+++ b/pkg/internal/grpc/stream.go
@@ -3,8 +3,10 @@ package grpc
 import (
 	"context"
 	"fmt"
+	"strings"
+
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
 	"git.solsynth.dev/hypernet/nexus/pkg/proto"
@@ -51,6 +53,35 @@ func (v *Server) PushStream(_ context.Context, request *proto.PushStreamRequest)
 			})
 			break
 		}
+	case "events.subscribe", "events.unsubscribe", "events.unsubscribeAll":
+		var data struct {
+			ChannelID uint `json:"channel_id" validate:"required"`
+		}
+
+		err := jsoniter.Unmarshal(in.RawPayload(), &data)
+		if err == nil {
+			err = exts.ValidateStruct(data)
+		}
+		if err != nil {
+			_, _ = sc.PushStream(context.Background(), &proto.PushStreamRequest{
+				ClientId: request.ClientId,
+				Body: nex.WebSocketPackage{
+					Action:  "error",
+					Message: fmt.Sprintf("unable parse payload: %v", err),
+				}.Marshal(),
+			})
+			break
+		}
+
+		action := strings.Split(in.Action, ".")[1]
+		switch action {
+		case "subscribe":
+			services.SubscribeChannel(uint(request.GetUserId()), data.ChannelID, request.GetClientId())
+		case "unsubscribe":
+			services.UnsubscribeChannel(uint(request.GetUserId()), data.ChannelID)
+		case "unsubscribeAll":
+			services.UnsubscribeAll(uint(request.GetUserId()))
+		}
 	case "events.read":
 		var data struct {
 			ChannelMemberID uint `json:"channel_member_id" validate:"required"`
--- a/pkg/internal/http/api/whats_new_api.go
+++ b/pkg/internal/http/api/whats_new_api.go
@@ -1,62 +0,0 @@
-package api
-
-import (
-	"fmt"
-	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
-	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
-
-	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
-	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
-	"github.com/gofiber/fiber/v2"
-)
-
-func getWhatsNew(c *fiber.Ctx) error {
-	if err := sec.EnsureAuthenticated(c); err != nil {
-		return err
-	}
-	user := c.Locals("user").(authm.Account)
-
-	var lookupRange []uint
-	var lookupPivots []int
-	var ignoreRange []uint
-	var channelMembers []models.ChannelMember
-	if err := database.C.Where("account_id = ?", user.ID).
-		Select("id", "channel_id", "reading_anchor").
-		Find(&channelMembers).Error; err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, fmt.Sprintf("unable to get channel identity of you: %v", err))
-	} else {
-		for _, member := range channelMembers {
-			if member.ReadingAnchor == nil {
-				continue
-			}
-			lookupRange = append(lookupRange, member.ChannelID)
-			lookupPivots = append(lookupPivots, *member.ReadingAnchor)
-			ignoreRange = append(ignoreRange, member.ID)
-		}
-	}
-
-	tx := database.C
-	tx = tx.Where("channel_id IN ?", lookupRange)
-	tx = tx.Where("sender_id NOT IN ?", ignoreRange)
-
-	countTx := tx
-	var count int64
-	if err := countTx.Model(&models.Event{}).Count(&count).Error; err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, err.Error())
-	}
-
-	var result []struct {
-		ChannelID          uint `json:"channel_id"`
-		UnreadMessageCount int  `json:"count"`
-	}
-	if err := database.C.Table("channel_members cm").
-		Select("cm.channel_id, COUNT(m.id) AS unread_message_count").
-		Joins("JOIN messages m ON m.channel_id = cm.channel_id").
-		Where("m.id > cm.reading_anchor AND cm.account_id = ?", 1).
-		Group("cm.channel_id").
-		Scan(&result).Error; err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, err.Error())
-	}
-
-	return c.JSON(result)
-}
--- a/pkg/internal/models/channels.go
+++ b/pkg/internal/models/channels.go
@@ -2,6 +2,7 @@ package models

 import (
 	"fmt"
+
 	"git.solsynth.dev/hypernet/nexus/pkg/nex/cruda"
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
 )
@@ -36,9 +37,9 @@ func (v Channel) DisplayText() string {
 		return "DM"
 	}
 	if v.Realm != nil {
-		return fmt.Sprintf("%s, %s", v.Alias, v.Realm.Alias)
+		return fmt.Sprintf("%s, %s", v.Name, v.Realm.Name)
 	}
-	return fmt.Sprintf("%s", v.Alias)
+	return v.Name
 }

 type NotifyLevel = int8
--- a/pkg/internal/models/events.go
+++ b/pkg/internal/models/events.go
@@ -30,6 +30,7 @@ type Event struct {

 type EventMessageBody struct {
 	Text           string   `json:"text,omitempty"`
+	KeyPair        string   `json:"keypair_id,omitempty"`
 	Algorithm      string   `json:"algorithm,omitempty"`
 	Attachments    []string `json:"attachments,omitempty"`
 	QuoteEventID   *uint    `json:"quote_event,omitempty"`
--- a/pkg/internal/services/calls.go
+++ b/pkg/internal/services/calls.go
@@ -117,10 +117,6 @@ func NewCall(channel models.Channel, founder models.ChannelMember) (models.Call,
 			if member.ID != call.Founder.ID {
 				pendingUsers = append(pendingUsers, uint64(member.AccountID))
 			}
-			PushCommand(member.AccountID, nex.WebSocketPackage{
-				Action:  "calls.new",
-				Payload: call,
-			})
 		}

 		channel, _ = GetChannel(channel.ID)
@@ -131,6 +127,13 @@ func NewCall(channel models.Channel, founder models.ChannelMember) (models.Call,
 			}
 		}

+		// The call notification is not happen very often
+		// So we don't need to optimize the performance for passive users
+		PushCommandBatch(pendingUsers, nex.WebSocketPackage{
+			Action:  "calls.new",
+			Payload: call,
+		})
+
 		err = authkit.NotifyUserBatch(
 			gap.Nx,
 			pendingUsers,
@@ -172,12 +175,17 @@ func EndCall(call models.Call) (models.Call, error) {
 		ChannelID: call.ChannelID,
 	}).Find(&members).Error; err == nil {
 		call, _ = GetCall(call.Channel, call.ID)
+		var pendingUsers []uint64
 		for _, member := range members {
-			PushCommand(member.AccountID, nex.WebSocketPackage{
-				Action:  "calls.end",
-				Payload: call,
-			})
+			if member.ID != call.Founder.ID {
+				pendingUsers = append(pendingUsers, uint64(member.AccountID))
+			}
 		}
+
+		PushCommandBatch(pendingUsers, nex.WebSocketPackage{
+			Action:  "calls.end",
+			Payload: call,
+		})
 	}

 	return call, nil
--- a/pkg/internal/services/channel_members.go
+++ b/pkg/internal/services/channel_members.go
@@ -1,16 +1,13 @@
 package services

 import (
-	"context"
 	"errors"
 	"fmt"
-	localCache "git.solsynth.dev/hypernet/messaging/pkg/internal/cache"
+
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
+	"git.solsynth.dev/hypernet/nexus/pkg/nex/cachekit"
 	"git.solsynth.dev/hypernet/passport/pkg/authkit"
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
-	"github.com/eko/gocache/lib/v4/cache"
-	"github.com/eko/gocache/lib/v4/marshaler"
-	"github.com/eko/gocache/lib/v4/store"
 	"gorm.io/gorm"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
@@ -46,7 +43,7 @@ func GetChannelMember(user authm.Account, channelId uint) (models.ChannelMember,

 	if err := database.C.
 		Where(&models.ChannelMember{AccountID: user.ID, ChannelID: channelId}).
-		Find(&member).Error; err != nil {
+		First(&member).Error; err != nil {
 		return member, err
 	}

@@ -80,16 +77,10 @@ func AddChannelMember(user authm.Account, target models.Channel) error {
 	err := database.C.Save(&member).Error

 	if err == nil {
-		cacheManager := cache.New[any](localCache.S)
-		marshal := marshaler.New(cacheManager)
-		ctx := context.Background()
-
-		_ = marshal.Invalidate(
-			ctx,
-			store.WithInvalidateTags([]string{
-				fmt.Sprintf("channel#%d", target.ID),
-				fmt.Sprintf("user#%d", user.ID),
-			}),
+		cachekit.DeleteByTags(
+			gap.Ca,
+			fmt.Sprintf("channel#%d", target.ID),
+			fmt.Sprintf("user#%d", user.ID),
 		)
 	}

@@ -100,16 +91,10 @@ func EditChannelMember(membership models.ChannelMember) (models.ChannelMember, e
 	if err := database.C.Save(&membership).Error; err != nil {
 		return membership, err
 	} else {
-		cacheManager := cache.New[any](localCache.S)
-		marshal := marshaler.New(cacheManager)
-		contx := context.Background()
-
-		_ = marshal.Invalidate(
-			contx,
-			store.WithInvalidateTags([]string{
-				fmt.Sprintf("channel#%d", membership.ChannelID),
-				fmt.Sprintf("user#%d", membership.AccountID),
-			}),
+		cachekit.DeleteByTags(
+			gap.Ca,
+			fmt.Sprintf("channel#%d", membership.ChannelID),
+			fmt.Sprintf("user#%d", membership.AccountID),
 		)
 	}

@@ -120,16 +105,10 @@ func RemoveChannelMember(member models.ChannelMember, target models.Channel) err
 	if err := database.C.Delete(&member).Error; err == nil {
 		database.C.Where("sender_id = ?").Delete(&models.Event{})

-		cacheManager := cache.New[any](localCache.S)
-		marshal := marshaler.New(cacheManager)
-		ctx := context.Background()
-
-		_ = marshal.Invalidate(
-			ctx,
-			store.WithInvalidateTags([]string{
-				fmt.Sprintf("channel#%d", target.ID),
-				fmt.Sprintf("user#%d", target.AccountID),
-			}),
+		cachekit.DeleteByTags(
+			gap.Ca,
+			fmt.Sprintf("channel#%d", target.ID),
+			fmt.Sprintf("user#%d", member.AccountID),
 		)

 		return nil
--- a/pkg/internal/services/channels.go
+++ b/pkg/internal/services/channels.go
@@ -1,17 +1,15 @@
 package services

 import (
-	"context"
 	"fmt"
 	"regexp"
+	"time"

-	localCache "git.solsynth.dev/hypernet/messaging/pkg/internal/cache"
+	"git.solsynth.dev/hypernet/nexus/pkg/nex/cachekit"
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
-	"github.com/eko/gocache/lib/v4/cache"
-	"github.com/eko/gocache/lib/v4/marshaler"
-	"github.com/eko/gocache/lib/v4/store"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"github.com/samber/lo"
 	"github.com/spf13/viper"
@@ -19,11 +17,11 @@ import (
 )

 type channelIdentityCacheEntry struct {
-	Channel       models.Channel
-	ChannelMember models.ChannelMember
+	Channel       models.Channel       `json:"channel"`
+	ChannelMember models.ChannelMember `json:"channel_member"`
 }

-func GetChannelIdentityCacheKey(channel string, user uint, realm ...uint) string {
+func KgChannelIdentityCache(channel string, user uint, realm ...uint) string {
 	if len(realm) > 0 {
 		return fmt.Sprintf("channel-identity-%s#%d@%d", channel, user, realm)
 	} else {
@@ -31,18 +29,16 @@ func GetChannelIdentityCacheKey(channel string, user uint, realm ...uint) string
 	}
 }

-func CacheChannelIdentityCache(channel models.Channel, member models.ChannelMember, user uint, realm ...uint) {
-	key := GetChannelIdentityCacheKey(channel.Alias, user, realm...)
+func CacheChannelIdentity(channel models.Channel, member models.ChannelMember, user uint, realm ...uint) {
+	key := KgChannelIdentityCache(channel.Alias, user, realm...)

-	cacheManager := cache.New[any](localCache.S)
-	marshal := marshaler.New(cacheManager)
-	contx := context.Background()
-
-	_ = marshal.Set(
-		contx,
+	cachekit.Set(
+		gap.Ca,
 		key,
 		channelIdentityCacheEntry{channel, member},
-		store.WithTags([]string{"channel-identity", fmt.Sprintf("channel#%d", channel.ID), fmt.Sprintf("user#%d", user)}),
+		60*time.Minute,
+		fmt.Sprintf("channel#%d", channel.ID),
+		fmt.Sprintf("user#%d", user),
 	)
 }

@@ -60,37 +56,37 @@ func GetChannelIdentityWithID(id uint, user uint) (models.Channel, models.Channe
 }

 func GetChannelIdentity(alias string, user uint, realm ...authm.Realm) (models.Channel, models.ChannelMember, error) {
-	cacheManager := cache.New[any](localCache.S)
-	marshal := marshaler.New(cacheManager)
-	contx := context.Background()
-
 	var err error
 	var channel models.Channel
 	var member models.ChannelMember

 	hitCache := false
 	if len(realm) > 0 {
-		if val, err := marshal.Get(contx, GetChannelIdentityCacheKey(alias, user, realm[0].ID), new(channelIdentityCacheEntry)); err == nil {
-			entry := val.(*channelIdentityCacheEntry)
-			channel = entry.Channel
-			member = entry.ChannelMember
+		if val, err := cachekit.Get[channelIdentityCacheEntry](
+			gap.Ca,
+			KgChannelIdentityCache(alias, user, realm[0].ID),
+		); err == nil {
+			channel = val.Channel
+			member = val.ChannelMember
 			hitCache = true
 		}
 	} else {
-		if val, err := marshal.Get(contx, GetChannelIdentityCacheKey(alias, user), new(channelIdentityCacheEntry)); err == nil {
-			entry := val.(*channelIdentityCacheEntry)
-			channel = entry.Channel
-			member = entry.ChannelMember
+		if val, err := cachekit.Get[channelIdentityCacheEntry](
+			gap.Ca,
+			KgChannelIdentityCache(alias, user),
+		); err == nil {
+			channel = val.Channel
+			member = val.ChannelMember
 			hitCache = true
 		}
 	}
 	if !hitCache {
 		if len(realm) > 0 {
 			channel, member, err = GetAvailableChannelWithAlias(alias, user, realm[0].ID)
-			CacheChannelIdentityCache(channel, member, user, realm[0].ID)
+			CacheChannelIdentity(channel, member, user, realm[0].ID)
 		} else {
 			channel, member, err = GetAvailableChannelWithAlias(alias, user)
-			CacheChannelIdentityCache(channel, member, user)
+			CacheChannelIdentity(channel, member, user)
 		}
 	}

@@ -282,14 +278,7 @@ func EditChannel(channel models.Channel) (models.Channel, error) {
 	err := database.C.Save(&channel).Error

 	if err == nil {
-		cacheManager := cache.New[any](localCache.S)
-		marshal := marshaler.New(cacheManager)
-		contx := context.Background()
-
-		_ = marshal.Invalidate(
-			contx,
-			store.WithInvalidateTags([]string{fmt.Sprintf("channel#%d", channel.ID)}),
-		)
+		cachekit.DeleteByTags(gap.Ca, fmt.Sprintf("channel#%d", channel.ID))
 	}

 	return channel, err
@@ -297,16 +286,12 @@ func EditChannel(channel models.Channel) (models.Channel, error) {

 func DeleteChannel(channel models.Channel) error {
 	if err := database.C.Delete(&channel).Error; err == nil {
+		UnsubscribeAllWithChannels(channel.ID)
+
 		database.C.Where("channel_id = ?", channel.ID).Delete(&models.Event{})
+		database.C.Where("channel_id = ?", channel.ID).Delete(&models.ChannelMember{})

-		cacheManager := cache.New[any](localCache.S)
-		marshal := marshaler.New(cacheManager)
-		contx := context.Background()
-
-		_ = marshal.Invalidate(
-			contx,
-			store.WithInvalidateTags([]string{fmt.Sprintf("channel#%d", channel.ID)}),
-		)
+		cachekit.DeleteByTags(gap.Ca, fmt.Sprintf("channel#%d", channel.ID))

 		return nil
 	} else {
--- a/pkg/internal/services/events.go
+++ b/pkg/internal/services/events.go
@@ -7,6 +7,8 @@ import (
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex/cruda"
+	"git.solsynth.dev/hypernet/paperclip/pkg/filekit"
+	"git.solsynth.dev/hypernet/paperclip/pkg/proto"
 	"git.solsynth.dev/hypernet/passport/pkg/authkit"
 	"git.solsynth.dev/hypernet/pusher/pkg/pushkit"

@@ -15,6 +17,7 @@ import (
 	jsoniter "github.com/json-iterator/go"
 	"github.com/rs/zerolog/log"
 	"github.com/samber/lo"
+	"github.com/spf13/viper"
 )

 func CountEvent(channel models.Channel) int64 {
@@ -84,12 +87,25 @@ func NewEvent(event models.Event) (models.Event, error) {
 		return event, nil
 	}

+	if val, ok := event.Body["attachments"].([]string); ok && len(val) > 0 {
+		filekit.CountAttachmentUsage(gap.Nx, &proto.UpdateUsageRequest{
+			Rid:   val,
+			Delta: 1,
+		})
+	}
+
 	event, err := GetEvent(event.ChannelID, event.ID)
 	if err != nil {
 		log.Error().Err(err).Msg("Failed to fetch event, the notifying of new event was terminated...")
 		return event, err
 	}
-	idxList := lo.Map(members, func(item models.ChannelMember, index int) uint64 {
+	idxList := lo.Map(lo.Filter(members, func(item models.ChannelMember, index int) bool {
+		if !viper.GetBool("performance.passive_user_optimize") {
+			// Leave this for backward compatibility
+			return true
+		}
+		return CheckSubscribed(item.AccountID, event.ChannelID)
+	}), func(item models.ChannelMember, index int) uint64 {
 		return uint64(item.AccountID)
 	})
 	_ = PushCommandBatch(idxList, nex.WebSocketPackage{
@@ -120,6 +136,9 @@ func NotifyMessageEvent(members []models.ChannelMember, event models.Event) {
 	var mentionedUsers []uint64

 	for _, member := range members {
+		if CheckSubscribed(member.AccountID, event.ChannelID) {
+			continue
+		}
 		if member.ID != event.SenderID {
 			switch member.Notify {
 			case models.NotifyLevelNone:
--- a/pkg/internal/services/reading_anchor.go
+++ b/pkg/internal/services/reading_anchor.go
@@ -4,7 +4,6 @@ import (
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"github.com/rs/zerolog/log"
-	"github.com/samber/lo"
 	"gorm.io/gorm"
 )

@@ -22,19 +21,15 @@ func FlushReadingAnchor() {
 	if len(readingAnchorQueue) == 0 {
 		return
 	}
-	idSet := lo.Uniq(lo.Map(lo.Keys(readingAnchorQueue), func(item uint, _ int) uint {
-		return item
-	}))
-	var pairs []map[string]any
 	for k, v := range readingAnchorQueue {
-		pairs = append(pairs, map[string]any{
-			"id":             k,
-			"reading_anchor": gorm.Expr("GREATEST(reading_anchor, ?)", v),
-		})
-	}
-	if err := database.C.Model(&models.ChannelMember{}).
-		Where("id IN ?", idSet).
-		Updates(pairs).Error; err != nil {
-		log.Error().Err(err).Msg("An error occurred when flushing reading anchor...")
+		if err := database.C.Model(&models.ChannelMember{}).
+			Where("id = ?", k).
+			Updates(map[string]any{
+				"reading_anchor": gorm.Expr("GREATEST(COALESCE(reading_anchor, 0), ?)", v),
+			}).Error; err != nil {
+			log.Error().Err(err).Msg("An error occurred when flushing reading anchor...")
+			return
+		}
 	}
+	clear(readingAnchorQueue)
 }
--- a/pkg/internal/services/status.go
+++ b/pkg/internal/services/status.go
@@ -1,17 +1,16 @@
 package services

 import (
-	"context"
 	"fmt"
-	localCache "git.solsynth.dev/hypernet/messaging/pkg/internal/cache"
+	"time"
+
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
-	"git.solsynth.dev/hypernet/nexus/pkg/proto"
-	"github.com/eko/gocache/lib/v4/cache"
-	"github.com/eko/gocache/lib/v4/marshaler"
-	"github.com/eko/gocache/lib/v4/store"
+	"git.solsynth.dev/hypernet/nexus/pkg/nex/cachekit"
+	"github.com/samber/lo"
+	"github.com/spf13/viper"
 )

 type statusQueryCacheEntry struct {
@@ -19,23 +18,21 @@ type statusQueryCacheEntry struct {
 	Data   any
 }

-func GetTypingStatusQueryCacheKey(channelId uint, userId uint) string {
-	return fmt.Sprintf("typing-status-query#%d;%d", channelId, userId)
+func KgTypingStatusCache(channelId uint, userId uint) string {
+	return fmt.Sprintf("chat-typing-status#%d@%d", userId, channelId)
 }

 func SetTypingStatus(channelId uint, userId uint) error {
 	var broadcastTarget []uint64
 	var data any

-	cacheManager := cache.New[any](localCache.S)
-	marshal := marshaler.New(cacheManager)
-	contx := context.Background()
-
 	hitCache := false
-	if val, err := marshal.Get(contx, GetTypingStatusQueryCacheKey(channelId, userId), new(statusQueryCacheEntry)); err == nil {
-		entry := val.(*statusQueryCacheEntry)
-		broadcastTarget = entry.Target
-		data = entry.Data
+	if val, err := cachekit.Get[statusQueryCacheEntry](
+		gap.Ca,
+		KgTypingStatusCache(channelId, userId),
+	); err == nil {
+		broadcastTarget = val.Target
+		data = val.Data
 		hitCache = true
 	}

@@ -68,22 +65,27 @@ func SetTypingStatus(channelId uint, userId uint) error {
 		}

 		// Cache queries
-		_ = marshal.Set(
-			contx,
-			GetTypingStatusQueryCacheKey(channelId, userId),
+		cachekit.Set(
+			gap.Ca,
+			KgTypingStatusCache(channelId, userId),
 			statusQueryCacheEntry{broadcastTarget, data},
-			store.WithTags([]string{"typing-status-query", fmt.Sprintf("channel#%d", channelId), fmt.Sprintf("user#%d", userId)}),
+			60*time.Minute,
+			fmt.Sprintf("channel#%d", channelId),
 		)
 	}

-	sc := proto.NewStreamServiceClient(gap.Nx.GetNexusGrpcConn())
-	_, err := sc.PushStreamBatch(context.Background(), &proto.PushStreamBatchRequest{
-		UserId: broadcastTarget,
-		Body: nex.WebSocketPackage{
-			Action:  "status.typing",
-			Payload: data,
-		}.Marshal(),
+	broadcastTarget = lo.Filter(broadcastTarget, func(item uint64, index int) bool {
+		if !viper.GetBool("performance.passive_user_optimize") {
+			// Leave this for backward compatibility
+			return true
+		}
+		return CheckSubscribed(uint(item), channelId)
 	})

-	return err
+	PushCommandBatch(broadcastTarget, nex.WebSocketPackage{
+		Action:  "status.typing",
+		Payload: data,
+	})
+
+	return nil
 }
--- a/pkg/internal/services/subscribe.go
+++ b/pkg/internal/services/subscribe.go
@@ -0,0 +1,63 @@
+package services
+
+import "sync"
+
+// ChannelID -> UserID -> Client ID
+var subscribeInfo = make(map[uint]map[uint]string)
+var subscribeLock sync.Mutex
+
+// If user subscribed to a channel
+// Push the new message to them via websocket
+// And skip the notification
+
+func CheckSubscribed(UserID uint, ChannelID uint) bool {
+	if _, ok := subscribeInfo[ChannelID]; ok {
+		if _, ok := subscribeInfo[ChannelID][UserID]; ok {
+			return true
+		}
+	}
+	return false
+}
+
+func SubscribeChannel(userId uint, channelId uint, clientId string) {
+	subscribeLock.Lock()
+	defer subscribeLock.Unlock()
+	if _, ok := subscribeInfo[channelId]; !ok {
+		subscribeInfo[channelId] = make(map[uint]string)
+	}
+	subscribeInfo[channelId][userId] = clientId
+}
+
+func UnsubscribeChannel(userId uint, channelId uint) {
+	subscribeLock.Lock()
+	defer subscribeLock.Unlock()
+	if _, ok := subscribeInfo[channelId]; ok {
+		delete(subscribeInfo[channelId], userId)
+	}
+}
+
+func UnsubscribeAll(userId uint) {
+	subscribeLock.Lock()
+	defer subscribeLock.Unlock()
+	for _, v := range subscribeInfo {
+		delete(v, userId)
+	}
+}
+
+func UnsubscribeAllWithChannels(channelId uint) {
+	subscribeLock.Lock()
+	defer subscribeLock.Unlock()
+	delete(subscribeInfo, channelId)
+}
+
+func UnsubscribeAllWithClient(clientId string) {
+	subscribeLock.Lock()
+	defer subscribeLock.Unlock()
+	for _, v := range subscribeInfo {
+		for k, item := range v {
+			if item == clientId {
+				delete(v, k)
+			}
+		}
+	}
+}
--- a/pkg/internal/services/websocket.go
+++ b/pkg/internal/services/websocket.go
@@ -2,9 +2,11 @@ package services

 import (
 	"context"
+	"strconv"
+	"time"
+
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
 	"github.com/rs/zerolog/log"
-	"time"

 	"github.com/samber/lo"

@@ -21,7 +23,6 @@ func PushCommand(userId uint, task nex.WebSocketPackage) {
 		UserId: lo.ToPtr(uint64(userId)),
 		Body:   task.Marshal(),
 	})
-
 	if err != nil {
 		log.Warn().Err(err).Msg("Failed to push websocket command to nexus...")
 	}
@@ -36,10 +37,12 @@ func PushCommandBatch(userId []uint64, task nex.WebSocketPackage) []uint64 {
 		UserId: userId,
 		Body:   task.Marshal(),
 	})
-
 	if err != nil {
 		log.Warn().Err(err).Msg("Failed to push websocket command to nexus in batches...")
 	}

-	return resp.GetSuccessList()
+	return lo.Map(resp.GetSuccessList(), func(item string, _ int) uint64 {
+		val, _ := strconv.ParseUint(item, 10, 64)
+		return val
+	})
 }
--- a/pkg/internal/http/api/calls_api.go
+++ b/pkg/internal/http/api/calls_api.go
@@ -6,7 +6,7 @@ import (
 	"sync"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 	"github.com/gofiber/fiber/v2"
--- a/pkg/internal/http/api/channel_members_api.go
+++ b/pkg/internal/http/api/channel_members_api.go
@@ -2,7 +2,7 @@ package api

 import (
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex/cruda"
 	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
 	"git.solsynth.dev/hypernet/passport/pkg/authkit"
--- a/pkg/internal/http/api/channels_api.go
+++ b/pkg/internal/http/api/channels_api.go
@@ -8,7 +8,7 @@ import (
 	"git.solsynth.dev/hypernet/passport/pkg/authkit"
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
--- a/pkg/internal/http/api/direct_channels_api.go
+++ b/pkg/internal/http/api/direct_channels_api.go
@@ -7,7 +7,7 @@ import (
 	"git.solsynth.dev/hypernet/passport/pkg/authkit"
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
--- a/pkg/internal/http/api/events_api.go
+++ b/pkg/internal/http/api/events_api.go
@@ -7,7 +7,7 @@ import (
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
 	"github.com/samber/lo"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 	"github.com/gofiber/fiber/v2"
--- a/pkg/internal/http/api/events_message_api.go
+++ b/pkg/internal/http/api/events_message_api.go
@@ -5,7 +5,7 @@ import (
 	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
 	"strings"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 	"github.com/gofiber/fiber/v2"
--- a/pkg/internal/http/api/index.go
+++ b/pkg/internal/http/api/index.go
@@ -23,8 +23,10 @@ func MapAPIs(app *fiber.App, baseURL string) {
 			channels.Get("/me/available", listAvailableChannel)
 			channels.Get("/:channel", getChannel)
 			channels.Get("/:channel/me", getChannelIdentity)
+			channels.Get("/:channel/members/me", getChannelIdentity)
 			channels.Put("/:channel/me", editChannelIdentity)
 			channels.Put("/:channel/me/notify", editChannelNotifyLevel)
+			channels.Put("/:channel/members/me/notify", editChannelNotifyLevel)
 			channels.Delete("/:channel/me", deleteChannelIdentity)

 			channels.Post("/", createChannel)
--- a/pkg/internal/http/api/quick_actions_api.go
+++ b/pkg/internal/http/api/quick_actions_api.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"strings"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/exts"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/exts"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/models"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 	"github.com/gofiber/fiber/v2"
--- a/pkg/internal/http/api/realms_api.go
+++ b/pkg/internal/http/api/realms_api.go
--- a/pkg/internal/web/api/whats_new_api.go
+++ b/pkg/internal/web/api/whats_new_api.go
@@ -0,0 +1,31 @@
+package api
+
+import (
+	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
+	authm "git.solsynth.dev/hypernet/passport/pkg/authkit/models"
+
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
+	"github.com/gofiber/fiber/v2"
+)
+
+func getWhatsNew(c *fiber.Ctx) error {
+	if err := sec.EnsureAuthenticated(c); err != nil {
+		return err
+	}
+	user := c.Locals("user").(authm.Account)
+
+	var result []struct {
+		ChannelID          uint `json:"channel_id"`
+		UnreadMessageCount int  `json:"count"`
+	}
+	if err := database.C.Table("channel_members cm").
+		Select("cm.channel_id, COUNT(m.id) AS unread_message_count").
+		Joins("JOIN events m ON m.channel_id = cm.channel_id").
+		Where("m.id > cm.reading_anchor AND cm.account_id = ?", user.ID).
+		Group("cm.channel_id").
+		Scan(&result).Error; err != nil {
+		return fiber.NewError(fiber.StatusInternalServerError, err.Error())
+	}
+
+	return c.JSON(result)
+}
--- a/pkg/internal/http/exts/utils.go
+++ b/pkg/internal/http/exts/utils.go
--- a/pkg/internal/http/server.go
+++ b/pkg/internal/http/server.go
@@ -1,11 +1,12 @@
-package http
+package web

 import (
-	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
-	"git.solsynth.dev/hypernet/passport/pkg/authkit"
 	"strings"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http/api"
+	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
+	"git.solsynth.dev/hypernet/passport/pkg/authkit"
+
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web/api"
 	"github.com/gofiber/fiber/v2"
 	"github.com/gofiber/fiber/v2/middleware/cors"
 	"github.com/gofiber/fiber/v2/middleware/idempotency"
@@ -31,6 +32,7 @@ func NewServer() *App {
 		JSONEncoder:           jsoniter.ConfigCompatibleWithStandardLibrary.Marshal,
 		JSONDecoder:           jsoniter.ConfigCompatibleWithStandardLibrary.Unmarshal,
 		BodyLimit:             50 * 1024 * 1024,
+		ReadBufferSize:        5 * 1024 * 1024, // 5MB for large JWT
 		EnablePrintRoutes:     viper.GetBool("debug.print_routes"),
 	})

--- a/pkg/main.go
+++ b/pkg/main.go
@@ -2,22 +2,22 @@ package main

 import (
 	"fmt"
-	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
-	"github.com/fatih/color"
 	"os"
 	"os/signal"
 	"syscall"

+	"git.solsynth.dev/hypernet/nexus/pkg/nex/sec"
+	"github.com/fatih/color"
+
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/gap"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/grpc"

 	"git.solsynth.dev/hypernet/messaging/pkg/internal/services"
 	"github.com/robfig/cron/v3"

-	"git.solsynth.dev/hypernet/messaging/pkg/internal/http"
+	"git.solsynth.dev/hypernet/messaging/pkg/internal/web"

 	pkg "git.solsynth.dev/hypernet/messaging/pkg/internal"
-	"git.solsynth.dev/hypernet/messaging/pkg/internal/cache"
 	"git.solsynth.dev/hypernet/messaging/pkg/internal/database"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
@@ -56,7 +56,7 @@ func main() {
 	if reader, err := sec.NewInternalTokenReader(viper.GetString("security.internal_public_key")); err != nil {
 		log.Error().Err(err).Msg("An error occurred when reading internal public key for jwt. Authentication related features will be disabled.")
 	} else {
-		http.IReader = reader
+		web.IReader = reader
 		log.Info().Msg("Internal jwt public key loaded.")
 	}

@@ -67,23 +67,18 @@ func main() {
 		log.Fatal().Err(err).Msg("An error occurred when running database auto migration.")
 	}

-	// Initialize cache
-	if err := cache.NewStore(); err != nil {
-		log.Fatal().Err(err).Msg("An error occurred when initializing cache.")
-	}
-
 	// Connect other services
 	services.SetupLiveKit()

 	// Server
-	go http.NewServer().Listen()
+	go web.NewServer().Listen()

 	go grpc.NewGrpc().Listen()

 	// Configure timed tasks
 	quartz := cron.New(cron.WithLogger(cron.VerbosePrintfLogger(&log.Logger)))
 	quartz.AddFunc("@every 60m", services.DoAutoDatabaseCleanup)
-	quartz.AddFunc("@every 1m", services.FlushReadingAnchor)
+	quartz.AddFunc("@every 30s", services.FlushReadingAnchor)
 	quartz.Start()

 	// Messages
--- a/settings.toml
+++ b/settings.toml
@@ -5,6 +5,9 @@ grpc_bind = "0.0.0.0:7447"

 nexus_addr = "localhost:7001"

+[performance]
+passive_user_optimize = true
+
 [debug]
 database = false
 print_routes = false
Author	SHA1	Message	Date
LittleSheep	24d04c3e79	⬆️ Upgrade nexus to fix bug	2025-03-29 16:02:10 +08:00
LittleSheep	e916eb2395	♻️ Rebuilt cache with nexus cache	2025-03-29 15:02:04 +08:00
LittleSheep	c24ed1e7e6	🚚 Rename http package to web	2025-03-29 14:45:12 +08:00
LittleSheep	ae2c141efa	🐛 Fix large JWT headers	2025-03-23 00:08:10 +08:00
LittleSheep	15c513fe6d	🐛 Fix channel member able to get empty data	2025-03-22 13:11:23 +08:00
LittleSheep	1c92ea36e3	🐛 Fix delete channel remain channel member	2025-03-18 00:28:20 +08:00
LittleSheep	9dacb152de	⬆️ Upgrade passport	2025-03-15 17:25:20 +08:00
LittleSheep	9014f59a2c	🐛 Fix message attachment didn't marked	2025-03-11 13:09:37 +08:00
LittleSheep	7294aa3e43	👽 Update to mark attachments	2025-03-11 00:14:31 +08:00
LittleSheep	dd8f6d933e	✨ Recycle realm channels when hear realm deleted	2025-03-10 21:43:23 +08:00
LittleSheep	40f752259c	🐛 Fix golang check sum	2025-03-07 23:37:15 +08:00
LittleSheep	e4844c3293	⬆️ Upgrade some SDKs	2025-03-07 23:35:13 +08:00
LittleSheep	d304f3b319	✨ Add keypair capability into message body	2025-03-03 23:51:05 +08:00
LittleSheep	eea9b85745	✨ Disconnect websocket auto cleaning up subscribed channels	2025-03-01 18:02:55 +08:00
LittleSheep	e3a4988ccf	⚡ Optimize for passive users ✨ Subscribe to channel focused	2025-03-01 17:52:57 +08:00
LittleSheep	d22a435224	⬆️ Upgrade nexus	2025-03-01 14:56:29 +08:00
LittleSheep	c4b64dfc09	👽 Update account deletion	2025-03-01 14:11:48 +08:00
LittleSheep	672c006cd5	🐛 Fix backward compability	2025-02-25 13:12:29 +08:00
LittleSheep	7566720420	💄 Show name instead of alias in notification	2025-02-23 21:05:27 +08:00
LittleSheep	c1d0b2f650	💄 Optimize notification displaying	2025-02-23 18:43:06 +08:00
LittleSheep	6d0caa1cde	🐛 Provide backwards compability on APIs	2025-02-23 18:27:55 +08:00
LittleSheep	c558044646	⚡ Reduce the flush reading anchor delay	2025-02-23 11:43:09 +08:00
LittleSheep	acd23deed4	🐛 Fix what's new query	2025-02-23 01:27:06 +08:00
LittleSheep	d010a9e5d4	🐛 Fix update reading anchor issue	2025-02-23 01:10:45 +08:00
LittleSheep	6bedb3a17d	🐛 Fix flush reading anchor	2025-02-23 00:58:20 +08:00
LittleSheep	bce86224bb	🐛 Bug fixes	2025-02-23 00:51:31 +08:00