devportal: add support for posting to discourse topics

Author: jwise

appstore/developer_portal_api.py

@@ -17,8 +17,8 @@
 from .pbw import PBW, release_from_pbw
 from .s3 import upload_pbw, upload_asset, get_link_for_archive
 from .settings import config
-from .discord import announce_release, announce_new_app, audit_log
-
+from .discord import audit_log
+from . import discord, discourse
 
 parent_app = None
 devportal_api = Blueprint('devportal_api', __name__)
@@ -205,10 +205,16 @@ def submit_new_app():
             algolia_index.partial_update_objects([algolia_app(app_obj)], { 'createIfNotExists': True })
 
         try:
-            announce_new_app(app_obj, pbw.is_generated())
-        except Exception:
+            discord.announce_new_app(app_obj, pbw.is_generated())
+        except Exception as e:
             # We don't want to fail just because Discord is being weird
-            print("Discord is being weird")
+            print("Discord is being weird: {repr(e)}")
+
+        try:
+            discourse.announce_new_app(app_obj, pbw.is_generated())
+        except Exception as e:
+            # We don't want to fail just because Discourse is being weird
+            print("Discourse is being weird: {repr(e)}")
 
         return jsonify(success=True, id=app_obj.id)
 
@@ -344,10 +350,16 @@ def submit_new_release(app_id):
     db.session.commit()
 
     try:
-        announce_release(app, release_new, pbw.is_generated())
-    except Exception:
+        discord.announce_release(app, release_new, pbw.is_generated())
+    except Exception as e:
         # We don't want to fail just because Discord webhook is being weird
-        print("Discord is being weird")
+        print("Discord is being weird: {repr(e)}")
+
+    try:
+        discourse.announce_release(app, release_new, pbw.is_generated())
+    except Exception as e:
+        # We don't want to fail just because Discourse webhook is being weird
+        print(f"Discourse is being weird: {repr(e)}")
 
     return jsonify(success=True)
 

appstore/discourse.py

@@ -0,0 +1,83 @@
+from pydiscourse.client import DiscourseClient
+
+from .settings import config
+from .models import App, db
+from .discord import random_party_emoji
+from .utils import get_app_description, generate_image_url
+
+if config['DISCOURSE_API_KEY'] is None:
+    _client = None
+else:
+    _client = DiscourseClient(host=f"https://{config['DISCOURSE_HOST']}", api_username=config['DISCOURSE_USER'], api_key=config['DISCOURSE_API_KEY'])
+
+def _md_quotify(text):
+    return '\n'.join("> " + line for line in text.split('\n'))
+
+def _create_or_post_to_topic(app, is_generated, text):
+    if is_generated:
+        # For now, we don't post about generated watchfaces.  Maybe they
+        # should go in their own topic later?
+        return
+
+    if app.discourse_topic_id is -1:
+        # We have manually set that we don't want a Discourse topic at all
+        # for this app.  Don't post at all.
+        return
+
+    if app.discourse_topic_id is None:
+        # This app doesn't have a topic of its own yet; create a new one,
+        # and store it in the database.
+        
+        if app.type == "watchapp":
+            tags = ['pebble-app', 'watchapp', app.category.name]
+            type_displayed = "Watchapp"
+        else:
+            tags = ['pebble-app', 'watchface']
+            type_displayed = "Watchface"
+        
+        # If any of this fails, someone can swallow the exception externally.
+        rv = _client.create_post(text,
+            category_id=config['DISCOURSE_SHOWCASE_TOPIC_ID'],
+            title=f"{type_displayed}: {app.title} by {app.developer.name}",
+            tags=tags)
+
+        App.query.filter_by(app_uuid=app.app_uuid).update({'discourse_topic_id': rv['topic_id']})
+        db.session.commit()
+    else:
+        _client.create_post(text, category_id=config['DISCOURSE_SHOWCASE_TOPIC_ID'], topic_id=app.discourse_topic_id)
+
+def announce_release(app, release, is_generated):
+    _create_or_post_to_topic(app, is_generated, text=f"""
+# {random_party_emoji()} Update alert!
+
+{app.developer.name} just released *version *{release.version}** of **{app.title}**!
+
+[Go check it out!]({config['APPSTORE_ROOT']}/application/{app.id})
+
+## Release notes
+
+{_md_quotify(release.release_notes or "N/A")}
+
+""")
+
+def announce_new_app(app, is_generated):
+    _create_or_post_to_topic(app, is_generated, text=f"""
+# {app.title} by {app.developer.name}
+
+There's a new {app.type} on the Rebble App Store!
+
+{app.developer.name} says:
+
+{_md_quotify(get_app_description(app))}
+
+[Go check it out in the App Store!]({config['APPSTORE_ROOT']}/application/{app.id})
+
+![App icon]({generate_image_url(app.icon_large)})
+
+*P.S.: I'm just a helpful robot that posted this.  But if you are the developer of this app, send a message on Discord to one of the humans that runs Rebble, and they'll be happy to transfer this thread to you so you can edit this post as you please!*
+""")
+
+def get_topic_url_for_app(app):
+    if not _client or not app.discourse_topic_id or app.discourse_topic_id == -1:
+        return None
+    return f"https://{config['DISCOURSE_HOST']}/t/{app.discourse_topic_id}"

appstore/models.py

@@ -78,6 +78,7 @@ class App(db.Model):
     visible = db.Column(db.Boolean, default=True, server_default='TRUE', nullable=False)
     timeline_token = db.Column(db.String, index=True)
     installs = db.Column(db.Integer, index=True)
+    discourse_topic_id = db.Column(db.Integer)
 
 
 category_banner_apps = Table('category_banner_apps', db.Model.metadata,

appstore/settings.py

@@ -28,4 +28,8 @@
     'AWS_SECRET_KEY': os.environ.get('AWS_SECRET_KEY', None),
     'S3_ENDPOINT': os.environ.get('S3_ENDPOINT', None),
     'TEST_APP_UUID': os.environ.get('TEST_APP_UUID', None),
+    'DISCOURSE_USER': os.environ.get('DISCOURSE_USER', 'annedroid'),
+    'DISCOURSE_API_KEY': os.environ.get('DISCOURSE_API_KEY', None),
+    'DISCOURSE_HOST': os.environ.get('DISCOURSE_HOST', f'forums.{domain_root}'),
+    'DISCOURSE_SHOWCASE_TOPIC_ID': int(os.environ.get('DISCOURSE_SHOWCASE_TOPIC_ID', '3')),
 }

appstore/utils.py

@@ -13,6 +13,7 @@
 
 import beeline
 
+import appstore # break the circular dependency to import get_topic_url_for_app from discourse
 from .settings import config
 from appstore.models import App, AssetCollection, CompanionApp
 
@@ -158,6 +159,7 @@ def jsonify_app(app: App, target_hw: str) -> dict:
         },
         'published_date': app.published_date,
         'visible': app.visible,
+        'discourse_url': appstore.discourse.get_topic_url_for_app(app),
     }
     if release:
         result['latest_release'] = {

migrations/versions/89e32c02be56_add_discourse_topic_id.py

@@ -0,0 +1,28 @@
+"""Add Discourse topic ID
+
+Revision ID: 89e32c02be56
+Revises: c2c7be2e8835
+Create Date: 2025-12-03 09:42:17.001613
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision = '89e32c02be56'
+down_revision = 'c2c7be2e8835'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('apps', sa.Column('discourse_topic_id', sa.Integer(), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('apps', 'discourse_topic_id')
+    # ### end Alembic commands ###