="diff-file-box diff-box file-content tab-size-8" id="diff-32">

+ 29 - 0
commu/interfaces/post_repository.py
Прегледај датотеку 

@@ -0,0 +1,29 @@
1 
+from abc import ABC, abstractmethod
2 
+
3 
+class PostRepository(ABC):
4 
+
5 
+    @abstractmethod
6 
+    def list(self, page=1, per_page=10, order_by="-created"): pass
7 
+
8 
+    @abstractmethod
9 
+    def add(self, post): pass
10 
+
11 
+    @abstractmethod
12 
+    def get(self, post_id): pass
13 
+
14 
+    @abstractmethod
15 
+    def update(self, post):
16 
+        """Update an existing post."""
17 
+        pass
18 
+
19 
+    @abstractmethod
20 
+    def delete(self, post_id):
21 
+        """Delete a post by its ID."""
22 
+        pass
23 
+
24 
+
25 
+    @abstractmethod
26 
+    def search(self, query: str): pass
27 
+
28 
+    @abstractmethod
29 
+    def rate_post(self, post_id, user_id, rating: int): pass

+ 11 - 0
commu/interfaces/user_repository.py
Прегледај датотеку 

@@ -0,0 +1,11 @@
1 
+from abc import ABC, abstractmethod
2 
+
3 
+class UserRepository(ABC):
4 
+    @abstractmethod
5 
+    def add(self, user): pass
6 
+
7 
+    @abstractmethod
8 
+    def get(self, user_id): pass
9 
+
10 
+    @abstractmethod
11 
+    def find_by_username(self, username): pass

+ 0 - 0
commu/tests/__init__.py
Прегледај датотеку


BIN
commu/tests/__pycache__/__init__.cpython-310.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/__init__.cpython-311.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/test_post_repository.cpython-310-pytest-8.4.1.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/test_post_repository.cpython-311.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/test_post_service.cpython-310-pytest-8.4.1.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/test_post_service.cpython-311.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/test_user_service.cpython-310-pytest-8.4.1.pyc
Прегледај датотеку


BIN
commu/tests/__pycache__/test_user_service.cpython-311.pyc
Прегледај датотеку


+ 27 - 0
commu/tests/test_post_repository.py
Прегледај датотеку 

@@ -0,0 +1,27 @@
1 
+from commu.infrastructure.memory_post_repository import InMemoryPostRepository
2 
+from commu.entities.post import Post
3 
+
4 
+def test_add_and_get_post():
5 
+    repo = InMemoryPostRepository()
6 
+    post = Post("user1", "content", images=["img.png"])
7 
+    repo.add(post)
8 
+    assert repo.get(post.id) == post
9 
+
10 
+def test_search():
11 
+    repo = InMemoryPostRepository()
12 
+    p1 = Post("u", "hello apple")
13 
+    p2 = Post("u", "banana orange")
14 
+    repo.add(p1)
15 
+    repo.add(p2)
16 
+    results = repo.search("apple")
17 
+    assert len(results) == 1 and results[0].id == p1.id
18 
+
19 
+def test_rate_post():
20 
+    repo = InMemoryPostRepository()
21 
+    p = Post("u", "rate me")
22 
+    repo.add(p)
23 
+    repo.rate_post(p.id, "userA", 3)
24 
+    repo.rate_post(p.id, "userB", 5)
25 
+    # userA updates rating
26 
+    repo.rate_post(p.id, "userA", 4)
27 
+    assert p.ratings == [("userB", 5), ("userA", 4)] or p.ratings == [("userA", 4), ("userB", 5)]

+ 57 - 0
commu/tests/test_post_service.py
Прегледај датотеку 

@@ -0,0 +1,57 @@
1 
+import pytest
2 
+from commu.usecases.post_service import PostService
3 
+from commu.usecases.user_service import UserService
4 
+from commu.infrastructure.memory_user_repository import InMemoryUserRepository
5 
+from commu.infrastructure.memory_post_repository import InMemoryPostRepository
6 
+from commu.entities.user import UserRole
7 
+
8 
+@pytest.fixture
9 
+def setup_services():
10 
+    user_repo = InMemoryUserRepository()
11 
+    post_repo = InMemoryPostRepository()
12 
+    user_svc = UserService(user_repo)
13 
+    post_svc = PostService(post_repo, user_repo)
14 
+    admin = user_svc.register("admin", UserRole.ADMIN)
15 
+    user = user_svc.register("user", UserRole.USER)
16 
+    guest = user_svc.register("guest", UserRole.GUEST)
17 
+    return user_svc, post_svc, admin, user, guest
18 
+
19 
+def test_create_post(setup_services):
20 
+    user_svc, post_svc, admin, user, guest = setup_services
21 
+    post = post_svc.create_post(user.id, "My post", images=["a.jpg"])
22 
+    assert post.text == "My post"
23 
+    assert post.images == ["a.jpg"]
24 
+
25 
+def test_guest_cannot_create_post(setup_services):
26 
+    user_svc, post_svc, admin, user, guest = setup_services
27 
+    with pytest.raises(PermissionError):
28 
+        post_svc.create_post(guest.id, "forbidden")
29 
+
30 
+def test_search_posts(setup_services):
31 
+    user_svc, post_svc, admin, user, guest = setup_services
32 
+    post1 = post_svc.create_post(user.id, "Hello world")
33 
+    post2 = post_svc.create_post(user.id, "Another post")
34 
+    results = post_svc.search_posts("hello")
35 
+    assert len(results) == 1
36 
+    assert results[0].text == "Hello world"
37 
+
38 
+def test_rate_post(setup_services):
39 
+    user_svc, post_svc, admin, user, guest = setup_services
40 
+    post = post_svc.create_post(user.id, "My post")
41 
+    post_svc.rate_post(post.id, admin.id, 5)
42 
+    post_svc.rate_post(post.id, user.id, 4)
43 
+    assert abs(post.average_rating() - 4.5) < 1e-6
44 
+
45 
+def test_guest_cannot_rate(setup_services):
46 
+    user_svc, post_svc, admin, user, guest = setup_services
47 
+    post = post_svc.create_post(user.id, "Guest can't rate")
48 
+    with pytest.raises(PermissionError):
49 
+        post_svc.rate_post(post.id, guest.id, 5)
50 
+
51 
+def test_rating_bounds(setup_services):
52 
+    user_svc, post_svc, admin, user, guest = setup_services
53 
+    post = post_svc.create_post(user.id, "Test bounds")
54 
+    with pytest.raises(ValueError):
55 
+        post_svc.rate_post(post.id, admin.id, 0)
56 
+    with pytest.raises(ValueError):
57 
+        post_svc.rate_post(post.id, admin.id, 6)

+ 25 - 0
commu/tests/test_user_service.py
Прегледај датотеку 

@@ -0,0 +1,25 @@
1 
+import pytest
2 
+from commu.usecases.user_service import UserService
3 
+from commu.infrastructure.memory_user_repository import InMemoryUserRepository
4 
+from commu.entities.user import UserRole
5 
+
6 
+def test_register_user():
7 
+    repo = InMemoryUserRepository()
8 
+    svc = UserService(repo)
9 
+    user = svc.register("testuser")
10 
+    assert user.username == "testuser"
11 
+    assert user.role == UserRole.USER
12 
+    assert repo.get(user.id) == user
13 
+
14 
+def test_register_admin():
15 
+    repo = InMemoryUserRepository()
16 
+    svc = UserService(repo)
17 
+    user = svc.register("adminuser", UserRole.ADMIN)
18 
+    assert user.role == UserRole.ADMIN
19 
+
20 
+def test_get_user():
21 
+    repo = InMemoryUserRepository()
22 
+    svc = UserService(repo)
23 
+    user = svc.register("abc")
24 
+    found = svc.get_user(user.id)
25 
+    assert found.username == "abc"

