method onCreated

Source

@override
onCreated() {
  var p = new Path(path);
  db = _link[p.parentPath];
  _watchName = configs[r"$name"];

  if (_watchName == null) {
    _watchName = NodeNamer.decodeName(p.name);
  }

  _link.addNode("${path}/addWatchPath", {
    r"$name": "Add Watch Path",
    r"$invokable": "write",
    r"$is": "addWatchPath",
    r"$params": [
      {
        "name": "Path",
        "type": "string"
      }
    ]
  });

  _link.addNode("${path}/publish", {
    r"$name": "Publish",
    r"$invokable": "write",
    r"$is": "publishValue",
    r"$params": [
      {
        "name": "Path",
        "type": "string"
      },
      {
        "name": "Value",
        "type": "dynamic"
      },
      {
        "name": "Timestamp",
        "type": "string"
      }
    ]
  });

  _link.addNode("${path}/delete", {
    r"$name": "Delete",
    r"$invokable": "write",
    r"$is": "delete"
  });

  _link.addNode("${path}/purge", {
    r"$name": "Purge",
    r"$invokable": "write",
    r"$params": [
      {
        "name": "timeRange",
        "type": "string",
        "editor": "daterange"
      }
    ],
    r"$is": "purgeGroup"
  });

  new Future(() async {
    if (db.database == null) {
      Completer c = new Completer();
      db.onDatabaseReady.add(c.complete);
      await c.future;
    }

    db.database.addWatchGroupExtensions(this);
  });
}