mergeSource copies all data from src into a new session in the target database. Files and avatars are copied when the corresponding flags are true an

mkThreadSetupFn creates a utility function that sets up the thread messages. It accepts the channelID that will be populated on the chunks, and the ar

next tries to get the next chunk for the given id. It returns io.EOF if there are no more chunks for the given id.

source returns the current source under a read-lock. Returns nil when no source has been loaded.

userkey should return the user key columns. User key is the key that uniquely identifies the logical entity, and is usually a part of primary key, ex

Close mocks base method.

ConvertMsgs converts a slice of slack.Message to []types.Message.

Copy iterates through the files in the message and copies them to the target directory. Source file location is determined by calling the srcFileLoc

CountUnfinished returns the number of unfinished threads in a channel.

Destroy closes all open file handles and removes the temporary directory.

EXPECT returns an object that allows the caller to indicate expected use.

ExistsErr checks if the workspace exists, and returns any errors that may occur.

Finish closes the controller and finalises the underlying encoder after a successful run.

Finish finalises the session, marking it as finished.

HeaderValue mocks base method.

IfTrue returns second argument if the condition is true, otherwise, returns the third one. Same as C's ternary condition operator: cond ? t : f;

IndexByID returns the userID map to relevant *slack.User

IsClientToken returns true if the tok is a web-client token.

IsEmptyThread checks if the message is a thread with no replies.

NVLTime returns the default time if the given time is zero.

New creates a new file processor that uses mattermost file naming pattern.

NewCustomRecorder creates a new recorder with a custom encoder.

NewMockEncodeReferenceFinisher creates a new mock instance.

NewMockMessageRepository creates a new mock instance.

NewMockUsers creates a new mock instance.

NewMockdatahandler creates a new mock instance.

SetBaseFlags sets base flags

Start starts an async file downloader. If the downloader is already started, it does nothing.

WithContext returns context with auth provider.

WithCoordinator configures the controller with a transformer.

WithLogger sets the logger used by the server. A nil value is silently ignored (the default logger is used in that case).

WithUsers allows to pass a list of users to the transform.

apply applies the pipeline functions in order.

channels returns the channels in the underlying source. It returns ErrNoChannels if there are zero channels.

checkArchives verifies that all sources belong to the same workspace as the target. If a workspace ID cannot be determined for a source, a warning is

closeSources closes any source that implements io.Closer, logging errors as warnings.

content generates n numbered lines.

errRateFnFn will return slack.RateLimitedError for numAttempts time and err after.

indexChunks indexes the records in the reader and returns an index.

initDB runs the initialisation commands on the database.

isInvalid returns true if the provided path component is not web-safe.

newDirProc initialises the new directory processor which wraps the file recorder. It creates a new chunk file in a directory cd. Directory cd must ex

saveCreds encrypts and saves the credentials.