+ 0 - 0
commu/usecases/__init__.py
Прегледај датотеку


BIN
commu/usecases/__pycache__/__init__.cpython-310.pyc
Прегледај датотеку


BIN
commu/usecases/__pycache__/__init__.cpython-311.pyc
Прегледај датотеку


BIN
commu/usecases/__pycache__/post_service.cpython-310.pyc
Прегледај датотеку


BIN
commu/usecases/__pycache__/post_service.cpython-311.pyc
Прегледај датотеку


BIN
commu/usecases/__pycache__/user_service.cpython-310.pyc
Прегледај датотеку


BIN
commu/usecases/__pycache__/user_service.cpython-311.pyc
Прегледај датотеку


+ 28 - 0
commu/usecases/post_service.py
Прегледај датотеку 

@@ -0,0 +1,28 @@
1 
+from commu.entities.post import Post
2 
+from commu.entities.user import UserRole
3 
+
4 
+class PostService:
5 
+    def __init__(self, post_repo, user_repo):
6 
+        self.post_repo = post_repo
7 
+        self.user_repo = user_repo
8 
+
9 
+    def create_post(self, author_id, text, images=None, videos=None):
10 
+        user = self.user_repo.get(author_id)
11 
+        print(f"user = {user}")
12 
+        print(f"role = {user.role}")
13 
+        if not user or user.role == UserRole.GUEST:
14 
+            raise PermissionError("User does not have permission to create posts")
15 
+        post = Post(author_id, text, images, videos)
16 
+        self.post_repo.add(post)
17 
+        return post
18 
+
19 
+    def search_posts(self, query):
20 
+        return self.post_repo.search(query)
21 
+
22 
+    def rate_post(self, post_id, user_id, rating):
23 
+        user = self.user_repo.get(user_id)
24 
+        if not user or user.role == UserRole.GUEST:
25 
+            raise PermissionError("Guests cannot rate posts")
26 
+        if not (1 <= rating <= 5):
27 
+            raise ValueError("Rating must be between 1 and 5")
28 
+        self.post_repo.rate_post(post_id, user_id, rating)

+ 13 - 0
commu/usecases/user_service.py
Прегледај датотеку 

@@ -0,0 +1,13 @@
1 
+from commu.entities.user import User, UserRole
2 
+
3 
+class UserService:
4 
+    def __init__(self, user_repo):
5 
+        self.user_repo = user_repo
6 
+
7 
+    def register(self, username, role=UserRole.USER):
8 
+        user = User(username, role)
9 
+        self.user_repo.add(user)
10 
+        return user
11 
+
12 
+    def get_user(self, user_id):
13 
+        return self.user_repo.get(user_id)

+ 0 - 0
core/__init__.py
Прегледај датотеку


BIN
core/__pycache__/__init__.cpython-311.pyc
Прегледај датотеку


BIN
core/__pycache__/admin.cpython-311.pyc
Прегледај датотеку


BIN
core/__pycache__/apps.cpython-311.pyc
Прегледај датотеку


BIN
core/__pycache__/models.cpython-311.pyc
Прегледај датотеку


BIN
core/__pycache__/tests.cpython-311.pyc
Прегледај датотеку


BIN
core/__pycache__/urls.cpython-311.pyc
Прегледај датотеку


BIN
core/__pycache__/views.cpython-311.pyc
Прегледај датотеку


+ 3 - 0
core/admin.py
Прегледај датотеку 

@@ -0,0 +1,3 @@
1 
+from django.contrib import admin
2 
+
3 
+# Register your models here.

+ 6 - 0
core/apps.py
Прегледај датотеку 

@@ -0,0 +1,6 @@
1 
+from django.apps import AppConfig
2 
+
3 
+
4 
+class CoreConfig(AppConfig):
5 
+    default_auto_field = 'django.db.models.BigAutoField'
6 
+    name = 'core'

+ 38 - 0
core/migrations/0001_initial.py
Прегледај датотеку 

@@ -0,0 +1,38 @@
1 
+# Generated by Django 5.2.4 on 2025-08-03 16:36
2 
+
3 
+import django.db.models.deletion
4 
+from django.conf import settings
5 
+from django.db import migrations, models
6 
+
7 
+
8 
+class Migration(migrations.Migration):
9 
+
10 
+    initial = True
11 
+
12 
+    dependencies = [
13 
+        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
14 
+    ]
15 
+
16 
+    operations = [
17 
+        migrations.CreateModel(
18 
+            name='Post',
19 
+            fields=[
20 
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
21 
+                ('text', models.TextField()),
22 
+                ('images', models.JSONField(blank=True, default=list)),
23 
+                ('videos', models.JSONField(blank=True, default=list)),
24 
+                ('created', models.DateTimeField(auto_now_add=True)),
25 
+                ('author', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='posts', to=settings.AUTH_USER_MODEL)),
26 
+            ],
27 
+        ),
28 
+        migrations.CreateModel(
29 
+            name='PostRating',
30 
+            fields=[
31 
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
32 
+                ('rating', models.IntegerField()),
33 
+                ('created', models.DateTimeField(auto_now_add=True)),
34 
+                ('post', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='ratings', to='core.post')),
35 
+                ('user', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to=settings.AUTH_USER_MODEL)),
36 
+            ],
37 
+        ),
38 
+    ]

+ 0 - 0
core/migrations/__init__.py
Прегледај датотеку


BIN
core/migrations/__pycache__/0001_initial.cpython-311.pyc
Прегледај датотеку


BIN
core/migrations/__pycache__/__init__.cpython-311.pyc
Прегледај датотеку


+ 18 - 0
core/models.py
Прегледај датотеку 

@@ -0,0 +1,18 @@
1 
+from django.db import models
2 
+from django.contrib.auth import get_user_model
3 
+
4 
+User = get_user_model()
5 
+
6 
+class Post(models.Model):
7 
+    author = models.ForeignKey(User, on_delete=models.CASCADE, related_name="posts")
8 
+    text = models.TextField()
9 
+    images = models.JSONField(default=list, blank=True)
10 
+    videos = models.JSONField(default=list, blank=True)
11 
+    created = models.DateTimeField(auto_now_add=True)
12 
+
13 
+class PostRating(models.Model):
14 
+    post = models.ForeignKey(Post, on_delete=models.CASCADE, related_name="ratings")
15 
+    user = models.ForeignKey(User, on_delete=models.CASCADE)
16 
+    rating = models.IntegerField()
17 
+    created = models.DateTimeField(auto_now_add=True)
18 
+

BIN
core/repositories/__pycache__/django_post_repository.cpython-311.pyc
Прегледај датотеку


BIN
core/repositories/__pycache__/django_user_repository.cpython-311.pyc
Прегледај датотеку


+ 112 - 0
core/repositories/django_post_repository.py
Прегледај датотеку 

