Skip to content

Instantly share code, notes, and snippets.

View puuble's full-sized avatar

marian ivanov puuble

  • full stack backend
  • Bulgaria
View GitHub Profile
@puuble
puuble / worker.js
Created February 24, 2023 12:10
worker
require("dotenv").config();
const axios = require("axios");
async function postData(url, res) {
try {
const options = {
url,
method: "POST",
headers: {"Content-Type": "application/json"},
data: res.body,
};
@puuble
puuble / app.js
Last active February 23, 2023 18:54
React for Elastic Search
/// npm install @elastic/elasticsearch
import { Client } from '@elastic/elasticsearch';
const client = new Client({
node: 'https://your-elastic-search-endpoint',
auth: {
username: 'your-username',
password: 'your-password'
}
});
@puuble
puuble / f1_index.js
Last active February 23, 2023 18:22
lambda and cloudwatch trigger
const MongoClient = require('mongodb').MongoClient;
const { Client } = require('@elastic/elasticsearch');
const uri = 'mongodb://localhost:27017/mydb';
const dbName = 'mydb';
const collectionName = 'mycollection';
const elasticUrl = 'http://localhost:9200';
const indexName = 'myindex';
exports.handler = async function(event, context) {
@puuble
puuble / order.php
Last active February 17, 2023 00:45
Posentegra Help - Order
<?php
/*
* Siparisler uzerinden islem yapmak icin PUT methoduyla ilgili URL tetiklenirken asagidaki sekilde gerekli fieldlari gonderebilirsiniz
* asagidaki ornekte trendyol uzerinde yapilacak islemlerin ornekleri bulunmaktadir.
*/
<?php
$curl = curl_init();
@puuble
puuble / webhook.php
Last active February 17, 2023 00:17
Posentegra Help
<?php
//webhook olarak vereceginiz URL icerisinde su sekilde bizden veri alabilirsiniz.
try {
// gelen datayi aliyoruz
$requestPayload = file_get_contents('php://input');
// JSON objectini decode ediyoruz.
$payload = json_decode($requestPayload);
@puuble
puuble / f1_config.js
Last active January 30, 2023 15:14
multiple database structure by schema
//database/config.js
const mongoose = require('mongoose');
class Database {
constructor(options) {
this.options = options;
this.connect();
}
connect() {
@puuble
puuble / f1_eventEmitter.py
Created January 18, 2023 23:19
python event emitter with SQS
import threading
from queue import Queue
import boto3
from pymongo import MongoClient
class LogService:
def __init__(self):
self.client = MongoClient('mongodb://localhost:27017/')
self.db = self.client['logs']
@puuble
puuble / f1_worker.js
Created January 18, 2023 23:15
working on worker for websocket queue SQS how to multiple thread p4
const { Worker, isMainThread, parentPort } = require('worker_threads');
const WebSocket = require('ws');
const AWS = require('aws-sdk');
const sqs = new AWS.SQS({
region: 'us-west-2',
accessKeyId: 'ACCESS_KEY',
secretAccessKey: 'SECRET_KEY'
});
const queueUrl = 'https://sqs.us-west-2.amazonaws.com/1234567890/my-queue';
@puuble
puuble / f1_mongodb_catch_logs_and_bounce.js
Last active January 18, 2023 22:50
adding mongodb websocket erorr logs with polling
//https://gist.github.com/puuble/d501bcdc03fb43499e09553458827c42 part 2
const MongoClient = require('mongodb').MongoClient;
const AWS = require('aws-sdk');
const sqs = new AWS.SQS({
region: 'us-west-2',
accessKeyId: 'ACCESS_KEY',
secretAccessKey: 'SECRET_KEY'
});
const queueUrl = 'https://sqs.us-west-2.amazonaws.com/1234567890/my-queue';
@puuble
puuble / f1_server.js
Last active January 18, 2023 22:38
web socket handle on nodejs for big concurrent
const WebSocket = require('ws');
const winston = require('winston');
const logger = winston.createLogger({
level: 'info',
format: winston.format.json(),
transports: [
new winston.transports.Console()
]
});