Skip to content

Commit

Permalink
allow for thread finalisation
Browse files Browse the repository at this point in the history
  • Loading branch information
rusq committed Apr 27, 2023
1 parent f5a1677 commit 3d300ac
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions cmd/slackdump/internal/export/expproc/conversations.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ type Conversations struct {
fileSubproc processor.Filer // files sub-processor
recordFiles bool

onFinalise func(ctx context.Context, channelID string) error
onFinalise func(ctx context.Context, id string) error
}

// ConvOption is a function that configures the Conversations processor.
Expand Down Expand Up @@ -224,8 +224,8 @@ func (cv *Conversations) ThreadMessages(ctx context.Context, channelID string, p
lg.Debugf("processor: decreased ref count for %q to %d", id, refcnt)
if isLast {
trace.Log(ctx, "isLast", "true")
lg.Debugf("processor: isLast=true, finalising thread %s:%s", channelID, parent.ThreadTimestamp)
return cv.finalise(ctx, channelID)
lg.Debugf("processor: isLast=true, finalising thread %s", id)
return cv.finalise(ctx, id)
}
return nil
}
Expand Down

0 comments on commit 3d300ac

Please sign in to comment.