@@ -0,0 +1,112 @@
1 
+from commu.interfaces.post_repository import PostRepository
2 
+from core.models import Post, PostRating
3 
+from django.contrib.auth import get_user_model
4 
+
5 
+User = get_user_model()
6 
+
7 
+class DjangoPostRepository(PostRepository):
8 
+    def add(self, post):
9 
+        # post: commu.entities.post.Post
10 
+        try:
11 
+            author = User.objects.get(id=post.author_id)
12 
+        except User.DoesNotExist:
13 
+            raise ValueError("Author not found")
14 
+        obj = Post.objects.create(
15 
+            author=author,
16 
+            text=post.text,
17 
+            images=post.images,
18 
+            videos=post.videos,
19 
+        )
20 
+        post.id = str(obj.id)
21 
+        return post
22 
+
23 
+    def get(self, post_id):
24 
+        try:
25 
+            obj = Post.objects.get(id=post_id)
26 
+            from commu.entities.post import Post as DomainPost
27 
+            domain_post = DomainPost(
28 
+                author_id=str(obj.author.id),
29 
+                text=obj.text,
30 
+                images=obj.images,
31 
+                videos=obj.videos,
32 
+            )
33 
+            domain_post.id = str(obj.id)
34 
+            # Load ratings
35 
+            domain_post.ratings = [
36 
+                (str(r.user.id), r.rating)
37 
+                for r in obj.ratings.all()
38 
+            ]
39 
+            return domain_post
40 
+        except Post.DoesNotExist:
41 
+            return None
42 
+
43 
+    def search(self, query: str):
44 
+        qs = Post.objects.filter(text__icontains=query)
45 
+        from commu.entities.post import Post as DomainPost
46 
+        result = []
47 
+        for obj in qs:
48 
+            domain_post = DomainPost(
49 
+                author_id=str(obj.author.id),
50 
+                text=obj.text,
51 
+                images=obj.images,
52 
+                videos=obj.videos,
53 
+            )
54 
+            domain_post.id = str(obj.id)
55 
+            # Load ratings
56 
+            domain_post.ratings = [
57 
+                (str(r.user.id), r.rating)
58 
+                for r in obj.ratings.all()
59 
+            ]
60 
+            result.append(domain_post)
61 
+        return result
62 
+
63 
+    def rate_post(self, post_id, user_id, rating: int):
64 
+        try:
65 
+            post = Post.objects.get(id=post_id)
66 
+            user = User.objects.get(id=user_id)
67 
+        except (Post.DoesNotExist, User.DoesNotExist):
68 
+            raise ValueError("Post or user not found")
69 
+        # Remove old rating from user, if any
70 
+        PostRating.objects.filter(post=post, user=user).delete()
71 
+        # Create new rating
72 
+        PostRating.objects.create(post=post, user=user, rating=rating)
73 
+
74 
+    def delete(self, post_id):
75 
+        try:
76 
+            obj = Post.objects.get(id=post_id)
77 
+            obj.delete()
78 
+        except Post.DoesNotExist:
79 
+            raise ValueError("Post not found")
80 
+
81 
+    def list(self, page=1, per_page=10, order_by="-created"):
82 
+        qs = Post.objects.all().order_by(order_by)
83 
+        total = qs.count()
84 
+        start = (page - 1) * per_page
85 
+        end = start + per_page
86 
+        from commu.entities.post import Post as DomainPost
87 
+        posts = []
88 
+        for obj in qs[start:end]:
89 
+            domain_post = DomainPost(
90 
+                author_id=str(obj.author.id),
91 
+                text=obj.text,
92 
+                images=obj.images,
93 
+                videos=obj.videos,
94 
+            )
95 
+            domain_post.id = str(obj.id)
96 
+            domain_post.ratings = [
97 
+                (str(r.user.id), r.rating)
98 
+                for r in obj.ratings.all()
99 
+            ]
100 
+            posts.append(domain_post)
101 
+        return posts, total
102 
+
103 
+    def update(self, post):
104 
+        try:
105 
+            obj = Post.objects.get(id=post.id)
106 
+            obj.text = post.text
107 
+            obj.images = post.images
108 
+            obj.videos = post.videos
109 
+            obj.save()
110 
+            # Optionally update ratings (if part of update)
111 
+        except Post.DoesNotExist:
112 
+            raise ValueError("Post not found")

+ 55 - 0
core/repositories/django_user_repository.py
Прегледај датотеку 

@@ -0,0 +1,55 @@
1 
+from commu.interfaces.user_repository import UserRepository
2 
+from django.contrib.auth.models import User as DjangoUser
3 
+
4 
+class DjangoUserRepository(UserRepository):
5 
+    def add(self, user):
6 
+        # user: commu.entities.user.User
7 
+        # Map role to Django flags
8 
+        is_staff = user.role.value in ("admin", "user") if hasattr(user.role, "value") else user.role in ("admin", "user")
9 
+        is_superuser = user.role.value == "admin" if hasattr(user.role, "value") else user.role == "admin"
10 
+        obj = DjangoUser.objects.create_user(
11 
+            username=user.username,
12 
+            password=None,  # You may set/generate a password as needed!
13 
+            is_staff=is_staff,
14 
+            is_superuser=is_superuser,
15 
+        )
16 
+        user.id = str(obj.id)
17 
+        return user
18 
+
19 
+    def get(self, user_id):
20 
+        try:
21 
+            obj = DjangoUser.objects.get(id=user_id)
22 
+            from commu.entities.user import User, UserRole
23 
+            role = self._role_from_django(obj)
24 
+            u = User(
25 
+                username=obj.username,
26 
+                role=role,
27 
+            )
28 
+            u.id = str(obj.id)
29 
+            return u
30 
+        except DjangoUser.DoesNotExist:
31 
+            return None
32 
+
33 
+    def find_by_username(self, username):
34 
+        try:
35 
+            obj = DjangoUser.objects.get(username=username)
36 
+            from commu.entities.user import User, UserRole
37 
+            role = self._role_from_django(obj)
38 
+            u = User(
39 
+                username=obj.username,
40 
+                role=role,
41 
+            )
42 
+            u.id = str(obj.id)
43 
+            return u
44 
+        except DjangoUser.DoesNotExist:
45 
+            return None
46 
+
47 
+    def _role_from_django(self, user_obj):
48 
+        from commu.entities.user import UserRole
49 
+        if user_obj.is_superuser:
50 
+            return UserRole.ADMIN
51 
+        elif user_obj.is_staff:
52 
+            return UserRole.USER
53 
+        else:
54 
+            return UserRole.GUEST
55 
+

+ 3 - 0
core/tests.py
Прегледај датотеку 

@@ -0,0 +1,3 @@
1 
+from django.test import TestCase
2 
+
3 
+# Create your tests here.

+ 0 - 0
core/tests/__init__.py
Прегледај датотеку


BIN
core/tests/__pycache__/__init__.cpython-311.pyc
Прегледај датотеку


BIN
core/tests/__pycache__/test_post_service_django.cpython-311.pyc
Прегледај датотеку


+ 60 - 0
core/tests/test_post_service_django.py
Прегледај датотеку 

@@ -0,0 +1,60 @@
1 
+import pytest
2 
+from django.test import TestCase
3 
+from django.contrib.auth import get_user_model
4 
+
5 
+from commu.usecases.post_service import PostService
6 
+from commu.entities.user import UserRole
7 
+from core.repositories.django_post_repository import DjangoPostRepository
8 
+from core.repositories.django_user_repository import DjangoUserRepository
9 
+
10 
+User = get_user_model()
11 
+
12 
+class PostServiceIntegrationTest(TestCase):
13 
+
14 
+    def setUp(self):
15 
+        # Use Django's repositories
16 
+        self.user_repo = DjangoUserRepository()
17 
+        self.post_repo = DjangoPostRepository()
18 
+        self.service = PostService(self.post_repo, self.user_repo)
19 
+
20 
+        # Create some users using Django ORM
21 
+        self.admin = User.objects.create_user(username="admin", is_superuser=True, is_staff=True)
22 
+        self.user = User.objects.create_user(username="user", is_staff=True)
23 
+        self.guest = User.objects.create_user(username="guest")  # Not staff or superuser
24 
+
25 
+    def test_create_post_by_user(self):
26 
+        post = self.service.create_post(str(self.user.id), "Hello Django!", ["img1.png"], ["vid1.mp4"])
27 
+        assert post.text == "Hello Django!"
28 
+        assert post.images == ["img1.png"]
29 
+        assert post.videos == ["vid1.mp4"]
30 
+
31 
+    def test_guest_cannot_create_post(self):
32 
+        with self.assertRaises(PermissionError):
33 
+            self.service.create_post(str(self.guest.id), "Forbidden")
34 
+
35 
+    def test_search_posts(self):
36 
+        p1 = self.service.create_post(str(self.user.id), "First Django post")
37 
+        p2 = self.service.create_post(str(self.user.id), "Second hello world")
38 
+        results = self.service.search_posts("hello")
39 
+        assert len(results) == 1
40 
+        assert results[0].text == "Second hello world"
41 
+
42 
+    def test_rate_post(self):
43 
+        post = self.service.create_post(str(self.user.id), "Rate me Django!")
44 
+        self.service.rate_post(post.id, str(self.admin.id), 5)
45 
+        self.service.rate_post(post.id, str(self.user.id), 4)
46 
+        updated_post = self.post_repo.get(post.id)
47 
+        assert abs(updated_post.average_rating() - 4.5) < 1e-6
48 
+
49 
+    def test_guest_cannot_rate_post(self):
50 
+        post = self.service.create_post(str(self.user.id), "No guest rate")
51 
+        with self.assertRaises(PermissionError):
52 
+            self.service.rate_post(post.id, str(self.guest.id), 2)
53 
+
54 
+    def test_rating_bounds(self):
55 
+        post = self.service.create_post(str(self.user.id), "Bounds Django")
56 
+        with self.assertRaises(ValueError):
57 
+            self.service.rate_post(post.id, str(self.admin.id), 0)
58 
+        with self.assertRaises(ValueError):
59 
+            self.service.rate_post(post.id, str(self.admin.id), 6)
60 
+

