chain and xybase build

Author: carterharrison

.vscode/settings.json

@@ -1,5 +1,6 @@
 {
   "typescript.tsdk": "node_modules/typescript/lib",
+  "tslint.autoFixOnSave": true,
   "psi-header.changes-tracking": {
     "isActive": true,
     "autoHeader": "manualSave"

bin/xyo-archivist

@@ -1,6 +1,6 @@
 {
   "name": "@xyo-network/sdk-diviner-nodejs",
-  "version": "0.2.62",
+  "version": "0.2.63",
   "description": "XYO Archivist SDK",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -22,11 +22,10 @@
     "pretest": "yarn install",
     "lint": "tslint --config tslint.json --project tsconfig.json",
     "test": "yarn lint",
-    "build": "tsc && yarn copy",
+    "build": "yarn xybuild && yarn copy",
     "copy": "copyfiles -u 1 src/**/*.sql dist/",
     "develop": "ts-node --files src/cli.ts",
-    "license": "yarn license-checker --onlyAllow 'MIT;BSD;BSD-2-Clause;BSD-3-Clause;Apache-2.0;ISC;Unlicense;UNKNOWN;BSD*;CC0-1.0' --excludePackages 'colors@0.6.2'",
-    "mock-data": "node packages/data-generator/dist/index.js --host=127.0.0.1 --user=admin --password=password --database=Xyo --port=3306"
+    "license": "yarn license-checker --onlyAllow 'MIT;BSD;BSD-2-Clause;BSD-3-Clause;Apache-2.0;ISC;Unlicense;UNKNOWN;BSD*;CC0-1.0' --excludePackages 'colors@0.6.2'"
   },
   "devDependencies": {
     "@types/ethereumjs-abi": "^0.6.3",
@@ -49,39 +48,15 @@
     "typescript": "^3.4.5"
   },
   "dependencies": {
-    "@xyo-network/base": "^0.55.9-alpha.0",
-    "@xyo-network/bound-witness": "^0.55.9-alpha.0",
-    "@xyo-network/errors": "^0.55.9-alpha.0",
-    "@xyo-network/hashing": "^0.55.9-alpha.0",
-    "@xyo-network/heuristics-common": "^0.55.9-alpha.0",
-    "@xyo-network/meta-list": "^0.55.9-alpha.0",
-    "@xyo-network/network": "^0.55.9-alpha.0",
-    "@xyo-network/network.tcp": "^0.55.9-alpha.0",
-    "@xyo-network/node-network": "^0.55.9-alpha.0",
-    "@xyo-network/origin-block-repository": "^0.55.9-alpha.0",
-    "@xyo-network/origin-chain": "^0.55.9-alpha.0",
-    "@xyo-network/p2p": "^0.55.9-alpha.0",
-    "@xyo-network/peer-connections": "^0.55.9-alpha.0",
-    "@xyo-network/peer-discovery": "^0.55.9-alpha.0",
-    "@xyo-network/peer-interaction": "^0.55.9-alpha.0",
-    "@xyo-network/peer-interaction-handlers": "^0.55.9-alpha.0",
-    "@xyo-network/peer-interaction-router": "^0.55.9-alpha.0",
-    "@xyo-network/serialization": "^0.55.9-alpha.0",
-    "@xyo-network/serialization-schema": "^0.55.9-alpha.0",
-    "@xyo-network/serializer": "^0.55.9-alpha.0",
-    "@xyo-network/signing": "^0.55.9-alpha.0",
-    "@xyo-network/signing.ecdsa": "^0.55.9-alpha.0",
-    "@xyo-network/storage": "^0.55.9-alpha.0",
-    "@xyo-network/storage.leveldb": "^0.60.2",
-    "@xyo-network/utils": "^0.55.9-alpha.0",
+    "@xyo-network/object-model": "^0.5.10",
+    "@xyo-network/sdk-base-nodejs": "^0.3.10",
+    "@xyo-network/sdk-core-nodejs": "^0.64.2",
     "abstract-leveldown": "^6.0.2",
     "apollo-cache-inmemory": "^1.5.1",
     "apollo-client": "^2.5.1",
     "apollo-link-http": "^1.5.14",
     "apollo-server": "^2.4.8",
     "aws-sdk": "^2.441.0",
-    "ethereumjs-abi": "^0.6.7",
-    "ethereumjs-tx": "^1.3.7",
     "graphql": "^14.2.1",
     "graphql-tag": "^2.10.1",
     "graphql-type-json": "^0.3.0",
@@ -90,10 +65,6 @@
     "levelup": "^4.0.1",
     "lodash": "^4.17.11",
     "lru-cache": "^5.1.1",
-    "mysql": "^2.17.1",
-    "web3": "^1.0.0-beta.52",
-    "web3-eth-contract": "^1.0.0-beta.52",
-    "web3-providers": "^1.0.0-beta.52",
     "yargs": "^13.2.2"
   }
 }

package.json

@@ -0,0 +1 @@
+export * from './xyo-chain-tracer'

src/block-producer/@types/index.ts

@@ -0,0 +1,4 @@
+
+export interface IXyoChainTracer {
+  traceChain(publicKey: Buffer, limit: number, offsetHash: Buffer | undefined, up: boolean): Promise<Buffer[]>
+}

src/block-producer/index.ts

@@ -0,0 +1,66 @@
+import { IXyoOriginBlockGetter, XyoBoundWitness, XyoBoundWitnessOriginGetter, IXyoBoundWitnessOrigin } from '@xyo-network/sdk-core-nodejs'
+
+export class XyoHashTracer {
+  private blockGetter: IXyoOriginBlockGetter
+
+  constructor (blockGetter: IXyoOriginBlockGetter) {
+    this.blockGetter = blockGetter
+  }
+
+  public async getBlocksDown (hash: Buffer, n: number, publicKey: Buffer): Promise<Buffer[]> {
+    let lookingPublicKeys = [publicKey]
+    let offset: Buffer = hash
+    const blocks: Buffer[] = []
+
+    while (blocks.length !== n) {
+      const block = await this.blockGetter.getOriginBlock(offset)
+
+      if (block) {
+        const newOffset = this.getBlockPreviousHash(lookingPublicKeys, block)
+
+        if (newOffset && newOffset.origin.previousHash) {
+          lookingPublicKeys = newOffset.publicKeys
+          offset = newOffset.origin.previousHash
+          blocks.push(block)
+        } else {
+            // if we are here, the chain is invalid, or we have hit the genesis block, so we break out
+          break
+        }
+
+      } else {
+        // stop looking for blocks if we have reached the end of the chain
+        break
+      }
+    }
+
+    return blocks
+  }
+
+  private getBlockPreviousHash (publicKeysOfParent: Buffer[], boundWitnessBytes: Buffer): {origin: IXyoBoundWitnessOrigin, publicKeys: Buffer[]} | undefined {
+    const boundWitness = new XyoBoundWitness(boundWitnessBytes)
+    const publicKeys = boundWitness.getPublicKeys()
+    const origins = XyoBoundWitnessOriginGetter.getOriginInformation(boundWitness)
+
+    // we look to see if the public keys match so that we can get the right previous hash
+    // tslint:disable-next-line:prefer-for-of
+    for (let i = 0; i < publicKeys.length; i++) {
+      const origin = origins[i]
+
+      for (const publicKeyLooking of publicKeysOfParent) {
+        for (const publicKey of publicKeys[i]) {
+
+          if (publicKeyLooking.equals(publicKey.getAll().getContentsCopy())) {
+            return { origin, publicKeys: publicKeys[i].map(pub => publicKey.getAll().getContentsCopy()) }
+          }
+
+          if (origin.nextPublicKey && origin.nextPublicKey.equals(publicKeyLooking)) {
+            return { origin, publicKeys: publicKeys[i].map(pub => publicKey.getAll().getContentsCopy()) }
+          }
+        }
+      }
+    }
+
+    return undefined
+
+  }
+}

src/block-producer/spec/xyo-block-producer.spec.ts

@@ -10,49 +10,4 @@
  * Copyright 2017 - 2019 XY - The Persistent Company
  */
 
-import { XyoNode } from './base-node'
-import { DEFAULT_NODE_OPTIONS_MYSQL, DEFAULT_NODE_OPTIONS_DYNAMODB, DEFAULT_NODE_OPTIONS } from './base-node/default-node-options'
-
-export { IXyoArchivistNetwork, XyoArchivistNetwork, CatalogueItem } from './network/'
-export { createArchivistDynamoDBRepository, IDynamoDBArchivistRepositoryConfig } from './repository/dynamodb'
-export { createArchivistLevelDBRepository, ILevelDBArchivistRepositoryConfig } from './repository/leveldb '
-export { createArchivistNeo4jRepository, INeo4jArchivistRepositoryConfig } from './repository/neo4j'
-export { createArchivistSqlRepository, ISqlArchivistRepositoryConfig } from './repository/sql'
-export {
-  IXyoArchivistRepository,
-  IXyoEntitiesList,
-  IXyoEntity,
-  IXyoEntityType,
-  IXyoOriginBlockResult,
-  IXyoOriginBlocksByPublicKeyResult,
-  IXyoIntersectionsList,
-  IArchivistRepositoryConfig
-} from './repository'
-export { IXyoComponentArchivistFeatureDetail } from './@types'
-export { XyoNode } from './base-node'
-
-// function to launch for testing.  Should never be used in production
-async function main() {
-  let node
-  const db = process.argv.length > 2 ? process.argv[2] : 'unknown'
-  switch (db) {
-    case 'mysql': {
-      node = new XyoNode(DEFAULT_NODE_OPTIONS_MYSQL)
-      break
-    }
-    case 'dynamodb': {
-      node = new XyoNode(DEFAULT_NODE_OPTIONS_DYNAMODB)
-      break
-    }
-    default: {
-      node = new XyoNode(DEFAULT_NODE_OPTIONS)
-      break
-    }
-  }
-  await node.initialize()
-  await node.start()
-}
-
-if (require.main === module) {
-  main()
-}
+console.log('hello world')