ThisIsMissEm

mutation updateUser(
  details: UpdateUserInput!
): UpdateUserResult

union UpdateUserResult = 
  UpdateUserSuccess |
  FormValidationError

type UpdateUserSuccess {}

ThisIsMissEm

import { Kafka, logLevel, KafkaConfig, SASLOptions } from "kafkajs";

const options: KafkaConfig = {
  clientId: "my-client",
  brokers: (process.env.KAFKA_BROKERS &&
    process.env.KAFKA_BROKERS.split(",")) || ["localhost:9092"]
};

if (
  process.env.KAFKA_AUTH_MECHANISM &&

ThisIsMissEm

import { Kafka, Consumer, Producer, KafkaMessage } from "kafkajs";
import { Logger } from "pino";
import { EventEmitter } from "events";
import uuidv4 from "uuid/v4";

type Options = {
  groupId: string;
  topicPrefix: string;
  logger: Logger;
};

ThisIsMissEm

type Key {
  constructor(identifier)
  unlock(): Promise<void>
  lock(): Promise()<void>
  decrypt(value: ArrayBuffer): Promise<ArrayBuffer>
}

ThisIsMissEm

type Key {
  constructor(identifier)
  unlock(): Promise<void>
  lock(): Promise()<void>
  decrypt(value: ArrayBuffer): Promise<ArrayBuffer>
}

ThisIsMissEm

‪From the initiating client (owner)‬
1. create a short-code (say 12 lowercase hex characters)‬
2. Using the dat archives public key, encrypt that value, let that be token‬
3. poll a DHT for token's value‬
4. Once we receive a value for that token, encrypt the archive private key with the received public key & save as a file

‪From the new client:‬
1. Ask the user to input the short-code from the same dat archive
2. Using the archives public-key, encrypt that value
3. Create a new public/private key pair

ThisIsMissEm

const fs = require("fs").promises;
const createReadStream = require("fs").createReadStream;
const debug = require("debug");

class MessageLogDB {
  constructor(filename, separator) {
    this.separator = separator || "\r\n";
    this.separator_length = Buffer.byteLength(this.separator, "utf8");

    this.filename = filename;

ThisIsMissEm

const fs = require("fs").promises;
const path = require("path");
const execa = require("execa");
const assert = require("assert");
const gitUrlParse = require("git-url-parse");
const fse = require("fs-extra");

async function findRepos(workingDirectory) {
  const nodes = await fs.readdir(workingDirectory, { withFileTypes: true });
  const directories = nodes.filter(node => node.isDirectory());

ThisIsMissEm

{
  "name": "my-app",
  "version": "1.0.0",
  "registries": {
    "npm": { "url": "registry.npmjs.org", "default": true },
    "tidelift": { "url": "registry.tidelift.org" },
    "acme-corp": { "url": "verdaccio.acme.corp" }
  },
  "dependencies": {
    "express": "^4.0.x",

ThisIsMissEm

$ npm run test

> node-fetch@2.2.0 test /Users/emelia/Work/HighSnobiety/repos/node-fetch
> cross-env BABEL_ENV=test mocha --require babel-register test/test.js



  node-fetch
    ✓ should return a promise
    ✓ should allow custom promise