+ 8 - 0
core/urls.py
Прегледај датотеку 

@@ -0,0 +1,8 @@
1 
+from django.urls import path
2 
+from . import views
3 
+
4 
+urlpatterns = [
5 
+    path('posts/create/', views.create_post, name='create_post'),
6 
+    path('posts/search/', views.search_posts, name='search_posts'),
7 
+    path('posts/rate/', views.rate_post, name='rate_post'),
8 
+]

+ 69 - 0
core/views.py
Прегледај датотеку 

@@ -0,0 +1,69 @@
1 
+import json
2 
+from django.http import JsonResponse, HttpResponseBadRequest
3 
+from django.views.decorators.csrf import csrf_exempt
4 
+from django.contrib.auth.decorators import login_required
5 
+from commu.usecases.post_service import PostService
6 
+from core.repositories.django_post_repository import DjangoPostRepository
7 
+from core.repositories.django_user_repository import DjangoUserRepository
8 
+
9 
+# Service setup (could be moved to app config for larger apps)
10 
+user_repo = DjangoUserRepository()
11 
+post_repo = DjangoPostRepository()
12 
+post_service = PostService(post_repo, user_repo)
13 
+
14 
+@csrf_exempt
15 
+@login_required
16 
+def create_post(request):
17 
+    if request.method != 'POST':
18 
+        return HttpResponseBadRequest("POST only")
19 
+    try:
20 
+        data = json.loads(request.body.decode())
21 
+        text = data.get("text")
22 
+        images = data.get("images", [])
23 
+        videos = data.get("videos", [])
24 
+        if not text:
25 
+            return JsonResponse({"error": "Missing post text"}, status=400)
26 
+        # Use logged-in Django user as author
27 
+        user_id = str(request.user.id)
28 
+        post = post_service.create_post(user_id, text, images, videos)
29 
+        return JsonResponse({
30 
+            "id": post.id,
31 
+            "text": post.text,
32 
+            "author_id": post.author_id,
33 
+            "images": post.images,
34 
+            "videos": post.videos
35 
+        })
36 
+    except Exception as e:
37 
+        return JsonResponse({"error": str(e)}, status=400)
38 
+
39 
+def search_posts(request):
40 
+    q = request.GET.get("q", "")
41 
+    results = post_service.search_posts(q)
42 
+    posts = [{
43 
+        "id": p.id,
44 
+        "text": p.text,
45 
+        "author_id": p.author_id,
46 
+        "images": p.images,
47 
+        "videos": p.videos,
48 
+        "avg_rating": p.average_rating()
49 
+    } for p in results]
50 
+    return JsonResponse({"results": posts})
51 
+
52 
+@csrf_exempt
53 
+@login_required
54 
+def rate_post(request):
55 
+    if request.method != 'POST':
56 
+        return HttpResponseBadRequest("POST only")
57 
+    try:
58 
+        data = json.loads(request.body.decode())
59 
+        post_id = data.get("post_id")
60 
+        rating = data.get("rating")
61 
+        if not post_id or rating is None:
62 
+            return JsonResponse({"error": "Missing post_id or rating"}, status=400)
63 
+        user_id = str(request.user.id)
64 
+        post_service.rate_post(post_id, user_id, int(rating))
65 
+        return JsonResponse({"ok": True})
66 
+    except Exception as e:
67 
+        return JsonResponse({"error": str(e)}, status=400)
68 
+
69 
+

+ 0 - 0
db.sqlite3
Прегледај датотеку


+ 0 - 0
django_commu/__init__.py
Прегледај датотеку


BIN
django_commu/__pycache__/__init__.cpython-311.pyc
Прегледај датотеку


BIN
django_commu/__pycache__/settings.cpython-311.pyc
Прегледај датотеку


BIN
django_commu/__pycache__/urls.cpython-311.pyc
Прегледај датотеку


BIN
django_commu/__pycache__/wsgi.cpython-311.pyc
Прегледај датотеку


+ 16 - 0
django_commu/asgi.py
Прегледај датотеку 

@@ -0,0 +1,16 @@
1 
+"""
2 
+ASGI config for django_commu project.
3 
+
4 
+It exposes the ASGI callable as a module-level variable named ``application``.
5 
+
6 
+For more information on this file, see
7 
+https://docs.djangoproject.com/en/5.2/howto/deployment/asgi/
8 
+"""
9 
+
10 
+import os
11 
+
12 
+from django.core.asgi import get_asgi_application
13 
+
14 
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django_commu.settings')
15 
+
16 
+application = get_asgi_application()

+ 128 - 0
django_commu/settings.py
Прегледај датотеку 

