HandleActivity handle activity message
(ctx context.Context, msg *schema.ActivityMsg)
| 67 | |
| 68 | // HandleActivity handle activity message |
| 69 | func (ac *ActivityCommon) HandleActivity(ctx context.Context, msg *schema.ActivityMsg) error { |
| 70 | activityType, err := ac.activityRepo.GetActivityTypeByConfigKey(ctx, string(msg.ActivityTypeKey)) |
| 71 | if err != nil { |
| 72 | log.Errorf("error getting activity type %s, activity type is %d", err, activityType) |
| 73 | return err |
| 74 | } |
| 75 | |
| 76 | act := &entity.Activity{ |
| 77 | UserID: msg.UserID, |
| 78 | TriggerUserID: msg.TriggerUserID, |
| 79 | ObjectID: uid.DeShortID(msg.ObjectID), |
| 80 | OriginalObjectID: uid.DeShortID(msg.OriginalObjectID), |
| 81 | ActivityType: activityType, |
| 82 | Cancelled: entity.ActivityAvailable, |
| 83 | } |
| 84 | if len(msg.RevisionID) > 0 { |
| 85 | act.RevisionID = converter.StringToInt64(msg.RevisionID) |
| 86 | } |
| 87 | if err := ac.activityRepo.AddActivity(ctx, act); err != nil { |
| 88 | return err |
| 89 | } |
| 90 | return nil |
| 91 | } |
nothing calls this directly
no test coverage detected