mirror of
https://git.sr.ht/~tsileo/microblog.pub
synced 2024-12-21 12:44:27 +00:00
Tweak queries in tests
This commit is contained in:
parent
d5c27287af
commit
16da166ee1
4 changed files with 17 additions and 16 deletions
|
@ -52,4 +52,4 @@ def test_sqlalchemy_factory(db: Session) -> None:
|
||||||
ap_actor=ra.ap_actor,
|
ap_actor=ra.ap_actor,
|
||||||
ap_id=ra.ap_id,
|
ap_id=ra.ap_id,
|
||||||
)
|
)
|
||||||
assert actor_in_db.id == db.query(models.Actor).one().id
|
assert actor_in_db.id == db.execute(select(models.Actor)).scalar_one().id
|
||||||
|
|
|
@ -75,7 +75,7 @@ def test_inbox_incoming_follow_request(
|
||||||
assert inbox_object.ap_object == follow_activity.ap_object
|
assert inbox_object.ap_object == follow_activity.ap_object
|
||||||
|
|
||||||
# And a follower was internally created
|
# And a follower was internally created
|
||||||
follower = db.query(models.Follower).one()
|
follower = db.execute(select(models.Follower)).scalar_one()
|
||||||
assert follower.ap_actor_id == ra.ap_id
|
assert follower.ap_actor_id == ra.ap_id
|
||||||
assert follower.actor_id == saved_actor.id
|
assert follower.actor_id == saved_actor.id
|
||||||
assert follower.inbox_object_id == inbox_object.id
|
assert follower.inbox_object_id == inbox_object.id
|
||||||
|
|
|
@ -53,12 +53,12 @@ def test_send_follow_request(
|
||||||
assert response.headers.get("Location") == "http://testserver/"
|
assert response.headers.get("Location") == "http://testserver/"
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Follow"
|
assert outbox_object.ap_type == "Follow"
|
||||||
assert outbox_object.activity_object_ap_id == ra.ap_id
|
assert outbox_object.activity_object_ap_id == ra.ap_id
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == ra.inbox_url
|
assert outgoing_activity.recipient == ra.inbox_url
|
||||||
|
|
||||||
|
@ -111,7 +111,7 @@ def test_send_delete__reverts_side_effects(
|
||||||
assert outbox_object.activity_object_ap_id == outbox_note.ap_id
|
assert outbox_object.activity_object_ap_id == outbox_note.ap_id
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == ra.inbox_url
|
assert outgoing_activity.recipient == ra.inbox_url
|
||||||
|
|
||||||
|
@ -144,11 +144,11 @@ def test_send_create_activity__no_followers_and_with_mention(
|
||||||
assert response.status_code == 302
|
assert response.status_code == 302
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Note"
|
assert outbox_object.ap_type == "Note"
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == ra.inbox_url
|
assert outgoing_activity.recipient == ra.inbox_url
|
||||||
|
|
||||||
|
@ -180,11 +180,11 @@ def test_send_create_activity__with_followers(
|
||||||
assert response.status_code == 302
|
assert response.status_code == 302
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Note"
|
assert outbox_object.ap_type == "Note"
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == follower.actor.inbox_url
|
assert outgoing_activity.recipient == follower.actor.inbox_url
|
||||||
|
|
||||||
|
@ -220,7 +220,7 @@ def test_send_create_activity__question__one_of(
|
||||||
assert response.status_code == 302
|
assert response.status_code == 302
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Question"
|
assert outbox_object.ap_type == "Question"
|
||||||
assert outbox_object.is_one_of_poll is True
|
assert outbox_object.is_one_of_poll is True
|
||||||
assert len(outbox_object.poll_items) == 2
|
assert len(outbox_object.poll_items) == 2
|
||||||
|
@ -228,7 +228,7 @@ def test_send_create_activity__question__one_of(
|
||||||
assert outbox_object.is_poll_ended is False
|
assert outbox_object.is_poll_ended is False
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == follower.actor.inbox_url
|
assert outgoing_activity.recipient == follower.actor.inbox_url
|
||||||
|
|
||||||
|
@ -266,7 +266,7 @@ def test_send_create_activity__question__any_of(
|
||||||
assert response.status_code == 302
|
assert response.status_code == 302
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Question"
|
assert outbox_object.ap_type == "Question"
|
||||||
assert outbox_object.is_one_of_poll is False
|
assert outbox_object.is_one_of_poll is False
|
||||||
assert len(outbox_object.poll_items) == 4
|
assert len(outbox_object.poll_items) == 4
|
||||||
|
@ -274,7 +274,7 @@ def test_send_create_activity__question__any_of(
|
||||||
assert outbox_object.is_poll_ended is False
|
assert outbox_object.is_poll_ended is False
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == follower.actor.inbox_url
|
assert outgoing_activity.recipient == follower.actor.inbox_url
|
||||||
|
|
||||||
|
@ -307,11 +307,11 @@ def test_send_create_activity__article(
|
||||||
assert response.status_code == 302
|
assert response.status_code == 302
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Article"
|
assert outbox_object.ap_type == "Article"
|
||||||
assert outbox_object.ap_object["name"] == "Article"
|
assert outbox_object.ap_object["name"] == "Article"
|
||||||
|
|
||||||
# And an outgoing activity was queued
|
# And an outgoing activity was queued
|
||||||
outgoing_activity = db.query(models.OutgoingActivity).one()
|
outgoing_activity = db.execute(select(models.OutgoingActivity)).scalar_one()
|
||||||
assert outgoing_activity.outbox_object_id == outbox_object.id
|
assert outgoing_activity.outbox_object_id == outbox_object.id
|
||||||
assert outgoing_activity.recipient == follower.actor.inbox_url
|
assert outgoing_activity.recipient == follower.actor.inbox_url
|
||||||
|
|
|
@ -1,4 +1,5 @@
|
||||||
from fastapi.testclient import TestClient
|
from fastapi.testclient import TestClient
|
||||||
|
from sqlalchemy import select
|
||||||
from sqlalchemy.orm import Session
|
from sqlalchemy.orm import Session
|
||||||
|
|
||||||
from app import activitypub as ap
|
from app import activitypub as ap
|
||||||
|
@ -35,7 +36,7 @@ def test_tags__note_with_tag(db: Session, client: TestClient) -> None:
|
||||||
assert response.status_code == 302
|
assert response.status_code == 302
|
||||||
|
|
||||||
# And the Follow activity was created in the outbox
|
# And the Follow activity was created in the outbox
|
||||||
outbox_object = db.query(models.OutboxObject).one()
|
outbox_object = db.execute(select(models.OutboxObject)).scalar_one()
|
||||||
assert outbox_object.ap_type == "Note"
|
assert outbox_object.ap_type == "Note"
|
||||||
assert len(outbox_object.tags) == 1
|
assert len(outbox_object.tags) == 1
|
||||||
emoji_tag = outbox_object.tags[0]
|
emoji_tag = outbox_object.tags[0]
|
||||||
|
|
Loading…
Reference in a new issue