// // Copyright © 2020 Anticrm Platform Contributors. // // Licensed under the Eclipse Public License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. You may // obtain a copy of the License at https://www.eclipse.org/legal/epl-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // // See the License for the specific language governing permissions and // limitations under the License. // import clientPlugin from '@hcengineering/client' import { Client, createClient, TxHander } from '@hcengineering/core' import { getMetadata, getPlugins, getResource } from '@hcengineering/platform' import { connect } from './connection' export { connect } let client: Promise | Client | undefined /*! * Anticrm Platform™ Client Plugin * © 2020, 2021 Anticrm Platform Contributors. All Rights Reserved. * Licensed under the Eclipse Public License, Version 2.0 */ // eslint-disable-next-line @typescript-eslint/explicit-function-return-type export default async () => { let _token: string | undefined return { function: { GetClient: async ( token: string, endpoint: string, onUpgrade?: () => void, onUnauthorized?: () => void ): Promise => { if (client instanceof Promise) { client = await client await client.close() } if (token !== _token && client !== undefined) { client = undefined } if (client === undefined) { const filterModel = getMetadata(clientPlugin.metadata.FilterModel) ?? false client = createClient( (handler: TxHander) => { const url = new URL(`/${token}`, endpoint) console.log('connecting to', url.href) return connect(url.href, handler, onUpgrade, onUnauthorized) }, filterModel ? getPlugins() : undefined ) _token = token // Check if we had dev hook for client. const hook = getMetadata(clientPlugin.metadata.ClientHook) if (hook !== undefined) { const hookProc = await getResource(hook) const _client = client client = new Promise((resolve, reject) => { _client .then((res) => { resolve(hookProc(res)) }) .catch((err) => reject(err)) }) } } return await client } } } }