feat(scope): scope models to tenant

spec/asset_spec.cr

@@ -22,6 +22,13 @@ module PlaceOS::Model
           asset.save!
         end
       end
+
+      it "ensure associated authority" do
+        asset = Generator.asset
+        asset.authority_id = ""
+        asset.valid?.should be_false
+        asset.errors.first.field.should eq :authority_id
+      end
     end
 
     describe "#consumable_assets" do

spec/broker_spec.cr

@@ -11,5 +11,14 @@ module PlaceOS::Model
       broker.persisted?.should be_true
       Broker.find!(broker.id.as(String)).id.should eq broker.id
     end
+
+    describe "validations" do
+      it "ensure associated authority" do
+        broker = Generator.broker
+        broker.authority_id = ""
+        broker.valid?.should be_false
+        broker.errors.first.field.should eq :authority_id
+      end
+    end
   end
 end

spec/control_system_spec.cr

@@ -88,12 +88,19 @@ module PlaceOS::Model
       end
     end
 
-    describe "validation" do
+    describe "validations" do
       it "rejects invalid support URI" do
         sys = Generator.control_system
         sys.support_url = "string"
         sys.valid?.should be_false
       end
+
+      it "ensure associated authority" do
+        control_system = Generator.control_system
+        control_system.authority_id = ""
+        control_system.valid?.should be_false
+        control_system.errors.first.field.should eq :authority_id
+      end
     end
 
     describe "add_module" do
@@ -193,7 +200,7 @@ module PlaceOS::Model
 
         cs.save!
 
-        trigger = Trigger.create!(name: "trigger test")
+        trigger = Trigger.create!(name: "trigger test", authority_id: "spec-authority-id")
         zone = Generator.zone
         trigger_id = trigger.id
         if trigger_id

spec/edge_spec.cr

@@ -15,5 +15,14 @@ module PlaceOS::Model
       edge = Generator.edge.save!
       Edge.jwt_edge_id?(edge.api_key.not_nil!.build_jwt).should eq(edge.id)
     end
+
+    describe "validations" do
+      it "ensure associated authority" do
+        edge = Generator.edge
+        edge.authority_id = ""
+        edge.valid?.should be_false
+        edge.errors.first.field.should eq :authority_id
+      end
+    end
   end
 end

spec/generator.cr

@@ -76,6 +76,7 @@ module PlaceOS::Model
     def self.trigger(system : ControlSystem? = nil)
       trigger = Trigger.new(
         name: Faker::Hacker.noun,
+        authority_id: "spec-authority-id",
       )
       trigger.control_system = system if system
       trigger
@@ -96,6 +97,7 @@ module PlaceOS::Model
     def self.control_system
       ControlSystem.new(
         name: RANDOM.base64(10),
+        authority_id: "spec-authority-id",
       )
     end
 
@@ -107,23 +109,25 @@ module PlaceOS::Model
 
       mod = case driver.role
             in .logic?
-              Module.new(custom_name: mod_name, uri: Faker::Internet.url)
+              Module.new(custom_name: mod_name, uri: Faker::Internet.url, authority_id: "spec-authority-id")
             in .device?
               Module.new(
                 custom_name: mod_name,
                 uri: Faker::Internet.url,
                 ip: Faker::Internet.ip_v4_address,
                 port: rand((1..6555)),
+                authority_id: "spec-authority-id",
               )
             in .ssh?
               Module.new(
                 custom_name: mod_name,
                 uri: Faker::Internet.url,
                 ip: Faker::Internet.ip_v4_address,
                 port: rand((1..65_535)),
+                authority_id: "spec-authority-id",
               )
             in .service?, .websocket?
-              Module.new(custom_name: mod_name, uri: Faker::Internet.url)
+              Module.new(custom_name: mod_name, uri: Faker::Internet.url, authority_id: "spec-authority-id")
             end
 
       # Set driver
@@ -137,7 +141,7 @@ module PlaceOS::Model
 
     def self.edge(user : User? = nil)
       user = self.user.save! if user.nil?
