renatoargh

import { DateTime, DateTimeUnit, DurationLike } from "luxon";
import { deburr, kebabCase } from "lodash";
import { marshall, unmarshall } from "@aws-sdk/util-dynamodb";
import { 
  ConditionalCheckFailedException,
  DynamoDBClient,
  UpdateItemCommand,
} from "@aws-sdk/client-dynamodb";

const client = new DynamoDBClient({ region: 'sa-east-1' })

renatoargh

version: '3'

services:
  flink-jobmanager:
    image: flink:1.7
    platform: linux/x86_64
    container_name: flink-jobmanager
    command: 
      - "jobmanager"
    ports:

renatoargh

const sleep = async (timeout: number = 1000) =>
  // tslint:disable-next-line:no-string-based-set-timeout
  new Promise((res) => setTimeout(res, timeout));

/**
 * A test-only utility that executes a function until a given condition is met.
 * Useful to wait for asynchronous operations to complete on integration tests.
 * If the condition is never met (`condition` never returns `true`) then tests will eventually timeout accordin to
 * the test framework timeout settings.
 * @param task Asynchronous function that will be repeatedly executed until the the desired `condition` is met.

renatoargh

import { isUndefined } from "lodash";

export abstract class Cloneable<T> {
  public clone(newValues: Partial<T> = {}): T {
    const clone = new (this.constructor as new () => T)();
    const newValuesWithNestedClones = Object.getOwnPropertyNames(clone)
      .reduce((partial, propertyName) => {
        const property = Object.getOwnPropertyDescriptor(clone, propertyName) as PropertyDescriptor;
        const isCloneable = property.value instanceof Cloneable;
        const isNotProvided = isUndefined(

renatoargh

version: 2

jobs:
  validate_terraform:
    docker:
      - image: hashicorp/terraform
    steps:
      - checkout
      - run:
          name: Validate Terraform Formatting

renatoargh

const className = 'StateId'
const interfaceName = 'StateIdInterface'
const data = `  state: string;
  value: string;
  isActive: boolean;
  toJSON(): { [key: string]: any };`

const members = data
  .replace(/\n/g, '')
  .split(';')

renatoargh

interface ObjectInterface {
  [key: string]: any;
}

function initCache<T>(obj: any): T {
  const cache = {};

  return new Proxy(obj, {
    get(target: ObjectInterface, methodKey: string) {
      const originalMethod = target[methodKey];

renatoargh

interface ObjectInterface {
  [key: string]: any;
}

function initCache<T>(obj: any): T {
  const cache = {};

  return new Proxy(obj, {
    get(target: ObjectInterface, methodKey: string) {
      const originalMethod = target[methodKey];

renatoargh

Edit /var/lib/postgres/data/postgresql.conf:

# change IP on subscriber
listen_addresses = '*'
wal_level = logical
shared_preload_libraries = 'pglogical'
max_worker_processes = 16
max_wal_senders = 16
max_replication_slots = 16
track_commit_timestamp = on

renatoargh

const validator = new Validator('http://example.com/swagger.yaml')
await validator.init()

validator.validate('UserCreated', payload)