feat: create google docs using google api (#211)

* feat: google docs using google api

* fix: prettier error

* chore: upgrade prettier cli action 1.0.0 to 1.0.2

.github/workflows/prettier.yml

@@ -47,7 +47,7 @@ jobs:
 
       - name: Run Prettier
         id: prettier-run
-        uses: rutajdash/[email protected].0
+        uses: rutajdash/[email protected].2
         with:
           file_pattern: ${{ inputs.file_pattern }}
           config_path: ${{ inputs.config_path }}

.gitignore

@@ -562,6 +562,7 @@ out
 
 # Roles Cache
 roles.json
+firebaseServiceAccount.json
 
 # Environment Variables
 .env.*

server/config/firebase.js

@@ -11,19 +11,25 @@
 
 const Admin = require('firebase-admin');
 const logger = require('../utils/logger')('firebase');
+const fs = require('fs');
 
 module.exports = {
   /**
    * @description Firebase Initialization Sequence
    * @function
    */
   init: () => {
+    const firebaseServiceAccount = JSON.parse(
+      Buffer.from(process.env.FIREBASE_SERVICE_ACCOUNT, 'base64').toString('ascii')
+    );
+
+    if (!fs.existsSync('firebaseServiceAccount.json')) {
+      fs.writeFileSync('firebaseServiceAccount.json', JSON.stringify(firebaseServiceAccount));
+    }
+
     try {
       /** Inititalize Firebase Admin SDK with required configuration */
       if (process.env.FIREBASE_SERVICE_ACCOUNT && process.env.NODE_ENV !== 'development') {
-        const firebaseServiceAccount = JSON.parse(
-          Buffer.from(process.env.FIREBASE_SERVICE_ACCOUNT, 'base64').toString('ascii')
-        );
         Admin.initializeApp({
           credential: Admin.credential.cert(firebaseServiceAccount),
           storageBucket: process.env.FIREBASE_STORAGE_BUCKET || null,

server/package.json

@@ -43,6 +43,8 @@
     ]
   },
   "dependencies": {
+    "@googleapis/docs": "^3.0.0",
+    "@googleapis/drive": "^8.6.0",
     "@graphql-tools/stitch": "^8.3.1",
     "apollo-server-core": "^3.10.1",
     "apollo-server-express": "^3.4.0",

server/schema/article/article.datasources.js

@@ -7,6 +7,54 @@ const UserModel = require('../user/user.model');
 const { connection } = require('../../config/mongoose');
 const createUpdateObject = require('../../utils/createUpdateObject');
 const TagModel = require('../tag/tag.model');
+const docs = require('@googleapis/docs');
+const drive = require('@googleapis/drive');
+
+let auth;
+
+const googleAuth = () => {
+  auth = new drive.auth.GoogleAuth({
+    keyFilename: './firebaseServiceAccount.json',
+    scopes: ['https://www.googleapis.com/auth/documents', 'https://www.googleapis.com/auth/drive'],
+  });
+};
+
+const createGoogleDoc = async (title = 'test', emails) => {
+  try {
+    googleAuth();
+    const authClient = await auth.getClient();
+
+    const driveClient = drive.drive({
+      version: 'v3',
+      auth: authClient,
+    });
+
+    const driveResponse = await driveClient.files.create({
+      requestBody: {
+        name: title,
+        mimeType: 'application/vnd.google-apps.document',
+      },
+    });
+
+    const googleDocsId = driveResponse.data.id;
+
+    await emails.forEach(async (email) => {
+      driveClient.permissions.create({
+        fileId: googleDocsId,
+        requestBody: {
+          role: 'writer',
+          type: 'user',
+          transferOwnership: true,
+          emailAddress: email,
+        },
+      });
+    });
+
+    return googleDocsId;
+  } catch (error) {
+    console.log('error:', error);
+  }
+};
 
 const ARTICLE_PUBLISH_TYPES = Object.fromEntries(
   PublishStatusEnumType.getValues().map((item) => [item.name, item.value])
@@ -196,6 +244,7 @@ const create = async (
   photographers,
   designers,
   tech,
+  emails,
   categories,
   session,
   authToken,
@@ -214,13 +263,18 @@ const create = async (
           'At least one of the user IDs supplied supplied is invalid, i.e. that user does not exist or is not a MM Team Member.',
       });
     }
-
-    // TODO: create google doc and link
+    let googleDocsId;
+    try {
+      googleDocsId = await createGoogleDoc(title, emails);
+    } catch (error) {
+      throw APIError(`Google docs can not be created`, null, { reason: error });
+    }
     const [_article] = await ArticleModel.create(
       [
         {
           articleType,
           title,
+          googleDocsId,
           users: _users.map((_user) => ({
             name: _user.fullName,
             team: authors.includes(_user._id.toString())
@@ -235,7 +289,7 @@ const create = async (
             details: _user._id,
           })),
           categories,
-          createdBy: UserSession.valid(session, authToken) ? mid : null,
+          createdBy: UserSession.valid(session, authToken) ? mid || null : null,
         },
       ],
       { session: mdbSession }

server/schema/article/article.model.js

@@ -26,6 +26,10 @@ const ArticleSchema = new Schema(
       min: 0,
       max: 2,
     },
+    googleDocsId: {
+      type: String,
+      required: false,
+    },
     title: {
       type: String,
       required: true,

server/schema/article/article.mutation.js

@@ -49,6 +49,7 @@ module.exports = new GraphQLObjectType({
         photographers: { type: new GraphQLNonNull(new GraphQLList(GraphQLID)) },
         designers: { type: new GraphQLNonNull(new GraphQLList(GraphQLID)) },
         tech: { type: new GraphQLNonNull(new GraphQLList(GraphQLID)) },
+        emails: { type: new GraphQLNonNull(new GraphQLList(GraphQLString)) },
         categoryNumbers: { type: new GraphQLNonNull(new GraphQLList(GraphQLInt)) },
       },
       resolve: createArticle,

server/schema/article/article.resolver.js

@@ -347,7 +347,7 @@ module.exports = {
 
   createArticle: async (
     _parent,
-    { articleType, title, authors, photographers, designers, tech, categoryNumbers },
+    { articleType, title, authors, photographers, designers, tech, emails, categoryNumbers },
     { mid, session, authToken, decodedToken, API: { Article, CategoryMap } }
   ) => {
     try {
@@ -377,6 +377,7 @@ module.exports = {
         photographers,
         designers,
         tech,
+        emails,
         categories,
         session,
         authToken,

server/schema/article/article.type.js

@@ -85,7 +85,7 @@ const ArticleType = new GraphQLObjectType({
     id: { type: GraphQLID },
 
     articleType: { type: ArticleTypeEnumType },
-
+    googleDocsId: { type: GraphQLString },
     title: { type: GraphQLString },
     content: { type: new GraphQLList(ContentType) },
     inshort: { type: GraphQLString },

server/schema/squiggle/squiggle.datasources.js

@@ -51,7 +51,7 @@ const updateContent = async (id, newContent) => {
 
     return _squiggle;
   } catch (error) {
-    throw APIError("failed to update squiggle content.", error);
+    throw APIError('failed to update squiggle content.', error);
   }
 };
 
@@ -60,7 +60,7 @@ const SquiggleDataSources = () => ({
   findByID,
   find,
   create,
-  updateContent
+  updateContent,
 });
 
 module.exports = SquiggleDataSources;

server/schema/squiggle/squiggle.mutation.js

@@ -1,4 +1,4 @@
-const { GraphQLObjectType, GraphQLNonNull, GraphQLID ,GraphQLString } = require('../scalars');
+const { GraphQLObjectType, GraphQLNonNull, GraphQLID, GraphQLString } = require('../scalars');
 const { createSquiggle, updateSquiggle } = require('./squiggle.resolver');
 
 const SquiggleType = require('./squiggle.type');
@@ -23,6 +23,6 @@ module.exports = new GraphQLObjectType({
         newContent: { type: GraphQLString },
       },
       resolve: updateSquiggle,
+    },
   },
-}
 });

server/schema/squiggle/squiggle.resolver.js

@@ -34,11 +34,7 @@ module.exports = {
     }
   },
 
-  updateSquiggle: async (
-    _parent,
-    { id, newContent },
-    { session, authToken, decodedToken, API: { Squiggle } }
-  ) => {
+  updateSquiggle: async (_parent, { id, newContent }, { session, authToken, decodedToken, API: { Squiggle } }) => {
     try {
       if (!UserPermission.exists(session, authToken, decodedToken, 'squiggle.write.all')) {
         throw APIError('FORBIDDEN', null, {
@@ -48,16 +44,16 @@ module.exports = {
       let _squiggle = await Squiggle.findByID(id);
 
       if (!_squiggle) {
-        throw APIError('NOT_FOUND', null, { reason: 'The squiggle to update does not exist.',});
+        throw APIError('NOT_FOUND', null, { reason: 'The squiggle to update does not exist.' });
       }
-      
+
       _squiggle = await Squiggle.updateContent(id, newContent);
-      return _squiggle; 
+      return _squiggle;
     } catch (error) {
       throw APIError(null, error);
     }
   },
-  
+
   getLatestSquiggle: async (_parent, _args, { API: { Squiggle } }, _) => {
     try {
       const _squiggle = await Squiggle.getLatest();