feat: add Granular OAuth Scopes

shard.lock

@@ -228,4 +228,3 @@ shards:
   yaml_mapping:
     git: https://github.com/crystal-lang/yaml_mapping.cr.git
     version: 0.1.1
-

shard.yml

@@ -1,5 +1,5 @@
 name: placeos-rest-api
-version: 1.29.3
+version: 1.30.0
 crystal: ~> 1
 
 targets:

spec/api_key_spec.cr

@@ -1,4 +1,5 @@
 require "./helper"
+require "./scope_helper"
 
 module PlaceOS::Api
   describe ApiKeys do
@@ -16,6 +17,10 @@ module PlaceOS::Api
       describe "CRUD operations", tags: "crud" do
         test_crd(Model::ApiKey, ApiKeys)
       end
+
+      describe "scopes" do
+        test_controller_scope(ApiKeys)
+      end
     end
   end
 end

spec/brokers_spec.cr

@@ -1,4 +1,5 @@
 require "./helper"
+require "./scope_helper"
 
 module PlaceOS::Api
   describe Brokers do
@@ -36,6 +37,11 @@ module PlaceOS::Api
           updated.name.should_not eq original_name
         end
       end
+
+      describe "scopes" do
+        test_update_write_scope(Brokers)
+        test_controller_scope(Brokers)
+      end
     end
   end
 end

spec/drivers_spec.cr

@@ -1,4 +1,5 @@
 require "./helper"
+require "./scope_helper"
 
 module PlaceOS::Api
   describe Drivers do
@@ -78,6 +79,10 @@ module PlaceOS::Api
           end
         end
       end
+
+      describe "scopes" do
+        test_controller_scope(Drivers)
+      end
     end
   end
 end

spec/edges_spec.cr

@@ -1,4 +1,5 @@
 require "./helper"
+require "./scope_helper"
 
 module PlaceOS::Api
   describe Edges do
@@ -16,6 +17,10 @@ module PlaceOS::Api
       describe "CRUD operations", tags: "crud" do
         test_crd(Model::Edge, Edges)
       end
+
+      describe "scopes" do
+        test_controller_scope(Edges)
+      end
     end
   end
 end

spec/helper.cr

@@ -91,6 +91,19 @@ def authentication(sys_admin : Bool = true, support : Bool = true, scope = [Plac
   end
 end
 
+def generate_auth_user(sys_admin, support, scopes)
+  scope_list = scopes.try &.join('-', &.to_s)
+  test_user_email = "test-#{"admin-" if sys_admin}#{"supp" if support}-scope-#{scope_list}-rest-api@place.tech"
+  existing = PlaceOS::Model::User.where(email: test_user_email).first?
+
+  existing || PlaceOS::Model::Generator.user.tap do |user|
+    user.email = test_user_email
+    user.sys_admin = sys_admin
+    user.support = support
+    user.save!
+  end
+end
+
 # Check application responds with 404 when model not present
 def test_404(base, model_name, headers)
   it "404s if #{model_name} isn't present in database", tags: "search" do

spec/metadata_spec.cr

@@ -205,6 +205,148 @@ module PlaceOS::Api
           metadata.size.should eq 1
         end
       end
+
+      describe "scopes" do
+        context "read" do
+          scope_name = "metadata"
+
+          it "allows access to show" do
+            _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new(scope_name, :read)])
+
+            parent = Model::Generator.zone.save!
+            parent_id = parent.id.as(String)
+
+            3.times do
+              child = Model::Generator.zone
+              child.parent_id = parent_id
+              child.save!
+              Model::Generator.metadata(parent: child.id).save!
+            end
+
+            result = curl(
+              method: "GET",
+              path: "#{base}/#{parent_id}/children",
+              headers: authorization_header,
+            )
+            result.status_code.should eq 200
+            Array(NamedTuple(zone: JSON::Any, metadata: Hash(String, Model::Metadata::Interface)))
+              .from_json(result.body)
+              .tap { |m| m.size.should eq(3) }
+              .count(&.[:metadata].empty?.!)
+              .should eq 3
+
+            parent.destroy
+          end
+
+          it "should not allow access to delete" do
+            _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new(scope_name, :read)])
+
+            parent = Model::Generator.zone.save!
+            parent_id = parent.id.as(String)
+
+            3.times do
+              child = Model::Generator.zone
+              child.parent_id = parent_id
+              child.save!
+              Model::Generator.metadata(parent: child.id).save!
+            end
+
+            id = parent.id.as(String)
+
+            result = curl(
+              method: "DELETE",
+              path: "#{base}/#{id}",
+              headers: authorization_header,
+            )
+            result.status_code.should eq 403
+          end
+        end
+        context "write" do
+          scope_name = "metadata"
+
+          it "should allow access to update" do
+            _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new(scope_name, :write)])
+
+            parent = Model::Generator.zone.save!
+            meta = Model::Metadata::Interface.new(
+              name: "test",
+              description: "",
+              details: JSON.parse(%({"hello":"world","bye":"friends"})),
+              parent_id: nil,
+              editors: Set(String).new,
+            )
+
+            parent_id = parent.id.as(String)
+            path = "#{base}/#{parent_id}"
+
+            result = curl(
+              method: "PUT",
+              path: path,
+              body: meta.to_json,
+              headers: authorization_header.merge({"Content-Type" => "application/json"}),
+            )
+
+            new_metadata = Model::Metadata::Interface.from_json(result.body)
+            found = Model::Metadata.for(parent_id, meta.name).first
+            found.name.should eq new_metadata.name
+          end
+
+          it "should not allow access to show" do
+            _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new(scope_name, :write)])
+
+            parent = Model::Generator.zone.save!
+            parent_id = parent.id.as(String)
+
+            3.times do
+              child = Model::Generator.zone
+              child.parent_id = parent_id
+              child.save!
+              Model::Generator.metadata(parent: child.id).save!
+            end
+
+            result = curl(
+              method: "GET",
+              path: "#{base}/#{parent_id}/children",
+              headers: authorization_header,
+            )
+            result.status_code.should eq 403
+          end
+        end
+
+        it "checks that guests can read metadata" do
+          _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new("guest", PlaceOS::Model::UserJWT::Scope::Access::Read)])
+
+          zone = Model::Generator.zone.save!
+          zone_id = zone.id.as(String)
+          meta = Model::Generator.metadata(name: "special", parent: zone_id).save!
+
+          result = curl(
+            method: "GET",
+            path: "#{base}/#{zone_id}",
+            headers: authorization_header,
+          )
+
+          result.status_code.should eq 200
+          metadata = Hash(String, Model::Metadata::Interface).from_json(result.body)
+          metadata.size.should eq 1
+          metadata.values.first.parent_id.should eq zone_id
+          metadata.values.first.name.should eq meta.name
+        end
+
+        it "checks that guests cannot write metadata" do
+          _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new("guest", PlaceOS::Model::UserJWT::Scope::Access::Read)])
+
+          zone = Model::Generator.zone.save!
+          zone_id = zone.id.as(String)
+
+          result = curl(
+            method: "POST",
+            path: "#{base}/#{zone_id}",
+            headers: authorization_header,
+          )
+          result.success?.should be_false
+        end
+      end
     end
   end
 end

