1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
import discord
from discord.ext import commands
import asyncio
import os
import re
import subprocess
from dotenv import load_dotenv
load_dotenv()
TOKEN = os.getenv("DISCORD_TOKEN")
PIPE_PATH = os.getenv("PIPE_PATH", "/opt/spotify-bot/spotify_pipe")
ENV_DIR = "/etc/librespot"
intents = discord.Intents.default()
intents.message_content = True
intents.voice_states = True
bot = commands.Bot(command_prefix="!", intents=intents)
@bot.event
async def on_ready():
print(f"Bot is online as {bot.user}")
if not os.path.exists(ENV_DIR):
print(f"Warning: {ENV_DIR} does not exist. Please create it manually.")
@bot.event
async def on_voice_state_update(member, before, after):
vc = member.guild.voice_client
if vc and vc.channel:
human_members = [m for m in vc.channel.members if not m.bot]
if len(human_members) == 0:
print(f"No humans left in {vc.channel.name}. Disconnecting...")
await vc.disconnect()
@bot.command()
async def setup(ctx):
user_id = str(ctx.author.id)
await ctx.send("β³ **Spinning up your private server speaker...**")
subprocess.run(["sudo", "systemctl", "restart", f"librespot@{user_id}"])
subprocess.run(["sudo", "systemctl", "enable", f"librespot@{user_id}"])
await asyncio.sleep(2)
log_output = subprocess.run(
["journalctl", "-u", f"librespot@{user_id}", "-n", "20", "--no-pager"],
capture_output=True, text=True
).stdout
matches = re.findall(r"https://accounts\.spotify\.com/[^\s]+", log_output)
if matches:
oauth_url = matches[-1]
instructions = (
f"π **Step 1:** Click this link to log in and authorize your account:\n<{oauth_url}>\n\n"
f"β **Step 2:** After you click 'Agree', your browser will show a broken page saying **'Unable to connect'** or **'Firefox canβt connect to the server'**.\n"
f"**THIS IS NORMAL!** \n\n"
f"π **Step 3:** Look at your browser's top address bar, **copy the entire broken URL** (it starts with `http://127.0.0.1:5588...`), and reply to me here like this:\n"
f"`!auth <paste_your_broken_url>`"
)
await ctx.send(instructions)
else:
await ctx.send(
"β Hrm, I couldn't extract the authorization link. Ask the server owner to check the system logs.")
@bot.command()
async def auth(ctx, url: str):
# Safety check: Make sure they actually gave us the redirect URL
if "127.0.0.1:5588" not in url and "localhost:5588" not in url:
await ctx.send(
"β That doesn't look like the correct redirect link. Make sure you copy the URL from the broken page's address bar!")
return
await ctx.send("π **Forwarding authentication token to your speaker instance...**")
local_url = url.replace("localhost", "127.0.0.1")
result = subprocess.run(["curl", "-s", local_url], capture_output=True, text=True)
await ctx.send("π **Success! Your speaker is authenticated.** Check your Spotify app's 'Devices' menuβyour server speaker will appear shortly!")
@bot.command()
async def speaker_on(ctx):
discord_id = str(ctx.author.id)
try:
subprocess.run(["sudo", "systemctl", "start", f"librespot@{discord_id}"], check=True)
await ctx.send("π Your personal speaker is now **Online**.")
except subprocess.CalledProcessError:
await ctx.send("β Failed to start. Have you used `!setup` yet?")
@bot.command()
async def speaker_off(ctx):
discord_id = str(ctx.author.id)
try:
subprocess.run(["sudo", "systemctl", "stop", f"librespot@{discord_id}"], check=True)
await ctx.send("π Your personal speaker is now **Offline**.")
except subprocess.CalledProcessError:
await ctx.send("β Failed to stop the speaker.")
@bot.command()
async def join(ctx):
if ctx.author.voice:
await ctx.author.voice.channel.connect()
await ctx.send(f"Joined {ctx.author.voice.channel.name}")
else:
await ctx.send("You need to be in a voice channel first!")
if not hasattr(bot, "active_pipes"):
bot.active_pipes = {}
if not hasattr(bot, "active_loops"):
bot.active_loops = set()
@bot.command()
async def play(ctx):
vc = ctx.voice_client
if not vc:
return await ctx.send("Use !join first!")
discord_id = str(ctx.author.id)
user_pipe = f"/opt/spotify-bot/pipes/{discord_id}_pipe"
# Make sure their pipe actually exists
if not os.path.exists(user_pipe):
return await ctx.send("β I can't find your audio pipe! Have you run `!setup` or `!speaker_on`?")
guild_id = ctx.guild.id
bot.active_pipes[guild_id] = user_pipe
if vc.is_playing():
await ctx.send(f"π Swapping stream to {ctx.author.display_name}'s Spotify...")
vc.stop()
return
if guild_id not in bot.active_loops:
bot.active_loops.add(guild_id)
await ctx.send(f"π Hooking into {ctx.author.display_name}'s Spotify stream...")
ffmpeg_options = {
'before_options': '-f s16le -ar 44100 -ac 2',
'options': '-loglevel warning'
}
try:
while vc.is_connected():
if not vc.is_playing():
# ALWAYS fetch the latest pipe assigned to this server
current_pipe = bot.active_pipes.get(guild_id)
if current_pipe and os.path.exists(current_pipe):
try:
audio_source = discord.FFmpegPCMAudio(current_pipe, **ffmpeg_options)
transformed_source = discord.PCMVolumeTransformer(audio_source, volume=1.0)
vc.play(transformed_source)
print(f"Successfully connected voice client to current target pipe: {current_pipe}")
except discord.ClientException:
pass
except Exception as e:
print(f"Pipeline sync error: {e}")
await asyncio.sleep(1)
finally:
bot.active_loops.discard(guild_id)
bot.active_pipes.pop(guild_id, None)
@bot.command()
async def stop(ctx):
vc = ctx.voice_client
if vc:
await vc.disconnect()
await ctx.send("Disconnected.")
if TOKEN:
bot.run(TOKEN)
else:
print("Error: DISCORD_TOKEN not found in environment variables or .env file.")
|
