dturton

Docker, TypeScript, Node.js

Preconditions:

• TS application listening port: 7777

|-- dist
|-- src
|-- .dockerignore
|-- Dockerfile

dturton

function createStore(target, listener) {
  const handler = {
    set(target, prop, value, receiver) {
				target[prop] = value;
				listener(receiver);
				return true;
		},
    get(target, prop) {
    	return target[prop];
  	},

dturton

const getCircularReplacer = () => {
  const seen = new WeakSet();
  return (_key: any, value: object) => {
    if (typeof value === "object" && value !== null) {
      if (seen.has(value)) {
        return;
      }
      seen.add(value);
    }
    return value;

dturton

import { createWorkflow, WorkflowEvent } from "@deepkit/workflow";
import { eventDispatcher, EventDispatcher } from "@deepkit/event";
import { ConsoleTransport, Logger } from "@deepkit/logger";
import { InjectorContext, InjectorModule } from "@deepkit/injector";
import { BrokerDirectClient, BrokerKernel } from "@deepkit/broker";

class EndEvent extends WorkflowEvent {
  completed: boolean = true;
}

dturton

  const toParameterObject = (search) =>
    JSON.parse(
      '{"' + search.replace(/&/g, '","').replace(/=/g, '":"') + '"}',
      (key, value) => (key === "" ? value : decodeURIComponent(value))
    );

dturton

const groupByKey = (list, key) => list.reduce((hash, obj) => ({...hash, [obj[key]]:( hash[obj[key]] || [] ).concat(obj)}), {})

dturton

const { Queue, QueueEvents } = require('bullmq');
const { EventEmitter } = require('events');
const config = require('../config');
const createUid = require('uid');


class QueueArena extends EventEmitter {
  constructor({ redisDb = 1 }) {
    super();
    this.redisDb = redisDb;

dturton

Array.from(Array(10).keys())

dturton

import client from "../client";
import CA from "../CA";

export const handle = async function() {
  try {
    const response = await CA.get(
      "Orders?$expand=Items($select=Sku,Quantity),CustomFields&exported=false&$filter=Fulfillments/Any (c: c/DistributionCenterID eq 2) and ShippingStatus eq 'Unshipped' and CreatedDateUtc ge 2020-01-12"
    );

    const promises = response.data.value

dturton

import client from "../client";
import CA from "../CA";

export const handle = async function() {
  try {
    const response = await CA.get(
      "Orders?$expand=Items($select=Sku,Quantity),CustomFields&exported=false&$filter=Fulfillments/Any (c: c/DistributionCenterID eq 2) and ShippingStatus eq 'Unshipped' and CreatedDateUtc ge 2020-01-12"
    );

    const promises = response.data.value