Neighbour Problem Manager

    mares-mongoose-model

    0.3.9 • Public • Published

    mares-mongoose-model

    슬로그업에서 사용하는 node.js DDD패턴 구현 시 필요합니다. mongoose 모델 생성시 반드시 해당 모듈을 상속받아야 합니다.

    Installation

    npm install --save mares-mongoose-model

    Examples

    const MaresMongooseModel = require('mares-mongoose-model')
     
    // 다음과 같이 몽구스 모델을 상속받아 추가 함수를 구현해서 사용합니다.
    class TestModel extends MaresMongooseModel {  
        /**
         * 문자열로 몽구스 프로젝션에 필요한 필드를 정의합니다.
         * @override
         */
        static getAttributes() {  
            return 'id a b' 
        } 
        
        /**
         * 다음함수는 기본 몽구스의 함수를 오버라이딩 하는 경우입니다.
         * @override
         * @static
         */
        static findById() {
            //todo
        }
        
        static doSomething() {}  
    }  

    Action

    모든 개발 패턴을 통일하기 위하여 에러핸들링, parameter 핸들링, return data의 정규화 등을 내부 지정된 함수를 이용해서 조작해야 합니다.

    Mongoose error object handling

    몽구스에서 나는 모든 에러는 catch 후 해당 함수를 통해서 전파해야 합니다. 내부적으로 throw를 하기 때문에 명시적으로 throw를 적을 필요가 없습니다.

    class TestModel extends MaresMongooseModel {  
        static doSomething() {  
            try { 
                // call mongoose built-in method
            } catch (e) {
                this.throwRefineError(e)  
            }
        }
    }  

    404 error handling

    데이터가 없는 경우 404에러를 throw 해줍니다.

    class TestModel extends MaresMongooseModel {  
        static async doSomething() {  
            let data = await get()  
            if (data === null) {
                // 데이터가 없다면 바로 404 error를 throw한다.
                this.throwNotfoundError()
            } 
        }
    }  

    Parameter normalization

    infra / repository 에는 domain layer의 PO가 넘어오는 경우가 많기 때문에 반드시 일반객체로 정규화 한 후 사용해야 합니다.

    class TestModel extends MaresMongooseModel {  
        static async doSomething(domainObject) {
          
            // object 인경우
            let pureObject = this.cleanObject(domainObject)
            
            // array 인경우
            let pureArray = this.cleanArray(domainObject)
        }
    }  

    Return mongoose object

    mongoose object를 pure함수를 통해 po로 변형 후 return 해야 합니다.

    class TestModel extends MaresMongooseModel {  
        static async doSomething(domainObject) {  
            let data = await get()  
            return this.toPure(data)
        }
    }  

    Get projection query

    몽고디비의 프로젝션에 필요한 쿼리를 만들어 줍니다. 해당 함수는 내부적으로 getAttributes() 함수를 이용합니다.

    class TestModel extends MaresMongooseModel {
        static getAttributes() {
            return 'id test value app.a app.b app.c.a app.c.b'  
        }
        static async doSomething(domainObject) {  
            let data = await get()  
            let projection = this.getProjection('', 'prefix') //빈문자열을 이용하면 getAttributes 함수를 이용합니다.
            /**
             * prjection 객체는 다음과 같이 변환됩니다. 
             * {
             *   'prefix.id': 1,  
             *   'prefix.test': 1,  
             *   'prefix.value': 1,  
             *   'prefix.app.a': 1,  
             *   'prefix.app.b': 1,  
             *   'prefix.app.c.a': 1,  
             *   'prefix.app.c.b': 1
             * }
             */
            // todo
        }
    }  

    Build group query

    조인을 위한 쿼리를 생성하기 위한 함수를 제공합니다. 몽구스에서 조인을 하게 되면, 응답형태를 다시 객체로 만들어야 하는데 이를 자동으로 해주는 함수를 제공합니다. 아래는 order-orderItem-inventory 3개를 조인하는 예제코드 입니다. (왼쪽에서 부터 오른쪽으로 1:N 관계입니다.)

    class TestModel extends MaresMongooseModel {
        static async findFullOrder(appKey, order, orderItem = null) {
            // 최초 모든 프로젝션 값을 얻어옵니다.
            const orderItemAttr = mongoose.models.OrderItem.getAttributes()  
            const inventoryAttr = mongoose.models.Inventory.getAttributes()  
            const orderAttr = this.getAttributes()  
            
            // 쿼리작성을 시작합니다.
            let aggregateQuery = []
            
            // 먼저 appKey라는 필드를 검색합니다.
            aggregateQuery.push({  
                $match: {  
                    appKey  
                }  
            })
            
            // join을 합니다. $lookup 키워드를 이용합니다.
            // from은 N관계의 join할 컬렉션명입니다.
            // foreignField는 OrderItem에서 들고있는 외래키의 이름입니다.
            // localField는 order의 고유키입니다. (primary Key)
            // as는 해당 N관계의 값들이 포함될 필드명입니다. 아래 배열로 들어갑니다.
            aggregateQuery.push({  
                $lookup: {  
                    from: 'OrderItem',  
                    foreignField: 'order',  
                    localField: '_id',  
                    as: 'orderItems'  
                }  
            })
            
            // unwind를 하게 되면 orderItems안의 배열의 값들이 모두 펼쳐지면서 각각의 로우로 변경됩니다. orderItems를 들고 있는 객체의 모든 필드는 중복됩니다.
            aggregateQuery.push({$unwind: '$orderItems'})  
            
            aggregateQuery.push({  
                $match: {  
                    'orderItems.canceledAt': {$exists: false},  
                }  
            })  
            
            aggregateQuery.push({  
                $lookup: {  
                    from: 'Inventory',  
                    foreignField: 'orderItem',  
                    localField: 'orderItems._id',  
                    as: 'orderItems.inventories'  
                }
            })  
            aggregateQuery.push({$unwind: '$orderItems.inventories'})  
            aggregateQuery.push({  
                $match: {  
                    'orderItems.inventories.canceledAt': {$exists: false}  
                }  
            })  
            aggregateQuery.push({$limit: 1})
     
            // buildGroupQuery를 이용하여 실제로 그룹핑을 위한 쿼리를 만듭니다.
            // 앞에 문자열은 root collection명을 제외한 depth 구조입니다. 닷(점)으로 구분합니다. 또한 최종 lookup 구문의 as와 동일합니다.
            // 두번째 인자는 프로젝션 스트링 값입니다. 만일 위에 depth의 닷이 1개라면 총 3개의 프로젝션 값이 필요합니다.
            aggregateQuery = [...aggregateQuery, ...this.buildGroupQuery('orderItems.inventories', [orderAttr, orderItemAttr, inventoryAttr])]  
            try {  
                let orders = await this.aggregate(aggregateQuery)  
                if (!orders || orders.length === 0) this.throwNotfoundError()  
                return this.toPure(orders[0])  
            } catch (e) {  
                this.throwRefineError(e)  
            }  
        }
    }

    Remove null fields

    클라이언트에서 생성시(POST) 생성할 필드가 없을때 null을 보낼 수 있는데 이때 null 값을 모두 제거하여 생성시 $set의 필드에 null이 들어가는 것을 방지하기 위한 함수 입니다.

    class TestModel extends MaresMongooseModel {
        static async doSomething(domainObject) {  
            // obj의 null값을 제거해줍니다.
            // 만일 모든 sub object 혹은 sub array의 값이 모두 null이면 해당 객체나 배열은 단순 null로 바뀝니다.
            // 두번째 인자는 undefined or {}, []값을 없애줄지 여부 입니다.
            this.removeNullFields(obj, true)
        }
    }  

    Generate unset query

    값을 수정할 때 null을 보내면 해당 필드를 unset으로 제거하여 주고 싶을 때 사용합니다.

    class TestModel extends MaresMongooseModel {
        static async doSomething(domainObject) {  
            // null 값을 찾아서 unset 쿼리를 만들어 줍니다.
            // 두번째 인자는 unset 쿼리 객체를 만들 때 배열의 원소까지 체크할지 여부입니다. 만일 true 라면 'array.0.a' 와같은 형태로 만들어 주며, false일 경우에는 해당 array 키값을 무시합니다.
            this.toUnsetFromNullFields(obj, true)
        }
    }  

    Install

    npm i mares-mongoose-model

    DownloadsWeekly Downloads

    1

    Version

    0.3.9

    License

    ISC

    Unpacked Size

    26 kB

    Total Files

    4

    Last publish

    Collaborators

    • hwaranglee
    • sngsng
    • piorio0919
    • kspark