kinow · February 3, 2020 20:45 · kinow · Jan 16, 2020 · kinow · Jan 17, 2020
diff --git a/graphql-demo.js b/graphql-demo.js
 const express = require('express')
 const bodyParser = require('body-parser')
 const { graphqlExpress, graphiqlExpress } = require('apollo-server-express')
 const { makeExecutableSchema } = require('graphql-tools')
 const { PubSub } = require('graphql-subscriptions')
 const { createServer } = require('http')
 const { SubscriptionServer } = require('subscriptions-transport-ws')
 const { execute, subscribe } = require('graphql')

 const statuses = [
  'running',
  'held',
  'stopped'
 ]

 // Some fake data
 const workflows = [
  {
    id: 'five',
    name: 'five',
    status: 'waiting',
    host: 'localhost',
    port: 1000,
    owner: 'kinow'
  },
  {
    id: 'six',
    name: 'six',
    status: 'stalled',
    host: 'localhost',
    port: 2000,
    owner: 'kinow'
  }
 ]

 // The GraphQL schema in string form
 const typeDefs = `
  type Query { workflows: [Workflow] }
  type Subscription { workflows: [Workflow] }
  type Workflow {
    id: String!,
    name: String,
    status: String,
    host: String,
    port: Int,
    owner: String
  }
 `

 // WebSockets
 const pubsub = new PubSub()

 // The resolvers
 const resolvers = {
  Query: { workflows: () => workflows },
  Subscription: {
    workflows: {
      subscribe: () => pubsub.asyncIterator('workflows')
    }
  }
 }

 setInterval(() => {
  for (const workflow of workflows) {
    workflow.status = statuses[Math.floor(Math.random() * statuses.length)]
  }
  pubsub.publish('workflows', {
    workflows: workflows
  })
 }, 5000)

 // Put together a schema
 const schema = makeExecutableSchema({
  typeDefs,
  resolvers
 })

 // Initialize the app
 const app = express()

 // The GraphQL endpoint
 app.use('/graphql', bodyParser.json(), graphqlExpress({ schema }))

 // GraphiQL, a visual editor for queries
 app.use('/graphiql', graphiqlExpress({
  endpointURL: '/graphql',
  subscriptionEndpoint: 'ws://localhost:3000/subscriptions'
 }))

 const server = createServer(app)

 // Start the server
 server.listen(3000, () => {
  // eslint-disable-next-line no-new
  new SubscriptionServer({
    execute,
    subscribe,
    schema: schema
  }, {
    server: server,
    path: '/subscriptions'
  })
  console.log('Go to http://localhost:3000/graphiql to run queries!')
 })

 // also need to include something in `package.json` like:
 // "scripts": {
 //   "graphql:serve": "node graphql-demo.js"
 //  }
diff --git a/logging_config.json b/logging_config.json
 {
  "logging": {
    "version": 1,
    "disable_existing_loggers": true,
    "formatters": {
      "basic": {
        "format": "%(asctime)s %(name)-12s %(levelname)-8s %(message)s"
      },
      "verbose": {
        "class": "logging.Formatter",
        "datefmt": "%I:%M:%S",
        "format": "%(levelname)-8s; [%(process)d]; %(threadName)s; %(name)-15s; %(module)s:%(funcName)s;%(lineno)d: %(message)s"
      }
    },
    "handlers": {
      "console": {
        "level": "DEBUG",
        "class": "logging.StreamHandler",
        "formatter": "basic",
        "stream" : "ext://sys.stdout"
      },
      "file": {
        "level": "DEBUG",
        "class": "logging.handlers.WatchedFileHandler",
        "formatter": "verbose",
        "filename" : "/tmp/websockets.log",
        "mode": "a",
        "encoding": "utf-8"
      }
    },
    "loggers": {
      "tornado.access": {
        "level": "WARN",
        "handlers": ["console"],
        "propagate": false
      },
      "tornado.application": {
        "level": "WARN",
        "handlers": ["console"],
        "propagate": false
      },
      "cylc.flow": {
        "level": "DEBUG",
        "handlers": ["console"],
        "propagate": false
      },
      "cylc.uiserver": {
        "level": "DEBUG",
        "handlers": ["console"],
        "propagate": false
      },
      "cylc.uiserver.websockets": {
        "level": "DEBUG",
        "handlers": ["file"],
        "propagate": false
      }
    },
    "root": {
      "handlers": ["console"],
      "level": "WARN"
    }
  }
 }
