api: Implement UpdatePolicy()

Signed-off-by: Satoshi Fujimoto <satoshi.fujimoto7@gmail.com>

1 files changed, 17 insertions, 3 deletions

diff --git a/gobgpd/main.go b/gobgpd/main.go
index ec414d1d..e8f15f10 100644
--- a/gobgpd/main.go
+++ b/gobgpd/main.go
@@ -266,8 +266,14 @@ func main() {
 					}
 				}
 				p := config.ConfigSetToRoutingPolicy(newConfig)
-				if err := bgpServer.UpdatePolicy(*p); err != nil {
-					log.Fatalf("failed to set routing policy: %s", err)
+				rp, err := api.NewAPIRoutingPolicyFromConfigStruct(p)
+				if err != nil {
+					log.Warn(err)
+				} else {
+					apiServer.UpdatePolicy(context.Background(), &api.UpdatePolicyRequest{
+						Sets:     rp.DefinedSet,
+						Policies: rp.PolicyDefinition,
+					})
 				}
 
 				added = newConfig.Neighbors
@@ -288,7 +294,15 @@ func main() {
 				if updatePolicy {
 					log.Info("Policy config is updated")
 					p := config.ConfigSetToRoutingPolicy(newConfig)
-					bgpServer.UpdatePolicy(*p)
+					rp, err := api.NewAPIRoutingPolicyFromConfigStruct(p)
+					if err != nil {
+						log.Warn(err)
+					} else {
+						apiServer.UpdatePolicy(context.Background(), &api.UpdatePolicyRequest{
+							Sets:     rp.DefinedSet,
+							Policies: rp.PolicyDefinition,
+						})
+					}
 				}
 				// global policy update
 				if !newConfig.Global.ApplyPolicy.Config.Equal(&c.Global.ApplyPolicy.Config) {