diff --git a/nest_backend/test/test_2_repository.py b/nest_backend/test/test_2_repository.py
index 958f0d8..910c6ae 100644
--- a/nest_backend/test/test_2_repository.py
+++ b/nest_backend/test/test_2_repository.py
@@ -125,7 +125,7 @@ class TestRepositoryGet:
assert r.status_code == 200
assert r.json["result"] == "success"
- def test_get_non_existing_repository(self, flask_client: Client, admin_headers):
+ def test_repository_not_found(self, flask_client: Client, admin_headers):
r = flask_client.get(f'/api/v1/repositories/99', headers=admin_headers)
assert r.status_code == 404
assert r.json["result"] == "failure"
diff --git a/nest_backend/test/test_5_authorizations.py b/nest_backend/test/test_5_authorizations.py
index 8ac2824..b91ca7f 100644
--- a/nest_backend/test/test_5_authorizations.py
+++ b/nest_backend/test/test_5_authorizations.py
@@ -9,7 +9,7 @@ class TestAuthozitazionsGet:
assert r.status_code == 200
assert r.json["result"] == "success"
- def test_get_non_existing_repository(self, flask_client: Client, admin_headers):
+ def test_repository_not_found(self, flask_client: Client, admin_headers):
r = flask_client.get('/api/v1/repositories/99/authorizations/', headers=admin_headers)
assert r.status_code == 404
assert r.json["result"] == "failure"
@@ -66,7 +66,28 @@ class TestAuthorizationsPut:
r = flask_client.put(f'/api/v1/repositories/1/authorizations/')
assert r.status_code == 401
- def test_get_non_existing_repository(self, flask_client: Client, admin_headers):
+ def test_repository_not_found(self, flask_client: Client, admin_headers):
r = flask_client.post('/api/v1/repositories/99/authorizations/', headers=admin_headers)
assert r.status_code == 404
assert r.json["result"] == "failure"
+
+
+class TestAuthorizationsDelete:
+ def test_for_success(self, flask_client: Client, user_headers):
+ r = flask_client.delete(f'/api/v1/repositories/1/authorizations/user_test@nest.com', headers=user_headers)
+ assert r.status_code == 204
+ assert r.json["result"] == "success"
+
+ def test_user_not_logged(self, flask_client: Client):
+ r = flask_client.delete(f'/api/v1/repositories/1/authorizations/user_test@nest.com')
+ assert r.status_code == 401
+
+ def test_wrong_owner(self, flask_client: Client, admin_headers):
+ r = flask_client.delete(f'/api/v1/repositories/1/authorizations/user_test@nest.com', headers=admin_headers)
+ assert r.status_code == 403
+ assert r.json["result"] == "failure"
+
+ def test_repository_not_found(self, flask_client: Client, admin_headers):
+ r = flask_client.delete(f'/api/v1/repositories/99/authorizations/user_test@nest.com', headers=admin_headers)
+ assert r.status_code == 404
+ assert r.json["result"] == "failure"
diff --git a/nest_crawler/__main__.py b/nest_crawler/__main__.py
index f9fc8a0..e24b264 100644
--- a/nest_crawler/__main__.py
+++ b/nest_crawler/__main__.py
@@ -1,245 +1,15 @@
-import random
-from nest_backend.app import app
from nest_backend.database import *
-import tweepy as tw
-from datetime import datetime, timedelta
-import smtplib
from nest_backend.app import app, extension_sqlalchemy
+from repo_search import search_repo_conditions
+from alert_trigger import is_repo_alert_triggered
ext.init_app(app=app)
-def authenticate():
- c_k = "GEhtSyP9e98mzFeiOCSW0lvQX"
- c_s = "438cmYrl5xqaX2W7I2Bf5A9nF1pN5VtM9f77WYQnAXg1BwKJ27"
- a_t = "1380217745732689921-IW3U1JlxhnQeGBUrnHZ2nxbxhksXUZ"
- a_t_s = "EUoYNoj72rb2q00tUIW8eTcLJAhUAYPstZlV78W9cPpEJ"
-
- auth = tw.OAuthHandler(c_k, c_s)
- auth.set_access_token(a_t, a_t_s)
- api = tw.API(auth, wait_on_rate_limit=True)
- # client = tw.Client(b_t, c_k, c_s, a_t, a_t_s, wait_on_rate_limit=True);
- return api
-
-
-def search_repo_conditions(repository_id):
- api = authenticate()
- geocode = "44.3591600,11.7132000,20km"
- repo = Repository.query.filter_by(id=repository_id).first()
- if repo is None:
- print("Non esiste una repository con questo id")
- return False
- conditions = [use for use in repo.conditions]
- if len(conditions) == 0:
- return False
- evaluation_mode = repo.evaluation_mode
- conditions_type = dict()
- # Dividing condition into condition types
- for condition in conditions:
- # print(condition.id)
- if condition.type not in conditions_type.keys():
- conditions_type[condition.type] = [condition]
- else:
- conditions_type[condition.type].append(condition)
-
- queryString = ""
-
- queryConjunction = "OR" if (evaluation_mode == ConditionMode.all_or) else ""
-
- tweetsFound = []
-
- for types in conditions_type.keys():
- print(types, ":", conditions_type[types])
- coordinates_string = ""
- if ConditionType.hashtag in conditions_type.keys():
- for condition_content in conditions_type[ConditionType.hashtag]:
- queryString += ("#" + condition_content.content + " " + queryConjunction + " ")
- if ConditionType.coordinates in conditions_type.keys():
- if evaluation_mode == ConditionMode.all_and:
- if len(conditions_type[ConditionType.coordinates]) == 1:
- coordinates_tweet = conditions_type[ConditionType.coordinates][0].content.split()
- coordinates_string = coordinates_tweet[2] + "," + coordinates_tweet[3] + "," + str(float(coordinates_tweet[1])/1000) + "km"
- else:
- return None
- elif evaluation_mode == ConditionMode.all_or:
- for condition_content in conditions_type[ConditionType.coordinates]:
- coordinates_tweet = condition_content.content.split()
- coordinates_string = coordinates_tweet[2] + "," + coordinates_tweet[3] + "," + str(float(coordinates_tweet[1])/1000) + "km"
- print(coordinates_string)
- for tweet in tw.Cursor(method=api.search, q="", geocode=coordinates_string).items(10):
- if not Tweet.query.filter_by(snowflake=str(tweet.id)).all():
- image_url_list = ''
- if 'media' in tweet.entities.keys():
- for url in tweet.entities['media']:
- image_url_list += (url['media_url_https'] + '|')
- image_url_list = image_url_list[:-1]
- else:
- image_url_list = None
-
- tweetDB = Tweet(snowflake=tweet.id, content=tweet.text,
- location=tweet.geo['coordinates'] if tweet.geo is not None else None,
- place=tweet.place.full_name if tweet.place is not None else None,
- insert_time=str(datetime.now()),
- poster=tweet.author.screen_name, post_time=str(tweet.created_at), image_url=image_url_list)
- ext.session.add(tweetDB)
- ext.session.commit()
- if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
- condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
- ext.session.add(condition_associated)
- ext.session.commit()
- if not Composed.query.filter_by(snowflake=str(tweet.id), rid=repository_id).all():
- composed = Composed(rid=repository_id, snowflake=tweet.id)
- ext.session.add(composed)
- ext.session.commit()
- if ConditionType.user in conditions_type.keys():
- for condition_content in conditions_type[ConditionType.user]:
- queryString += ("from:" + condition_content.content + " " + queryConjunction + " ")
- if ConditionType.time in conditions_type.keys():
- for condition_content in conditions_type[ConditionType.time]:
- if condition_content.content[0] == '<':
- queryString += ("until:" + condition_content.content[2:] + " " + queryConjunction + " ")
- elif condition_content.content[0] == '>':
- queryString += ("since:" + condition_content.content[2:] + " " + queryConjunction + " ")
- queryString = queryString[:-len(queryConjunction) - 1]
- print(queryString)
- if evaluation_mode == ConditionMode.all_or:
- if queryString != "":
- for tweet in tw.Cursor(method=api.search, q=queryString).items(10):
- tweetsFound.append(tweet)
- print(tweet.user.name + ' : ' + tweet.text + ' : ' + tweet.geo if tweet.geo is not None else '')
- elif evaluation_mode == ConditionMode.all_and:
- for tweet in tw.Cursor(method=api.search, q=queryString, geocode=coordinates_string).items(10):
- tweetsFound.append(tweet)
- print(tweet.user.name + ' : ' + tweet.text + ' : ' + str(tweet.geo))
- for tweet in tweetsFound:
- if not Tweet.query.filter_by(snowflake=str(tweet.id)).all():
- image_url_list = ''
- if 'media' in tweet.entities.keys():
- for url in tweet.entities['media']:
- image_url_list += (url['media_url_https'] + '|')
- image_url_list = image_url_list[:-1]
- else:
- image_url_list = None
- tweetDB = Tweet(snowflake=tweet.id, content=tweet.text,
- location=tweet.geo['coordinates'] if tweet.geo is not None else None,
- place=tweet.place.full_name if tweet.place is not None else None,
- insert_time=str(datetime.now()),
- poster=tweet.author.screen_name, post_time=str(tweet.created_at), image_url=image_url_list)
- ext.session.add(tweetDB)
- ext.session.commit()
- if evaluation_mode == ConditionMode.all_or:
- if ConditionType.hashtag in conditions_type.keys():
- for condition_content in conditions_type[ConditionType.hashtag]:
- if condition_content.content in [hashtag['text'] for hashtag in tweet.entities['hashtags']]:
- if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
- condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
- ext.session.add(condition_associated)
- ext.session.commit()
- if ConditionType.user in conditions_type.keys():
- for condition_content in conditions_type[ConditionType.user]:
- if condition_content.content == tweet.author.screen_name:
- if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
- condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
- ext.session.add(condition_associated)
- ext.session.commit()
-
- if ConditionType.time in conditions_type.keys():
- for condition_content in conditions_type[ConditionType.time]:
- condition_date_time = datetime.fromisoformat(condition_content.content[2:])
- if condition_content.content[0] == '<':
- if tweet.created_at < condition_date_time:
- if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
- condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
- ext.session.add(condition_associated)
- ext.session.commit()
- elif condition_content.content[0] == '>':
- if tweet.created_at > condition_date_time:
- if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
- condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
- ext.session.add(condition_associated)
- ext.session.commit()
- elif evaluation_mode == ConditionMode.all_and:
- for condition in conditions:
- if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition.id).all():
- condition_associated = Contains(cid=condition.id, snowflake=tweet.id)
- ext.session.add(condition_associated)
- ext.session.commit()
- if not Composed.query.filter_by(snowflake=str(tweet.id), rid=repository_id).all():
- composed = Composed(rid=repository_id, snowflake=tweet.id)
- ext.session.add(composed)
- ext.session.commit()
-
-
-def is_repo_alert_triggered(repository_id):
- repo = Repository.query.filter_by(id=repository_id).first()
- if repo is None:
- print("Non esiste una repository con questo id")
- return False
- alerts = [alert for alert in repo.alerts]
- alerts_triggered = []
- for alert in alerts:
- evaluation_mode = alert.evaluation_mode
- conditions = [condition.condition for condition in alert.conditions]
- repo_tweets = [tweet.tweet for tweet in repo.tweets]
- alert_tweets = set(repo_tweets)
- if evaluation_mode == ConditionMode.all_and:
- for condition in conditions:
- alert_tweets.intersection(set([tweet.tweet for tweet in condition.tweets]))
- elif evaluation_mode == ConditionMode.all_or:
- conditions_tweet = set()
- for condition in conditions:
- conditions_tweet.update([tweet.tweet for tweet in condition.tweets])
- alert_tweets = alert_tweets.intersection(conditions_tweet)
- end_time = datetime.now()
- window_size_hours = timedelta(hours = alert.window_size)
- last_notification_time = min([notification.ora for notification in alert.notifications] if len(alert.notifications)>0 else [end_time - window_size_hours])
- start_time = max(end_time - window_size_hours, last_notification_time)
- alert_tweets = [tweet for tweet in alert_tweets if (end_time > tweet.insert_time > start_time)]
- print(f"I tweet corrispondenti sono:{len(alert_tweets)}")
- if len(alert_tweets) >= alert.limit:
- alert_notification = Notification(ora=str(datetime.now()), alert_id=alert.id)
- ext.session.add(alert_notification)
- ext.session.commit()
- print("alert triggered")
- alerts_triggered.append(alert)
- send_notification_email(alert)
- send_notification_tweet(alert)
-
-
-def send_notification_email(alert):
- owner_repo = alert.repository.owner
- conditions_string = ''
- for condition in alert.conditions:
- conditions_string += condition.condition.content + ','
- conditions_string = conditions_string[:-1]
- try:
- smtpObj = smtplib.SMTP('localhost')
- smtpObj.sendmail("alert@nest.com", owner_repo.email, "Alert triggered")
- print("Successfully sent email")
- except smtplib.SMTPException:
- print("Error: unable to send email")
- finally:
- if smtpObj is not None:
- smtpObj.close()
-
-def send_notification_tweet(alert):
- api = authenticate()
- conditions_string = ''
- for condition in alert.conditions:
- conditions_string += condition.condition.content + ','
- conditions_string = conditions_string[:-1]
- print(conditions_string)
- api.update_status(f"L'alert {alert.name} è stato attivato! C'è stato un incremento di popolarità negli argomenti di ricerca {conditions_string}")
-
-
-def send_test_tweet():
- api = authenticate()
- api.update_status("Test")
-
def search_all_repo():
active_repos = Repository.query.filter_by(is_active=True)
for repo_id in [active_repo.id for active_repo in active_repos]:
- search_repo_conditions(repo_id)
+ #search_repo_conditions(repo_id)
is_repo_alert_triggered(repo_id)
if __name__ == "__main__":
diff --git a/nest_crawler/alert_trigger.py b/nest_crawler/alert_trigger.py
new file mode 100644
index 0000000..c8536c8
--- /dev/null
+++ b/nest_crawler/alert_trigger.py
@@ -0,0 +1,66 @@
+from datetime import datetime, timedelta
+from nest_backend.database import *
+from authentication import authenticate
+import smtplib
+
+def is_repo_alert_triggered(repository_id):
+ repo = Repository.query.filter_by(id=repository_id).first()
+ if repo is None:
+ print("Non esiste una repository con questo id")
+ return False
+ alerts = [alert for alert in repo.alerts]
+ alerts_triggered = []
+ for alert in alerts:
+ evaluation_mode = alert.evaluation_mode
+ conditions = [condition.condition for condition in alert.conditions]
+ repo_tweets = [tweet.tweet for tweet in repo.tweets]
+ alert_tweets = set(repo_tweets)
+ if evaluation_mode == ConditionMode.all_and:
+ for condition in conditions:
+ alert_tweets.intersection(set([tweet.tweet for tweet in condition.tweets]))
+ elif evaluation_mode == ConditionMode.all_or:
+ conditions_tweet = set()
+ for condition in conditions:
+ conditions_tweet.update([tweet.tweet for tweet in condition.tweets])
+ alert_tweets = alert_tweets.intersection(conditions_tweet)
+ end_time = datetime.now()
+ window_size_hours = timedelta(hours = alert.window_size)
+ last_notification_time = min([notification.ora for notification in alert.notifications] if len(alert.notifications)>0 else [end_time - window_size_hours])
+ start_time = max(end_time - window_size_hours, last_notification_time)
+ alert_tweets = [tweet for tweet in alert_tweets if (end_time > tweet.insert_time > start_time)]
+ print(f"I tweet corrispondenti sono:{len(alert_tweets)}")
+ if len(alert_tweets) >= alert.limit:
+ alert_notification = Notification(ora=str(datetime.now()), alert_id=alert.id)
+ ext.session.add(alert_notification)
+ ext.session.commit()
+ print("alert triggered")
+ alerts_triggered.append(alert)
+ send_notification_email(alert)
+ send_notification_tweet(alert)
+
+
+def send_notification_email(alert):
+ owner_repo = alert.repository.owner
+ conditions_string = ''
+ for condition in alert.conditions:
+ conditions_string += condition.condition.content + ','
+ conditions_string = conditions_string[:-1]
+ try:
+ smtpObj = smtplib.SMTP('localhost')
+ smtpObj.sendmail("alert@nest.com", owner_repo.email, "Alert triggered")
+ print("Successfully sent email")
+ except smtplib.SMTPException:
+ print("Error: unable to send email")
+ finally:
+ if smtpObj is not None:
+ smtpObj.close()
+
+def send_notification_tweet(alert):
+ api = authenticate()
+ conditions_string = ''
+ for condition in alert.conditions:
+ conditions_string += condition.condition.content + ','
+ conditions_string = conditions_string[:-1]
+ print(conditions_string)
+ api.update_status(f"L'alert {alert.name} è stato attivato! C'è stato un incremento di popolarità negli argomenti di ricerca {conditions_string}")
+
diff --git a/nest_crawler/authentication.py b/nest_crawler/authentication.py
new file mode 100644
index 0000000..4b369c2
--- /dev/null
+++ b/nest_crawler/authentication.py
@@ -0,0 +1,14 @@
+import tweepy as tw
+
+
+def authenticate():
+ c_k = "GEhtSyP9e98mzFeiOCSW0lvQX"
+ c_s = "438cmYrl5xqaX2W7I2Bf5A9nF1pN5VtM9f77WYQnAXg1BwKJ27"
+ a_t = "1380217745732689921-IW3U1JlxhnQeGBUrnHZ2nxbxhksXUZ"
+ a_t_s = "EUoYNoj72rb2q00tUIW8eTcLJAhUAYPstZlV78W9cPpEJ"
+
+ auth = tw.OAuthHandler(c_k, c_s)
+ auth.set_access_token(a_t, a_t_s)
+ api = tw.API(auth, wait_on_rate_limit=True)
+ # client = tw.Client(b_t, c_k, c_s, a_t, a_t_s, wait_on_rate_limit=True);
+ return api
\ No newline at end of file
diff --git a/nest_crawler/repo_search.py b/nest_crawler/repo_search.py
new file mode 100644
index 0000000..2daa636
--- /dev/null
+++ b/nest_crawler/repo_search.py
@@ -0,0 +1,151 @@
+from nest_backend.database import *
+from authentication import authenticate
+from datetime import datetime, timedelta
+import tweepy as tw
+
+def search_repo_conditions(repository_id):
+ api = authenticate()
+ geocode = "44.3591600,11.7132000,20km"
+ repo = Repository.query.filter_by(id=repository_id).first()
+ if repo is None:
+ print("Non esiste una repository con questo id")
+ return False
+ conditions = [use for use in repo.conditions]
+ if len(conditions) == 0:
+ return False
+ evaluation_mode = repo.evaluation_mode
+ conditions_type = dict()
+ # Dividing condition into condition types
+ for condition in conditions:
+ # print(condition.id)
+ if condition.type not in conditions_type.keys():
+ conditions_type[condition.type] = [condition]
+ else:
+ conditions_type[condition.type].append(condition)
+
+ queryString = ""
+
+ queryConjunction = "OR" if (evaluation_mode == ConditionMode.all_or) else ""
+
+ tweetsFound = []
+
+ for types in conditions_type.keys():
+ print(types, ":", conditions_type[types])
+ coordinates_string = ""
+ if ConditionType.hashtag in conditions_type.keys():
+ for condition_content in conditions_type[ConditionType.hashtag]:
+ queryString += ("#" + condition_content.content + " " + queryConjunction + " ")
+ if ConditionType.coordinates in conditions_type.keys():
+ if evaluation_mode == ConditionMode.all_and:
+ if len(conditions_type[ConditionType.coordinates]) == 1:
+ coordinates_tweet = conditions_type[ConditionType.coordinates][0].content.split()
+ coordinates_string = coordinates_tweet[2] + "," + coordinates_tweet[3] + "," + str(float(coordinates_tweet[1])/1000) + "km"
+ else:
+ return None
+ elif evaluation_mode == ConditionMode.all_or:
+ for condition_content in conditions_type[ConditionType.coordinates]:
+ coordinates_tweet = condition_content.content.split()
+ coordinates_string = coordinates_tweet[2] + "," + coordinates_tweet[3] + "," + str(float(coordinates_tweet[1])/1000) + "km"
+ print(coordinates_string)
+ for tweet in tw.Cursor(method=api.search, q="", geocode=coordinates_string).items(10):
+ if not Tweet.query.filter_by(snowflake=str(tweet.id)).all():
+ image_url_list = ''
+ if 'media' in tweet.entities.keys():
+ for url in tweet.entities['media']:
+ image_url_list += (url['media_url_https'] + '|')
+ image_url_list = image_url_list[:-1]
+ else:
+ image_url_list = None
+
+ tweetDB = Tweet(snowflake=tweet.id, content=tweet.text,
+ location=tweet.geo['coordinates'] if tweet.geo is not None else None,
+ place=tweet.place.full_name if tweet.place is not None else None,
+ insert_time=str(datetime.now()),
+ poster=tweet.author.screen_name, post_time=str(tweet.created_at), image_url=image_url_list)
+ ext.session.add(tweetDB)
+ ext.session.commit()
+ if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
+ condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
+ ext.session.add(condition_associated)
+ ext.session.commit()
+ if not Composed.query.filter_by(snowflake=str(tweet.id), rid=repository_id).all():
+ composed = Composed(rid=repository_id, snowflake=tweet.id)
+ ext.session.add(composed)
+ ext.session.commit()
+ if ConditionType.user in conditions_type.keys():
+ for condition_content in conditions_type[ConditionType.user]:
+ queryString += ("from:" + condition_content.content + " " + queryConjunction + " ")
+ if ConditionType.time in conditions_type.keys():
+ for condition_content in conditions_type[ConditionType.time]:
+ if condition_content.content[0] == '<':
+ queryString += ("until:" + condition_content.content[2:] + " " + queryConjunction + " ")
+ elif condition_content.content[0] == '>':
+ queryString += ("since:" + condition_content.content[2:] + " " + queryConjunction + " ")
+ queryString = queryString[:-len(queryConjunction) - 1]
+ print(queryString)
+ if evaluation_mode == ConditionMode.all_or:
+ if queryString != "":
+ for tweet in tw.Cursor(method=api.search, q=queryString).items(10):
+ tweetsFound.append(tweet)
+ print(tweet.user.name + ' : ' + tweet.text + ' : ' + tweet.geo if tweet.geo is not None else '')
+ elif evaluation_mode == ConditionMode.all_and:
+ for tweet in tw.Cursor(method=api.search, q=queryString, geocode=coordinates_string).items(10):
+ tweetsFound.append(tweet)
+ print(tweet.user.name + ' : ' + tweet.text + ' : ' + str(tweet.geo))
+ for tweet in tweetsFound:
+ if not Tweet.query.filter_by(snowflake=str(tweet.id)).all():
+ image_url_list = ''
+ if 'media' in tweet.entities.keys():
+ for url in tweet.entities['media']:
+ image_url_list += (url['media_url_https'] + '|')
+ image_url_list = image_url_list[:-1]
+ else:
+ image_url_list = None
+ tweetDB = Tweet(snowflake=tweet.id, content=tweet.text,
+ location=tweet.geo['coordinates'] if tweet.geo is not None else None,
+ place=tweet.place.full_name if tweet.place is not None else None,
+ insert_time=str(datetime.now()),
+ poster=tweet.author.screen_name, post_time=str(tweet.created_at), image_url=image_url_list)
+ ext.session.add(tweetDB)
+ ext.session.commit()
+ if evaluation_mode == ConditionMode.all_or:
+ if ConditionType.hashtag in conditions_type.keys():
+ for condition_content in conditions_type[ConditionType.hashtag]:
+ if condition_content.content in [hashtag['text'] for hashtag in tweet.entities['hashtags']]:
+ if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
+ condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
+ ext.session.add(condition_associated)
+ ext.session.commit()
+ if ConditionType.user in conditions_type.keys():
+ for condition_content in conditions_type[ConditionType.user]:
+ if condition_content.content == tweet.author.screen_name:
+ if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
+ condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
+ ext.session.add(condition_associated)
+ ext.session.commit()
+
+ if ConditionType.time in conditions_type.keys():
+ for condition_content in conditions_type[ConditionType.time]:
+ condition_date_time = datetime.fromisoformat(condition_content.content[2:])
+ if condition_content.content[0] == '<':
+ if tweet.created_at < condition_date_time:
+ if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
+ condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
+ ext.session.add(condition_associated)
+ ext.session.commit()
+ elif condition_content.content[0] == '>':
+ if tweet.created_at > condition_date_time:
+ if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition_content.id).all():
+ condition_associated = Contains(cid=condition_content.id, snowflake=tweet.id)
+ ext.session.add(condition_associated)
+ ext.session.commit()
+ elif evaluation_mode == ConditionMode.all_and:
+ for condition in conditions:
+ if not Contains.query.filter_by(snowflake=str(tweet.id), cid=condition.id).all():
+ condition_associated = Contains(cid=condition.id, snowflake=tweet.id)
+ ext.session.add(condition_associated)
+ ext.session.commit()
+ if not Composed.query.filter_by(snowflake=str(tweet.id), rid=repository_id).all():
+ composed = Composed(rid=repository_id, snowflake=tweet.id)
+ ext.session.add(composed)
+ ext.session.commit()