forked from Ivasoft/mattermost-mobile
* Remove watermelondb limitation on updating an already updated model * Add logic to handle different prepare states and improve logging * fix tests --------- Co-authored-by: Elias Nahum <nahumhbl@gmail.com>
319 lines
7.0 KiB
TypeScript
319 lines
7.0 KiB
TypeScript
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
/* eslint-disable max-lines */
|
|
|
|
import type {DatabaseType} from '@constants/database';
|
|
import type AppDataOperator from '@database/operator/app_data_operator';
|
|
import type ServerDataOperator from '@database/operator/server_data_operator';
|
|
import type {Database} from '@nozbe/watermelondb';
|
|
import type Model from '@nozbe/watermelondb/Model';
|
|
import type {Clause} from '@nozbe/watermelondb/QueryDescription';
|
|
import type {Class} from '@nozbe/watermelondb/types';
|
|
import type System from '@typings/database/models/servers/system';
|
|
|
|
export type WithDatabaseArgs = { database: Database }
|
|
|
|
export type CreateServerDatabaseConfig = {
|
|
dbName: string;
|
|
dbType?: DatabaseType;
|
|
displayName?: string;
|
|
serverUrl?: string;
|
|
identifier?: string;
|
|
};
|
|
|
|
export type RegisterServerDatabaseArgs = {
|
|
databaseFilePath: string;
|
|
displayName: string;
|
|
serverUrl: string;
|
|
identifier?: string;
|
|
};
|
|
|
|
export type AppDatabase = {
|
|
database: Database;
|
|
operator: AppDataOperator;
|
|
};
|
|
|
|
export type ServerDatabase = {
|
|
database: Database;
|
|
operator: ServerDataOperator;
|
|
}
|
|
|
|
export type ServerDatabases = {
|
|
[x: string]: ServerDatabase | undefined;
|
|
};
|
|
|
|
export type TransformerArgs = {
|
|
action: string;
|
|
database: Database;
|
|
fieldsMapper?: (model: Model) => void;
|
|
tableName?: string;
|
|
value: RecordPair;
|
|
};
|
|
|
|
export type PrepareBaseRecordArgs = TransformerArgs & {
|
|
fieldsMapper: (model: Model) => void;
|
|
}
|
|
|
|
export type OperationArgs<T extends Model> = {
|
|
tableName: string;
|
|
createRaws?: RecordPair[];
|
|
updateRaws?: RecordPair[];
|
|
deleteRaws?: T[];
|
|
transformer: (args: TransformerArgs) => Promise<T>;
|
|
};
|
|
|
|
export type Models = Array<Class<Model>>;
|
|
|
|
// The elements needed to create a new database
|
|
export type CreateServerDatabaseArgs = {
|
|
config: CreateServerDatabaseConfig;
|
|
shouldAddToAppDatabase?: boolean;
|
|
};
|
|
|
|
export type HandleReactionsArgs = {
|
|
prepareRecordsOnly: boolean;
|
|
postsReactions?: ReactionsPerPost[];
|
|
skipSync?: boolean;
|
|
};
|
|
|
|
export type HandleFilesArgs = {
|
|
files?: FileInfo[];
|
|
prepareRecordsOnly: boolean;
|
|
};
|
|
|
|
export type HandlePostsArgs = {
|
|
actionType: string;
|
|
order?: string[];
|
|
previousPostId?: string;
|
|
posts?: Post[];
|
|
prepareRecordsOnly?: boolean;
|
|
};
|
|
|
|
export type HandleThreadsArgs = {
|
|
threads?: ThreadWithLastFetchedAt[];
|
|
prepareRecordsOnly?: boolean;
|
|
teamId?: string;
|
|
};
|
|
|
|
export type HandleThreadParticipantsArgs = {
|
|
prepareRecordsOnly: boolean;
|
|
skipSync?: boolean;
|
|
threadsParticipants: ParticipantsPerThread[];
|
|
};
|
|
|
|
export type HandleThreadInTeamArgs = {
|
|
threadsMap?: Record<string, Thread[]>;
|
|
prepareRecordsOnly?: boolean;
|
|
};
|
|
|
|
export type HandleTeamThreadsSyncArgs = {
|
|
data: TeamThreadsSync[];
|
|
prepareRecordsOnly?: boolean;
|
|
};
|
|
|
|
export type SanitizeReactionsArgs = {
|
|
database: Database;
|
|
post_id: string;
|
|
rawReactions: Reaction[];
|
|
skipSync?: boolean;
|
|
};
|
|
|
|
export type SanitizeThreadParticipantsArgs = {
|
|
database: Database;
|
|
skipSync?: boolean;
|
|
thread_id: $ID<Thread>;
|
|
rawParticipants: ThreadParticipant[];
|
|
}
|
|
|
|
export type ChainPostsArgs = {
|
|
order?: string[];
|
|
previousPostId: string;
|
|
posts: Post[];
|
|
};
|
|
|
|
export type SanitizePostsArgs = {
|
|
orders: string[];
|
|
posts: Post[];
|
|
};
|
|
|
|
export type IdenticalRecordArgs = {
|
|
existingRecord: Model;
|
|
newValue: RawValue;
|
|
tableName: string;
|
|
};
|
|
|
|
export type RetrieveRecordsArgs = {
|
|
database: Database;
|
|
tableName: string;
|
|
condition: Clause;
|
|
};
|
|
|
|
export type ProcessRecordsArgs = {
|
|
createOrUpdateRawValues: RawValue[];
|
|
deleteRawValues: RawValue[];
|
|
tableName: string;
|
|
fieldName: string;
|
|
buildKeyRecordBy?: (obj: Record<string, any>) => string;
|
|
};
|
|
|
|
export type HandleRecordsArgs<T extends Model> = {
|
|
buildKeyRecordBy?: (obj: Record<string, any>) => string;
|
|
fieldName: string;
|
|
transformer: (args: TransformerArgs) => Promise<T>;
|
|
createOrUpdateRawValues: RawValue[];
|
|
deleteRawValues?: RawValue[];
|
|
tableName: string;
|
|
prepareRecordsOnly: boolean;
|
|
};
|
|
|
|
export type RangeOfValueArgs = {
|
|
raws: RawValue[];
|
|
fieldName: string;
|
|
};
|
|
|
|
export type RecordPair = {
|
|
record?: Model;
|
|
raw: RawValue;
|
|
};
|
|
|
|
type PrepareOnly = {
|
|
prepareRecordsOnly: boolean;
|
|
}
|
|
|
|
export type HandleInfoArgs = PrepareOnly & {
|
|
info?: AppInfo[];
|
|
}
|
|
|
|
export type HandleGlobalArgs = PrepareOnly & {
|
|
globals?: IdValue[];
|
|
}
|
|
|
|
export type HandleRoleArgs = PrepareOnly & {
|
|
roles?: Role[];
|
|
}
|
|
|
|
export type HandleCustomEmojiArgs = PrepareOnly & {
|
|
emojis?: CustomEmoji[];
|
|
}
|
|
|
|
export type HandleSystemArgs = PrepareOnly & {
|
|
systems?: IdValue[];
|
|
}
|
|
|
|
export type HandleConfigArgs = PrepareOnly & {
|
|
configs: IdValue[];
|
|
configsToDelete: IdValue[];
|
|
}
|
|
|
|
export type HandleMyChannelArgs = PrepareOnly & {
|
|
channels?: Channel[];
|
|
myChannels?: ChannelMembership[];
|
|
isCRTEnabled?: boolean;
|
|
};
|
|
|
|
export type HandleChannelInfoArgs = PrepareOnly &{
|
|
channelInfos?: Array<Partial<ChannelInfo>>;
|
|
};
|
|
|
|
export type HandleMyChannelSettingsArgs = PrepareOnly & {
|
|
settings?: ChannelMembership[];
|
|
};
|
|
|
|
export type HandleChannelArgs = PrepareOnly & {
|
|
channels?: Channel[];
|
|
};
|
|
|
|
export type HandleCategoryArgs = PrepareOnly & {
|
|
categories?: Category[];
|
|
};
|
|
|
|
export type HandleGroupArgs = PrepareOnly & {
|
|
groups?: Group[];
|
|
};
|
|
|
|
export type HandleGroupChannelsForChannelArgs = PrepareOnly & {
|
|
channelId: string;
|
|
groups?: Array<Pick<Group, 'id'>>;
|
|
}
|
|
|
|
export type HandleGroupMembershipForMemberArgs = PrepareOnly & {
|
|
userId: string;
|
|
groups?: Array<Pick<Group, 'id'>>;
|
|
}
|
|
|
|
export type HandleGroupTeamsForTeamArgs = PrepareOnly & {
|
|
teamId: string;
|
|
groups?: Array<Pick<Group, 'id'>>;
|
|
}
|
|
|
|
export type HandleCategoryChannelArgs = PrepareOnly & {
|
|
categoryChannels?: CategoryChannel[];
|
|
};
|
|
|
|
export type HandleMyTeamArgs = PrepareOnly & {
|
|
myTeams?: MyTeam[];
|
|
};
|
|
|
|
export type HandleTeamSearchHistoryArgs = PrepareOnly &{
|
|
teamSearchHistories?: TeamSearchHistory[];
|
|
};
|
|
|
|
export type HandleTeamChannelHistoryArgs = PrepareOnly & {
|
|
teamChannelHistories?: TeamChannelHistory[];
|
|
};
|
|
|
|
export type HandleTeamArgs = PrepareOnly & {
|
|
teams?: Team[];
|
|
};
|
|
|
|
export type HandleChannelMembershipArgs = PrepareOnly & {
|
|
channelMemberships?: Array<Pick<ChannelMembership, 'user_id' | 'channel_id' | 'scheme_admin'>>;
|
|
};
|
|
|
|
export type HandleTeamMembershipArgs = PrepareOnly & {
|
|
teamMemberships?: TeamMembership[];
|
|
};
|
|
|
|
export type HandlePreferencesArgs = PrepareOnly & {
|
|
preferences?: PreferenceType[];
|
|
sync?: boolean;
|
|
};
|
|
|
|
export type HandleUsersArgs = PrepareOnly & {
|
|
users?: UserProfile[];
|
|
};
|
|
|
|
export type HandleDraftArgs = PrepareOnly & {
|
|
drafts?: Draft[];
|
|
};
|
|
|
|
export type LoginArgs = {
|
|
config: Partial<ClientConfig>;
|
|
ldapOnly?: boolean;
|
|
license: Partial<ClientLicense>;
|
|
loginId: string;
|
|
mfaToken?: string;
|
|
password: string;
|
|
serverDisplayName: string;
|
|
};
|
|
|
|
export type ServerUrlChangedArgs = {
|
|
configRecord: System;
|
|
licenseRecord: System;
|
|
selectServerRecord: System;
|
|
serverUrl: string;
|
|
};
|
|
|
|
export type GetDatabaseConnectionArgs = {
|
|
serverUrl: string;
|
|
connectionName?: string;
|
|
setAsActiveDatabase: boolean;
|
|
}
|
|
|
|
export type ProcessRecordResults<T extends Model> = {
|
|
createRaws: RecordPair[];
|
|
updateRaws: RecordPair[];
|
|
deleteRaws: T[];
|
|
}
|