Moved routeid to eskip package

eskip/eskip.go

@@ -20,6 +20,8 @@ import (
 	"errors"
 	"fmt"
 	"strings"
+"regexp"
+"github.com/zalando/skipper/filters/flowid"
 )
 
 // Represents a matcher condition for incoming requests.
@@ -256,3 +258,26 @@ func ParseFilters(f string) ([]*Filter, error) {
 
 	return rs[0].filters, nil
 }
+
+const randomIdLength = 16
+
+var routeIdRx = regexp.MustCompile("\\W")
+
+// generate weak random id for a route if
+// it doesn't have one.
+func GenerateIfNeeded(existingId string) string {
+	if existingId != "" {
+		return existingId
+	}
+
+	// using this to avoid adding a new dependency.
+	id, err := flowid.NewFlowId(randomIdLength)
+	if err != nil {
+		return existingId
+	}
+
+	// replace characters that are not allowed
+	// for eskip route ids.
+	id = routeIdRx.ReplaceAllString(id, "x")
+	return "route" + id
+}

etcd/etcd.go

@@ -33,7 +33,6 @@ import (
 	log "github.com/Sirupsen/logrus"
 	"github.com/coreos/go-etcd/etcd"
 	"github.com/zalando/skipper/eskip"
-	"github.com/zalando/skipper/routeid"
 	"net/http"
 	"path"
 )
@@ -239,7 +238,7 @@ func (c *Client) Delete(id string) error {
 
 func (c *Client) UpsertAll(routes []*eskip.Route) error {
 	for _, r := range routes {
-		r.Id = routeid.GenerateIfNeeded(r.Id)
+		r.Id = eskip.GenerateIfNeeded(r.Id)
 		err := c.Upsert(r)
 		if err != nil {
 			return err

innkeeper/eskiptojson.go

@@ -2,7 +2,6 @@ package innkeeper
 
 import (
 	"github.com/zalando/skipper/eskip"
-	"github.com/zalando/skipper/routeid"
 )
 
 func convertPathMatcher(r *eskip.Route) *pathMatcher {
@@ -95,7 +94,7 @@ func convertEskipToInnkeeper(routes []*eskip.Route) (data []*routeData) {
 
 	for _, r := range routes {
 
-		id := routeid.GenerateIfNeeded(r.Id)
+		id := eskip.GenerateIfNeeded(r.Id)
 		host := convertHost(r)
 		method := convertMethod(r)
 		pathMatch := convertPathMatcher(r)