feat: send email notifications for network invites

Closes #126
This commit is contained in:
talksik
2026-04-12 10:45:24 -07:00
parent bfa970d706
commit e58edaddd3
8 changed files with 246 additions and 26 deletions
+8 -8
View File
@@ -33,7 +33,7 @@ func getStreamStatus(data json.RawMessage) string {
func TestParticleService_CreateAndGet(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network first
@@ -72,7 +72,7 @@ func TestParticleService_CreateAndGet(t *testing.T) {
func TestParticleService_NestedParticles(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network
@@ -118,7 +118,7 @@ func TestParticleService_NestedParticles(t *testing.T) {
func TestParticleService_CustomVisibility(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network with a member
@@ -160,7 +160,7 @@ func TestParticleService_CustomVisibility(t *testing.T) {
func TestParticleService_UpdateAndDelete(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network
@@ -198,7 +198,7 @@ func TestParticleService_UpdateAndDelete(t *testing.T) {
func TestParticleService_ListRootParticles(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network
@@ -224,7 +224,7 @@ func TestParticleService_ListRootParticles(t *testing.T) {
func TestParticleService_OpenCloseStream(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network
@@ -272,7 +272,7 @@ func TestParticleService_OpenCloseStream(t *testing.T) {
func TestParticleService_NotAStream(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network
@@ -301,7 +301,7 @@ func TestParticleService_NotAStream(t *testing.T) {
func TestParticleService_AccessInheritance(t *testing.T) {
ctx := context.Background()
networkSvc := network.NewService(dbPool)
networkSvc := network.NewService(dbPool, nil)
svc := particle.NewService(dbPool, networkSvc)
// Create a network with members