import json import os import re import streamlit as st from dotenv import load_dotenv from src.knob import range_knob, select_knob from src.orchestrator import run_album_pipeline load_dotenv(override=True) st.set_page_config(page_title="STUDIOBASE", page_icon="🎚️", layout="centered") # --------------------------------------------------------------------------- # RETRO SONY MÜZİK ÇALAR TEMASI # Streamlit'in kendi bileşenlerini (slider, radio, button, text_input) hiç # değiştirmeden, sadece CSS ile eski bir hi-fi cihazının kromlu/metalik # gövdesine, LCD ekranına ve döner potansiyometre (knob) görünümüne # büründürüyoruz. Fonksiyonellik (sürükleme, tıklama) aynen Streamlit # widget'larından geliyor; sadece görünüm retro. # --------------------------------------------------------------------------- st.markdown( """ """, unsafe_allow_html=True, ) def slugify(text: str) -> str: text = text.strip().lower() text = re.sub(r"[^a-z0-9ğüşıöç\s-]", "", text) text = re.sub(r"[\s]+", "-", text) return text or "album" class StreamlitProgressReporter: """Orkestratörün on_progress callback'ini alıp canlı olarak Streamlit arayüzüne yazan köprü. İki şeyi eş zamanlı günceller: 1) Ajan Pipeline diyagramı — hangi ajan şu an aktif, Söz Yazarı <-> Eleştirmen geri bildirim döngüsü ve iterasyon sayacı canlı görünür. 2) Ajan konuşma kartları — her ajanın ne söylediği/karar verdiği, renk kodlu ve Eleştirmen'in yapılandırılmış JSON kararı açıkça gösterilir (dinamik yönlendirmenin koddan değil modelin çıktısından geldiğini kanıtlamak için).""" def __init__(self, pipeline_placeholder, log_placeholder, track_containers): self.pipeline_placeholder = pipeline_placeholder self.log_placeholder = log_placeholder self.track_containers = track_containers self.messages: list[str] = [] self.active_node: str | None = None self.done_nodes: set[str] = set() self.iteration = 0 self.max_iterations = 0 self.last_critic_ok = True self._render_pipeline() # -- render yardımcıları ------------------------------------------------- def _render_log(self) -> None: html = ( f'

' f'{"".join(self.messages[-50:])}' f'

' f'' ) self.log_placeholder.markdown(html, unsafe_allow_html=True) def _msg(self, css_class: str, agent_label: str, icon: str, body_html: str) -> None: self.messages.append( f'

{icon} {agent_label}' f'{body_html}

' ) self._render_log() def _divider(self, text: str) -> None: self.messages.append(f'

{text}

') self._render_log() def _render_pipeline(self) -> None: def node(key: str, icon: str, label: str, glow: str) -> str: cls = "sb-pnode" style = "" if key == self.active_node: cls += " active" style = f' style="--glow:{glow}"' elif key in self.done_nodes: cls += " done" return f'

{icon}{label}

' critic_glow = "#22c55e" if self.last_critic_ok else "#f59e0b" loop_badge = f"İTR {self.iteration}/{self.max_iterations}" if self.max_iterations else "—" html = ( '

' + node("director", "🎬", "DİREKTÖR", "#3b82f6") + '

↓

' + '

' + node("lyricist", "✍️", "SÖZ YAZARI", "#8b5cf6") + f'

⟲

{loop_badge}

' + node("critic", "🎯", "ELEŞTİRMEN", critic_glow) + "

" + '

↓

' + node("visual", "🎨", "GÖRSEL AJAN", "#ec4899") + "

