UPDATE

app.py

@@ -2,6 +2,7 @@ import os
 import secrets
 import threading
 import gradio as gr
+from io import BytesIO
 from AudioFusion import Fusion
 
 from telethon.sync import TelegramClient, events, Button
@@ -136,130 +137,112 @@ with gr.Blocks(title="Audio Fusion") as iface:
 
 client = TelegramClient('session_name', API_ID, API_HASH)
 
+# Define the states for user interaction
+states = {}
 
-# Define the available commands
-commands = {
-    '/start': 'Welcome to Audio Bot! Send me an audio file to get started.',
-    '/help': 'List all available commands.',
-    '/trim': 'Trim the audio. Usage: /trim start_time end_time',
-    '/volume': 'Adjust volume. Usage: /volume level',
-    '/reverse': 'Reverse the audio.',
-    '/reverb': 'Apply reverb effect to the audio. Usage: /reverb roomSize damping width wetLevel dryLevel',
-    '/speedup': 'Increase the speed of the audio.',
-    '/slowdown': 'Decrease the speed of the audio.',
-    '/effect8D': 'Apply 8D effect to the audio. Usage: /effect8D panBoundary jumpPercentage timeLtoR volumeMultiplier', 
-    '/save': 'Save the modified audio. Usage: /save outputFileName',
-}
-
-@client.on(events.NewMessage(pattern='/start'))
 async def start_handler(event):
-    await event.respond(commands['/start'])
-
-@client.on(events.NewMessage(pattern='/help'))
-async def help_handler(event):
-    help_text = '\n'.join(f'{cmd}: {desc}' for cmd, desc in commands.items())
-    await event.respond(help_text)
-
-@client.on(events.NewMessage(incoming=True))
-async def audio_handler(event):
-    reply = await event.get_reply_message()
-    if event.message.media and event.message.media.document.mime_type.startswith('audio') and event.is_private:
-        msg = await event.reply("`Downloading...`")
-        # Download the audio file
-        file_path = await client.download_media(event.message, f"downloads/{event.sender.id}_audio.mp3")
-        return await msg.edit("`Downloaded successfully...`")
-    elif event.is_group and event.text.startswith("/edit") and reply:
-        if reply.media and reply.media.document.mime_type.startswith('audio'):
-            msg = await event.reply("`Downloading...`")
-            file_path = await reply.download_media(f"downloads/{event.sender.id}_audio.mp3")
-            # try:
-            #     # Load the audio file using your AudioFusion class
-            #     audio = Fusion.loadSound(file_path)
-            # except Fusion.InvalidMusicFileError as e:
-            #     await event.respond(f'Error: {e}')
-            #     return os.remove(file_path)
-            return await msg.edit("`Downloaded successfully...`")
-        else:
-            return await event.respond("`Please send an audio file...`")
-    else:
-        if event.is_private: return await event.respond("`Please send an audio file...`")
+    await event.reply("Welcome to AudioFusion Bot! Send me an audio file, and I'll apply effects for you.")
+
+buttons = [
+        [Button.inline('Slowed', b'slowed'), Button.inline('8D', b'8d')],
+        [Button.inline('Reverb', b'reverb'), Button.inline('Reverse', b'reverse')],
+        [Button.inline('Volume', b'volume'), Button.inline('Speedup', b'speedup')],
+        [Button.inline('Preview', b'preview')],
+        [Button.inline('Send', b'send')],
+    ]
+
+async def buttons_handler(event):
+    user_id = event.sender_id
+        
+    # Download the audio file and store it in the user's state
+    reply_message = await event.get_reply_message()
+    if not reply_message or not reply_message.file:
+        await event.reply("Please reply to an audio file.")
+        return
+
+    audio_file = BytesIO()
+    await event.client.download_media(reply_message, audio_file)
+    audio_file.seek(0)
     
+    # Store the audio file in the user's state
+    states[user_id] = audio_file
+
+    await client.send_file(event.chat_id, file="image.jpg", caption="Preview the current modification:", buttons=buttons)
+    
+
+async def audio_effect_handler(event):
+    user_id = event.sender_id
+    if user_id not in states or not states[user_id]:
+        await event.answer("`No audio file found. Please use /buttons command to upload an audio file.`")
+        return
+
+    # Retrieve the audio file from the user's state
+    audio_file = states[user_id]
 
-@client.on(events.NewMessage(incoming=True, pattern="/(edit|trim|volume|reverse|reverb|speedup|slowdown|effect8d|save|delete)"))
-async def audio_editor(event):
-    file_path = f"downloads/{event.sender.id}_audio.mp3"
-    if not os.path.exists(file_path): return
+    query = event.pattern_match.group(1).decode("UTF-8")
     try:
-        # Load the audio file using your AudioFusion class
-        audio = Fusion.loadSound(os.path.abspath(file_path))
-    except Fusion.InvalidMusicFileError as e:
-        await event.reply(f'Error: {e}')
-        return os.remove(file_path)
+        sound = Fusion.loadSound(audio_file)
+        if query == 'slowed':
+            modified_sound = Fusion.effectSlowed(sound, 0.82)
+        elif query == 'speedup':
+            modified_sound = Fusion.effectSlowed(sound, 1.2)
+        elif query == '8d':
+            modified_sound = Fusion.effect8D(sound)
+        elif query == 'reverb':
+            modified_sound = Fusion.effectReverb(sound)
+        elif query == 'reverse':
+            modified_sound = sound.reverse()
+
+        # Update the user's state with the modified sound
+        states[user_id] = modified_sound
+
+        await event.answer"Effect applied. Click 'Send' to receive the modified audio file.")
 
