fix: Typo in community schema.

__init__.py

@@ -1 +1 @@
-from .profiles import setup
+from .profiles import setup, twitch_setup

data/profiles.sql

@@ -41,7 +41,7 @@ CREATE UNIQUE INDEX profiles_twitch_userid ON profiles_twitch (userid);
 
 CREATE TABLE communities(
   communityid INTEGER PRIMARY KEY GENERATED ALWAYS AS IDENTITY,
-  migrated INTEGER REFERENCES user_profiles (profileid) ON DELETE CASCADE ON UPDATE CASCADE,
+  migrated INTEGER REFERENCES communities (communityid) ON DELETE CASCADE ON UPDATE CASCADE,
   created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
   last_seen TIMESTAMPTZ NOT NULL DEFAULT NOW(),
   _timestamp TIMESTAMPTZ NOT NULL DEFAULT NOW()

profiles/twitch/__init__.py

@@ -6,5 +6,5 @@ if TYPE_CHECKING:
 
 
 async def setup(bot: 'Bot'):
-    from .component import ProfileComponent
+    from .component import ProfilesComponent
-    await bot.add_component(ProfileComponent(bot))
+    await bot.add_component(ProfilesComponent(bot))

profiles/twitch/component.py

@@ -41,22 +41,22 @@ class ProfilesComponent(cmds.Component):
         Fetch or create the profile for the given user.
         """
         userid = str(user.id)
-        async with self.bot.dbconn.connection() as conn:
+        # TODO: Transaction
-            self.bot.dbconn.conn = conn 
+        profile = await self.profiles.get_profile_twitch(userid)
-            async with conn.transaction():
+        if profile is None:
-                profile = await self.profiles.get_profile_twitch(userid)
+            args = {}
-                if profile is None:
+            try:
-                    args = {}
+                user = await user.user()
-                    try:
+                args['nickname'] = user.display_name
-                        user = await user.user()
+                args['avatar'] = user.profile_image.url
-                        args['nickname'] = user.display_name
+            except twitchio.HTTPException:
-                        args['avatar'] = user.profile_image.url
+                pass
-                    except twitchio.HTTPException:
+            except IndexError:
-                        pass
+                pass
-                    profile = await UserProfile.create(**args)
+            profile = await UserProfile.create(**args)
-                    await TwitchProfileLink.create(profileid=profile.profileid, userid=userid)
+            await TwitchProfileLink.create(profileid=profile.profileid, userid=userid)
-                elif touch:
+        elif touch:
-                    await profile.update(last_seen=utc_now())
+            await profile.update(last_seen=utc_now())
 
         return profile
 
@@ -70,14 +70,12 @@ class ProfilesComponent(cmds.Component):
         Fetch or create the community for this channel.
         """
         chanid = channel.id
-        async with self.bot.dbconn.connection() as conn:
+        # TODO: Transaction
-            self.bot.dbconn.conn = conn
+        comm = await self.profiles.get_community_twitch(chanid)
-            async with conn.transaction():
+        if comm is None:
-                comm = await self.profiles.get_community_twitch(chanid)
+            comm = await Community.create()
-                if comm is None:
+            await TwitchCommunityLink.create(channelid=chanid, communityid=comm.communityid)
-                    comm = await Community.create()
+        elif touch:
-                    await TwitchCommunityLink.create(channelid=chanid, communityid=comm.communityid)
+            await comm.update(last_seen=utc_now())
-                elif touch:
-                    await comm.update(last_seen=utc_now())
         return comm