Bugfixes

RACE-Game · Jan 12, 2024 · d67cba0 · d67cba0
1 parent f9229c2
commit d67cba0
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 14 deletions.
diff --git a/README.md b/README.md
@@ -33,9 +33,9 @@ Work in progress, not ready to accept contributions yet.
 | Package                     | Version                                                                                                                              | Description                                    |
 |-----------------------------|--------------------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
 | @race-foundation/borsh      | [![NPM](https://img.shields.io/npm/v/@race-foundation/borsh?logo=npm)](https://www.npmjs.com/package/@race-foundation/borsh)         | A borsh implementation with decorators support |
-| @race-fonudation/sdk-core   | [![NPM](https://img.shields.io/npm/v/@race-foundation/sdk-core?logo=npm)](https://www.npmjs.com/package/@race-foundation/sdk-core)   | SDK for RACE Protocol                          |
-| @race-fonudation/sdk-solana | [![NPM](https://img.shields.io/npm/v/@race-foundation/sdk-core?logo=npm)](https://www.npmjs.com/package/@race-foundation/sdk-solana) | SDK integration for Solana blockchain          |
-| @race-fonudation/sdk-facade | [![NPM](https://img.shields.io/npm/v/@race-foundation/sdk-core?logo=npm)](https://www.npmjs.com/package/@race-foundation/sdk-facade) | SDK integration for local facade server        |
+| @race-foundation/sdk-core   | [![NPM](https://img.shields.io/npm/v/@race-foundation/sdk-core?logo=npm)](https://www.npmjs.com/package/@race-foundation/sdk-core)   | SDK for RACE Protocol                          |
+| @race-foundation/sdk-solana | [![NPM](https://img.shields.io/npm/v/@race-foundation/sdk-core?logo=npm)](https://www.npmjs.com/package/@race-foundation/sdk-solana) | SDK integration for Solana blockchain          |
+| @race-foundation/sdk-facade | [![NPM](https://img.shields.io/npm/v/@race-foundation/sdk-core?logo=npm)](https://www.npmjs.com/package/@race-foundation/sdk-facade) | SDK integration for local facade server        |
 
 ## Rust
 

diff --git a/js/sdk-core/src/base-client.ts b/js/sdk-core/src/base-client.ts
@@ -9,6 +9,7 @@ import {
   SubscribeEventParams,
   ConnectionSubscription,
   BroadcastFrame,
+  SubmitMessageParams,
 } from './connection';
 import { GameContext } from './game-context';
 import { GameContextSnapshot } from './game-context-snapshot';
@@ -154,6 +155,17 @@ export class BaseClient {
     }
   }
 
+  /**
+   * Submit a message.
+   */
+  async submitMessage(content: string): Promise<void> {
+    const connState = await this.__connection.submitMessage(new SubmitMessageParams({
+      content
+    }));
+    if (connState !== undefined && this.__onConnectionState !== undefined) {
+      this.__onConnectionState(connState);
+    }
+  }
   /**
    * Connect to the transactor and retrieve the event stream.
    */
@@ -304,17 +316,13 @@ export class BaseClient {
       if (this.__onConnectionState !== undefined) {
         this.__onConnectionState('disconnected')
       }
-      console.groupCollapsed('Disconnected, try reset state and context');
-      try {
-        const gameAccount = await this.__getGameAccount();
-        this.__gameContext = new GameContext(gameAccount);
-        const initAccount = InitAccount.createFromGameAccount(gameAccount, this.__gameContext.accessVersion, this.__gameContext.settleVersion);
-        this.__gameContext.applyCheckpoint(gameAccount.checkpointAccessVersion, this.__gameContext.settleVersion);
-        await this.__connection.connect(new SubscribeEventParams({ settleVersion: this.__gameContext.settleVersion }));
-        await this.__initializeState(initAccount);
-      } finally {
-        console.groupEnd();
-      }
+      console.log('Disconnected, try reset state and context');
+      const gameAccount = await this.__getGameAccount();
+      this.__gameContext = new GameContext(gameAccount);
+      const initAccount = InitAccount.createFromGameAccount(gameAccount, this.__gameContext.accessVersion, this.__gameContext.settleVersion);
+      this.__gameContext.applyCheckpoint(gameAccount.checkpointAccessVersion, this.__gameContext.settleVersion);
+      await this.__connection.connect(new SubscribeEventParams({ settleVersion: this.__gameContext.settleVersion }));
+      await this.__initializeState(initAccount);
     } else if (state === 'connected') {
       if (this.__onConnectionState !== undefined) {
         this.__onConnectionState('connected')

diff --git a/transactor/src/server.rs b/transactor/src/server.rs
@@ -82,6 +82,7 @@ async fn submit_message(
     let (game_addr, SubmitMessageParams { content }, sig) = parse_params(params, &context)?;
 
     let sender = sig.signer;
+    info!("Player message, {}: {}", sender, content);
     let message = Message { content, sender };
 
     context