feat: terms and conditions plugin

tradle · Dec 24, 2017 · 5f27c09 · 5f27c09
1 parent 9e48754
commit 5f27c09
Show file tree

Hide file tree

Showing 25 changed files with 302 additions and 44 deletions.
diff --git a/lib/cacheable-bucket-item.js b/lib/cacheable-bucket-item.js
diff --git a/lib/delivery-http.js b/lib/delivery-http.js
diff --git a/lib/s3-utils.js b/lib/s3-utils.js
diff --git a/lib/samplebot/configure.js b/lib/samplebot/configure.js
diff --git a/lib/samplebot/customize.js b/lib/samplebot/customize.js
diff --git a/lib/samplebot/lambda/http/inbox.js b/lib/samplebot/lambda/http/inbox.js
diff --git a/lib/samplebot/lambda/http/onfido-webhook.js b/lib/samplebot/lambda/http/onfido-webhook.js
diff --git a/lib/samplebot/lambda/mqtt/onmessage.js b/lib/samplebot/lambda/mqtt/onmessage.js
diff --git a/lib/samplebot/lambda/onmessagestream.js b/lib/samplebot/lambda/onmessagestream.js
diff --git a/lib/samplebot/strategy/index.js b/lib/samplebot/strategy/index.js
diff --git a/lib/samplebot/strategy/ts-and-cs.js b/lib/samplebot/strategy/ts-and-cs.js
diff --git a/src/cacheable-bucket-item.ts b/src/cacheable-bucket-item.ts
@@ -1,24 +1,36 @@
-
+import { omit } from 'lodash'
 import { Bucket } from './bucket'
+import { DatedValue } from './types'
 
 const identity = a => a
 
 export class CacheableBucketItem {
   private value: any
   private parse: Function
+  private lastModified?: number
   constructor(opts: {
     bucket:Bucket,
     key:string,
     ttl?: number
     parse?: Function
   }) {
-    this.value = opts.bucket.getCacheable(opts)
-    this.parse = identity
+    this.value = opts.bucket.getCacheable(omit(opts, ['parse']))
+    this.parse = opts.parse || identity
+    this.lastModified = null
+  }
+
+  public getDatedValue = async ():Promise<DatedValue> => {
+    const value = await this.get()
+    return {
+      value,
+      lastModified: this.lastModified
+    }
   }
 
-  public get = async (opts?) => {
-    const value = await this.value.get(opts)
-    return this.parse(value)
+  public get = async (opts?):Promise<any> => {
+    const { Body, LastModified } = await this.value.get(opts)
+    this.lastModified = new Date(LastModified).getTime()
+    return this.parse(Body)
   }
 
   public put = async (value:any, opts={}) => {

diff --git a/src/delivery-http.ts b/src/delivery-http.ts
@@ -9,7 +9,7 @@ import Env from './env'
 import Errors = require('./errors')
 
 const zlib = promisify(_zlib)
-const COMPRESSION_THRESHOLD = 2000
+const COMPRESSION_THRESHOLD = 0//2000
 const FETCH_TIMEOUT = 10000
 
 export default class Delivery extends EventEmitter implements IDelivery {

diff --git a/src/s3-utils.ts b/src/s3-utils.ts
@@ -114,6 +114,7 @@ export = function createUtils ({ s3, logger }) {
   }) => {
     if (!key) throw new Error('expected "key"')
     if (!bucket) throw new Error('expected "bucket"')
+    if (!ttl) throw new Error('expected "ttl"')
 
     let cached
     let type