Code
    RPS Digital P3 Intake ArchiveUpdated May 10, 2026TS

    RPS Digital P3 Intake Archive Api.Prompts source

    Imported TypeScript file from ../../app/app/routes/api.prompts.ts.

    Source file

    ../../app/app/routes/api.prompts.ts

    TypeScript87 lines
    1. import { json, type ActionFunctionArgs } from '@remix-run/node';
    2. import { randomUUID } from 'node:crypto';
    3. import path from 'node:path';
    4. import { getPromptProvider } from '../ai/provider.server';
    5. import { createJob, createPrompt, createProduct, createRelease, updateProductCurrentRelease } from '../db.server';
    6. import { buildObjectKeyPrefix } from '../../../shared/pipeline';
    7. import { requireInstalledShop } from '../authz.server';
    9. export async function action({ request }: ActionFunctionArgs) {
    10. if (request.method !== 'POST') {
    11. return json({ error: 'Method not allowed' }, { status: 405 });
    12. }
    14. const contentType = request.headers.get('content-type') || '';
    15. let body: Record<string, unknown> = {};
    16. try {
    17. body = contentType.includes('application/json')
    18. ? ((await request.json()) as Record<string, unknown>)
    19. : (Object.fromEntries(await request.formData()) as Record<string, unknown>);
    20. } catch {
    21. return json({ error: 'Invalid request body' }, { status: 400 });
    22. }
    24. const access = requireInstalledShop(request, body);
    25. if (access instanceof Response) return access;
    27. const prompt = String(body.prompt || '');
    28. const shopId = access.shopId;
    29. const sku = String(body.sku || `sku-${Date.now()}`);
    30. const release = String(body.release || 'v1');
    31. const prefixBase = String(body.prefixBase || (process.env.GCS_PREFIX || 'products'));
    33. if (!prompt.trim()) {
    34. return json({ error: 'Prompt is required' }, { status: 400 });
    35. }
    37. const provider = getPromptProvider();
    38. const outputDir = path.resolve(process.cwd(), 'tmp', `prompt-${randomUUID()}`);
    39. const generated = await provider.generateFromPrompt(prompt, outputDir);
    41. const promptId = createPrompt({
    42. shopId,
    43. rawPrompt: prompt,
    44. provider: generated.provider,
    45. model: generated.model,
    46. outputSummary: JSON.stringify(generated.metadata),
    47. });
    49. const productId = createProduct({ shopId, promptId });
    50. const releaseId = createRelease({ productId, version: release, status: 'draft' });
    51. updateProductCurrentRelease({ productId, releaseId });
    53. const objectKeyPrefix = buildObjectKeyPrefix(prefixBase, sku, release);
    54. let options = body.options || {};
    55. if (typeof options === 'string') {
    56. try {
    57. options = JSON.parse(options);
    58. } catch {
    59. options = {};
    60. }
    61. }
    62. const jobId = createJob({
    63. shopId,
    64. type: 'prompt',
    65. inputPayload: JSON.stringify({
    66. pipeline: {
    67. artPath: generated.imagePath,
    68. roomBgPath: body.roomBgPath || null,
    69. sku,
    70. release,
    71. outputDir,
    72. objectKeyPrefix,
    73. options,
    74. },
    75. metadata: generated.metadata,
    76. releaseId,
    77. productId,
    78. }),
    79. });
    81. return json({
    82. jobId,
    83. productId,
    84. releaseId,
    85. metadata: generated.metadata,
    86. });
    87. }