traslate sse notifications

Signed-off-by: jkoberg <jkoberg@owncloud.com>

services/userlog/pkg/command/server.go

@@ -16,6 +16,7 @@ import (
 	ogrpc "github.com/owncloud/ocis/v2/ocis-pkg/service/grpc"
 	"github.com/owncloud/ocis/v2/ocis-pkg/version"
 	ehsvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/eventhistory/v0"
+	settingssvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/settings/v0"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/config"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/config/parser"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/logging"
@@ -102,6 +103,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}
 
 			hClient := ehsvc.NewEventHistoryService("com.owncloud.api.eventhistory", ogrpc.DefaultClient())
+			vClient := settingssvc.NewValueService("com.owncloud.api.settings", ogrpc.DefaultClient())
 
 			{
 				server, err := http.Server(
@@ -113,6 +115,7 @@ func Server(cfg *config.Config) *cli.Command {
 					http.Consumer(consumer),
 					http.GatewaySelector(gatewaySelector),
 					http.History(hClient),
+					http.Value(vClient),
 					http.RegisteredEvents(_registeredEvents),
 				)
 

services/userlog/pkg/server/http/option.go

@@ -8,6 +8,7 @@ import (
 	"github.com/cs3org/reva/v2/pkg/rgrpc/todo/pool"
 	"github.com/owncloud/ocis/v2/ocis-pkg/log"
 	ehsvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/eventhistory/v0"
+	settingssvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/settings/v0"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/config"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/metrics"
 	"github.com/urfave/cli/v2"
@@ -29,6 +30,7 @@ type Options struct {
 	Consumer         events.Consumer
 	GatewaySelector  pool.Selectable[gateway.GatewayAPIClient]
 	HistoryClient    ehsvc.EventHistoryService
+	ValueClient      settingssvc.ValueService
 	RegisteredEvents []events.Unmarshaller
 }
 
@@ -119,3 +121,10 @@ func RegisteredEvents(evs []events.Unmarshaller) Option {
 		o.RegisteredEvents = evs
 	}
 }
+
+// Value provides a function to configure the value service client
+func Value(vs settingssvc.ValueService) Option {
+	return func(o *Options) {
+		o.ValueClient = vs
+	}
+}

services/userlog/pkg/server/http/server.go

@@ -76,6 +76,7 @@ func Server(opts ...Option) (http.Service, error) {
 		svc.Config(options.Config),
 		svc.HistoryClient(options.HistoryClient),
 		svc.GatewaySelector(options.GatewaySelector),
+		svc.ValueClient(options.ValueClient),
 		svc.RegisteredEvents(options.RegisteredEvents),
 	)
 	if err != nil {

services/userlog/pkg/service/options.go

@@ -7,6 +7,7 @@ import (
 	"github.com/go-chi/chi/v5"
 	"github.com/owncloud/ocis/v2/ocis-pkg/log"
 	ehsvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/eventhistory/v0"
+	settingssvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/settings/v0"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/config"
 	"go-micro.dev/v4/store"
 )
@@ -23,6 +24,7 @@ type Options struct {
 	Config           *config.Config
 	HistoryClient    ehsvc.EventHistoryService
 	GatewaySelector  pool.Selectable[gateway.GatewayAPIClient]
+	ValueClient      settingssvc.ValueService
 	RegisteredEvents []events.Unmarshaller
 }
 
@@ -81,3 +83,9 @@ func RegisteredEvents(e []events.Unmarshaller) Option {
 		o.RegisteredEvents = e
 	}
 }
+
+func ValueClient(vs settingssvc.ValueService) Option {
+	return func(o *Options) {
+		o.ValueClient = vs
+	}
+}

services/userlog/pkg/service/service.go

@@ -18,14 +18,20 @@ import (
 	"github.com/cs3org/reva/v2/pkg/utils"
 	"github.com/go-chi/chi/v5"
 	"github.com/owncloud/ocis/v2/ocis-pkg/log"
+	"github.com/owncloud/ocis/v2/ocis-pkg/middleware"
 	ehmsg "github.com/owncloud/ocis/v2/protogen/gen/ocis/messages/eventhistory/v0"
 	ehsvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/eventhistory/v0"
+	settingssvc "github.com/owncloud/ocis/v2/protogen/gen/ocis/services/settings/v0"
+	"github.com/owncloud/ocis/v2/services/settings/pkg/store/defaults"
 	"github.com/owncloud/ocis/v2/services/userlog/pkg/config"
 	"github.com/r3labs/sse/v2"
+	micrometadata "go-micro.dev/v4/metadata"
 	"go-micro.dev/v4/store"
 	"google.golang.org/grpc/metadata"
 )
 
+var _defaultLocale = "en"
+
 // UserlogService is the service responsible for user activities
 type UserlogService struct {
 	log              log.Logger
@@ -34,6 +40,7 @@ type UserlogService struct {
 	cfg              *config.Config
 	historyClient    ehsvc.EventHistoryService
 	gatewaySelector  pool.Selectable[gateway.GatewayAPIClient]
+	valueClient      settingssvc.ValueService
 	sse              *sse.Server
 	registeredEvents map[string]events.Unmarshaller
 	translationPath  string
@@ -62,6 +69,7 @@ func NewUserlogService(opts ...Option) (*UserlogService, error) {
 		cfg:              o.Config,
 		historyClient:    o.HistoryClient,
 		gatewaySelector:  o.GatewaySelector,
+		valueClient:      o.ValueClient,
 		sse:              sse.New(),
 		registeredEvents: make(map[string]events.Unmarshaller),
 	}
@@ -224,7 +232,7 @@ func (ul *UserlogService) DeleteEvents(userid string, evids []string) error {
 }
 
 func (ul *UserlogService) addEventToUser(userid string, event events.Event) error {
-	loc := "en" // TODO: where to get the locale from?
+	loc := getUserLang(context.Background(), userid, ul.valueClient)
 	ev, _ := NewConverter(loc, ul.gatewaySelector, ul.cfg.MachineAuthAPIKey, ul.cfg.Service.Name, ul.cfg.TranslationPath).ConvertEvent(event.ID, event.Event)
 	b, _ := json.Marshal(ev)
 
@@ -542,3 +550,19 @@ func editor(perms *storageprovider.ResourcePermissions) bool {
 func manager(perms *storageprovider.ResourcePermissions) bool {
 	return perms.DenyGrant
 }
+
+func getUserLang(ctx context.Context, userid string, vs settingssvc.ValueService) string {
+	granteeCtx := micrometadata.Set(ctx, middleware.AccountID, userid)
+	if resp, err := vs.GetValueByUniqueIdentifiers(granteeCtx,
+		&settingssvc.GetValueByUniqueIdentifiersRequest{
+			AccountUuid: userid,
+			SettingId:   defaults.SettingUUIDProfileLanguage,
+		},
+	); err == nil {
+		val := resp.GetValue().GetValue().GetListValue().GetValues()
+		if len(val) > 0 && val[0] != nil {
+			return val[0].GetStringValue()
+		}
+	}
+	return _defaultLocale
+}