BlueSky User Interactions Neo4j Import, data collection courtesy https://bsky.jazco.dev/

bsky_jazco_import.cypher

create constraint user_key if not exists for (u:User) require (u.key) is unique;

// add nodes
call apoc.load.json("https://bsky.jazco.dev/exported_graph_minified.json","$.nodes") 
yield value as nv
call { with nv
   merge (n:User {key:nv.key}) 
   on create set n += apoc.map.clean(nv.attributes,["key"],[])
} in transactions of 10000 rows;

// add relationships
call apoc.load.json("https://bsky.jazco.dev/exported_graph_minified.json","$.edges") yield value as ev
call { with ev
    match (source:User {key:ev.source}),(target:User {key:ev.target})
    merge (source)-[r:INTERACTED {key:ev.key}]-(target)
    set r += ev.attributes
} in transactions of 20000 rows;

// merge duplicate nodes
match (u:User)
with u.label as label, count(*) as count, collect(u) as users
where count > 1
call apoc.refactor.mergeNodes(users) yield node
return node;

create constraint user_label if not exists for (u:User) require (u.label) is unique;

/*
call apoc.load.json("https://bsky.jazco.dev/exported_graph_minified.json") yield value
return value.nodes[0], value.edges[0];
*/

// Load threads, like the hellthread:

call apoc.load.json("https://bsky-search.jazco.io/thread?authorHandle=pet.bun.how&postID=3juqpknhkxp2o&layout=true","$") yield value as entry
call { with entry 
   with entry, entry.post as post
   merge (p:Post {id:post.id})
   set 
     p += entry {.depth, .x, .y}, 
     p += post { .root_post_id, .has_embedded_media, created_at: datetime(post.created_at), .text}
   merge (parent:Post {id:post.parent_post_id})
   merge (p)-[:PARENT]->(parent)
   with *
   match (u:User { label: entry.author_handle})
   set u.did = post.author_did 
   merge (u)-[:POSTED]->(p)
} in transactions of 10000 rows;;

Example query:

match path = (u:User)-[:INTERACTED*2]-() 
where u.label = 'jaz.bsky.social' and all(r in relationships(path) where r.weight > 25)
return path limit 100