First commit

Author: Alfonso Garcia

.gitignore

@@ -0,0 +1,71 @@
+
+# Created by https://www.gitignore.io/api/node
+
+### Node ###
+# Logs
+logs
+*.log
+npm-debug.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules
+jspm_packages
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+###################################
+
+# Visual Studio 2015 cache/options directory
+
+bower_components/
+node_modules/
+
+
+#Exclude tsc generated files
+out/
+
+
+# Elastic Beanstalk Files
+
+.elasticbeanstalk/*
+
+!.elasticbeanstalk/*.cfg.yml
+
+!.elasticbeanstalk/*.global.yml
+
+# Visual Studio Code Settings
+.vscode/

adapters/dynamo-adapter.ts

@@ -0,0 +1,53 @@
+let DynamoDB = require('aws-sdk/clients/dynamodb')
+
+let docClient = new DynamoDB.DocumentClient({ endpoint: "http://localhost:8000/", region: "us-west-2" })
+
+export function getItem (table_name: string, id: string) {
+
+}
+
+export function getItems (table_name: string, ids?: Array<Object>) {
+    // IMPORTANT: scan operation is limited to 1MB of data
+    let params = {
+        TableName: table_name
+    }
+   /* try {
+      let res = await docClient.scan(params).promise()
+      return res.Items
+    }
+    catch(err) {
+      return err
+    }*/
+  
+      /*.then((res: any) => {
+        console.log('promise resolved')
+        return Promise.resolve(res.Items)
+      }, (err: Error) => {
+        console.log('promise rejected')
+        return Promise.reject(err)
+      })*/
+
+      return docClient.scan(params).promise()
+              .then((res: any) => {
+                return res.Items
+              }, (err: Error) => {
+                return Promise.reject(err)
+              })
+}
+
+export function putItem (table_name: string, item: Object) {
+  
+}
+
+export function putItems (table_name: string, items: Array<Object>) {
+
+}
+
+export function deleteItem (table_name: string, id: string) {
+
+}
+
+export function deleteItems (table_name: string, ids: Array<string>) {
+
+}
+

data-collector.ts

@@ -0,0 +1,77 @@
+import * as _ from 'lodash'
+import {getItems} from './adapters/dynamo-adapter'
+
+let promises = {}
+let error: string
+let solution: any
+
+export default {
+    // tables: {},
+    table: function (name: string) {
+        // console.log(this)
+        /*try {
+            this.tables.name = await getItems(name)
+        } catch (err) {
+            console.log(err)
+        }*/
+        
+       /* getItems(name)
+        .then((res: Array<Object>) => {
+            console.log(tables)
+            tables[name] = res
+            console.log(tables)
+        }, (err: Error) => {
+            console.log(err)
+        })*/
+    
+        // promises.push(getItems(name))
+
+        promises[name] = getItems(name)
+        
+        console.log(promises)
+        return this
+    },
+    join: function () {
+        console.log('join the first 2 tables ' + promises)
+        if(_.size(promises) < 2)
+            error = 'Not enough tables'
+        else {
+            solution = Promise.all(_.values(promises))
+                    .then((res: Array<Object>) => {
+                        return (_.reduce(res, (result, value) => {
+                            if(_.size(result) < 2)
+                                result.push(value)
+                            return result
+                        }, []))
+                    }, (err: Error) => {
+                        return Promise.reject(err)
+                    })
+        }
+        return this
+    },
+    then: function (result, reject) {
+        let promise: Promise<string | Array<Object>>
+        if(error) {
+            if(reject) {
+                promise = reject(error)
+            }
+            else {
+                promise = Promise.reject(error)
+            }      
+        }
+        else {
+            if(result) {
+                promise = solution
+                    .then((res: any) => {
+                        return result(res)
+                    })
+            }
+            else {
+                promise = result
+            }
+        }
+        error = undefined
+        solution = undefined
+        return promise
+    }
+}

index.ts

@@ -0,0 +1,24 @@
+
+import db from './data-collector'
+
+db.table('Music')
+    /*.then((res: any) => {
+        return res.join()
+    }, (err: Error) => {
+        console.log(err)
+    })
+    .then((res: any) => {
+        console.log
+    }, (err: Error) => {
+        console.log(err)
+    })*/
+    .table('Configurations')
+    .join()
+    .then((res: Array<Object>) => {
+        console.log(res)
+    }, (err: Error) => {
+        console.log(err)
+    })
+
+
+    

mocha.opts

@@ -0,0 +1,4 @@
+--require ts-node/register
+--reporter dot
+--watch-extensions tsx,ts
+test/**/*.ts

package.json

@@ -0,0 +1,23 @@
+{
+  "name": "data-collector",
+  "version": "1.0.0",
+  "main": "index.js",
+  "scripts": {
+    "build": "tsc",
+    "test": "mocha --opts mocha.opts",
+    "test:auto": "mocha --opts mocha.opts --watch"
+  },
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "@types/chai": "^3.4.35",
+    "@types/lodash": "^4.14.53",
+    "@types/mocha": "^2.2.39",
+    "@types/node": "^7.0.5",
+    "aws-sdk": "^2.12.0",
+    "chai": "^3.5.0"
+  },
+  "dependencies": {
+    "lodash": "^4.17.4"
+  }
+}

test/main.ts

@@ -0,0 +1,9 @@
+
+import { expect } from 'chai'
+import db from '../data-collector'
+
+describe('table', () => {
+     it('Should return an array', () => {
+     })
+})
+

tsconfig.json

@@ -0,0 +1,26 @@
+{
+    "compilerOptions": {
+        "outDir": "out",
+        "target": "es6",
+        "module": "commonjs",
+        "noEmitOnError": true,
+        "noImplicitAny": true,
+        "strictNullChecks": true,
+        "experimentalDecorators": true,
+        "removeComments": true,
+        "preserveConstEnums": true,
+        "sourceMap": true,
+        "typeRoots": [
+            "node_modules/@types"
+        ]
+    },
+    "include": [
+        "src/**/*",
+        "test/**/*"
+    ],
+    "exclude": [
+        "out",
+        "node_modules",
+        "**/*.spec.ts"
+    ]
+}