harlesbayu

const RedisSMQ = require('rsmq');
const config = require('../../../config');

const rsmq = new RedisSMQ({
  url: config.get('REDIS_URL'),
  ns: 'rsmq'
});

const controllerCreateQueue = (req, res) => {
  try {

harlesbayu

/* eslint-disable no-console */
const RSMQWorker = require('rsmq-worker');
const RedisSMQ = require('rsmq');

const { uploadMultipartVideo } = require('../libs/multipart_upload');
const config = require('../../config');

const rsmq = new RedisSMQ({
  url: config.get('REDIS_URL'),
  ns: 'rsmq'

harlesbayu

const AWS = require('aws-sdk');

const config = require('../../config');

const spacesEndpoint = new AWS.Endpoint(config.get('SPACE_ENDPOINT'));
const s3bucket = new AWS.S3({
  endpoint: spacesEndpoint,
  accessKeyId: config.get('ACCESS_KEY_ID'),
  secretAccessKey: config.get('SECRET_ACCESS_KEY')
});

harlesbayu

/* global Helpers HttpStatus */
const AWS = require('aws-sdk');
const Busboy = require('busboy');
const firebaseAdmin = require('firebase-admin')
const moment = require('moment');
const config = require('../../../config');

const s3 = new AWS.S3({
  accessKeyId: config.get('AWS_CREDENTIAL').ACCESS_KEY_ID,
  secretAccessKey: config.get('AWS_CREDENTIAL').SECRET_ACCESS_KEY