Method syncProperties

server/src/db/catalog-db.ts:400–421

(since: string, limit: number = 10000)

  }

  async syncProperties(since: string, limit: number = 10000): Promise<{
    entries: CatalogProperty[];
    server_timestamp: string;
    next_cursor: string | null;
  }> {
    const result = await query<CatalogProperty>(
      `SELECT * FROM catalog_properties
       WHERE updated_at > $1 AND classification = 'property' AND status = 'active'
       ORDER BY updated_at, property_rid
       LIMIT $2`,
      [since, limit]
    );

    const rows = result.rows;
    const nextCursor = rows.length === limit ? rows[rows.length - 1].property_rid : null;

    return {
      entries: rows,
      server_timestamp: new Date().toISOString(),
      next_cursor: nextCursor,
    };
  }

  async getPropertyActivity(propertyRid: string): Promise<{
    distinct_members: number;