Skip to content

Instantly share code, notes, and snippets.

jongleberry jonathanong

Block or report user

Report or block jonathanong

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
View README.md

TODO:

  • Add retries
  • Add timeouts
  • Keep the chunks buffer as small as possible instead of storing the whole thing in memory
  • Degrade gracefully - if it fails, return false
View test.ts
import { client, server } from '../grpc-test-helpers'
const address = `localhost:5000` // this port needs to be randomized in each test and make sure it's not already being used. not sure how to do that with grpc yet.
server.bind(address, grpc.ServerCredentials.createInsecure())
server.start()
View tracking-server.js
const createBulkWriteStream = require('bulk-insert')
const moment = require('moment')
const AWS = require('aws-sdk')
const { v4 } = require('uuid')
const http = require('http')
const url = require('url')
const GIF = new Buffer(`R0lGODlhAQABAAAAACH5BAEAAAAALAAAAAABAAEAAAI=`, `base64`)
const stream = new AWS.Firehose()
const DeliveryStreamName = 'some-delivery-stream-name'
You can’t perform that action at this time.