-      Edge.for_user(user, name: "#{Faker::Address.city}_#{RANDOM.base64(5)}")
+      Edge.for_user(user, name: "#{Faker::Address.city}_#{RANDOM.base64(5)}", authority_id: "spec-authority-id")
     end
 
     def self.encryption_level
@@ -208,6 +212,7 @@ module PlaceOS::Model
     def self.zone
       Zone.new(
         name: RANDOM.base64(10),
+        authority_id: "spec-authority-id",
       )
     end
 
@@ -217,6 +222,7 @@ module PlaceOS::Model
         purchase_date: Time.local,
         identifier: RANDOM.rand(Int32).to_s,
         purchase_price: RANDOM.rand(Int32),
+        authority_id: "spec-authority-id",
       )
     end
 
@@ -322,6 +328,7 @@ module PlaceOS::Model
       Broker.new(
         name: Faker::Name.name,
         host: Faker::Internet.domain_name,
+        authority_id: "spec-authority-id",
       )
     end
 

spec/module_spec.cr

@@ -322,5 +322,14 @@ module PlaceOS::Model
         end
       end
     end
+
+    describe "validations" do
+      it "ensure associated authority" do
+        mod = Generator.module
+        mod.authority_id = ""
+        mod.valid?.should be_false
+        mod.errors.first.field.should eq :authority_id
+      end
+    end
   end
 end

spec/trigger_spec.cr

@@ -9,16 +9,25 @@ module PlaceOS::Model
       Trigger.find!(inst.id.as(String)).id.should eq inst.id
     end
 
-    it "validates webhook methods" do
-      invalid_model = Generator.trigger
-      invalid_model.supported_methods = ["NUGGET", "GET"]
-      valid_model = Generator.trigger
-      valid_model.supported_methods = ["POST", "GET"]
-
-      valid_model.valid?.should be_true
-      invalid_model.valid?.should be_false
-      invalid_model.errors.size.should eq 1
-      invalid_model.errors.first.to_s.should end_with "supported_methods contains invalid methods: NUGGET"
+    describe "validations" do
+      it "validates webhook methods" do
+        invalid_model = Generator.trigger
+        invalid_model.supported_methods = ["NUGGET", "GET"]
+        valid_model = Generator.trigger
+        valid_model.supported_methods = ["POST", "GET"]
+
+        valid_model.valid?.should be_true
+        invalid_model.valid?.should be_false
+        invalid_model.errors.size.should eq 1
+        invalid_model.errors.first.to_s.should end_with "supported_methods contains invalid methods: NUGGET"
+      end
+
+      it "ensure associated authority" do
+        trigger = Generator.trigger
+        trigger.authority_id = ""
+        trigger.valid?.should be_false
+        trigger.errors.first.field.should eq :authority_id
+      end
     end
 
     describe Trigger::Actions do

spec/zone_spec.cr

@@ -89,7 +89,7 @@ module PlaceOS::Model
 
       cs.save!
 
-      trigger = Trigger.create!(name: "trigger test")
+      trigger = Trigger.create!(name: "trigger test", authority_id: "spec-authority-id")
 
       # No trigger_instances associated with zone
       zone.trigger_instances.to_a.size.should eq 0
@@ -125,11 +125,20 @@ module PlaceOS::Model
           zone.save!
         end
 
-        Zone.with_tag("0").to_a.compact_map(&.id).sort!.should eq zones.compact_map(&.id).sort!
-        Zone.with_tag("3").to_a.compact_map(&.id).sort!.should eq zones[3..].compact_map(&.id).sort!
+        Zone.with_tag("0", "spec-authority-id").to_a.compact_map(&.id).sort!.should eq zones.compact_map(&.id).sort!
+        Zone.with_tag("3", "spec-authority-id").to_a.compact_map(&.id).sort!.should eq zones[3..].compact_map(&.id).sort!
 
         zones.each &.destroy
       end
     end
+
+    describe "validations" do
+      it "ensure associated authority" do
+        zone = Generator.zone
+        zone.authority_id = ""
+        zone.valid?.should be_false
+        zone.errors.first.field.should eq :authority_id
+      end
+    end
   end
 end

