💻 code

Author: xDae

functions/graphql/database/create-video.js

@@ -0,0 +1,24 @@
+const firebase = require('../firebase');
+
+const DB = firebase.database();
+
+const createVideo = ({ id, title, duration, released }) => {
+  return new Promise((resolve, reject) => {
+    const ref = DB.ref('videos');
+    const video = { id, title, duration, released };
+
+    ref.child(id).set({
+      title,
+      duration,
+      released
+    }, error => {
+      if (error) {
+        reject(new Error('Data could not be saved.'))
+      } else {
+        resolve(video);
+      }
+    });
+  });
+}
+
+module.exports = createVideo;

functions/graphql/database/get-video.js

@@ -0,0 +1,13 @@
+const firebase = require('../firebase');
+const DB = firebase.database();
+
+const getVideoById = id => new Promise((resolve, reject) => {
+  var ref = DB.ref(`videos`);
+
+  ref.child(id).once('value', data => data.exists()
+    ? resolve(Object.assign({}, data.val(), { id: data.key }))
+    : reject(new Error(`Video with ID '${id}' doesnt found`))
+  );
+});
+
+module.exports = getVideoById;

functions/graphql/database/get-videos.js

@@ -0,0 +1,20 @@
+const firebase = require('../firebase');
+const toArray = require('./utils');
+
+const DB = firebase.database();
+
+const getVideos = args => new Promise(resolve => {
+  const ref = DB.ref('videos');
+
+  ref.once('value', data => {
+    const videos = toArray(data);
+
+    if (args.watched !== undefined) {
+      resolve(videos.filter(video => video.watched === args.watched));
+    } else {
+      resolve(videos);
+    }
+  });
+});
+
+module.exports = getVideos;

functions/graphql/database/utils.js

@@ -0,0 +1,17 @@
+const isObject = obj => {
+  return Object.prototype.toString(obj) === '[object Object]' ? true : false;
+};
+
+const toArray = snapshot => {
+  let arr = [];
+  snapshot.forEach(childSnapshot => {
+    let val = childSnapshot.val();
+    if(isObject(val)){
+      val.id = childSnapshot.key;
+    }
+    arr.push(val);
+  });
+  return arr;
+};
+
+module.exports = toArray;

functions/graphql/firebase.js

@@ -0,0 +1,4 @@
+const functions = require('firebase-functions');
+const admin = require('firebase-admin');
+
+module.exports = admin.initializeApp(functions.config().firebase);

functions/graphql/index.js

@@ -0,0 +1,20 @@
+const functions = require('firebase-functions');
+const cors = require('cors')({ origin: true });
+
+const { graphql } = require('graphql');
+
+const Schema = require('./schema');
+
+module.exports = functions.https.onRequest((req, res) => cors(req, res, () => {
+  if (req.method === 'POST') {
+    return graphql(Schema, req.body.query, null, {}, req.body.variables)
+    .then(result => {
+      res.send(result);
+    })
+    .catch(err => res.send(new Error('hubo un error madafaker')))
+  } else {
+    return graphql(Schema, req.body.query, null, {}, req.body.variables)
+    .then(result => res.send(result))
+    .catch(err => res.send(new Error('hubo un error madafaker')));
+  }
+}));

functions/graphql/schema.js

@@ -0,0 +1,11 @@
+const { GraphQLSchema } = require( 'graphql');
+
+const queryType = require('./types/query');
+const mutationType = require('./types/mutation');
+
+const Schema = new GraphQLSchema({
+  query: queryType,
+  mutation: mutationType
+});
+
+module.exports = Schema;

functions/graphql/types/mutation.js

@@ -0,0 +1,42 @@
+const {
+  GraphQLObjectType,
+  GraphQLString,
+  GraphQLInt,
+  GraphQLBoolean,
+  GraphQLNonNull
+} = require('graphql');
+
+const createVideo = require('../database/create-video');
+
+const videoType = require('./video');
+
+const MutationType = new GraphQLObjectType({
+  name: 'mutation',
+  description: 'The root mutation type',
+  fields: {
+    createVideo: {
+      type: videoType,
+      args: {
+        id: {
+          type: new GraphQLNonNull(GraphQLString),
+          description: 'the ID of the video'
+        },
+        title: {
+          type: new GraphQLNonNull(GraphQLString),
+          description: 'the title of the video'
+        },
+        duration: {
+          type: new GraphQLNonNull(GraphQLInt),
+          description: 'the duration of the video'
+        },
+        released: {
+          type: new GraphQLNonNull(GraphQLBoolean),
+          description: 'the ID of the video'
+        }
+      },
+      resolve: (_, args) => createVideo(args)
+    }
+  }
+});
+
+module.exports = MutationType;

functions/graphql/types/query.js

@@ -0,0 +1,41 @@
+const {
+  GraphQLObjectType,
+  GraphQLID,
+  GraphQLBoolean,
+  GraphQLNonNull,
+  GraphQLList
+} = require('graphql');
+
+const videoType = require('./video');
+
+const getVideo= require('../database/get-video');
+const getVideos = require('../database/get-videos');
+
+const QueryType = new GraphQLObjectType({
+  name: 'QueryType',
+  description: 'The root query type',
+  fields: {
+    videos: {
+      type: new GraphQLList(videoType),
+      args: {
+        watched: {
+          type: GraphQLBoolean,
+          description: 'if the video has been watched'
+        }
+      },
+      resolve: (_, args) => getVideos(args)
+    },
+    video: {
+      type: videoType,
+      args: {
+        id: {
+          type: new GraphQLNonNull(GraphQLID),
+          description: 'the ID of the video'
+        }
+      },
+      resolve: (_, args) => getVideo(args.id)
+    }
+  }
+});
+
+module.exports = QueryType;

functions/graphql/types/video.js

@@ -0,0 +1,32 @@
+const {
+  GraphQLObjectType,
+  GraphQLID,
+  GraphQLString,
+  GraphQLInt,
+  GraphQLBoolean
+} = require('graphql');
+
+const videoType = new GraphQLObjectType({
+  name: 'Video',
+  description: 'A video type',
+  fields: {
+    id: {
+      type: GraphQLID,
+      description: 'the ID of the video'
+    },
+    title: {
+      type: GraphQLString,
+      description: 'the title of the video'
+    },
+    duration: {
+      type: GraphQLInt,
+      description: 'the duration of video, in seconds'
+    },
+    watched: {
+      type: GraphQLBoolean,
+      description: 'if video has been watched'
+    },
+  }
+});
+
+module.exports = videoType;