1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package main
import (
"fmt"
"strings"
commonv1 "github.com/johnandersen777/socialweb-computer-kcp/api/common/v1alpha1"
eventsv1alpha1 "github.com/johnandersen777/socialweb-computer-kcp/api/events/v1alpha1"
"github.com/johnandersen777/socialweb-computer-kcp/api/v1alpha1"
)
func applyCommsOption(comms *v1alpha1.MarketComms, name, value string) (*v1alpha1.MarketComms, bool, error) {
switch name {
case "comms-mode", "comms-event-source":
default:
return comms, false, nil
}
if comms == nil {
comms = &v1alpha1.MarketComms{}
}
switch name {
case "comms-mode":
mode := v1alpha1.MarketCommsMode(strings.TrimSpace(value))
switch mode {
case v1alpha1.MarketCommsModeXRPC, v1alpha1.MarketCommsModeFirehose, v1alpha1.MarketCommsModeBoth:
default:
return comms, true, fmt.Errorf("--comms-mode %s: want XRPC, Firehose or Both", value)
}
comms.Mode = mode
case "comms-event-source":
for _, name := range splitList(value) {
comms.EventSourceRefs = append(comms.EventSourceRefs, commonv1.ObjectRef{Group: eventsv1alpha1.GroupName, Kind: eventsv1alpha1.EventSourceKind, Name: name})
}
}
return comms, true, nil
}
