getting null values when trying to listening to realtime changes on table

[Chetan-Akre]

JavaScript App

This is the output from a JavaScript web app on a Realtime update. Please compare this with the C# app output shown below.

{
  "schema": "public",
  "table": "user_profiles",
  "commit_timestamp": "2026-01-13T15:29:35.474Z",
  "eventType": "UPDATE",
  "new": {
    "role": "operator",
    "user_id": "3c0c5401-a42c-42ee-8bce-3e51257e28c9",
    "is_active": false,
    "created_at": "2026-01-11T11:36:26.547415+00:00",
    "updated_at": "2026-01-11T11:36:26.547415+00:00",
    "last_login_at": "2026-01-12T11:47:22.545841+00:00"
  },
  "old": {
    "role": "operator",
    "user_id": "3c0c5401-a42c-42ee-8bce-3e51257e28c9",
    "is_active": true,
    "created_at": "2026-01-11T11:36:26.547415+00:00",
    "updated_at": "2026-01-11T11:36:26.547415+00:00",
    "last_login_at": "2026-01-12T11:47:22.545841+00:00"
  },
  "errors": null
}

C# App

I am not sure what is going wrong here. If I am receiving a clean and correct payload in the JavaScript app, why does the C# app return null values for the row data?

This suggests that the Supabase dashboard configuration is correct, but there may be an issue with the C# app implementation or the SDK/library itself.

{
  "data": {
    "record": {
      "columns": null,
      "commit_timestamp": null,
      "record": null,
      "old_record": null,
      "schema": null,
      "table": null,
      "type": null,
      "status": null,
      "response": null,
      "joins": null,
      "leaves": null,
      "channel": null,
      "extension": null,
      "message": null
    },
    "old_record": {
      "columns": null,
      "commit_timestamp": null,
      "record": null,
      "old_record": null,
      "schema": null,
      "table": null,
      "type": null,
      "status": null,
      "response": null,
      "joins": null,
      "leaves": null,
      "channel": null,
      "extension": null,
      "message": null
    },
    "columns": [
      { "name": "user_id", "type": "uuid" },
      { "name": "role", "type": "text" },
      { "name": "is_active", "type": "bool" },
      { "name": "last_login_at", "type": "timestamptz" },
      { "name": "created_at", "type": "timestamptz" },
      { "name": "updated_at", "type": "timestamptz" }
    ],
    "commit_timestamp": "2026-01-13T13:13:44.632+00:00",
    "schema": "public",
    "table": "user_profiles",
    "type": "UPDATE",
    "status": null,
    "response": null,
    "joins": null,
    "leaves": null,
    "channel": null,
    "extension": null,
    "message": null
  }
}

[kallebysantos]

Hey @Chetan-Akre 💚
May you share a reproducible code example? As well your .net version specs

[Chetan-Akre]

here's the example code:

// Subscribe to real-time changes on user_profiles table using filter
var channel = client.Realtime.Channel("public:user_profiles:" + userIdInput);

// Register the table for postgres changes
var changesOptions = new PostgresChangesOptions(
    "public", 
    "user_profiles", 
    PostgresChangesOptions.ListenType.All, 
    $"user_id=eq.{userIdInput}");

channel.Register(changesOptions);

// Listen to all event types
channel.AddPostgresChangeHandler(PostgresChangesOptions.ListenType.All, (sender, change) =>
{
    try
    {
        Console.WriteLine($"[{change.Event}] {DateTime.Now:HH:mm:ss.fff}");
        
        // Unified handling for all events
        var profile = change.Model<UserProfile>() ?? change.OldModel<UserProfile>();

        if (profile != null)
        {
            Console.WriteLine("Mapped UserProfile:");
            Console.WriteLine(profile.ToString());
        }
        else
        {
             // Fallback logging if deserialization fails
             Console.WriteLine("No record data found");
             if (change.Payload != null)
             {
                 var json = JsonConvert.SerializeObject(change.Payload);
                 Console.WriteLine($"Raw Payload: {json}");
             }
        }
        
        Console.WriteLine();
    }
    catch (Exception ex)
    {
        Console.WriteLine($"Error handling change: {ex.Message}");
        Console.WriteLine(ex.StackTrace);
    }
});

await channel.Subscribe();

await Task.Delay(Timeout.Infinite);

[kallebysantos]

I believe that something is wrong with you filter or maybe your RLS policies — double check if the current user was permission to check or if your filter is correctly

Everything worked fine from my side:

Example

my table schema:

create table items (
  id bigint generated by default as identity primary key,
  name text,
  description text
);

-- Turn on security
alter table "items" enable row level security;

-- Allow anonymous access
create policy "Allow anonymous access"
on items for select
to anon using (true);

alter publication supabase_realtime add table items;

JS code:

import { createClient } from "npm:@supabase/supabase-js";

const supabase = createClient(
  "http://127.0.0.1:54321",
  "sb_publishable_ACJWlzQHlZjBrEguHvfOxg_3BJgxAaH",
);

const channelA = supabase
  .channel("schema-db-changes")
  .on(
    "postgres_changes",
    {
      event: "*",
      schema: "public",
    },
    (payload) => console.log(payload),
  )
  .subscribe();

C# code:

#:package Supabase@1.1.1

using System;
using System.Text.Json;

using Supabase;
using Supabase.Postgrest.Attributes;
using Supabase.Realtime.PostgresChanges;

var options = new Supabase.SupabaseOptions
{
  AutoRefreshToken = true,
  AutoConnectRealtime = true
};

var supabase = new Supabase.Client("http://127.0.0.1:54321", "sb_publishable_ACJWlzQHlZjBrEguHvfOxg_3BJgxAaH", options);
await supabase.InitializeAsync();

var itemId = 15;

// Subscribe to real-time changes on items table using filter
var channel = supabase.Realtime.Channel("public:items:" + itemId);

// Register the table for postgres changes
var changesOptions = new PostgresChangesOptions(
    "public",
    "items",
    PostgresChangesOptions.ListenType.All,
    $"id=eq.{itemId}");

channel.Register(changesOptions);

// Listen to all event types
channel.AddPostgresChangeHandler(PostgresChangesOptions.ListenType.All, (sender, change) =>
{
  try
  {
    Console.WriteLine($"[{change.Event}] {DateTime.Now:HH:mm:ss.fff}");

    // Unified handling for all events
    var item = change.Model<Items>() ?? change.OldModel<Items>();

    if (item != null)
    {
      Console.WriteLine($"TableName: {item.TableName}");
      Console.WriteLine($"Item: {item.Id} - {item.Name} | {item.Description}"); // <- Its working
    }
    else
    {
      // Fallback logging if deserialization fails
      Console.WriteLine("No record data found");
      if (change.Payload != null)
      {
        var json = JsonSerializer.Serialize(change.Payload);
        Console.WriteLine($"Raw Payload: {json}");
      }
    }

    Console.WriteLine();
  }
  catch (Exception ex)
  {
    Console.WriteLine($"Error handling change: {ex.Message}");
    Console.WriteLine(ex.StackTrace);
  }
});

await channel.Subscribe();

Console.WriteLine($"Awaiting for database changes on item: {itemId}");
await Task.Delay(Timeout.Infinite);

[Table("items")]
public class Items : Supabase.Postgrest.Models.BaseModel
{
  [PrimaryKey("id")]
  public int Id { get; set; }
  [Column("name")]
  public string? Name { get; set; }
  [Column("description")]
  public string? Description { get; set; }
}

Result:

Screen.Recording.2026-01-14.at.19.05.37.mov

[Chetan-Akre]

it's working, there was some issue with how i was passing the id also the filter logic, thank you