@@ -0,0 +1,128 @@
1 
+"""
2 
+Django settings for django_commu project.
3 
+
4 
+Generated by 'django-admin startproject' using Django 5.2.4.
5 
+
6 
+For more information on this file, see
7 
+https://docs.djangoproject.com/en/5.2/topics/settings/
8 
+
9 
+For the full list of settings and their values, see
10 
+https://docs.djangoproject.com/en/5.2/ref/settings/
11 
+"""
12 
+
13 
+from pathlib import Path
14 
+import os
15 
+
16 
+# Build paths inside the project like this: BASE_DIR / 'subdir'.
17 
+BASE_DIR = Path(__file__).resolve().parent.parent
18 
+
19 
+
20 
+# Quick-start development settings - unsuitable for production
21 
+# See https://docs.djangoproject.com/en/5.2/howto/deployment/checklist/
22 
+
23 
+# SECURITY WARNING: keep the secret key used in production secret!
24 
+SECRET_KEY = 'django-insecure-c$ieo22nwe^v#*e$xlh@fath9*t+f8wtqrt9e!op9-ittc=b_x'
25 
+
26 
+# SECURITY WARNING: don't run with debug turned on in production!
27 
+DEBUG = True
28 
+
29 
+ALLOWED_HOSTS = []
30 
+
31 
+
32 
+# Application definition
33 
+
34 
+INSTALLED_APPS = [
35 
+    'django.contrib.admin',
36 
+    'django.contrib.auth',
37 
+    'django.contrib.contenttypes',
38 
+    'django.contrib.sessions',
39 
+    'django.contrib.messages',
40 
+    'django.contrib.staticfiles',
41 
+    'core',
42 
+]
43 
+
44 
+MIDDLEWARE = [
45 
+    'django.middleware.security.SecurityMiddleware',
46 
+    'django.contrib.sessions.middleware.SessionMiddleware',
47 
+    'django.middleware.common.CommonMiddleware',
48 
+    'django.middleware.csrf.CsrfViewMiddleware',
49 
+    'django.contrib.auth.middleware.AuthenticationMiddleware',
50 
+    'django.contrib.messages.middleware.MessageMiddleware',
51 
+    'django.middleware.clickjacking.XFrameOptionsMiddleware',
52 
+]
53 
+
54 
+ROOT_URLCONF = 'django_commu.urls'
55 
+
56 
+TEMPLATES = [
57 
+    {
58 
+        'BACKEND': 'django.template.backends.django.DjangoTemplates',
59 
+        'DIRS': [],
60 
+        'APP_DIRS': True,
61 
+        'OPTIONS': {
62 
+            'context_processors': [
63 
+                'django.template.context_processors.request',
64 
+                'django.contrib.auth.context_processors.auth',
65 
+                'django.contrib.messages.context_processors.messages',
66 
+            ],
67 
+        },
68 
+    },
69 
+]
70 
+
71 
+WSGI_APPLICATION = 'django_commu.wsgi.application'
72 
+
73 
+
74 
+# Database
75 
+# https://docs.djangoproject.com/en/5.2/ref/settings/#databases
76 
+
77 
+DATABASES = {
78 
+    'default': {
79 
+        'ENGINE': 'django.db.backends.postgresql',
80 
+        'NAME': os.getenv('DB_NAME', 'commudb'),
81 
+        'USER': os.getenv('DB_USER', 'commuuser'),
82 
+        'PASSWORD': os.getenv('DB_PASSWORD', 'commupass'),
83 
+        'HOST': os.getenv('DB_HOST', 'db'),
84 
+        'PORT': os.getenv('DB_PORT', '5432'),
85 
+    }
86 
+}
87 
+
88 
+
89 
+# Password validation
90 
+# https://docs.djangoproject.com/en/5.2/ref/settings/#auth-password-validators
91 
+
92 
+AUTH_PASSWORD_VALIDATORS = [
93 
+    {
94 
+        'NAME': 'django.contrib.auth.password_validation.UserAttributeSimilarityValidator',
95 
+    },
96 
+    {
97 
+        'NAME': 'django.contrib.auth.password_validation.MinimumLengthValidator',
98 
+    },
99 
+    {
100 
+        'NAME': 'django.contrib.auth.password_validation.CommonPasswordValidator',
101 
+    },
102 
+    {
103 
+        'NAME': 'django.contrib.auth.password_validation.NumericPasswordValidator',
104 
+    },
105 
+]
106 
+
107 
+
108 
+# Internationalization
109 
+# https://docs.djangoproject.com/en/5.2/topics/i18n/
110 
+
111 
+LANGUAGE_CODE = 'en-us'
112 
+
113 
+TIME_ZONE = 'UTC'
114 
+
115 
+USE_I18N = True
116 
+
117 
+USE_TZ = True
118 
+
119 
+
120 
+# Static files (CSS, JavaScript, Images)
121 
+# https://docs.djangoproject.com/en/5.2/howto/static-files/
122 
+
123 
+STATIC_URL = 'static/'
124 
+
125 
+# Default primary key field type
126 
+# https://docs.djangoproject.com/en/5.2/ref/settings/#default-auto-field
127 
+
128 
+DEFAULT_AUTO_FIELD = 'django.db.models.BigAutoField'

+ 23 - 0
django_commu/urls.py
Прегледај датотеку 

@@ -0,0 +1,23 @@
1 
+"""
2 
+URL configuration for django_commu project.
3 
+
4 
+The `urlpatterns` list routes URLs to views. For more information please see:
5 
+    https://docs.djangoproject.com/en/5.2/topics/http/urls/
6 
+Examples:
7 
+Function views
8 
+    1. Add an import:  from my_app import views
9 
+    2. Add a URL to urlpatterns:  path('', views.home, name='home')
10 
+Class-based views
11 
+    1. Add an import:  from other_app.views import Home
12 
+    2. Add a URL to urlpatterns:  path('', Home.as_view(), name='home')
13 
+Including another URLconf
14 
+    1. Import the include() function: from django.urls import include, path
15 
+    2. Add a URL to urlpatterns:  path('blog/', include('blog.urls'))
16 
+"""
17 
+from django.contrib import admin
18 
+from django.urls import path, include
19 
+
20 
+urlpatterns = [
21 
+    path('admin/', admin.site.urls),
22 
+    path('core/', include('core.urls')),
23 
+]

+ 16 - 0
django_commu/wsgi.py
Прегледај датотеку 

@@ -0,0 +1,16 @@
1 
+"""
2 
+WSGI config for django_commu project.
3 
+
4 
+It exposes the WSGI callable as a module-level variable named ``application``.
5 
+
6 
+For more information on this file, see
7 
+https://docs.djangoproject.com/en/5.2/howto/deployment/wsgi/
8 
+"""
9 
+
10 
+import os
11 
+
12 
+from django.core.wsgi import get_wsgi_application
13 
+
14 
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django_commu.settings')
15 
+
16 
+application = get_wsgi_application()

+ 40 - 0
docker-compose.yml
Прегледај датотеку 

@@ -0,0 +1,40 @@
1 
+version: '3.9'
2 
+
3 
+services:
4 
+  db:
5 
+    image: postgres:16
6 
+    environment:
7 
+      POSTGRES_DB: commudb
8 
+      POSTGRES_USER: commuuser
9 
+      POSTGRES_PASSWORD: commupass
10 
+    ports:
11 
+      - "5432:5432"
12 
+    volumes:
13 
+      - postgres_data:/var/lib/postgresql/data
14 
+
15 
+  web:
16 
+    build:
17 
+      context: .
18 
+      args:
19 
+        UID: ${UID}
20 
+        GID: ${GID}
21 
+    user: "${UID}:${GID}"
22 
+    command: >
23 
+      sh -c "python manage.py runserver 0.0.0.0:8000"
24 
+    volumes:
25 
+      - .:/app
26 
+    working_dir: /app
27 
+    ports:
28 
+      - "8000:8000"
29 
+    depends_on:
30 
+      - db
31 
+    environment:
32 
+      - DEBUG=1
33 
+      - DB_NAME=commudb
34 
+      - DB_USER=commuuser
35 
+      - DB_PASSWORD=commupass
36 
+      - DB_HOST=db
37 
+      - DB_PORT=5432
38 
+
39 
+volumes:
40 
+  postgres_data:

+ 38 - 0
main.py
Прегледај датотеку 

@@ -0,0 +1,38 @@
1 
+from commu.infrastructure.memory_user_repository import InMemoryUserRepository
2 
+from commu.infrastructure.memory_post_repository import InMemoryPostRepository
3 
+from commu.usecases.user_service import UserService
4 
+from commu.usecases.post_service import PostService
5 
+from commu.entities.user import UserRole
6 
+
7 
+def main():
8 
+    user_repo = InMemoryUserRepository()
9 
+    post_repo = InMemoryPostRepository()
10 
+    user_service = UserService(user_repo)
11 
+    post_service = PostService(post_repo, user_repo)
12 
+
13 
+    # Create users
14 
+    admin = user_service.register("alice", UserRole.ADMIN)
15 
+    user = user_service.register("bob", UserRole.USER)
16 
+    guest = user_service.register("guest", UserRole.GUEST)
17 
+
18 
+    # User creates post
19 
+    post = post_service.create_post(user.id, "Hello world!", images=["img1.png"], videos=["vid1.mp4"])
20 
+    print(f"Created Post: {post.text}, by {user.username}")
21 
+
22 
+    # Post search
23 
+    found = post_service.search_posts("hello")
24 
+    print(f"Found {len(found)} posts containing 'hello'.")
25 
+
26 
+    # Post rating
27 
+    post_service.rate_post(post.id, admin.id, 5)
28 
+    post_service.rate_post(post.id, user.id, 4)
29 
+    print(f"Average Rating: {post.average_rating()}")
30 
+
31 
+    # Guest tries to create post (should fail)
32 
+    try:
33 
+        post_service.create_post(guest.id, "I am a guest")
34 
+    except PermissionError as e:
35 
+        print("Guest cannot create post:", e)
36 
+
37 
+if __name__ == "__main__":
38 
+    main()