+    except Fusion.InvalidMusicFileError as e:
+        await event.reply(str(e))
+    except Exception as e:
+        await event.reply(f"An error occurred: {str(e)}")
+
+
+async def preview_handler(event):
+    user_id = event.sender_id
+    if user_id in states and states[user_id]:
+        # Send the current modification for preview
+        output_file_name = f"{user_id}_preview"
+        output_file = Fusion.saveSound(states[user_id], output_file_name)
+        await event.edit("`Uploading...`", buttons=buttons)
+        # Edit the message and send the audio file in the edited message
+        await event.edit(file=output_file, text="`Preview the current modification:`", buttons=buttons)
         
-    # Process the user's command
-    if event.raw_text.startswith('/trim'):
-        # Parse parameters and apply the trim effect
-        # Example usage: /trim 5000 10000
-        parameters = event.raw_text.split()[1:]
-        start_time, end_time = map(int, parameters)
-        audio = audio[start_time:end_time]
-        await event.reply("`Following effect added to your audio file...`")
-    
-    elif event.raw_text.startswith('/volume'):
-        # Parse parameters and adjust volume
-        # Example usage: /volume 3
-        parameters = event.raw_text.split()[1:]
-        volume_level = int(parameters[0])
-        audio = audio + volume_level  # Adjust volume using Pydub's volume adjustment
-        await event.reply("`Following effect added to your audio file...`")
-    
-    elif event.raw_text.startswith('/reverse'):
-        # Reverse the audio
-        audio = audio.reverse()
-        await event.reply("`Following effect added to your audio file...`")
-    
-    elif event.raw_text.startswith('/speedup'):
-        # Increase the speed of the audio
-        audio = Fusion.effectSlowed(audio, speedMultiplier=0.8)
-        await event.reply("`Following effect added to your audio file...`")
-    
-    elif event.raw_text.startswith('/slowdown'):
-        # Decrease the speed of the audio
-        audio = Fusion.effectSlowed(audio, speedMultiplier=1.2)
-        await event.reply("`Following effect added to your audio file...`")
-
-    elif event.raw_text.startswith('/effect8d'):
-        # Parse parameters and apply the effect
-        # Example usage: /effect8D 100 5 10000 6
-        parameters = event.raw_text.split()[1:]
-        audio = Fusion.effect8D(audio, *map(int, parameters))
-        await event.reply("`Following effect added to your audio file...`")
-    
-    elif event.raw_text.startswith('/reverb'):
-        # Parse parameters and apply the effect
-        # Example usage: /effectReverb 0.8 1 0.5 0.3 0.8
-        parameters = event.raw_text.split()[1:]
-        audio = Fusion.effectReverb(audio, *map(float, parameters))
-        await event.reply("`Following effect added to your audio file...`")
-    
-    elif event.raw_text.startswith('/save'):
-        # Parse parameters and save the modified audio
-        msg = await event.reply("`Uploading...`")
-        # Example usage: /save outputFileName
-        parameters = event.raw_text.split()[1:]
-        output_file_name = parameters[0]
-        output_file_path = Fusion.saveSound(audio, output_file_name)
-        
-        # Send the modified audio file to the user
-        await client.send_file(event.chat_id, output_file_path, caption=f'Modified audio: {output_file_name}.mp3')
-        await msg.delete()
-        # Clean up the temporary files
-        os.remove(output_file_path)
-            
-    elif event.raw_text.startswith('/delete'):
-        os.remove(file_path)
-        msg = await event.reply("`Removed saved audio...`")
+        # Clean up - remove the saved preview audio file
+        os.remove(output_file)
+    else:
+        await event.answer("`No modified audio file found. Please apply an effect first.`")
+
+
+async def send_handler(event):
+    user_id = event.sender_id
+    if user_id in states and states[user_id]:
+        # Send the modified sound file
+        output_file_name = f"{user_id}_modified_audio"
+        output_file = Fusion.saveSound(states[user_id], output_file_name)
+        await event.reply(file=output_file)
+
+        # Clean up - remove the user's state and the saved audio file
+        del states[user_id]
+        os.remove(output_file)
+        await event.delete()
+    else:
+        await event.answer("No modified audio file found. Please apply an effect first.")
+
+
+
+# Register command and button handlers
+client.on(events.NewMessage(pattern='/start')(start_handler))
+client.on(events.NewMessage(pattern='/buttons')(buttons_handler))
+client.on(events.CallbackQuery(pattern=b'(slowed|8d|reverb|reverse|trim|volume|speedup)')(audio_effect_handler))
+client.on(events.CallbackQuery(pattern=b'preview')(preview_handler))
+client.on(events.CallbackQuery(pattern=b'send')(send_handler))
 
 async def initiation():
     await client.send_message(-1001662130485, "**Hugging is Running.**", buttons=[(Button.url("Execal", "https://t.me/execal"),)],)