File size: 10,053 Bytes
58498f0
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
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
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
"""
나의 앱
멋지지
Generated by MOUSE Workflow
"""

import os
import json
import gradio as gr
import requests

# Workflow configuration
WORKFLOW_DATA = {
  "nodes": [
    {
      "id": "input_1",
      "type": "ChatInput",
      "position": {
        "x": 100,
        "y": 200
      },
      "data": {
        "label": "User Question",
        "template": {
          "input_value": {
            "value": "What is the capital of Korea?"
          }
        }
      }
    },
    {
      "id": "llm_1",
      "type": "llmNode",
      "position": {
        "x": 400,
        "y": 200
      },
      "data": {
        "label": "AI Processing",
        "template": {
          "provider": {
            "value": "VIDraft"
          },
          "model": {
            "value": "Gemma-3-r1984-27B"
          },
          "temperature": {
            "value": 0.7
          },
          "system_prompt": {
            "value": "You are a helpful assistant."
          }
        }
      }
    },
    {
      "id": "output_1",
      "type": "ChatOutput",
      "position": {
        "x": 700,
        "y": 200
      },
      "data": {
        "label": "Answer"
      }
    }
  ],
  "edges": [
    {
      "id": "e1",
      "source": "input_1",
      "target": "llm_1"
    },
    {
      "id": "e2",
      "source": "llm_1",
      "target": "output_1"
    }
  ]
}

def execute_workflow(*input_values):
    """Execute the workflow with given inputs"""
    
    # API keys from environment
    vidraft_token = os.getenv("FRIENDLI_TOKEN")
    openai_key = os.getenv("OPENAI_API_KEY")
    
    nodes = WORKFLOW_DATA.get("nodes", [])
    edges = WORKFLOW_DATA.get("edges", [])
    
    results = {}
    
    # Get input nodes
    input_nodes = [n for n in nodes if n.get("type") in ["ChatInput", "textInput", "Input", "numberInput"]]
    
    # Map inputs to node IDs
    for i, node in enumerate(input_nodes):
        if i < len(input_values):
            results[node["id"]] = input_values[i]
    
    # Process nodes
    for node in nodes:
        node_id = node.get("id")
        node_type = node.get("type", "")
        node_data = node.get("data", {})
        template = node_data.get("template", {})
        
        if node_type == "textNode":
            # Combine connected inputs
            base_text = template.get("text", {}).get("value", "")
            connected_inputs = []
            
            for edge in edges:
                if edge.get("target") == node_id:
                    source_id = edge.get("source")
                    if source_id in results:
                        connected_inputs.append(f"{source_id}: {results[source_id]}")
            
            if connected_inputs:
                results[node_id] = f"{base_text}\n\nInputs:\n" + "\n".join(connected_inputs)
            else:
                results[node_id] = base_text
                
        elif node_type in ["llmNode", "OpenAIModel", "ChatModel"]:
            # Get provider and model - VIDraft as default
            provider = template.get("provider", {}).get("value", "VIDraft")
            if provider not in ["VIDraft", "OpenAI"]:
                provider = "VIDraft"  # Default to VIDraft
            temperature = template.get("temperature", {}).get("value", 0.7)
            system_prompt = template.get("system_prompt", {}).get("value", "")
            
            # Get input text
            input_text = ""
            for edge in edges:
                if edge.get("target") == node_id:
                    source_id = edge.get("source")
                    if source_id in results:
                        input_text = results[source_id]
                        break
            
            # Call API
            if provider == "OpenAI" and openai_key:
                try:
                    from openai import OpenAI
                    client = OpenAI(api_key=openai_key)
                    
                    messages = []
                    if system_prompt:
                        messages.append({"role": "system", "content": system_prompt})
                    messages.append({"role": "user", "content": input_text})
                    
                    response = client.chat.completions.create(
                        model="gpt-4.1-mini",
                        messages=messages,
                        temperature=temperature,
                        max_tokens=1000
                    )
                    
                    results[node_id] = response.choices[0].message.content
                except Exception as e:
                    results[node_id] = f"[OpenAI Error: {str(e)}]"
                    
            elif provider == "VIDraft" and vidraft_token:
                try:
                    headers = {
                        "Authorization": f"Bearer {vidraft_token}",
                        "Content-Type": "application/json"
                    }
                    
                    messages = []
                    if system_prompt:
                        messages.append({"role": "system", "content": system_prompt})
                    messages.append({"role": "user", "content": input_text})
                    
                    payload = {
                        "model": "dep89a2fld32mcm",
                        "messages": messages,
                        "max_tokens": 16384,
                        "temperature": temperature,
                        "top_p": 0.8,
                        "stream": False
                    }
                    
                    response = requests.post(
                        "https://api.friendli.ai/dedicated/v1/chat/completions",
                        headers=headers,
                        json=payload,
                        timeout=30
                    )
                    
                    if response.status_code == 200:
                        results[node_id] = response.json()["choices"][0]["message"]["content"]
                    else:
                        results[node_id] = f"[VIDraft Error: {response.status_code}]"
                except Exception as e:
                    results[node_id] = f"[VIDraft Error: {str(e)}]"
            else:
                # Show which API key is missing
                if provider == "OpenAI":
                    results[node_id] = "[OpenAI API key not found. Please set OPENAI_API_KEY in Space secrets]"
                elif provider == "VIDraft":
                    results[node_id] = "[VIDraft API key not found. Please set FRIENDLI_TOKEN in Space secrets]"
                else:
                    results[node_id] = f"[No API key found for {provider}. Using simulated response: {input_text[:50]}...]"
                
        elif node_type in ["ChatOutput", "textOutput", "Output"]:
            # Get connected result
            for edge in edges:
                if edge.get("target") == node_id:
                    source_id = edge.get("source")
                    if source_id in results:
                        results[node_id] = results[source_id]
                        break
    
    # Return outputs
    output_nodes = [n for n in nodes if n.get("type") in ["ChatOutput", "textOutput", "Output"]]
    return [results.get(n["id"], "") for n in output_nodes]

