From 3d2c2ee2c65b98f72b4b799dff35146b0bdc348a Mon Sep 17 00:00:00 2001
From: Stephen von Takach <steve@place.technology>
Date: Tue, 22 Aug 2023 14:41:44 +1000
Subject: [PATCH] fix(user_group_mappings): filter users by authority

---
 drivers/place/user_group_mappings.cr | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/drivers/place/user_group_mappings.cr b/drivers/place/user_group_mappings.cr
index 0616dfae58..877f965ff7 100644
--- a/drivers/place/user_group_mappings.cr
+++ b/drivers/place/user_group_mappings.cr
@@ -33,6 +33,9 @@ class Place::UserGroupMappings < PlaceOS::Driver
         place_id:     "optional-place-id",
       },
     },
+
+    # authority id
+    authority_id: "authority-12345",
   })
 
   class UserLogin
@@ -50,6 +53,7 @@ class Place::UserGroupMappings < PlaceOS::Driver
   alias Mapping = NamedTuple(place_id: String)
   alias Prefix = NamedTuple(strip_prefix: Bool?, place_id: String?)
 
+  @authority_id : String = ""
   @group_mappings : Hash(String, Mapping) = {} of String => Mapping
   @group_prefixes : Hash(String, Prefix) = {} of String => Prefix
   @users_checked : UInt64 = 0_u64
@@ -59,6 +63,8 @@ class Place::UserGroupMappings < PlaceOS::Driver
     @group_mappings = setting?(Hash(String, Mapping), :group_mappings) || {} of String => Mapping
     @group_prefixes = setting?(Hash(String, Prefix), :group_prefix) || {} of String => Prefix
     @group_prefixes = @group_prefixes.transform_keys(&.downcase)
+
+    @authority_id = setting?(String, :authority_id) || "authority-12345"
   end
 
   protected def new_user_login(user_json)
@@ -137,7 +143,8 @@ class Place::UserGroupMappings < PlaceOS::Driver
     loop do
       users = staff_api.query_users(
         limit: limit,
-        offset: offset
+        offset: offset,
+        authority_id: @authority_id
       ).get.as_a
 
       logger.debug { "syncing users #{offset}->#{offset + limit}..." }