chore: update refs

This commit is contained in:
appflowy 2023-03-15 16:14:36 +08:00
parent 6e028c4f64
commit 1d6f74180f
25 changed files with 63 additions and 58 deletions

View File

@ -9,7 +9,7 @@ import {
DatabaseGroupIdPB, DatabaseGroupIdPB,
MoveGroupPayloadPB, MoveGroupPayloadPB,
MoveGroupRowPayloadPB, MoveGroupRowPayloadPB,
} from '../../../../services/backend/events/flowy-database'; } from '@/services/backend/events/flowy-database';
import { import {
GetFieldPayloadPB, GetFieldPayloadPB,
RepeatedFieldIdPB, RepeatedFieldIdPB,
@ -17,9 +17,10 @@ import {
DatabaseViewIdPB, DatabaseViewIdPB,
CreateRowPayloadPB, CreateRowPayloadPB,
ViewIdPB, ViewIdPB,
} from '../../../../services/backend'; } from '@/services/backend';
import { FolderEventCloseView } from '../../../../services/backend/events/flowy-folder'; import { FolderEventCloseView } from '@/services/backend/events/flowy-folder';
/// A service that wraps the backend service
export class DatabaseBackendService { export class DatabaseBackendService {
viewId: string; viewId: string;
@ -27,6 +28,7 @@ export class DatabaseBackendService {
this.viewId = viewId; this.viewId = viewId;
} }
/// Open a database
openDatabase = async () => { openDatabase = async () => {
const payload = DatabaseViewIdPB.fromObject({ const payload = DatabaseViewIdPB.fromObject({
value: this.viewId, value: this.viewId,
@ -34,6 +36,7 @@ export class DatabaseBackendService {
return DatabaseEventGetDatabase(payload); return DatabaseEventGetDatabase(payload);
}; };
/// Close a database
closeDatabase = async () => { closeDatabase = async () => {
const payload = ViewIdPB.fromObject({ value: this.viewId }); const payload = ViewIdPB.fromObject({ value: this.viewId });
return FolderEventCloseView(payload); return FolderEventCloseView(payload);
@ -56,6 +59,7 @@ export class DatabaseBackendService {
return DatabaseEventCreateRow(payload); return DatabaseEventCreateRow(payload);
}; };
/// Move a row to another group
moveRow = (rowId: string, groupId?: string) => { moveRow = (rowId: string, groupId?: string) => {
const payload = MoveGroupRowPayloadPB.fromObject({ view_id: this.viewId, from_row_id: rowId }); const payload = MoveGroupRowPayloadPB.fromObject({ view_id: this.viewId, from_row_id: rowId });
if (groupId !== undefined) { if (groupId !== undefined) {
@ -73,6 +77,7 @@ export class DatabaseBackendService {
return DatabaseEventMoveGroup(payload); return DatabaseEventMoveGroup(payload);
}; };
/// Get all fields in database
getFields = async (fieldIds?: FieldIdPB[]) => { getFields = async (fieldIds?: FieldIdPB[]) => {
const payload = GetFieldPayloadPB.fromObject({ view_id: this.viewId }); const payload = GetFieldPayloadPB.fromObject({ view_id: this.viewId });
@ -83,11 +88,13 @@ export class DatabaseBackendService {
return DatabaseEventGetFields(payload).then((result) => result.map((value) => value.items)); return DatabaseEventGetFields(payload).then((result) => result.map((value) => value.items));
}; };
/// Get a group by id
getGroup = (groupId: string) => { getGroup = (groupId: string) => {
const payload = DatabaseGroupIdPB.fromObject({ view_id: this.viewId, group_id: groupId }); const payload = DatabaseGroupIdPB.fromObject({ view_id: this.viewId, group_id: groupId });
return DatabaseEventGetGroup(payload); return DatabaseEventGetGroup(payload);
}; };
/// Get all groups in database
loadGroups = () => { loadGroups = () => {
const payload = DatabaseViewIdPB.fromObject({ value: this.viewId }); const payload = DatabaseViewIdPB.fromObject({ value: this.viewId });
return DatabaseEventGetGroups(payload); return DatabaseEventGetGroups(payload);

View File

@ -1,13 +1,13 @@
import { DatabaseBackendService } from './database_bd_svc'; import { DatabaseBackendService } from './database_bd_svc';
import { FieldController, FieldInfo } from './field/field_controller'; import { FieldController, FieldInfo } from './field/field_controller';
import { DatabaseViewCache } from './view/database_view_cache'; import { DatabaseViewCache } from './view/database_view_cache';
import { DatabasePB, GroupPB } from '../../../../services/backend'; import { DatabasePB, GroupPB } from '@/services/backend';
import { RowChangedReason, RowInfo } from './row/row_cache'; import { RowChangedReason, RowInfo } from './row/row_cache';
import { Err } from 'ts-results'; import { Err } from 'ts-results';
import { DatabaseGroupController } from './group/group_controller'; import { DatabaseGroupController } from './group/group_controller';
import { BehaviorSubject } from 'rxjs'; import { BehaviorSubject } from 'rxjs';
import { DatabaseGroupObserver } from './group/group_observer'; import { DatabaseGroupObserver } from './group/group_observer';
import { Log } from '../../../utils/log'; import { Log } from '$app/utils/log';
export type DatabaseSubscriberCallbacks = { export type DatabaseSubscriberCallbacks = {
onViewChanged?: (data: DatabasePB) => void; onViewChanged?: (data: DatabasePB) => void;

View File

@ -5,14 +5,14 @@ import {
FieldType, FieldType,
TypeOptionChangesetPB, TypeOptionChangesetPB,
TypeOptionPathPB, TypeOptionPathPB,
} from '../../../../../services/backend/models/flowy-database/field_entities'; } from '@/services/backend';
import { import {
DatabaseEventDeleteField, DatabaseEventDeleteField,
DatabaseEventDuplicateField, DatabaseEventDuplicateField,
DatabaseEventGetTypeOption, DatabaseEventGetTypeOption,
DatabaseEventUpdateField, DatabaseEventUpdateField,
DatabaseEventUpdateFieldTypeOption, DatabaseEventUpdateFieldTypeOption,
} from '../../../../../services/backend/events/flowy-database'; } from '@/services/backend/events/flowy-database';
export abstract class TypeOptionParser<T> { export abstract class TypeOptionParser<T> {
abstract fromBuffer(buffer: Uint8Array): T; abstract fromBuffer(buffer: Uint8Array): T;

View File

@ -1,8 +1,8 @@
import { Log } from '../../../../utils/log'; import { Log } from '$app/utils/log';
import { DatabaseBackendService } from '../database_bd_svc'; import { DatabaseBackendService } from '../database_bd_svc';
import { DatabaseFieldChangesetObserver } from './field_observer'; import { DatabaseFieldChangesetObserver } from './field_observer';
import { FieldIdPB, FieldPB, IndexFieldPB } from '../../../../../services/backend'; import { FieldIdPB, FieldPB, IndexFieldPB } from '@/services/backend';
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
export class FieldController { export class FieldController {
private backendService: DatabaseBackendService; private backendService: DatabaseBackendService;

View File

@ -1,6 +1,6 @@
import { Ok, Result } from 'ts-results'; import { Ok, Result } from 'ts-results';
import { DatabaseNotification, DatabaseFieldChangesetPB, FlowyError, FieldPB } from '../../../../../services/backend'; import { DatabaseNotification, DatabaseFieldChangesetPB, FlowyError, FieldPB } from '@/services/backend';
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { DatabaseNotificationObserver } from '../notifications/observer'; import { DatabaseNotificationObserver } from '../notifications/observer';
export type FieldChangesetSubscribeCallback = (value: Result<DatabaseFieldChangesetPB, FlowyError>) => void; export type FieldChangesetSubscribeCallback = (value: Result<DatabaseFieldChangesetPB, FlowyError>) => void;

View File

@ -3,12 +3,12 @@ import {
FieldType, FieldType,
TypeOptionPathPB, TypeOptionPathPB,
UpdateFieldTypePayloadPB, UpdateFieldTypePayloadPB,
} from '../../../../../../services/backend'; } from '@/services/backend';
import { import {
DatabaseEventCreateTypeOption, DatabaseEventCreateTypeOption,
DatabaseEventGetTypeOption, DatabaseEventGetTypeOption,
DatabaseEventUpdateFieldType, DatabaseEventUpdateFieldType,
} from '../../../../../../services/backend/events/flowy-database'; } from '@/services/backend/events/flowy-database';
export class TypeOptionBackendService { export class TypeOptionBackendService {
constructor(public readonly viewId: string) {} constructor(public readonly viewId: string) {}

View File

@ -9,7 +9,7 @@ import {
NumberTypeOptionPB, NumberTypeOptionPB,
SingleSelectTypeOptionPB, SingleSelectTypeOptionPB,
URLTypeOptionPB, URLTypeOptionPB,
} from '../../../../../../services/backend'; } from '@/services/backend';
import { utf8Decoder, utf8Encoder } from '../../cell/data_parser'; import { utf8Decoder, utf8Encoder } from '../../cell/data_parser';
import { DatabaseFieldObserver } from '../field_observer'; import { DatabaseFieldObserver } from '../field_observer';

View File

@ -1,7 +1,7 @@
import { FieldPB, FieldType, TypeOptionPB } from '../../../../../../services/backend'; import { FieldPB, FieldType, TypeOptionPB } from '@/services/backend';
import { ChangeNotifier } from '../../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { FieldBackendService } from '../field_bd_svc'; import { FieldBackendService } from '../field_bd_svc';
import { Log } from '../../../../../utils/log'; import { Log } from '$app/utils/log';
import { None, Option, Some } from 'ts-results'; import { None, Option, Some } from 'ts-results';
import { FieldInfo } from '../field_controller'; import { FieldInfo } from '../field_controller';
import { TypeOptionBackendService } from './type_option_bd_svc'; import { TypeOptionBackendService } from './type_option_bd_svc';

View File

@ -4,11 +4,11 @@ import {
GroupPB, GroupPB,
GroupRowsNotificationPB, GroupRowsNotificationPB,
RowPB, RowPB,
} from '../../../../../services/backend'; } from '@/services/backend';
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { None, Ok, Option, Result, Some } from 'ts-results'; import { None, Ok, Option, Result, Some } from 'ts-results';
import { DatabaseNotificationObserver } from '../notifications/observer'; import { DatabaseNotificationObserver } from '../notifications/observer';
import { Log } from '../../../../utils/log'; import { Log } from '$app/utils/log';
import { DatabaseBackendService } from '../database_bd_svc'; import { DatabaseBackendService } from '../database_bd_svc';
export type GroupDataCallbacks = { export type GroupDataCallbacks = {

View File

@ -1,6 +1,6 @@
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { Ok, Result } from 'ts-results'; import { Ok, Result } from 'ts-results';
import { DatabaseNotification, FlowyError, GroupChangesetPB, GroupPB } from '../../../../../services/backend'; import { DatabaseNotification, FlowyError, GroupChangesetPB, GroupPB } from '@/services/backend';
import { DatabaseNotificationObserver } from '../notifications/observer'; import { DatabaseNotificationObserver } from '../notifications/observer';
export type GroupByFieldCallback = (value: Result<GroupPB[], FlowyError>) => void; export type GroupByFieldCallback = (value: Result<GroupPB[], FlowyError>) => void;

View File

@ -1,5 +1,5 @@
import { DatabaseNotification, FlowyError } from '../../../../../services/backend'; import { DatabaseNotification, FlowyError } from '@/services/backend';
import { AFNotificationObserver } from '../../../../../services/backend/notifications'; import { AFNotificationObserver } from '@/services/backend/notifications';
import { DatabaseNotificationParser } from './parser'; import { DatabaseNotificationParser } from './parser';
import { Result } from 'ts-results'; import { Result } from 'ts-results';

View File

@ -1,5 +1,5 @@
import { DatabaseNotification, FlowyError } from '../../../../../services/backend'; import { DatabaseNotification, FlowyError } from '@/services/backend';
import { NotificationParser } from '../../../../../services/backend/notifications'; import { NotificationParser } from '@/services/backend/notifications';
import { Result } from 'ts-results'; import { Result } from 'ts-results';
declare type DatabaseNotificationCallback = (ty: DatabaseNotification, payload: Result<Uint8Array, FlowyError>) => void; declare type DatabaseNotificationCallback = (ty: DatabaseNotification, payload: Result<Uint8Array, FlowyError>) => void;

View File

@ -1,10 +1,10 @@
import { CreateRowPayloadPB, RowIdPB } from '../../../../../services/backend'; import { CreateRowPayloadPB, RowIdPB } from '@/services/backend';
import { import {
DatabaseEventCreateRow, DatabaseEventCreateRow,
DatabaseEventDeleteRow, DatabaseEventDeleteRow,
DatabaseEventDuplicateRow, DatabaseEventDuplicateRow,
DatabaseEventGetRow, DatabaseEventGetRow,
} from '../../../../../services/backend/events/flowy-database'; } from '@/services/backend/events/flowy-database';
export class RowBackendService { export class RowBackendService {
constructor(public readonly viewId: string) {} constructor(public readonly viewId: string) {}

View File

@ -7,14 +7,14 @@ import {
RowsChangesetPB, RowsChangesetPB,
RowsVisibilityChangesetPB, RowsVisibilityChangesetPB,
ReorderSingleRowPB, ReorderSingleRowPB,
} from '../../../../../services/backend'; } from '@/services/backend';
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { FieldInfo } from '../field/field_controller'; import { FieldInfo } from '../field/field_controller';
import { CellCache, CellCacheKey } from '../cell/cell_cache'; import { CellCache, CellCacheKey } from '../cell/cell_cache';
import { CellIdentifier } from '../cell/cell_bd_svc'; import { CellIdentifier } from '../cell/cell_bd_svc';
import { DatabaseEventGetRow } from '../../../../../services/backend/events/flowy-database'; import { DatabaseEventGetRow } from '@/services/backend/events/flowy-database';
import { None, Option, Some } from 'ts-results'; import { None, Option, Some } from 'ts-results';
import { Log } from '../../../../utils/log'; import { Log } from '$app/utils/log';
export type CellByFieldId = Map<string, CellIdentifier>; export type CellByFieldId = Map<string, CellIdentifier>;

View File

@ -1,8 +1,7 @@
import { DatabaseViewRowsObserver } from './view_row_observer'; import { DatabaseViewRowsObserver } from './view_row_observer';
import { RowCache, RowInfo } from '../row/row_cache'; import { RowCache, RowInfo } from '../row/row_cache';
import { FieldController } from '../field/field_controller'; import { FieldController } from '../field/field_controller';
import { RowPB } from '../../../../../services/backend'; import { RowPB } from '@/services/backend';
import { Subscription } from 'rxjs';
export class DatabaseViewCache { export class DatabaseViewCache {
private readonly rowsObserver: DatabaseViewRowsObserver; private readonly rowsObserver: DatabaseViewRowsObserver;

View File

@ -5,10 +5,10 @@ import {
FlowyError, FlowyError,
OpenDocumentPayloadPB, OpenDocumentPayloadPB,
ViewIdPB, ViewIdPB,
} from '../../../../services/backend'; } from '@/services/backend';
import { DocumentEventApplyEdit, DocumentEventGetDocument } from '../../../../services/backend/events/flowy-document'; import { DocumentEventApplyEdit, DocumentEventGetDocument } from '@/services/backend/events/flowy-document';
import { Result } from 'ts-results'; import { Result } from 'ts-results';
import { FolderEventCloseView } from '../../../../services/backend/events/flowy-folder'; import { FolderEventCloseView } from '@/services/backend/events/flowy-folder';
export class DocumentBackendService { export class DocumentBackendService {
constructor(public readonly viewId: string) {} constructor(public readonly viewId: string) {}

View File

@ -6,7 +6,7 @@ import {
FolderEventReadApp, FolderEventReadApp,
FolderEventUpdateApp, FolderEventUpdateApp,
ViewLayoutTypePB, ViewLayoutTypePB,
} from '../../../../../services/backend/events/flowy-folder'; } from '@/services/backend/events/flowy-folder';
import { import {
AppIdPB, AppIdPB,
UpdateAppPayloadPB, UpdateAppPayloadPB,
@ -16,7 +16,7 @@ import {
MoveFolderItemPayloadPB, MoveFolderItemPayloadPB,
MoveFolderItemType, MoveFolderItemType,
FlowyError, FlowyError,
} from '../../../../../services/backend'; } from '@/services/backend';
import { None, Result, Some } from 'ts-results'; import { None, Result, Some } from 'ts-results';
export class AppBackendService { export class AppBackendService {

View File

@ -1,6 +1,6 @@
import { Ok, Result } from 'ts-results'; import { Ok, Result } from 'ts-results';
import { AppPB, FlowyError, FolderNotification } from '../../../../../services/backend'; import { AppPB, FlowyError, FolderNotification } from '@/services/backend';
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { FolderNotificationObserver } from '../notifications/observer'; import { FolderNotificationObserver } from '../notifications/observer';
export type AppUpdateNotifyCallback = (value: Result<AppPB, FlowyError>) => void; export type AppUpdateNotifyCallback = (value: Result<AppPB, FlowyError>) => void;

View File

@ -1,6 +1,6 @@
import { OnNotificationError, AFNotificationObserver } from '../../../../../services/backend/notifications'; import { OnNotificationError, AFNotificationObserver } from '@/services/backend/notifications';
import { FolderNotificationParser } from './parser'; import { FolderNotificationParser } from './parser';
import { FlowyError, FolderNotification } from '../../../../../services/backend'; import { FlowyError, FolderNotification } from '@/services/backend';
import { Result } from 'ts-results'; import { Result } from 'ts-results';
export type ParserHandler = (notification: FolderNotification, payload: Result<Uint8Array, FlowyError>) => void; export type ParserHandler = (notification: FolderNotification, payload: Result<Uint8Array, FlowyError>) => void;

View File

@ -1,5 +1,5 @@
import { NotificationParser, OnNotificationError } from '../../../../../services/backend/notifications'; import { NotificationParser, OnNotificationError } from '@/services/backend/notifications';
import { FlowyError, FolderNotification } from '../../../../../services/backend'; import { FlowyError, FolderNotification } from '@/services/backend';
import { Result } from 'ts-results'; import { Result } from 'ts-results';
declare type FolderNotificationCallback = (ty: FolderNotification, payload: Result<Uint8Array, FlowyError>) => void; declare type FolderNotificationCallback = (ty: FolderNotification, payload: Result<Uint8Array, FlowyError>) => void;

View File

@ -1,9 +1,9 @@
import { UpdateViewPayloadPB, RepeatedViewIdPB, ViewPB } from '../../../../../services/backend/models/flowy-folder/view'; import { UpdateViewPayloadPB, RepeatedViewIdPB, ViewPB } from '@/services/backend';
import { import {
FolderEventDeleteView, FolderEventDeleteView,
FolderEventDuplicateView, FolderEventDuplicateView,
FolderEventUpdateView, FolderEventUpdateView,
} from '../../../../../services/backend/events/flowy-folder'; } from '@/services/backend/events/flowy-folder';
export class ViewBackendService { export class ViewBackendService {
constructor(public readonly viewId: string) {} constructor(public readonly viewId: string) {}

View File

@ -1,7 +1,6 @@
import { Ok, Result } from 'ts-results'; import { Ok, Result } from 'ts-results';
import { FlowyError } from '../../../../../services/backend/models/flowy-error/errors'; import { DeletedViewPB, FolderNotification, ViewPB, FlowyError } from '@/services/backend';
import { DeletedViewPB, FolderNotification, ViewPB } from '../../../../../services/backend/models/flowy-folder'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { ChangeNotifier } from '../../../../utils/change_notifier';
import { FolderNotificationObserver } from '../notifications/observer'; import { FolderNotificationObserver } from '../notifications/observer';
type DeleteViewNotifyValue = Result<ViewPB, FlowyError>; type DeleteViewNotifyValue = Result<ViewPB, FlowyError>;

View File

@ -4,8 +4,8 @@ import {
FolderEventMoveItem, FolderEventMoveItem,
FolderEventReadWorkspaceApps, FolderEventReadWorkspaceApps,
FolderEventReadWorkspaces, FolderEventReadWorkspaces,
} from '../../../../../services/backend/events/flowy-folder'; } from '@/services/backend/events/flowy-folder';
import { CreateAppPayloadPB, WorkspaceIdPB, FlowyError, MoveFolderItemPayloadPB } from '../../../../../services/backend'; import { CreateAppPayloadPB, WorkspaceIdPB, FlowyError, MoveFolderItemPayloadPB } from '@/services/backend';
import assert from 'assert'; import assert from 'assert';
export class WorkspaceBackendService { export class WorkspaceBackendService {

View File

@ -1,6 +1,6 @@
import { Ok, Result } from 'ts-results'; import { Ok, Result } from 'ts-results';
import { AppPB, FolderNotification, RepeatedAppPB, WorkspacePB, FlowyError } from '../../../../../services/backend'; import { AppPB, FolderNotification, RepeatedAppPB, WorkspacePB, FlowyError } from '@/services/backend';
import { ChangeNotifier } from '../../../../utils/change_notifier'; import { ChangeNotifier } from '$app/utils/change_notifier';
import { FolderNotificationObserver } from '../notifications/observer'; import { FolderNotificationObserver } from '../notifications/observer';
export type AppListNotifyValue = Result<AppPB[], FlowyError>; export type AppListNotifyValue = Result<AppPB[], FlowyError>;

View File

@ -6,7 +6,7 @@ import {
UserEventSignOut, UserEventSignOut,
UserEventSignUp, UserEventSignUp,
UserEventUpdateUserProfile, UserEventUpdateUserProfile,
} from '../../../../services/backend/events/flowy-user'; } from '@/services/backend/events/flowy-user';
import { import {
SignInPayloadPB, SignInPayloadPB,
SignUpPayloadPB, SignUpPayloadPB,
@ -15,13 +15,13 @@ import {
CreateWorkspacePayloadPB, CreateWorkspacePayloadPB,
WorkspaceSettingPB, WorkspaceSettingPB,
WorkspacePB, WorkspacePB,
} from '../../../../services/backend'; } from '@/services/backend';
import { import {
FolderEventCreateWorkspace, FolderEventCreateWorkspace,
FolderEventOpenWorkspace, FolderEventOpenWorkspace,
FolderEventReadCurrentWorkspace, FolderEventReadCurrentWorkspace,
FolderEventReadWorkspaces, FolderEventReadWorkspaces,
} from '../../../../services/backend/events/flowy-folder'; } from '@/services/backend/events/flowy-folder';
export class UserBackendService { export class UserBackendService {
constructor(public readonly userId: string) {} constructor(public readonly userId: string) {}