fix: types of data center call

This commit is contained in:
DarkSky
2023-01-03 13:32:03 +08:00
committed by DarkSky
parent b105eaf9a6
commit 0110efc340
18 changed files with 111 additions and 120 deletions

View File

@@ -4,7 +4,7 @@ import { Modal, ModalWrapper, ModalCloseButton } from '@/ui/modal';
import { Button } from '@/ui/button'; import { Button } from '@/ui/button';
import Input from '@/ui/input'; import Input from '@/ui/input';
import { useState } from 'react'; import { useState } from 'react';
import { inviteMember, getUserByEmail } from '@affine/datacenter'; import { getDataCenter } from '@affine/datacenter';
import { Avatar } from '@mui/material'; import { Avatar } from '@mui/material';
interface LoginModalProps { interface LoginModalProps {
open: boolean; open: boolean;
@@ -60,15 +60,19 @@ export const InviteMembers = ({
setShowTip(false); setShowTip(false);
debounce( debounce(
() => { () => {
getUserByEmail({ getDataCenter()
email: value, .then(dc =>
workspace_id: workspaceId, dc.apis.getUserByEmail({
}).then(data => { email: value,
if (data?.name) { workspace_id: workspaceId,
setUserData(data); })
setShowTip(false); )
} .then(data => {
}); if (data?.name) {
setUserData(data);
setShowTip(false);
}
});
}, },
300, 300,
true true
@@ -130,7 +134,8 @@ export const InviteMembers = ({
shape="circle" shape="circle"
type="primary" type="primary"
onClick={() => { onClick={() => {
inviteMember({ id: workspaceId, email: email }) getDataCenter()
.then(dc => dc.apis.inviteMember({ id: workspaceId, email }))
.then(() => { .then(() => {
onClose(); onClose();
onInviteSuccess && onInviteSuccess(); onInviteSuccess && onInviteSuccess();

View File

@@ -10,7 +10,7 @@ export const GoogleLoginButton = () => {
<StyledGoogleButton <StyledGoogleButton
onClick={() => { onClick={() => {
getDataCenter() getDataCenter()
.then(dc => dc.apis.signInWithGoogle()) .then(dc => dc.apis.signInWithGoogle?.())
.then(() => { .then(() => {
triggerLoginModal(); triggerLoginModal();
}) })

View File

@@ -11,7 +11,7 @@ import {
import { useState } from 'react'; import { useState } from 'react';
import { ModalCloseButton } from '@/ui/modal'; import { ModalCloseButton } from '@/ui/modal';
import { Button } from '@/ui/button'; import { Button } from '@/ui/button';
import { deleteWorkspace } from '@affine/datacenter'; import { getDataCenter } from '@affine/datacenter';
import { useRouter } from 'next/router'; import { useRouter } from 'next/router';
import { useAppState } from '@/providers/app-state-provider'; import { useAppState } from '@/providers/app-state-provider';
@@ -39,7 +39,8 @@ export const WorkspaceDelete = ({
}; };
const handleDelete = async () => { const handleDelete = async () => {
await deleteWorkspace({ id: workspaceId }); const dc = await getDataCenter();
await dc.apis.deleteWorkspace({ id: workspaceId });
router.push(`/workspace/${nextWorkSpaceId}`); router.push(`/workspace/${nextWorkSpaceId}`);
refreshWorkspacesMeta(); refreshWorkspacesMeta();
onClose(); onClose();

View File

@@ -9,7 +9,7 @@ import { StyledSettingH2 } from '../style';
import { useState } from 'react'; import { useState } from 'react';
import { Button } from '@/ui/button'; import { Button } from '@/ui/button';
import Input from '@/ui/input'; import Input from '@/ui/input';
import { uploadBlob, Workspace, WorkspaceType } from '@affine/datacenter'; import { getDataCenter, Workspace, WorkspaceType } from '@affine/datacenter';
import { useAppState } from '@/providers/app-state-provider'; import { useAppState } from '@/providers/app-state-provider';
import { WorkspaceDetails } from '@/components/workspace-slider-bar/WorkspaceSelector/SelectorPopperContent'; import { WorkspaceDetails } from '@/components/workspace-slider-bar/WorkspaceSelector/SelectorPopperContent';
import { WorkspaceDelete } from './delete'; import { WorkspaceDelete } from './delete';
@@ -74,9 +74,11 @@ export const GeneralPage = ({
const fileChange = async (file: File) => { const fileChange = async (file: File) => {
setUploading(true); setUploading(true);
const blob = new Blob([file], { type: file.type }); const blob = new Blob([file], { type: file.type });
const blobId = await uploadBlob({ blob }).finally(() => { const blobId = await getDataCenter()
setUploading(false); .then(dc => dc.apis.uploadBlob({ blob }))
}); .finally(() => {
setUploading(false);
});
if (blobId) { if (blobId) {
currentWorkspace?.meta.setAvatar(blobId); currentWorkspace?.meta.setAvatar(blobId);
workspaces[workspace.id]?.meta.setAvatar(blobId); workspaces[workspace.id]?.meta.setAvatar(blobId);

View File

@@ -7,7 +7,7 @@ import {
} from './style'; } from './style';
import { ModalCloseButton } from '@/ui/modal'; import { ModalCloseButton } from '@/ui/modal';
import { Button } from '@/ui/button'; import { Button } from '@/ui/button';
import { leaveWorkspace } from '@affine/datacenter'; import { getDataCenter } from '@affine/datacenter';
import { useRouter } from 'next/router'; import { useRouter } from 'next/router';
import { useAppState } from '@/providers/app-state-provider'; import { useAppState } from '@/providers/app-state-provider';
@@ -28,7 +28,8 @@ export const WorkspaceLeave = ({
const router = useRouter(); const router = useRouter();
const { refreshWorkspacesMeta } = useAppState(); const { refreshWorkspacesMeta } = useAppState();
const handleLeave = async () => { const handleLeave = async () => {
await leaveWorkspace({ id: workspaceId }); const dc = await getDataCenter();
await dc.apis.leaveWorkspace({ id: workspaceId });
router.push(`/workspace/${nextWorkSpaceId}`); router.push(`/workspace/${nextWorkSpaceId}`);
refreshWorkspacesMeta(); refreshWorkspacesMeta();
onClose(); onClose();

View File

@@ -36,13 +36,7 @@ import { useCallback, useEffect, useState } from 'react';
import { Button, IconButton } from '@/ui/button'; import { Button, IconButton } from '@/ui/button';
import Input from '@/ui/input'; import Input from '@/ui/input';
import { InviteMembers } from '../invite-members/index'; import { InviteMembers } from '../invite-members/index';
import { import { Workspace, Member, getDataCenter } from '@affine/datacenter';
getWorkspaceMembers,
Workspace,
Member,
removeMember,
updateWorkspace,
} from '@affine/datacenter';
import { Avatar } from '@mui/material'; import { Avatar } from '@mui/material';
import { Menu, MenuItem } from '@/ui/menu'; import { Menu, MenuItem } from '@/ui/menu';
import { toast } from '@/ui/toast'; import { toast } from '@/ui/toast';
@@ -169,9 +163,12 @@ const MembersPage = ({ workspace }: { workspace: Workspace }) => {
const [isInviteModalShow, setIsInviteModalShow] = useState(false); const [isInviteModalShow, setIsInviteModalShow] = useState(false);
const [members, setMembers] = useState<Member[]>([]); const [members, setMembers] = useState<Member[]>([]);
const refreshMembers = useCallback(() => { const refreshMembers = useCallback(() => {
getWorkspaceMembers({ getDataCenter()
id: workspace.id, .then(dc =>
}) dc.apis.getWorkspaceMembers({
id: workspace.id,
})
)
.then(data => { .then(data => {
setMembers(data); setMembers(data);
}) })
@@ -236,13 +233,17 @@ const MembersPage = ({ workspace }: { workspace: Workspace }) => {
// confirmText: 'Delete', // confirmText: 'Delete',
// confirmType: 'danger', // confirmType: 'danger',
// }).then(confirm => { // }).then(confirm => {
removeMember({ getDataCenter()
permissionId: member.id, .then(dc =>
}).then(() => { dc.apis.removeMember({
// console.log('data: ', data); permissionId: member.id,
toast('Moved to Trash'); })
refreshMembers(); )
}); .then(() => {
// console.log('data: ', data);
toast('Moved to Trash');
refreshMembers();
});
// }); // });
}} }}
icon={<TrashIcon />} icon={<TrashIcon />}
@@ -297,13 +298,17 @@ const PublishPage = ({ workspace }: { workspace: Workspace }) => {
workspace.public workspace.public
); );
const togglePublic = (flag: boolean) => { const togglePublic = (flag: boolean) => {
updateWorkspace({ getDataCenter()
id: workspace.id, .then(dc =>
public: flag, dc.apis.updateWorkspace({
}).then(data => { id: workspace.id,
setPublicStatus(data?.public); public: flag,
toast('Updated Public Status Success'); })
}); )
.then(data => {
setPublicStatus(data?.public);
toast('Updated Public Status Success');
});
}; };
const copyUrl = () => { const copyUrl = () => {
navigator.clipboard.writeText(shareUrl); navigator.clipboard.writeText(shareUrl);

View File

@@ -12,7 +12,7 @@ import {
} from './WorkspaceItem'; } from './WorkspaceItem';
import { WorkspaceSetting } from '@/components/workspace-setting'; import { WorkspaceSetting } from '@/components/workspace-setting';
import { useCallback, useEffect, useState } from 'react'; import { useCallback, useEffect, useState } from 'react';
import { getWorkspaceDetail, WorkspaceType } from '@affine/datacenter'; import { getDataCenter, WorkspaceType } from '@affine/datacenter';
import { useModal } from '@/providers/global-modal-provider'; import { useModal } from '@/providers/global-modal-provider';
export type WorkspaceDetails = Record< export type WorkspaceDetails = Record<
@@ -54,7 +54,8 @@ export const SelectorPopperContent = ({
if (type === WorkspaceType.Private) { if (type === WorkspaceType.Private) {
return { id, member_count: 1, owner: user }; return { id, member_count: 1, owner: user };
} else { } else {
const data = await getWorkspaceDetail({ id }); const dc = await getDataCenter();
const data = await dc.apis.getWorkspaceDetail({ id });
return { id, ...data } || { id, member_count: 0, owner: user }; return { id, ...data } || { id, member_count: 0, owner: user };
} }
} }

View File

@@ -1,4 +1,4 @@
import { createWorkspace, uploadBlob } from '@affine/datacenter'; import { getDataCenter } from '@affine/datacenter';
import Modal from '@/ui/modal'; import Modal from '@/ui/modal';
import Input from '@/ui/input'; import Input from '@/ui/input';
import { import {
@@ -52,7 +52,9 @@ export const WorkspaceCreate = ({ open, onClose }: WorkspaceCreateProps) => {
ctx.fillText(workspaceName[0], 50, 50); ctx.fillText(workspaceName[0], 50, 50);
canvas.toBlob(blob => { canvas.toBlob(blob => {
if (blob) { if (blob) {
const blobId = uploadBlob({ blob }); const blobId = getDataCenter().then(dc =>
dc.apis.uploadBlob({ blob })
);
resolve(blobId); resolve(blobId);
} else { } else {
reject(); reject();
@@ -69,7 +71,10 @@ export const WorkspaceCreate = ({ open, onClose }: WorkspaceCreateProps) => {
setCreating(false); setCreating(false);
}); });
if (blobId) { if (blobId) {
createWorkspace({ name: workspaceName, avatar: blobId }) getDataCenter()
.then(dc =>
dc.apis.createWorkspace({ name: workspaceName, avatar: blobId })
)
.then(async data => { .then(async data => {
await refreshWorkspacesMeta(); await refreshWorkspacesMeta();
// eslint-disable-next-line @typescript-eslint/ban-ts-comment // eslint-disable-next-line @typescript-eslint/ban-ts-comment

View File

@@ -26,7 +26,6 @@ export const useEnsureWorkspace = () => {
meta => meta.id.toString() === router.query.workspaceId meta => meta.id.toString() === router.query.workspaceId
) === -1 ) === -1
) { ) {
debugger;
router.push('/404'); router.push('/404');
return; return;
} }

View File

@@ -1,7 +1,7 @@
import { styled } from '@/styles'; import { styled } from '@/styles';
import { Empty } from '@/ui/empty'; import { Empty } from '@/ui/empty';
import { Avatar } from '@mui/material'; import { Avatar } from '@mui/material';
import { acceptInviting } from '@affine/datacenter'; import { getDataCenter } from '@affine/datacenter';
import { useRouter } from 'next/router'; import { useRouter } from 'next/router';
import { useEffect, useState } from 'react'; import { useEffect, useState } from 'react';
@@ -24,7 +24,12 @@ export default function DevPage() {
// eslint-disable-next-line @typescript-eslint/no-explicit-any // eslint-disable-next-line @typescript-eslint/no-explicit-any
const [inviteData, setInviteData] = useState<any>(null); const [inviteData, setInviteData] = useState<any>(null);
useEffect(() => { useEffect(() => {
acceptInviting({ invitingCode: router.query.invite_code as string }) getDataCenter()
.then(dc =>
dc.apis.acceptInviting({
invitingCode: router.query.invite_code as string,
})
)
.then(data => { .then(data => {
setSuccessInvited(true); setSuccessInvited(true);
setInviteData(data); setInviteData(data);

View File

@@ -1,18 +1,18 @@
import { createContext, MutableRefObject, useContext } from 'react'; import { createContext, MutableRefObject, useContext } from 'react';
import type { Workspace } from '@affine/datacenter'; import type { AccessTokenMessage, Workspace } from '@affine/datacenter';
import type { import type {
Page as StorePage, Page as StorePage,
Workspace as StoreWorkspace, Workspace as StoreWorkspace,
} from '@blocksuite/store'; } from '@blocksuite/store';
import type { EditorContainer } from '@blocksuite/editor'; import type { EditorContainer } from '@blocksuite/editor';
export type LoadWorkspaceHandler = ( export type LoadWorkspaceHandler = (
workspaceId: string workspaceId: string,
// user?: AccessTokenMessage | null user?: AccessTokenMessage | null
) => Promise<StoreWorkspace | null> | null; ) => Promise<StoreWorkspace | null> | null;
export type CreateEditorHandler = (page: StorePage) => EditorContainer | null; export type CreateEditorHandler = (page: StorePage) => EditorContainer | null;
export interface AppStateValue { export interface AppStateValue {
// user: AccessTokenMessage | null; user: AccessTokenMessage | null;
workspacesMeta: Workspace[]; workspacesMeta: Workspace[];
currentWorkspaceId: string; currentWorkspaceId: string;
@@ -38,7 +38,7 @@ export interface AppStateContext extends AppStateValue {
} }
export const AppState = createContext<AppStateContext>({ export const AppState = createContext<AppStateContext>({
// user: null, user: null,
workspacesMeta: [], workspacesMeta: [],
currentWorkspaceId: '', currentWorkspaceId: '',

View File

@@ -15,19 +15,17 @@ const DynamicBlocksuite = ({
setCreateEditorHandler, setCreateEditorHandler,
}: Props) => { }: Props) => {
useEffect(() => { useEffect(() => {
const openWorkspace: LoadWorkspaceHandler = (workspaceId: string, user) => const openWorkspace: LoadWorkspaceHandler = async (
// eslint-disable-next-line no-async-promise-executor workspaceId: string,
new Promise(async resolve => { user
if (workspaceId) { ) => {
const workspace = await getDataCenter().then(dc => if (workspaceId) {
dc.getWorkspace(workspaceId, 'affine') const dc = await getDataCenter();
); return dc.getWorkspace(workspaceId, { providerId: 'affine' });
} else {
resolve(workspace); return null;
} else { }
resolve(null); };
}
});
setLoadWorkspaceHandler(openWorkspace); setLoadWorkspaceHandler(openWorkspace);
}, [setLoadWorkspaceHandler]); }, [setLoadWorkspaceHandler]);

View File

@@ -1,7 +1,7 @@
import { useMemo, useState, useEffect, useCallback, useRef } from 'react'; import { useMemo, useState, useEffect, useCallback, useRef } from 'react';
import type { ReactNode } from 'react'; import type { ReactNode } from 'react';
import dynamic from 'next/dynamic'; import dynamic from 'next/dynamic';
import { getWorkspaces } from '@affine/datacenter'; import { getDataCenter } from '@affine/datacenter';
import { AppState, AppStateContext } from './context'; import { AppState, AppStateContext } from './context';
import type { import type {
AppStateValue, AppStateValue,
@@ -16,7 +16,8 @@ const DynamicBlocksuite = dynamic(() => import('./dynamic-blocksuite'), {
export const AppStateProvider = ({ children }: { children?: ReactNode }) => { export const AppStateProvider = ({ children }: { children?: ReactNode }) => {
const refreshWorkspacesMeta = async () => { const refreshWorkspacesMeta = async () => {
const workspacesMeta = await getWorkspaces().catch(() => { const dc = await getDataCenter();
const workspacesMeta = await dc.apis.getWorkspaces().catch(() => {
return []; return [];
}); });
setState(state => ({ ...state, workspacesMeta })); setState(state => ({ ...state, workspacesMeta }));

View File

@@ -26,8 +26,8 @@
"typescript": "^4.8.4" "typescript": "^4.8.4"
}, },
"dependencies": { "dependencies": {
"@blocksuite/blocks": "0.3.0-20221228162706-9576a3a", "@blocksuite/blocks": "^0.3.1",
"@blocksuite/store": "0.3.0-20221228162706-9576a3a", "@blocksuite/store": "^0.3.1",
"debug": "^4.3.4", "debug": "^4.3.4",
"encoding": "^0.1.13", "encoding": "^0.1.13",
"firebase": "^9.15.0", "firebase": "^9.15.0",
@@ -36,7 +36,7 @@
"ky-universal": "^0.11.0", "ky-universal": "^0.11.0",
"lib0": "^0.2.58", "lib0": "^0.2.58",
"swr": "^2.0.0", "swr": "^2.0.0",
"yjs": "^13.5.43", "yjs": "^13.5.44",
"y-protocols": "^1.0.5" "y-protocols": "^1.0.5"
} }
} }

View File

@@ -15,3 +15,7 @@ export const getApis = (): Apis => {
const [signInWithGoogle, onAuthStateChanged] = getAuthorizer(); const [signInWithGoogle, onAuthStateChanged] = getAuthorizer();
return { ...user, ...workspace, signInWithGoogle, onAuthStateChanged }; return { ...user, ...workspace, signInWithGoogle, onAuthStateChanged };
}; };
export type { AccessTokenMessage } from './token';
export type { Member, Workspace } from './workspace';
export { WorkspaceType } from './workspace';

View File

@@ -5,7 +5,7 @@ import type { User } from 'firebase/auth';
import { getLogger } from '../index.js'; import { getLogger } from '../index.js';
import { bareClient } from './request.js'; import { bareClient } from './request.js';
interface AccessTokenMessage { export interface AccessTokenMessage {
create_at: number; create_at: number;
exp: number; exp: number;
email: string; email: string;

View File

@@ -20,3 +20,6 @@ export function getLogger(namespace: string) {
logger.log = console.log.bind(console); logger.log = console.log.bind(console);
return logger; return logger;
} }
export type { AccessTokenMessage, Member, Workspace } from './apis';
export { WorkspaceType } from './apis';

49
pnpm-lock.yaml generated
View File

@@ -131,8 +131,8 @@ importers:
packages/data-center: packages/data-center:
specifiers: specifiers:
'@blocksuite/blocks': 0.3.0-20221228162706-9576a3a '@blocksuite/blocks': ^0.3.1
'@blocksuite/store': 0.3.0-20221228162706-9576a3a '@blocksuite/store': ^0.3.1
'@playwright/test': ^1.29.1 '@playwright/test': ^1.29.1
'@types/debug': ^4.1.7 '@types/debug': ^4.1.7
debug: ^4.3.4 debug: ^4.3.4
@@ -146,10 +146,10 @@ importers:
swr: ^2.0.0 swr: ^2.0.0
typescript: ^4.8.4 typescript: ^4.8.4
y-protocols: ^1.0.5 y-protocols: ^1.0.5
yjs: ^13.5.43 yjs: ^13.5.44
dependencies: dependencies:
'@blocksuite/blocks': 0.3.0-20221228162706-9576a3a_yjs@13.5.44 '@blocksuite/blocks': 0.3.1_yjs@13.5.44
'@blocksuite/store': 0.3.0-20221228162706-9576a3a_yjs@13.5.44 '@blocksuite/store': 0.3.1_yjs@13.5.44
debug: 4.3.4 debug: 4.3.4
encoding: 0.1.13 encoding: 0.1.13
firebase: 9.15.0_encoding@0.1.13 firebase: 9.15.0_encoding@0.1.13
@@ -1496,24 +1496,6 @@ packages:
resolution: {integrity: sha512-0hYQ8SB4Db5zvZB4axdMHGwEaQjkZzFjQiN9LVYvIFB2nSUHW9tYpxWriPrWDASIxiaXax83REcLxuSdnGPZtw==} resolution: {integrity: sha512-0hYQ8SB4Db5zvZB4axdMHGwEaQjkZzFjQiN9LVYvIFB2nSUHW9tYpxWriPrWDASIxiaXax83REcLxuSdnGPZtw==}
dev: true dev: true
/@blocksuite/blocks/0.3.0-20221228162706-9576a3a_yjs@13.5.44:
resolution: {integrity: sha512-gBwqynM0WQuUbsJbazBKIe+jkyoXYZPalYQlz0f1TT51kXmvyhQ1TlvsnZx94aW1JwT2st3z65Q197MmfZ8jSw==}
dependencies:
'@blocksuite/store': 0.3.0-20221228162706-9576a3a_yjs@13.5.44
'@tldraw/intersect': 1.8.0
highlight.js: 11.7.0
hotkeys-js: 3.10.1
lit: 2.5.0
perfect-freehand: 1.2.0
quill: 1.3.7
quill-cursors: 4.0.0
transitivePeerDependencies:
- bufferutil
- supports-color
- utf-8-validate
- yjs
dev: false
/@blocksuite/blocks/0.3.1_yjs@13.5.44: /@blocksuite/blocks/0.3.1_yjs@13.5.44:
resolution: {integrity: sha512-b0dGz2MG4yIgngJPRumaMY58wAsd2FEVSZl3tpCXlagK9I0HD165Bq70PxcaRHVjBSV1Gf29ZVHUF6BVTYogPw==} resolution: {integrity: sha512-b0dGz2MG4yIgngJPRumaMY58wAsd2FEVSZl3tpCXlagK9I0HD165Bq70PxcaRHVjBSV1Gf29ZVHUF6BVTYogPw==}
dependencies: dependencies:
@@ -1558,27 +1540,6 @@ packages:
react: 18.2.0 react: 18.2.0
dev: false dev: false
/@blocksuite/store/0.3.0-20221228162706-9576a3a_yjs@13.5.44:
resolution: {integrity: sha512-uMbLD+zfhHasDwCmE1ZTtFtK9GNwN37Iaugbj/rtdwhQbdE6qfKHidSY0UzwKtNrQaUdAmp2IpnBpQ0vgk0ArQ==}
peerDependencies:
yjs: ^13
dependencies:
'@types/flexsearch': 0.7.3
'@types/quill': 1.3.10
buffer: 6.0.3
flexsearch: 0.7.21
idb-keyval: 6.2.0
ky: 0.33.1
lib0: 0.2.58
y-protocols: 1.0.5
y-webrtc: 10.2.3
yjs: 13.5.44
transitivePeerDependencies:
- bufferutil
- supports-color
- utf-8-validate
dev: false
/@blocksuite/store/0.3.1_yjs@13.5.44: /@blocksuite/store/0.3.1_yjs@13.5.44:
resolution: {integrity: sha512-kynVTDfNCSChz2JI2rtGHxRIV2YrLzvAgVajcbfDVCuXKG0siBoEjLasG1a0kvevbvW/FabrNAj+xaIplklioA==} resolution: {integrity: sha512-kynVTDfNCSChz2JI2rtGHxRIV2YrLzvAgVajcbfDVCuXKG0siBoEjLasG1a0kvevbvW/FabrNAj+xaIplklioA==}
peerDependencies: peerDependencies: