Parse transcription data

// Join a channel and add callback events
 rtcManager.joinChannel(roomName, localUid, agora_token, roleType.equals(ROLE_TYPE_BROADCAST), new RtcManager.OnChannelListener() {
     ...
     // Callback for receiving a stream message
     @Override
     public void onStreamMessage(int uid, int streamId, byte[] data) {
         // Check if the remote user ID matches the specified streaming bot ID.
         // If so, decode the stream data into a text object.
         if (String.valueOf(uid).equalsIgnoreCase(RTC_UID_STT_STREAM)) {
             AgoraSpeech2TextProtobuffer.Text text = STTManager.getInstance().parseTextByte(roomName, data);
             // Convert the parsed text object to JSON format and print it to the log
             LogUtil.d(originLogName, mGson.toJson(text));
         }
     }
     ...
 });

 public AgoraSpeech2TextProtobuffer.Text parseTextByte(String channel, byte[] data) {
     // Declare a variable of type AgoraSpeech2TextProtobuffer.Text to store the deserialized object
     AgoraSpeech2TextProtobuffer.Text textStream;
     try {
         // Deserialize the byte array data into an AgoraSpeech2TextProtobuffer.Text object
         textStream = AgoraSpeech2TextProtobuffer.Text.parseFrom(data);
     } catch (Exception ex) {
         notifyErrorHandler(new ErrorInfo("parseTextByte", "-1", "parseTextByte parseFrom error >> " + ex.toString()));
         return null;
     }
     ...
 }

private void InitRtcEngine()
{
    // Create an RTC engine instance
    RtcEngine = Agora.Rtc.RtcEngine.CreateAgoraRtcEngine();

    // Create an instance of the event handler class
    AgoraEventHandler handler = new AgoraEventHandler(this);

    // Create the RtcEngineContext object and set the channel profile to live broadcasting
    RtcEngineContext context = new RtcEngineContext(_appID, 0,
        CHANNEL_PROFILE_TYPE.CHANNEL_PROFILE_LIVE_BROADCASTING,
        AUDIO_SCENARIO_TYPE.AUDIO_SCENARIO_DEFAULT);

    // Initialize the engine
    RtcEngine.Initialize(context);

    // Add callback events
    RtcEngine.InitEventHandler(handler);
}

// Define a class to handle RTC-related callbacks, inheriting from IRtcEngineEventHandler
internal class AgoraEventHandler : IRtcEngineEventHandler
{
    // Callback for receiving data stream messages
    public override void OnStreamMessage(RtcConnection connection, uint remoteUid, int streamId, byte[] data, uint length, ulong sentTs)
    {
        // Debug.Log(String.Format("remoteUid: {0}", remoteUid));

        // If the remote user ID equals the specified streaming bot ID
        if (remoteUid == {pusher bot uid}) {
            // Parse Protobuf data
            AgoraSTTSample.Protobuf.Text t = ProtobufUtility.ParseProtobufData(data);
            // ...
        }
    }
}

import AgoraRTC from "agora-rtc-sdk-ng"

// Create an RTC client instance
this.rtc.client = AgoraRTC.createClient({ mode: "live", codec: "vp8", role: this.role })

// Listen for stream message events and bind the event handler function
this.rtc.client.on("stream-message", this.onStreamMessage.bind(this))

// Callback for receiving data stream messages
function onStreamMessage(uid, stream) {
    // Check if the remote user ID is the specified streaming bot ID; if not, return directly and do not proceed with further processing
    if (uid != {pusher bot uid}) {
        return
    }
    // Use Protobuf to decode the received data stream
    let textstream = protoRoot.Agora.SpeechToText.lookup("Text").decode(data)
    // ...
}

// Temp.h
#import "AgoraRtcKit/AgoraRtcKit.h"
#import "./Protobuff/SttMessage.pbobjc.h"

NS_ASSUME_NONNULL_BEGIN

@interface Temp : NSObject<AgoraRtcEngineDelegate>

@end

NS_ASSUME_NONNULL_END

// Temp.m
@implementation Temp

// Callback for receiving data stream messages
- (void)rtcEngine:(AgoraRtcEngineKit *)engine receiveStreamMessageFromUid:(NSUInteger)uid streamId:(NSInteger)streamId data:(NSData *)data {
    // Check if the remote user ID is the specified streaming bot ID;
    // if not, return directly and do not proceed with further processing
    if (uid != pusherUid) {
        return;
    }

    NSError* error;
    // Decode the received data stream
    SttText* st =  [SttText parseFromData: data error: &error];
    // ...
}

@end

// Callback for receiving data stream messages
func rtcEngine(_engine: AgoraRtcEngineKit, receiveStreamMessageFromUid uid: UInt, streamId: Int, data: Data) {
    // Check if the remote user ID is the specified streaming bot ID;
    // if not, return directly and do not proceed with further processing
    guard uid == {pusher bot uid} else {
        return
    }
    // Decode the received data stream
    let text = try? SttText.parse(from: data)
    // ...
}

time: 1753359518654
 words {
   text: "Hello, how are you?"
   is_final: true
 }
 duration_ms: 770
 data_type: "transcribe"
 culture: "en-US"
 text_ts: 1753359520754
 sentence_id: 1753359518654

{
    "transcript": {
        "uid": 222,
        "language": "zh-CN",
        "text": "北选手",
        "isFinal": false,
        "offset": 1751438272384,
        "duration": 760,
        "textTs": 1751438273939
    }
}

time: 1753359518654
duration_ms: 770
data_type: "translate"
trans {
  is_final: true
  lang: "es-ES"
  texts: "Hola, ¿cómo estás? "
}
text_ts: 1753359520754
sentence_id: 1753359518654
original_transcript {
  culture: "en-US"
  words {
    text: "Hello, how are you?"
    is_final: true
  }
}

{
  "translation": {
      "uid": 222,
      "isFinal": true,
      "offset": 1751438270274,
      "duration": 1320,
      "textTs": 1751438272825,
      "results0": {
          "language": "ja-JP",
          "texts": [
              "4月13日。 "
          ]
      },
      "original_transcript": {
          "language": "zh-CN",
          "text": "4月13日。"
      }
    }
}