Merge remote-tracking branch 'origin/develop'

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

dev/tool/src/storage.ts

@@ -34,6 +34,7 @@ export async function moveFiles (
 
   for (const [name, adapter] of exAdapter.adapters.entries()) {
     if (name === target) continue
+    console.log('moving from', name)
 
     const iterator = await adapter.listStream(ctx, workspaceId)
     while (true) {
@@ -44,9 +45,16 @@ export async function moveFiles (
       if (blob === undefined) continue
       if (blob.provider === target) continue
 
-      const readable = await exAdapter.get(ctx, workspaceId, data._id)
+      try {
-      const stream = readable.pipe(new PassThrough())
+        const readable = await exAdapter.get(ctx, workspaceId, data._id)
-      await exAdapter.put(ctx, workspaceId, data._id, stream, blob.contentType, blob.size)
+        readable.on('end', () => {
+          readable.destroy()
+        })
+        const stream = readable.pipe(new PassThrough())
+        await exAdapter.put(ctx, workspaceId, data._id, stream, blob.contentType, blob.size)
+      } catch (err) {
+        console.error('failed to process blob', name, data._id, err)
+      }
 
       count += 1
       if (count % 100 === 0) {

packages/presentation/src/file.ts

@@ -72,7 +72,7 @@ export function getFileUrl (file: string, filename?: string): string {
 
   const template = getFilesUrl()
   return template
-    .replaceAll(':filename', encodeURIComponent(filename ?? ''))
+    .replaceAll(':filename', encodeURIComponent(filename ?? file))
     .replaceAll(':workspace', encodeURIComponent(getCurrentWorkspace()))
     .replaceAll(':blobId', encodeURIComponent(file))
 }

packages/presentation/src/preview.ts

@@ -74,8 +74,6 @@ function blobToSrcSet (cfg: PreviewConfig, blob: Ref<Blob>, width: number | unde
       ' 2x, ' +
       fu.replaceAll(':size', `${width * 3}`) +
       ' 3x'
-  } else {
-    result += downloadUrl
   }
 
   return result

plugins/chunter-resources/src/components/chat/create/CreateChannel.svelte

@@ -68,14 +68,6 @@
       topic: description
     })
 
-    await client.createDoc(notification.class.DocNotifyContext, space._id, {
-      user: account._id,
-      objectId: channelId,
-      objectClass: chunter.class.Channel,
-      objectSpace: core.space.Space,
-      isPinned: false
-    })
-
     openChannel(channelId, chunter.class.Channel)
   }
 

server-plugins/notification-resources/src/utils.ts

@@ -151,7 +151,7 @@ export function isAllowed (
   notificationControl: NotificationProviderControl
 ): boolean {
   const providerSetting = (notificationControl.byProvider.get(provider._id) ?? []).find(
-    ({ attachedTo, modifiedBy }) => modifiedBy === receiver
+    ({ createdBy }) => createdBy === receiver
   )
 
   if (providerSetting !== undefined && !providerSetting.enabled) {
@@ -168,7 +168,7 @@ export function isAllowed (
     return false
   }
   const setting = (notificationControl.settingsByProvider.get(provider._id) ?? []).find(
-    (it) => it.type === type._id && it.modifiedBy === receiver
+    (it) => it.type === type._id && it.createdBy === receiver
   )
 
   if (setting !== undefined) {

server/core/src/server/aggregator.ts

@@ -256,12 +256,8 @@ export class AggregatorStorageAdapter implements StorageAdapter, StorageAdapterE
 
   @withContext('aggregator-get', {})
   async get (ctx: MeasureContext, workspaceId: WorkspaceId, name: string): Promise<Readable> {
-    // const { provider, stat } = await this.findProvider(ctx, workspaceId, name)
+    const { provider, stat } = await this.findProvider(ctx, workspaceId, name)
-    const provider = this.adapters.get(this.defaultAdapter)
+    return await provider.get(ctx, workspaceId, stat.storageId)
-    if (provider === undefined) {
-      throw new NoSuchKeyError('No such provider found')
-    }
-    return await provider.get(ctx, workspaceId, name)
   }
 
   @withContext('find-provider', {})