diff --git a/pkg/connector/backfill.go b/pkg/connector/backfill.go index fa572ff..1c82dec 100644 --- a/pkg/connector/backfill.go +++ b/pkg/connector/backfill.go @@ -126,6 +126,9 @@ func (m *MetaClient) handleUpdateExistingMessageRange(tk handlerParams, rng *tab } func (m *MetaClient) requestMoreHistory(ctx context.Context, threadID, minTimestampMS int64, minMessageID string) bool { + if m.Client == nil || m.Client.SyncManager == nil { + return false + } resp, err := m.Client.ExecuteTasks(&socket.FetchMessagesTask{ ThreadKey: threadID, Direction: 0,