hipstagram/index.js

const jwtSecret   = 'AjnjLhjxM'

const express           = require('express');
const express_graphql   = require('express-graphql');

const { buildSchema, printSchema } = require('graphql');
const expand = require('mm-graphql/expand')
const fs     = require('fs')
const upload  = require('multer')({ dest: `${__dirname}/public/images` })


;(async () => {

    const {Savable, slice, getModels} = await require('./models.js')()
    const { jwtGQL, jwtCheck } = require('mm-graphql/jwt')

    const {anonSchema, anonResolvers} = require('./anon')({Savable, secret: jwtSecret})

    let schema = buildSchema(`
        type User {
             _id: String
             createdAt: String
             login: String
             nick : String
             avatar: Image
             likes: [Like]
             likesCount: Int
        }

        input UserInput {
             _id: String
             login: String
             nick : String
             avatar: ImageInput
        }

        type Like {
            _id: ID,
            post: Post,
            comment: Comment,
            direct: Direct,
            user: User,
        }

        input LikeInput {
            _id: ID,
            post: Post,
            comment: CommentInput,
            direct: DirectInput,
            user: UserInput,
        }

        type Post {
            _id: ID,
            createdAt: String
            text: String,
            images: [Image],
            comments: [Comment],
            directs: [Direct],
            collections: [Collection]
            likes: [Like]
            likesCount: Int
        }

        input PostInput {
            _id: ID,
            text: String,
            images: [ImageInput],
            comments: [CommentInput],
            directs: [DirectInput],
            collections: [CollectionInput]
        }

        type Image {
            _id: ID,
            text: String,
            url: String,
            originalFileName: String,
            userAvatar: User,
            posts: [Post],
            directs: [Direct]
        }

        input ImageInput {
            _id: ID,
            userAvatar: User,
            posts: [Post],
            directs: [Direct]
        }

        type Comment {
            _id: ID,
            createdAt: String,
            text: String,
            post: Post,
            answers: [Comment],
            answerTo: Comment
            likes: [Like]
            likesCount: Int
        }

        input CommentInput {
            _id: ID,
            text: String,
            post: PostInput,
            answers: [CommentInput],
            answerTo: CommentInput
        }

        type Direct {
            _id: ID,
            createdAt: String,
            text: String,
            post: Post,
            image: Image,
            likes: [Like]
            likesCount: Int
        }

        input DirectInput {
            _id: ID,
            text: String,
            post: PostInput,
            image: ImageInput,
            likes: [LikeInput]
        }

        type Collection {
            _id: ID,
            text: String,
            posts: [Post]
        }

        input CollectionInput {
            _id: ID,
            text: String,
            posts: [Post]
        }
    `);

    schema = expand(schema)
    console.log(printSchema(schema))

    const app = express();
    app.use(express.static('public'));
    app.use('/graphql', express_graphql(jwtGQL({anonSchema, anonResolvers, schema, createContext: getModels, graphiql: true, secret: jwtSecret})))


    const uploadPath = `${__dirname}/public/images/`;
    app.post('/upload', upload.single('photo'), async (req, res, next) => {
        let decoded;
        if (decoded = jwtCheck(req, jwtSecret)){
            console.log('SOME UPLOAD', decoded, req.file)
            //let fileName = Math.random().toString('36')
            //let fileStream = fs.createWriteStream(uploadPath + fileName);

            let {models: {Image }} = await getModels(decoded.sub)

            let image  = new Image({})
            image.fileData = req.file
            image.url      = `images/${req.file.filename}`
            image.originalFileName = req.file.originalname
            await image.save()
            res.end(JSON.stringify({_id: image._id, url: image.url}))

            //req.pipe(fileStream)
            //req.on('end', () =>{
                //res.end(fileName)
            //})
        }
        else {
            res.status(503).send('permission denied')
        }
    })

    app.use(express.static('public'));


    app.listen(4000, () => console.log('Express GraphQL Server Now Running On localhost:4000/graphql'));
})()