repositories.cypher

// load repositories
UNWIND ["repositories_000001.json", "repositories_000002.json"] AS file
CALL apoc.load.json($baseURL + file) YIELD value 
// only import public repos
WITH value AS repo WHERE repo.private = false
MERGE (r:Repository {url: repo.url})
SET r += repo {.name, .description, .website, created_at: DateTime(repo.created_at)}

MERGE (u:User {url: repo.owner})
MERGE (r)<-[:OWNS]-(u)

FOREACH (collab IN repo.collaborators | 
    MERGE (c:User {url: collab.user})
    MERGE (c)-[cr:COLLABORATES]->(r)
    SET cr.permission = collab.permission
)

FOREACH (webhook IN repo.webhooks | 
    MERGE (w:Webhook {url: webhook.payload_url})
    MERGE (r)-[:HAS_WEBHOOK]->(w)
);