Skip to content

Instantly share code, notes, and snippets.

View alifrizkip's full-sized avatar
😎
Selo

Alif Rizki Pambudi alifrizkip

😎
Selo
View GitHub Profile
@alifrizkip
alifrizkip / index-secure-ls-persistedstate.js
Created August 22, 2020 13:53
index-secure-ls-persistedstate.js
import Vue from 'vue';
import Vuex from 'vuex';
import createPersistedState from 'vuex-persistedstate';
import SecureLS from "secure-ls";
import cart from './modules/cart';
Vue.use(Vuex);
const secureLS = new SecureLS({
@alifrizkip
alifrizkip / index-cookies-persistedstate.js
Created August 22, 2020 13:23
index-cookies-persistedstate.js
import Vue from 'vue';
import Vuex from 'vuex';
import createPersistedState from 'vuex-persistedstate';
import Cookies from 'js-cookie';
import cart from './modules/cart';
Vue.use(Vuex);
const cartState = createPersistedState({
@alifrizkip
alifrizkip / index-localstorage-persistedstate.js
Created August 22, 2020 04:54
src/store/index-localstorage-persistedstate.js
import Vue from 'vue';
import Vuex from 'vuex';
import createPersistedState from 'vuex-persistedstate';
import cart from './modules/cart';
Vue.use(Vuex);
const cartState = createPersistedState({
key: 'cart-persist-state',
@alifrizkip
alifrizkip / sortCommentWithTest.js
Created November 12, 2018 17:45
sortCommentWithTest.js
const axios = require('axios');
const readline = require('readline-sync');
class AppClass {
constructor(data) {
this.data = [...data];
this.pageNumber = 1;
this.pageSize = 10;
this.tempData = [];
this.isSearch = false;
@alifrizkip
alifrizkip / app.js
Last active August 31, 2018 03:40
app.js for medium article 'Error Handler di ExpressJS'
const express = require('express');
const axios = require('axios');
const router = express.Router();
const app = express();
// Router for /status
router.get('/status',
(req, res) => {
res.json({
@alifrizkip
alifrizkip / workerConsumer.js
Last active April 11, 2018 03:01
Work Queue workerConsumer.js RabbitMQ
const amqp = require('amqplib/callback_api') // Import library amqplib
amqp.connect('amqp://localhost', (err, conn) => {
conn.createChannel((err, ch) => {
const q = 'task_queue' // Nama antrian adalah 'task_queue'
ch.assertQueue(q, { durable: true }) // Menyatakan antriannya adalah 'task_queue'
ch.prefetch(1)
console.log(`[*] Waiting for messages in %s. To exit press CTRL+C`, q)
/* Menangkap pesan yang dikirimkan RabbitMQ dari antrian */
@alifrizkip
alifrizkip / taskProducer.js
Last active April 11, 2018 02:42
Work Queue taskProducer.js RabbitMQ
const amqp = require('amqplib/callback_api') // import library amqplib
amqp.connect('amqp://localhost', (err, conn) => {
conn.createChannel((err, ch) => {
const q = 'task_queue' // Nama antrian adalah 'task_queue'
const msg = process.argv.slice(2).join(' ') || 'Hello World!'
ch.assertQueue(q, { durable: true }) // Membuat antrian 'task_queue'
ch.sendToQueue(q, new Buffer(msg), { persistent: true }) // Mengirim pesan tugas ke antrian
console.log(`[x] Sent '%s'`, msg)
@alifrizkip
alifrizkip / consumer.js
Last active April 11, 2018 07:10
RabbitMQ consumer.js
const amqp = require('amqplib') // Import library amqp
amqp.connect('amqp://localhost')
.then(conn=> {
return conn.createChannel().then(ch => {
const ok = ch.assertQueue('hello', { durable: false }) // Deklarasi antrian
ok.then(() => {
/* Menangkap pesan yang dikirimkan oleh RabbitMQ */
return ch.consume('hello', msg => console.log('- Received', msg.content.toString()), { noAck: true })
})
@alifrizkip
alifrizkip / producer.js
Last active April 11, 2018 07:04
producer.js RabbitMQ
const amqp = require('amqplib') // Import library amqp
amqp.connect('amqp://localhost')
.then(conn => {
return conn.createChannel().then(ch => {
const q = 'hello' // Nama antrian adalah 'hello'
const msg = 'Hello world!' // Isi pesan yang dikirim ke RabbitMQ
const ok = ch.assertQueue(q, { durable: false }) // Membuat antrian 'hello'
return ok.then(() => {
const csv = require('csvjson')
const knex = require('./knex')
const fs = require('fs')
const file = fs.readFileSync('data.csv', 'utf8')
const dataObj = csv.toObject(file)
knex.insert(dataObj)
.into('employees')
.then(() => {