philsch

// Jest Snapshot v1, https://goo.gl/fbAQLP

exports[`Getting shop items Retrieves the shop items in default order 1`] = `
Object {
  "data": Object {
    "shopItems": Array [
      Object {
        "category": "shoes",
        "name": "Fancy Sneaker",
        "size": "8",

philsch

import * as util from 'util';
import * as rp from 'request-promise';
import { exec } from 'child_process';

const pExec = util.promisify(exec);

const API = 'http://localhost:4466/';
const CMD_SEED_DATABASE = `${__dirname}/../seed.sh`;

describe('Getting shop items', () => {

philsch

{
  "data": {
    "shopItems": [
      {
        "name": "Fancy Sneakers",
        "category": "shoes",
        "size": "8"
      },
      {
        "name": "Black shirt",

philsch

query {
  shopItems {
    name
    category
    size
  }
}

philsch

#!/usr/bin/env bash

# Truncate data in ShopItems collection
mongo shop --host localhost:27017 --username xxx --password xxx --authenticationDatabase admin \
    --eval 'db.getCollection("ShopItems").remove({})'

# Import seed data into ShopItems collection
mongoimport --host localhost:27017 --username xxx --password xxx --authenticationDatabase admin \
    --db shop --collection ShopItems --type JSON --file ShopItems.json        

philsch

mongoexport 
  --host localhost:27017 \ 
  --username xxx \
  --authenticationDatabase admin \
  --db shop \
  --type JSON \
  --out ~/project/seeds/ShopItems.json \
  --collection ShopItems \
  --query '{}'

philsch

{
 textPayload:  "[f85423] {"host":"api.example.org","content-length":"1014","accept":"*/*",
  "origin":"https://api.example.org","user-agent":"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_2) 
  AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3578.98 Safari/537.36",
  "content-type":"application/json","accept-encoding":"gzip, deflate, br",
  "via":"1.1 google","x-forwarded-for":"***","x-forwarded-proto":"https",
  "authorization":"***"}
 timestamp: "2019-02-05T13:24:20Z"
}
{

philsch

import {ApolloServer, SyntaxError, UserInputError, AuthenticationError, ForbiddenError} from 'apollo-server-express';
import {GraphQLErrorTrackingExtension} from 'graphql-error-tracking-extension';
import {ErrorReporting} from '@google-cloud/error-reporting';

const errorReporting = new ErrorReporting();

const server = new ApolloServer({
  schema,
  extensions: [() => new GraphQLErrorTrackingExtension({
    maskHeaders: ['x-forwarded-for', 'authorization'],

philsch

{
 receiveTimestamp:  "2019-02-05T11:53:31.329098822Z"  
 resource: {…}  
 textPayload: "{"message":"Syntax Error: Expected Name, found )",
  "locations":[{"line":2,"column":22}],
  "extensions":{"code":"GRAPHQL_PARSE_FAILED"}}"  
 timestamp: "2019-02-05T11:53:20Z"
}

philsch

def run():
    pipeline_options = PipelineOptions()
    pipeline = beam.Pipeline(options=pipeline_options)
    options = pipeline_options.view_as(AvroTransformOptions)

    steps = (
            pipeline
            | 'ReadData' >> beam.io.ReadFromAvro(options.input, use_fastavro=True)
            | 'Transaform rowkey' >> beam.ParDo(CellTransformDoFn())
            | 'WriteData' >> beam.io.WriteToAvro(options.output, BIG_TABLE_SCHEMA, use_fastavro=True))