Update to use dep, fix validation on fn IDs

actor/api.go

@@ -339,7 +339,7 @@ func (m *actorManager) StreamEvents(gr *model.StreamGraphRequest, stream model.F
 		func(event *persistence.StreamEvent) {
 			msg, ok := event.Event.(model.StreamableGraphEvent)
 			if !ok {
-				m.log.Info("Skipping unknown message %v", reflect.TypeOf(event.Event))
+				m.log.Infof("Skipping unknown message %v", reflect.TypeOf(event.Event))
 				return
 			}
 

actor/graph.go

@@ -5,8 +5,6 @@ import (
 	"reflect"
 	"time"
 
-	"regexp"
-
 	"github.com/AsynkronIT/protoactor-go/actor"
 	protoPersistence "github.com/AsynkronIT/protoactor-go/persistence"
 	"github.com/fnproject/flow/graph"
@@ -205,10 +203,7 @@ func (g *graphActor) receiveCommand(cmd model.Command, context actor.Context) {
 		g.log.Debug("Adding invoke stage")
 		stageID := g.graph.NextStageID()
 
-		realFunctionID, err := resolveFunctionID(g.graph.FunctionID, msg.FunctionId)
-		if err != nil {
-			panic(fmt.Sprintf("Unable to parse function ID (%s | %s): %s", g.graph.FunctionID, msg.FunctionId, err))
-		}
+		realFunctionID := msg.FunctionId
 
 		g.persistAndUpdateGraph(&model.StageAddedEvent{
 			FlowId:       msg.FlowId,
@@ -315,23 +310,6 @@ func (g *graphActor) receiveCommand(cmd model.Command, context actor.Context) {
 	}
 }
 
-var appIDRegex = regexp.MustCompile("^([^/]+)/(.*)$")
-
-func resolveFunctionID(original string, relative string) (string, error) {
-	orig, err := model.ParseFunctionID(original)
-	if err != nil {
-		return "", err
-	}
-	rel, err := model.ParseFunctionID(relative)
-	if err != nil {
-		return "", err
-	}
-
-	if rel.AppID == "." {
-		rel.AppID = orig.AppID
-	}
-	return rel.String(), nil
-}
 
 func (g *graphActor) receiveMessage(context actor.Context) {
 	switch msg := context.Message().(type) {