| 
1 | 1 | import { json } from "@remix-run/server-runtime";  | 
2 | 2 | import {  | 
3 |  | -  BatchTriggerTaskResponse,  | 
4 | 3 |   BatchTriggerTaskV2RequestBody,  | 
5 | 4 |   BatchTriggerTaskV2Response,  | 
6 | 5 |   generateJWT,  | 
7 | 6 | } from "@trigger.dev/core/v3";  | 
8 | 7 | import { env } from "~/env.server";  | 
 | 8 | +import { AuthenticatedEnvironment, getOneTimeUseToken } from "~/services/apiAuth.server";  | 
 | 9 | +import { logger } from "~/services/logger.server";  | 
9 | 10 | import { createActionApiRoute } from "~/services/routeBuilders/apiBuilder.server";  | 
10 |  | -import { HeadersSchema } from "./api.v1.tasks.$taskId.trigger";  | 
11 | 11 | import { resolveIdempotencyKeyTTL } from "~/utils/idempotencyKeys.server";  | 
 | 12 | +import { determineEngineVersion } from "~/v3/engineVersion.server";  | 
 | 13 | +import { ServiceValidationError } from "~/v3/services/baseService.server";  | 
12 | 14 | import {  | 
13 | 15 |   BatchProcessingStrategy,  | 
14 | 16 |   BatchTriggerV2Service,  | 
15 | 17 | } from "~/v3/services/batchTriggerV2.server";  | 
16 |  | -import { ServiceValidationError } from "~/v3/services/baseService.server";  | 
 | 18 | +import { BatchTriggerV3Service } from "~/v3/services/batchTriggerV3.server";  | 
17 | 19 | import { OutOfEntitlementError } from "~/v3/services/triggerTask.server";  | 
18 |  | -import { AuthenticatedEnvironment, getOneTimeUseToken } from "~/services/apiAuth.server";  | 
19 |  | -import { logger } from "~/services/logger.server";  | 
20 |  | -import { z } from "zod";  | 
 | 20 | +import { HeadersSchema } from "./api.v1.tasks.$taskId.trigger";  | 
21 | 21 | 
 
  | 
22 | 22 | const { action, loader } = createActionApiRoute(  | 
23 | 23 |   {  | 
@@ -87,7 +87,11 @@ const { action, loader } = createActionApiRoute(  | 
87 | 87 |       resolveIdempotencyKeyTTL(idempotencyKeyTTL) ??  | 
88 | 88 |       new Date(Date.now() + 24 * 60 * 60 * 1000 * 30);  | 
89 | 89 | 
 
  | 
90 |  | -    const service = new BatchTriggerV2Service(batchProcessingStrategy ?? undefined);  | 
 | 90 | +    const version = await determineEngineVersion({ environment: authentication.environment });  | 
 | 91 | +    const service =  | 
 | 92 | +      version === "V1"  | 
 | 93 | +        ? new BatchTriggerV2Service(batchProcessingStrategy ?? undefined)  | 
 | 94 | +        : new BatchTriggerV3Service(batchProcessingStrategy ?? undefined);  | 
91 | 95 | 
 
  | 
92 | 96 |     try {  | 
93 | 97 |       const batch = await service.call(authentication.environment, body, {  | 
 | 
0 commit comments