spec/modules_spec.cr

@@ -1,4 +1,5 @@
 require "./helper"
+require "./scope_helper"
 require "timecop"
 
 module PlaceOS
@@ -315,6 +316,35 @@ module PlaceOS::Api
         result.success?.should be_true
         body["pingable"].should be_true
       end
+
+      describe "scopes" do
+        test_controller_scope(Modules)
+
+        it "checks scope on update" do
+          _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new("modules", PlaceOS::Model::UserJWT::Scope::Access::Write)])
+          driver = Model::Generator.driver(role: Model::Driver::Role::Service).save!
+          mod = Model::Generator.module(driver: driver).save!
+
+          connected = mod.connected
+          mod.connected = !connected
+
+          id = mod.id.as(String)
+          path = base + id
+
+          result = update_route(path, mod, authorization_header)
+
+          result.status_code.should eq 200
+          updated = Model::Module.from_trusted_json(result.body)
+          updated.id.should eq mod.id
+          updated.connected.should eq !connected
+
+          _, authorization_header = authentication(scope: [PlaceOS::Model::UserJWT::Scope.new("modules", PlaceOS::Model::UserJWT::Scope::Access::Read)])
+          result = update_route(path, mod, authorization_header)
+
+          result.success?.should be_false
+          result.status_code.should eq 403
+        end
+      end
     end
   end
 end

spec/repositories_spec.cr

@@ -1,4 +1,5 @@
 require "./helper"
+require "./scope_helper"
 
 module PlaceOS::Api
   describe Repositories do
@@ -99,6 +100,11 @@ module PlaceOS::Api
           end
         end
       end
+
+      describe "scopes" do
+        test_controller_scope(Repositories)
+        test_update_write_scope(Repositories)
+      end
     end
   end
 end

spec/root_spec.cr

@@ -38,6 +38,12 @@ module PlaceOS::Api
         response.commit.should eq BUILD_COMMIT
       end
 
+      it "gets scope names" do
+        result = curl("GET", File.join(base, "scopes"), headers: authorization_header)
+        scopes = Array(String).from_json(result.body)
+        scopes.size.should eq(Root.scopes.size)
+      end
+
       it "constructs service versions" do
         WebMock.allow_net_connect = false