@@ -182,7 +182,7 @@ $.getJSON("/api/db-dump?legacy=true", function(db_dump){
182
182
callback ( { "id" : thePicoInp . id , "eci" : thePicoInp . admin_eci , "channel" : theChannels } ) ;
183
183
} else if ( label == "Subscriptions" ) {
184
184
var theSubscriptions = { } ;
185
- var subscriptions = get ( db_dump . pico , [ thePicoInp . id , "io.picolabs.subscription" , "vars" , "subscriptions " ] ) ;
185
+ var subscriptions = get ( db_dump . pico , [ thePicoInp . id , "io.picolabs.subscription" , "vars" , "established " ] ) ;
186
186
if ( subscriptions ) {
187
187
Object . keys ( subscriptions ) . forEach ( function ( id ) {
188
188
theSubscriptions [ id ] = JSON . stringify ( subscriptions [ id ] , undefined , 2 ) ;
@@ -481,12 +481,11 @@ $.getJSON("/api/db-dump?legacy=true", function(db_dump){
481
481
var limitI = Math . min ( i , 45 ) ;
482
482
walkPico ( cp , dNumber * 10 + i + 1 , left + ( limitI * 10 ) + 20 , top + 20 ) ;
483
483
}
484
- var subscriptions = get ( db_dump . pico , [ pico . id , "io.picolabs.subscription" , "vars" , "subscriptions " ] ) ;
484
+ var subscriptions = get ( db_dump . pico , [ pico . id , "io.picolabs.subscription" , "vars" , "established " ] ) ;
485
485
if ( subscriptions ) {
486
486
for ( var k in subscriptions ) {
487
- var subs_status = get ( subscriptions , [ k , "attributes" , "status" ] ) ;
488
- var subs_eci = get ( subscriptions , [ k , "attributes" , "subscriber_eci" ] ) ;
489
- if ( subs_status && subs_status === "subscribed" && subs_eci ) {
487
+ var subs_eci = get ( subscriptions , [ k , "Tx" ] ) ;
488
+ if ( subs_eci ) {
490
489
var subs_id = get ( db_dump . channel , [ subs_eci , "pico_id" ] ) ;
491
490
if ( subs_id ) {
492
491
db_graph . chans . push ( { class : pico . id + "-origin " + subs_id + "-target subscription" } ) ;
0 commit comments