de"> 
@@ -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
View File 

@@ -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
View File


BIN
commu/tests/__pycache__/__init__.cpython-310.pyc
View File


BIN
commu/tests/__pycache__/__init__.cpython-311.pyc
View File


BIN
commu/tests/__pycache__/test_post_repository.cpython-310-pytest-8.4.1.pyc
View File


BIN
commu/tests/__pycache__/test_post_repository.cpython-311.pyc
View File


BIN
commu/tests/__pycache__/test_post_service.cpython-310-pytest-8.4.1.pyc
View File


BIN
commu/tests/__pycache__/test_post_service.cpython-311.pyc
View File


BIN
commu/tests/__pycache__/test_user_service.cpython-310-pytest-8.4.1.pyc
View File


BIN
commu/tests/__pycache__/test_user_service.cpython-311.pyc
View File


+ 27 - 0
commu/tests/test_post_repository.py
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File


BIN
commu/usecases/__pycache__/__init__.cpython-310.pyc
View File


BIN
commu/usecases/__pycache__/__init__.cpython-311.pyc
View File


BIN
commu/usecases/__pycache__/post_service.cpython-310.pyc
View File


BIN
commu/usecases/__pycache__/post_service.cpython-311.pyc
View File


BIN
commu/usecases/__pycache__/user_service.cpython-310.pyc
View File


BIN
commu/usecases/__pycache__/user_service.cpython-311.pyc
View File


+ 28 - 0
commu/usecases/post_service.py
View File 

@@ -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
View File 

@@ -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
View File


BIN
core/__pycache__/__init__.cpython-311.pyc
View File


BIN
core/__pycache__/admin.cpython-311.pyc
View File


BIN
core/__pycache__/apps.cpython-311.pyc
View File


BIN
core/__pycache__/models.cpython-311.pyc
View File


BIN
core/__pycache__/tests.cpython-311.pyc
View File


BIN
core/__pycache__/urls.cpython-311.pyc
View File


BIN
core/__pycache__/views.cpython-311.pyc
View File


+ 3 - 0
core/admin.py
View File 

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

+ 6 - 0
core/apps.py
View File 

@@ -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
View File 

@@ -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
View File


BIN
core/migrations/__pycache__/0001_initial.cpython-311.pyc
View File


BIN
core/migrations/__pycache__/__init__.cpython-311.pyc
View File


+ 18 - 0
core/models.py
View File 

@@ -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
View File


BIN
core/repositories/__pycache__/django_user_repository.cpython-311.pyc
View File


+ 112 - 0
core/repositories/django_post_repository.py
View File 

@@ -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
View File 

@@ -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
View File 

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

+ 0 - 0
core/tests/__init__.py
View File


BIN
core/tests/__pycache__/__init__.cpython-311.pyc
View File


BIN
core/tests/__pycache__/test_post_service_django.cpython-311.pyc
View File


+ 60 - 0
core/tests/test_post_service_django.py
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File


+ 0 - 0
django_commu/__init__.py
View File


BIN
django_commu/__pycache__/__init__.cpython-311.pyc
View File


BIN
django_commu/__pycache__/settings.cpython-311.pyc
View File


BIN
django_commu/__pycache__/urls.cpython-311.pyc
View File


BIN
django_commu/__pycache__/wsgi.cpython-311.pyc
View File


+ 16 - 0
django_commu/asgi.py
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File 

@@ -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
View File 

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

tum/whitesports - Gogs: Simplico Git Service
Inicio Explorar Ayuda
Iniciar sesión
tum
/
whitesports
Seguir 1
Destacar 0
Fork 0
Código Incidencias 0 Pull Requests 0 Commits 6 Releases 0 Wiki

Sin descripción

Árbol: cc318a25cd
Ramas Etiquetas
whitesports
/
app
/
wp-content
/
plugins
/
copy-delete-...
/
post
/
handler.php

