Send notification new post to Twitter

.github/workflows/deploy.yml

@@ -54,6 +54,10 @@ jobs:
           secret_PATREON_CLIENT_SECRET: ${{ secrets.PATREON_CLIENT_SECRET }}
           secret_JWT_PRIVATE_KEY: ${{ secrets.JWT_PRIVATE_KEY }}
           secret_WEBHOOK_SECRETS: ${{ secrets.WEBHOOK_SECRETS }}
+          secret_TWITTER_CONSUMER_KEY: ${{ secrets.TWITTER_CONSUMER_KEY }}
+          secret_TWITTER_SECRET_KEY: ${{ secrets.TWITTER_SECRET_KEY }}
+          secret_TWITTER_ACCESS_TOKEN : ${{ secrets.TWITTER_ACCESS_TOKEN }}
+          secret_TWITTER_ACCESS_TOKEN_SECRET: ${{ secrets.TWITTER_ACCESS_TOKEN_SECRET }}
       - run: echo "GITHUB_SHA=$GITHUB_SHA" >> .env
       - run: echo "${{ secrets.PRODUCTION_SSH_KEY }}" > ${{ env.SSH_KEY_PATH }} && chmod 600 ${{ env.SSH_KEY_PATH }}
       - run: scp -o StrictHostKeyChecking=no -i ${{ env.SSH_KEY_PATH }} .env ${{ secrets.PRODUCTION_SSH_USERNAME }}@${{ secrets.PRODUCTION_SSH_HOST }}:/home/vas3k/vas3k.club/.env

Pipfile

@@ -38,6 +38,7 @@ icalendar = "*"
 httptools = "*"
 croniter = "*"
 authlib = "==1.2"
+tweepy = "==4.14.0"
 
 [requires]
 python_version = "3.8"

bot/handlers/moderation.py

@@ -12,6 +12,7 @@
 from notifications.telegram.posts import notify_post_approved, announce_in_club_chats, \
     notify_post_rejected, notify_post_collectible_tag_owners
 from notifications.telegram.users import notify_user_profile_approved, notify_user_profile_rejected
+from notifications.twitter.posts import send_to_twitter
 from posts.models.post import Post
 from posts.models.subscriptions import PostSubscription
 from search.models import SearchIndex
@@ -51,6 +52,7 @@ def approve_post(update: Update, context: CallbackContext) -> None:
     # send notifications
     notify_post_approved(post)
     announce_in_club_chats(post)
+    send_to_twitter(post)
     if post.collectible_tag_code:
         notify_post_collectible_tag_owners(post)
 

club/.env.example

@@ -27,3 +27,9 @@ PATREON_CLIENT_SECRET=""
 
 JWT_PRIVATE_KEY=""
 WEBHOOK_SECRETS=""
+
+TWITTER_CONSUMER_KEY=""
+TWITTER_SECRET_KEY=""
+TWITTER_ACCESS_TOKEN=""
+TWITTER_ACCESS_TOKEN_SECRET=""
+

club/settings.py

@@ -273,6 +273,11 @@
 TELEGRAM_BOT_WEBHOOK_HOST = "0.0.0.0"
 TELEGRAM_BOT_WEBHOOK_PORT = 8816
 
+TWITTER_CONSUMER_KEY=os.getenv("TWITTER_CONSUMER_KEY")
+TWITTER_SECRET_KEY=os.getenv("TWITTER_SECRET_KEY")
+TWITTER_ACCESS_TOKEN=os.getenv("TWITTER_ACCESS_TOKEN")
+TWITTER_ACCESS_TOKEN_SECRET=os.getenv("TWITTER_ACCESS_TOKEN_SECRET")
+
 STRIPE_API_KEY = os.getenv("STRIPE_API_KEY") or ""
 STRIPE_PUBLIC_KEY = os.getenv("STRIPE_PUBLIC_KEY") or ""
 STRIPE_WEBHOOK_SECRET = os.getenv("STRIPE_WEBHOOK_SECRET") or ""

notifications/twitter/posts.py

@@ -0,0 +1,29 @@
+import logging
+
+import tweepy
+
+from club import settings
+from posts.models.post import Post
+
+log = logging.getLogger()
+
+auth = tweepy.OAuth1UserHandler(
+    consumer_key=settings.TWITTER_CONSUMER_KEY,
+    consumer_secret=settings.TWITTER_SECRET_KEY,
+    access_token=settings.TWITTER_ACCESS_TOKEN,
+    access_token_secret=settings.TWITTER_ACCESS_TOKEN_SECRET
+)
+twitter = tweepy.API(auth)
+
+
+def send_to_twitter(post: Post):
+    if post.type == Post.TYPE_INTRO:
+        log.info(f"Twitter skipping post with type: {post.type}")
+        return
+
+    url = settings.APP_HOST + post.get_absolute_url()
+    title = post.title
+    text = f"{title} {url}"
+
+    log.info(f"Twitter sending tweet with text: {text}")
+    twitter.update_status(status=text)