Add endpoint

transiter/http/endpoints/feedendpoints.py

@@ -1,5 +1,6 @@
 from flask import Blueprint
 
+from transiter import models
 from transiter.http.httpmanager import (
     http_endpoint,
     link_target,
@@ -29,16 +30,26 @@ def get_in_system_by_id(system_id, feed_id):
     return feedservice.get_in_system_by_id(system_id, feed_id)
 
 
-@http_endpoint(
-    feed_endpoints, "/<feed_id>", method=HttpMethod.POST,
-)
+@http_endpoint(feed_endpoints, "/<feed_id>", method=HttpMethod.POST)
 @requires_permissions(PermissionsLevel.ALL)
 def create_feed_update(system_id, feed_id):
+    return _create_feed_update_helper(
+        system_id, feed_id, models.FeedUpdate.Type.REGULAR
+    )
+
+
+@http_endpoint(feed_endpoints, "/<feed_id>/flush", method=HttpMethod.POST)
+@requires_permissions(PermissionsLevel.ALL)
+def create_feed_update_flush(system_id, feed_id):
+    return _create_feed_update_helper(system_id, feed_id, models.FeedUpdate.Type.FLUSH)
+
+
+def _create_feed_update_helper(system_id, feed_id, update_type):
     """Create a new feed update."""
     request_args = get_request_args(["sync"])
     sync = request_args["sync"] == "true"
     feed_update_pk = feedservice.create_and_execute_feed_update(
-        system_id, feed_id, execute_async=not sync
+        system_id, feed_id, execute_async=not sync, update_type=update_type
     )
     return (
         feedservice.get_update_in_feed_by_pk(system_id, feed_id, feed_update_pk),