Jedd Morgan
91 lines
2.9 KiB
Python
91 lines
2.9 KiB
Python
from deprecated import deprecated
|
|
import pytest
|
|
|
|
from specklepy.api import operations
|
|
from specklepy.api.models import Commit, Stream
|
|
from specklepy.transports.server.server import ServerTransport
|
|
|
|
|
|
@deprecated
|
|
@pytest.mark.run(order=6)
|
|
class TestCommit:
|
|
@pytest.fixture(scope="module")
|
|
def commit(self):
|
|
return Commit(message="a fun little test commit")
|
|
|
|
@pytest.fixture(scope="module")
|
|
def updated_commit(
|
|
self,
|
|
):
|
|
return Commit(message="a fun little updated commit")
|
|
|
|
@pytest.fixture(scope="module")
|
|
def stream(self, client):
|
|
stream = Stream(
|
|
name="a sample stream for testing",
|
|
description="a stream created for testing",
|
|
isPublic=True,
|
|
)
|
|
stream.id = client.stream.create(
|
|
stream.name, stream.description, stream.isPublic
|
|
)
|
|
return stream
|
|
|
|
def test_commit_create(self, client, stream, mesh, commit):
|
|
transport = ServerTransport(client=client, stream_id=stream.id)
|
|
mesh.id = operations.send(mesh, transports=[transport])
|
|
|
|
commit.id = client.commit.create(
|
|
stream_id=stream.id, object_id=mesh.id, message=commit.message
|
|
)
|
|
|
|
assert isinstance(commit.id, str)
|
|
|
|
def test_commit_get(self, client, stream, mesh, commit):
|
|
fetched_commit = client.commit.get(stream_id=stream.id, commit_id=commit.id)
|
|
|
|
assert fetched_commit.message == commit.message
|
|
assert fetched_commit.referencedObject == mesh.id
|
|
|
|
def test_commit_list(self, client, stream):
|
|
commits = client.commit.list(stream_id=stream.id)
|
|
|
|
assert isinstance(commits, list)
|
|
assert isinstance(commits[0], Commit)
|
|
|
|
def test_commit_update(self, client, stream, commit, updated_commit):
|
|
updated = client.commit.update(
|
|
stream_id=stream.id, commit_id=commit.id, message=updated_commit.message
|
|
)
|
|
|
|
fetched_commit = client.commit.get(stream_id=stream.id, commit_id=commit.id)
|
|
|
|
assert updated is True
|
|
assert fetched_commit.message == updated_commit.message
|
|
|
|
def test_commit_delete(self, client, stream, mesh):
|
|
commit_id = client.commit.create(
|
|
stream_id=stream.id, object_id=mesh.id, message="a great commit to delete"
|
|
)
|
|
|
|
deleted = client.commit.delete(stream_id=stream.id, commit_id=commit_id)
|
|
|
|
assert deleted is True
|
|
|
|
def test_commit_marked_as_received(self, client, stream, mesh) -> None:
|
|
commit = Commit(message="this commit should be received")
|
|
commit.id = client.commit.create(
|
|
stream_id=stream.id,
|
|
object_id=mesh.id,
|
|
message=commit.message,
|
|
)
|
|
|
|
commit_marked_received = client.commit.received(
|
|
stream.id,
|
|
commit.id,
|
|
source_application="pytest",
|
|
message="testing received",
|
|
)
|
|
|
|
assert commit_marked_received is True
|