From 6acf38fac191f8eb58095156cd2835e538da21d8 Mon Sep 17 00:00:00 2001
From: Siddharth Gelera <ahoy@barelyhuman.dev>
Date: Wed, 24 Sep 2025 15:42:28 +0530
Subject: [PATCH] refactor: replace decoder with type in WebSocket message
 handling

---
 .../components/RequestPane/WsBody/index.js    | 23 +++++++++++++++++--
 .../bruno-app/src/utils/collections/index.js  |  4 ++--
 packages/bruno-lang/v2/src/bruToJson.js       |  6 ++---
 packages/bruno-lang/v2/src/jsonToBru.js       |  6 ++---
 .../bruno-schema/src/collections/index.js     |  2 +-
 5 files changed, 30 insertions(+), 11 deletions(-)

diff --git a/packages/bruno-app/src/components/RequestPane/WsBody/index.js b/packages/bruno-app/src/components/RequestPane/WsBody/index.js
index 47cc74cd7..8010df8e6 100644
--- a/packages/bruno-app/src/components/RequestPane/WsBody/index.js
+++ b/packages/bruno-app/src/components/RequestPane/WsBody/index.js
@@ -41,12 +41,31 @@ const SingleWSMessage = ({
   const { name, content, decoder } = message;
   const [messageFormat, setMessageFormat] = useState(autoDetectLang(content));
 
+  const onUpdateMessageType = mode => {
+    setMessageFormat(mode)
+    
+    const currentMessages = [...(body.ws || [])];
+
+    currentMessages[index] = {
+      ...currentMessages[index],
+      type: DECODER_BY_TYPE[messageFormat],
+    };
+
+    dispatch(
+      updateRequestBody({
+        content: currentMessages,
+        itemUid: item.uid,
+        collectionUid: collection.uid
+      })
+    );
+  }
+
   const onEdit = (value) => {
     const currentMessages = [...(body.ws || [])];
 
     currentMessages[index] = {
       name: name ? name : `message ${index + 1}`,
-      decoder: DECODER_BY_TYPE[messageFormat],
+      type: DECODER_BY_TYPE[messageFormat],
       content: value
     };
 
@@ -153,7 +172,7 @@ const SingleWSMessage = ({
           )}
         </div>
         <div className="flex items-center gap-2" onClick={(e) => e.stopPropagation()}>
-          <WSRequestBodyMode mode={messageFormat} onModeChange={setMessageFormat} />
+          <WSRequestBodyMode mode={messageFormat} onModeChange={onUpdateMessageType} />
           <ToolHint text="Prettify" toolhintId={`prettify-msg-${index}`}>
             <button
               onClick={onPrettify}
diff --git a/packages/bruno-app/src/utils/collections/index.js b/packages/bruno-app/src/utils/collections/index.js
index b3aeae079..19d0682ca 100644
--- a/packages/bruno-app/src/utils/collections/index.js
+++ b/packages/bruno-app/src/utils/collections/index.js
@@ -666,9 +666,9 @@ export const transformRequestToSaveToFilesystem = (item) => {
   if (itemToSave.request.body.mode === 'ws') {
     itemToSave.request.body = {
       ...itemToSave.request.body,
-      ws: itemToSave.request.body.ws.map(({ name, content, decoder }, index) => ({
+      ws: itemToSave.request.body.ws.map(({ name, content, type }, index) => ({
         name: name ? name : `message ${index + 1}`,
-        decoder,
+        type,
         content: replaceTabsWithSpaces(content)
       }))
     };
diff --git a/packages/bruno-lang/v2/src/bruToJson.js b/packages/bruno-lang/v2/src/bruToJson.js
index bd70d18bd..2a9b10d72 100644
--- a/packages/bruno-lang/v2/src/bruToJson.js
+++ b/packages/bruno-lang/v2/src/bruToJson.js
@@ -1011,11 +1011,11 @@ const sem = grammar.createSemantics().addAttribute('ast', {
     const pairs = mapPairListToKeyValPairs(dictionary.ast, false);
     const namePair = _.find(pairs, { name: 'name' });
     const contentPair = _.find(pairs, { name: 'content' });
-    const decoderPair = _.find(pairs, { name: 'decoder' });
+    const typePair = _.find(pairs, { name: 'type' });
 
     const messageName = namePair ? namePair.value : '';
     const messageContent = contentPair ? contentPair.value : '';
-    const decoderContent =  decoderPair ? decoderPair.value : '';
+    const messageTypeContent =  typePair ? typePair.value : '';
 
     return {
       body: {
@@ -1023,7 +1023,7 @@ const sem = grammar.createSemantics().addAttribute('ast', {
         ws: [
           {
             name: messageName,
-            decoder: decoderContent,
+            type: messageTypeContent,
             content: messageContent
           }
         ]
diff --git a/packages/bruno-lang/v2/src/jsonToBru.js b/packages/bruno-lang/v2/src/jsonToBru.js
index 0dc456131..affbf9f13 100644
--- a/packages/bruno-lang/v2/src/jsonToBru.js
+++ b/packages/bruno-lang/v2/src/jsonToBru.js
@@ -635,13 +635,13 @@ ${indentString(body.sparql)}
     // Convert each ws message to a separate body:ws block
     if (Array.isArray(body.ws)) {
       body.ws.forEach((m) => {
-        const { name, content, decoder = "" } = m;
+        const { name, content, type = "" } = m;
 
         bru += `body:ws {\n`;
 
         bru += `${indentString(`name: ${getValueString(name)}`)}\n`;
-        if(decoder.length){
-          bru += `${indentString(`decoder: ${getValueString(decoder)}`)}\n`;
+        if(type.length){
+          bru += `${indentString(`type: ${getValueString(type)}`)}\n`;
         }
 
         // Convert content to JSON string if it's an object
diff --git a/packages/bruno-schema/src/collections/index.js b/packages/bruno-schema/src/collections/index.js
index 92949bf31..5da66fc00 100644
--- a/packages/bruno-schema/src/collections/index.js
+++ b/packages/bruno-schema/src/collections/index.js
@@ -389,7 +389,7 @@ const wsRequestSchema = Yup.object({
       .of(
         Yup.object({
           name: Yup.string().nullable(),
-          decoder: Yup.string().nullable(),
+          type: Yup.string().nullable(),
           content: Yup.string().nullable()
         })
       )