Adds a local-public tag on the sidebar that shows all posts local to this pod

app/assets/javascripts/app/router.js

@@ -24,6 +24,7 @@ app.Router = Backbone.Router.extend({
     "posts/:id(/)": "singlePost",
     "profile/edit(/)": "settings",
     "public(/)": "stream",
+    "local_public(/)": "stream",
     "stream(/)": "stream",
     "tags/:name(/)": "followed_tags",
     "u/:name(/)": "profile",

app/controllers/streams_controller.rb

@@ -25,6 +25,10 @@ class StreamsController < ApplicationController
     stream_responder(Stream::Public)
   end
 
+  def local_public
+    stream_responder(Stream::LocalPublic)
+  end
+
   def activity
     stream_responder(Stream::Activity)
   end

app/helpers/stream_helper.rb

@@ -22,7 +22,7 @@ module StreamHelper
   end
 
   private
-
+  # rubocop:disable Rails/HelperInstanceVariable
   def next_stream_path
     if current_page?(:stream)
       stream_path(max_time: time_for_scroll(@stream))
@@ -30,6 +30,8 @@ module StreamHelper
       activity_stream_path(max_time: time_for_scroll(@stream))
     elsif current_page?(:aspects_stream)
       aspects_stream_path(max_time: time_for_scroll(@stream), a_ids: session[:a_ids])
+    elsif current_page?(:local_public_stream)
+      local_public_stream_path(max_time: time_for_scroll(@stream))
     elsif current_page?(:public_stream)
       public_stream_path(max_time: time_for_scroll(@stream))
     elsif current_page?(:commented_stream)
@@ -44,6 +46,7 @@ module StreamHelper
       raise "in order to use pagination for this new stream, update next_stream_path in stream helper"
     end
   end
+  # rubocop:enable Rails/HelperInstanceVariable
 
   def time_for_scroll(stream)
     if stream.stream_posts.empty?

app/models/post.rb

@@ -51,6 +51,12 @@ class Post < ApplicationRecord
 
   scope :all_public, -> { where(public: true) }
 
+  scope :all_local_public, -> {
+    left_outer_joins(author: [:pod])
+      .where("pods.host is null") # local posts have no host in pods
+      .where(public: true)
+  }
+
   scope :commented_by, ->(person)  {
     select('DISTINCT posts.*')
       .joins(:comments)

app/views/streams/main_stream.html.haml

@@ -37,6 +37,8 @@
               = render "aspects/aspect_listings", stream: @stream
             %li.nested-list
               = render "tags/followed_tags_listings"
+            %li{data: {stream: "local_public"}}
+              = link_to t("streams.local_public.title"), local_public_stream_path, rel: "backbone", class: "hoverable"
             %li{data: {stream: "public"}}
               = link_to t("streams.public.title"), public_stream_path, rel: "backbone", class: "hoverable"
 

config/locales/diaspora/de.yml

@@ -1245,6 +1245,8 @@ de:
       title: "Stream"
     public:
       title: "Öffentliche Aktivität"
+    local_public:
+      title: "Lokale Posts"
     tags:
       title: "Getaggte Beiträge: %{tags}"
   tag_followings:

config/locales/diaspora/en.yml

@@ -1249,6 +1249,9 @@ en:
     public:
       title: "Public activity"
 
+    local_public:
+      title: "Local posts"
+
     multi:
       title: "Stream"
 

config/routes.rb

@@ -52,6 +52,7 @@ Rails.application.routes.draw do
   get "activity" => "streams#activity", :as => "activity_stream"
   get "stream" => "streams#multi", :as => "stream"
   get "public" => "streams#public", :as => "public_stream"
+  get "local_public" => "streams#local_public", :as => "local_public_stream"
   get "followed_tags" => "streams#followed_tags", :as => "followed_tags_stream"
   get "mentions" => "streams#mentioned", :as => "mentioned_stream"
   get "liked" => "streams#liked", :as => "liked_stream"

lib/stream.rb

@@ -1,14 +1,15 @@
 # frozen_string_literal: true
 
 module Stream
-  require 'stream/activity'
+  require "stream/activity"
-  require 'stream/aspect'
+  require "stream/aspect"
-  require 'stream/comments'
+  require "stream/comments"
-  require 'stream/followed_tag'
+  require "stream/followed_tag"
-  require 'stream/likes'
+  require "stream/likes"
-  require 'stream/mention'
+  require "stream/mention"
-  require 'stream/multi'
+  require "stream/multi"
-  require 'stream/person'
+  require "stream/person"
-  require 'stream/public'
+  require "stream/public"
-  require 'stream/tag'
+  require "stream/local_public"
+  require "stream/tag"
 end

lib/stream/local_public.rb

@@ -0,0 +1,29 @@
+# frozen_string_literal: true
+
+#   Copyright (c) 2010-2011, Diaspora Inc.  This file is
+#   licensed under the Affero General Public License version 3 or later.  See
+#   the COPYRIGHT file.
+
+class Stream::LocalPublic < Stream::Base
+  def link(opts={})
+    Rails.application.routes.url_helpers.local_public_stream_path(opts)
+  end
+
+  def title
+    I18n.translate("streams.local_public.title")
+  end
+
+  # @return [ActiveRecord::Association<Post>] AR association of posts
+  def posts
+    @posts ||= Post.all_local_public
+  end
+
+  def can_comment?(post)
+    post.author.local?
+  end
+
+  # Override base class method
+  def aspects
+    ["public"]
+  end
+end

spec/helpers/stream_helper_spec.rb

@@ -20,6 +20,13 @@ describe StreamHelper, type: :helper do
       expect(helper.next_page_path).to include "/public"
     end
 
+    it "works for local-public page when current page is local-public stream" do
+      allow(helper).to receive(:current_page?).and_return(false)
+      expect(helper).to receive(:current_page?).with(:local_public_stream).and_return(true)
+      allow(helper).to receive(:controller).and_return(build_controller(StreamsController))
+      expect(helper.next_page_path).to include "/local-public"
+    end
+
     it "works for stream page when current page is stream" do
       allow(helper).to receive(:current_page?).and_return(false)
       expect(helper).to receive(:current_page?).with(:stream).and_return(true)

spec/lib/stream/local_public_spec.rb

@@ -0,0 +1,20 @@
+# frozen_string_literal: true
+
+require Rails.root.join('spec', 'shared_behaviors', 'stream')
+
+describe Stream::LocalPublic do
+  before do
+    @stream = Stream::LocalPublic.new(alice)
+  end
+
+  describe 'shared behaviors' do
+    it_should_behave_like 'it is a stream'
+  end
+
+  describe "#posts" do
+    it "calls Post#all_local_public" do
+      expect(Post).to receive(:all_local_public)
+      @stream.posts
+    end
+  end
+end

spec/models/post_spec.rb

@@ -58,8 +58,25 @@ describe Post, type: :model do
       end
     end
 
-    describe ".for_a_stream" do
+    describe ".all_local_public" do
-      it "calls #for_visible_shareable_sql" do
+      it "includes all public posts from local" do
+        post1 = FactoryBot.create(:status_message, author: alice.person, public: true)
+        post2 = FactoryBot.create(:status_message, author: bob.person, public: true)
+        expect(Post.all_local_public.ids).to match_array([post1.id, post2.id])
+      end
+
+      it "doesn't include any posts from other pods" do
+        pod = FactoryBot.create(:pod)
+        external_person = FactoryBot.create(:person, pod: pod)
+        FactoryBot.create(:status_message, author: alice.person, public: true)
+        FactoryBot.create(:status_message, author: bob.person, public: true)
+        post_from_extern = FactoryBot.create(:status_message, author: external_person, public: true)
+        expect(Post.all_local_public.ids).not_to match_array([post_from_extern.id])
+      end
+    end
+
+    describe '.for_a_stream' do
+      it 'calls #for_visible_shareable_sql' do
         time = double
         order = double
         expect(Post).to receive(:for_visible_shareable_sql).with(time, order).and_return(Post)