Loren ☺️ lorensr

GraphQL @Netflix, author of @GraphQLGuide. Formerly: Temporal's Node runtime, consulting, startups, NSA, Dartmouth.

lorensr / actors.ts

Last active June 26, 2023 20:24

	const addItem = defineSignal('addItem')
	const checkout = defineSignal('checkout')

	function cart(userId) {
	const items = []

	setHandler(addItem, (item) => items.push(item))

	setHandler(checkout, () => {
	const userInfo = await getUser(userId) // activity that gets a handle to the User workflow with Workflow Id = userId and does a 'getUserInfo' Query

lorensr / pollRace.ts

Last active March 23, 2022 00:37

	const { poll } = proxyActivities<typeof activities>({
	startToCloseTimeout: '10m',
	retryPolicy: {
	initialInterval: '1h',
	backoffCoefficient: 1
	}
	});

	export const stopPolling = defineSignal('stopPolling');

lorensr / FooDataSource-structure.js

Created April 8, 2020 19:15

	import { DataSource } from 'apollo-datasource'
	import { InMemoryLRUCache } from 'apollo-server-caching'
	import DataLoader from 'dataloader'

	class FooDataSource extends DataSource {
	constructor(dbClient) { ... }

	initialize({ context, cache } = {}) { ... }

	didEncounterError(error) { ... }

lorensr / resolvers.js

Created April 2, 2020 09:31

	const resolvers = {
	Query: {
	getFoo: (_, { id }, context) =>
	context.dataSources.myFoos.get(id, { ttlInSeconds: 60 })
	},
	Mutation: {
	updateFoo: async (_, { id, fields }, context) => {
	if (context.isAdmin) {
	context.dataSources.myFoos.updateFields(id, fields)
	}

lorensr / dataSources.js

Last active May 7, 2020 22:49

	import FooClient from 'imaginary-foo-library'

	import MyFooDB from './MyFooDB'

	const fooClient = new FooClient({ uri: 'https://foo.graphql.guide:9001' })

	const server = new ApolloServer({
	typeDefs,
	resolvers,
	dataSources: () => ({

lorensr / MyFooDB.js

Created April 2, 2020 09:28

	import FooDataSource from './FooDataSource'
	import { reportError } from './utils'

	export default class MyFooDB extends FooDataSource {
	async updateFields(id, fields) {
	const doc = await this.get(id)
	return this.update(id, {
	...doc,
	...fields
	})

lorensr / FooDataSource-update.js

Created April 2, 2020 09:27

	async update(id, newDoc) {
	try {
	await this.db.update(id, newDoc)
	this.cache.delete(this.cacheKey(id))
	} catch (error) {
	this.didEncounterError(error)
	}
	}

lorensr / FooDataSource-get.js

Created April 2, 2020 09:24

	async get(id, { ttlInSeconds } = {}) {
	const cacheDoc = await cache.get(this.cacheKey(id))
	if (cacheDoc) {
	return JSON.parse(cacheDoc)
	}

	const doc = await this.loader.load(id)

	if (ttlInSeconds) {
	cache.set(this.cacheKey(id), JSON.stringify(doc), { ttl: ttlInSeconds })

lorensr / FooDataSource-cacheKey.js

Created April 2, 2020 09:24

	cacheKey(id) {
	return `foo-${this.db.connectionURI}-${id}`
	}

lorensr / FooDataSource-didEncounterError.js

Created April 2, 2020 09:22