_id: 52a80e9beb8c714c6ea56de6
actions:
  requireConnectRunTableListDb:
    nodes:
      - 52a815feb824140000694e46
      - 52a80e9bfff7bcff27000004
      - 52a80e9bfff7bcff27000007
      - 52a80e9bfff7bcff27000006
      - 52a80e9bfff7bcff27000005
    title: requireConnectRunTableListDb
    description: ""
  requireConnectRunInsertTableDb:
    nodes:
      - 52a815feb824140000694e46
      - 52a80e9bfff7bcff27000004
      - 52a80e9bfff7bcff27000007
      - 52a8184a92897c0000a43675
      - 52a8188392897c0000a43676
      - 52a80e9bfff7bcff27000005
    title: requireConnectRunInsertTableDb
    description: ""
  runUpdateGetTableDbConnectRequire:
    nodes:
      - 52a80e9bfff7bcff27000007
      - 52a81afa65207500003e42b8
      - 52a81a0de7bcd200004af4a9
      - 52a8188392897c0000a43676
      - 52a80e9bfff7bcff27000005
      - 52a80e9bfff7bcff27000004
      - 52a815feb824140000694e46
    title: runUpdateGetTableDbConnectRequire
    description: ""
  connectRequireDbTableGetDeleteRun:
    nodes:
      - 52a80e9bfff7bcff27000004
      - 52a815feb824140000694e46
      - 52a80e9bfff7bcff27000005
      - 52a8188392897c0000a43676
      - 52a81a0de7bcd200004af4a9
      - 52a81f6f65207500003e42be
      - 52a80e9bfff7bcff27000007
    title: connectRequireDbTableGetDeleteRun
    description: ""
description: ""
env: server
keywords: []
type: flow
links:
  -
    id: 52a80f2e705e410000b3abae
    source: 52a80e9bfff7bcff27000004
    target: 52a80e9bfff7bcff27000007
    settings: {  }
    out: conn
    in: conn
  -
    id: 52a8147c54409a0000c556f3
    source: 52a80e9bfff7bcff27000006
    target: 52a80e9bfff7bcff27000007
    settings:
      hold: true
    out: query
    in: query
  -
    id: 52a81514b824140000694e44
    source: 52a80e9bfff7bcff27000005
    target: 52a80e9bfff7bcff27000006
    settings: {  }
    out: db
    in: db
  -
    id: 52a81603b824140000694e47
    source: 52a815feb824140000694e46
    target: 52a80e9bfff7bcff27000005
    settings: {  }
    out: rethinkdb
    in: rethinkdb
  -
    id: 52a816d2f4c1b90000ac39c1
    source: 52a815feb824140000694e46
    target: 52a80e9bfff7bcff27000004
    settings: {  }
    out: rethinkdb
    in: rethinkdb
  -
    id: 52a8173ff4c1b90000ac39c4
    source: 52a80e9bfff7bcff27000007
    target: 52a81736f4c1b90000ac39c3
    settings: {  }
    out: result
    in: msg
  -
    id: 52a81744f4c1b90000ac39c5
    source: 52a80e9bfff7bcff27000007
    target: 52a81736f4c1b90000ac39c3
    settings: {  }
    out: error
    in: msg
  -
    id: 52a8189192897c0000a43677
    source: 52a80e9bfff7bcff27000005
    target: 52a8188392897c0000a43676
    settings: {  }
    out: db
    in: db
  -
    id: 52a818ef92897c0000a43678
    source: 52a8188392897c0000a43676
    target: 52a8184a92897c0000a43675
    settings: {  }
    out: query
    in: table
  -
    id: 52a8194a92897c0000a43679
    source: 52a8184a92897c0000a43675
    target: 52a80e9bfff7bcff27000007
    settings: {  }
    out: query
    in: query
  -
    id: 52a81a3fe7bcd200004af4aa
    source: 52a8188392897c0000a43676
    target: 52a81a0de7bcd200004af4a9
    settings: {  }
    out: query
    in: table
  -
    id: 52a81a5ae7bcd200004af4ab
    source: 52a81a0de7bcd200004af4a9
    target: 52a80e9bfff7bcff27000007
    settings: {  }
    out: query
    in: query
  -
    id: 52a81b3065207500003e42b9
    source: 52a81a0de7bcd200004af4a9
    target: 52a81afa65207500003e42b8
    settings: {  }
    out: query
    in: query
  -
    id: 52a81f7b65207500003e42bf
    source: 52a81a0de7bcd200004af4a9
    target: 52a81f6f65207500003e42be
    settings: {  }
    out: query
    in: query
  -
    id: 52a824328084bc00002d5c73
    source: 52a81afa65207500003e42b8
    target: 52a80e9bfff7bcff27000007
    settings: {  }
    out: query
    in: query
  -
    id: 52a8243d8084bc00002d5c74
    source: 52a81f6f65207500003e42be
    target: 52a80e9bfff7bcff27000007
    settings: {  }
    out: query
    in: query
