diff --git a/wwwroot/v1/media/asr-transcribe/index.dspy b/wwwroot/v1/media/asr-transcribe/index.dspy
new file mode 100644
index 0000000..e4d5de0
--- /dev/null
+++ b/wwwroot/v1/media/asr-transcribe/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - asr-transcribe
+# /v1/media/asr-transcribe
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'asr-transcribe'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/demucs-separate/index.dspy b/wwwroot/v1/media/demucs-separate/index.dspy
new file mode 100644
index 0000000..d3bae6f
--- /dev/null
+++ b/wwwroot/v1/media/demucs-separate/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - demucs-separate
+# /v1/media/demucs-separate
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'demucs-separate'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/face-compare/index.dspy b/wwwroot/v1/media/face-compare/index.dspy
new file mode 100644
index 0000000..a84ed2e
--- /dev/null
+++ b/wwwroot/v1/media/face-compare/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - face-compare
+# /v1/media/face-compare
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'face-compare'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/face-detect/index.dspy b/wwwroot/v1/media/face-detect/index.dspy
new file mode 100644
index 0000000..91e6de6
--- /dev/null
+++ b/wwwroot/v1/media/face-detect/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - face-detect
+# /v1/media/face-detect
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'face-detect'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/face-recognize/index.dspy b/wwwroot/v1/media/face-recognize/index.dspy
new file mode 100644
index 0000000..404666b
--- /dev/null
+++ b/wwwroot/v1/media/face-recognize/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - face-recognize
+# /v1/media/face-recognize
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'face-recognize'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/merge-video/index.dspy b/wwwroot/v1/media/merge-video/index.dspy
new file mode 100644
index 0000000..12f6231
--- /dev/null
+++ b/wwwroot/v1/media/merge-video/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - merge-video
+# /v1/media/merge-video
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'merge-video'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/realesrgan-status/index.dspy b/wwwroot/v1/media/realesrgan-status/index.dspy
new file mode 100644
index 0000000..d49011a
--- /dev/null
+++ b/wwwroot/v1/media/realesrgan-status/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - realesrgan-status
+# /v1/media/realesrgan-status
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'realesrgan-status'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/realesrgan-upscale/index.dspy b/wwwroot/v1/media/realesrgan-upscale/index.dspy
new file mode 100644
index 0000000..f04951b
--- /dev/null
+++ b/wwwroot/v1/media/realesrgan-upscale/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - realesrgan-upscale
+# /v1/media/realesrgan-upscale
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'realesrgan-upscale'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/rvc-convert/index.dspy b/wwwroot/v1/media/rvc-convert/index.dspy
new file mode 100644
index 0000000..8d733b5
--- /dev/null
+++ b/wwwroot/v1/media/rvc-convert/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - rvc-convert
+# /v1/media/rvc-convert
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'rvc-convert'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/songrate-evaluate/index.dspy b/wwwroot/v1/media/songrate-evaluate/index.dspy
new file mode 100644
index 0000000..3dbf0c2
--- /dev/null
+++ b/wwwroot/v1/media/songrate-evaluate/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - songrate-evaluate
+# /v1/media/songrate-evaluate
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'songrate-evaluate'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/subtitle-render/index.dspy b/wwwroot/v1/media/subtitle-render/index.dspy
new file mode 100644
index 0000000..85d5c74
--- /dev/null
+++ b/wwwroot/v1/media/subtitle-render/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - subtitle-render
+# /v1/media/subtitle-render
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'subtitle-render'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/synth-generate/index.dspy b/wwwroot/v1/media/synth-generate/index.dspy
new file mode 100644
index 0000000..114d5d8
--- /dev/null
+++ b/wwwroot/v1/media/synth-generate/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - synth-generate
+# /v1/media/synth-generate
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'synth-generate'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/synth-status/index.dspy b/wwwroot/v1/media/synth-status/index.dspy
new file mode 100644
index 0000000..a41a2e5
--- /dev/null
+++ b/wwwroot/v1/media/synth-status/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - synth-status
+# /v1/media/synth-status
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'synth-status'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)
diff --git a/wwwroot/v1/media/video-eval-evaluate/index.dspy b/wwwroot/v1/media/video-eval-evaluate/index.dspy
new file mode 100644
index 0000000..2cc3fa8
--- /dev/null
+++ b/wwwroot/v1/media/video-eval-evaluate/index.dspy
@@ -0,0 +1,37 @@
+# KTV Media API - video-eval-evaluate
+# /v1/media/video-eval-evaluate
+
+debug_params('params_kw', params_kw)
+
+userid = await get_user()
+userorgid = await get_userorgid()
+if userid is None:
+	return openai_403()
+
+catelogid = 'ktv_pipeline'
+model_name = 'video-eval-evaluate'
+params_kw.model = model_name
+params_kw.catelogid = catelogid
+
+env = request._run_ns
+async with get_sor_context(env, 'llmage') as sor:
+	sql = """select distinct a.* from llm a
+join llm_api_map m on a.id = m.llmid
+join llmcatelog b on m.llmcatelogid = b.id
+where (b.id = ${catelogid}$ OR b.name = ${catelogid}$)
+	and a.model=${model}$
+	and a.status = 'published'"""
+	recs = await sor.sqlExe(sql, {'catelogid': catelogid, 'model': model_name})
+	if len(recs) == 0:
+		return openai_400()
+	params_kw.llmid = recs[0].id
+	params_kw.llmcatelogid = catelogid
+
+f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
+if not f:
+	return openai_429()
+
+if not params_kw.transno:
+	import uuid; params_kw.transno = str(uuid.uuid4()).replace("-","")
+
+return await inference(request, env=env)