MG-36 - Global ticker for scheduled rules

Makefile

@@ -66,7 +66,7 @@ define make_docker_dev
 		-f docker/Dockerfile.dev ./build
 endef
 
-ADDON_SERVICES = bootstrap journal provision certs timescale-reader timescale-writer postgres-reader postgres-writer
+ADDON_SERVICES = bootstrap journal provision certs timescale-reader timescale-writer postgres-reader postgres-writer re
 
 EXTERNAL_SERVICES = vault prometheus
 

cmd/re/main.go

@@ -181,6 +181,11 @@ func main() {
 		go chc.CallHome(ctx)
 	}
 
+	// Start scheduler
+	g.Go(func() error {
+		return svc.StartScheduler(ctx)
+	})
+
 	// Start all servers
 	g.Go(func() error {
 		return httpSvc.Start()
@@ -201,7 +206,7 @@ func newService(ctx context.Context, db *sqlx.DB, dbConfig pgclient.Config, auth
 	idp := uuid.New()
 
 	// csvc = authzmw.AuthorizationMiddleware(csvc, authz)
-	csvc := re.NewService(repo, idp, nil)
+	csvc := re.NewService(repo, idp, nil, re.NewTicker(time.Minute))
 
 	return csvc, nil
 }

docker/.env

@@ -343,7 +343,7 @@ MG_RE_DB_HOST=re-db
 MG_RE_DB_PORT=5432
 MG_RE_DB_USER=magistrala
 MG_RE_DB_PASS=magistrala
-MG_RE_DB_NAME=rule_engine
+MG_RE_DB_NAME=rules_engine
 MG_RE_DB_SSL_MODE=disable
 MG_RE_DB_SSL_CERT=
 MG_RE_DB_SSL_KEY=

re/api/transport.go

@@ -101,7 +101,7 @@ func decodeAddRuleRequest(_ context.Context, r *http.Request) (interface{}, erro
 	}
 	var rule re.Rule
 	if err := json.NewDecoder(r.Body).Decode(&rule); err != nil {
-		return nil, err
+		return nil, errors.Wrap(err, apiutil.ErrValidation)
 	}
 	return addRuleReq{Rule: rule}, nil
 }