vuongngo

package main

import (
	"net/http"
	"os"

	"app/api"
	"app/db"
	"app/repo"
	"app/worker"

vuongngo

package workers

import (
	"app/repo"
	"app/ws"

	"github.com/bitly/go-nsq"
)

/*

vuongngo

package repo

import (
	"gopkg.in/mgo.v2"

	"app/db"
	"app/model"
)

/**

vuongngo

package db

import (
	"errors"

	"gopkg.in/mgo.v2"
)

/*
Mongo construction

vuongngo

package model

import (
	"net/http"
	"time"

	"github.com/mholt/binding"
	"gopkg.in/mgo.v2/bson"
)

vuongngo

import React, { Component } from 'react';
import HighCharts from 'highcharts';

export default class Chart extends Component {
  componentDidMount() {
    if (this.props.modules) {
      this.props.modules.forEach(module => {
        module(HighCharts);
      });
    }

vuongngo

function (user, context, callback) {
  var namespace = 'your_domain';
  context.idToken[namespace + 'app_metadata'] = user.app_metadata;
  context.idToken[namespace + 'user_metadata'] = user.user_metadata;
  callback(null, user, context);
}

vuongngo

import mqtt from 'mqtt';

export function mqclient(options) {
  return new Promise((resolve, reject) => {
    fetch('https://your-lambda-endpoint', {
      method: 'get'
    }).then((response) => {
      const client = mqtt.connect(response.body.url, options);
      resolve(client);
    }).catch(err => reject(err));

vuongngo

'use strict';

const v4 = require('aws-signature-v4');
const crypto = require('crypto');

exports.handler = (event, context, callback) => {
  const url = v4.createPresignedURL(
    'GET',
    process.env.IOT_ENDPOINT_HOST.toLowerCase(),
    '/mqtt',

vuongngo

var awsIot = require('aws-iot-device-sdk');

var device = awsIot.device({
  keyPath: "./private.key",
  certPath: "./cert.pem",
  caPath: "./root-CA.crt",
  clientId: "name-of-thing",
  host: "https-endpoint",
});