commit 31f06683848498ab82bc0ac8082e1a3bbe044f2e · veryroundbird.house/core

+31
appview/ingester.go
···

       44
       44
        
       			ingestArtifact(&d, e, enforcer)

     

       45
       45
        
       		case tangled.ActorProfileNSID:

     

       46
       46
        
       			ingestProfile(&d, e)

     

       47
       47
       +
       		case tangled.SpindleMemberNSID:

     

       48
       48
       +
       			ingestSpindleMember(&d, e, enforcer)

     

       47
       49
        
       		}

     

       48
       50
        
       

     

       49
       51
        
       		return err

     
···

       285
       287
        
       

     

       286
       288
        
       	return nil

     

       287
       289
        
       }

     

       290
       290
       +
       

     

       291
       291
       +
       func ingestSpindleMember(_ *db.DbWrapper, e *models.Event, enforcer *rbac.Enforcer) error {

     

       292
       292
       +
       	did := e.Did

     

       293
       293
       +
       	var err error

     

       294
       294
       +
       

     

       295
       295
       +
       	switch e.Commit.Operation {

     

       296
       296
       +
       	case models.CommitOperationCreate:

     

       297
       297
       +
       		raw := json.RawMessage(e.Commit.Record)

     

       298
       298
       +
       		record := tangled.SpindleMember{}

     

       299
       299
       +
       		err = json.Unmarshal(raw, &record)

     

       300
       300
       +
       		if err != nil {

     

       301
       301
       +
       			log.Printf("invalid record: %s", err)

     

       302
       302
       +
       			return err

     

       303
       303
       +
       		}

     

       304
       304
       +
       

     

       305
       305
       +
       		// only spindle owner can invite to spindles

     

       306
       306
       +
       		ok, err := enforcer.IsSpindleInviteAllowed(did, record.Instance)

     

       307
       307
       +
       		if err != nil || !ok {

     

       308
       308
       +
       			return fmt.Errorf("failed to enforce permissions: %w", err)

     

       309
       309
       +
       		}

     

       310
       310
       +
       

     

       311
       311
       +
       		err = enforcer.AddSpindleMember(record.Instance, record.Subject)

     

       312
       312
       +
       		if err != nil {

     

       313
       313
       +
       			return fmt.Errorf("failed to add member: %w", err)

     

       314
       314
       +
       		}

     

       315
       315
       +
       	}

     

       316
       316
       +
       

     

       317
       317
       +
       	return nil

     

       318
       318
       +
       }