From 5e677990028be09f7ec352e6e5b93556161a6aef Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tomasz=20P=C4=99czek?= <tpeczek@gmail.com>
Date: Tue, 20 Feb 2024 13:24:00 +0100
Subject: [PATCH] Requesting desired number of workers

---
 .../Trigger/RethinkDbScaleMonitor.cs          |  4 +--
 .../Trigger/RethinkDbTargetScaler.cs          | 27 ++++++++++++++++---
 .../Trigger/RethinkDbTriggerListener.cs       |  2 +-
 3 files changed, 25 insertions(+), 8 deletions(-)

diff --git a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs
index c8ced1a..d503884 100644
--- a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs
+++ b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs
@@ -1,8 +1,6 @@
-using System;
-using System.Linq;
+using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.Azure.WebJobs.Host.Scale;
-using Microsoft.Extensions.Logging;
 
 namespace RethinkDb.Azure.WebJobs.Extensions.Trigger
 {
diff --git a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs
index 04cacdf..8b614f0 100644
--- a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs
+++ b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs
@@ -1,16 +1,35 @@
-using System;
-using System.Threading.Tasks;
+using System.Threading.Tasks;
 using Microsoft.Azure.WebJobs.Host.Scale;
 
 namespace RethinkDb.Azure.WebJobs.Extensions.Trigger
 {
     internal class RethinkDbTargetScaler : ITargetScaler
     {
-        public TargetScalerDescriptor TargetScalerDescriptor => throw new NotImplementedException();
+        #region Fields
+        private readonly string _functionId;
+        #endregion
 
+        #region Properties
+        public TargetScalerDescriptor TargetScalerDescriptor { get; }
+        #endregion
+
+        #region Constructor
+        public RethinkDbTargetScaler(string functionId)
+        {
+            _functionId = functionId;
+
+            TargetScalerDescriptor = new TargetScalerDescriptor(_functionId);
+        }
+        #endregion
+
+        #region Methods
         public Task<TargetScalerResult> GetScaleResultAsync(TargetScalerContext context)
         {
-            throw new NotImplementedException();
+            return Task.FromResult(new TargetScalerResult
+            {
+                TargetWorkerCount = 1
+            });
         }
+        #endregion
     }
 }
diff --git a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs
index e4186f8..5c42ce9 100644
--- a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs
+++ b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs
@@ -43,7 +43,7 @@ public RethinkDbTriggerListener(string functionId, ITriggeredFunctionExecutor ex
 
             _rethinkDbMetricsProvider = new RethinkDbMetricsProvider();
             _rethinkDbScaleMonitor = new RethinkDbScaleMonitor(_functionId, _rethinkDbMetricsProvider);
-            _rethinkDbTargetScaler = new RethinkDbTargetScaler();
+            _rethinkDbTargetScaler = new RethinkDbTargetScaler(_functionId);
         }
         #endregion