[WIP] Still need to test and refactor unit tests

plugins/grpc/forwarder.go

@@ -345,20 +345,35 @@ func (g *GRPCForwarder) SchedulerEvent(ctx context.Context, infos, fwdMetadata m
 
 //Forward send room or player status to specified server
 func (g *GRPCForwarder) Forward(ctx context.Context, event string, infos, fwdMetadata map[string]interface{}) (status int32, message string, err error) {
+
+	// Add forwarder metadata (from maestro config) to request
+	// Client metadata should take priority
+	metadata := g.config.GetStringMap("metadata")
+	fmt.Printf("\nARNALDO - metadata 1: %+v\n", metadata)
+	if metadata != nil {
+		for k := range fwdMetadata {
+			metadata[k] = fwdMetadata[k]
+		}
+	} else {
+		metadata = fwdMetadata
+	}
+
+	fmt.Printf("\nARNALDO - metadata 2: %+v\n", fwdMetadata)
+
 	l := g.logger.WithFields(log.Fields{
 		"op":          "Forward",
 		"source":      "plugin/grpc",
 		"event":       event,
 		"infos":       fmt.Sprintf("%v", infos),
-		"fwdMetadata": fmt.Sprintf("%v", fwdMetadata),
+		"fwdMetadata": fmt.Sprintf("%v", metadata),
 		"serverAddr":  g.serverAddress,
 	})
 	l.Info("forwarding event")
 	f := reflect.ValueOf(g).MethodByName(strings.Title(event))
 	if !f.IsValid() {
 		return 500, "", fmt.Errorf("error calling method %s in plugin", event)
 	}
-	ret := f.Call([]reflect.Value{reflect.ValueOf(ctx), reflect.ValueOf(infos), reflect.ValueOf(fwdMetadata)})
+	ret := f.Call([]reflect.Value{reflect.ValueOf(ctx), reflect.ValueOf(infos), reflect.ValueOf(metadata)})
 	err, ok := ret[2].Interface().(error)
 	if ok {
 		l.WithError(err).Error("forward event failed")