[SERVER➡️UNITY] 시나리오 텍스트 스트리밍 코드 (11/10 업데이트)

[silverpoodle]

카테고리

코드 관련

전달 사항

AI - SERVER - UNITY
텍스트 스트리밍은 되는데 잘못된 부분 없는지 확인 부탁드립니다!
아래는 실행화면입니당

- 작성 시 버튼 비활성화 & 텍스트 스트리밍

- 작성 완료 후 버튼 재활성

- 재작성 시 inputField 초기화 & 재작성

요청 사항

해당 부분은 배포했습니다! 어디서든 테스트 가능합니다. AI 와 연결되어있지 않기 때문에 임시 데이터가 스트리밍 됩니다.

첨부 코드

개행 문제 해결했습니다! 코드 다시 한 번 확인 부탁드려요😊

using System.IO;
using System.Text;
using TMPro;
using UnityEngine;
using UnityEngine.UI;
using System.Net.Http;
using System.Threading.Tasks;
using System;

public class AITranscripts : MonoBehaviour
{
    private string apiUrl_chat = "http://metaverse.ohgiraffers.com:8080/scenario/streaming";


    //HttpClient httpClient;

    public Button aiTranscriptsButton;
    public TextMeshProUGUI aiTranscriptsButtonText;
    public TMP_InputField chatInputField;
    public TMP_InputField transcriptsInputField;

    bool isGeneratingBG = false;
    bool isGeneratingTS = false;

    void Start()
    {
        aiTranscriptsButton.onClick.RemoveAllListeners(); 
        aiTranscriptsButton.onClick.AddListener(AITranscriptsButtonEvent);

    }

    //    void Update()
    //    {
    //        if (isGeneratingBG)
    //        {
    //            transcriptsInputField.text = "대본 작성 중...";
    //        }
    //    }

    async Task PostJson(byte[] jsonData)
    {
        using var httpClient = new HttpClient();

        var request = new HttpRequestMessage(HttpMethod.Post, apiUrl_chat);

        //실시간 streaming 데이터 받도록
        request.Headers.Add("Accept", "text/event-stream");

        //헤더에 토큰 추가
        //request.Headers.Add("Authorization", "eyJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ0ZXN0QGdtYWlsLmNvbSIsInJvbGUiOiJST0xFX01FTUJFUiIsImlkIjoxLCJpYXQiOjE2OTk1OTAwNzQsImV4cCI6MTcwMjE4MjA3NH0.xOu9WQ3Q-ptAvqh-S8ll_iWZLP4lkse8MPDrgHzRHJ8");
        
        request.Content = new ByteArrayContent(jsonData);
        request.Content.Headers.Add("Content-Type", "application/json");

        try
        {
            using var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead);

            if (response.IsSuccessStatusCode)
            {
                using var stream = await response.Content.ReadAsStreamAsync();
                using var reader = new StreamReader(stream, Encoding.UTF8);

                while (!reader.EndOfStream)
                {
                    string line = await reader.ReadLineAsync();

                    /*Debug.Log(line);  //지우기*/

                    const string prefix = "data:";

                    if (line.StartsWith(prefix))
                    {
                        line = line.Substring(prefix.Length);
                    }

                    // Check if the line contains " |" and replace it with a newline
                    if (line.Contains("|"))
                    {
                        /*line = line.Replace("|", "\n\n");*/
                        transcriptsInputField.text += "\n\n";
                        Debug.Log("good");
                        continue;
                    }

                    transcriptsInputField.text += line;




                }
            }
            else
            {
                Debug.LogError($"Request failed: {response.StatusCode}");
            }
        }
        catch (Exception ex)
        {
            Debug.LogError($"Error: {ex.Message}");
        }
        finally
        {
            Debug.Log("전송 끝");
            HandleServerResponse();
        }
    }

    async void AITranscriptsButtonEvent()
    {
        string inputText = chatInputField.text;
        string json = "{\"text\":\"" + inputText + "\"}";

        aiTranscriptsButtonText.text = "작성중";
        aiTranscriptsButton.interactable = false;

        transcriptsInputField.text = "";


        byte[] jsonData = Encoding.UTF8.GetBytes(json);

        try
        {
            await PostJson(jsonData);
        }
        catch (Exception ex)
        {
            Debug.LogError($"Error: {ex.Message}");
        }
    }


    void HandleServerResponse()
    {
        aiTranscriptsButtonText.text = "작성";
        aiTranscriptsButton.interactable = true;
    }

}

@hhkim331

[hhkim331]

텍스트 스트리밍 되는 것 확인했습니다

[silverpoodle]

다행이네요! 빠른 확인 감사합니다!

[yechan-9208]

AI에서 Server로 데이터를 보낼때 줄 바꿈 처리 이슈

AI측에서 보내는 줄 바꿈 처리는 (empty)로 판단해야 할 거 같습니다!
오늘중에 통신 테스트를 해보고 싶은데 언제쯤 가능하시나요?

[silverpoodle]

지금 로그인 통신 테스트 중이라서 혹시 1시 괜찮으신가요?

[yechan-9208]

넵 가능합니다!

[silverpoodle]

넹 1시에 봬요~ 🙆‍♀️

[silverpoodle]

@hhkim331 개행문자가 인식 안되는 문제가 있었는데 해결했습니다! 코드 수정했는데 다시 한 번 확인 부탁드려요 감사합니다 😄