diaspora/spec/lib/archive_importer_spec.rb

# frozen_string_literal: true

require "integration/federation/federation_helper"

describe ArchiveImporter do
  describe "#import" do
    let(:target) { FactoryBot.create(:user) }
    let(:archive_importer) {
      archive_importer = ArchiveImporter.new(archive_hash)
      archive_importer.user = target
      archive_importer
    }

    context "with tag following" do
      let(:archive_hash) {
        {
          "user" => {
            "profile"       => {
              "entity_data" => {
                "author" => "old_id@old_pod.nowhere"
              }
            },
            "followed_tags" => ["testtag"]
          }
        }
      }

      it "imports tag" do
        archive_importer.import
        expect(target.tag_followings.first.tag.name).to eq("testtag")
      end
    end

    context "with subscription" do
      let(:status_message) { FactoryBot.create(:status_message) }
      let(:archive_hash) {
        {
          "user" => {
            "profile"            => {
              "entity_data" => {
                "author" => "old_id@old_pod.nowhere"
              }
            },
            "post_subscriptions" => [status_message.guid]
          }
        }
      }

      it "imports tag" do
        archive_importer.import
        expect(target.participations.first.target).to eq(status_message)
      end
    end

    context "with duplicates" do
      let(:archive_hash) {
        {
          "user" => {
            "profile"            => {
              "entity_data" => {
                "author" => "old_id@old_pod.nowhere"
              }
            },
            "followed_tags"      => [target.tag_followings.first.tag.name],
            "post_subscriptions" => [target.participations.first.target.guid]
          }
        }
      }

      before do
        DataGenerator.create(target, %i[tag_following subscription])
      end

      it "doesn't fail" do
        expect {
          archive_importer.import
        }.not_to raise_error
      end
    end

    context "with non-fetchable subscription" do
      let(:archive_hash) {
        {
          "user" => {
            "profile"            => {
              "entity_data" => {
                "author" => "old_id@old_pod.nowhere"
              }
            },
            "post_subscriptions" => ["XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX"]
          }
        }
      }

      before do
        stub_request(:get, %r{https*://old_pod\.nowhere/\.well-known/webfinger\?resource=acct:old_id@old_pod\.nowhere})
          .to_return(status: 404, body: "", headers: {})
      end

      it "doesn't fail" do
        expect {
          archive_importer.import
        }.not_to raise_error
      end
    end

    context "with settings" do
      let(:archive_hash) {
        {
          "user" => {
            "profile"                            => {
              "entity_data" => {
                "author" => "old_id@old_pod.nowhere"
              }
            },
            "contact_groups"                     => [{
              "name" => "Follow"
            }],
            "show_community_spotlight_in_stream" => false,
            "language"                           => "ru",
            "auto_follow_back"                   => true,
            "auto_follow_back_aspect"            => "Follow"
          }
        }
      }

      it "imports the settings" do
        expect {
          archive_importer.import
        }.not_to raise_error

        expect(archive_importer.user.show_community_spotlight_in_stream).to eq(false)
        expect(archive_importer.user.language).to eq("ru")
        expect(archive_importer.user.auto_follow_back).to eq(true)
        expect(archive_importer.user.auto_follow_back_aspect.name).to eq("Follow")
      end

      it "does not overwrite settings if import_settings is disabled" do
        expect {
          archive_importer.import(import_settings: false)
        }.not_to raise_error

        expect(archive_importer.user.show_community_spotlight_in_stream).to eq(true)
        expect(archive_importer.user.language).to eq("en")
        expect(archive_importer.user.auto_follow_back).to eq(false)
      end
    end

    context "with profile" do
      let(:archive_hash) {
        {
          "user" => {
            "profile" => {
              "entity_data" => {
                "author"     => "old_id@old_pod.nowhere",
                "first_name" => "First",
                "last_name"  => "Last",
                "full_name"  => "Full Name",
                "image_url"  => "https://example.com/my_avatar.png",
                "bio"        => "I'm just a test account",
                "gender"     => "Robot",
                "birthday"   => "2006-01-01",
                "location"   => "diaspora* specs",
                "searchable" => false,
                "public"     => true,
                "nsfw"       => true,
                "tag_string" => "#diaspora #linux #partying"
              }
            }
          }
        }
      }

      it "imports the profile data" do
        expect {
          archive_importer.import
        }.not_to raise_error

        expect(archive_importer.user.profile.first_name).to eq("First")
        expect(archive_importer.user.profile.last_name).to eq("Last")
        expect(archive_importer.user.profile.image_url).to eq("https://example.com/my_avatar.png")
        expect(archive_importer.user.profile.bio).to eq("I'm just a test account")
        expect(archive_importer.user.profile.gender).to eq("Robot")
        expect(archive_importer.user.profile.birthday).to eq(Date.new(2006, 1, 1))
        expect(archive_importer.user.profile.location).to eq("diaspora* specs")
        expect(archive_importer.user.profile.searchable).to eq(false)
        expect(archive_importer.user.profile.public_details).to eq(true)
        expect(archive_importer.user.profile.nsfw).to eq(true)
        expect(archive_importer.user.profile.tag_string).to eq("#diaspora #linux #partying")
      end

      it "does not overwrite profile if import_profile is disabled" do
        original_profile = target.profile.dup

        expect {
          archive_importer.import(import_profile: false)
        }.not_to raise_error

        expect(archive_importer.user.profile.first_name).to eq(original_profile.first_name)
        expect(archive_importer.user.profile.last_name).to eq(original_profile.last_name)
        expect(archive_importer.user.profile.image_url).to eq(original_profile.image_url)
        expect(archive_importer.user.profile.bio).to eq(original_profile.bio)
        expect(archive_importer.user.profile.gender).to eq(original_profile.gender)
        expect(archive_importer.user.profile.birthday).to eq(original_profile.birthday)
        expect(archive_importer.user.profile.location).to eq(original_profile.location)
        expect(archive_importer.user.profile.searchable).to eq(original_profile.searchable)
        expect(archive_importer.user.profile.public_details).to eq(original_profile.public_details)
        expect(archive_importer.user.profile.nsfw).to eq(original_profile.nsfw)
        expect(archive_importer.user.profile.tag_string).to eq(original_profile.tag_string)
      end
    end
  end

  describe "#find_or_create_user" do
    let(:archive_hash) {
      {
        "user" => {
          "profile" => {
            "entity_data" => {
              "author"     => "old_id@old_pod.nowhere",
              "first_name" => "First",
              "last_name"  => "Last",
              "full_name"  => "Full Name",
              "image_url"  => "https://example.com/my_avatar.png",
              "bio"        => "I'm just a test account",
              "gender"     => "Robot",
              "birthday"   => "2006-01-01",
              "location"   => "diaspora* specs",
              "searchable" => false,
              "public"     => true,
              "nsfw"       => true,
              "tag_string" => "#diaspora #linux #partying"
            }
          },
          "email"   => "user@example.com"
        }
      }
    }
    let(:archive_importer) { ArchiveImporter.new(archive_hash) }

    it "creates user" do
      expect {
        archive_importer.find_or_create_user(username: "new_name", password: "123456")
      }.to change(User, :count).by(1)
      expect(archive_importer.user.email).to eq("user@example.com")
      expect(archive_importer.user.getting_started).to be_falsey

      expect(archive_importer.user.profile.first_name).to eq("First")
      expect(archive_importer.user.profile.last_name).to eq("Last")
      expect(archive_importer.user.profile.image_url).to eq("https://example.com/my_avatar.png")
      expect(archive_importer.user.profile.bio).to eq("I'm just a test account")
      expect(archive_importer.user.profile.gender).to eq("Robot")
      expect(archive_importer.user.profile.birthday).to eq(Date.new(2006, 1, 1))
      expect(archive_importer.user.profile.location).to eq("diaspora* specs")
      expect(archive_importer.user.profile.searchable).to eq(false)
      expect(archive_importer.user.profile.public_details).to eq(true)
      expect(archive_importer.user.profile.nsfw).to eq(true)
      expect(archive_importer.user.profile.tag_string).to eq("#diaspora #linux #partying")
    end
  end
end