clean merge mess

src/lavinmq/http/controller/nodes.cr

@@ -108,12 +108,6 @@ module LavinMQ
           end
           context
         end
-
-        put "/api/nodes" do |context, params|
-          settings = parse_body(context)
-          @amqp_server.update_replicator_settings(settings)
-          context
-        end
       end
 
       APPLICATIONS = [{

src/lavinmq/replication/server.cr

@@ -102,8 +102,20 @@ module LavinMQ
         end
       end
 
+      def has_min_followers?
+        @followers.size >= @min_followers
+      end
+
       getter min_followers
 
+      def has_max_lag?
+        @followers.all? do |f|
+          f.lag <= @max_lag
+        end
+      end
+
+      getter max_lag
+
       private def password : String
         path = File.join(Config.instance.data_dir, ".replication_secret")
         begin

static/js/nodes.js

@@ -215,18 +215,6 @@ const followersTable = Table.renderTable('followers', followersTableOpts, (tr, i
   Table.renderCell(tr, 3, humanizeBytes(item.sent_bytes - item.acked_bytes), 'right')
 })
 
-document.querySelector('#followerSettings').addEventListener('submit', function (evt) {
-  // evt.preventDefault()
-  const data = new window.FormData(this)
-  console.log(data.get('minFollowers'))
-  const body = {
-    minFollowers: parseInt(data.get('minFollowers')),
-    maxLag: parseInt(data.get('maxLag'))
-  }
-  HTTP.request('PUT', url, { body })
-    .then(minFollowers => {}).catch(HTTP.alertErrorHandler)
-})
-
 function updateCharts (response) {
   if(response[0].mem_used !== undefined) {
     const memoryStats = {