src/placeos-models/asset.cr

@@ -35,6 +35,10 @@ module PlaceOS::Model
     # Association
     ###############################################################################################
 
+    secondary_index :authority_id
+
+    belongs_to Authority
+
     belongs_to Asset, foreign_key: "parent_id", association_name: "parent"
 
     has_many(
@@ -53,6 +57,7 @@ module PlaceOS::Model
     # Validation
     ###############################################################################################
 
+    validates :authority_id, presence: true
     validates :quantity, numericality: {minimum: 0}
     validates :in_use, numericality: {minimum: 0}
 

src/placeos-models/broker.cr

@@ -34,14 +34,25 @@ module PlaceOS::Model
     # Matches will be replaced with a hmac_256(secret, match).
     attribute filters : Array(String) = ->{ [] of String }
 
+    # Association
+    ###############################################################################################
+
+    secondary_index :authority_id
+
+    belongs_to Authority
+
     # Validation
     ###############################################################################################
 
+    validates :authority_id, presence: true
     validates :name, presence: true
     validates :host, presence: true
     validates :secret, presence: true
 
-    ensure_unique :name
+    # Ensure unique name under authority scope
+    ensure_unique :name, scope: [:authority_id, :name] do |authority_id, name|
+      {authority_id, name}
+    end
 
     validate ->Broker.validate_filters(Broker)
 

src/placeos-models/control_system.cr

@@ -53,6 +53,10 @@ module PlaceOS::Model
     # Associations
     ###############################################################################################
 
+    secondary_index :authority_id
+
+    belongs_to Authority
+
     # Encrypted yaml settings, with metadata
     has_many(
       child_class: Settings,
@@ -83,12 +87,15 @@ module PlaceOS::Model
     # Validation
     ###############################################################################################
 
+    validates :authority_id, presence: true
+
     # Zones and settings are only required for confident coding
     validates :name, presence: true
 
     # TODO: Ensure unique regardless of casing
-    ensure_unique :name do |name|
-      name.strip
+    # Ensure unique name under authority scope
+    ensure_unique :name, scope: [:authority_id, :name] do |authority_id, name|
+      {authority_id, name.strip}
     end
 
     # Validate support URI

src/placeos-models/edge.cr

@@ -70,6 +70,10 @@ module PlaceOS::Model
     # Association
     ###############################################################################################
 
+    secondary_index :authority_id
+
+    belongs_to Authority
+
     # Modules allocated to this Edge
     has_many(
       child_class: Module,
@@ -128,8 +132,11 @@ module PlaceOS::Model
     # Validation
     ###############################################################################################
 
-    ensure_unique :name do |name|
-      name.strip
+    validates :authority_id, presence: true
+
+    # Ensure unique name under authority scope
+    ensure_unique :name, scope: [:authority_id, :name] do |authority_id, name|
+      {authority_id, name.strip}
     end
   end
 end

src/placeos-models/module.cr

@@ -46,6 +46,10 @@ module PlaceOS::Model
     # Associations
     ###############################################################################################
 
+    secondary_index :authority_id
+
+    belongs_to Authority
+
     # Control System the _logic_ module may be assigned to
     belongs_to ControlSystem, foreign_key: "control_system_id"
 
@@ -66,6 +70,8 @@ module PlaceOS::Model
     # Validation
     ###############################################################################################
 
+    validates :authority_id, presence: true
+
     validate ->(this : Module) {
       driver = this.driver
       role = driver.try(&.role)

src/placeos-models/trigger.cr

@@ -30,6 +30,10 @@ module PlaceOS::Model
     # Association
     ###############################################################################################
 
+    secondary_index :authority_id
+
+    belongs_to Authority
+
     has_many(
       child_class: TriggerInstance,
       dependent: :destroy,
@@ -43,6 +47,8 @@ module PlaceOS::Model
     # Validation
     ###############################################################################################
 
+    validates :authority_id, presence: true
+
     # Validate `supported_methods`
     validate ->(this : Trigger) do
       invalid = this.supported_methods - METHODS