Feature/public event

app/database/models.py

@@ -61,8 +61,8 @@ class Event(Base):
     color = Column(String, nullable=True)
     availability = Column(Boolean, default=True, nullable=False)
     invitees = Column(String)
+    is_public = Column(Boolean, default=False)
     emotion = Column(String, nullable=True)
-
     owner_id = Column(Integer, ForeignKey("users.id"))
     category_id = Column(Integer, ForeignKey("categories.id"))
 
@@ -89,8 +89,10 @@ class UserEvent(Base):
     __tablename__ = "user_event"
 
     id = Column(Integer, primary_key=True, index=True)
-    user_id = Column('user_id', Integer, ForeignKey('users.id'))
-    event_id = Column('event_id', Integer, ForeignKey('events.id'))
+    user_id = Column('user_id', Integer, ForeignKey(
+        'users.id'), nullable=False)
+    event_id = Column('event_id', Integer, ForeignKey(
+        'events.id'), nullable=False)
 
     events = relationship("Event", back_populates="participants")
     participants = relationship("User", back_populates="events")

app/internal/email.py

@@ -9,8 +9,8 @@
 
 from app.config import (CALENDAR_HOME_PAGE, CALENDAR_REGISTRATION_PAGE,
                         CALENDAR_SITE_NAME, email_conf, templates)
-from app.database.models import Event, User
-
+from app.database.models import Event, User, UserEvent
+from app.internal.utils import get_current_user
 mail = FastMail(email_conf)
 
 
@@ -52,6 +52,49 @@ def send(
     return True
 
 
+def send_email_to_event_participants(
+        session: Session, event_id: int,
+        title: str, content: str,
+        background_tasks: BackgroundTasks = BackgroundTasks
+) -> bool:
+    """This function is being used to send emails in the background.
+    it uses the main elements of the func writen above.
+    It takes an event and a user and it sends the event to the user.
+    Args:
+        session(Session): The session to redirect to the database.
+        title (str): Title of the email that is being sent.
+        event_id (int): Id number of the event that is used.
+        content (str): body of email sent.
+        background_tasks (BackgroundTasks): Function from fastapi that lets
+            you apply tasks in the background.
+    Returns:
+        bool: Returns True if emails were sent, False if none.
+    """
+    event_owner = session.query(Event.owner).filter(id == event_id).first()
+    if event_owner != get_current_user(session):
+        return False
+    # makes sure only event owner can send an email via this func.
+    mailing_list = session.query(User.email).join(
+        UserEvent, User.id == UserEvent.user_id
+        ).filter(
+            event_id == event_id).all()
+    valid_mailing_list = list(filter(verify_email_pattern, mailing_list))
+    if not valid_mailing_list:
+        return False
+    # making sure app doesn't crash if emails are invalid
+    event = session.query(Event).get(event_id)
+    subject = f"{event.title}: {title}"
+    recipients = valid_mailing_list
+    body = content
+    for r in recipients:
+        print(r)
+        background_tasks.add_task(send_internal,
+                                  subject=subject,
+                                  recipients=r,
+                                  body=body)
+    return True
+
+
 def send_email_invitation(sender_name: str,
                           recipient_name: str,
                           recipient_mail: str,

app/routers/email.py

@@ -8,6 +8,7 @@
 from app.internal.email import send as internal_send
 from app.internal.email import send_email_invitation
 
+
 router = APIRouter(
     prefix="/email",
     tags=["email"],

app/routers/event.py

@@ -19,7 +19,7 @@
 )
 from app.internal import comment as cmt
 from app.internal.emotion import get_emotion
-from app.internal.utils import create_model, get_current_user
+from app.internal.utils import create_model, save, get_current_user
 
 
 EVENT_DATA = Tuple[Event, List[Dict[str, str]], str, str]
@@ -208,6 +208,7 @@ def create_event(db: Session, title: str, start, end, owner_id: int,
                  vc_link: str = None,
                  color: Optional[str] = None,
                  invitees: List[str] = None,
+                 is_public: bool = False,
                  category_id: Optional[int] = None,
                  availability: bool = True,
                  ):
@@ -227,6 +228,7 @@ def create_event(db: Session, title: str, start, end, owner_id: int,
         color=color,
         emotion=get_emotion(title, content),
         invitees=invitees_concatenated,
+        is_public=is_public,
         category_id=category_id,
         availability=availability,
     )
@@ -323,6 +325,23 @@ def add_new_event(values: dict, db: Session) -> Optional[Event]:
         return None
 
 
+def add_user_to_event(session: Session, user_id: int, event_id: int):
+    user_already_connected = session.query(UserEvent)\
+        .filter_by(event_id=event_id, user_id=user_id).all()
+    if not user_already_connected:
+        """ if user is not registered to the event, the system will add him"""
+        association = UserEvent(
+            user_id=user_id,
+            event_id=event_id
+        )
+        save(session, association)
+        return True
+    else:
+        """if the user has a connection to the event,
+        the function will recognize the duplicate and return false."""
+        return False
+
+
 @router.post("/{event_id}")
 async def add_comment(request: Request, event_id: int,
                       session: Session = Depends(get_db)) -> Response:

app/templates/event/eventview.html

@@ -40,5 +40,20 @@
         ADD INCLUDE HERE
       </div> -->
     </div>
+<<<<<<< HEAD
+    <!--    Copy commented section to add another tab-->
+    <!--    <div class="tab-pane fade" id="(CHANGE_ME)" role="tabpanel" aria-labelledby="(CHANGE_ME)-tab">-->
+    <!--        ADD INCLUDE HERE -->
+    <!--    </div>-->
+  </div>
+  <div class="event_info_buttons_row event_info_row_end">
+    <!-- Buttons could and should be replaced with button-like anchors if need so -->
+    <button type="button">Duplicate</button>
+    <button type="button">Edit</button>
+    {% if event.is_public %}
+    <button type="button">Join event</button>
+    {% endif %}
+=======
+>>>>>>> 8cd3a6e3c8c94ff0e9c86c9a6ed15c9856f757f9
   </div>
 {% endblock content %}

tests/test_event.py

@@ -10,6 +10,8 @@
 from app.dependencies import get_db
 from app.internal.utils import delete_instance
 from app.main import app
+from app.routers.event import add_new_event, add_user_to_event
+from app.routers.user import create_user
 from app.routers import event as evt
 
 
@@ -99,6 +101,46 @@
 ]
 
 
+# -------------------------------------------------
+# fixtures
+# -------------------------------------------------
+
+
+@pytest.fixture
+def new_event(session, new_user):
+    event = add_new_event(TestApp.event_test_data, session)
+    return event
+
+
+@pytest.fixture
+def new_user(session):
+    user = create_user(
+        session=session,
+        username='new_test_username',
+        password='new_test_password',
+        email='[email protected]',
+        language_id='english'
+    )
+
+    return user
+
+
+# -------------------------------------------------
+# tests
+# -------------------------------------------------
+
+
+def test_joining_public_event(session, new_event, new_user):
+    """test in order to make sure user is added the first time
+    he asks to join event, yet won't join the same user twice"""
+    first_join = add_user_to_event(
+        session, event_id=new_event.id, user_id=new_user.id)
+    assert first_join
+    second_join = add_user_to_event(
+        session, event_id=new_event.id, user_id=new_user.id)
+    assert not second_join
+
+
 def test_eventedit(event_test_client):
     response = event_test_client.get("/event/edit")
     assert response.ok