feat: GraphQL API server

package.json

@@ -16,7 +16,9 @@
   },
   "dependencies": {
     "@koa/cors": "3",
+    "apollo-server": "^2.19.0",
     "beamcoder": "^0.6.10",
+    "graphql": "^15.4.0",
     "koa": "^2.13.0",
     "macadam": "^2.0.14",
     "naudiodon": "^2.3.0",

src/GraphQL/schema.ts

@@ -0,0 +1,58 @@
+import { gql } from 'apollo-server'
+
+export default gql`
+	"""
+	A channel is an individual composition of various sources, layed out on different layers
+	"""
+	type Channel {
+		id: ID!
+		number: Int!
+		videoFormat: VideoFormat!
+		layers: [Layer!]!
+	}
+
+	"""
+	A producer is a media stream source that will produce media when not paused
+	"""
+	type Producer {
+		sourceId: ID!
+		format: VideoFormat!
+		paused: Boolean!
+	}
+
+	type Mixer {
+		dupa: String
+	}
+
+	"""
+	A layer is a part of the channel, that can have a foreground and a background. The background can play
+	automatically, if the foreground is empty.
+	"""
+	type Layer {
+		foreground: Producer
+		background: Producer
+		autoPlay: Boolean!
+		mixer: Mixer!
+	}
+
+	"""
+	A video format is a specification of the audio & video format that will be produced by a Channel
+	"""
+	type VideoFormat {
+		name: String!
+		fields: Int!
+		width: Int!
+		height: Int!
+		squareWidth: Int!
+		squareHeight: Int!
+		timescale: Float!
+		duration: Int!
+		audioSampleRate: Int!
+		audioChannels: Int!
+	}
+
+	type Query {
+		channels: [Channel]!
+		videoFormats: [VideoFormat]!
+	}
+`

src/GraphQL/server.ts

@@ -0,0 +1,33 @@
+import { ApolloServer } from 'apollo-server'
+import { Channel } from '../channel'
+import { VideoFormat, VideoFormats } from '../config'
+import typeDefs from './schema'
+
+const model: {
+	channels: Channel[]
+	videoFormats: VideoFormat[]
+} = {
+	channels: [],
+	videoFormats: []
+}
+
+const resolvers = {
+	Query: {
+		channels: () => [], // (parent, args, context, info) => [],
+		videoFormats: () => [] // (parent, args, context, info) => []
+	}
+}
+
+const server = new ApolloServer({ typeDefs, resolvers })
+
+export async function start(channels: Channel[]): Promise<string> {
+	model.channels = channels
+	model.videoFormats = new VideoFormats().list()
+	const { url } = await server.listen()
+	return `🚀  GraphQL Server ready at ${url}`
+}
+
+export async function stop(): Promise<string> {
+	await server.stop()
+	return `GraphQL Server shut down.`
+}

src/config.ts

@@ -71,6 +71,10 @@ export class VideoFormats {
 		if (!format) throw new Error(`Video format ${name} not found`)
 		return format
 	}
+
+	list(): VideoFormat[] {
+		return Array.from(this.formats.values())
+	}
 }
 
 export interface DeviceConfig {

src/index.ts

@@ -20,7 +20,8 @@
 
 import { clContext as nodenCLContext } from 'nodencl'
 import { ClProcessJobs } from './clJobQueue'
-import { start, processCommand } from './AMCP/server'
+import { start as amcpStart, processCommand } from './AMCP/server'
+import { start as graphQLStart } from './GraphQL/server'
 import { Commands } from './AMCP/commands'
 import { Channel } from './channel'
 import { BasicCmds } from './AMCP/basicCmds'
@@ -102,16 +103,17 @@ rl.on('SIGINT', () => {
 
 console.log('\nWelcome to Phaneron\n')
 
+const channels: Channel[] = []
+
 const commands: Commands = new Commands()
 initialiseOpenCL()
 	.then(async (clContext) => {
+		const config = new Config()
 		const consReg = new ConsumerRegistry(clContext)
 		const prodReg = new ProducerRegistry(clContext)
 
 		const clProcessJobs = new ClProcessJobs(clContext)
 		const clJobs = clProcessJobs.getJobs()
-		const config = new Config()
-		const channels: Channel[] = []
 
 		config.consumers.forEach((consumerConfig, i) => {
 			try {
@@ -131,7 +133,9 @@ initialiseOpenCL()
 
 		// setInterval(() => clContext.logBuffers(), 2000)
 	})
-	.then(() => start(commands))
+	.then(() => graphQLStart(channels))
+	.then(console.log, console.error)
+	.then(() => amcpStart(commands))
 	.then(console.log, console.error)
 	.then(() => rl.prompt())
 	.catch(console.error)