+ 22 - 0
manage.py
Прегледај датотеку 

@@ -0,0 +1,22 @@
1 
+#!/usr/bin/env python
2 
+"""Django's command-line utility for administrative tasks."""
3 
+import os
4 
+import sys
5 
+
6 
+
7 
+def main():
8 
+    """Run administrative tasks."""
9 
+    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django_commu.settings')
10 
+    try:
11 
+        from django.core.management import execute_from_command_line
12 
+    except ImportError as exc:
13 
+        raise ImportError(
14 
+            "Couldn't import Django. Are you sure it's installed and "
15 
+            "available on your PYTHONPATH environment variable? Did you "
16 
+            "forget to activate a virtual environment?"
17 
+        ) from exc
18 
+    execute_from_command_line(sys.argv)
19 
+
20 
+
21 
+if __name__ == '__main__':
22 
+    main()

+ 3 - 0
requirements.txt
Прегледај датотеку 

@@ -0,0 +1,3 @@
1 
+pytest
2 
+Django>=4.2
3 
+psycopg2-binary

tum/whitesports - Gogs: Simplico Git Service
Home Esplora Aiuto
Accedi
tum
/
whitesports
Segui 1
Vota 0
Forka 0
Codice Problemi 0 Pull Requests 0 Commit 7 Rilasci 0 Wiki

Nessuna descrizione

Albero (Tree): 853f55d83f
Rami (Branch) Tag
whitesports
/
app
/
wp-content
/
plugins
/
mailpoet
/
lib
/
Entities
/
NewsletterEn...