nodeDefinitions:
  rethinkdb:
    connect:
      _id: 52a80290eb8c714c6ea56dd6
      description: 'RethinkDB connect'
      env: server
      fn: "output = [$.rethinkdb, 'connect', $.options]\n"
      name: connect
      ns: rethinkdb
      phrases:
        active: 'Creating rethink DB connection: {{input.host}}:{{input.port}}/{{input.db}}'
      ports:
        input:
          rethinkdb:
            type: function
            title: 'Rethink DB'
            description: RethinkDB
            required: true
          options:
            title: Options
            type: object
            properties:
              host:
                type: string
                title: Host
                description: 'the host to connect to'
                default: localhost
              port:
                type: string
                title: Port
                description: 'the port to connect on'
                default: '28015'
              db:
                type: string
                title: Database
                description: 'the default database to connect to'
                default: test
              authKey:
                type: string
                title: 'Authentication Key'
                description: 'the authentication key'
        output:
          error:
            type: object
            title: Error
          conn:
            type: function
            title: Connection
      require:
        rethinkdb: latest
      type: provider
    db:
      _id: 52a80290eb8c714c6ea56dda
      description: 'RethinkDB database'
      env: server
      fn: "output = { db: $.create($.rethinkdb.db($.dbName)) };\n"
      name: db
      ns: rethinkdb
      phrases:
        active: 'Selecting database {{input.db}}'
      ports:
        input:
          rethinkdb:
            type: function
            title: RethinkDB
            required: true
          dbName:
            type: string
            title: 'Database Name'
            description: 'Select a database'
        output:
          db:
            type: function
            title: Database
    tableList:
      _id: 52a80290eb8c714c6ea56dd7
      description: 'Table List'
      env: server
      fn: "output = { query: $.create($.db.tableList()) };\n"
      name: tableList
      ns: rethinkdb
      phrases:
        active: 'Getting tableList'
      ports:
        input:
          db:
            type: function
            title: Database
            required: true
        output:
          query:
            type: function
            title: query
    run:
      _id: 52a80290eb8c714c6ea56dd5
      description: 'RethinkDB run'
      env: server
      fn: "output = [$.query, 'run', $.conn]\n"
      name: run
      ns: rethinkdb
      phrases:
        active: running...
      ports:
        input:
          query:
            type: function
            title: 'RethinkDB query'
            required: true
          conn:
            type: function
            title: Connection
            required: true
          useOutdated:
            type: boolean
            title: 'Use Outdated'
            description: 'whether or not outdated reads are OK'
            default: true
          timeFormat:
            type: string
            title: 'Time Format'
            description: 'what format to return times in (default: `''native''`). Set this to `''raw''` if you want times returned as JSON objects for exporting.'
          profile:
            type: boolean
            title: Profile
            description: 'whether or not to return a profile of the query''s execution.'
            default: false
        output:
          error:
            type: object
            title: Error
          result:
            type: object
            title: Result
            description: 'A single JSON result, or a cursor, depending on the query'
            expose: true
    table:
      _id: 52a80292eb8c714c6ea56de2
      description: 'RethinkDB table'
      env: server
      fn: "output = { query: $.create($.db.table($.tableName, $.options)) };\n"
      name: table
      ns: rethinkdb
      phrases:
        active: 'Selecting table {{input.tableName}}'
      ports:
        input:
          db:
            type: function
            title: Database
            required: true
          tableName:
            type: string
            title: 'Table Name'
            description: 'Select all documents in a table. This command can be chained with other commands to do further processing on the data.'
          options:
            title: Options
            type: object
            properties:
              useOutdated:
                type: boolean
                title: 'Use Outdated'
                default: false
        output:
          query:
            type: function
            title: Query
    require:
      _id: 52a80d87eb8c714c6ea56de5
      description: 'RethinkDB require'
      env: server
      fn: "output = { rethinkdb: $.create(rethinkdb) }\n"
      name: require
      ns: rethinkdb
      phrases:
        active: 'Requiring RethinkDB'
      ports:
        input: {  }
        output:
          rethinkdb:
            type: function
            title: RethinkDB
      require:
        rethinkdb: latest
    insert:
      _id: 52a80292eb8c714c6ea56ddf
      description: 'Insert JSON documents into a table. Accepts a single JSON document or an array of documents.'
      env: server
      fn: "output = { query: $.create($.table.insert($.data)) };\n"
      name: insert
      ns: rethinkdb
      phrases:
        active: inserting
      ports:
        input:
          table:
            type: function
            title: Table
            required: true
          data:
            type: any
            title: 'JSON Document(s)'
            description: ""
        output:
          query:
            type: function
            title: Query
    get:
      _id: 52a80290eb8c714c6ea56dd8
      description: 'RethinkDB get'
      env: server
      fn: "output = { query: $.create($.table.get($.id)) };\n"
      name: get
      ns: rethinkdb
      phrases:
        active: 'Get {{input.id}}'
      ports:
        input:
          table:
            type: function
            title: Table
            required: true
          id:
            type: string
            title: ID
            description: 'Get a document by primary key'
        output:
          query:
            type: function
            title: Query
    update:
      _id: 52a80292eb8c714c6ea56ddb
      description: 'Update JSON documents in a table. Accepts a JSON document.'
      env: server
      fn: "output = { query: $.create($.query.update($.data)) };\n"
      name: update
      ns: rethinkdb
      phrases:
        active: 'Updating document'
      ports:
        input:
          query:
            type: function
            title: Table
            required: true
          data:
            type: any
            title: 'Document update'
            description: ""
        output:
          query:
            type: function
            title: Query
    delete:
      _id: 52a80290eb8c714c6ea56dd4
      description: 'delete document.'
      env: server
      fn: "output = { query: $.create($.query.delete()) };\n"
      name: delete
      ns: rethinkdb
      phrases:
        active: 'Deleting document'
      ports:
        input:
          query:
            type: function
            title: Query
            required: true
        output:
          query:
            type: function
            title: Query
  console:
    log:
      _id: 526dd2e4744e31bb6f000017
      description: 'Console log'
      fn: console.log($.msg)
      name: log
      ns: console
      phrases:
        active: 'Logging to console'
      ports:
        input:
          msg:
            type: any
            title: 'Log message'
            description: 'Logs a message to the console'
        output: {  }
  datashift:
    delete:
      _id: 529e47574dc9c28c2f7ddd5f
      description: Delete
      fn: "output = [$.consumer, 'on', 'delete']\n"
      name: delete
      ns: datashift
      phrases:
        active: 'Datashift Delete'
      ports:
        input:
          consumer:
            title: Consumer
            type: function
            required: 'true'
        output:
          data:
            type: object
      title: 'DataShift Delete'
