diff --git a/cmd/app/handler/slack_handler.go b/cmd/app/handler/slack_handler.go index 87daa42..9d5145d 100644 --- a/cmd/app/handler/slack_handler.go +++ b/cmd/app/handler/slack_handler.go @@ -2,6 +2,7 @@ package handler import ( "encoding/json" + "fmt" "houston/appcontext" "houston/common/metrics" "houston/common/util" @@ -158,6 +159,7 @@ func (sh *slackHandler) HoustonConnect() { switch innerEvent.Type { case util.UserChangeEvent: + logger.Info(fmt.Sprintf("received user change event: %v", evt.Data)) sh.userChangeEventProcessor.ProcessCommand(ev, evt.Request) case util.ChannelUnarchiveEvent: sh.channelUnarchivalEventProcessor.ProcessCommand( diff --git a/internal/processor/action/user_change_event_action.go b/internal/processor/action/user_change_event_action.go index 1b2e9c6..314629d 100644 --- a/internal/processor/action/user_change_event_action.go +++ b/internal/processor/action/user_change_event_action.go @@ -33,6 +33,8 @@ func (userChangeEventAction *UserChangeEventAction) PerformAction(event slackeve logger.Error("error occurred while deserializing the event object", zap.Any("error", unmarshalError), zap.String("event", string(serializedEventJson))) return } + + logger.Info(fmt.Sprintf("received user change event: %v", userChangeEventRequest)) // If User is not part of Navi Workspace Team, then we don't need to process the event if userChangeEventRequest.User.Profile.TeamName != viper.GetString("slack.workspace.id") { return diff --git a/service/user/upsert_users.go b/service/user/upsert_users.go index 43ee17b..6ed6918 100644 --- a/service/user/upsert_users.go +++ b/service/user/upsert_users.go @@ -45,6 +45,7 @@ func (service *userServiceImpl) processUsersMapsToUpsert(slackIdToUserDataMap, s usersToInsert = append(usersToInsert, slackUser) } else { dbUser := slackIdToHoustonUserDataMap[id] + logger.Info(fmt.Sprintf("%s found user %s in houston to update with cron", upsertUsersLogTag, slackUser.Email)) updatedUser, needsUpdate := dbUser.Update(slackUser) if needsUpdate { logger.Info(fmt.Sprintf("%s user %s needs update", upsertUsersLogTag, updatedUser.Name))