+
+
+ +
+ + +
+
+
diff --git a/internal/service/email/templates/project_role_notification.txt b/internal/service/email/templates/project_role_notification.txt
new file mode 100644
index 0000000..d235e4d
--- /dev/null
+++ b/internal/service/email/templates/project_role_notification.txt
@@ -0,0 +1,12 @@
+{{- /* Copyright The Linux Foundation and each contributor to LFX. */ -}}
+{{- /* SPDX-License-Identifier: MIT */ -}}
+Hi {{.RecipientName}},
+
+{{.InviterName}} has added you as a {{.Role}} on the {{.ProjectName}} project in LFX Self-Serve.
+
+You can view the project here:
+{{.ProjectURL}}
+
+---
+You are receiving this email because you were added to a project on LFX Self-Serve.
+© The Linux Foundation
diff --git a/internal/service/folder_operations.go b/internal/service/folder_operations.go
index 95e5f84..cfe8d47 100644
--- a/internal/service/folder_operations.go
+++ b/internal/service/folder_operations.go
@@ -15,7 +15,7 @@ import (
indexerTypes "github.com/linuxfoundation/lfx-v2-indexer-service/pkg/types"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain/models"
- "github.com/linuxfoundation/lfx-v2-project-service/internal/log"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/infrastructure/log"
"github.com/linuxfoundation/lfx-v2-project-service/pkg/constants"
)
diff --git a/internal/service/link_operations.go b/internal/service/link_operations.go
index 04da78c..43b7eaa 100644
--- a/internal/service/link_operations.go
+++ b/internal/service/link_operations.go
@@ -16,7 +16,7 @@ import (
indexerTypes "github.com/linuxfoundation/lfx-v2-indexer-service/pkg/types"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain/models"
- "github.com/linuxfoundation/lfx-v2-project-service/internal/log"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/infrastructure/log"
"github.com/linuxfoundation/lfx-v2-project-service/pkg/constants"
)
diff --git a/internal/service/project_handlers.go b/internal/service/project_handlers.go
index 4c54b06..258d56b 100644
--- a/internal/service/project_handlers.go
+++ b/internal/service/project_handlers.go
@@ -11,7 +11,7 @@ import (
"github.com/google/uuid"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain"
- "github.com/linuxfoundation/lfx-v2-project-service/internal/log"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/infrastructure/log"
"github.com/linuxfoundation/lfx-v2-project-service/pkg/constants"
structs "github.com/linuxfoundation/lfx-v2-project-service/pkg/struct"
)
diff --git a/internal/service/project_operations.go b/internal/service/project_operations.go
index 0bd4c16..a93437a 100644
--- a/internal/service/project_operations.go
+++ b/internal/service/project_operations.go
@@ -18,8 +18,9 @@ import (
projsvc "github.com/linuxfoundation/lfx-v2-project-service/api/project/v1/gen/project_service"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain/models"
- "github.com/linuxfoundation/lfx-v2-project-service/internal/log"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/infrastructure/log"
"github.com/linuxfoundation/lfx-v2-project-service/pkg/constants"
+ "github.com/linuxfoundation/lfx-v2-project-service/pkg/events"
"github.com/linuxfoundation/lfx-v2-project-service/pkg/misc"
"golang.org/x/sync/errgroup"
)
@@ -584,10 +585,12 @@ func (s *ProjectsService) UpdateProjectSettings(ctx context.Context, payload *pr
})
g.Go(func() error {
- msg := models.ProjectSettingsUpdatedMessage{
+ principal, _ := ctx.Value(constants.PrincipalContextID).(string)
+ msg := events.ProjectSettingsUpdatedMessage{
ProjectUID: *payload.UID,
- OldSettings: *existingProjectSettingsDB,
- NewSettings: *projectSettingsDB,
+ OldSettings: DomainSettingsToEvent(existingProjectSettingsDB),
+ NewSettings: DomainSettingsToEvent(projectSettingsDB),
+ Actor: events.Actor{Username: principal},
}
return s.MessageBuilder.SendProjectEventMessage(ctx, constants.ProjectSettingsUpdatedSubject, msg)
})
diff --git a/internal/service/project_service.go b/internal/service/project_service.go
index 76e0bc1..5467fa1 100644
--- a/internal/service/project_service.go
+++ b/internal/service/project_service.go
@@ -14,6 +14,7 @@ type ProjectsService struct {
LinkRepository domain.LinkRepository
FolderRepository domain.FolderRepository
MessageBuilder domain.MessageBuilder
+ UserReader domain.UserReader
Auth domain.Authenticator
Config ServiceConfig
}
@@ -36,4 +37,6 @@ func (s *ProjectsService) ServiceReady() bool {
type ServiceConfig struct {
// SkipEtagValidation is a flag to skip the Etag validation - only meant for local development.
SkipEtagValidation bool
+ // LFXSelfServeBaseURL is the base URL for LFX Self-Serve, used to build project URLs in notification emails.
+ LFXSelfServeBaseURL string
}
diff --git a/internal/service/project_subscriber.go b/internal/service/project_subscriber.go
new file mode 100644
index 0000000..b3499b0
--- /dev/null
+++ b/internal/service/project_subscriber.go
@@ -0,0 +1,203 @@
+// Copyright The Linux Foundation and each contributor to LFX.
+// SPDX-License-Identifier: MIT
+
+package service
+
+import (
+ "context"
+ "encoding/json"
+ "log/slog"
+ "strings"
+ "time"
+
+ emailapi "github.com/linuxfoundation/lfx-v2-email-service/pkg/api"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/domain"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/service/email"
+ "github.com/linuxfoundation/lfx-v2-project-service/pkg/constants"
+ "github.com/linuxfoundation/lfx-v2-project-service/pkg/events"
+ "golang.org/x/sync/errgroup"
+)
+
+const emailSendTimeout = 5 * time.Second
+
+// HandleProjectSettingsUpdated handles project_settings.updated events and sends
+// notification emails to any users newly added as writers, auditors, or meeting coordinators.
+// Errors from individual sends are logged but never returned — the handler is best-effort.
+func (s *ProjectsService) HandleProjectSettingsUpdated(ctx context.Context, msg domain.Message) error {
+ var event events.ProjectSettingsUpdatedMessage
+ if err := json.Unmarshal(msg.Data(), &event); err != nil {
+ slog.WarnContext(ctx, "project_subscriber: failed to unmarshal project settings updated event", constants.ErrKey, err)
+ return nil
+ }
+
+ additions := diffNewMembers(event.OldSettings, event.NewSettings)
+ slog.DebugContext(ctx, "project_subscriber: received project_settings.updated event",
+ "project_uid", event.ProjectUID, "new_member_count", len(additions))
+ if len(additions) == 0 {
+ return nil
+ }
+
+ projectBase, err := s.ProjectRepository.GetProjectBase(ctx, event.ProjectUID)
+ if err != nil {
+ slog.WarnContext(ctx, "project_subscriber: failed to load project", constants.ErrKey, err, "project_uid", event.ProjectUID)
+ return nil
+ }
+
+ projectURL := strings.TrimRight(s.Config.LFXSelfServeBaseURL, "/") + "/projects/overview"
+
+ inviterName := s.resolveActorDisplayName(ctx, event.Actor)
+
+ g, gctx := errgroup.WithContext(ctx)
+ g.SetLimit(5)
+
+ for _, add := range additions {
+ add := add
+ g.Go(func() error {
+ if add.User.Email == "" {
+ slog.WarnContext(gctx, "project_subscriber: skipping email — recipient has no email address",
+ "role", add.Role, "username", add.User.Username, "project_uid", event.ProjectUID)
+ return nil
+ }
+
+ recipientName := add.User.Name
+ if recipientName == "" {
+ recipientName = add.User.Username
+ }
+ if recipientName == "" {
+ recipientName = add.User.Email
+ }
+
+ subject, html, text, err := email.RenderProjectRoleNotification(email.ProjectRoleNotificationData{
+ RecipientName: recipientName,
+ ProjectName: projectBase.Name,
+ Role: add.Role,
+ ProjectURL: projectURL,
+ InviterName: inviterName,
+ })
+ if err != nil {
+ slog.WarnContext(gctx, "project_subscriber: failed to render email template",
+ constants.ErrKey, err, "role", add.Role, "project_uid", event.ProjectUID)
+ return nil
+ }
+
+ sendCtx, cancel := context.WithTimeout(gctx, emailSendTimeout)
+ defer cancel()
+ sendErr := s.MessageBuilder.SendEmailRequest(sendCtx, emailapi.SendEmailRequest{
+ To: add.User.Email,
+ Subject: subject,
+ HTML: html,
+ Text: text,
+ })
+ if sendErr != nil {
+ slog.WarnContext(gctx, "project_subscriber: failed to send role notification email",
+ constants.ErrKey, sendErr, "role", add.Role, "project_uid", event.ProjectUID)
+ } else {
+ slog.DebugContext(gctx, "project_subscriber: sent role notification email",
+ "role", add.Role, "project_uid", event.ProjectUID, "to", add.User.Email)
+ }
+ return nil
+ })
+ }
+
+ _ = g.Wait()
+ return nil
+}
+
+// resolveActorDisplayName looks up the actor's display name from the auth service.
+// Falls back to "A project administrator" if the lookup fails or returns no name.
+func (s *ProjectsService) resolveActorDisplayName(ctx context.Context, actor events.Actor) string {
+ if actor.Name != "" {
+ return actor.Name
+ }
+ if actor.Username != "" && s.UserReader != nil {
+ lookupCtx, cancel := context.WithTimeout(ctx, emailSendTimeout)
+ defer cancel()
+ if meta, err := s.UserReader.UserMetadataByPrincipal(lookupCtx, actor.Username); err == nil && meta != nil {
+ if meta.Name != "" {
+ return meta.Name
+ }
+ if full := strings.TrimSpace(meta.GivenName + " " + meta.FamilyName); full != "" {
+ return full
+ }
+ }
+ }
+ return "A project administrator"
+}
+
+// roleAssignment pairs a user with the role they were added to.
+type roleAssignment struct {
+ User events.UserInfo
+ Role string
+}
+
+// diffNewMembers returns the users that appear in newSettings but not in oldSettings,
+// across writers, auditors, and meeting_coordinators. Users are matched by Username
+// when present, otherwise by Email. Users with neither Username nor Email are skipped.
+func diffNewMembers(oldSettings, newSettings events.ProjectSettings) []roleAssignment {
+ var additions []roleAssignment
+ additions = append(additions, diffRole(oldSettings.Writers, newSettings.Writers, "Writer")...)
+ additions = append(additions, diffRole(oldSettings.Auditors, newSettings.Auditors, "Auditor")...)
+ additions = append(additions, diffRole(oldSettings.MeetingCoordinators, newSettings.MeetingCoordinators, "Meeting Coordinator")...)
+ return additions
+}
+
+func diffRole(old, new []events.UserInfo, role string) []roleAssignment {
+ // Index every identity key from old so a user matched by either
+ // username or email is recognised regardless of which field was set.
+ oldSet := make(map[string]struct{}, len(old)*2)
+ for _, u := range old {
+ for _, key := range memberKeys(u) {
+ oldSet[key] = struct{}{}
+ }
+ }
+ seenNew := make(map[string]struct{}, len(new)*2)
+ var additions []roleAssignment
+ for _, u := range new {
+ keys := memberKeys(u)
+ if len(keys) == 0 {
+ continue
+ }
+ // Skip if this user was already seen under any of their identity keys,
+ // covering cases where the same person appears with different identity
+ // shapes (e.g. username+email in one entry, email-only in another).
+ alreadySeen := false
+ for _, key := range keys {
+ if _, ok := seenNew[key]; ok {
+ alreadySeen = true
+ break
+ }
+ }
+ if alreadySeen {
+ continue
+ }
+ for _, key := range keys {
+ seenNew[key] = struct{}{}
+ }
+ // The user is already present if ANY of their keys appear in oldSet.
+ present := false
+ for _, key := range keys {
+ if _, ok := oldSet[key]; ok {
+ present = true
+ break
+ }
+ }
+ if !present {
+ additions = append(additions, roleAssignment{User: u, Role: role})
+ }
+ }
+ return additions
+}
+
+// memberKeys returns all stable identity keys for a user.
+// Username key comes first (preferred); Email key is appended when present.
+// Returns an empty slice if neither field is set.
+func memberKeys(u events.UserInfo) []string {
+ var keys []string
+ if u.Username != "" {
+ keys = append(keys, "username:"+u.Username)
+ }
+ if u.Email != "" {
+ keys = append(keys, "email:"+u.Email)
+ }
+ return keys
+}
diff --git a/internal/service/project_subscriber_test.go b/internal/service/project_subscriber_test.go
new file mode 100644
index 0000000..21ce62a
--- /dev/null
+++ b/internal/service/project_subscriber_test.go
@@ -0,0 +1,269 @@
+// Copyright The Linux Foundation and each contributor to LFX.
+// SPDX-License-Identifier: MIT
+
+package service
+
+import (
+ "context"
+ "encoding/json"
+ "testing"
+
+ emailapi "github.com/linuxfoundation/lfx-v2-email-service/pkg/api"
+ "github.com/stretchr/testify/assert"
+ "github.com/stretchr/testify/mock"
+ "github.com/stretchr/testify/require"
+
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/domain"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/domain/models"
+ "github.com/linuxfoundation/lfx-v2-project-service/pkg/events"
+)
+
+func marshalEvent(t *testing.T, v any) []byte {
+ t.Helper()
+ b, err := json.Marshal(v)
+ require.NoError(t, err)
+ return b
+}
+
+func makeProjectBase(uid, name, slug string) *models.ProjectBase {
+ return &models.ProjectBase{UID: uid, Name: name, Slug: slug}
+}
+
+func TestHandleProjectSettingsUpdated(t *testing.T) {
+ alice := events.UserInfo{Username: "alice", Email: "alice@example.com", Name: "Alice"}
+ bob := events.UserInfo{Username: "bob", Email: "bob@example.com", Name: "Bob"}
+
+ tests := []struct {
+ name string
+ event events.ProjectSettingsUpdatedMessage
+ projectBase *models.ProjectBase
+ projectBaseErr error
+ wantSendCount int
+ msgBuilderErr error
+ }{
+ {
+ name: "no additions — no emails sent",
+ event: events.ProjectSettingsUpdatedMessage{
+ ProjectUID: "proj-1",
+ OldSettings: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ NewSettings: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ },
+ // projectBase intentionally nil: handler returns before GetProjectBase when no additions found
+ wantSendCount: 0,
+ },
+ {
+ name: "one writer added — one email sent",
+ event: events.ProjectSettingsUpdatedMessage{
+ ProjectUID: "proj-1",
+ OldSettings: events.ProjectSettings{},
+ NewSettings: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ Actor: events.Actor{Username: "admin", Name: "Admin User"},
+ },
+ projectBase: makeProjectBase("proj-1", "Demo", "demo"),
+ wantSendCount: 1,
+ },
+ {
+ name: "two users added across roles — two emails sent",
+ event: events.ProjectSettingsUpdatedMessage{
+ ProjectUID: "proj-1",
+ OldSettings: events.ProjectSettings{},
+ NewSettings: events.ProjectSettings{
+ Writers: []events.UserInfo{alice},
+ Auditors: []events.UserInfo{bob},
+ },
+ Actor: events.Actor{Username: "admin"},
+ },
+ projectBase: makeProjectBase("proj-1", "Demo", "demo"),
+ wantSendCount: 2,
+ },
+ {
+ name: "send error on one — other still attempted",
+ event: events.ProjectSettingsUpdatedMessage{
+ ProjectUID: "proj-1",
+ OldSettings: events.ProjectSettings{},
+ NewSettings: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ Actor: events.Actor{Username: "admin"},
+ },
+ projectBase: makeProjectBase("proj-1", "Demo", "demo"),
+ wantSendCount: 1,
+ msgBuilderErr: assert.AnError,
+ },
+ {
+ name: "user without email address — skipped, no send",
+ event: events.ProjectSettingsUpdatedMessage{
+ ProjectUID: "proj-1",
+ OldSettings: events.ProjectSettings{},
+ NewSettings: events.ProjectSettings{Writers: []events.UserInfo{{Username: "noemail", Name: "No Email"}}},
+ Actor: events.Actor{Username: "admin"},
+ },
+ projectBase: makeProjectBase("proj-1", "Demo", "demo"),
+ wantSendCount: 0,
+ },
+ {
+ name: "project load failure — no email sent",
+ event: events.ProjectSettingsUpdatedMessage{
+ ProjectUID: "proj-1",
+ OldSettings: events.ProjectSettings{},
+ NewSettings: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ },
+ projectBase: nil,
+ projectBaseErr: assert.AnError,
+ wantSendCount: 0,
+ },
+ }
+
+ for _, tt := range tests {
+ t.Run(tt.name, func(t *testing.T) {
+ mockRepo := &domain.MockProjectRepository{}
+ mockMsg := &domain.MockMessageBuilder{}
+
+ if tt.projectBase != nil || tt.projectBaseErr != nil {
+ mockRepo.On("GetProjectBase", mock.Anything, tt.event.ProjectUID).
+ Return(tt.projectBase, tt.projectBaseErr)
+ }
+
+ if tt.wantSendCount > 0 {
+ mockMsg.On("SendEmailRequest", mock.Anything, mock.AnythingOfType("api.SendEmailRequest")).
+ Return(tt.msgBuilderErr).Times(tt.wantSendCount)
+ }
+
+ svc := &ProjectsService{
+ ProjectRepository: mockRepo,
+ MessageBuilder: mockMsg,
+ Config: ServiceConfig{
+ LFXSelfServeBaseURL: "https://dev.app.lfx.dev",
+ },
+ }
+
+ msg := domain.NewMockMessage(marshalEvent(t, tt.event), "")
+ err := svc.HandleProjectSettingsUpdated(context.Background(), msg)
+ assert.NoError(t, err)
+
+ mockMsg.AssertNumberOfCalls(t, "SendEmailRequest", tt.wantSendCount)
+ mockRepo.AssertExpectations(t)
+ mockMsg.AssertExpectations(t)
+ })
+ }
+
+ t.Run("invalid JSON — returns nil", func(t *testing.T) {
+ svc := &ProjectsService{}
+ msg := domain.NewMockMessage([]byte("not json"), "")
+ err := svc.HandleProjectSettingsUpdated(context.Background(), msg)
+ assert.NoError(t, err)
+ })
+}
+
+func TestDiffNewMembers(t *testing.T) {
+ alice := events.UserInfo{Username: "alice", Email: "alice@example.com", Name: "Alice"}
+ bob := events.UserInfo{Username: "bob", Email: "bob@example.com", Name: "Bob"}
+ noUsername := events.UserInfo{Email: "nouser@example.com", Name: "No Username"}
+ empty := events.UserInfo{}
+
+ tests := []struct {
+ name string
+ old events.ProjectSettings
+ new events.ProjectSettings
+ wantLen int
+ wantContains []roleAssignment
+ }{
+ {
+ name: "no changes",
+ old: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ new: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ },
+ {
+ name: "writer added",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ wantLen: 1,
+ wantContains: []roleAssignment{{User: alice, Role: "Writer"}},
+ },
+ {
+ name: "auditor added",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{Auditors: []events.UserInfo{bob}},
+ wantLen: 1,
+ wantContains: []roleAssignment{{User: bob, Role: "Auditor"}},
+ },
+ {
+ name: "meeting coordinator added",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{MeetingCoordinators: []events.UserInfo{alice}},
+ wantLen: 1,
+ wantContains: []roleAssignment{{User: alice, Role: "Meeting Coordinator"}},
+ },
+ {
+ name: "multiple roles added",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{
+ Writers: []events.UserInfo{alice},
+ Auditors: []events.UserInfo{bob},
+ },
+ wantLen: 2,
+ },
+ {
+ name: "removal only — no additions",
+ old: events.ProjectSettings{Writers: []events.UserInfo{alice, bob}},
+ new: events.ProjectSettings{Writers: []events.UserInfo{alice}},
+ },
+ {
+ name: "user with no username matched by email",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{Writers: []events.UserInfo{noUsername}},
+ wantLen: 1,
+ wantContains: []roleAssignment{{User: noUsername, Role: "Writer"}},
+ },
+ {
+ name: "user with neither username nor email is skipped",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{Writers: []events.UserInfo{empty}},
+ },
+ {
+ name: "existing user with no username skipped in old set",
+ old: events.ProjectSettings{Writers: []events.UserInfo{noUsername}},
+ new: events.ProjectSettings{Writers: []events.UserInfo{noUsername}},
+ },
+ {
+ name: "duplicate entries in new — only one addition returned",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{Writers: []events.UserInfo{alice, alice}},
+ wantLen: 1,
+ wantContains: []roleAssignment{{User: alice, Role: "Writer"}},
+ },
+ {
+ // Same person appears email-only in old, then gains a username in new.
+ // The multi-key lookup must recognise the shared email and not treat them as
+ // a new addition.
+ name: "identity shape change — email-only in old, username+email in new — not a new addition",
+ old: events.ProjectSettings{Writers: []events.UserInfo{{Email: "alice@example.com"}}},
+ new: events.ProjectSettings{Writers: []events.UserInfo{{Username: "alice", Email: "alice@example.com"}}},
+ wantLen: 0,
+ },
+ {
+ // Same person listed twice in new with different identity shapes (username+email,
+ // then email-only). seenNew must index all keys so the second entry is recognised
+ // as a duplicate and only one notification is sent.
+ name: "same person twice in new with different identity shapes — only one addition",
+ old: events.ProjectSettings{},
+ new: events.ProjectSettings{Writers: []events.UserInfo{
+ {Username: "alice", Email: "alice@example.com"},
+ {Email: "alice@example.com"},
+ }},
+ wantLen: 1,
+ wantContains: []roleAssignment{{User: events.UserInfo{Username: "alice", Email: "alice@example.com"}, Role: "Writer"}},
+ },
+ }
+
+ for _, tt := range tests {
+ t.Run(tt.name, func(t *testing.T) {
+ got := diffNewMembers(tt.old, tt.new)
+ assert.Len(t, got, tt.wantLen)
+ for _, want := range tt.wantContains {
+ assert.Contains(t, got, want)
+ }
+ })
+ }
+}
+
+// Compile-time check: emailapi.SendEmailRequest is used to ensure the type alias is correct.
+var _ emailapi.SendEmailRequest
diff --git a/pkg/constants/nats.go b/pkg/constants/nats.go
index b98a355..73fa12e 100644
--- a/pkg/constants/nats.go
+++ b/pkg/constants/nats.go
@@ -84,3 +84,10 @@ const (
// The subject is of the form: lfx.projects-api.get_parent_uid
ProjectGetParentUIDSubject = "lfx.projects-api.get_parent_uid"
)
+
+// NATS subjects for external service lookups.
+const (
+ // AuthUserMetadataReadSubject is the subject for looking up a user's profile metadata by principal.
+ // The subject is of the form: lfx.auth-service.user_metadata.read
+ AuthUserMetadataReadSubject = "lfx.auth-service.user_metadata.read"
+)
diff --git a/pkg/events/project.go b/pkg/events/project.go
new file mode 100644
index 0000000..eabc2a3
--- /dev/null
+++ b/pkg/events/project.go
@@ -0,0 +1,53 @@
+// Copyright The Linux Foundation and each contributor to LFX.
+// SPDX-License-Identifier: MIT
+
+// Package events contains the wire types for NATS events published by the
+// project service. Any struct that appears in a NATS message payload lives
+// here so other services can import the canonical definitions.
+//
+// Convention: if a type is used in a NATS message payload it belongs in
+// pkg/events, not internal/. Internal domain types may differ from event
+// types; explicit converters in internal/service map between them.
+package events
+
+import "time"
+
+// UserInfo is the user representation used in project event payloads.
+type UserInfo struct {
+ Name string `json:"name"`
+ Email string `json:"email"`
+ Username string `json:"username"`
+ Avatar string `json:"avatar"`
+}
+
+// ProjectSettings is the project-settings representation used in event payloads.
+type ProjectSettings struct {
+ UID string `json:"uid"`
+ MissionStatement string `json:"mission_statement"`
+ AnnouncementDate *time.Time `json:"announcement_date"`
+ Auditors []UserInfo `json:"auditors"`
+ Writers []UserInfo `json:"writers"`
+ MeetingCoordinators []UserInfo `json:"meeting_coordinators"`
+ ExecutiveDirector *UserInfo `json:"executive_director,omitempty"`
+ ProgramManager *UserInfo `json:"program_manager,omitempty"`
+ OpportunityOwner *UserInfo `json:"opportunity_owner,omitempty"`
+ CreatedAt *time.Time `json:"created_at"`
+ UpdatedAt *time.Time `json:"updated_at"`
+}
+
+// Actor represents the user who triggered a settings change.
+type Actor struct {
+ Username string `json:"username"`
+ Name string `json:"name"`
+ Email string `json:"email"`
+}
+
+// ProjectSettingsUpdatedMessage is published on
+// lfx.projects-api.project_settings.updated whenever project settings change.
+// It carries both the before and after states so subscribers can diff them.
+type ProjectSettingsUpdatedMessage struct {
+ ProjectUID string `json:"project_uid"`
+ OldSettings ProjectSettings `json:"old_settings"`
+ NewSettings ProjectSettings `json:"new_settings"`
+ Actor Actor `json:"actor"`
+}
diff --git a/scripts/root-project-setup/main.go b/scripts/root-project-setup/main.go
index ab8c589..a35ffc0 100644
--- a/scripts/root-project-setup/main.go
+++ b/scripts/root-project-setup/main.go
@@ -21,8 +21,8 @@ import (
indexerConstants "github.com/linuxfoundation/lfx-v2-indexer-service/pkg/constants"
indexerTypes "github.com/linuxfoundation/lfx-v2-indexer-service/pkg/types"
"github.com/linuxfoundation/lfx-v2-project-service/internal/domain/models"
+ "github.com/linuxfoundation/lfx-v2-project-service/internal/infrastructure/log"
"github.com/linuxfoundation/lfx-v2-project-service/internal/infrastructure/nats"
- "github.com/linuxfoundation/lfx-v2-project-service/internal/log"
"github.com/linuxfoundation/lfx-v2-project-service/pkg/constants"
)
+ 
+
+
+ + +
Hi {{.RecipientName}},
+ +{{.InviterName}} has added you as a {{.Role}} on the {{.ProjectName}} project in LFX Self-Serve.
+You can view the project and manage your responsibilities by visiting the link below.
+ + View Project +If the button above doesn't work, paste this into your browser: {{.ProjectURL}}
+ +Thank you,
The Linux Foundation Team
+ + +