Python realtime with RLS

[TomasRences]

Bug report

Describe the bug

Unable to catch event if policy checking if user is authentificated exists on table.

To Reproduce

Python client code:

from realtime.connection import Socket

SUPABASE_URL = "project_id"
SUPABASE_KEY = "anon_key"

realtime_url = f"wss://{SUPABASE_URL}/realtime/v1/websocket?apikey={SUPABASE_KEY}"


def callback(event):
    print(event)


s = Socket(realtime_url)
s.connect()

channel = s.set_channel("realtime:*")
channel.join().on("*", callback)
s.listen()

It is work for public tables, but when we want to enable RLS and allow to CRUD only for authentificated users with following policy:

CREATE POLICY "User Is Authentificated" ON "public"."myTable"
AS PERMISSIVE FOR ALL
TO authenticated
USING (true)

Expected behavior

Be able to authentificate with Bearer JWT token as user

System information

• Version of realtime-py: 1.0.2

[VisionOra]

PLease fix this

[fullstackwebdev]

is this why I am only getting INSERTs (public info) but not UPDATES (I guess RLS forbids these events?), even I am using SERVICE ROLE KEY?

[sidtuladhar]

I was able to get it working after a few hours. This is my code:

supabase: Client = create_client(SUPABASE_URL, SUPABASE_ANON_KEY)
user_jwt =  supabase.auth.sign_in_with_password({
    "email": EMAIL,
    "password": PASSWORD
})
access_token = user_jwt.session.access_token

async def main():
    sp = AClient(SUPABASE_URL, SUPABASE_ANON_KEY)
    await sp.realtime.connect()
    await sp.realtime.set_auth(access_token)
    
    channel = sp.realtime.channel("global-message-channel")
    await channel.on_postgres_changes("*", table="messages", callback=lambda payload: print(payload)).subscribe()

    await sp.realtime.listen()

if __name__ == "__main__":
    asyncio.run(main())

Remeber to call the set_auth method.

[pablocalvo-zh]

@sidtuladhar Freaking genius. The documentation is misleading and imcomplete... Thanks man