commune-ai commited on
Commit
30429df
1 Parent(s): 453429b

Create app.py

Browse files
Files changed (1) hide show
  1. app.py +301 -0
app.py ADDED
@@ -0,0 +1,301 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import gradio as gr
2
+ from requests.exceptions import ConnectTimeout
3
+ import time
4
+ import requests
5
+ import base64
6
+
7
+ global headers
8
+ global cancel_url
9
+ global path
10
+ path = ''
11
+ cancel_url =''
12
+ headers = {
13
+ 'Content-Type': 'application/json',
14
+ 'Authorization': 'Token r8_ZGZlzThfRkPZVDMygVclY1XZ9AuxmIQ2qwwPP',
15
+ "Access-Control-Allow-Headers": "Content-Type",
16
+ "Access-Control-Allow-Origin": '**',
17
+ "Access-Control-Allow-Methods": "OPTIONS,POST,GET,PATCH"}
18
+
19
+ with gr.Blocks() as demo:
20
+ owner = "lucataco"
21
+ name = "proteus-v0.3"
22
+ max_retries = 3
23
+ retry_delay = 2
24
+ for retry in range(max_retries):
25
+ try:
26
+ url = f'https://api.replicate.com/v1/models/{owner}/{name}'
27
+ response = requests.get(url, headers=headers, timeout=10)
28
+ # Process the response
29
+ break # Break out of the loop if the request is successful
30
+ except ConnectTimeout:
31
+ if retry < max_retries - 1:
32
+ print(f"Connection timed out. Retrying in {retry_delay} seconds...")
33
+ time.sleep(retry_delay)
34
+ else:
35
+ print("Max retries exceeded. Unable to establish connection.")
36
+
37
+ data = response.json()
38
+ description =data.get("description", '')
39
+ title = data.get("default_example",'').get("model",'')
40
+ version = data.get("default_example",'').get("version",'')
41
+
42
+ gr.Markdown(
43
+ f"""
44
+ # {title}
45
+ {description}
46
+ """)
47
+
48
+ with gr.Row():
49
+ with gr.Column():
50
+ inputs =[]
51
+ schema = data.get("latest_version", {}).get("openapi_schema", {}).get("components", {}).get("schemas", {})
52
+ ordered_properties = sorted(schema.get("Input", {}).get("properties", {}).items(), key=lambda x: x[1].get("x-order", 0))
53
+ required = schema.get("Input", '').get('required', [])
54
+ print(required,"required")
55
+ for property_name, property_info in ordered_properties :
56
+ if required:
57
+ for item in required:
58
+ if item == property_name:
59
+ label = "*"+ property_info.get('title', '')
60
+ description = property_info.get('description','')
61
+ break
62
+ else:
63
+ label = property_info.get('title', '')
64
+ description = property_info.get('description','')
65
+ else:
66
+ label = property_info.get('title', '')
67
+ description = property_info.get('description','')
68
+
69
+ if "x-order" in property_info:
70
+ order = int(property_info.get('x-order',''))
71
+ if property_info.get("type", {}) == "integer":
72
+ value= data.get('default_example', '').get('input','').get(property_name,0)
73
+ if "minimum" and "maximum" in property_info:
74
+ if value == 0:
75
+ inputs.insert(order, gr.Slider(label=label, info= description, value=property_info.get('default', value), minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', ''), step=1))
76
+ else:
77
+ inputs.insert(order, gr.Slider(label=label, info= description, value=value, minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', ''), step=1))
78
+ else:
79
+ if value == 0:
80
+ inputs.insert(order, gr.Number(label=label, info= description, value=property_info.get('default', value)))
81
+ else:
82
+ inputs.insert(order, gr.Number(label=label, info= description, value=value))
83
+
84
+ elif property_info.get("type", {}) == "string":
85
+ value= data.get('default_example', '').get('input','').get(property_name,'')
86
+ if property_info.get('format','') == 'uri':
87
+
88
+ if value :
89
+ inputs.insert(order, gr.Image(label=label, value=value, type="filepath"))
90
+ else :
91
+ inputs.insert(order, gr.Image(label=label, type="filepath"))
92
+
93
+ else:
94
+ if value == '':
95
+ inputs.insert(order, gr.Textbox(label=label,info= description, value=property_info.get('default', value)))
96
+ else:
97
+ inputs.insert(order, gr.Textbox(label=label,info= description, value=value))
98
+
99
+ elif property_info.get("type", {}) == "number":
100
+ value= data.get('default_example', '').get('input','').get(property_name, 0)
101
+ if "minimum" and "maximum" in property_info:
102
+ if value == 0:
103
+ inputs.insert(order, gr.Slider(label=label,info= description, value=property_info.get('default', value), minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', '')))
104
+ else:
105
+ inputs.insert(order, gr.Slider(label=label,info= description, value=value, minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', '')))
106
+ else:
107
+ if value == 0:
108
+ inputs.insert(order, gr.Number(label=label,info= description, value=property_info.get('default', value)))
109
+ else:
110
+ inputs.insert(order, gr.Number(label=label,info= description, value=value))
111
+ elif property_info.get("type", {}) == "boolean":
112
+ value= data.get('default_example', '').get('input','').get(property_name,'')
113
+ if value == '':
114
+ inputs.insert(order, gr.Checkbox(label=label,info= description, value=property_info.get('default', value)))
115
+ else:
116
+ inputs.insert(order, gr.Checkbox(label=label,info= description, value=value))
117
+ else:
118
+ value= data.get('default_example', '').get('input','').get(property_name,'')
119
+ options=schema.get(property_name,'').get('enum',[])
120
+ if value == '':
121
+ inputs.insert(order, gr.Dropdown(label=property_name,info= description,choices=options, value=property_info.get("default", value)))
122
+ else:
123
+ inputs.insert(order, gr.Dropdown(label=property_name,info= description,choices=options, value=value))
124
+
125
+ with gr.Row():
126
+ cancel_btn = gr.Button("Cancel")
127
+ run_btn = gr.Button("Run")
128
+
129
+ with gr.Column():
130
+
131
+ outputs = []
132
+ outputs.append(gr.Image(value='https://replicate.delivery/pbxt/C3LYYa30997dKRdeNDSXNjIK01CH5q8CSto12eWundnPPtWSA/out-0.png'))
133
+ outputs.append(gr.Image(visible=False))
134
+ outputs.append(gr.Image(visible=False))
135
+ outputs.append(gr.Image(visible=False))
136
+
137
+
138
+
139
+ def run_process(input1,input2,input3,input4,input5,input6,input7, input8, input9,input10,input11,input12, input13,input14):
140
+ global cancel_url
141
+ cancel_url=''
142
+ url = 'https://replicate.com/api/predictions'
143
+ if input3:
144
+ with open(input3, "rb") as file:
145
+ data = file.read()
146
+
147
+ base64_data = base64.b64encode(data).decode("utf-8")
148
+ mimetype = "image/jpg"
149
+ data_uri_image = f"data:{mimetype};base64,{base64_data}"
150
+ else:
151
+ data_uri_image=None
152
+
153
+ if input4:
154
+ with open(input4, "rb") as file:
155
+ data = file.read()
156
+
157
+ base64_data = base64.b64encode(data).decode("utf-8")
158
+ mimetype = "image/jpg"
159
+ data_uri_mask = f"data:{mimetype};base64,{base64_data}"
160
+ else:
161
+ data_uri_mask=None
162
+
163
+ if input3:
164
+ if input4:
165
+ body = {
166
+ "version": version,
167
+ "input": {
168
+ "prompt": input1,
169
+ "negative_prompt": input2,
170
+ "image": data_uri_image,
171
+ "mask": data_uri_mask,
172
+ "width": input5,
173
+ "height": input6,
174
+ "num_outputs": input7,
175
+ "scheduler": input8,
176
+ "num_inference_steps": input9,
177
+ "guidance_scale": input10,
178
+ "prompt_strength":input11,
179
+ "seed": input12,
180
+
181
+ }
182
+ }
183
+ else:
184
+ body = {
185
+ "version": version,
186
+ "input": {
187
+ "prompt": input1,
188
+ "negative_prompt": input2,
189
+ "image": data_uri_image,
190
+ "width": input5,
191
+ "height": input6,
192
+ "num_outputs": input7,
193
+ "scheduler": input8,
194
+ "num_inference_steps": input9,
195
+ "guidance_scale": input10,
196
+ "prompt_strength":input11,
197
+ "seed": input12,
198
+
199
+ }
200
+
201
+ }
202
+
203
+ else:
204
+ if input4:
205
+ body = {
206
+ "version": version,
207
+ "input": {
208
+ "prompt": input1,
209
+ "negative_prompt": input2,
210
+ "mask": data_uri_mask,
211
+ "width": input5,
212
+ "height": input6,
213
+ "num_outputs": input7,
214
+ "scheduler": input8,
215
+ "num_inference_steps": input9,
216
+ "guidance_scale": input10,
217
+ "prompt_strength":input11,
218
+ "seed": input12,
219
+
220
+ }
221
+ }
222
+ else:
223
+ body = {
224
+ "version": version,
225
+ "input": {
226
+ "prompt": input1,
227
+ "negative_prompt": input2,
228
+ "width": input5,
229
+ "height": input6,
230
+ "num_outputs": input7,
231
+ "scheduler": input8,
232
+ "num_inference_steps": input9,
233
+ "guidance_scale": input10,
234
+ "prompt_strength":input11,
235
+ "seed": input12,
236
+
237
+ }
238
+ }
239
+
240
+
241
+
242
+ response = requests.post(url, json=body)
243
+ print(response.status_code)
244
+ if response.status_code == 201:
245
+ response_data = response.json()
246
+ get_url = response_data.get('urls','').get('get','')
247
+ identifier = 'https://replicate.com/api/predictions/'+get_url.split("/")[-1]
248
+
249
+ print(identifier,'')
250
+ time.sleep(3)
251
+ output =verify_image(identifier)
252
+ print(output,'333')
253
+ if output:
254
+ if len(output) == 1:
255
+ return gr.Image(value=output[0]), gr.Image(),gr.Image(),gr.Image()
256
+ elif len(output) == 2:
257
+ return gr.Image(value=output[0]), gr.Image(value=output[1],visible= True),gr.Image(),gr.Image()
258
+ elif len(output) == 3:
259
+ return gr.Image(value=output[0]), gr.Image(value=output[1],visible= True),gr.Image(value=output[2],visible= True),gr.Image()
260
+ elif len(output) == 3:
261
+ return gr.Image(value=output[0]), gr.Image(value=output[1],visible= True),gr.Image(value=output[2],visible= True),gr.Image(value=output[2],visible= True)
262
+
263
+ return gr.Image(),gr.Image(visible=False),gr.Image(visible=False),gr.Image(visible=False)
264
+
265
+ def cancel_process(input1,input2,input3,input4,input5,input6,input7, input8, input9,input10,input11,input12, input13,input14):
266
+ global cancel_url
267
+ cancel_url = '123'
268
+ return gr.Image(value='https://replicate.delivery/pbxt/C3LYYa30997dKRdeNDSXNjIK01CH5q8CSto12eWundnPPtWSA/out-0.png'), gr.Image(visible=False),gr.Image(visible=False),gr.Image(visible=False)
269
+
270
+ def verify_image(get_url):
271
+ res = requests.get(get_url)
272
+ if res.status_code == 200:
273
+ res_data = res.json()
274
+ if res_data.get('error',''):
275
+ return
276
+ else:
277
+ if cancel_url:
278
+ return
279
+ else:
280
+ output = res_data.get('output', [])
281
+ print(output,'111')
282
+ if output:
283
+ print(output,'222')
284
+ return output
285
+
286
+ else:
287
+ time.sleep(1)
288
+ val = verify_image(get_url)
289
+ return val
290
+ else:
291
+ return []
292
+
293
+ run_btn.click(run_process, inputs=inputs, outputs=outputs, api_name="run")
294
+ cancel_btn.click(cancel_process, inputs=inputs, outputs=outputs, api_name="cancel")
295
+
296
+ demo.launch()
297
+
298
+
299
+
300
+
301
+