Adding Notif Service Docker Container

.gitignore

@@ -0,0 +1,436 @@
+### Python ###
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+db.sqlite3-journal
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+.pybuilder/
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+#   For a library or package, you might want to ignore these files since the code is
+#   intended to run in multiple environments; otherwise, check them in:
+# .python-version
+
+# pipenv
+#   According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
+#   However, in case of collaboration, if having platform-specific dependencies or dependencies
+#   having no cross-platform support, pipenv may install dependencies that don't work, or not
+#   install all needed dependencies.
+#Pipfile.lock
+
+# poetry
+#   Similar to Pipfile.lock, it is generally recommended to include poetry.lock in version control.
+#   This is especially recommended for binary packages to ensure reproducibility, and is more
+#   commonly ignored for libraries.
+#   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control
+#poetry.lock
+
+# pdm
+#   Similar to Pipfile.lock, it is generally recommended to include pdm.lock in version control.
+#pdm.lock
+#   pdm stores project-wide configurations in .pdm.toml, but it is recommended to not include it
+#   in version control.
+#   https://pdm.fming.dev/#use-with-ide
+.pdm.toml
+
+# PEP 582; used by e.g. github.com/David-OConnor/pyflow and github.com/pdm-project/pdm
+__pypackages__/
+
+# Celery stuff
+celerybeat-schedule
+celerybeat.pid
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/
+
+# pytype static type analyzer
+.pytype/
+
+# Cython debug symbols
+cython_debug/
+
+# PyCharm
+#  JetBrains specific template is maintained in a separate JetBrains.gitignore that can
+#  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
+#  and can be added to the global gitignore or merged into this file.  For a more nuclear
+#  option (not recommended) you can uncomment the following to ignore the entire idea folder.
+#.idea/
+
+### Python Patch ###
+# Poetry local configuration file - https://python-poetry.org/docs/configuration/#local-configuration
+poetry.toml
+
+# ruff
+.ruff_cache/
+
+# LSP config files
+pyrightconfig.json
+
+### react ###
+.DS_*
+logs
+**/*.backup.*
+**/*.back.*
+
+node_modules
+bower_components
+
+*.sublime*
+
+psd
+thumb
+sketch
+
+### ReactNative ###
+# React Native Stack Base
+
+.expo
+__generated__
+
+### ReactNative.Xcode Stack ###
+## User settings
+xcuserdata/
+
+## Xcode 8 and earlier
+*.xcscmblueprint
+*.xccheckout
+
+### ReactNative.Gradle Stack ###
+.gradle
+**/build/
+!src/**/build/
+
+# Ignore Gradle GUI config
+gradle-app.setting
+
+# Avoid ignoring Gradle wrapper jar file (.jar files are usually ignored)
+!gradle-wrapper.jar
+
+# Avoid ignore Gradle wrappper properties
+!gradle-wrapper.properties
+
+# Cache of project
+.gradletasknamecache
+
+# Eclipse Gradle plugin generated files
+# Eclipse Core
+.project
+# JDT-specific (Eclipse Java Development Tools)
+.classpath
+
+### ReactNative.macOS Stack ###
+# General
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Icon must end with two \r
+Icon
+
+
+# Thumbnails
+._*
+
+# Files that might appear in the root of a volume
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+
+# Directories potentially created on remote AFP share
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk
+
+### ReactNative.Linux Stack ###
+*~
+
+# temporary files which can be created if a process still has a handle open of a deleted file
+.fuse_hidden*
+
+# KDE directory preferences
+.directory
+
+# Linux trash folder which might appear on any partition or disk
+.Trash-*
+
+# .nfs files are created when an open file is removed but is still being accessed
+.nfs*
+
+### ReactNative.Node Stack ###
+# Logs
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+.pnpm-debug.log*
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+*.lcov
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Snowpack dependency directory (https://snowpack.dev/)
+web_modules/
+
+# TypeScript cache
+*.tsbuildinfo
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional stylelint cache
+.stylelintcache
+
+# Microbundle cache
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variable files
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# parcel-bundler cache (https://parceljs.org/)
+.parcel-cache
+
+# Next.js build output
+.next
+out
+
+# Nuxt.js build / generate output
+.nuxt
+dist
+
+# Gatsby files
+.cache/
+# Comment in the public line in if your project uses Gatsby and not Next.js
+# https://nextjs.org/blog/next-9-1#public-directory-support
+# public
+
+# vuepress build output
+.vuepress/dist
+
+# vuepress v2.x temp and cache directory
+.temp
+
+# Docusaurus cache and generated files
+.docusaurus
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/
+
+# TernJS port file
+.tern-port
+
+# Stores VSCode versions used for testing VSCode extensions
+.vscode-test
+
+# yarn v2
+.yarn/cache
+.yarn/unplugged
+.yarn/build-state.yml
+.yarn/install-state.gz
+.pnp.*
+
+### ReactNative.Buck Stack ###
+buck-out/
+.buckconfig.local
+.buckd/
+.buckversion
+.fakebuckversion
+
+### ReactNative.Android Stack ###
+# Gradle files
+.gradle/
+
+# Local configuration file (sdk path, etc)
+local.properties
+
+# Log/OS Files
+
+# Android Studio generated files and folders
+captures/
+.externalNativeBuild/
+.cxx/
+*.apk
+output.json
+
+# IntelliJ
+*.iml
+.idea/
+misc.xml
+deploymentTargetDropDown.xml
+render.experimental.xml
+
+# Keystore files
+*.jks
+*.keystore
+
+# Google Services (e.g. APIs or Firebase)
+google-services.json
+
+# Android Profiling
+*.hprof
+
+# Personal
+data
+package-lock.json

Dockerfile

@@ -0,0 +1,5 @@
+FROM python:3.10.9
+COPY . .
+WORKDIR /
+RUN pip install --no-cache-dir --upgrade -r /requirements.txt
+CMD ["python", "main.py"]

main.py

@@ -0,0 +1,334 @@
+import json
+import subprocess
+from concurrent.futures import ThreadPoolExecutor
+from realtime.connection import Socket
+import os
+import time
+from supabase import create_client
+from dotenv import load_dotenv
+import requests
+
+load_dotenv()
+
+SUPABASE_ID = os.getenv('supabaseID')
+SUPABASE_URL = os.getenv('supabaseUrl')
+SUPABASE_KEY = os.getenv('supabaseAnonKey')
+
+# Supabase client creation for each function
+def get_client():
+    return create_client(SUPABASE_URL, SUPABASE_KEY)
+
+def getUsername(userid):
+    supabase = get_client()
+    response = supabase.table("profiles").select(
+        "*").eq("id", userid).execute()
+    data = response.data
+    username = data[0]['username']
+    return username
+
+def getAuthorNotifToken(userid):
+    supabase = get_client()
+    response = supabase.table("profiles").select(
+        "*").eq("id", userid).execute()
+    data = response.data
+    token = data[0]['notifToken']
+    return token
+
+
+# def send_notification(title, body, token, id, post_id, notif_type):
+#     print(token)
+#     notification_data = {
+#         'to': token,
+#         'title': title,
+#         'body': body,
+#         'data': {
+#             'user_id': id,
+#             'id': post_id,
+#             'type': notif_type
+#         }
+#     }
+
+#     notification_json = json.dumps(notification_data)
+#     print(notification_json)
+#     curl_command = [
+#         'curl',
+#         '-X', 'POST',
+#         '-H', 'Content-Type: application/json',
+#         '-d', notification_json,
+#         'https://exp.host/--/api/v2/push/send'
+#     ]
+
+#     try:
+#         result = subprocess.run(
+#             curl_command, capture_output=True, text=True, check=True)
+#         print(f'Notification sent successfully: {result.stdout}')
+#     except subprocess.CalledProcessError as e:
+#         print(f'Failed to send notification: {e.stderr}')
+
+
+def send_notification(title, body, token, id, post_id, notif_type):
+    print(token)
+    notification_data = {
+        'to': token,
+        'title': title,
+        'body': body,
+        'data': {
+            'user_id': id,
+            'id': post_id,
+            'type': notif_type
+        }
+    }
+    try:
+        response = requests.post(
+            'https://exp.host/--/api/v2/push/send', json=notification_data)
+        response.raise_for_status()
+        print(f'Notification sent successfully: {response.text}')
+    except requests.exceptions.RequestException as e:
+        print(f'Failed to send notification: {e}')
+
+
+def handle_listlikes_update(event_payload):
+    print('Received update in listlikes:')
+    print(event_payload)
+    record = event_payload['record']
+    id = record['list_id']
+    author_id = record['author_id']
+    user_id = record['user_id']
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} liked your collection!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "list")
+
+def handle_listcomments_update(event_payload):
+    print('Received update in listcomments:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['author_id']
+    user_id = record['user_id']
+    id = record['list_id']
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} commented on your collection!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "list")
+
+def handle_likes_update(event_payload):
+    print('Received update in likes:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['author_id']
+    user_id = record['user_id']
+    id = record['post_id']
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} liked your post!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "post")
+
+def handle_comments_update(event_payload):
+    print('Received update in comments:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['author_id']
+    user_id = record['user_id']
+    id = record['post_id']
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} commented on your post!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "post")
+
+def handle_follow_update(event_payload):
+    print('Received update in followers:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['id']
+    user_id = record['following']
+    id = record['following']
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} followed you!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "follow")
+
+def getConversationUser(author_id, conv_id):
+    supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
+    response = supabase.table("conversations").select("*").eq("id", conv_id).execute()
+    data = response.data
+    user1 = data[0]['user1']
+    user2 = data[0]['user2']
+    if user1 == author_id:
+        return user2
+    else:
+        return user1
+
+def handle_message_update(event_payload):
+    print('Received update in messages:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['user_id']
+    conv_id = record['conversation_id']
+    id = record['conversation_id']
+    user_id = getConversationUser(author_id, conv_id)
+    token = getAuthorNotifToken(user_id)
+    username = getUsername(author_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} sent you a message!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "message")
+
+def handle_listreply_update(event_payload):
+    print('Received update in listreplies:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['user_id']
+    user_id = record['to']
+    id = record['list_id']
+    token = getAuthorNotifToken(user_id)
+    username = getUsername(author_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} replied to you!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "list")
+
+def handle_reply_update(event_payload):
+    print('Received update in replies:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['user_id']
+    user_id = record['to']
+    id = record['post_id']
+    token = getAuthorNotifToken(user_id)
+    username = getUsername(author_id).lower()
+    body = f'@{username} replied to you!'
+    title = 'Picturelock'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, "post")
+
+def handle_commentlikes_update(event_payload):
+    print('Received update in commentlikes:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['author_id']
+    user_id = record['user_id']
+    if record['post_id'] == None:
+        id = record['list_id']
+        post_type = "list"
+    else:
+        id = record['post_id']
+        post_type = "post"
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} liked your comment!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, post_type)
+
+def handle_replylikes_update(event_payload):
+    print('Received update in replylikes:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['author_id']
+    user_id = record['user_id']
+    if record['post_id'] == None:
+        id = record['list_id']
+        post_type = "list"
+    else:
+        id = record['post_id']
+        post_type = "post"
+    token = getAuthorNotifToken(author_id)
+    username = getUsername(user_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} liked your reply!'
+    if token and user_id != author_id:
+        send_notification(title, body, token, user_id, id, post_type)
+
+def handle_groupreviewrequests_update(event_payload):
+    print('Received update in posts:')
+    print(event_payload)
+    record = event_payload['record']
+    author_id = record['groupReviewLeader']
+    id = record['id']
+    user_id = record['author']
+    isGroupReview = record['isGroupReview']
+    token = getAuthorNotifToken(user_id)
+    username = getUsername(author_id).lower()
+    title = 'Picturelock'
+    body = f'@{username} sent you an invite to a group review!'
+    print(body)
+    if token and user_id != author_id and isGroupReview:
+        send_notification(title, body, token, author_id, id, "post")
+
+def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
+    URL = f"wss://{SUPABASE_ID}.supabase.co/realtime/v1/websocket?apikey={SUPABASE_KEY}&vsn=1.0.0"
+
+    with ThreadPoolExecutor(max_workers=10) as executor:
+        while True:
+            try:
+                s = Socket(URL)
+                s.connect()
+
+                channel_listlikes = s.set_channel("realtime:public:listlikes")
+                channel_listlikes.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_listlikes_update, payload))
+
+                channel_listcomments = s.set_channel(
+                    "realtime:public:listcomments")
+                channel_listcomments.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_listcomments_update, payload))
+
+                channel_likes = s.set_channel("realtime:public:likes")
+                channel_likes.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_likes_update, payload))
+
+                channel_replylikes = s.set_channel(
+                    "realtime:public:replylikes")
+                channel_replylikes.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_replylikes_update, payload))
+
+                channel_commentlikes = s.set_channel(
+                    "realtime:public:commentlikes")
+                channel_commentlikes.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_commentlikes_update, payload))
+
+                channel_comments = s.set_channel("realtime:public:comments")
+                channel_comments.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_comments_update, payload))
+
+                channel_followers = s.set_channel("realtime:public:followers")
+                channel_followers.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_follow_update, payload))
+
+                channel_replies = s.set_channel("realtime:public:replies")
+                channel_replies.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_reply_update, payload))
+
+                channel_listreplies = s.set_channel(
+                    "realtime:public:listreplies")
+                channel_listreplies.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_listreply_update, payload))
+
+                channel_messages = s.set_channel("realtime:public:messages")
+                channel_messages.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_message_update, payload))
+
+                channel_posts = s.set_channel("realtime:public:posts")
+                channel_posts.join().on("INSERT", lambda payload: executor.submit(
+                    handle_groupreviewrequests_update, payload))
+
+                s.listen()
+
+            except Exception as e:
+                print(f'Connection error: {e}')
+                print('Reconnecting in 5 seconds...')
+                time.sleep(5)
+
+
+if __name__ == '__main__':
+    setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY)

requirements.txt

@@ -0,0 +1,25 @@
+annotated-types==0.7.0
+anyio==4.4.0
+certifi==2024.7.4
+deprecation==2.1.0
+exceptiongroup==1.2.1
+gotrue==2.5.4
+h11==0.14.0
+httpcore==1.0.5
+httpx==0.27.0
+idna==3.7
+packaging==24.1
+postgrest==0.16.8
+pydantic==2.8.2
+pydantic_core==2.20.1
+python-dateutil==2.9.0.post0
+python-dotenv==1.0.1
+realtime==1.0.2
+six==1.16.0
+sniffio==1.3.1
+storage3==0.7.6
+StrEnum==0.4.15
+supabase==2.5.1
+supafunc==0.4.6
+typing_extensions==4.12.2
+websockets==11.0.3