Tie source and ingested resources to a space

Author: fbacall

app/controllers/sources_controller.rb

@@ -39,6 +39,7 @@ def create
     authorize Source
     @source = @content_provider.sources.build(source_params)
     @source.user = current_user
+    @source.space = current_space
 
     respond_to do |format|
       if @source.save

app/models/source.rb

@@ -2,6 +2,7 @@ class Source < ApplicationRecord
   include LogParameterChanges
   include HasTestJob
   include HasAssociatedNodes
+  include InSpace
 
   APPROVAL_STATUS = {
     0 => :not_approved,

lib/ingestors/ingestor.rb

@@ -135,6 +135,7 @@ def write_resources(type, resources, user, provider, source: nil)
         # check for matched events
         resource.user_id ||= user.id
         resource.content_provider_id ||= provider.id
+        resource.space_id ||= source&.space_id
         existing_resource = find_existing(type, resource)
 
         update = existing_resource

test/unit/ingestors/ingestor_test.rb

@@ -89,7 +89,7 @@ class IngestorTest < ActiveSupport::TestCase
     assert_equal(event.language, 'de')
   end
 
-  test 'does not set event language when languare and source default language missing' do
+  test 'does not set event language when language and source default language missing' do
     user = users(:scraper_user)
     provider = content_providers(:portal_provider)
 
@@ -113,4 +113,29 @@ class IngestorTest < ActiveSupport::TestCase
     assert_nil(event.language)
   end
 
+  test 'sets event space from source space' do
+    user = users(:scraper_user)
+    provider = content_providers(:portal_provider)
+    space = spaces(:plants)
+
+    # Source has default language set
+    @source = Source.create!(url: 'https://somewhere.com/stuff', method: 'bioschemas',
+                             enabled: true, approval_status: 'approved',
+                             space: space, content_provider: provider, user: users(:admin))
+
+    ingestor = Ingestors::Ingestor.new
+
+    # Fake an event that was read ... no language set
+    ingestor.instance_variable_set(:@events,
+                                   [OpenStruct.new(url: 'https://some-course.ca',
+                                                   title: 'Some course',
+                                                   start: '2021-01-31 13:00:00',
+                                                   end:'2021-01-31 14:00:00')])
+    assert_difference('provider.events.count', 1) do
+      ingestor.write(user, provider, source: @source)
+    end
+    event = Event.find_by(title: 'Some course')
+    assert_equal space, event.space
+  end
+
 end