sorsaffari

function personTemplate(person) {
  const { first_name, last_name, phone_number, city, age } = person;
  
  // insert person
  let graqlInsertQuery = `insert $person isa person has phone-number "${phone_number}"`;
  const isNotCustomer = typeof first_name === "undefined";
  
  if (isNotCustomer) {
    // person is not a customer
    graqlInsertQuery += " has is-customer false";

sorsaffari

function contractTemplate(contract) {
  const { company_name, person_id } = contract;
  // match company
  let graqlInsertQuery = `match $company isa company has name "${company_name}"; `;
  // match person
  graqlInsertQuery += `$customer isa person has phone-number "${person_id}"; `;
  // insert contract
  graqlInsertQuery +=
    "insert (provider: $company, customer: $customer) isa contract;";
  return graqlInsertQuery;

sorsaffari

function callTemplate(call) {
  const { caller_id, callee_id, started_at, duration } = call;
  
  // match caller
  let graqlInsertQuery = `match $caller isa person has phone-number "${caller_id}"; `;
  
  // match callee
  graqlInsertQuery += `$callee isa person has phone-number "${callee_id}"; `;
  
  // insert call

sorsaffari

function parseDataToObjects(input) {
  const items = [];
  
  return new Promise(function(resolve, reject) {
    papa.parse(
      fs.createReadStream(input.dataPath + ".csv"),
      {
        header: true, // a Papaparse config option
        step: function(result, parser) {
          items.push(result.data[0]);

sorsaffari

function parseDataToObjects(input) {
  const items = [];
  return new Promise(function(resolve, reject) {
    const pipeline = chain([
      fs.createReadStream(input.dataPath + ".json"),
      parser(),
      streamArray()
    ]);

    pipeline.on("data", function(result) {

sorsaffari

function parseDataToObjects(input) {
  const items = [];
  return new Promise((resolve, reject) => {
    const pipeline = new xmlStream(
      fs.createReadStream(input.dataPath + ".xml")
    );
    
    pipeline.on(`endElement: ${input.selector}`, function(result) {
      items.push(result);
    });

sorsaffari

const Grakn = require("grakn");
const fs = require("fs");
...

sorsaffari

const Grakn = require("grakn");
const fs = require("fs");
const papa = require("papaparse");
...

sorsaffari

const Grakn = require("grakn");
const fs = require("fs");
const { parser } = require("stream-json");
const { streamArray } = require("stream-json/streamers/StreamArray");
const { chain } = require("stream-chain");
...

sorsaffari

const Grakn = require("grakn");
const fs = require("fs");
const xmlStream = require("xml-stream");
...