UBER-62: Maintenance warnings

UBER-62: Maintenance warnings

+ Ghost mode
+ Updated server statistics
+ Ability to reboot server

Signed-off-by: Andrey Sobolev <haiodo@gmail.com>

dev/client-resources/src/connection.ts

@@ -14,6 +14,7 @@
 //
 
 import core, {
+  Account,
   Class,
   ClientConnection,
   Doc,
@@ -65,6 +66,10 @@ class ServerStorageWrapper implements ClientConnection {
     })
   }
 
+  async getAccount (): Promise<Account> {
+    return (await this.storage.findAll(this.measureCtx, core.class.Account, {}))[0]
+  }
+
   async tx (tx: Tx): Promise<TxResult> {
     const _tx = protoDeserialize(protoSerialize(tx, false), false)
     const [result, derived] = await this.storage.tx(this.measureCtx, _tx)

dev/client-resources/src/index.ts

@@ -13,18 +13,18 @@
 // limitations under the License.
 //
 
-import { createClient, Client } from '@hcengineering/core'
-import { getMetadata, getResource } from '@hcengineering/platform'
+import clientPlugin from '@hcengineering/client'
+import { AccountClient, createClient } from '@hcengineering/core'
 import { migrateOperations } from '@hcengineering/model-all'
+import { getMetadata, getResource } from '@hcengineering/platform'
 import { connect } from './connection'
-import clientPlugin from '@hcengineering/client'
 
-let client: Client
+let client: AccountClient
 // eslint-disable-next-line @typescript-eslint/explicit-function-return-type
 export default async () => {
   return {
     function: {
-      GetClient: async (): Promise<Client> => {
+      GetClient: async (): Promise<AccountClient> => {
         if (client === undefined) {
           client = await createClient(connect)
           for (const op of migrateOperations) {

dev/tool/src/index.ts

@@ -26,6 +26,7 @@ import {
   listAccounts,
   listWorkspaces,
   replacePassword,
+  setAccountAdmin,
   setRole,
   upgradeWorkspace
 } from '@hcengineering/account'
@@ -195,6 +196,17 @@ export function devTool (
       await setRole(email, workspace, productId, role)
     })
 
+  program
+    .command('set-user-admin <email> <role>')
+    .description('set user role')
+    .action(async (email: string, role: string) => {
+      const { mongodbUri } = prepareTools()
+      console.log(`set user ${email} admin...`)
+      return await withDatabase(mongodbUri, async (db) => {
+        await setAccountAdmin(db, email, role === 'true')
+      })
+    })
+
   program
     .command('upgrade-workspace <name>')
     .description('upgrade workspace')

models/chunter/src/index.ts

@@ -662,7 +662,7 @@ export function createModel (builder: Builder, options = { addApplication: true
       },
       templates: {
         textTemplate: '{sender} mentioned you in {doc} {data}',
-        htmlTemplate: '<p><b>{sender}</b> mentioned you in {doc}</p> {data}',
+        htmlTemplate: '<p>–{sender}</b> mentioned you in {doc}</p> {data}',
         subjectTemplate: 'You were mentioned in {doc}'
       }
     },

packages/core/src/__tests__/client.test.ts

@@ -14,7 +14,7 @@
 // limitations under the License.
 //
 import { Plugin, IntlString } from '@hcengineering/platform'
-import type { Class, Data, Doc, Domain, PluginConfiguration, Ref, Timestamp } from '../classes'
+import type { Account, Class, Data, Doc, Domain, PluginConfiguration, Ref, Timestamp } from '../classes'
 import { Space, ClassifierKind, DOMAIN_MODEL } from '../classes'
 import { createClient, ClientConnection } from '../client'
 import core from '../component'
@@ -113,7 +113,8 @@ describe('client', () => {
         loadDocs: async (domain: Domain, docs: Ref<Doc>[]) => [],
         upload: async (domain: Domain, docs: Doc[]) => {},
         clean: async (domain: Domain, docs: Ref<Doc>[]) => {},
-        loadModel: async (last: Timestamp) => txes
+        loadModel: async (last: Timestamp) => txes,
+        getAccount: async () => null as unknown as Account
       }
     }
     const spyCreate = jest.spyOn(TxProcessor, 'createDoc2Doc')

packages/core/src/__tests__/connection.ts

@@ -13,7 +13,7 @@
 // limitations under the License.
 //
 
-import type { Class, Doc, Domain, Ref, Timestamp } from '../classes'
+import type { Account, Class, Doc, Domain, Ref, Timestamp } from '../classes'
 import { ClientConnection } from '../client'
 import core from '../component'
 import { Hierarchy } from '../hierarchy'
@@ -65,6 +65,7 @@ export async function connect (handler: (tx: Tx) => void): Promise<ClientConnect
     loadDocs: async (domain: Domain, docs: Ref<Doc>[]) => [],
     upload: async (domain: Domain, docs: Doc[]) => {},
     clean: async (domain: Domain, docs: Ref<Doc>[]) => {},
-    loadModel: async (last: Timestamp) => txes
+    loadModel: async (last: Timestamp) => txes,
+    getAccount: async () => null as unknown as Account
   }
 }

packages/core/src/client.ts

@@ -15,7 +15,7 @@
 
 import { Plugin } from '@hcengineering/platform'
 import { BackupClient, DocChunk } from './backup'
-import { AttachedDoc, Class, DOMAIN_MODEL, Doc, Domain, PluginConfiguration, Ref, Timestamp } from './classes'
+import { Account, AttachedDoc, Class, DOMAIN_MODEL, Doc, Domain, PluginConfiguration, Ref, Timestamp } from './classes'
 import core from './component'
 import { Hierarchy } from './hierarchy'
 import { ModelDb } from './memdb'
@@ -47,16 +47,24 @@ export interface Client extends Storage {
   close: () => Promise<void>
 }
 
+/**
+ * @public
+ */
+export interface AccountClient extends Client {
+  getAccount: () => Promise<Account>
+}
+
 /**
  * @public
  */
 export interface ClientConnection extends Storage, BackupClient {
   close: () => Promise<void>
   onConnect?: (apply: boolean) => Promise<void>
   loadModel: (last: Timestamp) => Promise<Tx[]>
+  getAccount: () => Promise<Account>
 }
 
-class ClientImpl implements Client, BackupClient {
+class ClientImpl implements AccountClient, BackupClient {
   notify?: (tx: Tx) => void
 
   constructor (
@@ -144,6 +152,10 @@ class ClientImpl implements Client, BackupClient {
   async clean (domain: Domain, docs: Ref<Doc>[]): Promise<void> {
     return await this.conn.clean(domain, docs)
   }
+
+  async getAccount (): Promise<Account> {
+    return await this.conn.getAccount()
+  }
 }
 
 /**
@@ -153,7 +165,7 @@ export async function createClient (
   connect: (txHandler: TxHandler) => Promise<ClientConnection>,
   // If set will build model with only allowed plugins.
   allowedPlugins?: Plugin[]
-): Promise<Client> {
+): Promise<AccountClient> {
   let client: ClientImpl | null = null
 
   // Temporal buffer, while we apply model

packages/core/src/tx.ts

@@ -50,7 +50,8 @@ export enum WorkspaceEvent {
   UpgradeScheduled,
   Upgrade,
   IndexingUpdate,
-  SecurityChange
+  SecurityChange,
+  MaintenanceNotification
 }
 
 /**

packages/panel/src/components/Panel.svelte

@@ -62,6 +62,9 @@
   const startScrollHeightCheck = () => {
     clearTimeout(timer)
     timer = setTimeout(() => {
+      if (scroll == null) {
+        return
+      }
       if (lastScrollHeight <= scroll.scrollHeight && count <= waitCount) {
         count = lastScrollHeight < scroll.scrollHeight ? 0 : count + 1
         lastScrollHeight = scroll.scrollHeight

packages/platform/src/i18n.ts

@@ -14,14 +14,14 @@
 // limitations under the License.
 //
 
-import type { Plugin, IntlString } from './platform'
-import { Status, Severity, unknownError } from './status'
-import { _IdInfo, _parseId } from './ident'
-import { setPlatformStatus } from './event'
 import { IntlMessageFormat } from 'intl-messageformat'
+import { setPlatformStatus } from './event'
+import { _IdInfo, _parseId } from './ident'
+import type { IntlString, Plugin } from './platform'
+import { Severity, Status, unknownError } from './status'
 
-import platform from './platform'
 import { getMetadata } from './metadata'
+import platform from './platform'
 
 /**
  * @public
@@ -103,6 +103,7 @@ async function getTranslation (id: _IdInfo, locale: string): Promise<IntlString
 export async function translate<P extends Record<string, any>> (message: IntlString<P>, params: P): Promise<string> {
   const locale = getMetadata(platform.metadata.locale) ?? 'en'
   const compiled = cache.get(message)
+
   if (compiled !== undefined) {
     if (compiled instanceof Status) {
       return message

packages/platform/src/index.ts

@@ -15,15 +15,16 @@
 //
 
 import { addStringsLoader } from './i18n'
-import { platformId } from './platform'
 import type { Metadata } from './metadata'
+import { platformId } from './platform'
 
-export * from './platform'
-export * from './status'
 export * from './event'
-export * from './resource'
 export * from './i18n'
 export * from './metadata'
+export * from './platform'
+export { default } from './platform'
+export * from './resource'
+export * from './status'
 export * from './testUtils'
 
 addStringsLoader(platformId, async (lang: string) => {
@@ -39,5 +40,3 @@ export type URL = string
  * @public
  */
 export type Asset = Metadata<URL>
-
-export { default } from './platform'

packages/platform/src/lang/en.json

@@ -1,13 +1,14 @@
 {
   "status": {
-    "LoadingPlugin": "Loading plugin '<b>'{plugin}'</b>'...",
+    "LoadingPlugin": "Loading plugin {plugin}...",
     "UnknownError": "Unknown error: {message}",
     "InvalidId": "Invalid Id: {id}",
     "BadRequest": "Bad request",
     "Forbidden": "Forbidden",
     "ExpiredLink": "This invite link is expired",
     "Unauthorized": "Unauthorized",
     "UnknownMethod": "Unknown method: {method}",
-    "InternalServerError": "Internal server error"
+    "InternalServerError": "Internal server error",
+    "MaintenanceWarning": "Maintenance Scheduled in {time, plural, =1 {less a minute} other {# minutes}}"
   }
 }

packages/platform/src/lang/ru.json

@@ -1,13 +1,14 @@
 {
   "status": {
-    "LoadingPlugin": "Загрузка плагина '<b>'{plugin}'</b>'...",
+    "LoadingPlugin": "Загрузка плагина {plugin}...",
     "UnknownError": "Неизвестная ошибка: {message}",
     "InvalidId": "Некорректный Id: {id}",
     "BadRequest": "Некорректный запрос",
     "Forbidden": "Запрещено",
     "ExpiredLink": "Ссылка истекла",
     "Unauthorized": "Неавторизован",
     "UnknownMethod": "Неизвестный метод: {method}",
-    "InternalServerError": "Внутренняя ошибка сервера"
+    "InternalServerError": "Внутренняя ошибка сервера",
+    "MaintenanceWarning": "Серверные работы запланированы через {time} минут"
   }
 }

packages/platform/src/platform.ts

@@ -143,7 +143,8 @@ export default plugin(platformId, {
     Unauthorized: '' as StatusCode,
     ExpiredLink: '' as StatusCode,
     UnknownMethod: '' as StatusCode<{ method: string }>,
-    InternalServerError: '' as StatusCode
+    InternalServerError: '' as StatusCode,
+    MaintenanceWarning: '' as StatusCode<{ time: number }>
   },
   metadata: {
     locale: '' as Metadata<string>

packages/query/src/__tests__/connection.ts

@@ -14,9 +14,9 @@
 //
 
 import type {
+  AccountClient,
   BackupClient,
   Class,
-  Client,
   Doc,
   DocumentQuery,
   Domain,
@@ -31,7 +31,7 @@ import core, { DOMAIN_TX, Hierarchy, ModelDb, TxDb } from '@hcengineering/core'
 import { genMinModel } from './minmodel'
 
 export async function connect (handler: (tx: Tx) => void): Promise<
-Client &
+AccountClient &
 BackupClient & {
   loadModel: (lastTxTime: Timestamp) => Promise<Tx[]>
 }
@@ -63,6 +63,7 @@ BackupClient & {
     findOne: async (_class, query, options) => (await findAll(_class, query, { ...options, limit: 1 })).shift(),
     getHierarchy: () => hierarchy,
     getModel: () => model,
+    getAccount: async () => ({} as unknown as any),
     tx: async (tx: Tx): Promise<TxResult> => {
       if (tx.objectSpace === core.space.Model) {
         hierarchy.tx(tx)

packages/ui/src/components/Label.svelte

@@ -22,9 +22,13 @@
   let _value: string | undefined = undefined
 
   $: if (label !== undefined) {
-    translate(label, params ?? {}).then((r) => {
-      _value = r
-    })
+    translate(label, params ?? {})
+      .then((r) => {
+        _value = r
+      })
+      .catch((err) => {
+        console.error(err)
+      })
   } else {
     _value = label
   }