Merge branch 'main' into shuhui/random-perf

lerna.json

@@ -1,6 +1,6 @@
 {
     "$schema": "node_modules/lerna/schemas/lerna-schema.json",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packages": ["packages/*", "protocol"],
     "npmClient": "yarn"
 }

packages/dlog/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/dlog",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "type": "module",
     "main": "dist/index.js",

packages/encryption/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/encryption",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "type": "module",
     "main": "dist/index.js",

packages/eslint-config/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/eslint-config",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "license": "MIT",
     "main": "typescript.js"
 }

packages/generated/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/generated",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "scripts": {
         "preinstall": "node ./scripts/make-config.js",

packages/prettier-config/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/prettier-config",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "license": "MIT",
     "main": "config.js",
     "peerDependencies": {

packages/proto/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/proto",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "type": "module",
     "main": "dist/index.js",

packages/react-sdk/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/react-sdk",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "description": "React Hooks for River SDK",
     "repository": {
         "type": "git",

packages/sdk/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/sdk",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "type": "module",
     "main": "dist/index.js",

packages/sdk/src/sync-agent/spaces/models/channel.ts

@@ -1,6 +1,6 @@
 import { PlainMessage } from '@bufbuild/protobuf'
 import { PersistedObservable, persistedObservable } from '../../../observable/persistedObservable'
-import { Identifiable, Store } from '../../../store/store'
+import { Identifiable, LoadPriority, Store } from '../../../store/store'
 import { RiverConnection } from '../../river-connection/riverConnection'
 import { ChannelMessage_Post_Attachment, ChannelMessage_Post_Mention } from '@river-build/proto'
 import { Timeline } from '../../timeline/timeline'
@@ -29,7 +29,7 @@ export class Channel extends PersistedObservable<ChannelModel> {
         private spaceDapp: SpaceDapp,
         store: Store,
     ) {
-        super({ id, spaceId, isJoined: false }, store)
+        super({ id, spaceId, isJoined: false }, store, LoadPriority.high)
         this.timeline = new Timeline(riverConnection.userId)
         this.members = new Members(id, riverConnection, store)
     }

packages/sdk/src/sync-agent/spaces/models/space.ts

@@ -1,8 +1,12 @@
 import { check, dlogger } from '@river-build/dlog'
 import { isDefined } from '../../../check'
-import { makeDefaultChannelStreamId, makeUniqueChannelStreamId } from '../../../id'
+import {
+    isChannelStreamId,
+    makeDefaultChannelStreamId,
+    makeUniqueChannelStreamId,
+} from '../../../id'
 import { PersistedObservable, persistedObservable } from '../../../observable/persistedObservable'
-import { Identifiable, Store } from '../../../store/store'
+import { Identifiable, LoadPriority, Store } from '../../../store/store'
 import { RiverConnection } from '../../river-connection/riverConnection'
 import { Channel } from './channel'
 import { ethers } from 'ethers'
@@ -28,7 +32,7 @@ export class Space extends PersistedObservable<SpaceModel> {
         store: Store,
         private spaceDapp: SpaceDapp,
     ) {
-        super({ id, channelIds: [], initialized: false }, store)
+        super({ id, channelIds: [], initialized: false }, store, LoadPriority.high)
         this.channels = {
             [makeDefaultChannelStreamId(id)]: new Channel(
                 makeDefaultChannelStreamId(id),
@@ -111,6 +115,7 @@ export class Space extends PersistedObservable<SpaceModel> {
     }
 
     getChannel(channelId: string): Channel {
+        check(isChannelStreamId(channelId), 'channelId is not a channel stream id')
         if (!this.channels[channelId]) {
             this.channels[channelId] = new Channel(
                 channelId,

packages/web3/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/web3",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "type": "module",
     "main": "dist/index.js",

protocol/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@river-build/proto-source",
-    "version": "0.0.60",
+    "version": "0.0.61",
     "packageManager": "[email protected]",
     "files": [
         "*.proto"