diff --git a/websocket.md b/websocket.md
	const express = require('express')
	const bodyParser = require('body-parser')
	const { graphqlExpress, graphiqlExpress } = require('apollo-server-express')
	const { makeExecutableSchema } = require('graphql-tools')
	const { PubSub } = require('graphql-subscriptions')
	const { createServer } = require('http')
	const { SubscriptionServer } = require('subscriptions-transport-ws')
	const { execute, subscribe } = require('graphql')

	const statuses = [
	'running',
	'held',
	'stopped'
	]

	// Some fake data
	const workflows = [
	{
	id: 'five',
	name: 'five',
	status: 'waiting',
	host: 'localhost',
	port: 1000,
	owner: 'kinow'
	},
	{
	id: 'six',
	name: 'six',
	status: 'stalled',
	host: 'localhost',
	port: 2000,
	owner: 'kinow'
	}
	]

	// The GraphQL schema in string form
	const typeDefs = `
	type Query { workflows: [Workflow] }
	type Subscription { workflows: [Workflow] }
	type Workflow {
	id: String!,
	name: String,
	status: String,
	host: String,
	port: Int,
	owner: String
	}
	`

	// WebSockets
	const pubsub = new PubSub()

	// The resolvers
	const resolvers = {
	Query: { workflows: () => workflows },
	Subscription: {
	workflows: {
	subscribe: () => pubsub.asyncIterator('workflows')
	}
	}
	}

	setInterval(() => {
	for (const workflow of workflows) {
	workflow.status = statuses[Math.floor(Math.random() * statuses.length)]
	}
	pubsub.publish('workflows', {
	workflows: workflows
	})
	}, 5000)

	// Put together a schema
	const schema = makeExecutableSchema({
	typeDefs,
	resolvers
	})

	// Initialize the app
	const app = express()

	// The GraphQL endpoint
	app.use('/graphql', bodyParser.json(), graphqlExpress({ schema }))

	// GraphiQL, a visual editor for queries
	app.use('/graphiql', graphiqlExpress({
	endpointURL: '/graphql',
	subscriptionEndpoint: 'ws://localhost:3000/subscriptions'
	}))

	const server = createServer(app)

	// Start the server
	server.listen(3000, () => {
	// eslint-disable-next-line no-new
	new SubscriptionServer({
	execute,
	subscribe,
	schema: schema
	}, {
	server: server,
	path: '/subscriptions'
	})
	console.log('Go to http://localhost:3000/graphiql to run queries!')
	})

	// also need to include something in `package.json` like:
	// "scripts": {
	// "graphql:serve": "node graphql-demo.js"
	// }
	{
	"logging": {
	"version": 1,
	"disable_existing_loggers": true,
	"formatters": {
	"basic": {
	"format": "%(asctime)s %(name)-12s %(levelname)-8s %(message)s"
	},
	"verbose": {
	"class": "logging.Formatter",
	"datefmt": "%I:%M:%S",
	"format": "%(levelname)-8s; [%(process)d]; %(threadName)s; %(name)-15s; %(module)s:%(funcName)s;%(lineno)d: %(message)s"
	}
	},
	"handlers": {
	"console": {
	"level": "DEBUG",
	"class": "logging.StreamHandler",
	"formatter": "basic",
	"stream" : "ext://sys.stdout"
	},
	"file": {
	"level": "DEBUG",
	"class": "logging.handlers.WatchedFileHandler",
	"formatter": "verbose",
	"filename" : "/tmp/websockets.log",
	"mode": "a",
	"encoding": "utf-8"
	}
	},
	"loggers": {
	"tornado.access": {
	"level": "WARN",
	"handlers": ["console"],
	"propagate": false
	},
	"tornado.application": {
	"level": "WARN",
	"handlers": ["console"],
	"propagate": false
	},
	"cylc.flow": {
	"level": "DEBUG",
	"handlers": ["console"],
	"propagate": false
	},
	"cylc.uiserver": {
	"level": "DEBUG",
	"handlers": ["console"],
	"propagate": false
	},
	"cylc.uiserver.websockets": {
	"level": "DEBUG",
	"handlers": ["file"],
	"propagate": false
	}
	},
	"root": {
	"handlers": ["console"],
	"level": "WARN"
	}
	}
	}