# Build UI
with gr.Blocks(title="나의 앱", theme=gr.themes.Soft()) as demo:
    gr.Markdown("# 나의 앱")
    gr.Markdown("멋지지")
    
    # API Status Check
    vidraft_token = os.getenv("FRIENDLI_TOKEN")
    openai_key = os.getenv("OPENAI_API_KEY")
    
    with gr.Accordion("🔑 API Status", open=False):
        if vidraft_token:
            gr.Markdown("✅ **VIDraft API**: Connected (Gemma-3-r1984-27B)")
        else:
            gr.Markdown("❌ **VIDraft API**: Not configured")
            
        if openai_key:
            gr.Markdown("✅ **OpenAI API**: Connected (gpt-4.1-mini)")
        else:
            gr.Markdown("⚠️ **OpenAI API**: Not configured (optional)")
        
        if not vidraft_token:
            gr.Markdown("""
            **⚠️ Important**: Please add FRIENDLI_TOKEN to Space secrets for the app to work properly.
            
            Go to: Space settings → Repository secrets → Add secret
            """)
        elif not openai_key:
            gr.Markdown("""
            **💡 Tip**: The app will work with VIDraft alone. Add OPENAI_API_KEY if you need OpenAI features.
            """)
        else:
            gr.Markdown("**✨ All APIs configured! Your app is fully functional.**")
    
    # Extract nodes
    nodes = WORKFLOW_DATA.get("nodes", [])
    input_nodes = [n for n in nodes if n.get("type") in ["ChatInput", "textInput", "Input", "numberInput"]]
    output_nodes = [n for n in nodes if n.get("type") in ["ChatOutput", "textOutput", "Output"]]
    
    # Create inputs
    inputs = []
    if input_nodes:
        gr.Markdown("### 📥 Inputs")
        for node in input_nodes:
            label = node.get("data", {}).get("label", node.get("id"))
            template = node.get("data", {}).get("template", {})
            default_value = template.get("input_value", {}).get("value", "")
            
            if node.get("type") == "numberInput":
                inp = gr.Number(label=label, value=float(default_value) if default_value else 0)
            else:
                inp = gr.Textbox(label=label, value=default_value, lines=2)
            inputs.append(inp)
    
    # Execute button
    btn = gr.Button("🚀 Execute Workflow", variant="primary")
    
    # Create outputs
    outputs = []
    if output_nodes:
        gr.Markdown("### 📤 Outputs")
        for node in output_nodes:
            label = node.get("data", {}).get("label", node.get("id"))
            out = gr.Textbox(label=label, interactive=False, lines=3)
            outputs.append(out)
    
    # Connect
    btn.click(fn=execute_workflow, inputs=inputs, outputs=outputs)
    
    gr.Markdown("---")
    gr.Markdown("*Powered by MOUSE Workflow*")

if __name__ == "__main__":
    demo.launch()