" ) self.pipeline_placeholder.markdown(html, unsafe_allow_html=True) # -- olay işleyici -------------------------------------------------------- def __call__(self, event: str, **kwargs) -> None: if event == "director_start": self.active_node = "director" self._render_pipeline() self._msg( "director", "KREATİF DİREKTÖR", "🎬", f"Tema alındı: {kwargs['theme']} — {kwargs['n_tracks']} parçalık " f"tracklist planlanıyor…", ) elif event == "director_done": self.done_nodes.add("director") self.active_node = None self._render_pipeline() self._msg( "director", "KREATİF DİREKTÖR", "🎬", f"Albüm başlığına karar verdim: {kwargs['album_title']}", ) elif event == "track_start": track = kwargs["track"] self.iteration = 0 self.max_iterations = 0 self.done_nodes.discard("lyricist") self.done_nodes.discard("critic") self._divider( f"— Parça {kwargs['index']}/{kwargs['total']}: {track.title} " f"({track.mood}) —" ) elif event == "lyricist_start": self.active_node = "lyricist" self.iteration = kwargs["iteration"] self.max_iterations = kwargs["max_iterations"] self._render_pipeline() if kwargs["iteration"] > 1: note = "Eleştirmenin geri bildirimini dikkate alarak sözü revize ediyorum…" else: note = "İlk taslağı yazıyorum…" self._msg( "lyricist", "SÖZ YAZARI", "✍️", f"İterasyon {kwargs['iteration']}/{kwargs['max_iterations']}: {note}", ) elif event == "lyricist_done": self.done_nodes.add("lyricist") preview = kwargs["track"].current_lyrics.strip().split("\n")[0][:50] self._msg("lyricist", "SÖZ YAZARI", "✍️", f"Taslak hazır → “{preview}…”") elif event == "critic_start": self.active_node = "critic" self._render_pipeline() self._msg( "critic-pending", "ELEŞTİRMEN", "🎯", "Hece ölçüsü, kafiye ve akıcılığı değerlendiriyorum…", ) elif event == "track_iteration": verdict = kwargs["verdict"] self.last_critic_ok = verdict["approved"] self.done_nodes.add("critic") self.active_node = None self._render_pipeline() cls = "critic-ok" if verdict["approved"] else "critic-revise" durum = "✅ ONAYLANDI" if verdict["approved"] else "🔁 REVİZYON İSTENDİ" routing = ( "parça finalize ediliyor" if verdict["approved"] else "söz yazarına geri dönülüyor (dinamik yönlendirme)" ) verdict_json = ( f'approved={str(verdict["approved"]).lower()} · ' f'issues={len(verdict["issues"])} · → {routing}' ) self._msg( cls, "ELEŞTİRMEN", "🎯", f"{durum} — {verdict['feedback']}" f'

{verdict_json}

', ) elif event == "track_done": track = kwargs["track"] container = self.track_containers[kwargs["index"] - 1] with container: st.markdown( f'

▶ {track.title}
' f'Mood: {track.mood} — ' f"{track.status} ({track.iterations_used} iterasyon)

", unsafe_allow_html=True, ) st.text_area( "Şarkı Sözü", value=track.current_lyrics, height=220, key=f"lyrics_{kwargs['index']}", label_visibility="collapsed", ) if track.critic_feedback_history: with st.expander("Revizyon Geçmişi"): for entry in track.critic_feedback_history: verdict_text = "Onaylandı" if entry.approved else "Revizyon istendi" st.markdown(f"- İterasyon {entry.iteration}: **{verdict_text}** — {entry.feedback}") elif event == "visual_start": self.active_node = "visual" self._render_pipeline() self._msg("visual", "GÖRSEL STİL AJANI", "🎨", "Albüm kapağı için görsel prompt üretiyorum…") elif event == "visual_done": self.done_nodes.add("visual") self.active_node = None self._render_pipeline() self._msg("visual", "GÖRSEL STİL AJANI", "🎨", "Tamamlandı.") # --------------------------------------------------------------------------- # CİHAZ ÖN PANELİ # --------------------------------------------------------------------------- st.markdown( """

STUDIOBASE.vst

STUDIOBASE

MULTI-AGENT MUSIC ENGINE