handler.php 45KB
Histórico Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239 
  1. <?php
    2. 

  2. 

  3. /**
    4. 

  4.  * Copy & Delete Posts – Post requests handler file.
    5. 

  5.  *
    6. 

  6.  * @package CDP
    7. 

  7.  * @subpackage PostHandler
    8. 

  8.  * @author CopyDeletePosts
    9. 

  9.  * @since 1.0.0
    10. 

  10.  * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
    11. 

  11. /** –– **\
    12. 

  12.  * Main handler + It will also sanitize and verify that request a little bit.
    13. 

  13.  * @since 1.0.0
    14. 

  14.  */
    15. 

  15. add_action('wp_ajax_cdp_action_handling', function () {
    16. 

  16.     if (isset($_SERVER['HTTP_X_REQUESTED_WITH']) && strtolower($_SERVER['HTTP_X_REQUESTED_WITH']) === 'xmlhttprequest') {
    17. 

  17.         if (isset($_POST['token']) && $_POST['token'] == 'cdp' && isset($_POST['f']) && is_admin()) {
    18. 

  18. 

  19.             // Expand execution time
    20. 

  20.             if (intval(ini_get('max_execution_time')) < 7200)
    21. 

  21.                 set_time_limit(0);
    22. 

  22. 

  23.             // Get WP-Plugin path
    24. 

  24.             $premium_plugin = 'copy-delete-posts-premium/copy-delete-posts-premium.php';
    25. 

  25.             $premium_dir = WP_PLUGIN_DIR . '/' . 'copy-delete-posts-premium';
    26. 

  26.             $pplugin_path = $premium_dir . '/handler/premium.php';
    27. 

  27. 

  28.             // Load premium content if the plugin is here
    29. 

  29.             if (is_dir($premium_dir) && is_plugin_active($premium_plugin))
    30. 

  30.                 require_once($pplugin_path);
    31. 

  31. 

  32.             // Is premium function
    33. 

  33.             $areWePro = is_plugin_active($premium_plugin);
    34. 

  34. 

  35.             // Get user roles and check if the role is permmited to use plugin
    36. 

  36.             $access = false;
    37. 

  37.             $current_user = wp_get_current_user();
    38. 

  38.             $access_roles = get_option('_cdp_globals');
    39. 

  39.             if (!isset($access_roles['roles']))
    40. 

  40.                 $access_roles = array();
    41. 

  41.             foreach ($current_user->roles as $role => $name)
    42. 

  42.                 if ($name == 'administrator' || (isset($access_roles['roles'][$name]) && $access_roles['roles'][$name] == 'true')) {
    43. 

  43.                     $access = true;
    44. 

  44.                     break;
    45. 

  45.                 }
    46. 

  46. 

  47.             // Check user permission
    48. 

  48.             if ($access === true) {
    49. 

  49. 

  50.                 // Pointers
    51. 

  51.                 if ($_POST['f'] == 'no_intro')
    52. 

  52.                     cdp_add_new_no_intro();
    53. 

  53.                 else if ($_POST['f'] == 'intro_again')
    54. 

  54.                     cdp_add_new_intro();
    55. 

  55.                 else if ($_POST['f'] == 'save_options')
    56. 

  56.                     cdp_save_plugin_options($areWePro);
    57. 

  57.                 else if ($_POST['f'] == 'copy_post')
    58. 

  58.                     cdp_insert_new_post($areWePro);
    59. 

  59.                 else if ($_POST['f'] == 'get_settings')
    60. 

  60.                     cdp_get_profile();
    61. 

  61.                 else if ($_POST['f'] == 'get_all_settings')
    62. 

  62.                     cdp_get_all_profiles();
    63. 

  63.                 else if ($_POST['f'] == 'save_profiles' && $areWePro)
    64. 

  64.                     cdp_save_profile_set();
    65. 

  65.                 else if ($_POST['f'] == 'get_all_posts')
    66. 

  66.                     cdp_get_all_posts();
    67. 

  67.                 else if ($_POST['f'] == 'delete_them')
    68. 

  68.                     cdp_delete_posts();
    69. 

  69.                 else if ($_POST['f'] == 'get_formatted_time' && $areWePro)
    70. 

  70.                     cdp_formatted_time();
    71. 

  71.                 else if ($_POST['f'] == 'set_default_profile')
    72. 

  72.                     cdp_set_default_profile();
    73. 

  73.                 else if ($_POST['f'] == 'get_default_profile')
    74. 

  74.                     cdp_get_default_profile();
    75. 

  75.                 else if ($_POST['f'] == 'clear_crons')
    76. 

  76.                     cdp_clear_all_crons();
    77. 

  77.                 else if ($_POST['f'] == 'i_saw_this_noti')
    78. 

  78.                     cdp_set_noti_as_seen();
    79. 

  79.                 else if ($_POST['f'] == 'try_to_hide_the_tasks')
    80. 

  80.                     cdp_just_hide_task();
    81. 

  81.                 else if ($_POST['f'] == 'try_to_kill_the_tasks')
    82. 

  82.                     cdp_just_kill_task();
    83. 

  83.                 else if ($_POST['f'] == 'give_me_current_tasks')
    84. 

  84.                     cdp_just_get_tasks();
    85. 

  85.                 else if ($_POST['f'] == 'hide_cron_notice')
    86. 

  86.                     cdp_hide_perf_notice();
    87. 

  87.                 else if ($_POST['f'] == 'review_dismiss')
    88. 

  88.                     cdp_review();
    89. 

  89.                 else if ($_POST['f'] == 'debug_function')
    90. 

  90.                     cdp_debug_function();
    91. 

  91.                 else if ($_POST['f'] == 'delete_success_img')
    92. 

  92.                     delete_option('_cdp_show_copy');
    93. 

  93.                 else if ($_POST['f'] == 'save_redi_state' && $areWePro)
    94. 

  94.                     cdpp_save_redi_state();
    95. 

  95.                 else if ($_POST['f'] == 'multi_redi_importer' && $areWePro)
    96. 

  96.                     cdpp_redis_importer();
    97. 

  97.                 else if ($_POST['f'] == 'save_redirections' && $areWePro)
    98. 

  98.                     cdpp_save_redirections();
    99. 

  99.                 else if ($_POST['f'] == 'delete_redirect' && $areWePro)
    100. 

  100.                     cdpp_delete_redirection();
    101. 

  101.                 else if ($_POST['f'] == 'switch_redirects' && $areWePro)
    102. 

  102.                     cdpp_switch_redirects();
    103. 

  103.                 else if ($_POST['f'] == 'get_authors' && $areWePro)
    104. 

  104.                     cdpp_get_authors();
    105. 

  105.                 else if ($_POST['f'] == 'get_curr_time' && $areWePro)
    106. 

  106.                     cdpp_get_curr_s_time();
    107. 

  107.                 else if ($_POST['f'] == 'get_post_export' && $areWePro)
    108. 

  108.                     cdpp_get_for_export();
    109. 

  109.                 else if ($_POST['f'] == 'import_posts' && $areWePro)
    110. 

  110.                     cdpp_take_for_import();
    111. 

  111.                 else if ($_POST['f'] == 'save_aci' && $areWePro)
    112. 

  112.                     cdpp_save_cleanup_settings();
    113. 

  113.                 else if ($_POST['f'] == 'get_aci' && $areWePro)
    114. 

  114.                     cdpp_get_cleanup_settings();
    115. 

  115.                 else if ($_POST['f'] == 'turn_off_aci' && $areWePro)
    116. 

  116.                     cdpp_turn_the_acii_off();
    117. 

  117.                 else if ($_POST['f'] == 'i_love_squirrels' && $areWePro)
    118. 

  118.                     cdpp_squirrel();
    119. 

  119.                 else
    120. 

  120.                     echo 'error';
    121. 

  121.             } else
    122. 

  122.                 echo 'error';
    123. 

  123.         } else
    124. 

  124.             echo 'no_access';
    125. 

  125.     } else
    126. 

  126.         echo 'no_access';
    127. 

  127. 

  128.     wp_die();
    129. 

  129. });
    130. 

  130. /** –– * */
    131. 

  131. 

  132. /** –– **\
    133. 

  133.  * This function will be fired when user don't want to see intro – never again.
    134. 

  134.  * @since 1.0.6
    135. 

  135.  */
    136. 

  136. function cdp_review() {
    137. 

  137. 

  138.     // Option
    139. 

  139.     $method = sanitize_text_field($_POST['decision']);
    140. 

  140. 

  141.     // Get user id and array from db
    142. 

  142.     $user_id = get_current_user_id();
    143. 

  143.     $already = get_option('_cdp_review', false);
    144. 

  144. 

  145.     // Create if not exists
    146. 

  146.     if ($already == false)
    147. 

  147.         $already = array('installed' => time(), 'users' => array());
    148. 

  148. 

  149.     // Set dismiss
    150. 

  150.     $already['users'][$user_id] = array();
    151. 

  151.     $already['users'][$user_id]['dismiss'] = (($method == 'remind') ? time() : true);
    152. 

  152. 

  153.     // Add option to datbase if not exit.
    154. 

  154.     $opt = update_option('_cdp_review', $already);
    155. 

  155. 

  156.     // Return success
    157. 

  157.     echo json_encode(array('status' => 'success'));
    158. 

  158. }
    159. 

  159. 

  160. /** –– * */
    161. 

  161. 

  162. /** –– **\
    163. 

  163.  * This function will be fired when user don't want to see intro – never again.
    164. 

  164.  * @since 1.0.0
    165. 

  165.  */
    166. 

  166. function cdp_add_new_no_intro() {
    167. 

  167. 

  168.     // Get user id and array from db
    169. 

  169.     $user_id = get_current_user_id();
    170. 

  170.     $already = get_option('_cdp_no_intro');
    171. 

  171. 

  172.     // Check if it's first time that user checked this option.
    173. 

  173.     if (!$already)
    174. 

  174.         $already = array($user_id);
    175. 

  175. 

  176.     // If it already exists just add another user.
    177. 

  177.     else if (!in_array($user_id, $already))
    178. 

  178.         array_push($already, $user_id);
    179. 

  179. 

  180.     // If the user already exists exit.
    181. 

  181.     else
    182. 

  182.         exit;
    183. 

  183. 

  184.     // Add option to datbase if not exit.
    185. 

  185.     $opt = update_option('_cdp_no_intro', $already);
    186. 

  186. }
    187. 

  187. 

  188. /** –– * */
    189. 

  189. 

  190. /** –– **\
    191. 

  191.  * This function will be fired when user want to see intro – again.
    192. 

  192.  * @since 1.0.0
    193. 

  193.  */
    194. 

  194. function cdp_add_new_intro() {
    195. 

  195. 

  196.     // Get user id and array from db
    197. 

  197.     $user_id = get_current_user_id();
    198. 

  198.     $already = get_option('_cdp_no_intro');
    199. 

  199. 

  200.     // Check if it's first time that user checked this option.
    201. 

  201.     if ($already && in_array($user_id, $already))
    202. 

  202.         unset($already[array_search($user_id, $already, true)]);
    203. 

  203. 

  204.     // If the user no exists exit.
    205. 

  205.     else
    206. 

  206.         exit;
    207. 

  207. 

  208.     // Add option to database if not exit.
    209. 

  209.     $opt = update_option('_cdp_no_intro', $already);
    210. 

  210. }
    211. 

  211. 

  212. /** –– * */
    213. 

  213. 

  214. /** –– **\
    215. 

  215.  * This function will be fired when user want to save plugin options – again.
    216. 

  216.  * @since 1.0.0
    217. 

  217.  */
    218. 

  218. function cdp_save_plugin_options($areWePro) {
    219. 

  219. 

  220.     // Get the info about our professionalness
    221. 

  221.     $areWePro = $areWePro;
    222. 

  222. 

  223.     // Get new options and current profile.
    224. 

  224.     $options = ((isset($_POST['options'])) ? cdp_sanitize_array($_POST['options']) : false);
    225. 

  225.     $entire = ((isset($_POST['entire'])) ? cdp_sanitize_array($_POST['entire']) : false);
    226. 

  226.     $profile = ((isset($_POST['profile'])) ? sanitize_text_field($_POST['profile']) : false);
    227. 

  227. 

  228.     // Get current options and profiles.
    229. 

  229.     $a_or = get_option('_cdp_profiles');
    230. 

  230.     $already = get_option('_cdp_profiles');
    231. 

  231.     $g_or = get_option('_cdp_globals');
    232. 

  232.     $globals = get_option('_cdp_globals');
    233. 

  233. 

  234.     // Check if it's first time – create array.
    235. 

  235.     if (!is_array($already))
    236. 

  236.         $already = array();
    237. 

  237.     if (!is_array($globals))
    238. 

  238.         $globals = array();
    239. 

  239. 

  240.     // Add display name for this profile
    241. 

  241.     $profile = preg_replace('/\s+/', '_', trim(strtolower($profile)));
    242. 

  242. 

  243.     // Write new settings for this profile.
    244. 

  244.     $already[$profile] = $options;
    245. 

  245.     $already[$profile]['usmplugin'] = 'false';
    246. 

  246.     $already[$profile]['yoast'] = 'false';
    247. 

  247.     $already[$profile]['woo'] = 'false';
    248. 

  248.     if ($areWePro)
    249. 

  249.         $already[$profile] = cdpp_filter_premium_opts($already, $options, $profile);
    250. 

  250. 

  251.     if (!isset($already[$profile]['names']['display']) || (strlen(trim($already[$profile]['names']['display'])) <= 0))
    252. 

  252.         $already[$profile]['names']['display'] = $profile;
    253. 

  253.     $globals = $entire;
    254. 

  254. 

  255.     // Check if there is default profile
    256. 

  256.     if (!array_key_exists('default', $already) || !array_key_exists('title', $already['default'])) {
    257. 

  257.         $already['default'] = array();
    258. 

  258. 

  259.         if (function_exists('cdp_default_options'))
    260. 

  260.             $already['default'] = cdp_default_options();
    261. 

  261.         if (function_exists('cdp_default_global_options'))
    262. 

  262.             $globals['others'] = cdp_default_global_options();
    263. 

  263.     }
    264. 

  264. 

  265.     // Add new options to database.
    266. 

  266.     $s1 = update_option('_cdp_globals', $globals);
    267. 

  267.     $s2 = update_option('_cdp_profiles', $already);
    268. 

  268. 

  269.     // Check if success while uploading
    270. 

  270.     if (($s1 || $s2) || ($globals == $g_or) || ($already == $a_or))
    271. 

  271.         echo 'success';
    272. 

  272.     else
    273. 

  273.         echo 'error';
    274. 

  274. }
    275. 

  275. 

  276. /** –– * */
    277. 

  277. 

  278. /** –– **\
    279. 

  279.  * This function will be fired when user want to save plugin options – again.
    280. 

  280.  * @since 1.0.0
    281. 

  281.  */
    282. 

  282. function cdp_insert_new_post($areWePro = false) {
    283. 

  283. 

  284.     // Performance copy time start
    285. 

  285.     $timein = microtime(true);
    286. 

  286. 

  287.     // Create output array which will be returned to requester
    288. 

  288.     $output = array('status' => 'success');
    289. 

  289. 

  290.     // Get ID(s) of post(s)
    291. 

  291.     $ids = ((isset($_POST['id'])) ? cdp_sanitize_array($_POST['id']) : false);
    292. 

  292. 

  293.     // Get all important pieces of information from requester
    294. 

  294.     $data = ((isset($_POST['data'])) ? cdp_sanitize_array($_POST['data']) : false);
    295. 

  295.     $site = isset($_POST['data']['site']) ? sanitize_text_field($_POST['data']['site']) : false;
    296. 

  296.     $times = isset($_POST['data']['times']) ? sanitize_text_field($_POST['data']['times']) : 1;
    297. 

  297.     $swap = isset($_POST['data']['swap']) ? sanitize_text_field($_POST['data']['swap']) : false;
    298. 

  298.     $profile = isset($_POST['data']['profile']) ? sanitize_text_field($_POST['data']['profile']) : 'default';
    299. 

  299.     $origin = isset($_POST['origin']) ? sanitize_text_field($_POST['origin']) : false;
    300. 

  300.     $custom = isset($_POST['data']['custom']) ? cdp_sanitize_array($_POST['data']['custom']) : false;
    301. 

  301. 

  302.     // Load default options for selected profile
    303. 

  303.     $defaults = get_option('_cdp_profiles')[$profile];
    304. 

  304. 

  305.     // Settings for this copy
    306. 

  306.     $settings = (($data['type'] != 'copy-quick' && $custom != false) ? $custom : $defaults);
    307. 

  307.     if (!isset($settings['names']))
    308. 

  308.         $settings['names'] = $defaults['names'];
    309. 

  309. 

  310.     // Convert string to boolean – only for much less code later
    311. 

  311.     foreach ($settings as $setting => $val)
    312. 

  312.         if ($setting != 'names')
    313. 

  313.             $settings[$setting] = (($val == 'true') ? true : false);
    314. 

  314. 

  315.     /**
    316. 

  316.      * This local function filters post data by user settings
    317. 

  317.      * @param $post (array of wordpress post/page data)
    318. 

  318.      * @param $settings (array of preselected settings of profile or by user)
    319. 

  319.      * @return array with insert ready values for wordpress post || false on wrong $post
    320. 

  320.      */
    321. 

  321.     function cdp_filter_post($post, $swap, $opt, $settings, $taxonomies = false, $areWePro) {
    322. 

  322. 

  323.         // If $post has wrong format return false
    324. 

  324.         if (!(is_array($post) || is_object($post)))
    325. 

  325.             return false;
    326. 

  326. 

  327.         // Array for formatted and prepared taxonomy
    328. 

  328.         $ft = array();
    329. 

  329.         $buin = array('link_category', 'nav_menu', 'post_tag', 'category', 'post_format');
    330. 

  330. 

  331.         // Loop thorugh all taxonomies from post
    332. 

  332.         foreach ($taxonomies as $taxonomy) {
    333. 

  333. 

  334.             // Set the name to shorted variable
    335. 

  335.             $tn = $taxonomy->taxonomy;
    336. 

  336. 

  337.             // Check if it's private taxonomy and if it's set in options
    338. 

  338.             if ($tn == 'link_category' && !$settings['link_category'])
    339. 

  339.                 continue;
    340. 

  340.             if ($tn == 'nav_menu' && !$settings['nav_menu'])
    341. 

  341.                 continue;
    342. 

  342.             if ($tn == 'post_tag' && !$settings['post_tag'])
    343. 

  343.                 continue;
    344. 

  344.             if ($tn == 'category' && !$settings['category'])
    345. 

  345.                 continue;
    346. 

  346.             if ($tn == 'post_format' && !$settings['format'])
    347. 

  347.                 continue;
    348. 

  348. 

  349.             // Don't copy custom taxonomy if it's not checked
    350. 

  350.             if (!in_array($tn, $buin) && !$settings['taxonomy'])
    351. 

  351.                 continue;
    352. 

  352. 

  353.             // Push next term of existing taxonomy
    354. 

  354.             if (isset($ft[$tn]))
    355. 

  355.                 array_push($ft[$tn], $taxonomy->term_id);
    356. 

  356. 

  357.             // Create new taxonomy and push new term
    358. 

  358.             else {
    359. 

  359.                 $ft[$tn] = array();
    360. 

  360.                 array_push($ft[$tn], $taxonomy->term_id);
    361. 

  361.             }
    362. 

  362.         }
    363. 

  363. 

  364.         // Create array with required values and contant values
    365. 

  365.         $new = array(
    366. 

  366.             'post_title' => ($settings['title'] ? cdp_create_title($post['post_title'], $settings['names'], $post['ID'], $areWePro) : __('Untitled Copy', 'copy-delete-posts')),
    367. 

  367.             'post_date' => ($settings['date'] ? $post['post_date'] : current_time('mysql')),
    368. 

  368.             'post_status' => ($settings['status'] ? $post['post_status'] : 'draft'),
    369. 

  369.             'post_author' => ($settings['author'] ? $post['post_author'] : wp_get_current_user()->ID),
    370. 

  370.             'post_content' => ($settings['content']) ? $post['post_content'] : ' ',
    371. 

  371.             'comment_status' => $post['comment_status'], // that's additional element which cannot be edited by user
    372. 

  372.             'post_parent' => $post['post_parent'] // that's additional element which cannot be edited by user
    373. 

  373.         );
    374. 

  374. 

  375.         // Converter
    376. 

  376.         if ((($opt == '2' && $swap == 'true') || $swap == 'true') && $areWePro && function_exists('cdpp_post_converter'))
    377. 

  377.             $new['post_type'] = cdpp_post_converter($post['post_type']);
    378. 

  378.         else
    379. 

  379.             $new['post_type'] = $post['post_type'];
    380. 

  380. 

  381.         // Add optional values of post – depending on settings
    382. 

  382.         if ($settings['slug'])
    383. 

  383.             $new['post_name'] = $post['post_name'];
    384. 

  384.         if ($settings['excerpt'])
    385. 

  385.             $new['post_excerpt'] = $post['post_excerpt'];
    386. 

  386.         if ($settings['template'])
    387. 

  387.             $new['page_template'] = $post['page_template'];
    388. 

  388.         if ($settings['password'])
    389. 

  389.             $new['post_password'] = $post['post_password'];
    390. 

  390.         if ($settings['menu_order'])
    391. 

  391.             $new['menu_order'] = $post['menu_order'];
    392. 

  392.         if ($settings['category'])
    393. 

  393.             $new['post_category'] = $post['post_category'];
    394. 

  394.         if ($settings['post_tag'])
    395. 

  395.             $new['tags_input'] = $post['tags_input'];
    396. 

  396.         if ($taxonomies != false)
    397. 

  397.             $new['tax_input'] = $ft;
    398. 

  398. 

  399.         // Return filtered data of current post
    400. 

  400.         return $new;
    401. 

  401.     }
    402. 

  402. 

  403.     /**
    404. 

  404.      * This local function filters post data by user settings
    405. 

  405.      * @param $metas (array of wordpress post/page meta data)
    406. 

  406.      * @param $settings (array of preselected settings of profile or by user)
    407. 

  407.      * @return array with metadata values for post || false on wrong $metas
    408. 

  408.      */
    409. 

  409.     function cdp_filter_meta($metas, $settings, $id, $areWePro, $site, $title) {
    410. 

  410. 

  411.         // If $metas has wrong format return false
    412. 

  412.         if (!(is_array($metas) || is_object($metas)))
    413. 

  413.             return false;
    414. 

  414. 

  415.         // Create empty array for filtered meta data
    416. 

  416.         $prepared = array(
    417. 

  417.             // Add or replace ours copy tracker
    418. 

  418.             array('_cdp_origin' => $id),
    419. 

  419.             array('_cdp_origin_site' => $site),
    420. 

  420.             array('_cdp_origin_title' => $title),
    421. 

  421.             array('_cdp_counter' => '0')
    422. 

  422.         );
    423. 

  423. 

  424.         // Iterate through every meta index
    425. 

  425.         foreach ($metas as $meta => $vals) {
    426. 

  426. 

  427.             // Conditions
    428. 

  428.             $a = ($areWePro && function_exists('cdpp_check_yoast')) ? cdpp_check_yoast($settings, $meta) : false;
    429. 

  429.             $b = ($areWePro && function_exists('cdpp_check_usm')) ? cdpp_check_usm($settings, $meta) : false;
    430. 

  430.             $c = ($areWePro && function_exists('cdpp_check_woo')) ? cdpp_check_woo($settings, $meta, $id) : false;
    431. 

  431.             $d = ($settings['f_image'] && $meta == '_thumbnail_id') ? true : false;
    432. 

  432.             $e = (mb_substr($meta, 0, 4) == '_wp_') ? true : false;
    433. 

  433.             $f = ($meta == '_thumbnail_id' && $settings['f_image']) ? true : false;
    434. 

  434.             $g = ($meta == '_cdp_origin') ? true : false;
    435. 

  435.             $h = (mb_substr($meta, 0, 11) == '_elementor_') ? true : false;
    436. 

  436.             // $i = (isset($settings['all_metadata']) && $settings['all_metadata'] == 'true') ? true : false;
    437. 

  437. 

  438.             // If any of above condition is true pass the meta tag
    439. 

  439.             if ($a || $b || $c || $d || $e || $f || $g || $h /*|| $i*/) {
    440. 

  440. 

  441.                 // Prepare data and insert filtered to results
    442. 

  442.                 foreach ($vals as $val)
    443. 

  443.                     array_push($prepared, array($meta => $val));
    444. 

  444. 

  445.             } else {
    446. 

  446. 

  447.               // error_log(print_r($vals, true));
    448. 

  448. 

  449.             }
    450. 

  450.         }
    451. 

  451. 

  452.         // Return results
    453. 

  453.         return $prepared;
    454. 

  454.     }
    455. 

  455. 

  456.     /**
    457. 

  457.      * This local function format title by user settings
    458. 

  458.      * @param $title (string)
    459. 

  459.      * @param $settings (array of name settings preselected in profile)
    460. 

  460.      * @return string formated title
    461. 

  461.      */
    462. 

  462.     function cdp_create_title($title, $settings, $id, $areWePro) {
    463. 

  463. 

  464.         // Date formats
    465. 

  465.         $date_format = intval($settings['format']);
    466. 

  466. 

  467.         // Get right format
    468. 

  468.         if ($date_format == 1)
    469. 

  469.             $date_format = 'm/d/Y';
    470. 

  470.         else if ($date_format == 2)
    471. 

  471.             $date_format = 'd/m/Y';
    472. 

  472.         else {
    473. 

  473.             if ($areWePro && function_exists('cdpp_custom_date'))
    474. 

  474.                 $date_format = cdpp_custom_date($settings);
    475. 

  475.             else
    476. 

  476.                 $date_format = 'd/m/Y';
    477. 

  477.         }
    478. 

  478. 

  479.         // Create date and time replacements
    480. 

  480.         $curr = current_time('timestamp', true);
    481. 

  481.         $date = date($date_format, $curr);
    482. 

  482.         $time = date('H:i:s', $curr);
    483. 

  483. 

  484.         // Concat whole title with prefix and suffix
    485. 

  485.         $new_title = $settings['prefix'] . ' ' . $title . ' ' . $settings['suffix'];
    486. 

  486. 

  487.         // Make replace of placeholders
    488. 

  488.         $new_title = str_replace('[CurrentDate]', $date, $new_title);
    489. 

  489.         $new_title = str_replace('[CurrentTime]', $time, $new_title);
    490. 

  490. 

  491.         // Return formatted title
    492. 

  492.         return $new_title;
    493. 

  493.     }
    494. 

  494. 

  495.     /**
    496. 

  496.      * This local function inserts whole post into database
    497. 

  497.      * @param $data (array prepared by cdp_filter_post function)
    498. 

  498.      * @param $times (int how many times should this function copy post)
    499. 

  499.      * @return array of new inserted post(s) and error status
    500. 

  500.      * Structure of return array: { ids: [$ids], error: (count of errors) }
    501. 

  501.      */
    502. 

  502.     function cdp_insert_post($id, $data, $times, $areWePro, $isChild = false, $p_ids = null, $site) {
    503. 

  503. 

  504.         // Get Wordpress database
    505. 

  505.         global $wpdb;
    506. 

  506. 

  507.         // Create empty array for new id(s) and error(s)
    508. 

  508.         $results = array('ids' => array(), 'error' => 0, 'counter' => 0);
    509. 

  509. 

  510.         // Prevent SQL injection
    511. 

  511.         if (!is_numeric($id)) {
    512. 

  512. 

  513.           echo json_encode(array('status' => 'error', 'message' => __('Invalid ID argument.', 'copy-delete-posts')));
    514. 

  514.           exit;
    515. 

  515. 

  516.         }
    517. 

  517. 

  518.         // And just in case
    519. 

  519.         $id = esc_sql(intval($id));
    520. 

  520. 

  521.         // Get Counter value
    522. 

  522.         $prefix = (($site != -1) ? $wpdb->get_blog_prefix($site) : $wpdb->get_blog_prefix());
    523. 

  523.         $newestId = $wpdb->get_results("SELECT post_id FROM {$prefix}postmeta WHERE meta_key = '_cdp_origin' AND meta_value = {$id} ORDER BY post_id DESC LIMIT 1", ARRAY_A);
    524. 

  524.         $newestId = ((array_key_exists(0, $newestId)) ? (intval($newestId[0]['post_id'])) : false);
    525. 

  525.         if (isset($newestId) && $newestId != false && $newestId > 0)
    526. 

  526.             $counter = $wpdb->get_results("SELECT meta_value AS 'Counter' FROM {$prefix}postmeta WHERE meta_key = '_cdp_counter' AND post_id = {$newestId} ORDER BY post_id DESC", ARRAY_A)[0]['Counter'];
    527. 

  527.         else
    528. 

  528.             $counter = 1;
    529. 

  529. 

  530.         $base_title = $data['post_title'];
    531. 

  531.         $counter = intval($counter) + 1;
    532. 

  532. 

  533.         // Handle multisite for premium
    534. 

  534.         if ($areWePro && function_exists('cdpp_handle_multisite'))
    535. 

  535.             cdpp_handle_multisite($site);
    536. 

  536. 

  537.         // Loop for each post iteration
    538. 

  538.         for ($i = 0; $i < $times; ++$i) {
    539. 

  539. 

  540.             // Change parent if it's child
    541. 

  541.             if ($isChild)
    542. 

  542.                 $data['post_parent'] = $p_ids['posts'][$i];
    543. 

  543. 

  544.             // Replace title with Counter if multiple copies
    545. 

  545.             $data['post_title'] = str_replace('[Counter]', ($counter + $i), $base_title);
    546. 

  546. 

  547.             // Insert post with filtered data
    548. 

  548.             $new = wp_insert_post($data, true);
    549. 

  549. 

  550.             // Check if the post is inserted successfully and append array
    551. 

  551.             if (is_numeric($new))
    552. 

  552.                 array_push($results['ids'], $new);
    553. 

  553.             else
    554. 

  554.                 $results['error'] ++;
    555. 

  555.         }
    556. 

  556. 

  557.         // Handle multisite for premium fix
    558. 

  558.         if ($areWePro && function_exists('cdpp_handle_multisite_after'))
    559. 

  559.             cdpp_handle_multisite_after($site);
    560. 

  560. 

  561.         // Set first counter number for future
    562. 

  562.         $results['counter'] = $counter;
    563. 

  563. 

  564.         // Return array with results
    565. 

  565.         return $results;
    566. 

  566.     }
    567. 

  567. 

  568.     /**
    569. 

  569.      * This local function filter and adds missing meta to added post
    570. 

  570.      * @param $ids (array of post ids)
    571. 

  571.      * @param $metas (filtered meta data with cdp_filter_meta function)
    572. 

  572.      * @return array structure below
    573. 

  573.      * { ids: { [id] => [failed times]}, error: { [id] => [failed times]} }
    574. 

  574.      */
    575. 

  575.     function cdp_insert_post_meta($ids, $metas, $areWePro, $counter, $site) {
    576. 

  576. 

  577.         // Handle multisite for premium
    578. 

  578.         if ($areWePro && function_exists('cdpp_handle_multisite'))
    579. 

  579.             cdpp_handle_multisite($site);
    580. 

  580. 

  581.         // Create empty array for new id(s) and error(s)
    582. 

  582.         $results = array('ids' => array(), 'error' => array());
    583. 

  583. 

  584.         // Iterate through every inserted post
    585. 

  585.         foreach ($ids as $id) {
    586. 

  586. 

  587.             // Iterate through every meta tag
    588. 

  588.             foreach ($metas as $meta_id => $meta) {
    589. 

  589. 

  590.                 // Get individual data from metas array
    591. 

  591.                 foreach ($meta as $key => $val) {
    592. 

  592. 

  593.                     // Replace the counter with dynamic value
    594. 

  594.                     if ($key == '_cdp_counter')
    595. 

  595.                         $val = $counter;
    596. 

  596. 

  597.                     // Insert meta tag
    598. 

  598.                     $res = add_post_meta($id, $key, $val);
    599. 

  599. 

  600.                     // Check if the insert was successfull
    601. 

  601.                     if ($res != false) {
    602. 

  602.                         if (!isset($results['ids'][$id]))
    603. 

  603.                             $results['ids'][$id] = [];
    604. 

  604.                         array_push($results['ids'][$id], array($key, $val));
    605. 

  605.                     } else {
    606. 

  606.                         if (!isset($results['error'][$id]))
    607. 

  607.                             $results['error'][$id] = [];
    608. 

  608.                         array_push($results['error'][$id], array($key, $val));
    609. 

  609.                     }
    610. 

  610.                 }
    611. 

  611.             }
    612. 

  612. 

  613.             // Iterate the counter
    614. 

  614.             $counter++;
    615. 

  615.         }
    616. 

  616. 

  617.         // Fix multisite handler
    618. 

  618.         if ($areWePro && function_exists('cdpp_handle_multisite_after'))
    619. 

  619.             cdpp_handle_multisite_after($site);
    620. 

  620. 

  621.         // Return the results
    622. 

  622.         return $results;
    623. 

  623.     }
    624. 

  624. 

  625.     /**
    626. 

  626.      * This local function search for childs and catch their IDs
    627. 

  627.      * @param $id string/int (post id)
    628. 

  628.      * @return array of child(s) ID(s)
    629. 

  629.      */
    630. 

  630.     function cdp_check_childs($id) {
    631. 

  631.         $childs = [];
    632. 

  632.         $childrens = get_children(array('post_parent' => $id));
    633. 

  633. 

  634.         foreach ($childrens as $i => $child)
    635. 

  635.             array_push($childs, $child->ID);
    636. 

  636. 

  637.         return $childs;
    638. 

  638.     }
    639. 

  639. 

  640.     /**
    641. 

  641.      * This local function copies original attachments
    642. 

  642.      * @param $path string (path to original file)
    643. 

  643.      * @return string path to new file
    644. 

  644.      */
    645. 

  645.     function cdp_copy_attachment($path = '', $destination) {
    646. 

  646.         if ($path == '')
    647. 

  647.             return false;
    648. 

  648. 

  649.         $dirname = $destination;
    650. 

  650.         $name = basename($path);
    651. 

  651.         $actual_name = pathinfo($name, PATHINFO_FILENAME);
    652. 

  652.         $original_name = $actual_name;
    653. 

  653.         $extension = pathinfo($name, PATHINFO_EXTENSION);
    654. 

  654. 

  655.         $i = 1;
    656. 

  656.         while (file_exists($dirname . '/' . $actual_name . "." . $extension)) {
    657. 

  657.             $actual_name = (string) $original_name . '-' . $i;
    658. 

  658.             $name = $actual_name . '.' . $extension;
    659. 

  659.             $i++;
    660. 

  660.         }
    661. 

  661. 

  662.         copy($path, $dirname . '/' . $name);
    663. 

  663.         return $dirname . '/' . $name;
    664. 

  664.     }
    665. 

  665. 

  666.     /**
    667. 

  667.      * This local function gets copy and insert attachments
    668. 

  668.      * @param $id int/string of post
    669. 

  669.      * @return array of inserted attachments
    670. 

  670.      */
    671. 

  671.     function cdp_insert_attachments($id, $inserted_posts, $areWePro, $site) {
    672. 

  672.         $inserts = array();
    673. 

  673.         $media = get_attached_media('', $id);
    674. 

  674. 

  675.         // Handle multisite for premium
    676. 

  676.         if ($areWePro && function_exists('cdpp_handle_multisite'))
    677. 

  677.             cdpp_handle_multisite($site);
    678. 

  678. 

  679.         // Fix wordpress multisite path
    680. 

  680.         add_filter('upload_dir', 'cdp_fix_upload_paths');
    681. 

  681.         $wp_upload_dir = wp_upload_dir();
    682. 

  682.         remove_filter('upload_dir', 'cdp_fix_upload_paths');
    683. 

  683. 

  684.         // Handle multisite for premium fix
    685. 

  685.         if ($areWePro && function_exists('cdpp_handle_multisite_after'))
    686. 

  686.             cdpp_handle_multisite_after($site);
    687. 

  687. 

  688.         foreach ($media as $i => $m) {
    689. 

  689.             if (get_attached_file($m->ID) == '')
    690. 

  690.                 continue;
    691. 

  691.             $path = cdp_copy_attachment(get_attached_file($m->ID), $wp_upload_dir['path']);
    692. 

  692. 

  693.             $filename = $path;
    694. 

  694.             $parent_post_id = $inserted_posts['ids'][0];
    695. 

  695. 

  696.             $filetype = wp_check_filetype(basename($filename), null);
    697. 

  697. 

  698.             // Handle multisite for premium
    699. 

  699.             if ($areWePro && function_exists('cdpp_handle_multisite'))
    700. 

  700.                 cdpp_handle_multisite($site);
    701. 

  701. 

  702.             $attachment = array(
    703. 

  703.                 'guid' => $wp_upload_dir['url'] . '/' . basename($filename),
    704. 

  704.                 'post_mime_type' => $filetype['type'],
    705. 

  705.                 'post_title' => preg_replace('/\.[^.]+$/', '', basename($filename)),
    706. 

  706.                 'post_content' => '',
    707. 

  707.                 'post_status' => 'inherit'
    708. 

  708.             );
    709. 

  709. 

  710.             $attach_id = wp_insert_attachment($attachment, $filename, $parent_post_id);
    711. 

  711.             array_push($inserts, array('url' => wp_get_attachment_url($attach_id), 'id' => $attach_id));
    712. 

  712. 

  713.             $attach_data = wp_generate_attachment_metadata($attach_id, $filename);
    714. 

  714.             wp_update_attachment_metadata($attach_id, $attach_data);
    715. 

  715. 

  716.             // Handle multisite for premium fix
    717. 

  717.             if ($areWePro && function_exists('cdpp_handle_multisite_after'))
    718. 

  718.                 cdpp_handle_multisite_after($site);
    719. 

  719.         }
    720. 

  720. 

  721.         return $inserts;
    722. 

  722.     }
    723. 

  723. 

  724.     /**
    725. 

  725.      * This local function gets comments and copy them
    726. 

  726.      * @param $id int/string of base post
    727. 

  727.      * @param $dests array of post ids where the comms from $id should be copied
    728. 

  728.      * @return array of inserted comments
    729. 

  729.      */
    730. 

  730.     function cdp_copy_comments($id, $dests) {
    731. 

  731.         $comments = get_comments(array('post_id' => $id));
    732. 

  732.         $curr = current_time('mysql');
    733. 

  733.         $all_inserts = array();
    734. 

  734.         $all_inserts['fix_try'] = array();
    735. 

  735.         $all_inserts['olds'] = '';
    736. 

  736. 

  737.         foreach ($dests as $dest) {
    738. 

  738.             $p = 0;
    739. 

  739.             $olds = array();
    740. 

  740. 

  741.             $cm1 = $comments;
    742. 

  742.             foreach ($cm1 as $i => $c) {
    743. 

  743.                 $c = $c->to_array();
    744. 

  744.                 $old_id = $c['comment_ID'];
    745. 

  745.                 $parent = $c['comment_parent'];
    746. 

  746. 

  747.                 $c['comment_date'] = $curr;
    748. 

  748.                 $c['comment_date_gmt'] = $curr;
    749. 

  749.                 $c['comment_post_ID'] = $dest;
    750. 

  750.                 $c['comment_parent'] = 0;
    751. 

  751.                 if ($parent != "0")
    752. 

  752.                     $p++;
    753. 

  753. 

  754.                 $new_id = @wp_insert_comment($c);
    755. 

  755. 

  756.                 $olds[$old_id] = array('new' => $new_id, 'old_parent_id' => $parent);
    757. 

  757.                 array_push($all_inserts, array('old' => $old_id, 'new' => $new_id, 'parent' => $parent));
    758. 

  758.             }
    759. 

  759. 

  760.             if ($p != 0) {
    761. 

  761.                 $cm2 = $comments;
    762. 

  762.                 foreach ($cm2 as $j => $m) {
    763. 

  763.                     if ($m->comment_parent != "0" && $olds[$m->comment_ID]['old_parent_id'] == $m->comment_parent) {
    764. 

  764.                         $post = get_comment($olds[$m->comment_ID]['new']);
    765. 

  765.                         $post = $post->to_array();
    766. 

  766.                         $post['comment_parent'] = $olds[$m->comment_parent]['new'];
    767. 

  767.                         wp_update_comment($post);
    768. 

  768.                     }
    769. 

  769.                 }
    770. 

  770.             }
    771. 

  771.         }
    772. 

  772. 

  773.         return $all_inserts;
    774. 

  774.     }
    775. 

  775. 

  776.     // Main code for this duplication – for each id (post) do whole process
    777. 

  777.     function cdp_process_ids($ids, $swap, $settings, $times, $site, $areWePro, $g, $isChild = false, $p_ids = null) {
    778. 

  778. 

  779.         // Make it clear
    780. 

  780.         $globals = cdp_default_global_options();
    781. 

  781.         if ($g != false)
    782. 

  782.             $globals = $g;
    783. 

  783.         $g = $globals['others'];
    784. 

  784. 

  785.         // Return data storage
    786. 

  786.         $output = [];
    787. 

  787.         $new_posts = array('parents' => array(), 'childs' => array(), 'ids' => array());
    788. 

  788. 

  789.         // Iterate each id
    790. 

  790.         foreach ($ids as $id) {
    791. 

  791. 

  792.             // Get post data and meta data
    793. 

  793.             $post = get_post($id)->to_array();
    794. 

  794.             $meta = get_post_custom($id);
    795. 

  795.             $taxonomies = wp_get_object_terms($id, get_taxonomies());
    796. 

  796. 

  797.             // Check if this post type is allowed to copy
    798. 

  798.             $type = $post['post_type'];
    799. 

  799.             if ($g['cdp-content-pages'] == 'false' && $type == 'page')
    800. 

  800.                 continue;
    801. 

  801.             if ($g['cdp-content-posts'] == 'false' && $type == 'post')
    802. 

  802.                 continue;
    803. 

  803.             if ($g['cdp-content-custom'] == 'false' && ($type != 'page' && $type != 'post'))
    804. 

  804.                 continue;
    805. 

  805. 

  806.             // Post converting?
    807. 

  807.             $pConv = false;
    808. 

  808.             if (array_key_exists('postConverter', $globals))
    809. 

  809.                 $pConv = $globals['postConverter'];
    810. 

  810. 

  811.             // Run process and validate response
    812. 

  812.             $childrens = cdp_check_childs($id); // if sizeof($this) == has childs
    813. 

  813.             $post_data = cdp_filter_post($post, $swap, $pConv, $settings, $taxonomies, $areWePro, $swap); // can be false
    814. 

  814.             $meta_data = cdp_filter_meta($meta, $settings, $id, $areWePro, $site, $post_data['post_title']); // can be false
    815. 

  815.             $inserted_posts = cdp_insert_post($id, $post_data, $times, $areWePro, $isChild, $p_ids, $site); // $res['error'] must be == 0
    816. 

  816.             $inserted_metas = cdp_insert_post_meta($inserted_posts['ids'], $meta_data, $areWePro, $inserted_posts['counter'], $site); // sizeof($res['error']) must be == 0
    817. 

  817.             // Comments copy
    818. 

  818.             if ($settings['comments'])
    819. 

  819.                 $inserted_comments = cdp_copy_comments($id, $inserted_posts['ids']);
    820. 

  820.             $cms = get_comments(array('post_id' => $id));
    821. 

  821. 

  822.             // Post format
    823. 

  823.             if ($settings['format'])
    824. 

  824.                 foreach ($inserted_posts['ids'] as $i => $tid)
    825. 

  825.                     $isReFormat = set_post_format($tid, get_post_format($id));
    826. 

  826. 

  827.             // Featured image copy
    828. 

  828.             if ($settings['attachments'])
    829. 

  829.                 $inserted_attachments = cdp_insert_attachments($id, $inserted_posts, $areWePro, $site);
    830. 

  830.             else
    831. 

  831.                 $inserted_attachments = false;
    832. 

  832. 

  833.             // Copy childrens recursively if exist
    834. 

  834.             if ($settings['children'] && sizeof($childrens) > 0) {
    835. 

  835.                 $child_helpers = array('posts' => $inserted_posts['ids']);
    836. 

  836.                 $inserted_childs = cdp_process_ids($childrens, $swap, $settings, $times, $site, $areWePro, $globals, true, $child_helpers);
    837. 

  837.                 array_push($new_posts['childs'], array($id => $inserted_childs['$new_posts']['ids']));
    838. 

  838.             }
    839. 

  839. 

  840.             // Add new inserted IDs
    841. 

  841.             foreach ($inserted_posts['ids'] as $i_id)
    842. 

  842.                 array_push($new_posts['parents'], $i_id);
    843. 

  843. 

  844.             // Merge for easier read
    845. 

  845.             $new_posts['ids'] = array_merge($new_posts['ids'], $new_posts['parents'], $new_posts['childs']);
    846. 

  846.         }
    847. 

  847. 

  848.         // Return all data to main request
    849. 

  849.         return array('$output' => $output, '$new_posts' => $new_posts);
    850. 

  850.     }
    851. 

  851. 

  852.     // Run the machine for selected post(s)
    853. 

  853.     $g = get_option('_cdp_globals', false);
    854. 

  854.     $new_insertions = cdp_process_ids($ids, $swap, $settings, $times, $site, $areWePro, $g);
    855. 

  855. 

  856.     // Handle multisite for premium
    857. 

  857.     if ($areWePro && function_exists('cdpp_handle_multisite'))
    858. 

  858.         cdpp_handle_multisite($site);
    859. 

  859. 

  860.     $pConv = false;
    861. 

  861.     if (array_key_exists('postConverter', $g) && $areWePro)
    862. 

  862.         $pConv = (($g['postConverter'] === '2' || $g['postConverter'] === 2) ? true : false);
    863. 

  863. 

  864.     // Output link if it's edited post
    865. 

  865.     $aCop = ((array_key_exists('afterCopy', $g)) ? $g['afterCopy'] : '1');
    866. 

  866.     if (($data['type'] == 'copy-custom-link' || $aCop == '2'))
    867. 

  867.         $output['link'] = get_edit_post_link($new_insertions['$new_posts']['parents'][0], 'x');
    868. 

  868. 

  869.     if ($pConv == true && !($data['type'] == 'copy-custom-link' || $aCop == '2'))
    870. 

  870.         $output['link'] = 'pConv';
    871. 

  871.     else
    872. 

  872.         update_option('_cdp_show_copy', true);
    873. 

  873. 

  874.     // Handle multisite for premium fix
    875. 

  875.     if ($areWePro && function_exists('cdpp_handle_multisite_after'))
    876. 

  876.         cdpp_handle_multisite_after($site);
    877. 

  877. 

  878.     // Check performance by time
    879. 

  879.     $copyTime = microtime(true) - $timein;
    880. 

  880.     $copyTimePerOne = $copyTime / $times;
    881. 

  881. 

  882.     // Set only if had good performance all the time
    883. 

  883.     $isSlowPerf = true;
    884. 

  884.     if (get_option('cdp_latest_slow_performance', false) == false) {
    885. 

  885.       $isSlowPerf = false;
    886. 

  886.     }
    887. 

  887. 

  888.     // Check if the copy time of one page was slower than 0.051 of second
    889. 

  889.     if ($copyTimePerOne > 0.051) {
    890. 

  890.       $isSlowPerf = true;
    891. 

  891.     }
    892. 

  892. 

  893.     // Set the performance status
    894. 

  894.     update_option('cdp_latest_slow_performance', $isSlowPerf);
    895. 

  895. 

  896.     // Update history with logs
    897. 

  897.     $logs = get_option('cdp_copy_logs_times', array());
    898. 

  898.     if (sizeof($logs) >= 50) {
    899. 

  899.       $logs = array_slice($logs, 0, 48);
    900. 

  900.     }
    901. 

  901.     $logs = array_values($logs);
    902. 

  902.     array_unshift($logs, array('amount' => $times, 'time' => $copyTime, 'perOne' => $copyTimePerOne, 'data' => time(), 'memory' => memory_get_usage(), 'peak' => memory_get_peak_usage(true)));
    903. 

  903.     update_option('cdp_copy_logs_times', $logs);
    904. 

  904. 

  905.     echo json_encode(cdp_sanitize_array($output));
    906. 

  906. }
    907. 

  907. 

  908. /** –– * */
    909. 

  909. 

  910. /** –– **\
    911. 

  911.  * This function will return profile information for presets.
    912. 

  912.  * @return object of settings by requested profile
    913. 

  913.  * @since 1.0.0
    914. 

  914.  */
    915. 

  915. function cdp_get_profile() {
    916. 

  916. 

  917.     if (function_exists('cdpp_get_all_profiles'))
    918. 

  918.         cdpp_get_profile();
    919. 

  919.     else {
    920. 

  920. 

  921.         // Search for the settings of profile
    922. 

  922.         $settings = get_option('_cdp_profiles')['default'];
    923. 

  923. 

  924.         // Display those settings
    925. 

  925.         echo json_encode(cdp_sanitize_array($settings));
    926. 

  926.     }
    927. 

  927. }
    928. 

  928. 

  929. /** –– * */
    930. 

  930. 

  931. /** –– **\
    932. 

  932.  * This function will return all profile information for manager.
    933. 

  933.  * @return object of settings by requested profile
    934. 

  934.  * @since 1.0.0
    935. 

  935.  */
    936. 

  936. function cdp_get_all_profiles() {
    937. 

  937. 

  938.     if (function_exists('cdpp_get_all_profiles'))
    939. 

  939.         cdpp_get_all_profiles();
    940. 

  940.     else
    941. 

  941.         cdp_get_profile();
    942. 

  942. }
    943. 

  943. 

  944. /** –– * */
    945. 

  945. 

  946. /** –– **\
    947. 

  947.  * This function will return all not trashed posts
    948. 

  948.  * @return object of posts and success or fail message
    949. 

  949.  */
    950. 

  950. function cdp_get_all_posts() {
    951. 

  951.     $output = array();
    952. 

  952. 

  953.     $args = array(
    954. 

  954.         'numberposts' => -1,
    955. 

  955.         'post_type' => 'post',
    956. 

  956.         'post_status' => 'publish,private,draft,future,pending,inherit,sticky'
    957. 

  957.     );
    958. 

  958. 

  959.     $output['posts'] = get_posts($args);
    960. 

  960.     $args['post_type'] = 'page';
    961. 

  961.     $output['pages'] = get_posts($args);
    962. 

  962.     $output['custom'] = array();
    963. 

  963. 

  964.     $post_types = get_post_types(array('public' => true, '_builtin' => false));
    965. 

  965. 

  966.     if (sizeof($post_types) > 0)
    967. 

  967.         $output['custom'] = get_posts(array(
    968. 

  968.             'post_type' => $post_types,
    969. 

  969.             'numberposts' => -1,
    970. 

  970.             'post_status' => 'publish,private,draft,future,pending,inherit,sticky'
    971. 

  971.         ));
    972. 

  972. 

  973.     $output['meta'] = array();
    974. 

  974.     foreach ($output['posts'] as $k => $p)
    975. 

  975.         $output['meta'][$p->ID] = get_post_meta($p->ID);
    976. 

  976.     foreach ($output['pages'] as $k => $p)
    977. 

  977.         $output['meta'][$p->ID] = get_post_meta($p->ID);
    978. 

  978.     foreach ($output['custom'] as $k => $p)
    979. 

  979.         $output['meta'][$p->ID] = get_post_meta($p->ID);
    980. 

  980. 

  981.     echo json_encode(cdp_sanitize_array($output));
    982. 

  982. }
    983. 

  983. 

  984. /** –– * */
    985. 

  985. 

  986. /** –– **\
    987. 

  987.  * This function will delete all posts in array PERMANENTLY!
    988. 

  988.  * @return object of success message or error
    989. 

  989.  */
    990. 

  990. function cdp_delete_posts() {
    991. 

  991.     $ids = ((isset($_POST['ids'])) ? cdp_sanitize_array($_POST['ids']) : false); // ids to delete
    992. 

  992.     $throttling = sanitize_text_field($_POST['throttling']); // throttling if enabeld
    993. 

  993.     $thc = sanitize_text_field($_POST['thc']); // throttling count if enabeld
    994. 

  994.     $thrs = sanitize_text_field($_POST['thrs']) == 'true' ? true : false; // trash or not?
    995. 

  995.     $redi = sanitize_text_field($_POST['redi']) == 'true' ? true : false; // redirect if enabled
    996. 

  996.     $auit = sanitize_text_field($_POST['auit']) == 'true' ? true : false; // auit if enabled
    997. 

  997.     $auitd = ((isset($_POST['auitd'])) ? cdp_sanitize_array($_POST['auitd']) : false); // auitd if auit enabled
    998. 

  998. 

  999.     $prepared_ids = array();
    1000. 

  1000.     $inGroup = 0;
    1001. 

  1001.     $curr = current_time('timestamp');
    1002. 

  1002.     $token = uniqid($curr, true);
    1003. 

  1003.     $cdp_cron = get_option('_cdp_crons');
    1004. 

  1004.     $site = is_multisite() ? get_current_blog_id() : '-1';
    1005. 

  1005.     if ($cdp_cron == false)
    1006. 

  1006.         $cdp_cron = array();
    1007. 

  1007.     $cdp_cron[$token] = array(
    1008. 

  1008.         'start' => $curr,
    1009. 

  1009.         'ids' => $ids,
    1010. 

  1010.         'done' => false,
    1011. 

  1011.         'shown' => false,
    1012. 

  1012.         'f' => 'delete',
    1013. 

  1013.         'del_size' => sizeof($ids),
    1014. 

  1014.         'handler' => 'cdp_cron_delete',
    1015. 

  1015.         'auit' => $auit,
    1016. 

  1016.         'auitd' => $auitd
    1017. 

  1017.     );
    1018. 

  1018.     $cdp_cron[$token]['tasks'] = array();
    1019. 

  1019.     $cdp_cron[$token]['args'] = array();
    1020. 

  1020. 

  1021.     if ($throttling == '1' && $thc && intval($thc) >= 1 && intval($thc) <= 10240) {
    1022. 

  1022. 

  1023.         $inGroup = ceil(intval($thc) / 30);
    1024. 

  1024. 

  1025.         for ($i = 0, $k = 2; $i < sizeof($ids); $i = $i + $inGroup, $k++)
    1026. 

  1026.             $cdp_cron[$token]['tasks']["-$k"] = false;
    1027. 

  1027. 

  1028.         update_option('_cdp_crons', $cdp_cron);
    1029. 

  1029.         for ($i = 0, $k = 2; $i < sizeof($ids); $i = $i + $inGroup, $k++) {
    1030. 

  1030.             $tg = array();
    1031. 

  1031.             $tt = array('tsk' => "-" . $k, 'token' => $token);
    1032. 

  1032. 

  1033.             for ($j = $i; $j < ($i + $inGroup); $j++)
    1034. 

  1034.                 if (isset($ids[$j]))
    1035. 

  1035.                     array_push($tg, $ids[$j]);
    1036. 

  1036. 

  1037.             array_push($prepared_ids, $tg);
    1038. 

  1038.             $time = $k * 2;
    1039. 

  1039.             $args = array(array('ids' => $tg, 'site' => $site, 'trash' => $thrs, 'token' => $tt));
    1040. 

  1040.             wp_schedule_single_event(strtotime("+$time seconds"), 'cdp_cron_delete', $args);
    1041. 

  1041.             array_push($cdp_cron[$token]['args'], $args);
    1042. 

  1042.         }
    1043. 

  1043.     } else {
    1044. 

  1044. 

  1045.         $cdp_cron[$token]['tasks']["-0"] = false;
    1046. 

  1046.         update_option('_cdp_crons', $cdp_cron);
    1047. 

  1047.         $tt = array('tsk' => "-0", 'token' => $token);
    1048. 

  1048.         $args = array(array('ids' => $ids, 'site' => $site, 'trash' => $thrs, 'token' => $tt));
    1049. 

  1049.         wp_schedule_single_event(strtotime('+2 seconds'), 'cdp_cron_delete', $args);
    1050. 

  1050.         array_push($cdp_cron[$token]['args'], $args);
    1051. 

  1051.     }
    1052. 

  1052. 

  1053.     echo json_encode(array('status' => 'success', 'token' => cdp_sanitize_array($token)));
    1054. 

  1054. }
    1055. 

  1055. 

  1056. /** –– * */
    1057. 

  1057. 

  1058. /** –– **\
    1059. 

  1059.  * This function will delete all posts in array PERMANENTLY!
    1060. 

  1060.  * @return object of success message or error
    1061. 

  1061.  */
    1062. 

  1062. function cdp_clear_all_crons() {
    1063. 

  1063.     $cdp_cron = get_option('_cdp_crons');
    1064. 

  1064. 

  1065.     foreach ($cdp_cron as $cron => $val) {
    1066. 

  1066.         if (array_key_exists('done', $val)) {
    1067. 

  1067.             if ($val['done'] != true) {
    1068. 

  1068.                 echo json_encode(array(
    1069. 

  1069.                     'status' => 'fail',
    1070. 

  1070.                     'type' => 'warning',
    1071. 

  1071.                     'msg' => __('You can\'t clear messages when tasks are in progress, please firstly kill tasks or wait till the end.', 'copy-delete-posts')
    1072. 

  1072.                 ));
    1073. 

  1073.                 return;
    1074. 

  1074.             }
    1075. 

  1075.         }
    1076. 

  1076.     }
    1077. 

  1077. 

  1078.     $cdp_cron = delete_option('_cdp_crons');
    1079. 

  1079.     echo json_encode(array('status' => 'success'));
    1080. 

  1080. }
    1081. 

  1081. 

  1082. /** –– * */
    1083. 

  1083. 

  1084. /** –– **\
    1085. 

  1085.  * Local function which sets default profile for user
    1086. 

  1086.  * @return Boolean
    1087. 

  1087.  */
    1088. 

  1088. function cdp_set_default_profile() {
    1089. 

  1089.     $curr = get_option('_cdp_preselections');
    1090. 

  1090.     $id = get_current_user_id();
    1091. 

  1091.     $new = array();
    1092. 

  1092.     $selection = ((isset($_POST['selection'])) ? cdp_sanitize_array($_POST['selection']) : false);
    1093. 

  1093.     if ($curr && !is_object($curr) || $curr == false)
    1094. 

  1094.         $new = array($id => $selection);
    1095. 

  1095.     else {
    1096. 

  1096.         $new = $curr;
    1097. 

  1097.         $new[$id] = $selection;
    1098. 

  1098.     }
    1099. 

  1099.     $stat = update_option('_cdp_preselections', $new);
    1100. 

  1100.     echo cdp_sanitize_array($stat);
    1101. 

  1101. }
    1102. 

  1102. 

  1103. /** –– * */
    1104. 

  1104. 

  1105. /** –– **\
    1106. 

  1106.  * Local function which gets default profile for user
    1107. 

  1107.  * @return String
    1108. 

  1108.  */
    1109. 

  1109. function cdp_get_default_profile() {
    1110. 

  1110.     echo(esc_html(get_option('_cdp_preselections')[get_current_user_id()]));
    1111. 

  1111. }
    1112. 

  1112. 

  1113. /** –– * */
    1114. 

  1114. 

  1115. /** –– **\
    1116. 

  1116.  * This function will set as seen notification!
    1117. 

  1117.  * @return object of success message — WARNING: ALWAYS
    1118. 

  1118.  */
    1119. 

  1119. function cdp_set_noti_as_seen() {
    1120. 

  1120.     if (wp_doing_cron())
    1121. 

  1121.         return;
    1122. 

  1122. 

  1123.     $token = ((isset($_POST['noti_token'])) ? sanitize_text_field($_POST['noti_token']) : false);
    1124. 

  1124.     $cdp_cron = get_option('_cdp_crons', array());
    1125. 

  1125.     $cdp_cron[$token]['shown'] = true;
    1126. 

  1126.     update_option('_cdp_crons', $cdp_cron);
    1127. 

  1127. 

  1128.     echo json_encode(array('status' => 'success'));
    1129. 

  1129. }
    1130. 

  1130. 

  1131. /** –– * */
    1132. 

  1132. 

  1133. /** –– **\
    1134. 

  1134.  * This function will delete task from the history!
    1135. 

  1135.  * @return object of success message or fail
    1136. 

  1136.  */
    1137. 

  1137. function cdp_just_hide_task() {
    1138. 

  1138.     $token = ((isset($_POST['task'])) ? sanitize_text_field($_POST['task']) : false);
    1139. 

  1139.     $cdp_cron = get_option('_cdp_crons', array());
    1140. 

  1140.     unset($cdp_cron[$token]);
    1141. 

  1141.     $res = update_option('_cdp_crons', $cdp_cron);
    1142. 

  1142. 

  1143.     if ($res)
    1144. 

  1144.         echo json_encode(array('status' => 'success'));
    1145. 

  1145.     else
    1146. 

  1146.         echo json_encode(array('status' => 'fail', 'type' => 'error', 'msg' => __('We can\'t hide this task now, – maybe it\'t already hidden. Please try again later.', 'copy-delete-posts')));
    1147. 

  1147. }
    1148. 

  1148. 

  1149. /** –– * */
    1150. 

  1150. 

  1151. /** –– **\
    1152. 

  1152.  * This function will kill task from the cron!
    1153. 

  1153.  * @return object of success message or fail
    1154. 

  1154.  */
    1155. 

  1155. function cdp_just_kill_task() {
    1156. 

  1156.     $token = ((isset($_POST['task'])) ? sanitize_text_field($_POST['task']) : false);
    1157. 

  1157.     $cdp_cron = get_option('_cdp_crons', array());
    1158. 

  1158.     $handler = $cdp_cron[$token]['handler'];
    1159. 

  1159.     $args = (array_key_exists('args', $cdp_cron[$token]) ? $cdp_cron[$token]['args'] : array());
    1160. 

  1160. 

  1161.     if ($cdp_cron[$token]['done'] != false) {
    1162. 

  1162.         echo json_encode(array('status' => 'fail', 'type' => 'error', 'msg' => __('This task has already ended this work, please wait for list refresh and try again.', 'copy-delete-posts')));
    1163. 

  1163.         return;
    1164. 

  1164.     }
    1165. 

  1165. 

  1166.     $status = true;
    1167. 

  1167.     $res = false;
    1168. 

  1168.     foreach ($args as $arg => $val) {
    1169. 

  1169.         $sres = wp_clear_scheduled_hook($handler, $val);
    1170. 

  1170.         if ($sres == false)
    1171. 

  1171.             $status = false;
    1172. 

  1172.     }
    1173. 

  1173. 

  1174.     if ($cdp_cron[$token]['done'] != false)
    1175. 

  1175.         $status = true;
    1176. 

  1176. 

  1177.     if ($status == true) {
    1178. 

  1178.         unset($cdp_cron[$token]);
    1179. 

  1179.         $res = update_option('_cdp_crons', $cdp_cron);
    1180. 

  1180.     }
    1181. 

  1181. 

  1182.     if ($status || $res)
    1183. 

  1183.         echo json_encode(array('status' => 'success'));
    1184. 

  1184.     else
    1185. 

  1185.         echo json_encode(array('status' => 'fail', 'type' => 'error', 'msg' => __('We can\'t confirm that we killed this task now, please try again later or check if it\'t killed.', 'copy-delete-posts')));
    1186. 

  1186. }
    1187. 

  1187. 

  1188. /** –– * */
    1189. 

  1189. 

  1190. /** –– **\
    1191. 

  1191.  * This function will catch current cron tasks!
    1192. 

  1192.  * @return object of tasks or fail
    1193. 

  1193.  */
    1194. 

  1194. function cdp_just_get_tasks() {
    1195. 

  1195.     $cdp_cron = get_option('_cdp_crons', false);
    1196. 

  1196. 

  1197.     if ($cdp_cron)
    1198. 

  1198.         echo json_encode(array('status' => 'success', 'tasks' => cdp_sanitize_array($cdp_cron)));
    1199. 

  1199.     else
    1200. 

  1200.         echo json_encode(array('status' => 'fail', 'type' => 'error', 'msg' => __('We couldn\'t catch current tasks, please try again later.', 'copy-delete-posts')));
    1201. 

  1201. }
    1202. 

  1202. 

  1203. /** –– * */
    1204. 

  1204. 

  1205. /** –– **\
    1206. 

  1206.  * This function will remove performance notice
    1207. 

  1207.  * @return void
    1208. 

  1208.  */
    1209. 

  1209. function cdp_hide_perf_notice() {
    1210. 

  1210.   update_option('cdp_dismiss_perf_notice', true);
    1211. 

  1211.   update_option('cdp_latest_slow_performance', false);
    1212. 

  1212.   echo json_encode(array('status' => 'success'));
    1213. 

  1213. }
    1214. 

  1214. 

  1215. /** –– * */
    1216. 

  1216. 

  1217. /** –– **\
    1218. 

  1218.  * This function is just for debug have fun with it!
    1219. 

  1219.  * It can be fired by function cdp_totally_know_what_i_am_doing('really');
    1220. 

  1220.  * It won't work in production mode so dont even try it, if you're not me ~ Mikołaj :P
    1221. 

  1221.  * @return mixed
    1222. 

  1222.  */
    1223. 

  1223. function cdp_debug_function() {
    1224. 

  1224. 

  1225.     // require_once('C:/Developer/Web/wordpress/wp-content/plugins/copy-delete-posts-premium/classes/methods.php');
    1226. 

  1226.     // $settings = get_option('cdpp_aci_settings', false);
    1227. 

  1227.     // $meth = new CDP_Premium($settings);
    1228. 

  1228.     // $posts = $meth->load_posts($settings['scan']);
    1229. 

  1229.     // $filtred = $meth->filter_posts($posts);
    1230. 

  1230. 

  1231.     $cdp_cron = get_option('_cdp_crons', false);
    1232. 

  1232.     $things_to_debug = array(
    1233. 

  1233.         '$cdp_cron' => $cdp_cron
    1234. 

  1234.     );
    1235. 

  1235.     var_export($things_to_debug);
    1236. 

  1236. }
    1237. 

  1237. 

  1238. /** –– **/
    1239. 

  1239.