File tree Expand file tree Collapse file tree 2 files changed +9
-6
lines changed Expand file tree Collapse file tree 2 files changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -105,7 +105,7 @@ export function createManagerRouter(
105
105
}
106
106
107
107
function addServerlessRoutes (
108
- serverlessActorDriverBuilder : ( ) => ActorDriver ,
108
+ serverlessActorDriverBuilder : ( token : string | undefined ) => ActorDriver ,
109
109
router : OpenAPIHono ,
110
110
cors : MiddlewareHandler ,
111
111
) {
@@ -118,7 +118,7 @@ function addServerlessRoutes(
118
118
119
119
// Serverless start endpoint
120
120
router . get ( "/start" , cors , async ( c ) => {
121
- const actorDriver = serverlessActorDriverBuilder ( ) ;
121
+ const actorDriver = serverlessActorDriverBuilder ( c . req . header ( "x-rivet-token" ) ) ;
122
122
invariant (
123
123
actorDriver . serverlessHandleStart ,
124
124
"missing serverlessHandleStart on ActorDriver" ,
@@ -169,9 +169,9 @@ function addManagerRoutes(
169
169
170
170
const actorIdsParsed = actor_ids
171
171
? actor_ids
172
- . split ( "," )
173
- . map ( ( id ) => id . trim ( ) )
174
- . filter ( ( id ) => id . length > 0 )
172
+ . split ( "," )
173
+ . map ( ( id ) => id . trim ( ) )
174
+ . filter ( ( id ) => id . length > 0 )
175
175
: undefined ;
176
176
177
177
const actors : ActorOutput [ ] = [ ] ;
Original file line number Diff line number Diff line change @@ -215,7 +215,10 @@ export class Registry<A extends RegistryActors> {
215
215
console . log ( ) ;
216
216
}
217
217
218
- let serverlessActorDriverBuilder : ( ( ) => ActorDriver ) | undefined = ( ) => {
218
+ let serverlessActorDriverBuilder : ( ( token ?: string ) => ActorDriver ) | undefined = ( token : string | undefined ) => {
219
+ // Override config token if one was set
220
+ if ( token ) config . token = token ;
221
+
219
222
return driver . actor ( this . #config, config , managerDriver , client ) ;
220
223
} ;
221
224
You can’t perform that action at this time.
0 commit comments