""", unsafe_allow_html=True, ) st.markdown('

ALBÜM TEMASI

', unsafe_allow_html=True) st.markdown('

', unsafe_allow_html=True) theme = st.text_input( "Albüm Teması", placeholder="ör. CYBERPUNK MELANKOLİ", label_visibility="collapsed" ) st.markdown("

", unsafe_allow_html=True) st.markdown('

KUMANDA PANELİ

', unsafe_allow_html=True) # Knobs Row (PARÇA & REVİZYON) knob_row_col1, knob_row_col2 = st.columns(2) with knob_row_col1: n_tracks = range_knob("PARÇA", min_value=1, max_value=8, value=4, key="n_tracks_knob") with knob_row_col2: max_iterations = range_knob("REVİZYON", min_value=1, max_value=5, value=3, key="max_iter_knob") st.markdown('

', unsafe_allow_html=True) # Toggles Row (SAĞLAYICI & MODEL) toggle_row_col1, toggle_row_col2 = st.columns(2) with toggle_row_col1: st.markdown('

SAĞLAYICI

', unsafe_allow_html=True) provider_options = ["ollama", "gemini", "anthropic"] saved_provider = st.session_state.get("provider_value", "gemini") default_provider_index = ( provider_options.index(saved_provider) if saved_provider in provider_options else 0 ) provider = st.radio( "SAĞLAYICI", options=provider_options, index=default_provider_index, horizontal=True, label_visibility="collapsed", key="provider_toggle" ) st.session_state["provider_value"] = provider ollama_models = ["qwen2.5:7b", "qwen2.5-coder:3b"] gemini_models = ["gemini-3.5-flash-lite", "gemini-3.6-flash", "gemini-2.5-flash", "gemini-2.5-pro"] anthropic_models = ["claude-sonnet-5", "claude-haiku-4-5", "claude-opus-5"] if provider == "ollama": model_options = ollama_models elif provider == "gemini": model_options = gemini_models else: model_options = anthropic_models friendly_names = { "qwen2.5:7b": "Qwen 7B", "qwen2.5-coder:3b": "Coder", "gemini-3.5-flash-lite": "Gemini 3.5 Lite", "gemini-3.6-flash": "Gemini 3.6 Flash", "gemini-2.5-flash": "Gemini 2.5 Flash", "gemini-2.5-pro": "Gemini Pro", "claude-sonnet-5": "Sonnet", "claude-haiku-4-5": "Haiku", "claude-opus-5": "Opus" } friendly_to_tech = {v: k for k, v in friendly_names.items()} model_friendly_options = [friendly_names.get(m, m) for m in model_options] model_default = st.session_state.get("model_value") if model_default not in model_options: model_default = model_options[0] default_friendly = friendly_names.get(model_default, model_default) default_index = model_friendly_options.index(default_friendly) if default_friendly in model_friendly_options else 0 with toggle_row_col2: st.markdown('

MODEL

', unsafe_allow_html=True) model_friendly = st.radio( "MODEL", options=model_friendly_options, index=default_index, horizontal=True, label_visibility="collapsed", key="model_toggle" ) model = friendly_to_tech.get(model_friendly, model_friendly) st.session_state["model_value"] = model generate_clicked = st.button("▶ PLAY — ALBÜM ÜRET", type="primary", use_container_width=True) st.markdown("

", unsafe_allow_html=True) # /sb-chassis # --------------------------------------------------------------------------- # ÜRETİM VE SONUÇLAR # --------------------------------------------------------------------------- if generate_clicked: os.environ["LLM_PROVIDER"] = provider if provider == "ollama": os.environ["OLLAMA_MODEL"] = model elif provider == "gemini": os.environ["GEMINI_MODEL"] = model else: os.environ["ANTHROPIC_MODEL"] = model if not theme.strip(): st.error("Lütfen bir albüm teması girin.") elif provider == "anthropic" and not os.environ.get("ANTHROPIC_API_KEY"): st.error( "ANTHROPIC_API_KEY tanımlı değil. Proje kökündeki `.env` dosyasına " "API anahtarınızı ekleyin (bkz. `.env.example`)." ) elif provider == "gemini" and not os.environ.get("GEMINI_API_KEY"): st.error( "GEMINI_API_KEY tanımlı değil. Proje kökündeki `.env` dosyasına " "Gemini API anahtarınızı ekleyin (Google AI Studio'dan alabilirsiniz)." ) else: st.markdown('

AJAN PIPELINE\'I

', unsafe_allow_html=True) pipeline_placeholder = st.empty() st.markdown('

AJAN KONUŞMA GÜNLÜĞÜ

', unsafe_allow_html=True) log_placeholder = st.empty() st.subheader("🎼 Parçalar") track_columns = st.columns(2) track_containers = [track_columns[i % 2].container() for i in range(n_tracks)] reporter = StreamlitProgressReporter(pipeline_placeholder, log_placeholder, track_containers) with st.spinner("Ajanlar çalışıyor..."): try: print(f"DEBUG: provider={provider}, env={os.environ.get('LLM_PROVIDER')}, gemini_key_set={bool(os.environ.get('GEMINI_API_KEY'))}, anthropic_key_set={bool(os.environ.get('ANTHROPIC_API_KEY'))}") album = run_album_pipeline( theme=theme, n_tracks=n_tracks, max_iterations=max_iterations, on_progress=reporter, ) except Exception as exc: # noqa: BLE001 - kullanıcıya net hata göstermek için st.error(f"Üretim sırasında hata oluştu: {exc}") st.stop() st.success(f"Albüm tamamlandı: **{album.album_title}**") if album.cover_art_prompt: st.subheader("🎨 Albüm Kapağı Görsel Prompt'u") st.info(album.cover_art_prompt) slug = slugify(album.album_title or theme) markdown_report = album.markdown_report() json_report = json.dumps(album.to_dict(), ensure_ascii=False, indent=2) st.subheader("📄 Tam Rapor") tab_md, tab_json = st.tabs(["Markdown", "JSON (State)"]) with tab_md: st.markdown(markdown_report) with tab_json: st.code(json_report, language="json") col1, col2 = st.columns(2) with col1: st.download_button( "⬇️ Markdown indir", data=markdown_report, file_name=f"{slug}.md", mime="text/markdown", use_container_width=True, ) with col2: st.download_button( "⬇️ JSON indir", data=json_report, file_name=f"{slug}.json", mime="application/json", use_container_width=True, ) else: st.caption("Yukarıdan bir tema girip PLAY'e basın.")

efe hamd

Published skills (1)

STUDIOBASE