File tree Expand file tree Collapse file tree 1 file changed +16
-2
lines changed Expand file tree Collapse file tree 1 file changed +16
-2
lines changed Original file line number Diff line number Diff line change @@ -280,8 +280,8 @@ func (c *codeConfig) ToStack() (*stack.Stack, error) {
280
280
}
281
281
errs := utils .NewErrorList ()
282
282
for handler , f := range c .functions {
283
- name := strings . Replace ( path . Base ( handler ), path . Ext ( handler ), "" , 1 )
284
- s . Functions [ name ] = stack. Function { Handler : handler }
283
+ name := containerNameFromHandler ( handler )
284
+
285
285
for k , v := range f .apis {
286
286
if current , ok := s .Apis [k ]; ok {
287
287
if current != v .workers [0 ].String () {
@@ -343,6 +343,20 @@ func (c *codeConfig) ToStack() (*stack.Stack, error) {
343
343
s .Topics [k ] = v .String ()
344
344
}
345
345
}
346
+
347
+ topicTriggers := make ([]string , len (f .subscriptions ), 0 )
348
+ for k := range f .subscriptions {
349
+ topicTriggers = append (topicTriggers , k )
350
+ }
351
+
352
+ s .Functions [name ] = stack.Function {
353
+ Handler : handler ,
354
+ ComputeUnit : stack.ComputeUnit {
355
+ Triggers : stack.Triggers {
356
+ Topics : topicTriggers ,
357
+ },
358
+ },
359
+ }
346
360
}
347
361
348
362
return s , errs .Aggregate ()
You can’t perform that action at this time.
0 commit comments