NewsletterEntity.php 11KB
Cronologia Originale

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493 
  1. <?php
    2. 

  2. 

  3. namespace MailPoet\Entities;
    4. 

  4. 

  5. if (!defined('ABSPATH')) exit;
    6. 

  6. 

  7. 

  8. use DateTimeInterface;
    9. 

  9. use MailPoet\Doctrine\EntityTraits\AutoincrementedIdTrait;
    10. 

  10. use MailPoet\Doctrine\EntityTraits\CreatedAtTrait;
    11. 

  11. use MailPoet\Doctrine\EntityTraits\DeletedAtTrait;
    12. 

  12. use MailPoet\Doctrine\EntityTraits\SafeToOneAssociationLoadTrait;
    13. 

  13. use MailPoet\Doctrine\EntityTraits\UpdatedAtTrait;
    14. 

  14. use MailPoet\Util\Helpers;
    15. 

  15. use MailPoetVendor\Carbon\Carbon;
    16. 

  16. use MailPoetVendor\Doctrine\Common\Collections\ArrayCollection;
    17. 

  17. use MailPoetVendor\Doctrine\Common\Collections\Collection;
    18. 

  18. use MailPoetVendor\Doctrine\Common\Collections\Criteria;
    19. 

  19. use MailPoetVendor\Doctrine\ORM\Mapping as ORM;
    20. 

  20. use MailPoetVendor\Symfony\Component\Validator\Constraints as Assert;
    21. 

  21. 

  22. /**
    23. 

  23.  * @ORM\Entity()
    24. 

  24.  * @ORM\Table(name="newsletters")
    25. 

  25.  */
    26. 

  26. class NewsletterEntity {
    27. 

  27.   // types
    28. 

  28.   const TYPE_AUTOMATIC = 'automatic';
    29. 

  29.   const TYPE_STANDARD = 'standard';
    30. 

  30.   const TYPE_WELCOME = 'welcome';
    31. 

  31.   const TYPE_NOTIFICATION = 'notification';
    32. 

  32.   const TYPE_NOTIFICATION_HISTORY = 'notification_history';
    33. 

  33.   const TYPE_WC_TRANSACTIONAL_EMAIL = 'wc_transactional';
    34. 

  34.   const TYPE_RE_ENGAGEMENT = 're_engagement';
    35. 

  35. 

  36.   // standard newsletters
    37. 

  37.   const STATUS_DRAFT = 'draft';
    38. 

  38.   const STATUS_SCHEDULED = 'scheduled';
    39. 

  39.   const STATUS_SENDING = 'sending';
    40. 

  40.   const STATUS_SENT = 'sent';
    41. 

  41. 

  42.   // automatic newsletters status
    43. 

  43.   const STATUS_ACTIVE = 'active';
    44. 

  44. 

  45.   use AutoincrementedIdTrait;
    46. 

  46.   use CreatedAtTrait;
    47. 

  47.   use UpdatedAtTrait;
    48. 

  48.   use DeletedAtTrait;
    49. 

  49.   use SafeToOneAssociationLoadTrait;
    50. 

  50. 

  51.   /**
    52. 

  52.    * @ORM\Column(type="string", nullable=true)
    53. 

  53.    * @var string|null
    54. 

  54.    */
    55. 

  55.   private $hash;
    56. 

  56. 

  57.   /**
    58. 

  58.    * @ORM\Column(type="string")
    59. 

  59.    * @var string
    60. 

  60.    */
    61. 

  61.   private $subject;
    62. 

  62. 

  63.   /**
    64. 

  64.    * @ORM\Column(type="string")
    65. 

  65.    * @Assert\NotBlank()
    66. 

  66.    * @var string
    67. 

  67.    */
    68. 

  68.   private $type;
    69. 

  69. 

  70.   /**
    71. 

  71.    * @ORM\Column(type="string")
    72. 

  72.    * @var string
    73. 

  73.    */
    74. 

  74.   private $senderAddress = '';
    75. 

  75. 

  76.   /**
    77. 

  77.    * @ORM\Column(type="string")
    78. 

  78.    * @var string
    79. 

  79.    */
    80. 

  80.   private $senderName = '';
    81. 

  81. 

  82.   /**
    83. 

  83.    * @ORM\Column(type="string")
    84. 

  84.    * @var string
    85. 

  85.    */
    86. 

  86.   private $status = self::STATUS_DRAFT;
    87. 

  87. 

  88.   /**
    89. 

  89.    * @ORM\Column(type="string")
    90. 

  90.    * @var string
    91. 

  91.    */
    92. 

  92.   private $replyToAddress = '';
    93. 

  93. 

  94.   /**
    95. 

  95.    * @ORM\Column(type="string")
    96. 

  96.    * @var string
    97. 

  97.    */
    98. 

  98.   private $replyToName = '';
    99. 

  99. 

  100.   /**
    101. 

  101.    * @ORM\Column(type="string")
    102. 

  102.    * @var string
    103. 

  103.    */
    104. 

  104.   private $preheader = '';
    105. 

  105. 

  106.   /**
    107. 

  107.    * @ORM\Column(type="json", nullable=true)
    108. 

  108.    * @var array|null
    109. 

  109.    */
    110. 

  110.   private $body;
    111. 

  111. 

  112.   /**
    113. 

  113.    * @ORM\Column(type="datetimetz", nullable=true)
    114. 

  114.    * @var DateTimeInterface|null
    115. 

  115.    */
    116. 

  116.   private $sentAt;
    117. 

  117. 

  118.   /**
    119. 

  119.    * @ORM\Column(type="string", nullable=true)
    120. 

  120.    * @var string|null
    121. 

  121.    */
    122. 

  122.   private $unsubscribeToken;
    123. 

  123. 

  124.   /**
    125. 

  125.    * @ORM\Column(type="string")
    126. 

  126.    * @var string
    127. 

  127.    */
    128. 

  128.   private $gaCampaign = '';
    129. 

  129. 

  130.   /**
    131. 

  131.    * @ORM\ManyToOne(targetEntity="MailPoet\Entities\NewsletterEntity")
    132. 

  132.    * @var NewsletterEntity|null
    133. 

  133.    */
    134. 

  134.   private $parent;
    135. 

  135. 

  136.   /**
    137. 

  137.    * @ORM\OneToMany(targetEntity="MailPoet\Entities\NewsletterEntity", mappedBy="parent")
    138. 

  138.    * @var ArrayCollection<int, NewsletterEntity>
    139. 

  139.    */
    140. 

  140.   private $children;
    141. 

  141. 

  142.   /**
    143. 

  143.    * @ORM\OneToMany(targetEntity="MailPoet\Entities\NewsletterSegmentEntity", mappedBy="newsletter", orphanRemoval=true)
    144. 

  144.    * @var ArrayCollection<int, NewsletterSegmentEntity>
    145. 

  145.    */
    146. 

  146.   private $newsletterSegments;
    147. 

  147. 

  148.   /**
    149. 

  149.    * @ORM\OneToMany(targetEntity="MailPoet\Entities\NewsletterOptionEntity", mappedBy="newsletter", orphanRemoval=true)
    150. 

  150.    * @var ArrayCollection<int, NewsletterOptionEntity>
    151. 

  151.    */
    152. 

  152.   private $options;
    153. 

  153. 

  154.   /**
    155. 

  155.    * @ORM\OneToMany(targetEntity="MailPoet\Entities\SendingQueueEntity", mappedBy="newsletter")
    156. 

  156.    * @var ArrayCollection<int, SendingQueueEntity>
    157. 

  157.    */
    158. 

  158.   private $queues;
    159. 

  159. 

  160.   public function __construct() {
    161. 

  161.     $this->children = new ArrayCollection();
    162. 

  162.     $this->newsletterSegments = new ArrayCollection();
    163. 

  163.     $this->options = new ArrayCollection();
    164. 

  164.     $this->queues = new ArrayCollection();
    165. 

  165.   }
    166. 

  166. 

  167.   /**
    168. 

  168.    * @deprecated This is here only for backward compatibility with custom shortcodes https://kb.mailpoet.com/article/160-create-a-custom-shortcode
    169. 

  169.    * This can be removed after 2021-08-01
    170. 

  170.    */
    171. 

  171.   public function __get($key) {
    172. 

  172.     $getterName = 'get' . Helpers::underscoreToCamelCase($key, $capitaliseFirstChar = true);
    173. 

  173.     $callable = [$this, $getterName];
    174. 

  174.     if (is_callable($callable)) {
    175. 

  175.       return call_user_func($callable);
    176. 

  176.     }
    177. 

  177.   }
    178. 

  178. 

  179.   public function __clone() {
    180. 

  180.     // reset ID
    181. 

  181.     $this->id = null;
    182. 

  182.   }
    183. 

  183. 

  184.   /**
    185. 

  185.    * @return string|null
    186. 

  186.    */
    187. 

  187.   public function getHash() {
    188. 

  188.     return $this->hash;
    189. 

  189.   }
    190. 

  190. 

  191.   /**
    192. 

  192.    * @param string|null $hash
    193. 

  193.    */
    194. 

  194.   public function setHash($hash) {
    195. 

  195.     $this->hash = $hash;
    196. 

  196.   }
    197. 

  197. 

  198.   /**
    199. 

  199.    * @return string
    200. 

  200.    */
    201. 

  201.   public function getSubject() {
    202. 

  202.     return $this->subject;
    203. 

  203.   }
    204. 

  204. 

  205.   /**
    206. 

  206.    * @param string $subject
    207. 

  207.    */
    208. 

  208.   public function setSubject($subject) {
    209. 

  209.     $this->subject = $subject;
    210. 

  210.   }
    211. 

  211. 

  212.   /**
    213. 

  213.    * @return string
    214. 

  214.    */
    215. 

  215.   public function getType() {
    216. 

  216.     return $this->type;
    217. 

  217.   }
    218. 

  218. 

  219.   /**
    220. 

  220.    * @param string $type
    221. 

  221.    */
    222. 

  222.   public function setType($type) {
    223. 

  223.     $this->type = $type;
    224. 

  224.   }
    225. 

  225. 

  226.   /**
    227. 

  227.    * @return string
    228. 

  228.    */
    229. 

  229.   public function getSenderAddress() {
    230. 

  230.     return $this->senderAddress;
    231. 

  231.   }
    232. 

  232. 

  233.   /**
    234. 

  234.    * @param string $senderAddress
    235. 

  235.    */
    236. 

  236.   public function setSenderAddress($senderAddress) {
    237. 

  237.     $this->senderAddress = $senderAddress;
    238. 

  238.   }
    239. 

  239. 

  240.   /**
    241. 

  241.    * @return string
    242. 

  242.    */
    243. 

  243.   public function getSenderName() {
    244. 

  244.     return $this->senderName;
    245. 

  245.   }
    246. 

  246. 

  247.   /**
    248. 

  248.    * @param string $senderName
    249. 

  249.    */
    250. 

  250.   public function setSenderName($senderName) {
    251. 

  251.     $this->senderName = $senderName;
    252. 

  252.   }
    253. 

  253. 

  254.   /**
    255. 

  255.    * @return string
    256. 

  256.    */
    257. 

  257.   public function getStatus() {
    258. 

  258.     return $this->status;
    259. 

  259.   }
    260. 

  260. 

  261.   /**
    262. 

  262.    * @param string $status
    263. 

  263.    */
    264. 

  264.   public function setStatus($status) {
    265. 

  265.     $this->status = $status;
    266. 

  266. 

  267.     // activate/deactivate unfinished tasks
    268. 

  268.     $newTaskStatus = null;
    269. 

  269.     $typesWithActivation = [self::TYPE_NOTIFICATION, self::TYPE_WELCOME, self::TYPE_AUTOMATIC];
    270. 

  270. 

  271.     if (($status === self::STATUS_DRAFT) && in_array($this->type, $typesWithActivation)) {
    272. 

  272.       $newTaskStatus = ScheduledTaskEntity::STATUS_PAUSED;
    273. 

  273.     }
    274. 

  274.     if (($status === self::STATUS_ACTIVE) && in_array($this->type, $typesWithActivation)) {
    275. 

  275.       $newTaskStatus = ScheduledTaskEntity::STATUS_SCHEDULED;
    276. 

  276.     }
    277. 

  277. 

  278.     if (!$newTaskStatus) return;
    279. 

  279. 

  280.     $queues = $this->getUnfinishedQueues();
    281. 

  281. 

  282.     foreach ($queues as $queue) {
    283. 

  283.       /** @var SendingQueueEntity $queue */
    284. 

  284.       $task = $queue->getTask();
    285. 

  285.       if ($task === null) continue;
    286. 

  286. 

  287.       $scheduled = new Carbon($task->getScheduledAt());
    288. 

  288.       if ($scheduled < (new Carbon())->subDays(30)) continue;
    289. 

  289. 

  290.       if (($status === self::STATUS_DRAFT) && ($task->getStatus() !== ScheduledTaskEntity::STATUS_SCHEDULED)) continue;
    291. 

  291.       if (($status === self::STATUS_ACTIVE) && ($task->getStatus() !== ScheduledTaskEntity::STATUS_PAUSED)) continue;
    292. 

  292. 

  293.       $task->setStatus($newTaskStatus);
    294. 

  294.     }
    295. 

  295.   }
    296. 

  296. 

  297.   /**
    298. 

  298.    * @return string
    299. 

  299.    */
    300. 

  300.   public function getReplyToAddress() {
    301. 

  301.     return $this->replyToAddress;
    302. 

  302.   }
    303. 

  303. 

  304.   /**
    305. 

  305.    * @param string $replyToAddress
    306. 

  306.    */
    307. 

  307.   public function setReplyToAddress($replyToAddress) {
    308. 

  308.     $this->replyToAddress = $replyToAddress;
    309. 

  309.   }
    310. 

  310. 

  311.   /**
    312. 

  312.    * @return string
    313. 

  313.    */
    314. 

  314.   public function getReplyToName() {
    315. 

  315.     return $this->replyToName;
    316. 

  316.   }
    317. 

  317. 

  318.   /**
    319. 

  319.    * @param string $replyToName
    320. 

  320.    */
    321. 

  321.   public function setReplyToName($replyToName) {
    322. 

  322.     $this->replyToName = $replyToName;
    323. 

  323.   }
    324. 

  324. 

  325.   /**
    326. 

  326.    * @return string
    327. 

  327.    */
    328. 

  328.   public function getPreheader() {
    329. 

  329.     return $this->preheader;
    330. 

  330.   }
    331. 

  331. 

  332.   /**
    333. 

  333.    * @param string $preheader
    334. 

  334.    */
    335. 

  335.   public function setPreheader($preheader) {
    336. 

  336.     $this->preheader = $preheader;
    337. 

  337.   }
    338. 

  338. 

  339.   /**
    340. 

  340.    * @return array|null
    341. 

  341.    */
    342. 

  342.   public function getBody() {
    343. 

  343.     return $this->body;
    344. 

  344.   }
    345. 

  345. 

  346.   /**
    347. 

  347.    * @param array|null $body
    348. 

  348.    */
    349. 

  349.   public function setBody($body) {
    350. 

  350.     $this->body = $body;
    351. 

  351.   }
    352. 

  352. 

  353.   /**
    354. 

  354.    * @return DateTimeInterface|null
    355. 

  355.    */
    356. 

  356.   public function getSentAt() {
    357. 

  357.     return $this->sentAt;
    358. 

  358.   }
    359. 

  359. 

  360.   /**
    361. 

  361.    * @param DateTimeInterface|null $sentAt
    362. 

  362.    */
    363. 

  363.   public function setSentAt($sentAt) {
    364. 

  364.     $this->sentAt = $sentAt;
    365. 

  365.   }
    366. 

  366. 

  367.   /**
    368. 

  368.    * @return string|null
    369. 

  369.    */
    370. 

  370.   public function getUnsubscribeToken() {
    371. 

  371.     return $this->unsubscribeToken;
    372. 

  372.   }
    373. 

  373. 

  374.   /**
    375. 

  375.    * @return string
    376. 

  376.    */
    377. 

  377.   public function getGaCampaign() {
    378. 

  378.     return $this->gaCampaign;
    379. 

  379.   }
    380. 

  380. 

  381.   /**
    382. 

  382.    * @param string $gaCampaign
    383. 

  383.    */
    384. 

  384.   public function setGaCampaign($gaCampaign) {
    385. 

  385.     $this->gaCampaign = $gaCampaign;
    386. 

  386.   }
    387. 

  387. 

  388.   /**
    389. 

  389.    * @param string|null $unsubscribeToken
    390. 

  390.    */
    391. 

  391.   public function setUnsubscribeToken($unsubscribeToken) {
    392. 

  392.     $this->unsubscribeToken = $unsubscribeToken;
    393. 

  393.   }
    394. 

  394. 

  395.   /**
    396. 

  396.    * @return NewsletterEntity|null
    397. 

  397.    */
    398. 

  398.   public function getParent() {
    399. 

  399.     $this->safelyLoadToOneAssociation('parent');
    400. 

  400.     return $this->parent;
    401. 

  401.   }
    402. 

  402. 

  403.   /**
    404. 

  404.    * @param NewsletterEntity|null $parent
    405. 

  405.    */
    406. 

  406.   public function setParent($parent) {
    407. 

  407.     $this->parent = $parent;
    408. 

  408.   }
    409. 

  409. 

  410.   /**
    411. 

  411.    * @return ArrayCollection<int, NewsletterEntity>
    412. 

  412.    */
    413. 

  413.   public function getChildren() {
    414. 

  414.     return $this->children;
    415. 

  415.   }
    416. 

  416. 

  417.   /**
    418. 

  418.    * @return ArrayCollection<int, NewsletterSegmentEntity>
    419. 

  419.    */
    420. 

  420.   public function getNewsletterSegments() {
    421. 

  421.     return $this->newsletterSegments;
    422. 

  422.   }
    423. 

  423. 

  424.   /**
    425. 

  425.    * @return ArrayCollection<int, NewsletterOptionEntity>
    426. 

  426.    */
    427. 

  427.   public function getOptions() {
    428. 

  428.     return $this->options;
    429. 

  429.   }
    430. 

  430. 

  431.   public function getOption(string $name): ?NewsletterOptionEntity {
    432. 

  432.     $option = $this->options->filter(function (NewsletterOptionEntity $option) use ($name): bool {
    433. 

  433.       return ($field = $option->getOptionField()) ? $field->getName() === $name : false;
    434. 

  434.     })->first();
    435. 

  435.     return $option ?: null;
    436. 

  436.   }
    437. 

  437. 

  438.   public function getOptionValue(string $name) {
    439. 

  439.     $option = $this->getOption($name);
    440. 

  440.     return $option ? $option->getValue() : null;
    441. 

  441.   }
    442. 

  442. 

  443.   /**
    444. 

  444.    * @return ArrayCollection<int, SendingQueueEntity>
    445. 

  445.    */
    446. 

  446.   public function getQueues() {
    447. 

  447.     return $this->queues;
    448. 

  448.   }
    449. 

  449. 

  450.   /**
    451. 

  451.    * @return SendingQueueEntity|null
    452. 

  452.    */
    453. 

  453.   public function getLatestQueue() {
    454. 

  454.     $criteria = new Criteria();
    455. 

  455.     $criteria->orderBy(['id' => Criteria::DESC]);
    456. 

  456.     $criteria->setMaxResults(1);
    457. 

  457.     return $this->queues->matching($criteria)->first() ?: null;
    458. 

  458.   }
    459. 

  459. 

  460.   /**
    461. 

  461.    * @return Collection<int, SendingQueueEntity>
    462. 

  462.    */
    463. 

  463.   private function getUnfinishedQueues(): Collection {
    464. 

  464.     $criteria = new Criteria();
    465. 

  465.     $expr = Criteria::expr();
    466. 

  466.     $criteria->where($expr->neq('countToProcess', 0));
    467. 

  467.     return $this->queues->matching($criteria);
    468. 

  468.   }
    469. 

  469. 

  470.   public function getGlobalStyle(string $category, string $style): ?string {
    471. 

  471.     $body = $this->getBody();
    472. 

  472.     if ($body === null) {
    473. 

  473.       return null;
    474. 

  474.     }
    475. 

  475.     return $body['globalStyles'][$category][$style] ?? null;
    476. 

  476.   }
    477. 

  477. 

  478.   public function getProcessedAt(): ?DateTimeInterface {
    479. 

  479.     $processedAt = null;
    480. 

  480.     $queue = $this->getLatestQueue();
    481. 

  481. 

  482.     if ($queue instanceof SendingQueueEntity) {
    483. 

  483.       $task = $queue->getTask();
    484. 

  484. 

  485.       if ($task instanceof ScheduledTaskEntity) {
    486. 

  486.         $processedAt = $task->getProcessedAt();
    487. 

  487.       }
    488. 

  488.     }
    489. 

  489. 

  490.     return $processedAt;
    491. 

  491.   }
    492. 

  492. }
    493. 

  493.