Configure pwa and add notifications

.github/workflows/notification_service.yml

@@ -0,0 +1,16 @@
+name: Notification Service
+
+on:
+  pull_request:
+    branches: [ main ]
+    paths:
+    - 'backend/services/notifications/**'
+    - 'backend/store/**'
+
+jobs:
+  build-notifications:
+    uses: ./.github/workflows/build_service.yml
+    with:
+      image-name: kioku_notifications
+      path: ./backend/services/notifications
+      context: ./backend

.github/workflows/release.yml

@@ -52,4 +52,11 @@ jobs:
       image-name: kioku_srs
       image-tag: prod
       path: ./backend/services/srs
-      context: ./backend
+      context: ./backend
+  build-notifications:
+    uses: ./.github/workflows/build_service.yml
+    with:
+      image-name: kioku_notifications
+      image-tag: prod
+      path: ./backend/services/notifications
+      context: ./backend

.gitignore

@@ -3,4 +3,3 @@
 *secret.yaml
 private_key.yaml
 .DS_STORE
-frontend/build-storybook.log

README.md

@@ -120,6 +120,12 @@ You can generate the `JWT_PRIVATE_KEY` with the following command
 openssl ecparam -name secp521r1 -genkey -noout -out my.key.pem
 ```
 
+To enable notification support, you will have to generate a VAPID keypair and add the public and private key to the frontend and backend `.env` files.
+To do this, you can type the following command in the frontend folder:
+```bash
+npx web-push generate-vapid-keys
+```
+
 > [!WARNING]
 > The example environment file is populated with default values, be sure to change all values before using the application in production!
 

backend/.env.example

@@ -16,3 +16,5 @@ TRACING_ENABLED=false
 JWT_PRIVATE_KEY="
 # generate with: `openssl ecparam -name secp521r1 -genkey -noout -out my.key.pem`
 "
+VAPID_PUBLIC_KEY=""
+VAPID_PRIVATE_KEY=""

backend/api-documentation/user/delete user.bru

@@ -1,7 +1,7 @@
 meta {
   name: delete user
   type: http
-  seq: 7
+  seq: 9
 }
 
 delete {

backend/api-documentation/user/get notification subscriptions.bru

@@ -0,0 +1,23 @@
+meta {
+  name: get notification subscriptions
+  type: http
+  seq: 4
+}
+
+get {
+  url: {{baseUrl}}/api/user/notifications
+  body: json
+  auth: bearer
+}
+
+auth:bearer {
+  token: {{accessToken}}
+}
+
+body:json {
+  {
+    "endpoint": "",
+    "auth": "",
+    "p256dh": ""
+  }
+}

backend/api-documentation/user/modify user.bru

@@ -1,7 +1,7 @@
 meta {
   name: modify user
   type: http
-  seq: 6
+  seq: 8
 }
 
 put {

backend/api-documentation/user/register.bru

@@ -1,7 +1,7 @@
 meta {
   name: register
   type: http
-  seq: 4
+  seq: 6
 }
 
 post {

backend/api-documentation/user/subscribe notifications.bru

@@ -0,0 +1,23 @@
+meta {
+  name: subscribe notifications
+  type: http
+  seq: 7
+}
+
+post {
+  url: {{baseUrl}}/api/user/notifications
+  body: json
+  auth: bearer
+}
+
+auth:bearer {
+  token: {{accessToken}}
+}
+
+body:json {
+  {
+    "endpoint": "",
+    "auth": "",
+    "p256dh": ""
+  }
+}

backend/api-documentation/user/unsubscribe notifications.bru

@@ -0,0 +1,15 @@
+meta {
+  name: unsubscribe notifications
+  type: http
+  seq: 10
+}
+
+delete {
+  url: {{baseUrl}}/api/user/notifications/{{subscriptionID}}
+  body: none
+  auth: bearer
+}
+
+auth:bearer {
+  token: {{accessToken}}
+}

backend/go.mod

@@ -19,12 +19,14 @@ require (
 
 require (
 	dario.cat/mergo v1.0.0 // indirect
+	github.com/SherClockHolmes/webpush-go v1.3.0 // indirect
 	github.com/andybalholm/brotli v1.1.0 // indirect
 	github.com/cenkalti/backoff/v4 v4.2.1 // indirect
 	github.com/cyphar/filepath-securejoin v0.2.4 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/go-logr/logr v1.4.1 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
 	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
@@ -39,6 +41,7 @@ require (
 	github.com/mattn/go-runewidth v0.0.15 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/rivo/uniseg v0.4.4 // indirect
+	github.com/robfig/cron/v3 v3.0.0 // indirect
 	github.com/sirupsen/logrus v1.9.3 // indirect
 	github.com/valyala/bytebufferpool v1.0.0 // indirect
 	github.com/valyala/fasthttp v1.51.0 // indirect

backend/go.sum

@@ -3,6 +3,10 @@ dario.cat/mergo v1.0.0/go.mod h1:uNxQE+84aUszobStD9th8a29P2fMDhsBdgRYvZOxGmk=
 github.com/Microsoft/go-winio v0.5.2/go.mod h1:WpS1mjBmmwHBEWmogvA2mj8546UReBk4v8QkMxJ6pZY=
 github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
 github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
+github.com/SherClockHolmes/webpush-go v1.3.0 h1:CAu3FvEE9QS4drc3iKNgpBWFfGqNthKlZhp5QpYnu6k=
+github.com/SherClockHolmes/webpush-go v1.3.0/go.mod h1:AxRHmJuYwKGG1PVgYzToik1lphQvDnqFYDqimHvwhIw=
+github.com/acomagu/bufpipe v1.0.4 h1:e3H4WUzM3npvo5uv95QuJM3cQspFNtFBzvJ2oNjKIDQ=
+github.com/acomagu/bufpipe v1.0.4/go.mod h1:mxdxdup/WdsKVreO5GpW4+M/1CE2sMG4jeGJ2sYmHc4=
 github.com/ProtonMail/go-crypto v1.0.0 h1:LRuvITjQWX+WIfr930YHG2HNfjR1uOfyf5vE0kC2U78=
 github.com/ProtonMail/go-crypto v1.0.0/go.mod h1:EjAoLdwvbIOoOQr3ihjnSoLZRtE8azugULFRteWMNc0=
 github.com/andybalholm/brotli v1.0.5/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig=
@@ -72,6 +76,8 @@ github.com/gofiber/fiber/v2 v2.52.0 h1:S+qXi7y+/Pgvqq4DrSmREGiFwtB7Bu6+QFLuIHYw/
 github.com/gofiber/fiber/v2 v2.52.0/go.mod h1:KEOE+cXMhXG0zHc9d8+E38hoX+ZN7bhOtgeF2oT6jrQ=
 github.com/gofiber/jwt/v3 v3.3.10 h1:0bpWtFKaGepjwYTU4efHfy0o+matSqZwTxGMo5a+uuc=
 github.com/gofiber/jwt/v3 v3.3.10/go.mod h1:GJorFVaDyfMPSK9RB8RG4NQ3s1oXKTmYaoL/ny08O1A=
+github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY=
+github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
 github.com/golang-jwt/jwt/v4 v4.5.0 h1:7cYmW1XlMY7h7ii7UhUyChSgS5wUJEnm9uZVTGqOWzg=
 github.com/golang-jwt/jwt/v4 v4.5.0/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0=
 github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE=
@@ -146,6 +152,8 @@ github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZN
 github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
 github.com/rivo/uniseg v0.4.4 h1:8TfxU8dW6PdqD27gjM8MVNuicgxIjxpm4K7x4jp8sis=
 github.com/rivo/uniseg v0.4.4/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
+github.com/robfig/cron/v3 v3.0.0 h1:kQ6Cb7aHOHTSzNVNEhmp8EcWKLb4CbiMW9h9VyIhO4E=
+github.com/robfig/cron/v3 v3.0.0/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M=
 github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
@@ -260,6 +268,8 @@ golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.13.0 h1:Af8nKPmuFypiUBjVoU9V20FiaFXOcuZI21p0ycVYYGE=
+golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.16.0 h1:xWw16ngr6ZMtmxDyKyIgsE93KNKz5HKmMa3b8ALHidU=
 golang.org/x/sys v0.16.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
@@ -268,6 +278,8 @@ golang.org/x/term v0.2.0/go.mod h1:TVmDHMZPmdnySmBfhjOoOdhjzdE1h4u1VwSiw2l1Nuc=
 golang.org/x/term v0.3.0/go.mod h1:q750SLmJuPmVoN1blW3UFBPREJfb1KmY3vwxfr+nFDA=
 golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
 golang.org/x/term v0.6.0/go.mod h1:m6U89DPEgQRMq3DNkDClhWw02AUbt2daBVO4cn4Hv9U=
+golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
+golang.org/x/term v0.13.0 h1:bb+I9cTfFazGW51MZqBVmZy7+JEJMouUHTUSKVQLBek=
 golang.org/x/term v0.16.0 h1:m+B6fahuftsE9qjo0VWp2FW0mB3MTJvR0BaMQrq0pmE=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
@@ -277,6 +289,9 @@ golang.org/x/text v0.4.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
+golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
+golang.org/x/text v0.13.0 h1:ablQoSUd0tRdKxZewP80B+BaqeKJuVhuRxj/dkrun3k=
+golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
 golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
 golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=

backend/pkg/converter/fiberSerializerTypes.go

@@ -81,3 +81,7 @@ type FiberGetGroupMemberRequestsResponseBody struct {
 type FiberGetInvitationsForGroupResponseBody struct {
 	MemberRequests []FiberGroupMemberAdmission `json:"groupInvitations"`
 }
+
+type FiberGetUserSubscriptionsResponseBody struct {
+	UserSubscriptions []string `json:"userSubscriptions"`
+}

backend/pkg/converter/typeConverter.go

@@ -235,3 +235,16 @@ func ProtoUserWithRoleToFiberGroupMember(groupMembers *pbCommon.User) FiberGroup
 		GroupRole: groupMembers.GroupRole.String(),
 	}
 }
+
+func StoreNotificationSubscriptionToProtoNotificationSubscriptionConverter(subscription *model.PushSubscription) *pbCommon.PushSubscription {
+	return &pbCommon.PushSubscription{
+		SubscriptionID: subscription.ID,
+		Endpoint:       subscription.Endpoint,
+		P256Dh:         subscription.P256DH,
+		Auth:           subscription.Auth,
+	}
+}
+
+func ProtoNotificationSubscriptionToIDStringConverter(subscription *pbCommon.PushSubscription) string {
+	return subscription.SubscriptionID
+}

backend/pkg/helper/errors.go

@@ -15,6 +15,7 @@ const (
 	FrontendServiceID      ClientID = "services.frontend"
 	UserServiceID          ClientID = "services.user"
 	SrsServiceID           ClientID = "services.srs"
+	NotificationsServiceID ClientID = "services.notifications"
 )
 
 var (

backend/pkg/helper/validation.go

@@ -0,0 +1,10 @@
+package helper
+
+func SomeEmpty(fields ...string) bool {
+	for _, field := range fields {
+		if field == "" {
+			return true
+		}
+	}
+	return false
+}

backend/pkg/model/notification.go

@@ -0,0 +1,34 @@
+package model
+
+import gorm "gorm.io/gorm"
+import "github.com/kioku-project/kioku/pkg/helper"
+
+type PushNotification struct {
+	Title   string                  `json:"title"`
+	Options PushNotificationOptions `json:"options"`
+}
+
+type PushNotificationOptions struct {
+	Body    string              `json:"body"`
+	Actions []map[string]string `json:"actions"`
+	Vibrate []int               `json:"vibrate"`
+	Tag     string              `json:"tag"`
+}
+
+type PushSubscription struct {
+	ID       string `gorm:"primaryKey"`
+	UserID   string `gorm:"not null"`
+	User     User
+	Endpoint string `gorm:"not null"`
+	P256DH   string `gorm:"not null"`
+	Auth     string `gorm:"not null"`
+}
+
+func (c *PushSubscription) BeforeCreate(db *gorm.DB) (err error) {
+	newID, err := helper.FindFreeID(db, 10, func() (helper.PublicID, *PushSubscription) {
+		id := helper.GenerateID('N')
+		return id, &PushSubscription{ID: id.GetStringRepresentation()}
+	})
+	c.ID = newID.GetStringRepresentation()
+	return
+}