Enable go plugins to send events

Signed-off-by: Sam Foo <[email protected]>
Co-authored-by: Liam Rathke <[email protected]>

changelogs/unreleased/2691-GuessWhoSamFoo

@@ -0,0 +1 @@
+Added `SendEvent` for go plugins

pkg/plugin/api/client.go

@@ -8,6 +8,8 @@ package api
 import (
  "context"
 
+ "github.com/vmware-tanzu/octant/pkg/event"
+
  "google.golang.org/grpc"
  "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 
@@ -274,3 +276,22 @@ func (c *Client) CreateLink(ctx context.Context, key store.Key) (LinkResponse, e
  Link: *linkComponent,
  }, nil
 }
+
+// SendEvent sends an event
+func (c *Client) SendEvent(ctx context.Context, clientID string, eventName event.EventType, payload action.Payload) error {
+ client := c.DashboardConnection.Client()
+
+ data, err := convertFromPayload(payload)
+ if err != nil {
+ return err
+ }
+
+ eventRequest := &proto.EventRequest{
+ ClientID: clientID,
+ EventName: string(eventName),
+ Payload: data,
+ }
+
+ _, err = client.SendEvent(ctx, eventRequest)
+ return err
+}

pkg/plugin/api/conversion.go

@@ -6,6 +6,8 @@ SPDX-License-Identifier: Apache-2.0
 package api
 
 import (
+ "fmt"
+
  "github.com/golang/protobuf/ptypes"
  "github.com/golang/protobuf/ptypes/wrappers"
  "github.com/pkg/errors"
@@ -107,6 +109,22 @@ func convertToLinkComponent(in, name string) (*component.Link, error) {
  return link, nil
 }
 
+func convertFromPayload(payload action.Payload) ([]byte, error) {
+ return json.Marshal(payload)
+}
+
+func convertToEvent(in *proto.EventRequest) (string, string, action.Payload, error) {
+ if in == nil {
+ return "", "", action.Payload{}, fmt.Errorf("event request is nil")
+ }
+ payload := action.Payload{}
+ err := json.Unmarshal(in.Payload, &payload)
+ if err != nil {
+ return "", "", action.Payload{}, fmt.Errorf("unmarshal payload: %w", err)
+ }
+ return in.ClientID, in.EventName, payload, nil
+}
+
 func convertFromObjects(in *unstructured.UnstructuredList) ([][]byte, error) {
  var out [][]byte