nodes:
  -
    id: 52a80e9bfff7bcff27000004
    ns: rethinkdb
    name: connect
    context:
      options:
        host: localhost
        port: '28015'
        db: chix
  -
    id: 52a80e9bfff7bcff27000005
    ns: rethinkdb
    name: db
    context:
      dbName: chix
  -
    id: 52a80e9bfff7bcff27000006
    ns: rethinkdb
    name: tableList
    context: {  }
  -
    id: 52a80e9bfff7bcff27000007
    ns: rethinkdb
    name: run
    context:
      useOutdated: true
      timeFormat: raw
      profile: true
    ports:
      output:
        result:
          expose: true
  -
    id: 52a815feb824140000694e46
    ns: rethinkdb
    name: require
    context: {  }
  -
    id: 52a81736f4c1b90000ac39c3
    ns: console
    name: log
    context: {  }
  -
    id: 52a8184a92897c0000a43675
    ns: rethinkdb
    name: insert
    context: {  }
  -
    id: 52a8188392897c0000a43676
    ns: rethinkdb
    name: table
    context:
      tableName: nodes
      options:
        useOutdated: false
  -
    id: 52a81a0de7bcd200004af4a9
    ns: rethinkdb
    name: get
    context: {  }
  -
    id: 52a81afa65207500003e42b8
    ns: rethinkdb
    name: update
    context: {  }
  -
    id: 52a81f6f65207500003e42be
    ns: rethinkdb
    name: delete
    context: {  }
requireDbTableListRun:
  nodes:
    - 52a815feb824140000694e46
    - 52a80e9bfff7bcff27000005
    - 52a80e9bfff7bcff27000006
    - 52a80e9bfff7bcff27000007
  title: requireDbTableListRun
  description: ""
title: RethinkDB
id: X1386776338789